server

Documentation

Index

• type GroupedMessage
• type Server
  • func New(agg *message.Aggregator, repoURLs map[string]string) (*Server, error)
  • func (s *Server) Handler() http.Handler
  • func (s *Server) Start(ctx context.Context) error
• type WorkspaceInfo

Types

type GroupedMessage

type GroupedMessage struct {
	message.Message
	IsGroupStart bool // True if this is the first message in a group from this sender
	IsGroupEnd   bool // True if this is the last message in a group from this sender
}

GroupedMessage wraps a message with grouping metadata for the UI.

type Server

type Server struct {

	// RepoURLs maps workspace names (e.g., "mc-agent-chat") to GitHub URLs.
	RepoURLs map[string]string
	// contains filtered or unexported fields
}

Server handles HTTP requests for the chat UI.

func New

func New(agg *message.Aggregator, repoURLs map[string]string) (*Server, error)

New creates a new server with the given message aggregator. repoURLs maps workspace names (e.g., "mc-agent-chat") to GitHub URLs.

func (*Server) Handler

func (s *Server) Handler() http.Handler

Handler returns an http.Handler for the server.

func (*Server) Start

func (s *Server) Start(ctx context.Context) error

Start begins broadcasting messages from the aggregator to SSE subscribers.

type WorkspaceInfo

type WorkspaceInfo struct {
	Name          string
	LatestMsgTime int64 // Unix milliseconds for JavaScript compatibility
	MessageCount  int
}

WorkspaceInfo contains workspace metadata for the UI.