messaging

type ActiveAgent struct {
	ID           string `json:"id"`
	Label        string `json:"label"`
	MessagesSent int    `json:"messages_sent"`
	MessagesRecv int    `json:"messages_recv"`
	LastActivity string `json:"last_activity"`
}

type AgentInfo struct {
	ID         string `json:"id"`
	LastActive int64  `json:"last_active,omitempty"`
	Status     string `json:"status,omitempty"`
	Label      string `json:"label,omitempty"`
}

type AgentStats struct {
	AgentID          string        `json:"agent_id"`
	Status           string        `json:"status"` // "active", "idle", "pending"
	ThreadCount      int           `json:"thread_count"`
	UnreadMessages   int           `json:"unread_messages"`
	PendingApprovals int           `json:"pending_approvals"`
	RunningProcesses int           `json:"running_processes"`
	LastActivity     string        `json:"last_activity,omitempty"`
	Threads          []ThreadStats `json:"threads,omitempty"`
}

type AggregateStats struct {
	TotalAgents      int            `json:"total_agents"`
	ActiveAgents     int            `json:"active_agents"`
	IdleAgents       int            `json:"idle_agents"`
	PendingApprovals int            `json:"pending_approvals"`
	RunningProcesses int            `json:"running_processes"`
	TotalThreads     int            `json:"total_threads"`
	Execution        ExecutionStats `json:"execution"`
}

type AggregatedMetrics struct {
	ScopeType     string  `json:"scope_type"`
	ScopeID       string  `json:"scope_id"`
	TotalRuns     int     `json:"total_runs"`
	TotalTokens   int     `json:"total_tokens"`
	TotalCost     float64 `json:"total_cost"` // Dollars (cents / 100)
	TotalDuration int     `json:"total_duration_ms"`
	TotalFiles    int     `json:"total_files_modified"`
	AvgTokens     float64 `json:"avg_tokens_per_run"`
	AvgCost       float64 `json:"avg_cost_per_run"`
	AvgDuration   float64 `json:"avg_duration_per_run"`
	PendingTasks  int     `json:"pending_tasks"` // Number of currently running/pending tasks
}

type Approval struct {
	ID              string    `json:"id"`
	ThreadID        string    `json:"thread_id"`
	ThreadTitle     string    `json:"thread_title,omitempty"` // Title of the associated thread
	InstanceID      string    `json:"instance_id"`
	CreatedAt       time.Time `json:"created_at"`
	EffectDeltaJSON string    `json:"effect_delta_json"`
	Proposal        string    `json:"proposal"`
	Impact          string    `json:"impact"`
	EstimatedCost   float64   `json:"estimated_cost"`
	Status          string    `json:"status"`
	ReviewedBy      string    `json:"reviewed_by,omitempty"`
	ReviewedAt      time.Time `json:"reviewed_at,omitempty"`
	ReviewNotes     string    `json:"review_notes,omitempty"`
	CapabilityToken string    `json:"capability_token,omitempty"`
	TokenExpiresAt  time.Time `json:"token_expires_at,omitempty"`
}

type ApprovalHistoryEntry struct {
	ID              string   `json:"id"`
	ApprovalID      string   `json:"approval_id"`
	ThreadID        string   `json:"thread_id"`
	AgentID         string   `json:"agent_id"`
	Action          string   `json:"action"` // created, approved, rejected, expired
	Actor           string   `json:"actor"`
	Proposal        string   `json:"proposal,omitempty"`
	Impact          string   `json:"impact,omitempty"`
	EstimatedCost   *float64 `json:"estimated_cost,omitempty"`
	CapabilityToken string   `json:"capability_token,omitempty"`
	CreatedAt       int64    `json:"created_at"`
}

type Badge struct {
	Type  string `json:"type"`  // "unread", "pending", "running"
	Count int    `json:"count"` // Number of items
}

type CapabilityToken struct {
	ThreadID   string    `json:"thread_id"`
	InstanceID string    `json:"instance_id"`
	ApprovalID string    `json:"approval_id"`
	Effects    string    `json:"effects"` // JSON-encoded EffectDelta
	IssuedAt   time.Time `json:"issued_at"`
	ExpiresAt  time.Time `json:"expires_at"`
	Signature  string    `json:"signature"`
}

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

