contextpack

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

type AtomReadPort interface {
	Search(ctx context.Context, workspaceID *uuid.UUID, query string, limit int) ([]atom.Atom, error)
}

type BehaviorRuleReadPort interface {
	List(ctx context.Context, p behaviorrule.ListParams) ([]*behaviorrule.BehaviorRule, error)
}

type DecisionReadPort interface {
	ByRepo(ctx context.Context, repoName string, limit int32) ([]db.Decision, error)
	ByProject(ctx context.Context, projectID uuid.UUID, limit int32) ([]db.Decision, error)
	ByTask(ctx context.Context, taskID uuid.UUID, limit int32) ([]db.Decision, error)
	// All returns the most recent decisions across every repo/project/task —
	// used only when req has no scope signal at all (RepoName == "" &&
	// ProjectID == nil && TaskID == nil). The session-start hook (A5a) is one
	// caller that hits this: it has no current-repo signal to pass — see
	// retrieveDecisions and backend-security-design.md-adjacent dispatch
	// notes on why deriveRepoSlug is deliberately not used to manufacture
	// one. It is NOT the only caller: assemble_context's MCP tool schema
	// (internal/mcp/tools_contextpack.go) marks repo_name/project_id/task_id
	// Optional — only objective is Required — so any MCP client that omits
	// all three (e.g. a bare "what have we decided" query) reaches this
	// branch too, returning workspace-wide decisions instead of the empty
	// set a caller of the pre-A5a code path would have seen. Both All()
	// implementations (Postgres and SQLite) still filter to the caller's own
	// workspace, so this is a scope-widening within one tenant, not a
	// cross-tenant leak — see TestHandleAssembleContext_UnscopedRequestReachesDecisionAll
	// (internal/mcp/tools_contextpack_test.go) for the locked-in contract.
	All(ctx context.Context, limit int32) ([]db.Decision, error)
}

type Item struct {
	Type        string            `json:"type"`
	ID          uuid.UUID         `json:"id"`
	SourceTable string            `json:"source_table"`
	Summary     string            `json:"summary"`
	Score       float64           `json:"score"`
	Reasons     []string          `json:"reasons"`
	Provenance  map[string]string `json:"provenance"`
}

type KnowledgeReadPort interface {
	SearchReadOnly(ctx context.Context, query string, limit int) ([]db.KnowledgeItem, error)
}

type Omitted struct {
	Type   string `json:"type"`
	Count  int    `json:"count"`
	Reason string `json:"reason"`
}

type OutcomeReadPort interface {
	ListFailedOutcomes(ctx context.Context, workspaceID *uuid.UUID, limit int) ([]outcome.Outcome, error)
}

type Pack struct {
	PackID      *uuid.UUID `json:"pack_id"`
	Objective   string     `json:"objective"`
	BudgetChars int        `json:"budget_chars"`
	UsedChars   int        `json:"used_chars"`
	Items       []Item     `json:"items"`
	Warnings    []Warning  `json:"warnings"`
	Omitted     []Omitted  `json:"omitted"`
}

type ProceduralReadPort interface {
	Query(ctx context.Context, f procedural.QueryFilter) ([]procedural.ProceduralMemory, error)
}

type ReflectionReadPort interface {
	RecentWithPatterns(ctx context.Context, workspaceID *uuid.UUID, since time.Time, limit int) ([]*reflection.Reflection, error)
}

type Request struct {
	Objective    string
	RepoName     string
	ProjectID    *uuid.UUID
	TaskID       *uuid.UUID
	BranchName   string
	FilesTouched []string
	BudgetChars  int
	IncludeTypes []string
	Persist      bool
}

type SessionReadPort interface {
	LatestHandoff(ctx context.Context) (*db.SessionHandoff, error)
}

type SkillReadPort interface {
	Search(ctx context.Context, f skill.SearchFilter) ([]*skill.Skill, error)
}

type TaskProjectReadPort interface {
	GetTaskByID(ctx context.Context, id uuid.UUID) (*db.Task, error)
	GetProjectByID(ctx context.Context, id uuid.UUID) (*db.Project, error)
	ProjectsByRepoName(ctx context.Context, repoName string) ([]db.Project, error)
	WorkspaceID() pgtype.UUID
}

type Warning struct {
	Type    string `json:"type"`
	Summary string `json:"summary"`
}

type WorkSessionReadPort interface {
	GetActive(ctx context.Context, workspaceID uuid.UUID, repoName string) (*worksession.ActiveSessionResult, error)
}