projectseed

type Attachment struct {
	TaskID int `json:"task_id"`
	// TaskTitle is the title the task had in the seed — or, for a task the
	// run created, as it left it. The hub attaches the file only to the task
	// the run worked on: one the hub deleted or retitled while the run was
	// out, and whose id now belongs to another, does not get it.
	TaskTitle string    `json:"task_title,omitempty"`
	Name      string    `json:"name"`
	Size      int64     `json:"size"`
	SHA256    string    `json:"sha256,omitempty"`
	CreatedAt time.Time `json:"created_at"`
	Data      []byte    `json:"data,omitempty"`
	Left      string    `json:"left,omitempty"`
}

type Cost struct {
	Timestamp      time.Time `json:"timestamp"`
	TaskID         int       `json:"task_id,omitempty"`
	TaskTitle      string    `json:"task_title,omitempty"`
	Provider       string    `json:"provider,omitempty"`
	Model          string    `json:"model,omitempty"`
	InputTokens    int       `json:"input_tokens,omitempty"`
	OutputTokens   int       `json:"output_tokens,omitempty"`
	ThinkingTokens int       `json:"thinking_tokens,omitempty"`
	EstimatedUSD   float64   `json:"estimated_usd,omitempty"`
}

type Event struct {
	Timestamp time.Time `json:"timestamp"`
	Type      string    `json:"type"`
	TaskID    int       `json:"task_id,omitempty"`
	TaskTitle string    `json:"task_title,omitempty"`
	Step      int       `json:"step"`
	Message   string    `json:"message,omitempty"`
	Details   string    `json:"details,omitempty"`
}

type MergeReport struct {
	// Updated are the tasks whose outcome was taken from the run, and
	// Outcomes their status afterwards, by ID.
	Updated  []int
	Outcomes map[int]pm.TaskStatus
	// Added are the tasks the run created, as numbered on the hub.
	Added []int
	// Renumbered maps a created task's ID on the device to the one it was
	// given here, for the tasks whose ID the hub had already used.
	Renumbered map[int]int
	// Kept are changes the hub declined, one sentence each.
	Kept []string
	// StatusFrom and StatusTo record the project status change, if any.
	StatusFrom, StatusTo string
	// Steps, Events and Costs count what was recorded.
	Steps, Events, Costs int
	// Omitted is what the device said it left out.
	Omitted []string
	// Unreviewed are tasks that came back done without a review although the
	// project's review gate is on (Task 20357): the device's cloop predates
	// the gate, so it ran them — and published their work — unreviewed.
	Unreviewed []int
	// Attached counts the run's files stored on the hub (Task 20428),
	// LeftBehind names, one sentence each, the ones recorded without their
	// bytes — left in the executor's workspace, or refused here — and
	// NotRecorded the ones the hub has no task for.
	Attached    int
	LeftBehind  []string
	NotRecorded []string
	// contains filtered or unexported fields
}

type Provenance struct {
	// ExecutorID, ExecutorKind and Isolation are where the hub sent the run.
	ExecutorID   string
	ExecutorKind string
	Isolation    string
	// RunID is the execution id the hub minted for the dispatch; it joins the
	// tasks to the lease rows the broker wrote.
	RunID string
	// Identity is who the run's spend is billed to.
	Identity string
}

type Records struct {
	Steps  []state.StepResult
	Events []statedb.EventRow
	Costs  []cost.LedgerEntry
}

type Result struct {
	// Format is the document version; see ResultFormat.
	Format int `json:"format"`
	// BaseStep is the step counter the run started from — the seed's
	// CurrentStep. Informational: the hub numbers the run's steps after its
	// own history whatever this says, because its history may have grown
	// while the run was out.
	BaseStep int `json:"base_step"`
	// Status is the project status the run left behind ("complete",
	// "paused", "failed", ...).
	Status string `json:"status,omitempty"`
	// PauseReason explains a "paused" Status, including when a usage cap
	// lifts — which is what lets the hub's auto-resume pick the run back up.
	PauseReason *pausereason.Reason `json:"pause_reason,omitempty"`
	// InputTokens, OutputTokens and EvolveSteps are what the run *added*,
	// rather than the device's totals: the hub's own totals may have moved
	// while the run was out, and adding a delta is correct either way.
	InputTokens  int `json:"input_tokens,omitempty"`
	OutputTokens int `json:"output_tokens,omitempty"`
	EvolveSteps  int `json:"evolve_steps,omitempty"`
	// Tasks are the tasks the run changed or created.
	Tasks []TaskChange `json:"tasks,omitempty"`
	// Steps are the steps the run recorded, in order.
	Steps []state.StepResult `json:"steps,omitempty"`
	// Events are the journal rows the run wrote, oldest first.
	Events []Event `json:"events,omitempty"`
	// Costs are the cost rows the run recorded.
	Costs []Cost `json:"costs,omitempty"`
	// Attachments are the files the run attached to tasks (Task 20428), with
	// their bytes when the result had room for them.
	Attachments []Attachment `json:"attachments,omitempty"`
	// Omitted says what the device left out to fit the transport, one
	// sentence each, so the hub can say so instead of presenting a partial
	// history as a whole one.
	Omitted []string `json:"omitted,omitempty"`
}

type TaskChange struct {
	// Before is the task as the seed had it; nil when the run created it.
	//
	// It travels so the hub can tell its own edits from the run's: a field
	// the hub changed while the run was out no longer matches Before, and the
	// hub's value is kept. It is the device's claim, and the hub treats it as
	// one — see merge.go.
	Before *pm.Task `json:"before,omitempty"`
	// After is the task as the run left it.
	After *pm.Task `json:"after"`
}