From 13dfd9ebb4bef808716a265bf8ece4b7b9c8f89d Mon Sep 17 00:00:00 2001
From: prathamesh <prathamesh.musale0@gmail.com>
Date: Wed, 6 Oct 2021 12:58:06 +0530
Subject: [PATCH] Change IPLD block structure

---
 .../src/templates/hooks-template.handlebars   | 24 +++++++++++++++----
 .../src/templates/indexer-template.handlebars | 18 ++++++++++++++
 2 files changed, 38 insertions(+), 4 deletions(-)

diff --git a/packages/codegen/src/templates/hooks-template.handlebars b/packages/codegen/src/templates/hooks-template.handlebars
index 2eb4af08..82e51195 100644
--- a/packages/codegen/src/templates/hooks-template.handlebars
+++ b/packages/codegen/src/templates/hooks-template.handlebars
@@ -26,9 +26,25 @@ export async function handleBlock (indexer: Indexer, jobData: any): Promise<void
     const block = event.block;
     const contractAddress = event.contract;
 
+    const ipldBlockData: any = {};
+
     const oldIpldBlock = await indexer.getIPLDBlock(block, contractAddress);
 
-    const ipldBlockData: any = {};
+    if (!oldIpldBlock) {
+      ipldBlockData.meta = {
+        id: contractAddress,
+        kind: 'diff',
+        parent: {
+          '/': null
+        }
+      };
+
+      ipldBlockData.ethBlock = {
+        cid: await indexer.getBlockCID(block.blockHash),
+        num: block.blockNumber
+      };
+    }
+
     const eventData = indexer.getResultEvent(event);
 
     switch (event.eventName) {
@@ -48,8 +64,8 @@ export async function handleBlock (indexer: Indexer, jobData: any): Promise<void
         //      }
         //   }
         // }
-        _.set(ipldBlockData, `_balances[${from}]`, fromBalance);
-        _.set(ipldBlockData, `_balances[${to}]`, toBalance);
+        _.set(ipldBlockData, `state._balances[${from}]`, fromBalance);
+        _.set(ipldBlockData, `state._balances[${to}]`, toBalance);
 
         break;
       }
@@ -67,7 +83,7 @@ export async function handleBlock (indexer: Indexer, jobData: any): Promise<void
         //      }
         //   }
         // }
-        _.set(ipldBlockData, `_allowances[${owner}][${spender}]`, allowance);
+        _.set(ipldBlockData, `state._allowances[${owner}][${spender}]`, allowance);
 
         break;
       }
diff --git a/packages/codegen/src/templates/indexer-template.handlebars b/packages/codegen/src/templates/indexer-template.handlebars
index df561250..9381e3db 100644
--- a/packages/codegen/src/templates/indexer-template.handlebars
+++ b/packages/codegen/src/templates/indexer-template.handlebars
@@ -178,6 +178,24 @@ export class Indexer {
     return this._db.saveOrUpdateIPLDBlock(ipldBlock);
   }
 
+  async getBlockCID (blockHash: string): Promise<string> {
+    assert(blockHash);
+
+    const {
+      allEthHeaderCids: {
+        nodes: [
+          {
+            cid
+          }
+        ]
+      }
+    } = await this._postgraphileClient.getBlockWithTransactions({ blockHash });
+
+    assert(cid);
+
+    return cid;
+  }
+
   async triggerIndexingOnEvent (event: Event): Promise<void> {
     const resultEvent = this.getResultEvent(event);