type CompatEvidence struct {
	FailingExports     []string `json:"failing_exports,omitempty"`
	ContractViolations []string `json:"contract_violations,omitempty"`
	LockfileSnapshot   string   `json:"lockfile_snapshot,omitempty"`
	Summary            string   `json:"summary,omitempty"`
}

type Config struct {
	GitHub     *GitHubConfig         `yaml:"github"`
	Embeddings *EmbeddingsYAMLConfig `yaml:"embeddings"`
	PubSub     *PubSubConfig         `yaml:"pubsub"`
}

type CreateIssueInput struct {
	Title     string   // Issue title (will be prefixed with [from])
	Body      string   // Issue body content
	FromAgent string   // Agent name for attribution
	Category  string   // bug, feature, or general
	Repo      string   // Optional repo override (owner/repo)
	Labels    []string // Additional labels
}

type DuplicateGroup struct {
	Representative InboxMessage   `json:"representative"` // Oldest message in group (kept)
	Duplicates     []InboxMessage `json:"duplicates"`     // Similar messages (to be marked)
	MinScore       float64        `json:"min_score"`      // Minimum similarity in group
	ScoreKind      string         `json:"score_kind"`     // "simhash" or "embedding"
}

type EffectDelta struct {
	CapType     string   `json:"cap_type"`     // e.g., "FS", "IO", "Net"
	Paths       []string `json:"paths"`        // e.g., ["src/", "docs/"]
	BudgetDelta float64  `json:"budget_delta"` // e.g., 0.50 (50 cents)
}

type EmbedConfig struct {
	Provider string            `yaml:"provider"` // "ollama", "openai", "gemini", or "none"
	Ollama   OllamaConfig      `yaml:"ollama"`
	OpenAI   OpenAIEmbedConfig `yaml:"openai"`
	Gemini   GeminiEmbedConfig `yaml:"gemini"`
}

type Embedder interface {
	Embed(text string) ([]float32, error)
	EmbedBatch(texts []string) ([][]float32, error)
	Dimension() int
	ModelName() string
}

type EmbeddingsYAMLConfig struct {
	// Provider: "ollama", "openai", "gemini", or "none"
	Provider string `yaml:"provider"`

	// Ollama-specific settings
	Ollama struct {
		Model     string `yaml:"model"`
		Endpoint  string `yaml:"endpoint"`
		Dimension int    `yaml:"dimension"`
		Timeout   string `yaml:"timeout"` // e.g., "30s"
		BatchSize int    `yaml:"batch_size"`
	} `yaml:"ollama"`

	// OpenAI-specific settings (M-SEMANTIC-ENVELOPE)
	OpenAI struct {
		APIKey    string `yaml:"api_key"`   // Falls back to OPENAI_API_KEY env
		Model     string `yaml:"model"`     // e.g. "text-embedding-3-small"
		Dimension int    `yaml:"dimension"` // 0 = model default
		Timeout   string `yaml:"timeout"`
	} `yaml:"openai"`

	// Gemini-specific settings (M-SEMANTIC-ENVELOPE)
	Gemini struct {
		APIKey    string `yaml:"api_key"`   // Falls back to GOOGLE_API_KEY env
		Model     string `yaml:"model"`     // e.g. "text-embedding-004"
		Dimension int    `yaml:"dimension"` // 0 = model default
		Timeout   string `yaml:"timeout"`
	} `yaml:"gemini"`

	// Search behavior
	Search struct {
		DefaultMode       string  `yaml:"default_mode"` // "simhash" or "neural"
		AutoEmbedOnInsert bool    `yaml:"auto_embed_on_insert"`
		SimhashThreshold  float64 `yaml:"simhash_threshold"`
		NeuralThreshold   float64 `yaml:"neural_threshold"`
	} `yaml:"search"`
}

type Envelope struct {
	Slots map[string]*EnvelopeVector `json:"slots"`
}

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

type EnvelopeOption func(b *EnvelopeBuilder)

type EnvelopeVector struct {
	Vector    []float32 `json:"vector"`
	Model     string    `json:"model"`     // e.g. "ollama:nomic-embed-text"
	Dimension int       `json:"dimension"` // e.g. 768
}

