base

type Agent interface {
	Close() concurrent.Future
	IsClosed() bool
	Session() Session
	GetRemoteSession(sessionId string) concurrent.CastFuture[RemoteSession]
	OnClosed(f func())
	OnMessage(f func(tf *omega.TransitFrame))
	OnSessionMessage(f func(tf *omega.TransitFrame))
	OnRequest(f func(tf *omega.TransitFrame))
	OnResponse(f func(tf *omega.TransitFrame))
	OnRequestReplay(f func(tf *omega.TransitFrame))
	OnResponseReplay(f func(tf *omega.TransitFrame))
	OnNotification(f func(tf *omega.TransitFrame))
	OnNotificationReplay(f func(tf *omega.TransitFrame))
	OnError(f func(err error))
	Ping() SendFuture
	OnBroadcast(f func(tf *omega.TransitFrame))
	Broadcast(msg string) SendFuture
	Hello() SendFuture
	ServerTime() SendFuture
	PlaybackChannelMessage(channelId string, targetTimestamp int64, inverse bool, volume omega.Volume, nextId string) SendFuture
	GetChannelMetadata(channelId string) SendFuture
	SetChannelMetadata(channelId string, name string, metadata *Metadata, skill *omega.Skill) SendFuture
	JoinChannel(channelId string, key string) SendFuture
	LeaveChannel(channelId string) SendFuture
	CloseChannel(channelId, key string) SendFuture
	ChannelMessage(channelId string, message string, metadata *Metadata) SendFuture
	ChannelCount(channelId string) SendFuture
	ChannelOwnerMessage(channelId string, message string, metadata *Metadata) SendFuture
	ReplayChannelMessage(channelId string, targetTimestamp int64, inverse bool, volume omega.Volume, nextId string) SendFuture
	GetVoteMetadata(voteId string) SendFuture
	SetVoteMetadata(voteId string, name string, metadata *Metadata) SendFuture
	JoinVote(voteId string, key string) SendFuture
	LeaveVote(voteId string) SendFuture
	CloseVote(voteId, key string) SendFuture
	VoteMessage(voteId string, message string) SendFuture
	VoteSelect(voteId string, voteOptionId string) SendFuture
	VoteCount(voteId string) SendFuture
	VoteOwnerMessage(voteId string, message string) SendFuture
	VoteStatus(voteId string, statusType omega.Vote_Status) SendFuture
	GetSessionMeta(sessionId string) SendFuture
	SetSessionMeta(metadata *Metadata) SendFuture
	SessionMessage(sessionId string, message string) SendFuture
	SessionsMessage(sessionIds []string, message string) SendFuture
	CreateChannel(createChannel apirequest.CreateChannel) concurrent.CastFuture[*apiresponse.CreateChannel]
	CreateVote(createVote apirequest.CreateVote) concurrent.CastFuture[*apiresponse.CreateVote]
}

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

type Config struct {
	Scheme         string
	Domain         string
	ConnectTimeout time.Duration
	TransitTimeout time.Duration
	AppId          string
	Token          string
}

type DefaultSendFuture struct {
	concurrent.CastFuture[*omega.TransitFrame]
	// contains filtered or unexported fields
}

type Engine struct {
	Config *Config
	APIUri string
	WSUri  string
}

type Metadata = structpb.Struct

type RemoteSession interface {
	GetId() string
	GetSubject() string
	GetName() string
	GetMetadata() *Metadata
	OnMessage(f func(msg *omega.TransitFrame))
	SendMessage(message string) SendFuture
	Fetch() SendFuture
	Close() concurrent.Future
}

type SendFuture interface {
	concurrent.CastFuture[*omega.TransitFrame]
	SentTransitFrame() *omega.TransitFrame
}

type Session interface {
	RemoteSession
	GetRemoteSession(sessionId string) concurrent.CastFuture[RemoteSession]
	Ch() channel.Channel
	GetEngine() *Engine
	SetName(name string) SendFuture
	SetMetadata(metadata *Metadata) SendFuture
	Send(tf *omega.TransitFrame) SendFuture
	SendRequest(data omega.TransitFrameData) SendFuture
	Ping() SendFuture
	Hello() SendFuture
	ServerTime() SendFuture
	OnClosed(f func())
	OnRead(f func(tf *omega.TransitFrame))
	OnError(f func(err error))
	IsClosed() bool
}