adminapi

type B5AdminBackend interface {
	Status(context.Context) (B5StatusView, error)
	ListSessions(context.Context, B5ListFilter) (B5SessionPage, error)
	GetSession(context.Context, string) (*B5SessionView, error)
	ListTransactions(context.Context, B5ListFilter) (B5TransactionPage, error)
	GetTransaction(context.Context, string) (*B5TransactionView, error)
	ListQuarantine(context.Context, B5ListFilter) (B5QuarantinePage, error)
	Inventory(context.Context, string) (B5InventoryView, error)
	Metrics(context.Context, string) (B5MetricsView, error)
	ListReconciliation(context.Context, B5ListFilter) (B5ReconciliationPage, error)
	ConfirmDiscard(context.Context, string) (B5QuarantineView, error)
	Reconcile(context.Context, B5ReconcileInput) ([]B5ReconciliationView, error)
}

type B5BackendIdentityView struct {
	ServerID       string     `json:"server_id"`
	Database       string     `json:"database"`
	PID            int32      `json:"pid"`
	BackendStarted *time.Time `json:"backend_started_at,omitempty"`
	DialPermitID   string     `json:"dial_permit_id"`
}

type B5DurationMetric struct {
	Phase string  `json:"phase"`
	P50MS float64 `json:"p50_ms"`
	P95MS float64 `json:"p95_ms"`
	P99MS float64 `json:"p99_ms"`
}

type B5EventView struct {
	Sequence       uint64    `json:"sequence"`
	Type           string    `json:"type"`
	SchemaID       string    `json:"schema_id"`
	SchemaVersion  uint16    `json:"schema_version"`
	PreviousDigest string    `json:"previous_digest"`
	Digest         string    `json:"digest"`
	CreatedAt      time.Time `json:"created_at"`
}

type B5InventoryChildView struct {
	LeaseID       string                `json:"lease_id"`
	ClaimID       string                `json:"claim_id"`
	DatasourceID  string                `json:"datasource_id"`
	State         string                `json:"state"`
	Charged       bool                  `json:"charged"`
	DialAttempted bool                  `json:"dial_attempted"`
	Backend       B5BackendIdentityView `json:"backend"`
}

type B5InventoryView struct {
	DialPermits int                    `json:"dial_permits"`
	Children    []B5InventoryChildView `json:"children"`
}

type B5ListFilter struct {
	Page, PageSize int
	Status         string
	Phase          string
	DatasourceID   string
	Owner          string
	Query          string
}

type B5MetricsView struct {
	Sessions               int64              `json:"sessions"`
	Transactions           int64              `json:"transactions"`
	Unknown                int64              `json:"unknown"`
	DiscardUnconfirmed     int64              `json:"discard_unconfirmed"`
	QuarantineCount        int64              `json:"quarantine_count"`
	QuarantineChargedSlots int64              `json:"quarantine_charged_slots"`
	HardBudget             int64              `json:"hard_budget"`
	QuarantineBudgetRatio  float64            `json:"quarantine_budget_ratio"`
	SessionStates          []B5StateCount     `json:"session_states"`
	TransactionStates      []B5StateCount     `json:"transaction_states"`
	PhaseDurations         []B5DurationMetric `json:"phase_durations"`
}

type B5QuarantinePage struct {
	Total int64              `json:"total"`
	List  []B5QuarantineView `json:"list"`
}

type B5QuarantineView struct {
	LeaseID        string                `json:"lease_id"`
	ClaimID        string                `json:"claim_id"`
	DatasourceID   string                `json:"datasource_id"`
	Reason         string                `json:"reason"`
	AgeSeconds     int64                 `json:"age_seconds"`
	ChargedSlots   int                   `json:"charged_slots"`
	Generation     uint64                `json:"generation"`
	InventoryEpoch uint64                `json:"inventory_epoch"`
	Backend        B5BackendIdentityView `json:"backend"`
}

type B5ReconcileInput struct {
	TransactionID string `json:"transaction_id,omitempty"`
	DatasourceID  string `json:"datasource_id,omitempty"`
	Confirm       bool   `json:"confirm"`
}

type B5ReconciliationPage struct {
	Total int64                  `json:"total"`
	List  []B5ReconciliationView `json:"list"`
}

type B5ReconciliationView struct {
	EventUUID          string    `json:"event_uuid"`
	TransactionID      string    `json:"transaction_id"`
	Sequence           uint64    `json:"sequence"`
	Classification     string    `json:"classification"`
	ReportedDurability string    `json:"reported_durability"`
	AppendConfirmation string    `json:"append_confirmation"`
	Reconciliation     string    `json:"reconciliation"`
	Replayed           bool      `json:"replayed"`
	UpdatedAt          time.Time `json:"updated_at"`
}

