ccbroker

type AgentTurn struct {
	ID          string
	SessionID   string
	WorkspaceID string
	State       string // queued|running|done|cancelled|failed
	UserEventID string
	UserMessage string
	Metadata    json.RawMessage
	IMChannelID sql.NullString
	IMUserID    sql.NullString
	ErrorMsg    sql.NullString
	EnqueuedAt  time.Time
	StartedAt   sql.NullTime
	FinishedAt  sql.NullTime
}

type Config struct {
	Port                string
	DatabaseURL         string
	LogLevel            slog.Level
	ExecutorRegistryURL string
	AgentserverURL      string
	S3Endpoint          string
	S3Region            string
	S3Bucket            string
	S3AccessKeyID       string
	S3SecretAccessKey   string
	S3PathStyle         bool
	IMBridgeURL         string
	IMBridgeSecret      string

	// Phase 1 Task 13: turn-finished callback to agentserver.
	AgentserverInternalURL string // env: AGENTSERVER_INTERNAL_URL
	InternalAPISecret      string // env: INTERNAL_API_SECRET

	// LLM proxy URL: cc-broker injects this as ANTHROPIC_BASE_URL on the
	// spawned Claude CLI so LLM traffic is authenticated against llmproxy
	// using the per-workspace proxy token (not directly to upstream).
	LLMProxyURL string // env: CCBROKER_LLMPROXY_URL
}

type EventInput struct {
	EventID   string
	Payload   json.RawMessage
	Ephemeral bool
}

type InsertedEvent struct {
	SeqNum  int64
	EventID string
}

type ProcessTurnRequest struct {
	SessionID   string       `json:"session_id"`
	WorkspaceID string       `json:"workspace_id"`
	UserMessage string       `json:"user_message"`
	IMChannelID string       `json:"im_channel_id,omitempty"`
	IMUserID    string       `json:"im_user_id,omitempty"`
	Metadata    TurnMetadata `json:"metadata,omitempty"`
	TurnID      string       `json:"turn_id,omitempty"` // optional caller-supplied id
}

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

type SSESubscriber struct {
	Ch chan *StreamClientEvent
	// contains filtered or unexported fields
}

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

type Session struct {
	ID          string    `json:"id"`
	WorkspaceID string    `json:"workspace_id"`
	Title       string    `json:"title,omitempty"`
	Status      string    `json:"status"`
	Epoch       int       `json:"epoch"`
	ExternalID  *string   `json:"external_id,omitempty"`
	Source      string    `json:"source,omitempty"`
	CreatedAt   time.Time `json:"created_at"`
}

type SessionEvent struct {
	ID        int64           `json:"id"`
	SessionID string          `json:"session_id"`
	EventID   string          `json:"event_id"`
	EventType string          `json:"event_type"`
	Source    string          `json:"source"`
	Epoch     int             `json:"epoch"`
	Payload   json.RawMessage `json:"payload"`
	Ephemeral bool            `json:"ephemeral"`
	CreatedAt time.Time       `json:"created_at"`
}

type Store struct {
	*sql.DB
}

type StreamClientEvent struct {
	EventID     string          `json:"event_id"`
	SequenceNum int64           `json:"sequence_num"`
	EventType   string          `json:"event_type"`
	Source      string          `json:"source"`
	TurnID      string          `json:"turn_id,omitempty"`
	Payload     json.RawMessage `json:"payload"`
	CreatedAt   string          `json:"created_at"`
}

type TurnEvent struct {
	SeqNum    int64
	EventID   string
	EventType string
	Payload   json.RawMessage
	CreatedAt time.Time
}

type TurnMetadata struct {
	ChannelType         string `json:"channel_type,omitempty"`
	CreatorUserID       string `json:"creator_user_id,omitempty"`
	PermissionMode      string `json:"permission_mode,omitempty"`
	Model               string `json:"model,omitempty"`
	PreferredExecutorID string `json:"preferred_executor_id,omitempty"`
	TurnKind            string `json:"turn_kind,omitempty"`
}