session

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

type AgentSessionRunnerOption func(runner *AgentSessionRunner) error

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

type IOpenTurnExecutor interface {
	ITurnExecutor
	Interrupt(ctx context.Context) error
	Close(ctx context.Context) error
}

type IRouter interface {
	Route(ctx context.Context, request RouteRequest) (string, error)
}

type ITurnExecutor interface {
	Propose(ctx context.Context, turn *claudecode.Turn) (*model.Proposal[claudecode.Event], error)
}

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

type OpenTurnExecutorFactory func(ctx context.Context, spec TurnExecutorSpec) (IOpenTurnExecutor, error)

type RouteRequest struct {
	Virtual string
	// Session is the conversation the virtual session opens when no
	// existing one fits.
	Session string
	Model   string
	// Agent is the agent's identity: its id and a hash of its instructions.
	// A resumed conversation keeps the system prompt it first recorded, so
	// only a conversation with the same identity may be attached.
	Agent string
	// Key is the topic key: the assignment's ticket.
	Key string
	// Summary is the assignment in a line: its pull request title.
	Summary string
}

type RunState struct {
	AssignmentID     string `json:"assignment_id"`
	AgentID          string `json:"agent_id"`
	TicketURL        string `json:"ticket_url"`
	SessionID        string `json:"session_id"`
	TraceID          string `json:"trace_id"`
	SpanID           string `json:"span_id"`
	Repository       string `json:"repository"`
	Worktree         string `json:"worktree"`
	Branch           string `json:"branch"`
	BaseBranch       string `json:"base_branch"`
	PullRequestTitle string `json:"pull_request_title"`
	// Turns counts the turns started on the session, so a gate attributes its
	// decisions to the turn that is running.
	Turns int `json:"turns"`
	// LastPushTime records the Unix timestamp of the most recent push,
	// initialized when the session starts and updated by the commit gate.
	LastPushTime int64 `json:"last_push_time,omitempty"`
	// Model is the LLM model the session runs on, needed by the commit hook.
	Model string `json:"model,omitempty"`
}

type TurnExecutorFactory func(spec TurnExecutorSpec) (ITurnExecutor, error)

type TurnExecutorSpec struct {
	Session   uuid.UUID
	Directory string
	// Arguments are the turn executor's extra arguments: the settings with
	// the gates, the model, the permission mode and the allowed tools.
	Arguments []string
	Logger    *slog.Logger
	// Resume is true when the session already exists.
	Resume bool
	// Environment is appended, as NAME=value, to the environment the turn
	// executor's process inherits: the Bazel cache locations, for one.
	Environment []string
}