journal

type Actor string

type AdvanceInput struct {
	Plan        string `json:"plan"`
	Task        string `json:"task"`
	Status      string `json:"status,omitempty"`
	CommitState string `json:"commit_state,omitempty"`
}

type AdvanceObserved struct {
	FromStatus string `json:"from_status"`
	ToStatus   string `json:"to_status"`
	Committed  bool   `json:"committed"`
	HeadSHA    string `json:"head_sha,omitempty"`
	Locus      *Locus `json:"locus,omitempty"`
}

type ArchiveOrphansInput struct {
	DryRun bool `json:"dry_run,omitempty"`
}

type ArchiveOrphansObserved struct {
	Actions []OrphanAction `json:"actions,omitempty"`
}

type CanonicalRef struct {
	Ref string `json:"ref"`
}

type ChangedFields []FieldDelta

type CheckpointInput struct {
	Message            string `json:"message"`
	VerificationStatus string `json:"verification_status,omitempty"`
	LogToIter          bool   `json:"log_to_iter,omitempty"`
}

type CheckpointObserved struct {
	CheckpointID string `json:"checkpoint_id"`
	IterStubPath string `json:"iter_stub_path,omitempty"`
}

type CloseTaskInput struct {
	Plan      string `json:"plan"`
	Task      string `json:"task"`
	NextFocus string `json:"next_focus,omitempty"`
}

type CloseTaskObserved struct {
	ToStatus     string `json:"to_status"`
	NextFocusSet bool   `json:"next_focus_set"`
	Committed    bool   `json:"committed"`
	HeadSHA      string `json:"head_sha,omitempty"`
	Locus        *Locus `json:"locus,omitempty"`
}

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

type CommitInput struct {
	Includes []string `json:"includes,omitempty"`
	DryRun   bool     `json:"dry_run,omitempty"`
}

type CommitObserved struct {
	StagedPaths []string `json:"staged_paths,omitempty"`
	HeadSHA     string   `json:"head_sha,omitempty"`
	Noop        bool     `json:"noop"`
}

type ContractCreateInput struct {
	Plan       string   `json:"plan"`
	Task       string   `json:"task"`
	Owner      string   `json:"owner,omitempty"`
	WriteScope []string `json:"write_scope,omitempty"`
	Mode       string   `json:"mode,omitempty"`
	Force      bool     `json:"force,omitempty"`
}

type ContractCreateObserved struct {
	ContractID         string   `json:"contract_id"`
	Mode               string   `json:"mode"`
	Status             string   `json:"status,omitempty"`
	ContractPath       string   `json:"contract_path,omitempty"`
	ResolvedWriteScope []string `json:"resolved_write_scope,omitempty"`
}

type DelegationCloseoutInput struct {
	Plan     string `json:"plan"`
	Task     string `json:"task"`
	Decision string `json:"decision"`
	Note     string `json:"note,omitempty"`
}

type DelegationCloseoutObserved struct {
	ArchivedPaths        []string `json:"archived_paths,omitempty"`
	ReconciledTaskStatus string   `json:"reconciled_task_status"`
}

type DelegationState struct {
	ID           string `json:"id"`
	ParentPlanID string `json:"parent_plan_id"`
	ParentTaskID string `json:"parent_task_id"`
	Status       string `json:"status"`
}

type DeltaInput struct {
	Plan          string        `json:"plan,omitempty"`
	Task          string        `json:"task,omitempty"`
	ChangedFields ChangedFields `json:"changed_fields,omitempty"`
}

type DeltaObserved struct {
	FieldsReplaced []string `json:"fields_replaced,omitempty"`
}

type DeriveScopeInput struct {
	Plan        string   `json:"plan"`
	Task        string   `json:"task"`
	SeedSymbols []string `json:"seed_symbols,omitempty"`
	SeedPaths   []string `json:"seed_paths,omitempty"`
}

type DeriveScopeObserved struct {
	SidecarPath   string `json:"sidecar_path"`
	Mode          string `json:"mode,omitempty"`
	Confidence    string `json:"confidence,omitempty"`
	RequiredPaths int    `json:"required_paths"`
	Queries       int    `json:"queries"`
}

type Envelope struct {
	// Schema/Version namespace and version the record (stamped by Emit).
	Schema  string `json:"schema"`
	Version int    `json:"version"`

	// TS is the RFC3339 UTC nanosecond timestamp — the primary replay ordering
	// key. Stamped by Emit when empty.
	TS string `json:"ts"`
	// Seq is a process-monotonic counter, the tiebreaker for records sharing a
	// TS. Stamped by Emit.
	Seq int64 `json:"seq"`

	// Actor is the agent role that produced the event.
	Actor Actor `json:"actor"`
	// Command is the canonical command name, e.g. "workflow advance".
	Command string `json:"command"`
	// CwdRepo is the repo identity/path the command ran against. The journal may
	// span repos (sweep/drift). Stamped by Emit from the repo fingerprint when
	// the caller leaves it empty.
	CwdRepo string `json:"cwd_repo"`
	// EventType selects durable_delta / input_only / failed.
	EventType EventType `json:"event_type"`

	// Input is the typed flags the command was invoked with (opaque here).
	Input json.RawMessage `json:"input,omitempty"`
	// Observed is the typed durable delta the command produced (opaque here).
	// Always absent on an EventFailed record (R1: never a false observed).
	Observed json.RawMessage `json:"observed,omitempty"`
}