type ExecutionMetadata struct {
	Success             bool     `json:"success"`
	DurationMS          int      `json:"duration_ms"`
	NumTurns            int      `json:"num_turns"`
	Cost                float64  `json:"cost"`
	SessionID           string   `json:"session_id"`
	InputTokens         int      `json:"input_tokens"`
	OutputTokens        int      `json:"output_tokens"`
	CacheReadTokens     int      `json:"cache_read_tokens"`
	CacheCreationTokens int      `json:"cache_creation_tokens"`
	FilesCreatedCount   int      `json:"files_created_count"`
	FilesCreated        []string `json:"files_created"`
	Workspace           string   `json:"workspace"`
}

type ExecutionStats struct {
	TotalExecutions        int     `json:"total_executions"`
	SuccessfulExecutions   int     `json:"successful_executions"`
	FailedExecutions       int     `json:"failed_executions"`
	TotalDurationMS        int64   `json:"total_duration_ms"`
	TotalCost              float64 `json:"total_cost"`
	TotalInputTokens       int     `json:"total_input_tokens"`
	TotalOutputTokens      int     `json:"total_output_tokens"`
	TotalCacheReadTokens   int     `json:"total_cache_read_tokens"`
	TotalCacheCreateTokens int     `json:"total_cache_create_tokens"`
	TotalFilesCreated      int     `json:"total_files_created"`
}

type GeminiEmbedConfig struct {
	APIKey    string        `yaml:"api_key"`   // Defaults to GOOGLE_API_KEY env
	Model     string        `yaml:"model"`     // e.g. "text-embedding-004"
	Dimension int           `yaml:"dimension"` // Output dimension (0 = model default)
	Timeout   time.Duration `yaml:"timeout"`
}

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

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

type GitHubComment struct {
	ID        int64  `json:"id"`
	Body      string `json:"body"`
	Author    string `json:"author"`
	CreatedAt string `json:"createdAt"`
}

type GitHubConfig struct {
	// DefaultRepo is the default repository for --github flag (e.g., "sunholo-data/ailang")
	DefaultRepo string `yaml:"default_repo"`

	// InboxRepos maps inbox names (or prefixes) to specific GitHub repositories.
	// This allows messages sent to different inboxes to create issues in the correct repo.
	// Supports exact matches and prefix matches (e.g., "pkg:" matches "pkg:sunholo/auth").
	InboxRepos map[string]string `yaml:"inbox_repos"`

	// ExpectedUser is the expected GitHub username (must match gh auth status)
	// This prevents accidentally creating issues under the wrong account
	ExpectedUser string `yaml:"expected_user"`

	// CreateLabels are labels to add when creating issues
	CreateLabels []string `yaml:"create_labels"`

	// WatchLabels are labels to watch for incoming messages (import)
	WatchLabels []string `yaml:"watch_labels"`

	// AutoImport enables automatic import on session start (default: true)
	AutoImport *bool `yaml:"auto_import"`
}

type GitHubIssue struct {
	Number    int      `json:"number"`
	Title     string   `json:"title"`
	Body      string   `json:"body"`
	State     string   `json:"state"`
	Labels    []string `json:"labels"`
	CreatedAt string   `json:"createdAt"`
	Author    string   `json:"author"`
	URL       string   `json:"url"`
}

type HierarchyNode struct {
	Type     string          `json:"type"`               // "root", "agent", "thread"
	ID       string          `json:"id"`                 // Unique identifier
	Label    string          `json:"label"`              // Display label
	Status   string          `json:"status,omitempty"`   // "active", "idle", "pending"
	Badges   []Badge         `json:"badges,omitempty"`   // Status badges
	Children []HierarchyNode `json:"children,omitempty"` // Child nodes
}

type HierarchyResponse struct {
	Root      HierarchyNode  `json:"root"`
	Aggregate AggregateStats `json:"aggregate"`
}

type InboxAddress struct {
	Type InboxAddressType
	Name string // The part after the prefix (e.g., "sunholo/auth" from "pkg:sunholo/auth")
	Raw  string // Original full address string
}

