v1

type AgentColorResponse struct {

	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// New color of agent
	Color *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

type AgentLastResponse struct {

	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Updated last checkout timestamp
	Last *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type AgentNoteResponse struct {

	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// New note of agent
	Note *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"`
	// contains filtered or unexported fields
}

type AgentResponse struct {

	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] Listener's ID
	Lid int64 `protobuf:"varint,2,opt,name=lid,proto3" json:"lid,omitempty"`
	// External IP address of agent
	ExtIp *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=ext_ip,json=extIp,proto3" json:"ext_ip,omitempty"`
	// Internal IP address of agent
	IntIp *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=int_ip,json=intIp,proto3" json:"int_ip,omitempty"`
	// [MANDATORY] Operating system type
	Os uint32 `protobuf:"varint,5,opt,name=os,proto3" json:"os,omitempty"`
	// Operating system meta information (for example kernel version)
	OsMeta *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=os_meta,json=osMeta,proto3" json:"os_meta,omitempty"`
	// Hostname of compromised target
	Hostname *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// Username under which agent's process is working
	Username *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=username,proto3" json:"username,omitempty"`
	// Domain name of compromised target
	Domain *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=domain,proto3" json:"domain,omitempty"`
	// Is process privilged (root, high intergity, etc)
	Privileged *wrapperspb.BoolValue `protobuf:"bytes,10,opt,name=privileged,proto3" json:"privileged,omitempty"`
	// Name of agent's process
	ProcName *wrapperspb.StringValue `protobuf:"bytes,11,opt,name=proc_name,json=procName,proto3" json:"proc_name,omitempty"`
	// Agent's process ID
	Pid *wrapperspb.UInt64Value `protobuf:"bytes,12,opt,name=pid,proto3" json:"pid,omitempty"`
	// [MANDATORY] Process architecture
	Arch uint32 `protobuf:"varint,13,opt,name=arch,proto3" json:"arch,omitempty"`
	// [MANDATORY] Sleep value of agent's process (in seconds)
	Sleep uint32 `protobuf:"varint,14,opt,name=sleep,proto3" json:"sleep,omitempty"`
	// [MANDATORY] Jitter value of agent's process (in range 1-99)
	Jitter uint32 `protobuf:"varint,15,opt,name=jitter,proto3" json:"jitter,omitempty"`
	// [MANDATORY] Binary mask represented supported agent's capabilities
	Caps uint32 `protobuf:"varint,16,opt,name=caps,proto3" json:"caps,omitempty"`
	// Color of agent
	Color *wrapperspb.UInt32Value `protobuf:"bytes,17,opt,name=color,proto3" json:"color,omitempty"`
	// Note of agent
	Note *wrapperspb.StringValue `protobuf:"bytes,18,opt,name=note,proto3" json:"note,omitempty"`
	// First checkout timestamp
	First *timestamppb.Timestamp `protobuf:"bytes,19,opt,name=first,proto3" json:"first,omitempty"`
	// Last checkout timestamp
	Last *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type AgentSleepResponse struct {

	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] Updated sleep value of agent
	Sleep uint32 `protobuf:"varint,2,opt,name=sleep,proto3" json:"sleep,omitempty"`
	// [MANDATORY] Updated jitter value of agent
	Jitter uint32 `protobuf:"varint,3,opt,name=jitter,proto3" json:"jitter,omitempty"`
	// contains filtered or unexported fields
}

type AgentsResponse struct {

	// List of agents
	Agents []*AgentResponse `protobuf:"bytes,1,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

type CancelTasksRequest struct {

	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type CancelTasksResponse struct {
	// contains filtered or unexported fields
}

type ChatMessagesResponse struct {

	// List of messages in chat
	Messages []*ChatResponse `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

type ChatResponse struct {

	// [MANDATORY] Timestamp of message creation
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Author of message
	From *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	// [MANDATORY] Message body
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// [MANDATORY] Is message created by server
	IsServer bool `protobuf:"varint,4,opt,name=is_server,json=isServer,proto3" json:"is_server,omitempty"`
	// contains filtered or unexported fields
}

type CommandResponse struct {

	// [MANDATORY] Command ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] Agent's ID
	Aid uint32 `protobuf:"varint,2,opt,name=aid,proto3" json:"aid,omitempty"`
	// [MANDATORY] String with command
	Cmd string `protobuf:"bytes,3,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// [MANDATORY] Author of comman
	Author string `protobuf:"bytes,4,opt,name=author,proto3" json:"author,omitempty"`
	// [MANDATORY] Is comman visible for another operators
	Visible bool `protobuf:"varint,5,opt,name=visible,proto3" json:"visible,omitempty"`
	// [MANDATORY] Timestamp of command creation
	Created *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

type CreateCommandRequest struct {

	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] String with command
	Cmd string `protobuf:"bytes,2,opt,name=cmd,proto3" json:"cmd,omitempty"`
	// [MANDATORY] Is command visible for other operators
	Visible bool `protobuf:"varint,3,opt,name=visible,proto3" json:"visible,omitempty"`
	// contains filtered or unexported fields
}

type CreateMessageRequest struct {

	// [MANDATORY] Message type
	Type uint32 `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	// [MANDATORY] Message body
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type CreateTaskRequest struct {

	// [MANDATORY] Capability value
	Cap uint32 `protobuf:"varint,1,opt,name=cap,proto3" json:"cap,omitempty"`
	// Types that are valid to be assigned to Args:
	//
	//	*CreateTaskRequest_Sleep
	//	*CreateTaskRequest_Ls
	//	*CreateTaskRequest_Pwd
	//	*CreateTaskRequest_Cd
	//	*CreateTaskRequest_Whoami
	//	*CreateTaskRequest_Ps
	//	*CreateTaskRequest_Cat
	//	*CreateTaskRequest_Exec
	//	*CreateTaskRequest_Cp
	//	*CreateTaskRequest_Jobs
	//	*CreateTaskRequest_Jobkill
	//	*CreateTaskRequest_Kill
	//	*CreateTaskRequest_Mv
	//	*CreateTaskRequest_Mkdir
	//	*CreateTaskRequest_Rm
	//	*CreateTaskRequest_ExecAssembly
	//	*CreateTaskRequest_ShellcodeInjection
	//	*CreateTaskRequest_Download
	//	*CreateTaskRequest_Upload
	//	*CreateTaskRequest_Pause
	//	*CreateTaskRequest_Destroy
	//	*CreateTaskRequest_ExecDetach
	//	*CreateTaskRequest_Shell
	//	*CreateTaskRequest_Ppid
	//	*CreateTaskRequest_Exit
	Args isCreateTaskRequest_Args `protobuf_oneof:"args"`
	// contains filtered or unexported fields
}

type CreateTaskRequest_Cat struct {
	Cat *v1.CapCat `protobuf:"bytes,8,opt,name=cat,proto3,oneof"`
}

type CreateTaskRequest_Cd struct {
	Cd *v1.CapCd `protobuf:"bytes,5,opt,name=cd,proto3,oneof"`
}

type CreateTaskRequest_Cp struct {
	Cp *v1.CapCp `protobuf:"bytes,10,opt,name=cp,proto3,oneof"`
}

type CreateTaskRequest_Destroy struct {
	Destroy *v1.CapDestroy `protobuf:"bytes,22,opt,name=destroy,proto3,oneof"`
}

type CreateTaskRequest_Download struct {
	Download *v1.CapDownload `protobuf:"bytes,19,opt,name=download,proto3,oneof"`
}

type CreateTaskRequest_Exec struct {
	Exec *v1.CapExec `protobuf:"bytes,9,opt,name=exec,proto3,oneof"`
}

type CreateTaskRequest_ExecAssembly struct {
	ExecAssembly *v1.CapExecAssembly `protobuf:"bytes,17,opt,name=exec_assembly,json=execAssembly,proto3,oneof"`
}

type CreateTaskRequest_ExecDetach struct {
	ExecDetach *v1.CapExecDetach `protobuf:"bytes,23,opt,name=exec_detach,json=execDetach,proto3,oneof"`
}

type CreateTaskRequest_Exit struct {
	Exit *v1.CapExit `protobuf:"bytes,26,opt,name=exit,proto3,oneof"`
}

type CreateTaskRequest_Jobkill struct {
	Jobkill *v1.CapJobkill `protobuf:"bytes,12,opt,name=jobkill,proto3,oneof"`
}

type CreateTaskRequest_Jobs struct {
	Jobs *v1.CapJobs `protobuf:"bytes,11,opt,name=jobs,proto3,oneof"`
}

type CreateTaskRequest_Kill struct {
	Kill *v1.CapKill `protobuf:"bytes,13,opt,name=kill,proto3,oneof"`
}

type CreateTaskRequest_Ls struct {
	Ls *v1.CapLs `protobuf:"bytes,3,opt,name=ls,proto3,oneof"`
}

type CreateTaskRequest_Mkdir struct {
	Mkdir *v1.CapMkdir `protobuf:"bytes,15,opt,name=mkdir,proto3,oneof"`
}

type CreateTaskRequest_Mv struct {
	Mv *v1.CapMv `protobuf:"bytes,14,opt,name=mv,proto3,oneof"`
}

type CreateTaskRequest_Pause struct {
	Pause *v1.CapPause `protobuf:"bytes,21,opt,name=pause,proto3,oneof"`
}

type CreateTaskRequest_Ppid struct {
	Ppid *v1.CapPpid `protobuf:"bytes,25,opt,name=ppid,proto3,oneof"`
}

type CreateTaskRequest_Ps struct {
	Ps *v1.CapPs `protobuf:"bytes,7,opt,name=ps,proto3,oneof"`
}

type CreateTaskRequest_Pwd struct {
	Pwd *v1.CapPwd `protobuf:"bytes,4,opt,name=pwd,proto3,oneof"`
}

type CreateTaskRequest_Rm struct {
	Rm *v1.CapRm `protobuf:"bytes,16,opt,name=rm,proto3,oneof"`
}

type CreateTaskRequest_Shell struct {
	Shell *v1.CapShell `protobuf:"bytes,24,opt,name=shell,proto3,oneof"`
}

type CreateTaskRequest_ShellcodeInjection struct {
	ShellcodeInjection *v1.CapShellcodeInjection `protobuf:"bytes,18,opt,name=shellcode_injection,json=shellcodeInjection,proto3,oneof"`
}

type CreateTaskRequest_Sleep struct {
	Sleep *v1.CapSleep `protobuf:"bytes,2,opt,name=sleep,proto3,oneof"`
}

type CreateTaskRequest_Upload struct {
	Upload *v1.CapUpload `protobuf:"bytes,20,opt,name=upload,proto3,oneof"`
}

type CreateTaskRequest_Whoami struct {
	Whoami *v1.CapWhoami `protobuf:"bytes,6,opt,name=whoami,proto3,oneof"`
}

type CredentialColorResponse struct {

	// [MANDATORY] Credential's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// New credential's color
	Color *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

type CredentialNoteResponse struct {

	// [MANDATORY] Credential's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// New credential's note
	Note *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"`
	// contains filtered or unexported fields
}

type CredentialResponse struct {

	// [MANDATORY] Credential's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Username
	Username *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Password
	Password *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// Realm
	Realm *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=realm,proto3" json:"realm,omitempty"`
	// Host
	Host *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	// Timestamp of credential's creation
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Note on credential
	Note *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=note,proto3" json:"note,omitempty"`
	// Note on color
	Color *wrapperspb.UInt32Value `protobuf:"bytes,8,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

type CredentialsResponse struct {

	// List of credentials
	Credentials []*CredentialResponse `protobuf:"bytes,1,rep,name=credentials,proto3" json:"credentials,omitempty"`
	// contains filtered or unexported fields
}

type GetTaskOutputRequest struct {

	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// [MANDATORY] Task ID
	Id int64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type GetTaskOutputResponse struct {

	// Task's output blob
	Output *wrapperspb.BytesValue `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	// [MANDATORY] Length of output blob
	OutputLen uint64 `protobuf:"varint,6,opt,name=output_len,json=outputLen,proto3" json:"output_len,omitempty"`
	// contains filtered or unexported fields
}

type HandshakeResponse struct {

	// [MANDATORY] Operator's username
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// [MANDATORY] Current server's timestamp
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,3,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// contains filtered or unexported fields
}

type HelloRequest struct {

	// [MANDATORY] Operator's client version
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

type HelloResponse struct {

	// Types that are valid to be assigned to Response:
	//
	//	*HelloResponse_Handshake
	Response isHelloResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type HelloResponse_Handshake struct {
	Handshake *HandshakeResponse `protobuf:"bytes,1,opt,name=handshake,proto3,oneof"`
}

type ListenerColorResponse struct {

	// [MANDATORY] Listener's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// New color of listener
	Color *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

type ListenerInfoResponse struct {

	// [MANDATORY] Listener's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of listener. Can be string with maximum length of 256
	Name *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// IP address which used to serving agent's server
	Ip *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port which used to serving agent's server
	Port *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type ListenerLastResponse struct {

	// [MANDATORY] Listener's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Last checkout timestamp
	Last *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type ListenerNoteResponse struct {

	// [MANDATORY] Listener's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// New note on listener
	Note *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"`
	// contains filtered or unexported fields
}

type ListenerResponse struct {

	// [MANDATORY] Listener's ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Name of listener. Can be string with maximum length of 256
	Name *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// IP address which used to serving agent's server
	Ip *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	// Port which used to serving agent's server
	Port *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=port,proto3" json:"port,omitempty"`
	// Color of listener
	Color *wrapperspb.UInt32Value `protobuf:"bytes,5,opt,name=color,proto3" json:"color,omitempty"`
	// Note of listener
	Note *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=note,proto3" json:"note,omitempty"`
	// Last checkout timestamp
	Last *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type ListenersResponse struct {
	Listeners []*ListenerResponse `protobuf:"bytes,1,rep,name=listeners,proto3" json:"listeners,omitempty"`
	// contains filtered or unexported fields
}

type MessageResponse struct {

	// [MANDATORY] Command ID
	Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] Message ID
	Mid int64 `protobuf:"varint,2,opt,name=mid,proto3" json:"mid,omitempty"`
	// [MANDATORY] Agent's ID
	Aid uint32 `protobuf:"varint,3,opt,name=aid,proto3" json:"aid,omitempty"`
	// [MANDATORY] Type of message
	Type uint32 `protobuf:"varint,4,opt,name=type,proto3" json:"type,omitempty"`
	// [MANDATORY] Body of message
	Message string `protobuf:"bytes,5,opt,name=message,proto3" json:"message,omitempty"`
	// [MANDATORY] Timestamp of message creation
	Created *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created,proto3" json:"created,omitempty"`
	// contains filtered or unexported fields
}

type NewChatMessageRequest struct {

	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// [MANDATORY] Message in chat
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type NewChatMessageResponse struct {
	// contains filtered or unexported fields
}

type NewCommandRequest struct {

	// Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// Types that are valid to be assigned to Type:
	//
	//	*NewCommandRequest_Command
	//	*NewCommandRequest_Message
	//	*NewCommandRequest_Task
	Type isNewCommandRequest_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

type NewCommandRequest_Command struct {
	Command *CreateCommandRequest `protobuf:"bytes,2,opt,name=command,proto3,oneof"`
}

type NewCommandRequest_Message struct {
	Message *CreateMessageRequest `protobuf:"bytes,3,opt,name=message,proto3,oneof"`
}

type NewCommandRequest_Task struct {
	Task *CreateTaskRequest `protobuf:"bytes,4,opt,name=task,proto3,oneof"`
}

type NewCommandResponse struct {
	// contains filtered or unexported fields
}

type NewCredentialRequest struct {

	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// Username
	Username *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=username,proto3" json:"username,omitempty"`
	// Password
	Password *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	// Realm
	Realm *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=realm,proto3" json:"realm,omitempty"`
	// Host
	Host *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=host,proto3" json:"host,omitempty"`
	// contains filtered or unexported fields
}

type NewCredentialResponse struct {
	// contains filtered or unexported fields
}

type OperatorColorResponse struct {

	// [MANDATORY] Operator's username
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// New color of operator
	Color *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

type OperatorLastResponse struct {

	// [MANDATORY] Operator's username
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// Last checkout timestamp
	Last *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type OperatorResponse struct {

	// [MANDATORY] Operator's username
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	// Color of operator
	Color *wrapperspb.UInt32Value `protobuf:"bytes,2,opt,name=color,proto3" json:"color,omitempty"`
	// Last checkout timestamp
	Last *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last,proto3" json:"last,omitempty"`
	// contains filtered or unexported fields
}

type OperatorServiceClient interface {
	// Initial handshake to provide operator's cookie. If this stream
	// will be interrupted by operator - all subscriptions on another
	// streams will be interrupted. If operator has already subscribed on
	// this stream - new connection with same username will be dropped.
	Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[HelloResponse], error)
	// Subscription for gathering listeners information with runtime updates
	SubscribeListeners(ctx context.Context, in *SubscribeListenersRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeListenersResponse], error)
	// Subscription for gathering agents information with runtime updates
	SubscribeAgents(ctx context.Context, in *SubscribeAgentsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeAgentsResponse], error)
	// Subscription for gathering operators information with runtime updates
	SubscribeOperators(ctx context.Context, in *SubscribeOperatorsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeOperatorsResponse], error)
	// Subscription for gathering chat's messages information with runtime updates
	SubscribeChat(ctx context.Context, in *SubscribeChatRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeChatResponse], error)
	// Subscription for gathering credentials information with runtime updates
	SubscribeCredentials(ctx context.Context, in *SubscribeCredentialsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[SubscribeCredentialsResponse], error)
	// Subscription for gathering agent's supplying tasks information with runtime updates
	SubscribeTasks(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[SubscribeTasksRequest, SubscribeTasksResponse], error)
	// Update color on listener
	SetListenerColor(ctx context.Context, in *SetListenerColorRequest, opts ...grpc.CallOption) (*SetListenerColorResponse, error)
	// Update color on list of listeners
	SetListenersColor(ctx context.Context, in *SetListenersColorRequest, opts ...grpc.CallOption) (*SetListenersColorResponse, error)
	// Update note on listener
	SetListenerNote(ctx context.Context, in *SetListenerNoteRequest, opts ...grpc.CallOption) (*SetListenerNoteResponse, error)
	// Update note on list of listeners
	SetListenersNote(ctx context.Context, in *SetListenersNoteRequest, opts ...grpc.CallOption) (*SetListenersNoteResponse, error)
	// Update color on agent
	SetAgentColor(ctx context.Context, in *SetAgentColorRequest, opts ...grpc.CallOption) (*SetAgentColorResponse, error)
	// Update color on list of agents
	SetAgentsColor(ctx context.Context, in *SetAgentsColorRequest, opts ...grpc.CallOption) (*SetAgentsColorResponse, error)
	// Update note on agent
	SetAgentNote(ctx context.Context, in *SetAgentNoteRequest, opts ...grpc.CallOption) (*SetAgentNoteResponse, error)
	// Update note on list of agents
	SetAgentsNote(ctx context.Context, in *SetAgentsNoteRequest, opts ...grpc.CallOption) (*SetAgentsNoteResponse, error)
	// Update color on operator
	SetOperatorColor(ctx context.Context, in *SetOperatorColorRequest, opts ...grpc.CallOption) (*SetOperatorColorResponse, error)
	// Update color on list of operators
	SetOperatorsColor(ctx context.Context, in *SetOperatorsColorRequest, opts ...grpc.CallOption) (*SetOperatorsColorResponse, error)
	// Create new message in chat
	NewChatMessage(ctx context.Context, in *NewChatMessageRequest, opts ...grpc.CallOption) (*NewChatMessageResponse, error)
	// Create new credential
	NewCredential(ctx context.Context, in *NewCredentialRequest, opts ...grpc.CallOption) (*NewCredentialResponse, error)
	// Update color on credential
	SetCredentialColor(ctx context.Context, in *SetCredentialColorRequest, opts ...grpc.CallOption) (*SetCredentialColorResponse, error)
	// Update color on list of credentials
	SetCredentialsColor(ctx context.Context, in *SetCredentialsColorRequest, opts ...grpc.CallOption) (*SetCredentialsColorResponse, error)
	// Update note on credential
	SetCredentialNote(ctx context.Context, in *SetCredentialNoteRequest, opts ...grpc.CallOption) (*SetCredentialNoteResponse, error)
	// Update note on list of credentials
	SetCredentialsNote(ctx context.Context, in *SetCredentialsNoteRequest, opts ...grpc.CallOption) (*SetCredentialsNoteResponse, error)
	// Create new command for merging tasks and messages in
	NewCommand(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[NewCommandRequest, NewCommandResponse], error)
	// Cancel all tasks in queue created by operator and located in status "NEW"
	CancelTasks(ctx context.Context, in *CancelTasksRequest, opts ...grpc.CallOption) (*CancelTasksResponse, error)
	// Get direct task's output. Used to get task's big output
	GetTaskOutput(ctx context.Context, in *GetTaskOutputRequest, opts ...grpc.CallOption) (*GetTaskOutputResponse, error)
}

type OperatorServiceServer interface {
	// Initial handshake to provide operator's cookie. If this stream
	// will be interrupted by operator - all subscriptions on another
	// streams will be interrupted. If operator has already subscribed on
	// this stream - new connection with same username will be dropped.
	Hello(*HelloRequest, grpc.ServerStreamingServer[HelloResponse]) error
	// Subscription for gathering listeners information with runtime updates
	SubscribeListeners(*SubscribeListenersRequest, grpc.ServerStreamingServer[SubscribeListenersResponse]) error
	// Subscription for gathering agents information with runtime updates
	SubscribeAgents(*SubscribeAgentsRequest, grpc.ServerStreamingServer[SubscribeAgentsResponse]) error
	// Subscription for gathering operators information with runtime updates
	SubscribeOperators(*SubscribeOperatorsRequest, grpc.ServerStreamingServer[SubscribeOperatorsResponse]) error
	// Subscription for gathering chat's messages information with runtime updates
	SubscribeChat(*SubscribeChatRequest, grpc.ServerStreamingServer[SubscribeChatResponse]) error
	// Subscription for gathering credentials information with runtime updates
	SubscribeCredentials(*SubscribeCredentialsRequest, grpc.ServerStreamingServer[SubscribeCredentialsResponse]) error
	// Subscription for gathering agent's supplying tasks information with runtime updates
	SubscribeTasks(grpc.BidiStreamingServer[SubscribeTasksRequest, SubscribeTasksResponse]) error
	// Update color on listener
	SetListenerColor(context.Context, *SetListenerColorRequest) (*SetListenerColorResponse, error)
	// Update color on list of listeners
	SetListenersColor(context.Context, *SetListenersColorRequest) (*SetListenersColorResponse, error)
	// Update note on listener
	SetListenerNote(context.Context, *SetListenerNoteRequest) (*SetListenerNoteResponse, error)
	// Update note on list of listeners
	SetListenersNote(context.Context, *SetListenersNoteRequest) (*SetListenersNoteResponse, error)
	// Update color on agent
	SetAgentColor(context.Context, *SetAgentColorRequest) (*SetAgentColorResponse, error)
	// Update color on list of agents
	SetAgentsColor(context.Context, *SetAgentsColorRequest) (*SetAgentsColorResponse, error)
	// Update note on agent
	SetAgentNote(context.Context, *SetAgentNoteRequest) (*SetAgentNoteResponse, error)
	// Update note on list of agents
	SetAgentsNote(context.Context, *SetAgentsNoteRequest) (*SetAgentsNoteResponse, error)
	// Update color on operator
	SetOperatorColor(context.Context, *SetOperatorColorRequest) (*SetOperatorColorResponse, error)
	// Update color on list of operators
	SetOperatorsColor(context.Context, *SetOperatorsColorRequest) (*SetOperatorsColorResponse, error)
	// Create new message in chat
	NewChatMessage(context.Context, *NewChatMessageRequest) (*NewChatMessageResponse, error)
	// Create new credential
	NewCredential(context.Context, *NewCredentialRequest) (*NewCredentialResponse, error)
	// Update color on credential
	SetCredentialColor(context.Context, *SetCredentialColorRequest) (*SetCredentialColorResponse, error)
	// Update color on list of credentials
	SetCredentialsColor(context.Context, *SetCredentialsColorRequest) (*SetCredentialsColorResponse, error)
	// Update note on credential
	SetCredentialNote(context.Context, *SetCredentialNoteRequest) (*SetCredentialNoteResponse, error)
	// Update note on list of credentials
	SetCredentialsNote(context.Context, *SetCredentialsNoteRequest) (*SetCredentialsNoteResponse, error)
	// Create new command for merging tasks and messages in
	NewCommand(grpc.ClientStreamingServer[NewCommandRequest, NewCommandResponse]) error
	// Cancel all tasks in queue created by operator and located in status "NEW"
	CancelTasks(context.Context, *CancelTasksRequest) (*CancelTasksResponse, error)
	// Get direct task's output. Used to get task's big output
	GetTaskOutput(context.Context, *GetTaskOutputRequest) (*GetTaskOutputResponse, error)
	// contains filtered or unexported methods
}

type OperatorService_HelloClient = grpc.ServerStreamingClient[HelloResponse]

type OperatorService_HelloServer = grpc.ServerStreamingServer[HelloResponse]

type OperatorService_NewCommandClient = grpc.ClientStreamingClient[NewCommandRequest, NewCommandResponse]

type OperatorService_NewCommandServer = grpc.ClientStreamingServer[NewCommandRequest, NewCommandResponse]

type OperatorService_SubscribeAgentsClient = grpc.ServerStreamingClient[SubscribeAgentsResponse]

type OperatorService_SubscribeAgentsServer = grpc.ServerStreamingServer[SubscribeAgentsResponse]

type OperatorService_SubscribeChatClient = grpc.ServerStreamingClient[SubscribeChatResponse]

type OperatorService_SubscribeChatServer = grpc.ServerStreamingServer[SubscribeChatResponse]

type OperatorService_SubscribeCredentialsClient = grpc.ServerStreamingClient[SubscribeCredentialsResponse]

type OperatorService_SubscribeCredentialsServer = grpc.ServerStreamingServer[SubscribeCredentialsResponse]

type OperatorService_SubscribeListenersClient = grpc.ServerStreamingClient[SubscribeListenersResponse]

type OperatorService_SubscribeListenersServer = grpc.ServerStreamingServer[SubscribeListenersResponse]

type OperatorService_SubscribeOperatorsClient = grpc.ServerStreamingClient[SubscribeOperatorsResponse]

type OperatorService_SubscribeOperatorsServer = grpc.ServerStreamingServer[SubscribeOperatorsResponse]

type OperatorService_SubscribeTasksClient = grpc.BidiStreamingClient[SubscribeTasksRequest, SubscribeTasksResponse]

type OperatorService_SubscribeTasksServer = grpc.BidiStreamingServer[SubscribeTasksRequest, SubscribeTasksResponse]

type OperatorsResponse struct {

	// List of operators
	Operators []*OperatorResponse `protobuf:"bytes,1,rep,name=operators,proto3" json:"operators,omitempty"`
	// contains filtered or unexported fields
}

type SessionCookie struct {

	// [MANDATORY] value of session cookie
	Value string `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type SetAgentColorRequest struct {

	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] Color to set on agent
	Color *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=color,proto3" json:"color,omitempty"`
	// contains filtered or unexported fields
}

type SetAgentColorResponse struct {
	// contains filtered or unexported fields
}

type SetAgentNoteRequest struct {

	// [MANDATORY] Operator's session cookie
	Cookie *SessionCookie `protobuf:"bytes,1,opt,name=cookie,proto3" json:"cookie,omitempty"`
	// [MANDATORY] Agent's ID
	Id uint32 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// [MANDATORY] Note to set on agent
	Note string `protobuf:"bytes,3,opt,name=note,proto3" json:"note,omitempty"`
	// contains filtered or unexported fields
}

type SetAgentNoteResponse struct {
	// contains filtered or unexported fields
}