type EventType string

type FanoutInput struct {
	Plan             string   `json:"plan"`
	Task             string   `json:"task"`
	WriteScope       []string `json:"write_scope,omitempty"`
	DelegateProfile  string   `json:"delegate_profile,omitempty"`
	BaseBranch       string   `json:"base_branch,omitempty"`
	VerifierSequence []string `json:"verifier_sequence,omitempty"`
}

type FanoutObserved struct {
	DelegationPath     string   `json:"delegation_path"`
	BundlePath         string   `json:"bundle_path"`
	ResolvedBaseBranch string   `json:"resolved_base_branch,omitempty"`
	ResolvedWriteScope []string `json:"resolved_write_scope,omitempty"`
}

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

type FoldBackInput struct {
	Plan        string `json:"plan"`
	Task        string `json:"task,omitempty"`
	Observation string `json:"observation"`
	Slug        string `json:"slug,omitempty"`
	Propose     bool   `json:"propose,omitempty"`
}

type FoldBackObserved struct {
	ArtifactID string   `json:"artifact_id"`
	RoutedTo   []string `json:"routed_to,omitempty"`
	Action     string   `json:"action"`
}

type Identity struct {
	Fingerprint   string `json:"fingerprint"`
	RepoID        string `json:"repo_id,omitempty"`
	RemoteURL     string `json:"remote_url,omitempty"`
	DefaultBranch string `json:"default_branch,omitempty"`
	CurrentBranch string `json:"current_branch,omitempty"`
	Head          string `json:"head,omitempty"`
	WorktreePath  string `json:"worktree_path,omitempty"`
	PRNumber      int    `json:"pr_number,omitempty"`
}

type InOpenPRRef struct {
	PR     int    `json:"pr"`
	Status string `json:"status"`
}

type KGContentDeltaInput struct {
	Operation string   `json:"operation"`
	Targets   []string `json:"targets,omitempty"`
}

type KGContentDeltaObserved struct {
	Counts map[string]int `json:"counts,omitempty"`
	IDs    []string       `json:"ids,omitempty"`
}

type KGDecisionInput struct {
	Repo string `json:"repo,omitempty"`
	Base string `json:"base,omitempty"`
}

type KGDecisionObserved struct {
	Outcome string `json:"outcome"`
	Nodes   *int   `json:"nodes,omitempty"`
	Edges   *int   `json:"edges,omitempty"`
	Files   *int   `json:"files,omitempty"`
}

type KGIngestInput struct {
	File string `json:"file,omitempty"`
	All  bool   `json:"all,omitempty"`
	Type string `json:"type,omitempty"`
}

type KGIngestObserved struct {
	NotesCreated int      `json:"notes_created"`
	NotesUpdated int      `json:"notes_updated"`
	NoteIDs      []string `json:"note_ids,omitempty"`
}

type KGSyncInput struct {
	Push bool `json:"push,omitempty"`
}

type KGSyncObserved struct {
	PullStatus string `json:"pull_status,omitempty"`
	PushStatus string `json:"push_status,omitempty"`
	HeadSHA    string `json:"head_sha,omitempty"`
}

type Locus struct {
	// Canonical is set when the change is landed on the canonical branch.
	Canonical *CanonicalRef `json:"canonical,omitempty"`
	// InOpenPR is set when the change lives only in an open, unmerged PR.
	InOpenPR *InOpenPRRef `json:"in_open_pr,omitempty"`
}

type MergeBackInput struct {
	Task               string `json:"task"`
	Summary            string `json:"summary,omitempty"`
	VerificationStatus string `json:"verification_status,omitempty"`
	CommitState        string `json:"commit_state,omitempty"`
}

type MergeBackObserved struct {
	ArtifactPath string   `json:"artifact_path"`
	FilesChanged []string `json:"files_changed,omitempty"`
	Verdict      string   `json:"verdict,omitempty"`
	Committed    bool     `json:"committed"`
	HeadSHA      string   `json:"head_sha,omitempty"`
	Locus        *Locus   `json:"locus,omitempty"`
}

type OrphanAction struct {
	Artifact   string `json:"artifact"`
	Class      string `json:"class"`
	Resolution string `json:"resolution"`
	DestPath   string `json:"dest_path,omitempty"`
}