type InboxAddressType string

type InboxListOptions struct {
	Inbox       string // Filter by inbox name (empty = all)
	Status      string // Filter by status (empty = all)
	UnreadOnly  bool   // Only unread messages
	FromAgent   string // Filter by sender
	Limit       int    // Max results (0 = no limit)
	IncludeRead bool   // Include read messages (default: true unless UnreadOnly)
	Collapsed   bool   // Hide messages where dup_of IS NOT NULL (semantic dedup)
	DupOf       string // Only messages that are duplicates of this ID
	StartDate   string // Filter messages created >= this date (YYYY-MM-DD)
	EndDate     string // Filter messages created <= this date (YYYY-MM-DD)
}

type InboxMessage struct {
	ID                 string     `json:"id"`
	MessageID          string     `json:"message_id"`
	CorrelationID      string     `json:"correlation_id,omitempty"`
	FromAgent          string     `json:"from_agent"`
	ToInbox            string     `json:"to_inbox"`
	MessageType        string     `json:"message_type"`
	Title              string     `json:"title"`
	Payload            string     `json:"payload,omitempty"`
	Category           string     `json:"category,omitempty"`             // bug, feature, general (for GitHub sync)
	GitHubIssue        *int       `json:"github_issue,omitempty"`         // GitHub issue number
	GitHubRepo         string     `json:"github_repo,omitempty"`          // GitHub repo (owner/repo)
	Simhash            *int64     `json:"simhash,omitempty"`              // SimHash for semantic search (v1.2.0)
	DupOf              string     `json:"dup_of,omitempty"`               // ID of message this is a duplicate of (v1.2.0)
	Embedding          string     `json:"embedding,omitempty"`            // JSON-encoded float32 array (v1.3.0)
	EmbeddingModel     string     `json:"embedding_model,omitempty"`      // e.g., "ollama:nomic-embed-text" (v1.3.0)
	EmbeddingUpdatedAt *int64     `json:"embedding_updated_at,omitempty"` // Unix millis (v1.3.0)
	ParentTaskID       string     `json:"parent_task_id,omitempty"`       // Parent task for hierarchy (v1.5.0, M-UNIFIED-AI-CONTROL-PLANE)
	ChainID            string     `json:"chain_id,omitempty"`             // Execution chain ID for unified hierarchy (M-CHAINS-SIMPLIFY)
	Iteration          int        `json:"iteration,omitempty"`            // Iteration number for feedback loops (M-TASK-HIERARCHY)
	Envelope           *Envelope  `json:"envelope,omitempty"`             // Multi-aspect semantic embeddings (v1.8.0, M-SEMANTIC-ENVELOPE)
	Status             string     `json:"status"`
	CreatedAt          time.Time  `json:"created_at"`
	ReadAt             *time.Time `json:"read_at,omitempty"`
	ExpiresAt          *time.Time `json:"expires_at,omitempty"`
}

type InstanceHistoryEntry struct {
	ID            string `json:"id"`
	AgentID       string `json:"agent_id"`
	InstanceID    string `json:"instance_id"`
	StartedAt     int64  `json:"started_at"`
	EndedAt       *int64 `json:"ended_at,omitempty"`
	ExitCode      *int   `json:"exit_code,omitempty"`
	TotalTokens   int    `json:"total_tokens"`
	TotalCostCent int    `json:"total_cost_cents"`
	ThreadCount   int    `json:"thread_count"`
}

type Message struct {
	ID            string    `json:"id"`
	ThreadID      string    `json:"thread_id"`
	MessageSeq    int       `json:"message_seq"`
	CreatedAt     time.Time `json:"created_at"`
	FromType      string    `json:"from_type"`
	FromID        string    `json:"from_id"`
	ToType        string    `json:"to_type"`
	ToID          string    `json:"to_id"`
	Kind          string    `json:"kind"`
	Content       string    `json:"content"`
	MetadataJSON  string    `json:"metadata_json"`
	DeliveryState string    `json:"delivery_state"`
	BusinessState string    `json:"business_state"`
}