type B5RuntimePlane interface {
	Status(context.Context) (B5StatusView, error)
	ListQuarantine(context.Context, B5ListFilter) (B5QuarantinePage, error)
	Inventory(context.Context, string) (B5InventoryView, error)
	Metrics(context.Context, string) (B5MetricsView, error)
	ListReconciliation(context.Context, B5ListFilter) (B5ReconciliationPage, error)
	ConfirmDiscard(context.Context, string) (B5QuarantineView, error)
	Reconcile(context.Context, B5ReconcileInput) ([]B5ReconciliationView, error)
}

type B5SessionPage struct {
	Total int64           `json:"total"`
	List  []B5SessionView `json:"list"`
}

type B5SessionView struct {
	ID                string    `json:"id"`
	AgentID           string    `json:"agent_id"`
	TenantID          string    `json:"tenant_id"`
	PrincipalID       string    `json:"principal_id"`
	Status            string    `json:"status"`
	OwnerInstanceID   string    `json:"owner_instance_id"`
	OwnerEpoch        uint64    `json:"owner_epoch"`
	StickyRoute       string    `json:"sticky_route"`
	IdleExpiresAt     time.Time `json:"idle_expires_at"`
	AbsoluteExpiresAt time.Time `json:"absolute_expires_at"`
	CreatedAt         time.Time `json:"created_at"`
	UpdatedAt         time.Time `json:"updated_at"`
}

type B5StateCount struct {
	State string `json:"state"`
	Count int64  `json:"count"`
}

type B5StatusView struct {
	Enabled bool   `json:"enabled"`
	State   string `json:"state"`
	Reason  string `json:"reason"`
	Ready   bool   `json:"ready"`
}

type B5TransactionPage struct {
	Total int64               `json:"total"`
	List  []B5TransactionView `json:"list"`
}

type B5TransactionView struct {
	ID                   string        `json:"id"`
	SessionID            string        `json:"session_id"`
	DatasourceID         string        `json:"datasource_id"`
	Status               string        `json:"status"`
	Phase                string        `json:"phase"`
	PlanDigest           string        `json:"plan_digest"`
	ApprovalID           *string       `json:"approval_id,omitempty"`
	OwnerEpoch           uint64        `json:"owner_epoch"`
	IdleDeadline         time.Time     `json:"idle_deadline"`
	WallDeadline         time.Time     `json:"wall_deadline"`
	StatementDeadline    *time.Time    `json:"statement_deadline,omitempty"`
	BackendPID           *int          `json:"backend_pid,omitempty"`
	BackendStartedAt     *time.Time    `json:"backend_started_at,omitempty"`
	ConnectionGeneration uint64        `json:"connection_generation"`
	LeaseGeneration      uint64        `json:"lease_generation"`
	StatementCount       int           `json:"statement_count"`
	Sequence             uint64        `json:"sequence"`
	PreviousEventDigest  string        `json:"previous_event_digest"`
	CreatedAt            time.Time     `json:"created_at"`
	UpdatedAt            time.Time     `json:"updated_at"`
	Events               []B5EventView `json:"events"`
}

type ChainManifestProvider = store.ChainManifestProvider

type DatasourcePinger interface {
	Ping(ctx context.Context, datasource model.Datasource) (PingResult, error)
}

type DemoRunner interface {
	ProcessDemo(context.Context, pipeline.Request) (pipeline.Response, error)
}

type Deps struct {
	Runtime          *bootstrap.Runtime
	Config           config.Config
	AdminUsername    string
	AdminPassword    string
	TokenKey         []byte
	RBAC             *rbac.Service
	DatasourcePinger DatasourcePinger
	Native           NativeBackend
	Discovery        DiscoveryRunner
	ChainManifests   ChainManifestProvider
	// B5Admin is nil only for an explicit feature-off assembly. S9 routes remain
	// registered so clients receive stable empty capability responses, while an
	// activated assembly must explicitly provide the
	// read/operation boundary.
	B5Admin B5AdminBackend
	// EventStreamHeartbeatInterval is injectable for deterministic stream tests.
	// Zero uses the production interval.
	EventStreamHeartbeatInterval time.Duration
	// contains filtered or unexported fields
}

type DiscoveryRunner interface {
	Discover(context.Context, string, string, discovery.ScanRequest) (discovery.ScanResult, error)
}

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

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

type NativeBackend interface {
	NativeQueryRead(context.Context, model.Datasource, executor.NativeQueryRequest) (executor.NativeQueryResult, error)
	NativeDiscover(context.Context, model.Datasource) (executor.NativeCatalog, error)
	NativeServerVersion(context.Context, model.Datasource) (string, error)
}

type PingResult struct {
	OK           bool    `json:"ok"`
	LatencyMS    int64   `json:"latency_ms"`
	ErrorCode    *string `json:"error_code,omitempty"`
	ErrorMessage *string `json:"error_message,omitempty"`
}

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