feat: added handler to index MsgInstallBundle

project.ts

@@ -46,6 +46,13 @@ const project: CosmosProject = {
           file: "./proto/cosmos/gov/v1beta1/gov.proto",
           messages: ["WeightedVoteOption"],
         },
+      ],  
+      [
+        "/agoric.swingset.MsgInstallBundle",
+        {
+          file: "./proto/agoric/swingset/msgs.proto",
+          messages: ["MsgInstallBundle"],
+        },
       ],
     ]),
   },
@@ -107,6 +114,13 @@ const project: CosmosProject = {
               type: "state_change",
             },
           },
+          {
+            handler: 'handleBundleInstallMessage',
+            kind: CosmosHandlerKind.Message,
+            filter: {
+              type: '/agoric.swingset.MsgInstallBundle',
+            },
+          },
         ],
       },
     },

schema.graphql

@@ -303,3 +303,13 @@ type VaultStatesDaily @entity {
   liquidated: BigInt!
   liquidatedClosed: BigInt!
 }
+
+type BundleInstall @entity {
+  id: ID!
+  blockHeight: BigInt!
+  blockTime: Date!
+  uncompressedSize: BigInt!
+  bundle: String!
+  compressedBundle: String!
+  submitter: String!
+}

src/mappings/mappingHandlers.ts

@@ -1,5 +1,5 @@
-import { StateChangeEvent, IBCChannel, IBCTransfer, TransferType } from '../types';
-import { CosmosEvent } from '@subql/types-cosmos';
+import { StateChangeEvent, IBCChannel, IBCTransfer, TransferType, BundleInstall } from '../types';
+import { CosmosEvent, CosmosMessage } from '@subql/types-cosmos';
 import {
   b64decode,
   extractStoragePath,
@@ -128,6 +128,29 @@ export async function handleIbcReceivePacketEvent(cosmosEvent: CosmosEvent): Pro
   await Promise.allSettled([transferRecord.save(), ibcChannel]);
 }
 
+export async function handleBundleInstallMessage(message: CosmosMessage): Promise<void> {
+  const { msg, block, tx } = message;
+
+  if (msg.typeUrl !== '/agoric.swingset.MsgInstallBundle') {
+    logger.warn('message type is not /agoric.swingset.MsgInstallBundle');
+    return;
+  }
+
+  // JSON.stringify converts the object from Uint8Array to readable string
+  const { uncompressedSize, compressedBundle, submitter, bundle } = JSON.parse(JSON.stringify(msg.decodedMsg));
+  const bundleRecord = new BundleInstall(
+    tx.hash,
+    BigInt(block.header.height),
+    block.header.time as any,
+    BigInt(uncompressedSize),
+    bundle || '',
+    compressedBundle || '',
+    submitter,
+  );
+
+  await bundleRecord.save();
+}
+
 export async function handleStateChangeEvent(cosmosEvent: CosmosEvent): Promise<void> {
   const { event, block } = cosmosEvent;