process and save transaction cids when header watcher enabled (#53)

* process and save transaction cids when header watcher enabled

* bump version

docker-compose.yml

@@ -31,7 +31,7 @@ services:
     image: postgres:10.12-alpine
     environment:
       - POSTGRES_USER=vdbm
-      - POSTGRES_DB=vulcanize_public
+      - POSTGRES_DB=indexer
       - POSTGRES_PASSWORD=password
     volumes:
       - indexer_db_data:/var/lib/postgresql/data

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@vulcanize/eth-watcher-ts",
-  "version": "0.0.19",
+  "version": "0.0.20",
   "type": "commonjs",
   "types": "./dist",
   "main": "./dist/server.js",

src/repositories/graphqlRepository.ts

@@ -261,6 +261,23 @@ export default class GraphqlRepository {
 						txRoot
 						uncleRoot
 						stateRoot
+						ethTransactionCidsByHeaderId {
+						  nodes {
+							id
+							cid
+							headerId
+							index
+							mhKey
+							nodeId
+							dst
+							src
+							txData
+							txHash
+							blockByMhKey {
+							  data
+							}
+						  }
+						}
 					}
 					}
 				}

src/run.ts

@@ -3,6 +3,7 @@ dotenv.config();
 
 import { EthWatcherServer } from './server';
 import DataService from './services/dataService';
+import HeaderCids from "./models/eth/headerCids";
 
 process.on('unhandledRejection', (reason, p) => {
 	console.log('Unhandled Rejection at:', p, 'reason:', reason);
@@ -20,7 +21,15 @@ process.on('unhandledRejection', (reason, p) => {
 			}
 			dataService.processState(data.relatedNode)
 		},
-		processHeader: (data) => dataService.processHeader(data),
+		processHeader: async (data) => {
+			const header: HeaderCids = await dataService.processHeader(data);
+			if (data?.ethTransactionCidsByHeaderId?.nodes && data?.ethTransactionCidsByHeaderId?.nodes.length > 0) {
+				const txs = data.ethTransactionCidsByHeaderId.nodes;
+				for (const tx of txs) {
+					await dataService.processTransaction(tx, header.id);
+				}
+			}
+		},
 		processEvent: (data) => {
 			if (!data) {
 				return;

src/types/graphql.ts

@@ -26,6 +26,10 @@ export type EthTransactionCid = {
     blockByMhKey: BlockByMhKey;
 };
 
+export type ethTransactionCids = {
+    nodes: EthTransactionCid[];
+}
+
 export type EthHeaderCid = {
     td: string;
     cid: string;
@@ -42,6 +46,7 @@ export type EthHeaderCid = {
     uncleRoot: string;
     timesValidated: number;
     timestamp: string;
+    ethTransactionCidsByHeaderId: ethTransactionCids;
 }
 
 export type EthStateCid = {