session

type CloseDetail ¶

type CloseDetail struct {
	SessionID   string   `json:"session_id"`
	Repo        string   `json:"repo"`
	Project     string   `json:"project,omitempty"`
	Summary     string   `json:"summary,omitempty"`
	AllowDirty  bool     `json:"allow_dirty"`
	ReviewRange string   `json:"review_range,omitempty"`
	Commits     []Commit `json:"commits"`
	ReviewTask  string   `json:"review_task,omitempty"`
	StatusTask  string   `json:"status_task,omitempty"`
}

CloseDetail is the session.closed fact's detail: what the session

committed (as far as attribution can see), what close minted, and the clean-tree decision + review range it acted on (forensics: the fact answers "why did close tolerate a dirty tree / which commits did the reviewer see" without re-deriving them from the payload).

type CloseInput ¶

type CloseInput struct {
	// ID is the interactive session's id (CRUSH_SESSION_ID). Required.
	ID string
	// Repo is the absolute repository path the session worked in. Required.
	Repo string
	// Project is the queue project the minted tasks belong to (convention:
	// the repo directory's base name).
	Project string
	// Summary is the operator's one-paragraph account of what the session
	// did; it becomes the review's bar and the status entry's item. Empty
	// falls back to a default text.
	Summary string
	// AllowDirty mirrors the pool's --allow-dirty stance into the minted
	// payloads' RequireClean: a multi-agent repo is effectively always
	// dirty, and a clean-tree-required task there requeues forever.
	AllowDirty bool
}

CloseInput carries one Close invocation's parameters.

type CloseResult ¶

type CloseResult struct {
	// Commits are the session-attributed commits, oldest first.
	Commits []Commit
	// ReviewTask / StatusTask are the minted tasks; zero TaskIDs when no
	// commits were attributed (nothing minted).
	ReviewTask task.Task
	StatusTask task.Task
	// ReviewFresh / StatusFresh are false when the enqueue hit the dedup
	// key (the task already existed from an earlier close of this session).
	ReviewFresh bool
	StatusFresh bool
}

CloseResult reports what Close recorded and minted.

func Close(ctx context.Context, s Store, scanner GitScanner, in CloseInput) (CloseResult, error)

type Commit ¶

type Commit = executor.Commit

The commit-attribution scanner lives in internal/executor (gitscan.go, shared with outcome derivation); these aliases keep the bridge's signatures stable. Aliases, not copies: the types are identical.

type FactSource ¶ added in v0.3.1

type FactSource interface {
	Facts(ctx context.Context, after int64, limit int) ([]journal.Fact, error)
}

FactSource is List's read side: page through journal facts in Seq order.

type GitLogScanner ¶

type GitLogScanner = executor.GitLogScanner

The commit-attribution scanner lives in internal/executor (gitscan.go, shared with outcome derivation); these aliases keep the bridge's signatures stable. Aliases, not copies: the types are identical.

type GitScanner ¶

type GitScanner = executor.GitScanner

The commit-attribution scanner lives in internal/executor (gitscan.go, shared with outcome derivation); these aliases keep the bridge's signatures stable. Aliases, not copies: the types are identical.

type GitScannerFunc ¶

type GitScannerFunc = executor.GitScannerFunc

The commit-attribution scanner lives in internal/executor (gitscan.go, shared with outcome derivation); these aliases keep the bridge's signatures stable. Aliases, not copies: the types are identical.

type OpenDetail ¶

type OpenDetail struct {
	SessionID string `json:"session_id"`
	Repo      string `json:"repo"`
	Project   string `json:"project,omitempty"`
}

OpenDetail is the session.opened fact's detail.

type PgrepOwner ¶ added in v0.3.1

type PgrepOwner struct{}

PgrepOwner is the production ProcessOwner: a session id counts as owned while any process whose full command line mentions it is alive.

func (PgrepOwner) Owns(ctx context.Context, id string) (bool, error)

type ProcessOwner ¶ added in v0.3.1

type ProcessOwner interface {
	Owns(ctx context.Context, id string) (bool, error)
}

ProcessOwner reports whether a live crush process owns a session id. The default implementation shells out to pgrep; tests stub it.

type RegistryEntry ¶ added in v0.3.1

type RegistryEntry struct {
	ID       string    `json:"id"`
	CWD      string    `json:"cwd"`
	LastSeen time.Time `json:"last_seen"`
}

RegistryEntry is one ping's observation: which session, working where, seen when. Snake_case keys: the file is a machine-payload wire format, appended by hooks and consumed by the sweeper (tagliatelle exclusion below).

func LoadRegistry(path string) ([]RegistryEntry, error)

type SessionInfo ¶ added in v0.3.1

type SessionInfo struct {
	// ID is the session's CRUSH_SESSION_ID.
	ID string
	// Repo / Project mirror the session.opened fact's detail.
	Repo string
	// Project may be empty (older opens without the field).
	Project string
	// OpenedAt is the opened fact's timestamp.
	OpenedAt time.Time
}

SessionInfo describes one journal-recorded interactive session.

func List(ctx context.Context, src FactSource) ([]SessionInfo, error)

type Store ¶

type Store interface {
	Enqueue(ctx context.Context, n task.New) (task.Task, error)
	AppendFact(ctx context.Context, f journal.Fact) error
	FactsForTask(ctx context.Context, id string, limit int) ([]journal.Fact, error)
}

Store is the bridge's view of the queue core: mint tasks, append the session's lifecycle facts, and read one identity's facts (the double-begin guard).

type SweepInput ¶ added in v0.3.1

type SweepInput struct {
	RegistryPath string
	StaleAfter   time.Duration
	Owner        ProcessOwner
	AllowDirty   bool
	Summary      string
	Now          time.Time
}

SweepInput configures one sweep pass.

type SweepOutcome ¶ added in v0.3.1

type SweepOutcome struct {
	Entry  RegistryEntry
	Closed bool
	Reason string
	Err    error
}

SweepOutcome records what the sweeper did to one registry session.

func Sweep(ctx context.Context, store Store, scanner GitScanner, input SweepInput) ([]SweepOutcome, error)