type MessageExecutionStats struct {
	DurationMS   int      `json:"duration_ms"`
	InputTokens  int      `json:"input_tokens"`
	OutputTokens int      `json:"output_tokens"`
	CostCents    int      `json:"cost_cents"`
	FilesCreated []string `json:"files_created"`
}

type MessageFlowEdge struct {
	FromAgent    string `json:"from_agent"`
	ToInbox      string `json:"to_inbox"`
	MessageCount int    `json:"message_count"`
	LastActivity string `json:"last_activity,omitempty"`
}

type MessageStore interface {
	// Lifecycle
	Close() error

	CreateThread(title, createdByType, createdByID, targetAgent string) (*Thread, error)
	CreateThreadWithWorkspace(title, createdByType, createdByID, targetAgent, workspace string) (*Thread, error)
	GetOrCreateThreadWithWorkspace(title, createdByType, createdByID, targetAgent, workspace string) (*Thread, bool, error)
	GetThreadByTitleAndAgent(title, targetAgent string) (*Thread, error)
	GetThread(threadID string) (*Thread, error)
	SetThreadWorkspace(threadID, workspace string) error
	GetThreadWorkspace(threadID string) (string, error)
	SetThreadTargetAgent(threadID, targetAgent string) error
	UpdateThreadTitle(threadID, title string) error
	DeleteThread(threadID string) error
	GetThreadsByStatus(status string, limit int) ([]Thread, error)
	NewThreadFilter(status, workspace string, limit int) ThreadFilter
	GetThreadsFiltered(filter ThreadFilter) ([]Thread, error)
	GetDistinctWorkspaces() ([]string, error)
	GetThreadAggregateStats() (*ThreadAggregateStats, error)

	GetMessages(toType, toID string, deliveryState string) ([]Message, error)
	MarkAsAcked(messageID string) error
	MarkAsUnacked(messageID string) error
	ClaimMessage(messageID, claimedBy string) error
	MarkAllAsAcked(toType, toID string) (int64, error)
	CreateMessage(threadID, fromType, fromID, toType, toID, kind, content, metadataJSON string) (*Message, error)
	GetMessagesFromSeq(threadID string, fromSeq int, limit int) ([]Message, error)
	Subscribe(instanceID, threadID string) error
	UpdateAckSeq(instanceID, threadID string, ackSeq int) error

	InsertInboxMessage(msg *InboxMessage) error
	InsertInboxMessageWithContext(ctx context.Context, msg *InboxMessage) error
	ListInboxMessages(opts InboxListOptions) ([]InboxMessage, error)
	GetInboxMessage(id string) (*InboxMessage, error)
	FindMessageByPrefix(prefix string) (string, error)
	MarkInboxMessageRead(id string) error
	MarkInboxMessageUnread(id string) error
	MarkAllInboxMessagesRead(inbox string) (int64, error)
	ForwardInboxMessage(id string, toInbox string) error
	InboxMessageExistsByGitHub(repo string, issueNumber int) (bool, error)
	InboxMessageExistsByTitle(inbox string, title string) (string, error)
	UpdateInboxMessageGitHub(messageID string, issueNumber int, repo string) error
	CleanupInboxMessages(olderThan time.Duration, expiredOnly bool) (int64, error)
	CountInboxMessagesByStatus(inbox string) (map[string]int64, error)
	GetMessageFlowEdges() ([]MessageFlowEdge, error)
	GetActiveAgents() ([]ActiveAgent, error)

	CreateApproval(threadID, instanceID string, effectDelta *EffectDelta, proposal, impact string, estimatedCost float64) (*Approval, error)
	GetApproval(approvalID string) (*Approval, error)
	GetApprovalsByStatus(status string, limit int) ([]Approval, error)
	ApproveApproval(approvalID, reviewedBy string, reviewNotes string, tokenDuration time.Duration) error
	RejectApproval(approvalID, reviewedBy string, reviewNotes string) error

	RecordApprovalHistory(approvalID, threadID, agentID, action, actor, proposal, impact string, estimatedCost *float64, capabilityToken string) error
	GetApprovalHistory(threadID string, limit int) ([]ApprovalHistoryEntry, error)
	RecordInstanceStart(agentID, instanceID string) error
	RecordInstanceEnd(instanceID string, exitCode int, totalTokens, totalCostCents, threadCount int) error
	GetInstanceHistory(agentID string, limit int) ([]InstanceHistoryEntry, error)
	CleanupOldHistory(retentionDays int) (int64, int64, error)

	SemanticSearch(opts SearchOptions) ([]SearchHit, error)
	FindSimilar(msgID string, threshold float64, limit int) ([]SearchHit, error)
	FindDuplicates(inbox string, threshold float64) ([]DuplicateGroup, error)
	ApplyDuplicates(groups []DuplicateGroup, runID string) error
	ClearDuplicateMarker(msgID string) error
	UpdateMessageEmbedding(msgID string, embedding []float32, model string) error
	UpdateMessageEnvelope(msgID string, env *Envelope, overwrite bool) error

	RecordMetrics(threadID, agentID string, stats *MessageExecutionStats) error
	GetMetrics(scopeType, scopeID string) (*AggregatedMetrics, error)
	GetGlobalMetrics() (*AggregatedMetrics, error)
	GetAgentMetrics(agentID string) (*AggregatedMetrics, error)
	GetThreadMetrics(threadID string) (*AggregatedMetrics, error)
	GetMetricsTrends(scopeType, scopeID, period string, limit int) ([]map[string]interface{}, error)

	GetAggregatedExecutionStats() (*ExecutionStats, error)
	GetExecutionStatsByThread(threadID string) (*ExecutionStats, error)
	GetHierarchy() (*HierarchyResponse, error)
	GetAgentStats(agentID string) (*AgentStats, error)
	GetKnownAgents() ([]AgentInfo, error)

	RegisterAgent(agentID, label, status string) error
	UpdateAgentStatus(agentID, status string) error
	RecordAgentInstance(agentID, instanceID string) error
}