type PlanArchiveInput struct {
	Plans []string `json:"plans"`
	Force bool     `json:"force,omitempty"`
}

type PlanArchiveObserved struct {
	ArchivePaths      []string `json:"archive_paths,omitempty"`
	ActiveDirsRemoved []string `json:"active_dirs_removed,omitempty"`
}

type PlanCreateInput struct {
	Plan  string `json:"plan"`
	Title string `json:"title,omitempty"`
	Owner string `json:"owner,omitempty"`
}

type PlanCreateObserved struct {
	PlanDir      string   `json:"plan_dir"`
	FilesCreated []string `json:"files_created,omitempty"`
}

type PlanState struct {
	ID               string      `json:"id"`
	Status           string      `json:"status"`
	CurrentFocusTask string      `json:"current_focus_task,omitempty"`
	Tasks            []TaskState `json:"tasks"`
}

type ReviewInput struct {
	ProposalID string `json:"proposal_id"`
	Reason     string `json:"reason,omitempty"`
}

type ReviewObserved struct {
	Decision         string `json:"decision"`
	Applied          bool   `json:"applied"`
	ArchivedPath     string `json:"archived_path,omitempty"`
	RefreshTriggered bool   `json:"refresh_triggered"`
}

type SnapshotState struct {
	// Schema/Version namespace and version the record.
	Schema  string `json:"schema"`
	Version int    `json:"version"`
	// CapturedAt is the RFC3339 UTC nanosecond capture time (the one varying
	// field; everything else is a pure function of the captured state).
	CapturedAt string `json:"captured_at"`
	// Identity pins the snapshot to the repo it was captured against, so a
	// recovery can quarantine a snapshot taken against a different checkout.
	Identity Identity `json:"identity"`
	// Plans is the captured active plans, sorted by id.
	Plans []PlanState `json:"plans"`
	// PendingUnblocked is a deterministic, filesystem-only PROJECTION: pending
	// tasks whose declared dependencies are all satisfied, sorted by (plan,
	// task). It is deliberately weaker than — and NOT a substitute for — the
	// authoritative `da workflow eligible` engine, which additionally considers
	// in_progress tasks, filters to active plans, excludes tasks under an active
	// delegation lock, and falls back to .agents/history for cross-plan deps.
	// Re-implementing that here would duplicate the engine and drift, so the
	// snapshot records only this cheap, byte-stable hint; p5 recovery should
	// call `da workflow eligible` directly for authoritative eligibility.
	PendingUnblocked []TaskRef `json:"pending_unblocked"`
	// Delegations is the in-flight delegations (pending/active), sorted by id.
	Delegations []DelegationState `json:"delegations"`
	// PendingMergeBacks is the task ids with a merge-back awaiting integration,
	// sorted.
	PendingMergeBacks []string `json:"pending_merge_backs"`
}

type StartTaskInput struct {
	Plan        string   `json:"plan"`
	Task        string   `json:"task"`
	SeedSymbols []string `json:"seed_symbols,omitempty"`
	SeedPaths   []string `json:"seed_paths,omitempty"`
}

type StartTaskObserved struct {
	ToStatus    string `json:"to_status"`
	SidecarPath string `json:"sidecar_path,omitempty"`
	Committed   bool   `json:"committed"`
	HeadSHA     string `json:"head_sha,omitempty"`
}

type SweepApplyInput struct {
	StaleDays    int `json:"stale_days,omitempty"`
	ProposalDays int `json:"proposal_days,omitempty"`
}

type SweepApplyObserved struct {
	FixesApplied []SweepFix `json:"fixes_applied,omitempty"`
}

type SweepFix struct {
	Project string `json:"project"`
	Action  string `json:"action"`
}

type TaskAddInput struct {
	Plan       string   `json:"plan"`
	TaskID     string   `json:"task_id"`
	Title      string   `json:"title,omitempty"`
	DependsOn  []string `json:"depends_on,omitempty"`
	WriteScope []string `json:"write_scope,omitempty"`
	AppType    string   `json:"app_type,omitempty"`
}

type TaskAddObserved struct {
	Appended bool `json:"appended"`
}

type TaskRef struct {
	Plan string `json:"plan"`
	Task string `json:"task"`
}

type TaskState struct {
	ID        string   `json:"id"`
	Status    string   `json:"status"`
	DependsOn []string `json:"depends_on,omitempty"`
	Locus     *Locus   `json:"locus,omitempty"`
}

type Tier string

type VerifyRecordInput struct {
	Kind    string `json:"kind"`
	Status  string `json:"status"`
	Scope   string `json:"scope,omitempty"`
	Summary string `json:"summary,omitempty"`
	Task    string `json:"task,omitempty"`
}

type VerifyRecordObserved struct {
	VerificationLogID  string `json:"verification_log_id"`
	ResultArtifactPath string `json:"result_artifact_path,omitempty"`
}