Interface GovernedNextObservationStore<TFeatures>

interface GovernedNextObservationStore<
    TFeatures extends Record<string, unknown>,
> {
    all(): Promise<readonly Observation<TFeatures>[]>;
    get(id: string): Promise<Observation<TFeatures> | undefined>;
    purgeExpired(): Promise<number>;
    recordEvent(
        action: "verification" | "abstention",
        observationId: string | undefined,
        outcome: "allowed" | "denied" | "completed",
        reason?: string,
    ): Promise<void>;
    remove(id: string): Promise<boolean>;
    restore(snapshot: NextSnapshot<TFeatures>): Promise<void>;
    save(observation: Observation<TFeatures>): Promise<void>;
    snapshot(): Promise<NextSnapshot<TFeatures>>;
    transaction<TResult>(
        operation: (
            store: NextObservationStore<TFeatures>,
        ) => TResult | Promise<TResult>,
    ): Promise<TResult>;
}