temporal

type Activities struct {
	Catalog        durable.Catalog
	Snapshots      durable.SnapshotStore
	Projection     vfs.Projection
	Fallback       durable.EventLog
	DisableStreams bool
}

type CommitToolInput struct {
	SessionID  durable.SessionID
	AgentID    string
	MCPServers []mcp.MCPConfig
	Call       tacklr.ToolCall
	Output     string
	Auth       durable.AuthContext
	Mounts     []durable.MountRecipe
	Specialist string
	State      map[string]any
}

type Config struct {
	Catalog    durable.Catalog
	TaskQueue  string
	Snapshots  durable.SnapshotStore
	Fallback   durable.EventLog
	Projection vfs.Projection
	// DisableStreams uses the fallback EventLog instead of Workflow Streams.
	// Tests that use the Temporal testsuite mock must set this.
	DisableStreams bool
	// TurnLocality, when > 0, pins a turn's activities to one worker.
	TurnLocality time.Duration
	// ActivityTimeout is Inference/Tool StartToCloseTimeout. Zero is 10 minutes.
	ActivityTimeout time.Duration
	// HeartbeatTimeout is the activity heartbeat timeout. Zero is 30 seconds.
	HeartbeatTimeout time.Duration
	// ActivityAttempts is Temporal MaximumAttempts. Zero is 3. 1 means no retry.
	ActivityAttempts int32
}

type EmitEventInput struct {
	SessionID durable.SessionID
	Event     tacklr.StreamEvent
}

type InferenceInput struct {
	SessionID     durable.SessionID
	AgentID       string
	MCPServers    []mcp.MCPConfig
	User          *tacklr.Message
	HadToolRound  bool
	ModelRequests int
	Resume        map[string][]byte
	Auth          durable.AuthContext
	Mounts        []durable.MountRecipe
	Specialist    string
	// State is host userState merged after checkpoint restore.
	State map[string]any
}

type InferenceOutput struct {
	Complete  bool
	ToolCalls []tacklr.ToolCall
	Result    string
}

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

type ToolInput struct {
	SessionID  durable.SessionID
	AgentID    string
	MCPServers []mcp.MCPConfig
	Call       tacklr.ToolCall
	Auth       durable.AuthContext
	Mounts     []durable.MountRecipe
	Specialist string
	// Known is this session's child ids for list_children (not a ChildOp ledger).
	Known []durable.SessionID
	State map[string]any
}

type ToolOutput struct {
	Interrupted   bool
	InterruptID   string
	InterruptData []byte
	SpawnID       durable.SessionID
	SpawnSpec     string
	SpawnTask     string
	CancelID      durable.SessionID
	AwaitID       durable.SessionID
}

type WorkflowInput struct {
	SessionID  durable.SessionID
	AgentID    string
	MCPServers []mcp.MCPConfig
	Mounts     []durable.MountRecipe
	Auth       durable.AuthContext
	// TurnLocalityTimeout, when > 0, pins the turn's activities to one worker
	// (Temporal CreateSession). Zero skips worker sessions: activities can run
	// on any worker. There is no default timeout.
	TurnLocalityTimeout time.Duration
	// ActivityTimeout is StartToCloseTimeout for Inference/Tool activities.
	// Zero means 10 minutes (resolveActivityTimeout).
	ActivityTimeout time.Duration
	// HeartbeatTimeout is the activity heartbeat timeout. Zero means 30 seconds.
	HeartbeatTimeout time.Duration
	// ActivityAttempts is Temporal MaximumAttempts. Zero means 3.
	ActivityAttempts int32
	// Prompt, when set, runs one turn then completes the workflow (spawn_specialist child).
	Prompt     string
	Parent     durable.SessionID
	Specialist string
	// State is CreateSession.State, already JSON-roundtripped by Runtime.CreateSession.
	State map[string]any
}