registry

type ConversationAffinity struct {
	RunnerID           string
	EnvironmentProfile string
}

type CredentialAuthorizer interface {
	RunnerCredentialActive(ctx context.Context, credentialID, runnerID, hostInstanceID, workspacePath string) (bool, error)
}

type Link interface {
	Call(ctx context.Context, method string, params any, result any) error
	CallTracked(ctx context.Context, method string, params any, result any, onRequestID func(string)) error
	Notify(ctx context.Context, method string, params any) error
	Close() error
	Done() <-chan struct{}
	Err() error
}

type Options struct {
	HeartbeatInterval time.Duration
	HeartbeatTimeout  time.Duration
	RunLeaseGrace     time.Duration
	Now               func() time.Time
	NewID             func(prefix string) (string, error)
	Persistence       Persistence
	Credentials       CredentialAuthorizer
}

type PersistedState struct {
	Runners    []Runner
	Runs       []Run
	Affinities map[string]ConversationAffinity
}

type Persistence interface {
	Load(ctx context.Context) (PersistedState, error)
	SaveRunner(ctx context.Context, runner Runner) error
	SaveRun(ctx context.Context, run Run) error
	SaveRunnerAndRun(ctx context.Context, runner Runner, run Run) error
	SaveRunnerAndRuns(ctx context.Context, runner Runner, runs []Run) error
	BindConversation(ctx context.Context, conversationID, runnerID, environmentProfile string, now time.Time) error
	ConversationAffinity(ctx context.Context, conversationID string) (ConversationAffinity, bool, error)
	RemoveRunner(ctx context.Context, runnerID string, force bool) (RemovalResult, error)
	Close() error
}

type RegistrationAuthMode string

type RegistrationPrincipal struct {
	Mode           RegistrationAuthMode
	CredentialID   string
	RunnerID       string
	HostInstanceID string
	WorkspacePath  string
}

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

type RemovalResult struct {
	RunnerID                      string `json:"runnerId"`
	RemovedRuns                   int    `json:"removedRuns"`
	RemovedConversationAffinities int    `json:"removedConversationAffinities"`
}

type Run struct {
	ID             string    `db:"id" json:"id"`
	ConversationID string    `db:"conversation_id" json:"conversationId"`
	RunnerID       string    `db:"runner_id" json:"runnerId"`
	Status         RunStatus `db:"status" json:"status"`
	ManifestDigest string    `db:"manifest_digest" json:"manifestDigest,omitempty"`
	ManifestJSON   string    `db:"manifest_json" json:"-"`
	Error          string    `db:"error" json:"error,omitempty"`
	CreatedAt      time.Time `db:"created_at" json:"createdAt"`
	UpdatedAt      time.Time `db:"updated_at" json:"updatedAt"`
}

type RunStatus = protocol.RunStatus

type Runner struct {
	ID                 string             `json:"id"`
	DisplayName        string             `json:"displayName,omitempty"`
	Host               protocol.Host      `json:"host"`
	Workspace          protocol.Workspace `json:"workspace"`
	KodeletVersion     string             `json:"kodeletVersion"`
	ManifestDigest     string             `json:"manifestDigest,omitempty"`
	ManifestChanged    bool               `json:"manifestChanged"`
	CompatibilityError string             `json:"compatibilityError,omitempty"`
	Status             RunnerStatus       `json:"status"`
	Connected          bool               `json:"connected"`
	ConcurrentRuns     bool               `json:"concurrentRuns"`
	WorkspaceGitDiff   bool               `json:"workspaceGitDiff"`
	WorkspaceTerminal  bool               `json:"workspaceTerminal"`
	ActiveRunID        string             `json:"activeRunId,omitempty"`
	ActiveRunIDs       []string           `json:"activeRunIds,omitempty"`
	ConnectionID       string             `json:"connectionId,omitempty"`
	Generation         int64              `json:"generation"`
	ConnectedAt        time.Time          `json:"connectedAt,omitempty"`
	LastHeartbeatAt    time.Time          `json:"lastHeartbeatAt,omitempty"`
	CreatedAt          time.Time          `json:"createdAt"`
	UpdatedAt          time.Time          `json:"updatedAt"`
}

type RunnerStatus string

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

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

type UIRequestIdentity struct {
	RunnerID     string
	ConnectionID string
	Generation   int64
}

type UIRequestRouter interface {
	HandleRunnerUIRequest(ctx context.Context, identity UIRequestIdentity, method string, params json.RawMessage) (any, *protocol.RPCError)
}