Merge pull request #27 from Agoric/feat/bundle-install-indexing

Feat: MsgInstallBundle indexing

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,11 +1,12 @@
-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,
  getStateChangeModule,
  resolveBrandNamesAndValues,
  getEscrowAddress,
+ getAddressFromUint8Array,
 } from './utils';
 
 import {
@@ -128,6 +129,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, 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 || '',
+ getAddressFromUint8Array(msg.decodedMsg.submitter),
+ );
+
+ await bundleRecord.save();
+}
+
 export async function handleStateChangeEvent(cosmosEvent: CosmosEvent): Promise<void> {
  const { event, block } = cosmosEvent;
 

src/mappings/utils.ts

@@ -101,10 +101,16 @@ export function dateToDayKey(timestamp: any): number {
 
 export const getEscrowAddress = (port: string, channel: string) => {
  const version = 'ics20-1';
- const chainPrefix = 'agoric';
  const stringtoSha = Buffer.from([...Buffer.from(version), 0, ...Buffer.from(`${port}/${channel}`)]);
  const shaHash = sha256.sha256.array(stringtoSha.toString());
- const bechWords = bech32.toWords(shaHash.slice(0, 20));
- const address = bech32.encode(chainPrefix, bechWords);
+ const hashArray = new Uint8Array(shaHash.slice(0, 20));
+ const address = getAddressFromUint8Array(hashArray);
  return address;
 };
+
+export const getAddressFromUint8Array = (uint8Array: Uint8Array, chainPrefix: string = 'agoric') => {
+ const words = bech32.toWords(uint8Array);
+ const bech32String = bech32.encode(chainPrefix, words);
+
+ return bech32String;
+};