ccbroker

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

type BridgeResponse struct {
	WorkerJWT   string `json:"worker_jwt"`
	APIBaseURL  string `json:"api_base_url"`
	ExpiresIn   int    `json:"expires_in"`
	WorkerEpoch int    `json:"worker_epoch"`
}

type CCWorker struct {
	ID          string
	Process     *exec.Cmd
	SessionID   string
	WorkspaceID string
	Status      string // "running" | "done" | "failed"
	StartedAt   time.Time
	// contains filtered or unexported fields
}

type Config struct {
	Port                string
	DatabaseURL         string
	JWTSecret           []byte
	LogLevel            slog.Level
	ExecutorRegistryURL string
	AgentserverURL      string
	OpenVikingURL       string
	OpenVikingAPIKey    string
	IMBridgeURL         string
	IMBridgeSecret      string
}

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

type EventBatchItem struct {
	Payload   json.RawMessage `json:"payload"`
	Ephemeral bool            `json:"ephemeral"`
}

type EventBatchRequest struct {
	WorkerEpoch int              `json:"worker_epoch"`
	Events      []EventBatchItem `json:"events"`
}

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

type HeartbeatRequest struct {
	WorkerEpoch int `json:"worker_epoch"`
}

type InsertedEvent struct {
	SeqNum  int64
	EventID string
}

type InternalEventBatchItem struct {
	Payload      json.RawMessage `json:"payload"`
	IsCompaction bool            `json:"is_compaction"`
	AgentID      string          `json:"agent_id,omitempty"`
}

type InternalEventBatchRequest struct {
	WorkerEpoch int                      `json:"worker_epoch"`
	Events      []InternalEventBatchItem `json:"events"`
}

type InternalEventInput struct {
	EventType    string
	Payload      json.RawMessage
	IsCompaction bool
	AgentID      string
}

type JSONRPCRequest struct {
	JSONRPC string           `json:"jsonrpc"`
	ID      *json.RawMessage `json:"id,omitempty"`
	Method  string           `json:"method"`
	Params  json.RawMessage  `json:"params,omitempty"`
}

type JSONRPCResponse struct {
	JSONRPC string           `json:"jsonrpc"`
	ID      *json.RawMessage `json:"id,omitempty"`
	Result  interface{}      `json:"result,omitempty"`
	Error   *RPCError        `json:"error,omitempty"`
}

type MCPContentBlock struct {
	Type string `json:"type"`
	Text string `json:"text,omitempty"`
}

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

type MCPToolCallParams struct {
	Name      string                 `json:"name"`
	Arguments map[string]interface{} `json:"arguments,omitempty"`
}

type MCPToolDef struct {
	Name        string      `json:"name"`
	Description string      `json:"description,omitempty"`
	InputSchema interface{} `json:"inputSchema"`
}

type MCPToolResult struct {
	Content []MCPContentBlock `json:"content"`
	IsError bool              `json:"isError,omitempty"`
}

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"`
}

type RPCError struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

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"`
	Payload     json.RawMessage `json:"payload"`
	CreatedAt   string          `json:"created_at"`
}

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

type ToolRouterConfig struct {
	ExecutorRegistryURL string
	AgentserverURL      string
	IMBridgeURL         string
	IMBridgeSecret      string
	WorkspaceDir        string
	SessionID           string
	WorkspaceID         string
	IMChannelID         string
	IMUserID            string
}

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

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

type Worker struct {
	SessionID             string
	Epoch                 int
	State                 string
	ExternalMetadata      json.RawMessage
	RequiresActionDetails json.RawMessage
	LastHeartbeatAt       *time.Time
	RegisteredAt          time.Time
}

type WorkerJWTClaims struct {
	SessionID   string `json:"sid"`
	WorkspaceID string `json:"wid"`
	Epoch       int    `json:"epoch"`
	Exp         int64  `json:"exp"`
}

type WorkerStateRequest struct {
	WorkerStatus          string          `json:"worker_status"`
	WorkerEpoch           int             `json:"worker_epoch"`
	ExternalMetadata      json.RawMessage `json:"external_metadata,omitempty"`
	RequiresActionDetails json.RawMessage `json:"requires_action_details,omitempty"`
}