transport

type Service interface {
	Health(ctx context.Context) error
	Network() protocol.Network
	GetAgent(agentID string) (protocol.AgentSummary, error)
	GetDirectConversation(dmID string) (protocol.DirectConversation, error)
	GetRoom(roomID string) (protocol.Room, error)
	GetThread(threadID string) (protocol.Thread, error)
	ListAgentsContext(ctx context.Context, page protocol.PageRequest) (protocol.AgentPage, error)
	ListPairingsContext(ctx context.Context, page protocol.PageRequest) (protocol.PairingPage, error)
	PairingNetwork(ctx context.Context, pairingID string) (protocol.Network, error)
	PairingRoomsContext(ctx context.Context, pairingID string, page protocol.PageRequest) (protocol.RoomPage, error)
	PairingAgentsContext(ctx context.Context, pairingID string, page protocol.PageRequest) (protocol.AgentPage, error)
	ListRoomsContext(ctx context.Context, page protocol.PageRequest) (protocol.RoomPage, error)
	CreateRoomContext(ctx context.Context, request protocol.CreateRoomRequest) (protocol.Room, error)
	UpdateRoomMembers(ctx context.Context, roomID string, request protocol.UpdateRoomMembersRequest) (protocol.Room, error)
	RegisterAgentContext(ctx context.Context, request protocol.RegisterAgentRequest) (protocol.AgentRegistration, error)
	ListRoomMessagesContext(ctx context.Context, roomID string, page protocol.PageRequest) (protocol.MessagePage, error)
	ListThreadsContext(ctx context.Context, roomID string, page protocol.PageRequest) (protocol.ThreadPage, error)
	ListThreadMessagesContext(ctx context.Context, threadID string, page protocol.PageRequest) (protocol.MessagePage, error)
	ListDirectConversationsContext(ctx context.Context, page protocol.PageRequest) (protocol.DirectConversationPage, error)
	ListDMMessagesContext(ctx context.Context, dmID string, page protocol.PageRequest) (protocol.MessagePage, error)
	ListArtifactsContext(ctx context.Context, filter protocol.ArtifactFilter, page protocol.PageRequest) (protocol.ArtifactPage, error)
	SendMessageContext(ctx context.Context, request protocol.SendMessageRequest) (protocol.MessageAccepted, error)
	Subscribe(ctx context.Context) <-chan protocol.Event
	SubscribeFrom(ctx context.Context, lastEventID string) <-chan protocol.Event
}