From c5f84cdf8d16cc6eb05b95f1fe39d00b209c6e0e Mon Sep 17 00:00:00 2001 From: mintaka Date: Tue, 25 Aug 2026 18:29:45 -0400 Subject: [PATCH] feat(proto): org-management comms + spawn arms for agent gateway (RIG-2673) Add the three org-management comms-call arms (create_channel=7, update_members=8, create_channel_group=9 on CommsCallRequest.call; the matching results =8/=9/=10 on CommsCallResult.result) and the Manager- creation role=5/persona=6 fields on SpawnPeerRequest, reusing the existing comms.proto payload messages verbatim. Regenerated the internal Go (go/internal/gen) and agent TS (packages/compass-agent/src/gen) lanes. T1 of the frozen org-management-tools record (RIG-2673, #589); the single additive proto+regen commit both compass-server and compass-agent consume. Co-authored-by: Matt Wilkinson jj-hooks: autofixes for compass-server/rig-2724-org-mgmt-proto regen-resolve --- .../gen/compass/v1/agent_gateway.pb.go | 403 ++++++++++++------ .../src/gen/compass/v1/agent_gateway_pb.ts | 63 ++- proto/compass/v1/agent_gateway.proto | 20 +- 3 files changed, 349 insertions(+), 137 deletions(-) diff --git a/go/internal/gen/compass/v1/agent_gateway.pb.go b/go/internal/gen/compass/v1/agent_gateway.pb.go index a511809d..701a50ec 100644 --- a/go/internal/gen/compass/v1/agent_gateway.pb.go +++ b/go/internal/gen/compass/v1/agent_gateway.pb.go @@ -121,6 +121,9 @@ type CommsCallRequest struct { // *CommsCallRequest_Roster // *CommsCallRequest_SetStatus // *CommsCallRequest_Pin + // *CommsCallRequest_CreateChannel + // *CommsCallRequest_UpdateMembers + // *CommsCallRequest_CreateChannelGroup Call isCommsCallRequest_Call `protobuf_oneof:"call"` // The W3C `traceparent` of the delivered message that triggered this outbound // call, re-attached by the agent so the Server can LINK the reply's fresh @@ -226,6 +229,33 @@ func (x *CommsCallRequest) GetPin() *v1.UpdatePinnedBoardRequest { return nil } +func (x *CommsCallRequest) GetCreateChannel() *v1.CreateChannelRequest { + if x != nil { + if x, ok := x.Call.(*CommsCallRequest_CreateChannel); ok { + return x.CreateChannel + } + } + return nil +} + +func (x *CommsCallRequest) GetUpdateMembers() *v1.UpdateChannelMembersRequest { + if x != nil { + if x, ok := x.Call.(*CommsCallRequest_UpdateMembers); ok { + return x.UpdateMembers + } + } + return nil +} + +func (x *CommsCallRequest) GetCreateChannelGroup() *v1.CreateChannelGroupRequest { + if x != nil { + if x, ok := x.Call.(*CommsCallRequest_CreateChannelGroup); ok { + return x.CreateChannelGroup + } + } + return nil +} + func (x *CommsCallRequest) GetTriggerTraceparent() string { if x != nil { return x.TriggerTraceparent @@ -257,6 +287,18 @@ type CommsCallRequest_Pin struct { Pin *v1.UpdatePinnedBoardRequest `protobuf:"bytes,6,opt,name=pin,proto3,oneof"` } +type CommsCallRequest_CreateChannel struct { + CreateChannel *v1.CreateChannelRequest `protobuf:"bytes,7,opt,name=create_channel,json=createChannel,proto3,oneof"` +} + +type CommsCallRequest_UpdateMembers struct { + UpdateMembers *v1.UpdateChannelMembersRequest `protobuf:"bytes,8,opt,name=update_members,json=updateMembers,proto3,oneof"` +} + +type CommsCallRequest_CreateChannelGroup struct { + CreateChannelGroup *v1.CreateChannelGroupRequest `protobuf:"bytes,9,opt,name=create_channel_group,json=createChannelGroup,proto3,oneof"` +} + func (*CommsCallRequest_Post) isCommsCallRequest_Call() {} func (*CommsCallRequest_List) isCommsCallRequest_Call() {} @@ -267,10 +309,19 @@ func (*CommsCallRequest_SetStatus) isCommsCallRequest_Call() {} func (*CommsCallRequest_Pin) isCommsCallRequest_Call() {} +func (*CommsCallRequest_CreateChannel) isCommsCallRequest_Call() {} + +func (*CommsCallRequest_UpdateMembers) isCommsCallRequest_Call() {} + +func (*CommsCallRequest_CreateChannelGroup) isCommsCallRequest_Call() {} + // The result of one comms call, correlated by `call_id`. A successful call sets -// `post`/`list`; an in-band failure (a tool error — non-member channel, bad -// input) sets `error`, which is NOT a transport teardown. The same message is -// the `RelayCommsCallResponse.result` payload on the Runner->Server leg. +// the response arm matching the request's operation (`post`, `list`, `roster`, +// `set_status`, `pin`, `create_channel`, `update_members`, +// `create_channel_group`); an in-band failure (a tool error — non-member +// channel, bad input) sets `error`, which is NOT a transport teardown. The same +// message is the `RelayCommsCallResponse.result` payload on the Runner->Server +// leg. type CommsCallResult struct { state protoimpl.MessageState `protogen:"open.v1"` CallId string `protobuf:"bytes,1,opt,name=call_id,json=callId,proto3" json:"call_id,omitempty"` @@ -282,6 +333,9 @@ type CommsCallResult struct { // *CommsCallResult_Roster // *CommsCallResult_SetStatus // *CommsCallResult_Pin + // *CommsCallResult_CreateChannel + // *CommsCallResult_UpdateMembers + // *CommsCallResult_CreateChannelGroup Result isCommsCallResult_Result `protobuf_oneof:"result"` unknownFields protoimpl.UnknownFields sizeCache protoimpl.SizeCache @@ -385,6 +439,33 @@ func (x *CommsCallResult) GetPin() *v1.UpdatePinnedBoardResponse { return nil } +func (x *CommsCallResult) GetCreateChannel() *v1.CreateChannelResponse { + if x != nil { + if x, ok := x.Result.(*CommsCallResult_CreateChannel); ok { + return x.CreateChannel + } + } + return nil +} + +func (x *CommsCallResult) GetUpdateMembers() *v1.UpdateChannelMembersResponse { + if x != nil { + if x, ok := x.Result.(*CommsCallResult_UpdateMembers); ok { + return x.UpdateMembers + } + } + return nil +} + +func (x *CommsCallResult) GetCreateChannelGroup() *v1.CreateChannelGroupResponse { + if x != nil { + if x, ok := x.Result.(*CommsCallResult_CreateChannelGroup); ok { + return x.CreateChannelGroup + } + } + return nil +} + type isCommsCallResult_Result interface { isCommsCallResult_Result() } @@ -413,6 +494,18 @@ type CommsCallResult_Pin struct { Pin *v1.UpdatePinnedBoardResponse `protobuf:"bytes,7,opt,name=pin,proto3,oneof"` } +type CommsCallResult_CreateChannel struct { + CreateChannel *v1.CreateChannelResponse `protobuf:"bytes,8,opt,name=create_channel,json=createChannel,proto3,oneof"` +} + +type CommsCallResult_UpdateMembers struct { + UpdateMembers *v1.UpdateChannelMembersResponse `protobuf:"bytes,9,opt,name=update_members,json=updateMembers,proto3,oneof"` +} + +type CommsCallResult_CreateChannelGroup struct { + CreateChannelGroup *v1.CreateChannelGroupResponse `protobuf:"bytes,10,opt,name=create_channel_group,json=createChannelGroup,proto3,oneof"` +} + func (*CommsCallResult_Post) isCommsCallResult_Result() {} func (*CommsCallResult_List) isCommsCallResult_Result() {} @@ -425,6 +518,12 @@ func (*CommsCallResult_SetStatus) isCommsCallResult_Result() {} func (*CommsCallResult_Pin) isCommsCallResult_Result() {} +func (*CommsCallResult_CreateChannel) isCommsCallResult_Result() {} + +func (*CommsCallResult_UpdateMembers) isCommsCallResult_Result() {} + +func (*CommsCallResult_CreateChannelGroup) isCommsCallResult_Result() {} + // An in-band comms-call failure: a tool error the agent renders to the model, // never a stream teardown. `code` is a short stable token (e.g. "not_found"); // `message` is human-readable detail. @@ -667,8 +766,13 @@ type SpawnPeerRequest struct { Handle string `protobuf:"bytes,1,opt,name=handle,proto3" json:"handle,omitempty"` // the new agent's account handle (unique) DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"` ClientRequestId string `protobuf:"bytes,4,opt,name=client_request_id,json=clientRequestId,proto3" json:"client_request_id,omitempty"` // whole-chain idempotency key (handler-level join + Provision dedup) - unknownFields protoimpl.UnknownFields - sizeCache protoimpl.SizeCache + // Optional role/persona for the spawned agent, applied at creation only + // (org-management Manager creation, RIG-2673). Empty = the server's default + // role/persona for a peer. + Role string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"` + Persona string `protobuf:"bytes,6,opt,name=persona,proto3" json:"persona,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache } func (x *SpawnPeerRequest) Reset() { @@ -722,6 +826,20 @@ func (x *SpawnPeerRequest) GetClientRequestId() string { return "" } +func (x *SpawnPeerRequest) GetRole() string { + if x != nil { + return x.Role + } + return "" +} + +func (x *SpawnPeerRequest) GetPersona() string { + if x != nil { + return x.Persona + } + return "" +} + type SpawnPeerResponse struct { state protoimpl.MessageState `protogen:"open.v1"` AgentAccountId string `protobuf:"bytes,1,opt,name=agent_account_id,json=agentAccountId,proto3" json:"agent_account_id,omitempty"` @@ -2950,7 +3068,7 @@ var File_compass_v1_agent_gateway_proto protoreflect.FileDescriptor const file_compass_v1_agent_gateway_proto_rawDesc = "" + "\n" + "\x1ecompass/v1/agent_gateway.proto\x12\n" + - "compass.v1\x1a\x16compass/v1/comms.proto\x1a\x16compass/v1/agent.proto\x1a\x18compass/v1/compass.proto\x1a\x16compass/v1/forge.proto\"\x87\x03\n" + + "compass.v1\x1a\x16compass/v1/comms.proto\x1a\x16compass/v1/agent.proto\x1a\x18compass/v1/compass.proto\x1a\x16compass/v1/forge.proto\"\xff\x04\n" + "\x10CommsCallRequest\x12\x17\n" + "\acall_id\x18\x01 \x01(\tR\x06callId\x124\n" + "\x04post\x18\x02 \x01(\v2\x1e.compass.v1.PostMessageRequestH\x00R\x04post\x125\n" + @@ -2958,10 +3076,13 @@ const file_compass_v1_agent_gateway_proto_rawDesc = "" + "\x06roster\x18\x04 \x01(\v2\x1c.compass.v1.GetRosterRequestH\x00R\x06roster\x12B\n" + "\n" + "set_status\x18\x05 \x01(\v2!.compass.v1.SetAgentStatusRequestH\x00R\tsetStatus\x128\n" + - "\x03pin\x18\x06 \x01(\v2$.compass.v1.UpdatePinnedBoardRequestH\x00R\x03pin\x12/\n" + + "\x03pin\x18\x06 \x01(\v2$.compass.v1.UpdatePinnedBoardRequestH\x00R\x03pin\x12I\n" + + "\x0ecreate_channel\x18\a \x01(\v2 .compass.v1.CreateChannelRequestH\x00R\rcreateChannel\x12P\n" + + "\x0eupdate_members\x18\b \x01(\v2'.compass.v1.UpdateChannelMembersRequestH\x00R\rupdateMembers\x12Y\n" + + "\x14create_channel_group\x18\t \x01(\v2%.compass.v1.CreateChannelGroupRequestH\x00R\x12createChannelGroup\x12/\n" + "\x13trigger_traceparent\x18\n" + " \x01(\tR\x12triggerTraceparentB\x06\n" + - "\x04call\"\x90\x03\n" + + "\x04call\"\x8b\x05\n" + "\x0fCommsCallResult\x12\x17\n" + "\acall_id\x18\x01 \x01(\tR\x06callId\x125\n" + "\x04post\x18\x02 \x01(\v2\x1f.compass.v1.PostMessageResponseH\x00R\x04post\x126\n" + @@ -2970,7 +3091,11 @@ const file_compass_v1_agent_gateway_proto_rawDesc = "" + "\x06roster\x18\x05 \x01(\v2\x1d.compass.v1.GetRosterResponseH\x00R\x06roster\x12C\n" + "\n" + "set_status\x18\x06 \x01(\v2\".compass.v1.SetAgentStatusResponseH\x00R\tsetStatus\x129\n" + - "\x03pin\x18\a \x01(\v2%.compass.v1.UpdatePinnedBoardResponseH\x00R\x03pinB\b\n" + + "\x03pin\x18\a \x01(\v2%.compass.v1.UpdatePinnedBoardResponseH\x00R\x03pin\x12J\n" + + "\x0ecreate_channel\x18\b \x01(\v2!.compass.v1.CreateChannelResponseH\x00R\rcreateChannel\x12Q\n" + + "\x0eupdate_members\x18\t \x01(\v2(.compass.v1.UpdateChannelMembersResponseH\x00R\rupdateMembers\x12Z\n" + + "\x14create_channel_group\x18\n" + + " \x01(\v2&.compass.v1.CreateChannelGroupResponseH\x00R\x12createChannelGroupB\b\n" + "\x06result\">\n" + "\x0eCommsCallError\x12\x12\n" + "\x04code\x18\x01 \x01(\tR\x04code\x12\x18\n" + @@ -2982,11 +3107,13 @@ const file_compass_v1_agent_gateway_proto_rawDesc = "" + "\acall_id\x18\x01 \x01(\tR\x06callId\x124\n" + "\x05spawn\x18\x02 \x01(\v2\x1c.compass.v1.SpawnPeerRequestH\x00R\x05spawn\x12:\n" + "\adespawn\x18\x03 \x01(\v2\x1e.compass.v1.DespawnPeerRequestH\x00R\adespawnB\x06\n" + - "\x04call\"\x8f\x01\n" + + "\x04call\"\xbd\x01\n" + "\x10SpawnPeerRequest\x12\x16\n" + "\x06handle\x18\x01 \x01(\tR\x06handle\x12!\n" + "\fdisplay_name\x18\x02 \x01(\tR\vdisplayName\x12*\n" + - "\x11client_request_id\x18\x04 \x01(\tR\x0fclientRequestIdJ\x04\b\x03\x10\x04R\x0einitial_prompt\"\x83\x01\n" + + "\x11client_request_id\x18\x04 \x01(\tR\x0fclientRequestId\x12\x12\n" + + "\x04role\x18\x05 \x01(\tR\x04role\x12\x18\n" + + "\apersona\x18\x06 \x01(\tR\apersonaJ\x04\b\x03\x10\x04R\x0einitial_prompt\"\x83\x01\n" + "\x11SpawnPeerResponse\x12(\n" + "\x10agent_account_id\x18\x01 \x01(\tR\x0eagentAccountId\x12%\n" + "\x0econtainer_name\x18\x02 \x01(\tR\rcontainerName\x12\x1d\n" + @@ -3152,63 +3279,69 @@ func file_compass_v1_agent_gateway_proto_rawDescGZIP() []byte { var file_compass_v1_agent_gateway_proto_enumTypes = make([]protoimpl.EnumInfo, 1) var file_compass_v1_agent_gateway_proto_msgTypes = make([]protoimpl.MessageInfo, 39) var file_compass_v1_agent_gateway_proto_goTypes = []any{ - (ForgeSubscriptionScope)(0), // 0: compass.v1.ForgeSubscriptionScope - (*CommsCallRequest)(nil), // 1: compass.v1.CommsCallRequest - (*CommsCallResult)(nil), // 2: compass.v1.CommsCallResult - (*CommsCallError)(nil), // 3: compass.v1.CommsCallError - (*SetAgentStatusRequest)(nil), // 4: compass.v1.SetAgentStatusRequest - (*SetAgentStatusResponse)(nil), // 5: compass.v1.SetAgentStatusResponse - (*LifecycleCallRequest)(nil), // 6: compass.v1.LifecycleCallRequest - (*SpawnPeerRequest)(nil), // 7: compass.v1.SpawnPeerRequest - (*SpawnPeerResponse)(nil), // 8: compass.v1.SpawnPeerResponse - (*DespawnPeerRequest)(nil), // 9: compass.v1.DespawnPeerRequest - (*DespawnPeerResponse)(nil), // 10: compass.v1.DespawnPeerResponse - (*LifecycleCallResult)(nil), // 11: compass.v1.LifecycleCallResult - (*LifecycleCallError)(nil), // 12: compass.v1.LifecycleCallError - (*ForgeCallRequest)(nil), // 13: compass.v1.ForgeCallRequest - (*ForgeCallResult)(nil), // 14: compass.v1.ForgeCallResult - (*ForgeCallError)(nil), // 15: compass.v1.ForgeCallError - (*CreateIssueRequest)(nil), // 16: compass.v1.CreateIssueRequest - (*CommentOnIssueRequest)(nil), // 17: compass.v1.CommentOnIssueRequest - (*GetIssueRequest)(nil), // 18: compass.v1.GetIssueRequest - (*ListIssuesRequest)(nil), // 19: compass.v1.ListIssuesRequest - (*ListIssuesResponse)(nil), // 20: compass.v1.ListIssuesResponse - (*CreatePullRequestRequest)(nil), // 21: compass.v1.CreatePullRequestRequest - (*CommentOnPullRequestRequest)(nil), // 22: compass.v1.CommentOnPullRequestRequest - (*GetPullRequestRequest)(nil), // 23: compass.v1.GetPullRequestRequest - (*SubmitReviewRequest)(nil), // 24: compass.v1.SubmitReviewRequest - (*ReviewCommentInput)(nil), // 25: compass.v1.ReviewCommentInput - (*SubscribeForgeRequest)(nil), // 26: compass.v1.SubscribeForgeRequest - (*SubscribeForgeResponse)(nil), // 27: compass.v1.SubscribeForgeResponse - (*UnsubscribeForgeRequest)(nil), // 28: compass.v1.UnsubscribeForgeRequest - (*UnsubscribeForgeResponse)(nil), // 29: compass.v1.UnsubscribeForgeResponse - (*BoardCallRequest)(nil), // 30: compass.v1.BoardCallRequest - (*SetIssueStateRequest)(nil), // 31: compass.v1.SetIssueStateRequest - (*SetIssueStateResponse)(nil), // 32: compass.v1.SetIssueStateResponse - (*BoardCallResult)(nil), // 33: compass.v1.BoardCallResult - (*BoardCallError)(nil), // 34: compass.v1.BoardCallError - (*PublishFrameRequest)(nil), // 35: compass.v1.PublishFrameRequest - (*PublishFrameResponse)(nil), // 36: compass.v1.PublishFrameResponse - (*PostConversationFrameRequest)(nil), // 37: compass.v1.PostConversationFrameRequest - (*PostConversationFrameResponse)(nil), // 38: compass.v1.PostConversationFrameResponse - (*ControlSubscribeRequest)(nil), // 39: compass.v1.ControlSubscribeRequest - (*v1.PostMessageRequest)(nil), // 40: compass.v1.PostMessageRequest - (*v1.ListMessagesRequest)(nil), // 41: compass.v1.ListMessagesRequest - (*v1.GetRosterRequest)(nil), // 42: compass.v1.GetRosterRequest - (*v1.UpdatePinnedBoardRequest)(nil), // 43: compass.v1.UpdatePinnedBoardRequest - (*v1.PostMessageResponse)(nil), // 44: compass.v1.PostMessageResponse - (*v1.ListMessagesResponse)(nil), // 45: compass.v1.ListMessagesResponse - (*v1.GetRosterResponse)(nil), // 46: compass.v1.GetRosterResponse - (*v1.UpdatePinnedBoardResponse)(nil), // 47: compass.v1.UpdatePinnedBoardResponse - (*v1.ForgeRef)(nil), // 48: compass.v1.ForgeRef - (*v1.Issue)(nil), // 49: compass.v1.Issue - (*CommentRef)(nil), // 50: compass.v1.CommentRef - (*v1.PullRequest)(nil), // 51: compass.v1.PullRequest - (*ReviewRef)(nil), // 52: compass.v1.ReviewRef - (ForgeArtifactKind)(0), // 53: compass.v1.ForgeArtifactKind - (v1.IssueState)(0), // 54: compass.v1.IssueState - (*AgentFrame)(nil), // 55: compass.v1.AgentFrame - (*AgentControl)(nil), // 56: compass.v1.AgentControl + (ForgeSubscriptionScope)(0), // 0: compass.v1.ForgeSubscriptionScope + (*CommsCallRequest)(nil), // 1: compass.v1.CommsCallRequest + (*CommsCallResult)(nil), // 2: compass.v1.CommsCallResult + (*CommsCallError)(nil), // 3: compass.v1.CommsCallError + (*SetAgentStatusRequest)(nil), // 4: compass.v1.SetAgentStatusRequest + (*SetAgentStatusResponse)(nil), // 5: compass.v1.SetAgentStatusResponse + (*LifecycleCallRequest)(nil), // 6: compass.v1.LifecycleCallRequest + (*SpawnPeerRequest)(nil), // 7: compass.v1.SpawnPeerRequest + (*SpawnPeerResponse)(nil), // 8: compass.v1.SpawnPeerResponse + (*DespawnPeerRequest)(nil), // 9: compass.v1.DespawnPeerRequest + (*DespawnPeerResponse)(nil), // 10: compass.v1.DespawnPeerResponse + (*LifecycleCallResult)(nil), // 11: compass.v1.LifecycleCallResult + (*LifecycleCallError)(nil), // 12: compass.v1.LifecycleCallError + (*ForgeCallRequest)(nil), // 13: compass.v1.ForgeCallRequest + (*ForgeCallResult)(nil), // 14: compass.v1.ForgeCallResult + (*ForgeCallError)(nil), // 15: compass.v1.ForgeCallError + (*CreateIssueRequest)(nil), // 16: compass.v1.CreateIssueRequest + (*CommentOnIssueRequest)(nil), // 17: compass.v1.CommentOnIssueRequest + (*GetIssueRequest)(nil), // 18: compass.v1.GetIssueRequest + (*ListIssuesRequest)(nil), // 19: compass.v1.ListIssuesRequest + (*ListIssuesResponse)(nil), // 20: compass.v1.ListIssuesResponse + (*CreatePullRequestRequest)(nil), // 21: compass.v1.CreatePullRequestRequest + (*CommentOnPullRequestRequest)(nil), // 22: compass.v1.CommentOnPullRequestRequest + (*GetPullRequestRequest)(nil), // 23: compass.v1.GetPullRequestRequest + (*SubmitReviewRequest)(nil), // 24: compass.v1.SubmitReviewRequest + (*ReviewCommentInput)(nil), // 25: compass.v1.ReviewCommentInput + (*SubscribeForgeRequest)(nil), // 26: compass.v1.SubscribeForgeRequest + (*SubscribeForgeResponse)(nil), // 27: compass.v1.SubscribeForgeResponse + (*UnsubscribeForgeRequest)(nil), // 28: compass.v1.UnsubscribeForgeRequest + (*UnsubscribeForgeResponse)(nil), // 29: compass.v1.UnsubscribeForgeResponse + (*BoardCallRequest)(nil), // 30: compass.v1.BoardCallRequest + (*SetIssueStateRequest)(nil), // 31: compass.v1.SetIssueStateRequest + (*SetIssueStateResponse)(nil), // 32: compass.v1.SetIssueStateResponse + (*BoardCallResult)(nil), // 33: compass.v1.BoardCallResult + (*BoardCallError)(nil), // 34: compass.v1.BoardCallError + (*PublishFrameRequest)(nil), // 35: compass.v1.PublishFrameRequest + (*PublishFrameResponse)(nil), // 36: compass.v1.PublishFrameResponse + (*PostConversationFrameRequest)(nil), // 37: compass.v1.PostConversationFrameRequest + (*PostConversationFrameResponse)(nil), // 38: compass.v1.PostConversationFrameResponse + (*ControlSubscribeRequest)(nil), // 39: compass.v1.ControlSubscribeRequest + (*v1.PostMessageRequest)(nil), // 40: compass.v1.PostMessageRequest + (*v1.ListMessagesRequest)(nil), // 41: compass.v1.ListMessagesRequest + (*v1.GetRosterRequest)(nil), // 42: compass.v1.GetRosterRequest + (*v1.UpdatePinnedBoardRequest)(nil), // 43: compass.v1.UpdatePinnedBoardRequest + (*v1.CreateChannelRequest)(nil), // 44: compass.v1.CreateChannelRequest + (*v1.UpdateChannelMembersRequest)(nil), // 45: compass.v1.UpdateChannelMembersRequest + (*v1.CreateChannelGroupRequest)(nil), // 46: compass.v1.CreateChannelGroupRequest + (*v1.PostMessageResponse)(nil), // 47: compass.v1.PostMessageResponse + (*v1.ListMessagesResponse)(nil), // 48: compass.v1.ListMessagesResponse + (*v1.GetRosterResponse)(nil), // 49: compass.v1.GetRosterResponse + (*v1.UpdatePinnedBoardResponse)(nil), // 50: compass.v1.UpdatePinnedBoardResponse + (*v1.CreateChannelResponse)(nil), // 51: compass.v1.CreateChannelResponse + (*v1.UpdateChannelMembersResponse)(nil), // 52: compass.v1.UpdateChannelMembersResponse + (*v1.CreateChannelGroupResponse)(nil), // 53: compass.v1.CreateChannelGroupResponse + (*v1.ForgeRef)(nil), // 54: compass.v1.ForgeRef + (*v1.Issue)(nil), // 55: compass.v1.Issue + (*CommentRef)(nil), // 56: compass.v1.CommentRef + (*v1.PullRequest)(nil), // 57: compass.v1.PullRequest + (*ReviewRef)(nil), // 58: compass.v1.ReviewRef + (ForgeArtifactKind)(0), // 59: compass.v1.ForgeArtifactKind + (v1.IssueState)(0), // 60: compass.v1.IssueState + (*AgentFrame)(nil), // 61: compass.v1.AgentFrame + (*AgentControl)(nil), // 62: compass.v1.AgentControl } var file_compass_v1_agent_gateway_proto_depIdxs = []int32{ 40, // 0: compass.v1.CommsCallRequest.post:type_name -> compass.v1.PostMessageRequest @@ -3216,67 +3349,73 @@ var file_compass_v1_agent_gateway_proto_depIdxs = []int32{ 42, // 2: compass.v1.CommsCallRequest.roster:type_name -> compass.v1.GetRosterRequest 4, // 3: compass.v1.CommsCallRequest.set_status:type_name -> compass.v1.SetAgentStatusRequest 43, // 4: compass.v1.CommsCallRequest.pin:type_name -> compass.v1.UpdatePinnedBoardRequest - 44, // 5: compass.v1.CommsCallResult.post:type_name -> compass.v1.PostMessageResponse - 45, // 6: compass.v1.CommsCallResult.list:type_name -> compass.v1.ListMessagesResponse - 3, // 7: compass.v1.CommsCallResult.error:type_name -> compass.v1.CommsCallError - 46, // 8: compass.v1.CommsCallResult.roster:type_name -> compass.v1.GetRosterResponse - 5, // 9: compass.v1.CommsCallResult.set_status:type_name -> compass.v1.SetAgentStatusResponse - 47, // 10: compass.v1.CommsCallResult.pin:type_name -> compass.v1.UpdatePinnedBoardResponse - 7, // 11: compass.v1.LifecycleCallRequest.spawn:type_name -> compass.v1.SpawnPeerRequest - 9, // 12: compass.v1.LifecycleCallRequest.despawn:type_name -> compass.v1.DespawnPeerRequest - 8, // 13: compass.v1.LifecycleCallResult.spawn:type_name -> compass.v1.SpawnPeerResponse - 10, // 14: compass.v1.LifecycleCallResult.despawn:type_name -> compass.v1.DespawnPeerResponse - 12, // 15: compass.v1.LifecycleCallResult.error:type_name -> compass.v1.LifecycleCallError - 16, // 16: compass.v1.ForgeCallRequest.create_issue:type_name -> compass.v1.CreateIssueRequest - 17, // 17: compass.v1.ForgeCallRequest.comment_on_issue:type_name -> compass.v1.CommentOnIssueRequest - 18, // 18: compass.v1.ForgeCallRequest.get_issue:type_name -> compass.v1.GetIssueRequest - 19, // 19: compass.v1.ForgeCallRequest.list_issues:type_name -> compass.v1.ListIssuesRequest - 21, // 20: compass.v1.ForgeCallRequest.create_pull_request:type_name -> compass.v1.CreatePullRequestRequest - 22, // 21: compass.v1.ForgeCallRequest.comment_on_pull_request:type_name -> compass.v1.CommentOnPullRequestRequest - 23, // 22: compass.v1.ForgeCallRequest.get_pull_request:type_name -> compass.v1.GetPullRequestRequest - 26, // 23: compass.v1.ForgeCallRequest.subscribe:type_name -> compass.v1.SubscribeForgeRequest - 28, // 24: compass.v1.ForgeCallRequest.unsubscribe:type_name -> compass.v1.UnsubscribeForgeRequest - 24, // 25: compass.v1.ForgeCallRequest.submit_review:type_name -> compass.v1.SubmitReviewRequest - 48, // 26: compass.v1.ForgeCallRequest.forge:type_name -> compass.v1.ForgeRef - 49, // 27: compass.v1.ForgeCallResult.issue:type_name -> compass.v1.Issue - 50, // 28: compass.v1.ForgeCallResult.issue_comment:type_name -> compass.v1.CommentRef - 20, // 29: compass.v1.ForgeCallResult.issues:type_name -> compass.v1.ListIssuesResponse - 51, // 30: compass.v1.ForgeCallResult.pull_request:type_name -> compass.v1.PullRequest - 50, // 31: compass.v1.ForgeCallResult.pr_comment:type_name -> compass.v1.CommentRef - 27, // 32: compass.v1.ForgeCallResult.subscribed:type_name -> compass.v1.SubscribeForgeResponse - 29, // 33: compass.v1.ForgeCallResult.unsubscribed:type_name -> compass.v1.UnsubscribeForgeResponse - 15, // 34: compass.v1.ForgeCallResult.error:type_name -> compass.v1.ForgeCallError - 52, // 35: compass.v1.ForgeCallResult.review:type_name -> compass.v1.ReviewRef - 49, // 36: compass.v1.ListIssuesResponse.issues:type_name -> compass.v1.Issue - 25, // 37: compass.v1.SubmitReviewRequest.comments:type_name -> compass.v1.ReviewCommentInput - 53, // 38: compass.v1.SubscribeForgeRequest.kind:type_name -> compass.v1.ForgeArtifactKind - 0, // 39: compass.v1.SubscribeForgeRequest.scope:type_name -> compass.v1.ForgeSubscriptionScope - 31, // 40: compass.v1.BoardCallRequest.set_issue_state:type_name -> compass.v1.SetIssueStateRequest - 54, // 41: compass.v1.SetIssueStateRequest.state:type_name -> compass.v1.IssueState - 49, // 42: compass.v1.SetIssueStateResponse.issue:type_name -> compass.v1.Issue - 32, // 43: compass.v1.BoardCallResult.set_issue_state:type_name -> compass.v1.SetIssueStateResponse - 34, // 44: compass.v1.BoardCallResult.error:type_name -> compass.v1.BoardCallError - 55, // 45: compass.v1.PublishFrameRequest.frame:type_name -> compass.v1.AgentFrame - 55, // 46: compass.v1.PostConversationFrameRequest.frame:type_name -> compass.v1.AgentFrame - 1, // 47: compass.v1.AgentGateway.Comms:input_type -> compass.v1.CommsCallRequest - 6, // 48: compass.v1.AgentGateway.Lifecycle:input_type -> compass.v1.LifecycleCallRequest - 35, // 49: compass.v1.AgentGateway.Publish:input_type -> compass.v1.PublishFrameRequest - 37, // 50: compass.v1.AgentGateway.PostConversationFrame:input_type -> compass.v1.PostConversationFrameRequest - 39, // 51: compass.v1.AgentGateway.Control:input_type -> compass.v1.ControlSubscribeRequest - 13, // 52: compass.v1.AgentGateway.Forge:input_type -> compass.v1.ForgeCallRequest - 30, // 53: compass.v1.AgentGateway.Board:input_type -> compass.v1.BoardCallRequest - 2, // 54: compass.v1.AgentGateway.Comms:output_type -> compass.v1.CommsCallResult - 11, // 55: compass.v1.AgentGateway.Lifecycle:output_type -> compass.v1.LifecycleCallResult - 36, // 56: compass.v1.AgentGateway.Publish:output_type -> compass.v1.PublishFrameResponse - 38, // 57: compass.v1.AgentGateway.PostConversationFrame:output_type -> compass.v1.PostConversationFrameResponse - 56, // 58: compass.v1.AgentGateway.Control:output_type -> compass.v1.AgentControl - 14, // 59: compass.v1.AgentGateway.Forge:output_type -> compass.v1.ForgeCallResult - 33, // 60: compass.v1.AgentGateway.Board:output_type -> compass.v1.BoardCallResult - 54, // [54:61] is the sub-list for method output_type - 47, // [47:54] is the sub-list for method input_type - 47, // [47:47] is the sub-list for extension type_name - 47, // [47:47] is the sub-list for extension extendee - 0, // [0:47] is the sub-list for field type_name + 44, // 5: compass.v1.CommsCallRequest.create_channel:type_name -> compass.v1.CreateChannelRequest + 45, // 6: compass.v1.CommsCallRequest.update_members:type_name -> compass.v1.UpdateChannelMembersRequest + 46, // 7: compass.v1.CommsCallRequest.create_channel_group:type_name -> compass.v1.CreateChannelGroupRequest + 47, // 8: compass.v1.CommsCallResult.post:type_name -> compass.v1.PostMessageResponse + 48, // 9: compass.v1.CommsCallResult.list:type_name -> compass.v1.ListMessagesResponse + 3, // 10: compass.v1.CommsCallResult.error:type_name -> compass.v1.CommsCallError + 49, // 11: compass.v1.CommsCallResult.roster:type_name -> compass.v1.GetRosterResponse + 5, // 12: compass.v1.CommsCallResult.set_status:type_name -> compass.v1.SetAgentStatusResponse + 50, // 13: compass.v1.CommsCallResult.pin:type_name -> compass.v1.UpdatePinnedBoardResponse + 51, // 14: compass.v1.CommsCallResult.create_channel:type_name -> compass.v1.CreateChannelResponse + 52, // 15: compass.v1.CommsCallResult.update_members:type_name -> compass.v1.UpdateChannelMembersResponse + 53, // 16: compass.v1.CommsCallResult.create_channel_group:type_name -> compass.v1.CreateChannelGroupResponse + 7, // 17: compass.v1.LifecycleCallRequest.spawn:type_name -> compass.v1.SpawnPeerRequest + 9, // 18: compass.v1.LifecycleCallRequest.despawn:type_name -> compass.v1.DespawnPeerRequest + 8, // 19: compass.v1.LifecycleCallResult.spawn:type_name -> compass.v1.SpawnPeerResponse + 10, // 20: compass.v1.LifecycleCallResult.despawn:type_name -> compass.v1.DespawnPeerResponse + 12, // 21: compass.v1.LifecycleCallResult.error:type_name -> compass.v1.LifecycleCallError + 16, // 22: compass.v1.ForgeCallRequest.create_issue:type_name -> compass.v1.CreateIssueRequest + 17, // 23: compass.v1.ForgeCallRequest.comment_on_issue:type_name -> compass.v1.CommentOnIssueRequest + 18, // 24: compass.v1.ForgeCallRequest.get_issue:type_name -> compass.v1.GetIssueRequest + 19, // 25: compass.v1.ForgeCallRequest.list_issues:type_name -> compass.v1.ListIssuesRequest + 21, // 26: compass.v1.ForgeCallRequest.create_pull_request:type_name -> compass.v1.CreatePullRequestRequest + 22, // 27: compass.v1.ForgeCallRequest.comment_on_pull_request:type_name -> compass.v1.CommentOnPullRequestRequest + 23, // 28: compass.v1.ForgeCallRequest.get_pull_request:type_name -> compass.v1.GetPullRequestRequest + 26, // 29: compass.v1.ForgeCallRequest.subscribe:type_name -> compass.v1.SubscribeForgeRequest + 28, // 30: compass.v1.ForgeCallRequest.unsubscribe:type_name -> compass.v1.UnsubscribeForgeRequest + 24, // 31: compass.v1.ForgeCallRequest.submit_review:type_name -> compass.v1.SubmitReviewRequest + 54, // 32: compass.v1.ForgeCallRequest.forge:type_name -> compass.v1.ForgeRef + 55, // 33: compass.v1.ForgeCallResult.issue:type_name -> compass.v1.Issue + 56, // 34: compass.v1.ForgeCallResult.issue_comment:type_name -> compass.v1.CommentRef + 20, // 35: compass.v1.ForgeCallResult.issues:type_name -> compass.v1.ListIssuesResponse + 57, // 36: compass.v1.ForgeCallResult.pull_request:type_name -> compass.v1.PullRequest + 56, // 37: compass.v1.ForgeCallResult.pr_comment:type_name -> compass.v1.CommentRef + 27, // 38: compass.v1.ForgeCallResult.subscribed:type_name -> compass.v1.SubscribeForgeResponse + 29, // 39: compass.v1.ForgeCallResult.unsubscribed:type_name -> compass.v1.UnsubscribeForgeResponse + 15, // 40: compass.v1.ForgeCallResult.error:type_name -> compass.v1.ForgeCallError + 58, // 41: compass.v1.ForgeCallResult.review:type_name -> compass.v1.ReviewRef + 55, // 42: compass.v1.ListIssuesResponse.issues:type_name -> compass.v1.Issue + 25, // 43: compass.v1.SubmitReviewRequest.comments:type_name -> compass.v1.ReviewCommentInput + 59, // 44: compass.v1.SubscribeForgeRequest.kind:type_name -> compass.v1.ForgeArtifactKind + 0, // 45: compass.v1.SubscribeForgeRequest.scope:type_name -> compass.v1.ForgeSubscriptionScope + 31, // 46: compass.v1.BoardCallRequest.set_issue_state:type_name -> compass.v1.SetIssueStateRequest + 60, // 47: compass.v1.SetIssueStateRequest.state:type_name -> compass.v1.IssueState + 55, // 48: compass.v1.SetIssueStateResponse.issue:type_name -> compass.v1.Issue + 32, // 49: compass.v1.BoardCallResult.set_issue_state:type_name -> compass.v1.SetIssueStateResponse + 34, // 50: compass.v1.BoardCallResult.error:type_name -> compass.v1.BoardCallError + 61, // 51: compass.v1.PublishFrameRequest.frame:type_name -> compass.v1.AgentFrame + 61, // 52: compass.v1.PostConversationFrameRequest.frame:type_name -> compass.v1.AgentFrame + 1, // 53: compass.v1.AgentGateway.Comms:input_type -> compass.v1.CommsCallRequest + 6, // 54: compass.v1.AgentGateway.Lifecycle:input_type -> compass.v1.LifecycleCallRequest + 35, // 55: compass.v1.AgentGateway.Publish:input_type -> compass.v1.PublishFrameRequest + 37, // 56: compass.v1.AgentGateway.PostConversationFrame:input_type -> compass.v1.PostConversationFrameRequest + 39, // 57: compass.v1.AgentGateway.Control:input_type -> compass.v1.ControlSubscribeRequest + 13, // 58: compass.v1.AgentGateway.Forge:input_type -> compass.v1.ForgeCallRequest + 30, // 59: compass.v1.AgentGateway.Board:input_type -> compass.v1.BoardCallRequest + 2, // 60: compass.v1.AgentGateway.Comms:output_type -> compass.v1.CommsCallResult + 11, // 61: compass.v1.AgentGateway.Lifecycle:output_type -> compass.v1.LifecycleCallResult + 36, // 62: compass.v1.AgentGateway.Publish:output_type -> compass.v1.PublishFrameResponse + 38, // 63: compass.v1.AgentGateway.PostConversationFrame:output_type -> compass.v1.PostConversationFrameResponse + 62, // 64: compass.v1.AgentGateway.Control:output_type -> compass.v1.AgentControl + 14, // 65: compass.v1.AgentGateway.Forge:output_type -> compass.v1.ForgeCallResult + 33, // 66: compass.v1.AgentGateway.Board:output_type -> compass.v1.BoardCallResult + 60, // [60:67] is the sub-list for method output_type + 53, // [53:60] is the sub-list for method input_type + 53, // [53:53] is the sub-list for extension type_name + 53, // [53:53] is the sub-list for extension extendee + 0, // [0:53] is the sub-list for field type_name } func init() { file_compass_v1_agent_gateway_proto_init() } @@ -3292,6 +3431,9 @@ func file_compass_v1_agent_gateway_proto_init() { (*CommsCallRequest_Roster)(nil), (*CommsCallRequest_SetStatus)(nil), (*CommsCallRequest_Pin)(nil), + (*CommsCallRequest_CreateChannel)(nil), + (*CommsCallRequest_UpdateMembers)(nil), + (*CommsCallRequest_CreateChannelGroup)(nil), } file_compass_v1_agent_gateway_proto_msgTypes[1].OneofWrappers = []any{ (*CommsCallResult_Post)(nil), @@ -3300,6 +3442,9 @@ func file_compass_v1_agent_gateway_proto_init() { (*CommsCallResult_Roster)(nil), (*CommsCallResult_SetStatus)(nil), (*CommsCallResult_Pin)(nil), + (*CommsCallResult_CreateChannel)(nil), + (*CommsCallResult_UpdateMembers)(nil), + (*CommsCallResult_CreateChannelGroup)(nil), } file_compass_v1_agent_gateway_proto_msgTypes[5].OneofWrappers = []any{ (*LifecycleCallRequest_Spawn)(nil), diff --git a/packages/compass-agent/src/gen/compass/v1/agent_gateway_pb.ts b/packages/compass-agent/src/gen/compass/v1/agent_gateway_pb.ts index 76782e98..c373cf85 100644 --- a/packages/compass-agent/src/gen/compass/v1/agent_gateway_pb.ts +++ b/packages/compass-agent/src/gen/compass/v1/agent_gateway_pb.ts @@ -34,7 +34,7 @@ import type { GenEnum, GenFile, GenMessage, GenService } from "@bufbuild/protobuf/codegenv2"; import { enumDesc, fileDesc, messageDesc, serviceDesc } from "@bufbuild/protobuf/codegenv2"; -import type { GetRosterRequest, GetRosterResponse, ListMessagesRequest, ListMessagesResponse, PostMessageRequest, PostMessageResponse, UpdatePinnedBoardRequest, UpdatePinnedBoardResponse } from "./comms_pb"; +import type { CreateChannelGroupRequest, CreateChannelGroupResponse, CreateChannelRequest, CreateChannelResponse, GetRosterRequest, GetRosterResponse, ListMessagesRequest, ListMessagesResponse, PostMessageRequest, PostMessageResponse, UpdateChannelMembersRequest, UpdateChannelMembersResponse, UpdatePinnedBoardRequest, UpdatePinnedBoardResponse } from "./comms_pb"; import { file_compass_v1_comms } from "./comms_pb"; import type { AgentControlSchema, AgentFrame } from "./agent_pb"; import { file_compass_v1_agent } from "./agent_pb"; @@ -48,7 +48,7 @@ import type { Message } from "@bufbuild/protobuf"; * Describes the file compass/v1/agent_gateway.proto. */ export const file_compass_v1_agent_gateway: GenFile = /*@__PURE__*/ - fileDesc("Ch5jb21wYXNzL3YxL2FnZW50X2dhdGV3YXkucHJvdG8SCmNvbXBhc3MudjEixwIKEENvbW1zQ2FsbFJlcXVlc3QSDwoHY2FsbF9pZBgBIAEoCRIuCgRwb3N0GAIgASgLMh4uY29tcGFzcy52MS5Qb3N0TWVzc2FnZVJlcXVlc3RIABIvCgRsaXN0GAMgASgLMh8uY29tcGFzcy52MS5MaXN0TWVzc2FnZXNSZXF1ZXN0SAASLgoGcm9zdGVyGAQgASgLMhwuY29tcGFzcy52MS5HZXRSb3N0ZXJSZXF1ZXN0SAASNwoKc2V0X3N0YXR1cxgFIAEoCzIhLmNvbXBhc3MudjEuU2V0QWdlbnRTdGF0dXNSZXF1ZXN0SAASMwoDcGluGAYgASgLMiQuY29tcGFzcy52MS5VcGRhdGVQaW5uZWRCb2FyZFJlcXVlc3RIABIbChN0cmlnZ2VyX3RyYWNlcGFyZW50GAogASgJQgYKBGNhbGwi3QIKD0NvbW1zQ2FsbFJlc3VsdBIPCgdjYWxsX2lkGAEgASgJEi8KBHBvc3QYAiABKAsyHy5jb21wYXNzLnYxLlBvc3RNZXNzYWdlUmVzcG9uc2VIABIwCgRsaXN0GAMgASgLMiAuY29tcGFzcy52MS5MaXN0TWVzc2FnZXNSZXNwb25zZUgAEisKBWVycm9yGAQgASgLMhouY29tcGFzcy52MS5Db21tc0NhbGxFcnJvckgAEi8KBnJvc3RlchgFIAEoCzIdLmNvbXBhc3MudjEuR2V0Um9zdGVyUmVzcG9uc2VIABI4CgpzZXRfc3RhdHVzGAYgASgLMiIuY29tcGFzcy52MS5TZXRBZ2VudFN0YXR1c1Jlc3BvbnNlSAASNAoDcGluGAcgASgLMiUuY29tcGFzcy52MS5VcGRhdGVQaW5uZWRCb2FyZFJlc3BvbnNlSABCCAoGcmVzdWx0Ii8KDkNvbW1zQ2FsbEVycm9yEgwKBGNvZGUYASABKAkSDwoHbWVzc2FnZRgCIAEoCSIpChVTZXRBZ2VudFN0YXR1c1JlcXVlc3QSEAoIYWN0aXZpdHkYASABKAkiGAoWU2V0QWdlbnRTdGF0dXNSZXNwb25zZSKRAQoUTGlmZWN5Y2xlQ2FsbFJlcXVlc3QSDwoHY2FsbF9pZBgBIAEoCRItCgVzcGF3bhgCIAEoCzIcLmNvbXBhc3MudjEuU3Bhd25QZWVyUmVxdWVzdEgAEjEKB2Rlc3Bhd24YAyABKAsyHi5jb21wYXNzLnYxLkRlc3Bhd25QZWVyUmVxdWVzdEgAQgYKBGNhbGwiaQoQU3Bhd25QZWVyUmVxdWVzdBIOCgZoYW5kbGUYASABKAkSFAoMZGlzcGxheV9uYW1lGAIgASgJEhkKEWNsaWVudF9yZXF1ZXN0X2lkGAQgASgJSgQIAxAEUg5pbml0aWFsX3Byb21wdCJZChFTcGF3blBlZXJSZXNwb25zZRIYChBhZ2VudF9hY2NvdW50X2lkGAEgASgJEhYKDmNvbnRhaW5lcl9uYW1lGAIgASgJEhIKCnNlc3Npb25faWQYAyABKAkiKgoSRGVzcGF3blBlZXJSZXF1ZXN0EhQKDGFnZW50X2hhbmRsZRgBIAEoCSIVChNEZXNwYXduUGVlclJlc3BvbnNlIsUBChNMaWZlY3ljbGVDYWxsUmVzdWx0Eg8KB2NhbGxfaWQYASABKAkSLgoFc3Bhd24YAiABKAsyHS5jb21wYXNzLnYxLlNwYXduUGVlclJlc3BvbnNlSAASMgoHZGVzcGF3bhgDIAEoCzIfLmNvbXBhc3MudjEuRGVzcGF3blBlZXJSZXNwb25zZUgAEi8KBWVycm9yGAQgASgLMh4uY29tcGFzcy52MS5MaWZlY3ljbGVDYWxsRXJyb3JIAEIICgZyZXN1bHQiMwoSTGlmZWN5Y2xlQ2FsbEVycm9yEgwKBGNvZGUYASABKAkSDwoHbWVzc2FnZRgCIAEoCSLIBQoQRm9yZ2VDYWxsUmVxdWVzdBIPCgdjYWxsX2lkGAEgASgJEjYKDGNyZWF0ZV9pc3N1ZRgCIAEoCzIeLmNvbXBhc3MudjEuQ3JlYXRlSXNzdWVSZXF1ZXN0SAASPQoQY29tbWVudF9vbl9pc3N1ZRgDIAEoCzIhLmNvbXBhc3MudjEuQ29tbWVudE9uSXNzdWVSZXF1ZXN0SAASMAoJZ2V0X2lzc3VlGAQgASgLMhsuY29tcGFzcy52MS5HZXRJc3N1ZVJlcXVlc3RIABI0CgtsaXN0X2lzc3VlcxgFIAEoCzIdLmNvbXBhc3MudjEuTGlzdElzc3Vlc1JlcXVlc3RIABJDChNjcmVhdGVfcHVsbF9yZXF1ZXN0GAYgASgLMiQuY29tcGFzcy52MS5DcmVhdGVQdWxsUmVxdWVzdFJlcXVlc3RIABJKChdjb21tZW50X29uX3B1bGxfcmVxdWVzdBgHIAEoCzInLmNvbXBhc3MudjEuQ29tbWVudE9uUHVsbFJlcXVlc3RSZXF1ZXN0SAASPQoQZ2V0X3B1bGxfcmVxdWVzdBgIIAEoCzIhLmNvbXBhc3MudjEuR2V0UHVsbFJlcXVlc3RSZXF1ZXN0SAASNgoJc3Vic2NyaWJlGAkgASgLMiEuY29tcGFzcy52MS5TdWJzY3JpYmVGb3JnZVJlcXVlc3RIABI6Cgt1bnN1YnNjcmliZRgKIAEoCzIjLmNvbXBhc3MudjEuVW5zdWJzY3JpYmVGb3JnZVJlcXVlc3RIABI4Cg1zdWJtaXRfcmV2aWV3GAsgASgLMh8uY29tcGFzcy52MS5TdWJtaXRSZXZpZXdSZXF1ZXN0SAASIwoFZm9yZ2UYDCABKAsyFC5jb21wYXNzLnYxLkZvcmdlUmVmEhkKEWNsaWVudF9yZXF1ZXN0X2lkGA0gASgJQgYKBGNhbGwi4AMKD0ZvcmdlQ2FsbFJlc3VsdBIPCgdjYWxsX2lkGAEgASgJEiIKBWlzc3VlGAIgASgLMhEuY29tcGFzcy52MS5Jc3N1ZUgAEi8KDWlzc3VlX2NvbW1lbnQYAyABKAsyFi5jb21wYXNzLnYxLkNvbW1lbnRSZWZIABIwCgZpc3N1ZXMYBCABKAsyHi5jb21wYXNzLnYxLkxpc3RJc3N1ZXNSZXNwb25zZUgAEi8KDHB1bGxfcmVxdWVzdBgFIAEoCzIXLmNvbXBhc3MudjEuUHVsbFJlcXVlc3RIABIsCgpwcl9jb21tZW50GAYgASgLMhYuY29tcGFzcy52MS5Db21tZW50UmVmSAASOAoKc3Vic2NyaWJlZBgHIAEoCzIiLmNvbXBhc3MudjEuU3Vic2NyaWJlRm9yZ2VSZXNwb25zZUgAEjwKDHVuc3Vic2NyaWJlZBgIIAEoCzIkLmNvbXBhc3MudjEuVW5zdWJzY3JpYmVGb3JnZVJlc3BvbnNlSAASKwoFZXJyb3IYCSABKAsyGi5jb21wYXNzLnYxLkZvcmdlQ2FsbEVycm9ySAASJwoGcmV2aWV3GAogASgLMhUuY29tcGFzcy52MS5SZXZpZXdSZWZIAEIICgZyZXN1bHQiRwoORm9yZ2VDYWxsRXJyb3ISDAoEY29kZRgBIAEoCRIPCgdtZXNzYWdlGAIgASgJEhYKDnJldHJ5X2FmdGVyX21zGAMgASgNIk8KEkNyZWF0ZUlzc3VlUmVxdWVzdBIMCgRyZXBvGAEgASgJEg0KBXRpdGxlGAIgASgJEgwKBGJvZHkYAyABKAkSDgoGbGFiZWxzGAQgAygJIkkKFUNvbW1lbnRPbklzc3VlUmVxdWVzdBIMCgRyZXBvGAEgASgJEhQKDGlzc3VlX251bWJlchgCIAEoBBIMCgRib2R5GAMgASgJIjUKD0dldElzc3VlUmVxdWVzdBIMCgRyZXBvGAEgASgJEhQKDGlzc3VlX251bWJlchgCIAEoBCJPChFMaXN0SXNzdWVzUmVxdWVzdBIMCgRyZXBvGAEgASgJEg0KBXN0YXRlGAIgASgJEg4KBmxhYmVscxgDIAMoCRINCgVsaW1pdBgEIAEoDSI3ChJMaXN0SXNzdWVzUmVzcG9uc2USIQoGaXNzdWVzGAEgAygLMhEuY29tcGFzcy52MS5Jc3N1ZSJ4ChhDcmVhdGVQdWxsUmVxdWVzdFJlcXVlc3QSDAoEcmVwbxgBIAEoCRINCgV0aXRsZRgCIAEoCRIMCgRib2R5GAMgASgJEhAKCGhlYWRfcmVmGAQgASgJEhAKCGJhc2VfcmVmGAUgASgJEg0KBWRyYWZ0GAYgASgIIk4KG0NvbW1lbnRPblB1bGxSZXF1ZXN0UmVxdWVzdBIMCgRyZXBvGAEgASgJEhMKC3B1bGxfbnVtYmVyGAIgASgEEgwKBGJvZHkYAyABKAkiOgoVR2V0UHVsbFJlcXVlc3RSZXF1ZXN0EgwKBHJlcG8YASABKAkSEwoLcHVsbF9udW1iZXIYAiABKAQiiQEKE1N1Ym1pdFJldmlld1JlcXVlc3QSDAoEcmVwbxgBIAEoCRITCgtwdWxsX251bWJlchgCIAEoBBIPCgd2ZXJkaWN0GAMgASgJEgwKBGJvZHkYBCABKAkSMAoIY29tbWVudHMYBSADKAsyHi5jb21wYXNzLnYxLlJldmlld0NvbW1lbnRJbnB1dCJMChJSZXZpZXdDb21tZW50SW5wdXQSDAoEcGF0aBgBIAEoCRIMCgRsaW5lGAIgASgNEgwKBHNpZGUYAyABKAkSDAoEYm9keRgEIAEoCSKmAQoVU3Vic2NyaWJlRm9yZ2VSZXF1ZXN0EgwKBHJlcG8YASABKAkSKwoEa2luZBgCIAEoDjIdLmNvbXBhc3MudjEuRm9yZ2VBcnRpZmFjdEtpbmQSDgoGbnVtYmVyGAMgASgEEjEKBXNjb3BlGAQgASgOMiIuY29tcGFzcy52MS5Gb3JnZVN1YnNjcmlwdGlvblNjb3BlEg8KB3Byb2plY3QYBSABKAkiMQoWU3Vic2NyaWJlRm9yZ2VSZXNwb25zZRIXCg9zdWJzY3JpcHRpb25faWQYASABKAkiMgoXVW5zdWJzY3JpYmVGb3JnZVJlcXVlc3QSFwoPc3Vic2NyaXB0aW9uX2lkGAEgASgJIhoKGFVuc3Vic2NyaWJlRm9yZ2VSZXNwb25zZSJoChBCb2FyZENhbGxSZXF1ZXN0Eg8KB2NhbGxfaWQYASABKAkSOwoPc2V0X2lzc3VlX3N0YXRlGAIgASgLMiAuY29tcGFzcy52MS5TZXRJc3N1ZVN0YXRlUmVxdWVzdEgAQgYKBGNhbGwiTwoUU2V0SXNzdWVTdGF0ZVJlcXVlc3QSEAoIaXNzdWVfaWQYASABKAkSJQoFc3RhdGUYAiABKA4yFi5jb21wYXNzLnYxLklzc3VlU3RhdGUiOQoVU2V0SXNzdWVTdGF0ZVJlc3BvbnNlEiAKBWlzc3VlGAEgASgLMhEuY29tcGFzcy52MS5Jc3N1ZSKXAQoPQm9hcmRDYWxsUmVzdWx0Eg8KB2NhbGxfaWQYASABKAkSPAoPc2V0X2lzc3VlX3N0YXRlGAIgASgLMiEuY29tcGFzcy52MS5TZXRJc3N1ZVN0YXRlUmVzcG9uc2VIABIrCgVlcnJvchgDIAEoCzIaLmNvbXBhc3MudjEuQm9hcmRDYWxsRXJyb3JIAEIICgZyZXN1bHQiLwoOQm9hcmRDYWxsRXJyb3ISDAoEY29kZRgBIAEoCRIPCgdtZXNzYWdlGAIgASgJIjwKE1B1Ymxpc2hGcmFtZVJlcXVlc3QSJQoFZnJhbWUYASABKAsyFi5jb21wYXNzLnYxLkFnZW50RnJhbWUiFgoUUHVibGlzaEZyYW1lUmVzcG9uc2UiXgocUG9zdENvbnZlcnNhdGlvbkZyYW1lUmVxdWVzdBIlCgVmcmFtZRgBIAEoCzIWLmNvbXBhc3MudjEuQWdlbnRGcmFtZRIXCg9pZGVtcG90ZW5jeV9rZXkYAiABKAkiHwodUG9zdENvbnZlcnNhdGlvbkZyYW1lUmVzcG9uc2UiGQoXQ29udHJvbFN1YnNjcmliZVJlcXVlc3QqkQEKFkZvcmdlU3Vic2NyaXB0aW9uU2NvcGUSKAokRk9SR0VfU1VCU0NSSVBUSU9OX1NDT1BFX1VOU1BFQ0lGSUVEEAASJQohRk9SR0VfU1VCU0NSSVBUSU9OX1NDT1BFX0FSVElGQUNUEAESJgoiRk9SR0VfU1VCU0NSSVBUSU9OX1NDT1BFX0NPTlRBSU5FUhACMrQECgxBZ2VudEdhdGV3YXkSQgoFQ29tbXMSHC5jb21wYXNzLnYxLkNvbW1zQ2FsbFJlcXVlc3QaGy5jb21wYXNzLnYxLkNvbW1zQ2FsbFJlc3VsdBJOCglMaWZlY3ljbGUSIC5jb21wYXNzLnYxLkxpZmVjeWNsZUNhbGxSZXF1ZXN0Gh8uY29tcGFzcy52MS5MaWZlY3ljbGVDYWxsUmVzdWx0Ek4KB1B1Ymxpc2gSHy5jb21wYXNzLnYxLlB1Ymxpc2hGcmFtZVJlcXVlc3QaIC5jb21wYXNzLnYxLlB1Ymxpc2hGcmFtZVJlc3BvbnNlKAESbAoVUG9zdENvbnZlcnNhdGlvbkZyYW1lEiguY29tcGFzcy52MS5Qb3N0Q29udmVyc2F0aW9uRnJhbWVSZXF1ZXN0GikuY29tcGFzcy52MS5Qb3N0Q29udmVyc2F0aW9uRnJhbWVSZXNwb25zZRJKCgdDb250cm9sEiMuY29tcGFzcy52MS5Db250cm9sU3Vic2NyaWJlUmVxdWVzdBoYLmNvbXBhc3MudjEuQWdlbnRDb250cm9sMAESQgoFRm9yZ2USHC5jb21wYXNzLnYxLkZvcmdlQ2FsbFJlcXVlc3QaGy5jb21wYXNzLnYxLkZvcmdlQ2FsbFJlc3VsdBJCCgVCb2FyZBIcLmNvbXBhc3MudjEuQm9hcmRDYWxsUmVxdWVzdBobLmNvbXBhc3MudjEuQm9hcmRDYWxsUmVzdWx0YgZwcm90bzM", [file_compass_v1_comms, file_compass_v1_agent, file_compass_v1_compass, file_compass_v1_forge]); + fileDesc("Ch5jb21wYXNzL3YxL2FnZW50X2dhdGV3YXkucHJvdG8SCmNvbXBhc3MudjEijQQKEENvbW1zQ2FsbFJlcXVlc3QSDwoHY2FsbF9pZBgBIAEoCRIuCgRwb3N0GAIgASgLMh4uY29tcGFzcy52MS5Qb3N0TWVzc2FnZVJlcXVlc3RIABIvCgRsaXN0GAMgASgLMh8uY29tcGFzcy52MS5MaXN0TWVzc2FnZXNSZXF1ZXN0SAASLgoGcm9zdGVyGAQgASgLMhwuY29tcGFzcy52MS5HZXRSb3N0ZXJSZXF1ZXN0SAASNwoKc2V0X3N0YXR1cxgFIAEoCzIhLmNvbXBhc3MudjEuU2V0QWdlbnRTdGF0dXNSZXF1ZXN0SAASMwoDcGluGAYgASgLMiQuY29tcGFzcy52MS5VcGRhdGVQaW5uZWRCb2FyZFJlcXVlc3RIABI6Cg5jcmVhdGVfY2hhbm5lbBgHIAEoCzIgLmNvbXBhc3MudjEuQ3JlYXRlQ2hhbm5lbFJlcXVlc3RIABJBCg51cGRhdGVfbWVtYmVycxgIIAEoCzInLmNvbXBhc3MudjEuVXBkYXRlQ2hhbm5lbE1lbWJlcnNSZXF1ZXN0SAASRQoUY3JlYXRlX2NoYW5uZWxfZ3JvdXAYCSABKAsyJS5jb21wYXNzLnYxLkNyZWF0ZUNoYW5uZWxHcm91cFJlcXVlc3RIABIbChN0cmlnZ2VyX3RyYWNlcGFyZW50GAogASgJQgYKBGNhbGwipgQKD0NvbW1zQ2FsbFJlc3VsdBIPCgdjYWxsX2lkGAEgASgJEi8KBHBvc3QYAiABKAsyHy5jb21wYXNzLnYxLlBvc3RNZXNzYWdlUmVzcG9uc2VIABIwCgRsaXN0GAMgASgLMiAuY29tcGFzcy52MS5MaXN0TWVzc2FnZXNSZXNwb25zZUgAEisKBWVycm9yGAQgASgLMhouY29tcGFzcy52MS5Db21tc0NhbGxFcnJvckgAEi8KBnJvc3RlchgFIAEoCzIdLmNvbXBhc3MudjEuR2V0Um9zdGVyUmVzcG9uc2VIABI4CgpzZXRfc3RhdHVzGAYgASgLMiIuY29tcGFzcy52MS5TZXRBZ2VudFN0YXR1c1Jlc3BvbnNlSAASNAoDcGluGAcgASgLMiUuY29tcGFzcy52MS5VcGRhdGVQaW5uZWRCb2FyZFJlc3BvbnNlSAASOwoOY3JlYXRlX2NoYW5uZWwYCCABKAsyIS5jb21wYXNzLnYxLkNyZWF0ZUNoYW5uZWxSZXNwb25zZUgAEkIKDnVwZGF0ZV9tZW1iZXJzGAkgASgLMiguY29tcGFzcy52MS5VcGRhdGVDaGFubmVsTWVtYmVyc1Jlc3BvbnNlSAASRgoUY3JlYXRlX2NoYW5uZWxfZ3JvdXAYCiABKAsyJi5jb21wYXNzLnYxLkNyZWF0ZUNoYW5uZWxHcm91cFJlc3BvbnNlSABCCAoGcmVzdWx0Ii8KDkNvbW1zQ2FsbEVycm9yEgwKBGNvZGUYASABKAkSDwoHbWVzc2FnZRgCIAEoCSIpChVTZXRBZ2VudFN0YXR1c1JlcXVlc3QSEAoIYWN0aXZpdHkYASABKAkiGAoWU2V0QWdlbnRTdGF0dXNSZXNwb25zZSKRAQoUTGlmZWN5Y2xlQ2FsbFJlcXVlc3QSDwoHY2FsbF9pZBgBIAEoCRItCgVzcGF3bhgCIAEoCzIcLmNvbXBhc3MudjEuU3Bhd25QZWVyUmVxdWVzdEgAEjEKB2Rlc3Bhd24YAyABKAsyHi5jb21wYXNzLnYxLkRlc3Bhd25QZWVyUmVxdWVzdEgAQgYKBGNhbGwiiAEKEFNwYXduUGVlclJlcXVlc3QSDgoGaGFuZGxlGAEgASgJEhQKDGRpc3BsYXlfbmFtZRgCIAEoCRIZChFjbGllbnRfcmVxdWVzdF9pZBgEIAEoCRIMCgRyb2xlGAUgASgJEg8KB3BlcnNvbmEYBiABKAlKBAgDEARSDmluaXRpYWxfcHJvbXB0IlkKEVNwYXduUGVlclJlc3BvbnNlEhgKEGFnZW50X2FjY291bnRfaWQYASABKAkSFgoOY29udGFpbmVyX25hbWUYAiABKAkSEgoKc2Vzc2lvbl9pZBgDIAEoCSIqChJEZXNwYXduUGVlclJlcXVlc3QSFAoMYWdlbnRfaGFuZGxlGAEgASgJIhUKE0Rlc3Bhd25QZWVyUmVzcG9uc2UixQEKE0xpZmVjeWNsZUNhbGxSZXN1bHQSDwoHY2FsbF9pZBgBIAEoCRIuCgVzcGF3bhgCIAEoCzIdLmNvbXBhc3MudjEuU3Bhd25QZWVyUmVzcG9uc2VIABIyCgdkZXNwYXduGAMgASgLMh8uY29tcGFzcy52MS5EZXNwYXduUGVlclJlc3BvbnNlSAASLwoFZXJyb3IYBCABKAsyHi5jb21wYXNzLnYxLkxpZmVjeWNsZUNhbGxFcnJvckgAQggKBnJlc3VsdCIzChJMaWZlY3ljbGVDYWxsRXJyb3ISDAoEY29kZRgBIAEoCRIPCgdtZXNzYWdlGAIgASgJIsgFChBGb3JnZUNhbGxSZXF1ZXN0Eg8KB2NhbGxfaWQYASABKAkSNgoMY3JlYXRlX2lzc3VlGAIgASgLMh4uY29tcGFzcy52MS5DcmVhdGVJc3N1ZVJlcXVlc3RIABI9ChBjb21tZW50X29uX2lzc3VlGAMgASgLMiEuY29tcGFzcy52MS5Db21tZW50T25Jc3N1ZVJlcXVlc3RIABIwCglnZXRfaXNzdWUYBCABKAsyGy5jb21wYXNzLnYxLkdldElzc3VlUmVxdWVzdEgAEjQKC2xpc3RfaXNzdWVzGAUgASgLMh0uY29tcGFzcy52MS5MaXN0SXNzdWVzUmVxdWVzdEgAEkMKE2NyZWF0ZV9wdWxsX3JlcXVlc3QYBiABKAsyJC5jb21wYXNzLnYxLkNyZWF0ZVB1bGxSZXF1ZXN0UmVxdWVzdEgAEkoKF2NvbW1lbnRfb25fcHVsbF9yZXF1ZXN0GAcgASgLMicuY29tcGFzcy52MS5Db21tZW50T25QdWxsUmVxdWVzdFJlcXVlc3RIABI9ChBnZXRfcHVsbF9yZXF1ZXN0GAggASgLMiEuY29tcGFzcy52MS5HZXRQdWxsUmVxdWVzdFJlcXVlc3RIABI2CglzdWJzY3JpYmUYCSABKAsyIS5jb21wYXNzLnYxLlN1YnNjcmliZUZvcmdlUmVxdWVzdEgAEjoKC3Vuc3Vic2NyaWJlGAogASgLMiMuY29tcGFzcy52MS5VbnN1YnNjcmliZUZvcmdlUmVxdWVzdEgAEjgKDXN1Ym1pdF9yZXZpZXcYCyABKAsyHy5jb21wYXNzLnYxLlN1Ym1pdFJldmlld1JlcXVlc3RIABIjCgVmb3JnZRgMIAEoCzIULmNvbXBhc3MudjEuRm9yZ2VSZWYSGQoRY2xpZW50X3JlcXVlc3RfaWQYDSABKAlCBgoEY2FsbCLgAwoPRm9yZ2VDYWxsUmVzdWx0Eg8KB2NhbGxfaWQYASABKAkSIgoFaXNzdWUYAiABKAsyES5jb21wYXNzLnYxLklzc3VlSAASLwoNaXNzdWVfY29tbWVudBgDIAEoCzIWLmNvbXBhc3MudjEuQ29tbWVudFJlZkgAEjAKBmlzc3VlcxgEIAEoCzIeLmNvbXBhc3MudjEuTGlzdElzc3Vlc1Jlc3BvbnNlSAASLwoMcHVsbF9yZXF1ZXN0GAUgASgLMhcuY29tcGFzcy52MS5QdWxsUmVxdWVzdEgAEiwKCnByX2NvbW1lbnQYBiABKAsyFi5jb21wYXNzLnYxLkNvbW1lbnRSZWZIABI4CgpzdWJzY3JpYmVkGAcgASgLMiIuY29tcGFzcy52MS5TdWJzY3JpYmVGb3JnZVJlc3BvbnNlSAASPAoMdW5zdWJzY3JpYmVkGAggASgLMiQuY29tcGFzcy52MS5VbnN1YnNjcmliZUZvcmdlUmVzcG9uc2VIABIrCgVlcnJvchgJIAEoCzIaLmNvbXBhc3MudjEuRm9yZ2VDYWxsRXJyb3JIABInCgZyZXZpZXcYCiABKAsyFS5jb21wYXNzLnYxLlJldmlld1JlZkgAQggKBnJlc3VsdCJHCg5Gb3JnZUNhbGxFcnJvchIMCgRjb2RlGAEgASgJEg8KB21lc3NhZ2UYAiABKAkSFgoOcmV0cnlfYWZ0ZXJfbXMYAyABKA0iTwoSQ3JlYXRlSXNzdWVSZXF1ZXN0EgwKBHJlcG8YASABKAkSDQoFdGl0bGUYAiABKAkSDAoEYm9keRgDIAEoCRIOCgZsYWJlbHMYBCADKAkiSQoVQ29tbWVudE9uSXNzdWVSZXF1ZXN0EgwKBHJlcG8YASABKAkSFAoMaXNzdWVfbnVtYmVyGAIgASgEEgwKBGJvZHkYAyABKAkiNQoPR2V0SXNzdWVSZXF1ZXN0EgwKBHJlcG8YASABKAkSFAoMaXNzdWVfbnVtYmVyGAIgASgEIk8KEUxpc3RJc3N1ZXNSZXF1ZXN0EgwKBHJlcG8YASABKAkSDQoFc3RhdGUYAiABKAkSDgoGbGFiZWxzGAMgAygJEg0KBWxpbWl0GAQgASgNIjcKEkxpc3RJc3N1ZXNSZXNwb25zZRIhCgZpc3N1ZXMYASADKAsyES5jb21wYXNzLnYxLklzc3VlIngKGENyZWF0ZVB1bGxSZXF1ZXN0UmVxdWVzdBIMCgRyZXBvGAEgASgJEg0KBXRpdGxlGAIgASgJEgwKBGJvZHkYAyABKAkSEAoIaGVhZF9yZWYYBCABKAkSEAoIYmFzZV9yZWYYBSABKAkSDQoFZHJhZnQYBiABKAgiTgobQ29tbWVudE9uUHVsbFJlcXVlc3RSZXF1ZXN0EgwKBHJlcG8YASABKAkSEwoLcHVsbF9udW1iZXIYAiABKAQSDAoEYm9keRgDIAEoCSI6ChVHZXRQdWxsUmVxdWVzdFJlcXVlc3QSDAoEcmVwbxgBIAEoCRITCgtwdWxsX251bWJlchgCIAEoBCKJAQoTU3VibWl0UmV2aWV3UmVxdWVzdBIMCgRyZXBvGAEgASgJEhMKC3B1bGxfbnVtYmVyGAIgASgEEg8KB3ZlcmRpY3QYAyABKAkSDAoEYm9keRgEIAEoCRIwCghjb21tZW50cxgFIAMoCzIeLmNvbXBhc3MudjEuUmV2aWV3Q29tbWVudElucHV0IkwKElJldmlld0NvbW1lbnRJbnB1dBIMCgRwYXRoGAEgASgJEgwKBGxpbmUYAiABKA0SDAoEc2lkZRgDIAEoCRIMCgRib2R5GAQgASgJIqYBChVTdWJzY3JpYmVGb3JnZVJlcXVlc3QSDAoEcmVwbxgBIAEoCRIrCgRraW5kGAIgASgOMh0uY29tcGFzcy52MS5Gb3JnZUFydGlmYWN0S2luZBIOCgZudW1iZXIYAyABKAQSMQoFc2NvcGUYBCABKA4yIi5jb21wYXNzLnYxLkZvcmdlU3Vic2NyaXB0aW9uU2NvcGUSDwoHcHJvamVjdBgFIAEoCSIxChZTdWJzY3JpYmVGb3JnZVJlc3BvbnNlEhcKD3N1YnNjcmlwdGlvbl9pZBgBIAEoCSIyChdVbnN1YnNjcmliZUZvcmdlUmVxdWVzdBIXCg9zdWJzY3JpcHRpb25faWQYASABKAkiGgoYVW5zdWJzY3JpYmVGb3JnZVJlc3BvbnNlImgKEEJvYXJkQ2FsbFJlcXVlc3QSDwoHY2FsbF9pZBgBIAEoCRI7Cg9zZXRfaXNzdWVfc3RhdGUYAiABKAsyIC5jb21wYXNzLnYxLlNldElzc3VlU3RhdGVSZXF1ZXN0SABCBgoEY2FsbCJPChRTZXRJc3N1ZVN0YXRlUmVxdWVzdBIQCghpc3N1ZV9pZBgBIAEoCRIlCgVzdGF0ZRgCIAEoDjIWLmNvbXBhc3MudjEuSXNzdWVTdGF0ZSI5ChVTZXRJc3N1ZVN0YXRlUmVzcG9uc2USIAoFaXNzdWUYASABKAsyES5jb21wYXNzLnYxLklzc3VlIpcBCg9Cb2FyZENhbGxSZXN1bHQSDwoHY2FsbF9pZBgBIAEoCRI8Cg9zZXRfaXNzdWVfc3RhdGUYAiABKAsyIS5jb21wYXNzLnYxLlNldElzc3VlU3RhdGVSZXNwb25zZUgAEisKBWVycm9yGAMgASgLMhouY29tcGFzcy52MS5Cb2FyZENhbGxFcnJvckgAQggKBnJlc3VsdCIvCg5Cb2FyZENhbGxFcnJvchIMCgRjb2RlGAEgASgJEg8KB21lc3NhZ2UYAiABKAkiPAoTUHVibGlzaEZyYW1lUmVxdWVzdBIlCgVmcmFtZRgBIAEoCzIWLmNvbXBhc3MudjEuQWdlbnRGcmFtZSIWChRQdWJsaXNoRnJhbWVSZXNwb25zZSJeChxQb3N0Q29udmVyc2F0aW9uRnJhbWVSZXF1ZXN0EiUKBWZyYW1lGAEgASgLMhYuY29tcGFzcy52MS5BZ2VudEZyYW1lEhcKD2lkZW1wb3RlbmN5X2tleRgCIAEoCSIfCh1Qb3N0Q29udmVyc2F0aW9uRnJhbWVSZXNwb25zZSIZChdDb250cm9sU3Vic2NyaWJlUmVxdWVzdCqRAQoWRm9yZ2VTdWJzY3JpcHRpb25TY29wZRIoCiRGT1JHRV9TVUJTQ1JJUFRJT05fU0NPUEVfVU5TUEVDSUZJRUQQABIlCiFGT1JHRV9TVUJTQ1JJUFRJT05fU0NPUEVfQVJUSUZBQ1QQARImCiJGT1JHRV9TVUJTQ1JJUFRJT05fU0NPUEVfQ09OVEFJTkVSEAIytAQKDEFnZW50R2F0ZXdheRJCCgVDb21tcxIcLmNvbXBhc3MudjEuQ29tbXNDYWxsUmVxdWVzdBobLmNvbXBhc3MudjEuQ29tbXNDYWxsUmVzdWx0Ek4KCUxpZmVjeWNsZRIgLmNvbXBhc3MudjEuTGlmZWN5Y2xlQ2FsbFJlcXVlc3QaHy5jb21wYXNzLnYxLkxpZmVjeWNsZUNhbGxSZXN1bHQSTgoHUHVibGlzaBIfLmNvbXBhc3MudjEuUHVibGlzaEZyYW1lUmVxdWVzdBogLmNvbXBhc3MudjEuUHVibGlzaEZyYW1lUmVzcG9uc2UoARJsChVQb3N0Q29udmVyc2F0aW9uRnJhbWUSKC5jb21wYXNzLnYxLlBvc3RDb252ZXJzYXRpb25GcmFtZVJlcXVlc3QaKS5jb21wYXNzLnYxLlBvc3RDb252ZXJzYXRpb25GcmFtZVJlc3BvbnNlEkoKB0NvbnRyb2wSIy5jb21wYXNzLnYxLkNvbnRyb2xTdWJzY3JpYmVSZXF1ZXN0GhguY29tcGFzcy52MS5BZ2VudENvbnRyb2wwARJCCgVGb3JnZRIcLmNvbXBhc3MudjEuRm9yZ2VDYWxsUmVxdWVzdBobLmNvbXBhc3MudjEuRm9yZ2VDYWxsUmVzdWx0EkIKBUJvYXJkEhwuY29tcGFzcy52MS5Cb2FyZENhbGxSZXF1ZXN0GhsuY29tcGFzcy52MS5Cb2FyZENhbGxSZXN1bHRiBnByb3RvMw", [file_compass_v1_comms, file_compass_v1_agent, file_compass_v1_compass, file_compass_v1_forge]); /** * One agent-initiated comms call. `call_id` is the agent-minted correlation id @@ -96,6 +96,24 @@ export type CommsCallRequest = Message<"compass.v1.CommsCallRequest"> & { */ value: UpdatePinnedBoardRequest; case: "pin"; + } | { + /** + * @generated from field: compass.v1.CreateChannelRequest create_channel = 7; + */ + value: CreateChannelRequest; + case: "createChannel"; + } | { + /** + * @generated from field: compass.v1.UpdateChannelMembersRequest update_members = 8; + */ + value: UpdateChannelMembersRequest; + case: "updateMembers"; + } | { + /** + * @generated from field: compass.v1.CreateChannelGroupRequest create_channel_group = 9; + */ + value: CreateChannelGroupRequest; + case: "createChannelGroup"; } | { case: undefined; value?: undefined }; /** @@ -124,9 +142,12 @@ export const CommsCallRequestSchema: GenMessage = /*@__PURE__* /** * The result of one comms call, correlated by `call_id`. A successful call sets - * `post`/`list`; an in-band failure (a tool error — non-member channel, bad - * input) sets `error`, which is NOT a transport teardown. The same message is - * the `RelayCommsCallResponse.result` payload on the Runner->Server leg. + * the response arm matching the request's operation (`post`, `list`, `roster`, + * `set_status`, `pin`, `create_channel`, `update_members`, + * `create_channel_group`); an in-band failure (a tool error — non-member + * channel, bad input) sets `error`, which is NOT a transport teardown. The same + * message is the `RelayCommsCallResponse.result` payload on the Runner->Server + * leg. * * @generated from message compass.v1.CommsCallResult */ @@ -175,6 +196,24 @@ export type CommsCallResult = Message<"compass.v1.CommsCallResult"> & { */ value: UpdatePinnedBoardResponse; case: "pin"; + } | { + /** + * @generated from field: compass.v1.CreateChannelResponse create_channel = 8; + */ + value: CreateChannelResponse; + case: "createChannel"; + } | { + /** + * @generated from field: compass.v1.UpdateChannelMembersResponse update_members = 9; + */ + value: UpdateChannelMembersResponse; + case: "updateMembers"; + } | { + /** + * @generated from field: compass.v1.CreateChannelGroupResponse create_channel_group = 10; + */ + value: CreateChannelGroupResponse; + case: "createChannelGroup"; } | { case: undefined; value?: undefined }; }; @@ -313,6 +352,20 @@ export type SpawnPeerRequest = Message<"compass.v1.SpawnPeerRequest"> & { * @generated from field: string client_request_id = 4; */ clientRequestId: string; + + /** + * Optional role/persona for the spawned agent, applied at creation only + * (org-management Manager creation, RIG-2673). Empty = the server's default + * role/persona for a peer. + * + * @generated from field: string role = 5; + */ + role: string; + + /** + * @generated from field: string persona = 6; + */ + persona: string; }; /** diff --git a/proto/compass/v1/agent_gateway.proto b/proto/compass/v1/agent_gateway.proto index 85ddbccb..2e041952 100644 --- a/proto/compass/v1/agent_gateway.proto +++ b/proto/compass/v1/agent_gateway.proto @@ -111,6 +111,9 @@ message CommsCallRequest { GetRosterRequest roster = 4; SetAgentStatusRequest set_status = 5; UpdatePinnedBoardRequest pin = 6; + CreateChannelRequest create_channel = 7; + UpdateChannelMembersRequest update_members = 8; + CreateChannelGroupRequest create_channel_group = 9; } // The W3C `traceparent` of the delivered message that triggered this outbound // call, re-attached by the agent so the Server can LINK the reply's fresh @@ -126,9 +129,12 @@ message CommsCallRequest { } // The result of one comms call, correlated by `call_id`. A successful call sets -// `post`/`list`; an in-band failure (a tool error — non-member channel, bad -// input) sets `error`, which is NOT a transport teardown. The same message is -// the `RelayCommsCallResponse.result` payload on the Runner->Server leg. +// the response arm matching the request's operation (`post`, `list`, `roster`, +// `set_status`, `pin`, `create_channel`, `update_members`, +// `create_channel_group`); an in-band failure (a tool error — non-member +// channel, bad input) sets `error`, which is NOT a transport teardown. The same +// message is the `RelayCommsCallResponse.result` payload on the Runner->Server +// leg. message CommsCallResult { string call_id = 1; oneof result { @@ -138,6 +144,9 @@ message CommsCallResult { GetRosterResponse roster = 5; SetAgentStatusResponse set_status = 6; UpdatePinnedBoardResponse pin = 7; + CreateChannelResponse create_channel = 8; + UpdateChannelMembersResponse update_members = 9; + CreateChannelGroupResponse create_channel_group = 10; } } @@ -181,6 +190,11 @@ message SpawnPeerRequest { reserved 3; reserved "initial_prompt"; string client_request_id = 4; // whole-chain idempotency key (handler-level join + Provision dedup) + // Optional role/persona for the spawned agent, applied at creation only + // (org-management Manager creation, RIG-2673). Empty = the server's default + // role/persona for a peer. + string role = 5; + string persona = 6; } message SpawnPeerResponse { string agent_account_id = 1;