checkpoint

type BackendIngressInput struct {
	Call         lipapi.Call
	Scope        scope.PrincipalScopeView
	AttemptID    string
	BLegID       string
	ALegID       string
	BackendID    string
	Model        string
	CheckpointID string
	StreamID     string
	TraceID      string // runtime trace; defaults to Call.ID when empty (never FE stream id)
	Perspective  metering.EconomicPerspective
	Now          time.Time
}

type EgressFactInput struct {
	Checkpoint      metering.Checkpoint // boundary/lifecycle/correlation template
	FactID          string
	Sequence        int64
	Kind            metering.FactKind
	Quantities      []metering.Quantity
	Outcome         metering.AttemptOutcome
	Surfaced        metering.SurfacedState
	Presence        metering.Presence
	Source          metering.Source
	Authority       metering.Authority
	Now             time.Time
	Money           *metering.MoneyObservation
	SourceID        string
	IdentityVersion int
	SourceEventKind string
	SourceRevision  int64
}

type FrontendIngressInput struct {
	Call         lipapi.Call
	Scope        scope.PrincipalScopeView
	FrontendID   string
	CheckpointID string
	StreamID     string
	TraceID      string // runtime trace; defaults to Call.ID when empty
	Perspective  metering.EconomicPerspective
	Now          time.Time
}

type IngressFactInput struct {
	Checkpoint      metering.Checkpoint
	FactID          string
	Sequence        int64
	Kind            metering.FactKind
	Quantities      []metering.Quantity
	Presence        metering.Presence
	Source          metering.Source
	Authority       metering.Authority
	Now             time.Time
	SourceID        string
	IdentityVersion int
	SourceEventKind string
	SourceRevision  int64
}

type RequestHolder struct {
	FrontendIngress *Snapshot
	BackendIngress  map[string]*Snapshot // keyed by AttemptID
	// contains filtered or unexported fields
}

type Snapshot struct {
	Public   metering.Checkpoint
	Call     lipapi.Call
	Evidence *WireAttemptEvidence
}

type WireAttemptEvidence struct {
	SourceDigest    [32]byte
	RewriteDigest   [32]byte
	AttemptDigest   [32]byte
	Model           string
	MaxOutputTokens *int
}

type WireBackendIngressInput struct {
	RequestID       string
	TraceID         string // runtime trace; defaults to RequestID when empty
	AttemptID       string
	BLegID          string // defaults to AttemptID when empty
	ALegID          string
	SessionID       string // authoritative session ID or correlation ID
	Scope           scope.PrincipalScopeView
	BackendID       string
	Model           string
	CheckpointID    string // defaults to "operator-attempt:" + AttemptID
	StreamID        string // defaults to "operator-attempt:" + AttemptID
	MaxOutputTokens *int   // optional max output token bound
	Perspective     metering.EconomicPerspective
	Now             time.Time

	// Digest evidence (Req 15.3, Design 10):
	SourceDigest  [32]byte // SHA-256 digest of captured source payload
	RewriteDigest [32]byte // digest of model rewrite token / splice (or zero if no rewrite)
	AttemptDigest [32]byte // composite attempt digest
}

type WireFrontendIngressInput struct {
	RequestID       string
	TraceID         string // runtime trace; defaults to RequestID when empty
	CheckpointID    string // defaults to "customer-request:" + RequestID
	StreamID        string // defaults to "customer-request:" + RequestID
	Scope           scope.PrincipalScopeView
	FrontendID      string
	ALegID          string
	SessionID       string // authoritative session ID or correlation ID
	MaxOutputTokens *int   // optional max output token bound
	Perspective     metering.EconomicPerspective
	Now             time.Time
}