transport

type ConsoleAnalyticsConfig struct {
	Provider      string
	MeasurementID string
}

type ConsoleConfig struct {
	Analytics ConsoleAnalyticsConfig
}

type HTTPConfig struct {
	Console ConsoleConfig
}

type Service interface {
	Health(ctx context.Context) error
	Network() protocol.Network
	GetAgent(agentID string) (protocol.AgentSummary, error)
	GetAgentContext(ctx context.Context, agentID string) (protocol.AgentSummary, error)
	GetDirectConversation(dmID string) (protocol.DirectConversation, error)
	GetRoom(roomID string) (protocol.Room, error)
	GetRoomContext(ctx context.Context, roomID string) (protocol.Room, error)
	GetThread(threadID string) (protocol.Thread, error)
	GetThreadContext(ctx context.Context, 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)
	ApplyConfigContext(ctx context.Context, request protocol.ApplyConfigRequest) (protocol.ApplyConfigResult, error)
	CreateRoomContext(ctx context.Context, request protocol.CreateRoomRequest) (protocol.Room, error)
	RemoveRoomContext(ctx context.Context, roomID string) (protocol.RemoveResult, error)
	UpdateRoomMembers(ctx context.Context, roomID string, request protocol.UpdateRoomMembersRequest) (protocol.Room, error)
	RegisterAgentContext(ctx context.Context, request protocol.RegisterAgentRequest) (protocol.AgentRegistration, error)
	RemoveAgentContext(ctx context.Context, agentID string) (protocol.RemoveResult, error)
	AgentConnected(ctx context.Context, agent protocol.Actor)
	AgentDisconnected(ctx context.Context, agent protocol.Actor, reason string, err error)
	AgentWakeDelivered(ctx context.Context, agent protocol.Actor, event protocol.Event)
	AgentWakeFailed(ctx context.Context, agent protocol.Actor, event protocol.Event, err 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)
	AuthenticateAgentTokenContext(ctx context.Context, token string) (authn.Claims, bool, error)
	Subscribe(ctx context.Context) <-chan protocol.Event
	SubscribeFrom(ctx context.Context, lastEventID string) <-chan protocol.Event
}