feat: balaneKeeper MVP, fix onchain TX indexing

vsc-eco · Mar 21, 2024 · dda33bd · dda33bd
1 parent 4db4f67
commit dda33bd
Show file tree

Hide file tree

Showing 6 changed files with 456 additions and 46 deletions.
diff --git a/src/services/new/index.ts b/src/services/new/index.ts
@@ -19,10 +19,7 @@ import { ContractEngineV2 } from './contractEngineV2';
 import { VersionManager } from './witness/versionManager';
 import { ElectionManager } from './witness/electionManager';
 
-const CONSTANTS = {
-    //Reset block records 
-    tb_reset_key: '1'
-}
+
 export class NewCoreService {
     config: Config;
     consensusKey: BlsDID;

diff --git a/src/services/new/transactionPool.ts b/src/services/new/transactionPool.ts
@@ -299,45 +299,56 @@ export class TransactionPoolV2 {
      * @returns 
      */
     protected async blockParser(args) {
-        const {tx, blkHeight} = args.data
-        // console.log('picked up TX', tx, fullTx)
-        if(tx.id === 'vsc.announce_tx' || tx.id === 'vsc.tx') {
-            const json = JSON.parse(tx.json)
+        try {
 
-            if(json.net_id !== this.self.config.get('network.id')) {
-                return;
-            }
+
+            const {tx, blkHeight} = args.data
 
-            const required_auths = []
-            required_auths.push(...tx.required_posting_auths.map(e => {
-                return `${e}?type=posting`
-            }))
-            required_auths.push(...tx.required_auths.map(e => {
-                return `${e}?type=active`
-            }))
-            const txData = {
-                status: TransactionDbStatus.included,
-                id: tx.transaction_id,
-                required_auths,
-                anchored_height: blkHeight,
-                anchored_index: tx.index,
-                headers: {
-                    // lock_block: fullTx.block_height + 120,
-                    contract_id: json.data.contract_id
-                },
-                data: {
-                    op: json.data.op,
-                    payload: json.data.payload,
-                    action: json.data.action,
-                },
-                result: null,
-                local: false,
-                first_seen: new Date(),
-                accessible: true,
-                src: "hive" as any,
+            for(let [op, opBody] of tx.operations) {
+                console.log('parsing', [op, opBody])
+                if(op === 'custom_json') {
+                    // console.log('picked up TX', tx, fullTx)
+                    if(opBody.id === 'vsc.announce_tx' || opBody.id === 'vsc.tx') {
+                        const json = JSON.parse(opBody.json)
+
+                        if(json.net_id !== this.self.config.get('network.id')) {
+                            return;
+                        }
+
+                        const required_auths = []
+                        required_auths.push(...opBody.required_posting_auths.map(e => {
+                            return `${e}?type=posting`
+                        }))
+                        required_auths.push(...opBody.required_auths.map(e => {
+                            return `${e}?type=active`
+                        }))
+                        const txData = {
+                            status: TransactionDbStatus.included,
+                            id: tx.transaction_id,
+                            required_auths,
+                            anchored_height: blkHeight,
+                            anchored_index: tx.index,
+                            headers: {
+                                // lock_block: fullTx.block_height + 120,
+                            },
+                            data: {
+                                contract_id: json.tx.contract_id,
+                                op: json.tx.op,
+                                payload: json.tx.payload,
+                                action: json.tx.action,
+                            },
+                            result: null,
+                            local: false,
+                            first_seen: new Date(),
+                            accessible: true,
+                            src: "hive" as any,
+                        }
+                        await this.txDb.insertOne(txData)
+                    }
+                }
             }
-            console.log('txData', txData)
-            await this.txDb.insertOne(txData)
+        } catch (ex) {
+            console.log(ex)
         }
     }