type OllamaConfig struct {
	Model     string        `yaml:"model"`
	Endpoint  string        `yaml:"endpoint"`
	Dimension int           `yaml:"dimension"`
	Timeout   time.Duration `yaml:"timeout"`
	BatchSize int           `yaml:"batch_size"`
}

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

type OpenAIEmbedConfig struct {
	APIKey    string        `yaml:"api_key"`   // Defaults to OPENAI_API_KEY env
	Model     string        `yaml:"model"`     // e.g. "text-embedding-3-small"
	Dimension int           `yaml:"dimension"` // Output dimension (0 = model default)
	Timeout   time.Duration `yaml:"timeout"`
}

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

type PackageMessageEnvelope struct {
	Schema    string             `json:"schema"`
	MessageID string             `json:"message_id,omitempty"`
	Kind      PackageMessageKind `json:"kind"`
	From      string             `json:"from"`
	To        []string           `json:"to"`
	Timestamp time.Time          `json:"timestamp"`
	Package   PackageRef         `json:"package"`

	// Optional fields
	Summary           string          `json:"summary,omitempty"`
	RecommendedAction string          `json:"recommended_action,omitempty"`
	Refs              *PackageRefs    `json:"refs,omitempty"`
	Status            string          `json:"status,omitempty"`
	Supersedes        string          `json:"supersedes,omitempty"`
	RelatedMessages   []string        `json:"related_messages,omitempty"`
	Evidence          *CompatEvidence `json:"evidence,omitempty"`
	BlockReason       string          `json:"block_reason,omitempty"`
}

type PackageMessageKind string

type PackageMessageStats struct {
	TotalMessages     int            `json:"total_messages"`
	ByKind            map[string]int `json:"by_kind"`
	ByStatus          map[string]int `json:"by_status"`
	OpenUpgrades      int            `json:"open_upgrades"`
	BlockedMigrations int            `json:"blocked_migrations"`
	LastActivity      *time.Time     `json:"last_activity,omitempty"`
}

