journal

const (
	Enqueued     FactType = "task.enqueued"
	Claimed      FactType = "task.claimed"
	Heartbeat    FactType = "task.heartbeat"
	Completed    FactType = "task.completed"
	Failed       FactType = "task.failed"        // attempt failed, will retry
	DeadLettered FactType = "task.dead-lettered" // attempts exhausted
	Cancelled    FactType = "task.cancelled"
	// CancelRequested records an operator's request to stop a Running
	// task. The fact IS the flag: the executing worker observes it at its
	// next heartbeat, cancels the execution context, and records
	// task.cancelled; a crashed worker's expired lease finalizes the same
	// cancel at reclaim. No task-row column mirrors it.
	CancelRequested FactType = "task.cancel-requested"
	Released        FactType = "task.released" // lease expired, back to pending
	Requeued        FactType = "task.requeued" // preflight refusal, no attempt burned
	// Orphaned records that a Running task's lease expired and NO worker
	// reclaimed it (the worker died with the pool down). It is an
	// observation, not a state change: the task stays Running until a
	// ClaimDue reclaim (or a human) picks it up. Appended idempotently by
	// Store.MarkOrphaned, so `tq show` can explain a stranded task.
	Orphaned FactType = "task.orphaned"
	// Reprioritized records that a PENDING task's priority changed
	// (ADR-0015 §5): the mutation is UpdatePendingPriority's in-tx fact,
	// carrying old/new priority, the source (marker|importance|ai|keyword|
	// manual|unblock|migration) and why. Priority never mutates
	// running/terminal tasks — those facts do not exist by construction.
	Reprioritized FactType = "task.reprioritized"
	// SessionOpened / SessionClosed record the lifecycle of an INTERACTIVE
	// crush session (the session-close bridge, internal/session). They are
	// observations, not task state: TaskID carries the synthetic
	// "session:<id>" identity, never a real task row, so no enqueue/claim
	// machinery can ever pick them up. SessionClosed's detail names the
	// attributed commits and the minted review/status task IDs.
	SessionOpened FactType = "session.opened"
	SessionClosed FactType = "session.closed"
	// QuestionAsked records an agent's request for a human decision while
	// its task is parked (PapDashboard questions). TaskID is the PARKED
	// task; detail carries the question contract (ref, type, text,
	// options, repo, expiry). The task stays PENDING — the park is a
	// requeue without attempt burn — until RecordAnswer unblocks it.
	QuestionAsked FactType = "task.question-asked"
	// QuestionAnswered records the owner's decision arriving from
	// PapDashboard. Written by Store.RecordAnswer in the SAME transaction
	// that injects the answer into the parked task's payload and clears
	// its NotBefore, so "answered but still parked" is unrepresentable.
	// Idempotent per question ref: a replayed pickup appends nothing.
	QuestionAnswered FactType = "task.question-answered"
)