From 20ecdcdee808f97ac19164751cf70d34e1f3c95d Mon Sep 17 00:00:00 2001
From: dapplion <35266934+dapplion@users.noreply.github.com>
Date: Fri, 4 Aug 2023 17:47:12 +0200
Subject: [PATCH] Ensure bn Buckets are sorted and unique

---
 packages/beacon-node/src/db/buckets.ts        | 20 +++++++++++--------
 .../beacon-node/test/unit/db/buckets.test.ts  | 20 +++++++++++++++++++
 2 files changed, 32 insertions(+), 8 deletions(-)
 create mode 100644 packages/beacon-node/test/unit/db/buckets.test.ts

diff --git a/packages/beacon-node/src/db/buckets.ts b/packages/beacon-node/src/db/buckets.ts
index 0ad10ed904e..15b0cc4b487 100644
--- a/packages/beacon-node/src/db/buckets.ts
+++ b/packages/beacon-node/src/db/buckets.ts
@@ -19,9 +19,7 @@ export enum Bucket {
   // eth1 processing
   phase0_eth1Data = 8, // timestamp -> Eth1Data
   index_depositDataRoot = 9, // depositIndex -> Root<DepositData>
-  phase0_depositEvent = 19, // depositIndex -> DepositEvent
-  phase0_preGenesisState = 30, // Single = phase0.BeaconState
-  phase0_preGenesisStateLastProcessedBlock = 31, // Single = Uint8
+
   // op pool
   // phase0_attestation = 10, // DEPRECATED on v0.25.0
   // phase0_aggregateAndProof = 11, // Root -> AggregateAndProof, DEPRECATED on v.27.0
@@ -30,7 +28,9 @@ export enum Bucket {
   phase0_proposerSlashing = 14, // ValidatorIndex -> ProposerSlashing
   phase0_attesterSlashing = 15, // Root -> AttesterSlashing
   capella_blsToExecutionChange = 16, // ValidatorIndex -> SignedBLSToExecutionChange
+
   // allForks_pendingBlock = 25, // Root -> SignedBeaconBlock // DEPRECATED on v0.30.0
+  phase0_depositEvent = 19, // depositIndex -> DepositEvent
 
   index_stateArchiveRootIndex = 26, // State Root -> slot
 
@@ -42,9 +42,13 @@ export enum Bucket {
   // can be ignored and safely deleted later on
   allForks_blobsSidecar = 29, // DENEB BeaconBlockRoot -> BlobsSidecar
 
-  // https://github.com/ChainSafe/lodestar/issues/5753
-  // eslint-disable-next-line @typescript-eslint/no-duplicate-enum-values
-  allForks_blobsSidecarArchive = 30, // DENEB BeaconBlockSlot -> BlobsSidecar
+  phase0_preGenesisState = 30, // Single = phase0.BeaconState
+  phase0_preGenesisStateLastProcessedBlock = 31, // Single = Uint8
+
+  // TODO DENEB: cleanup the below buckets once BlobsSidecar fully migrated to BlobSidecars
+  // note: below buckets would not be in use till deneb hf so their number assignments
+  // can be ignored and safely deleted later on
+  allForks_blobsSidecarArchive = 32, // DENEB BeaconBlockSlot -> BlobsSidecar
 
   // Lightclient server
   // altair_bestUpdatePerCommitteePeriod = 30, // DEPRECATED on v0.32.0
@@ -55,6 +59,8 @@ export enum Bucket {
   // altair_lightClientSyncCommitteeProof = 35, // DEPRECATED on v0.32.0
   // index_lightClientInitProof = 36, // DEPRECATED on v0.32.0
 
+  backfilled_ranges = 42, // Backfilled From to To, inclusive of both From, To
+
   // Buckets to support LightClient server v2
   lightClient_syncCommitteeWitness = 51, // BlockRoot -> SyncCommitteeWitness
   lightClient_syncCommittee = 52, // Root(altair.SyncCommittee) -> altair.SyncCommittee
@@ -63,8 +69,6 @@ export enum Bucket {
   // 54 was for bestPartialLightClientUpdate, allocate a fresh one
   // lightClient_bestLightClientUpdate = 55, // SyncPeriod -> LightClientUpdate // DEPRECATED on v1.5.0
   lightClient_bestLightClientUpdate = 56, // SyncPeriod -> [Slot, LightClientUpdate]
-
-  backfilled_ranges = 42, // Backfilled From to To, inclusive of both From, To
 }
 
 export function getBucketNameByValue<T extends Bucket>(enumValue: T): keyof typeof Bucket {
diff --git a/packages/beacon-node/test/unit/db/buckets.test.ts b/packages/beacon-node/test/unit/db/buckets.test.ts
new file mode 100644
index 00000000000..0f193e7ffbc
--- /dev/null
+++ b/packages/beacon-node/test/unit/db/buckets.test.ts
@@ -0,0 +1,20 @@
+import {Bucket} from "../../../src/db/buckets.js";
+
+describe("db buckets", () => {
+  it("sorted and unique", () => {
+    let prevBucket = -1;
+
+    for (const key of Object.keys(Bucket)) {
+      if (isNaN(parseInt(key))) {
+        const bucket = (Bucket as unknown as Record<string, number>)[key];
+        if (bucket < prevBucket) {
+          throw Error(`Bucket ${key} not sorted`);
+        }
+        if (bucket === prevBucket) {
+          throw Error(`Bucket ${key}: ${bucket} duplicated`);
+        }
+        prevBucket = bucket;
+      }
+    }
+  });
+});