trigger

type Declaration struct {
	Commit string
	Inputs map[string]graph.Input
	Files  map[string]any
}

type InputsTooLarge struct{ Why string }

type Options struct {
	Pool     *db.Pool
	Versions Versions
	Objects  artifact.Objects
	Report   func(error)
	Now      func() time.Time
}

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

type Request struct {
	Namespace, Workflow string

	// Kind is what asked, and By the principal the run is attributed to: whoever asked, for the
	// kinds somebody asks by, and nobody for a schedule, a webhook or an event, whose runs are the
	// namespace's built-in identity's, which the database writes.
	Kind agk.TriggerKind
	By   string

	// Commit is the version to run, or Ref a branch, a tag or a whole commit resolved to one now,
	// once, or neither, which runs the default branch's head. Both is refused.
	Commit, Ref string

	// Inputs are what was supplied, each number a json.Number as it was written, bound here against
	// the version's declaration with required and default applied. Bound takes their place for a run
	// whose inputs were bound already, a replay's, and is written as it is.
	Inputs map[string]any
	Bound  json.RawMessage

	// ReplayOf and ReplayFrom make the run a replay of another, from a step or from the start.
	ReplayOf   agk.RunID
	ReplayFrom agk.Step

	// Detail is added to what the run.trigger entry records of the run.
	Detail map[string]any

	// Context is what fired the run as expressions read it, frozen on the run: the trigger root,
	// body, headers, query and scheduled_for, and an event trigger's event. A replay is handed the
	// context of the run it replays, so that it sees what fired it and not what is true now.
	Context db.TriggerContext

	// NamespaceVars are the variables the namespace shows the workflow, for a run whose were read
	// already: a replay's, those the run it replays read, so that it reads what that run read and
	// not what is true now; a webhook's or an event's, those its map and its filter read, so that
	// its steps read what they did. Nil, which every other run leaves it, reads them in Create's
	// transaction, the one that writes the run. Either way the run keeps those its file does not
	// write, frozen on it.
	NamespaceVars map[string]any

	// Caller is the step whose call asks for the run, for the kind workflow, and Depth how deep
	// in a chain of calls the run is.
	Caller *db.Caller
	Depth  int
}

type Started struct {
	Run    agk.RunID
	Commit string
}

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

type Versions interface {
	Graph(ctx context.Context, namespace, workflow, commit string) (*graph.Graph, error)
}