type PackageRef struct {
	Name              string   `json:"name"`
	FromVersion       string   `json:"from_version,omitempty"`
	ToVersion         string   `json:"to_version,omitempty"`
	FromInterfaceHash string   `json:"from_interface_hash,omitempty"`
	ToInterfaceHash   string   `json:"to_interface_hash,omitempty"`
	FromContentHash   string   `json:"from_content_hash,omitempty"`
	ToContentHash     string   `json:"to_content_hash,omitempty"`
	ChangeClass       string   `json:"change_class,omitempty"`
	EffectDelta       []string `json:"effect_delta,omitempty"`
	Breaking          *bool    `json:"breaking,omitempty"`

	// For effect-widening-warning
	PrevEffectCeiling []string `json:"prev_effect_ceiling,omitempty"`
	NewEffectCeiling  []string `json:"new_effect_ceiling,omitempty"`

	// For contract-regression
	AffectedExports []string `json:"affected_exports,omitempty"`
	PrevContract    string   `json:"prev_contract,omitempty"`
	NewContract     string   `json:"new_contract,omitempty"`

	// For compatibility-report
	Result          string `json:"result,omitempty"` // "pass", "fail", "partial"
	TargetWorkspace string `json:"target_workspace,omitempty"`
}

type PackageRefs struct {
	PackageURL   string `json:"package_url,omitempty"`
	ReleaseNotes string `json:"release_notes,omitempty"`
	LockfileRef  string `json:"lockfile_ref,omitempty"`
}

type PackageVersionInfo struct {
	Name          string
	Version       string
	InterfaceHash string
	ContentHash   string
	Effects       []string
	Exports       []string
}

type PubSubConfig struct {
	Enabled            bool   `yaml:"enabled"`
	ProjectID          string `yaml:"project_id"`          // Defaults to AILANG_CLOUD_PROJECT
	TopicPrefix        string `yaml:"topic_prefix"`        // Defaults to "ailang"
	LaptopSubscription bool   `yaml:"laptop_subscription"` // Create pull subscription for laptop
}

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

type SearchHit struct {
	Message   InboxMessage `json:"message"`
	Score     float64      `json:"score"`      // Similarity score (0.0-1.0)
	ScoreKind string       `json:"score_kind"` // "simhash", "embedding", or "envelope:<slot>"
}

type SearchOptions struct {
	Query         string   // Natural language query
	Threshold     float64  // Minimum similarity (0.0-1.0), default 0.70
	Limit         int      // Max results, default 20
	MaxScan       int      // Max messages to scan, default 1000
	Inbox         string   // Filter by inbox (optional)
	UseNeural     bool     // Use embedding search via Ollama
	Embedder      Embedder // Optional embedder instance (created if nil and UseNeural=true)
	EnvelopeSpace string   // Search within a specific envelope slot (e.g., "code", "intent")
}

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

type Thread struct {
	ID            string    `json:"id"`
	Title         string    `json:"title"`
	CreatedAt     time.Time `json:"created_at"`
	CreatedByType string    `json:"created_by_type"`
	CreatedByID   string    `json:"created_by_id"`
	Status        string    `json:"status"`
	ContextJSON   string    `json:"context_json,omitempty"`
	TargetAgent   string    `json:"target_agent,omitempty"` // Which agent this conversation is with
	Workspace     string    `json:"workspace,omitempty"`    // Working directory for this thread
	LastSeq       int       `json:"last_seq"`
	UpdatedAt     time.Time `json:"updated_at"`
}

type ThreadAggregateStats struct {
	TotalThreads int            `json:"total_threads"`
	ByStatus     map[string]int `json:"by_status"`
	ByWorkspace  map[string]int `json:"by_workspace"`
}

type ThreadContext struct {
	TargetAgent string `json:"target_agent,omitempty"`
	Workspace   string `json:"workspace,omitempty"`
}

type ThreadFilter struct {
	Status    string // Filter by status (active, paused, resolved, archived)
	Workspace string // Filter by workspace
	Limit     int    // Maximum number of results
}

type ThreadStats struct {
	ID               string `json:"id"`
	Title            string `json:"title"`
	UnreadCount      int    `json:"unread_count"`
	PendingApprovals int    `json:"pending_approvals"`
	RunningProcesses int    `json:"running_processes"`
	LastMessageAt    string `json:"last_message_at,omitempty"`
}

type TriageActionability string

type TriageResult struct {
	Action      TriageActionability `json:"action"`
	Reason      string              `json:"reason"`
	MessageKind PackageMessageKind  `json:"message_kind"`
	PackageName string              `json:"package_name"`
}