console

type Cluster interface {
	// Organization returns the AgentOrganization with the given platform
	// organisation id, or nil.
	Organization(ctx context.Context, orgID string) (*v1alpha1.AgentOrganization, error)
	// Seats returns the organisation's AgentSeats keyed by seat id.
	Seats(ctx context.Context, org *v1alpha1.AgentOrganization) (map[string]v1alpha1.AgentSeat, error)
	// Pods returns the organisation's seat runner Pods keyed by seat key.
	Pods(ctx context.Context, org *v1alpha1.AgentOrganization) (map[string]corev1.Pod, error)
	// Claims returns the phases of the namespace's seat volume claims by name.
	Claims(ctx context.Context, namespace string) (map[string]corev1.PersistentVolumeClaimPhase, error)
}

type Config struct {
	Platform Platform
	Cluster  Cluster
	Log      *slog.Logger
	// PollInterval is how often the live activity stream polls the platform.
	PollInterval time.Duration
	// Now is the clock; nil uses time.Now.
	Now func() time.Time
}

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

type Platform interface {
	Organizations(ctx context.Context) ([]runtimeapi.ConsoleOrganization, error)
	Organization(ctx context.Context, orgID string) (*runtimeapi.ConsoleOrganization, error)
	Seats(ctx context.Context, orgID string) ([]runtimeapi.ConsoleSeatStatus, error)
	Seat(ctx context.Context, seatID string) (*runtimeapi.ConsoleSeatDetail, error)
	Execution(ctx context.Context, id string) (*runtimeapi.ConsoleExecutionDetail, error)
	Conversations(ctx context.Context, orgID string) ([]runtimeapi.ConsoleConversation, error)
	Conversation(ctx context.Context, id string) (*runtimeapi.ConsoleConversationDetail, error)
	Operations(ctx context.Context, orgID, seat, status string) ([]runtimeapi.ConsoleOperation, error)
	Artifacts(ctx context.Context, orgID string) ([]runtimeapi.ConsoleArtifact, error)
	// Work lists work items in shared stores with their publication state.
	Work(ctx context.Context, orgID string) ([]runtimeapi.ConsoleWorkItem, error)
	// Executions lists the organisation's runs, newest first, optionally in one state.
	Executions(ctx context.Context, orgID, state string) ([]runtimeapi.ConsoleExecution, error)
	// Activity returns items after the given time, or the latest limit items
	// when after is zero.
	Activity(ctx context.Context, orgID string, after time.Time, limit int) ([]runtimeapi.ConsoleActivityItem, error)
}

type PlatformClient struct {
	BaseURL   string
	TokenFile string
	HTTP      *http.Client
}