diff --git a/apps/randomness/src/Randomness.ts b/apps/randomness/src/Randomness.ts index bee98c2874..93e9856424 100644 --- a/apps/randomness/src/Randomness.ts +++ b/apps/randomness/src/Randomness.ts @@ -13,6 +13,12 @@ export enum RandomnessStatus { REVEAL_NOT_SUBMITTED_ON_TIME = "REVEAL_NOT_SUBMITTED_ON_TIME", } +export const FINALIZED_STATUSES = [ + RandomnessStatus.REVEAL_EXECUTED, + RandomnessStatus.REVEAL_FAILED, + RandomnessStatus.REVEAL_NOT_SUBMITTED_ON_TIME, +] + export class Randomness { public timestamp: bigint public value: bigint diff --git a/apps/randomness/src/RandomnessRepository.ts b/apps/randomness/src/RandomnessRepository.ts index b74b0fb157..b93f80f16d 100644 --- a/apps/randomness/src/RandomnessRepository.ts +++ b/apps/randomness/src/RandomnessRepository.ts @@ -1,7 +1,7 @@ import { type UUID, unknownToError } from "@happy.tech/common" import { bigIntToZeroPadded } from "@happy.tech/common" import { type Result, ResultAsync } from "neverthrow" -import type { Randomness, RandomnessStatus } from "./Randomness" +import { FINALIZED_STATUSES, type Randomness, type RandomnessStatus } from "./Randomness" import { db } from "./db/driver" import { randomnessEntityToRow, randomnessRowToEntity } from "./db/types" @@ -87,6 +87,7 @@ export class RandomnessRepository { "<", bigIntToZeroPadded(latestBlockTimestamp - COMMITMENT_PRUNE_INTERVAL_SECONDS, DIGITS_MAX_UINT256), ) + .where("status", "in", FINALIZED_STATUSES) .execute(), unknownToError, ).map(() => undefined)