websocket

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

type ConnDeps struct {
	Conversations coreconv.Store
	Turns         *turnqueue.Registry
	// Turner runs one conversation turn. An interface so this package does not
	// depend on the service that assembles agents, models, and tools.
	Turner   Turner
	Registry *ConnRegistry
	// CORSOrigin is checked on the upgrade. Empty or "*" accepts any origin,
	// which is what a deployment serving Portal from the same host has.
	CORSOrigin string
}

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

type ConversationCreate struct {
	Channel string `json:"channel,omitempty"`
	Message string `json:"message"`
}

type ConversationCreated struct {
	ConversationID string `json:"conversation_id"`
}

type ConversationError struct {
	ConversationID string `json:"conversation_id,omitempty"`
	Error          string `json:"error"`
	// Code is an optional machine-readable reason. Empty means the turn itself failed.
	Code string `json:"code,omitempty"`
}

type ConversationMessage struct {
	ConversationID string `json:"conversation_id"`
	Content        string `json:"content"`
}

type Envelope struct {
	Type    string          `json:"type"`
	Payload json.RawMessage `json:"payload"`
}

type MessageCompleted struct {
	ConversationID string `json:"conversation_id"`
	// QueuedRemaining is how many messages are still waiting for their turn. A
	// client uses it to decide whether the conversation is idle or merely between
	// turns.
	QueuedRemaining int `json:"queued_remaining,omitempty"`
}

type MessageDelta struct {
	ConversationID string `json:"conversation_id"`
	Delta          string `json:"delta"`
}

type MessageDequeued struct {
	ConversationID string `json:"conversation_id"`
	Content        string `json:"content"`
}

type MessageQueued struct {
	ConversationID string `json:"conversation_id"`
	Content        string `json:"content"`
	// Position is 1-based: 1 is the next turn to run after the current one.
	Position int `json:"position"`
}

type StreamHub interface {
	// Append adds a delta to the buffer and broadcasts to all subscribers for that task.
	Append(taskID, delta string)
	// Buffer returns the current buffered content for the task. Empty string if task has no buffer or was Done.
	Buffer(taskID string) string
	// Done marks the task's current run as finished; sends StreamEventDone to subscribers and clears state.
	Done(taskID string)
	// Subscribe returns a channel of deltas (and finally StreamEventDone) for the task. unsub must be called when done.
	Subscribe(taskID string) (events <-chan string, unsub func())
}

type SubscribeTask struct {
	TaskID string `json:"task_id"`
}

type SystemError struct {
	Error string `json:"error"`
}

type TaskStatusChanged struct {
	TaskID string `json:"task_id"`
	Status string `json:"status"`
	Title  string `json:"title,omitempty"`
}

type TaskStreamDelta struct {
	TaskID string `json:"task_id"`
	Delta  string `json:"delta"`
}

type TaskStreamDone struct {
	TaskID string `json:"task_id"`
}

type Turner interface {
	HandleTurn(ctx context.Context, cmd conversation.HandleTurnCmd) (conversation.ConversationResult, error)
}

type UnsubscribeTask struct {
	TaskID string `json:"task_id"`
}