re-add id & block_id

pinax-network · Dec 1, 2023 · 797861a · 797861a
1 parent 46c4904
commit 797861a
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/clickhouse/handleSinkRequest.ts b/src/clickhouse/handleSinkRequest.ts
@@ -148,8 +148,10 @@ function insertEntityChange(
   values: Record<string, unknown>,
   metadata: { id: string; clock: Clock; manifest: Manifest; cursor: string }
 ) {
+  values["id"] = metadata.id; // Entity ID
+  values["block_id"] = metadata.clock.id; // Block Index
   values["chain"] = metadata.manifest.chain;
-  values["block_number"] = metadata.clock.number;
+  values["block_number"] = metadata.clock.number; // Block Number
   values["module_hash"] = metadata.manifest.moduleHash;
   values["timestamp"] = Number(new Date(metadata.clock.timestamp)); // Block timestamp
 

diff --git a/src/clickhouse/table-initialization.ts b/src/clickhouse/table-initialization.ts
@@ -23,8 +23,10 @@ export async function initializeDefaultTables(): Promise<Result> {
 }
 
 const extraColumns = [
+  "id           String",
   "chain        LowCardinality(String)",
   "block_number UInt32",
+  "block_id     FixedString(64)",
   "module_hash  FixedString(40)",
   "timestamp    DateTime64(3, 'UTC')",
 ];