Feat/ibc app ics20 ( develop )

ci/config.json.ci

@@ -184,5 +184,11 @@
     "key": "crawlIbcApp",
     "millisecondRepeatJob": 2000,
     "blocksPerCall": 100
+  },
+  "crawlIbcIcs20": {
+    "key": "crawlIbcIcs20",
+    "millisecondRepeatJob": 2000,
+    "blocksPerCall": 100,
+    "port": "transfer"
   }
 }

config.json

@@ -184,5 +184,11 @@
     "key": "crawlIbcApp",
     "millisecondRepeatJob": 2000,
     "blocksPerCall": 100
+  },
+  "crawlIbcIcs20": {
+    "key": "crawlIbcIcs20",
+    "millisecondRepeatJob": 2000,
+    "blocksPerCall": 100,
+    "port": "transfer"
   }
 }

migrations/20230823070516_ics20_model.ts

@@ -0,0 +1,18 @@
+import { Knex } from 'knex';
+
+export async function up(knex: Knex): Promise<void> {
+  await knex.schema.createTable('ibc_ics20', (table) => {
+    table.increments();
+    table.integer('ibc_message_id').notNullable().unique();
+    table.string('sender').index();
+    table.string('receiver').index().notNullable();
+    table.decimal('amount', 80, 0).notNullable();
+    table.string('denom').notNullable().index();
+    table.boolean('ack_status');
+    table.foreign('ibc_message_id').references('ibc_message.id');
+  });
+}
+
+export async function down(knex: Knex): Promise<void> {
+  await knex.schema.dropTableIfExists('ibc_ics20');
+}

src/common/constant.ts

@@ -76,6 +76,7 @@ export const BULL_JOB_NAME = {
   REINDEX_CW20_CONTRACT: 'reindex:cw20-contract',
   REINDEX_CW20_HISTORY: 'reindex:cw20-history',
   CRAWL_IBC_APP: 'crawl:ibc-app',
+  CRAWL_IBC_ICS20: 'crawl:ibc-ics20',
 };
 
 export const SERVICE = {
@@ -269,6 +270,10 @@ export const SERVICE = {
       key: 'CrawlIBCAppService',
       name: 'v1.CrawlIBCAppService',
     },
+    CrawlIBCIcs20Service: {
+      key: 'CrawlIBCIcs20Service',
+      name: 'v1.CrawlIBCIcs20Service',
+    },
   },
 };
 

src/common/utils/utils.ts

@@ -210,3 +210,14 @@ export default class Utils {
     return [response, heightRange];
   }
 }
+
+// get Attribute value by specified key from array of attributes
+export function getAttributesFrom(
+  listAttributes: any,
+  attributesType: string[]
+) {
+  return attributesType.map(
+    (attributeType) =>
+      listAttributes?.find((attr: any) => attr.key === attributeType)?.value
+  );
+}

src/models/event_attribute.ts

@@ -114,6 +114,11 @@ export class EventAttribute extends BaseModel {
     SRC_CHANNEL: 'packet_src_channel',
     DST_PORT: 'packet_dst_port',
     DST_CHANNEL: 'packet_dst_channel',
+    DENOM: 'denom',
+    SUCCESS: 'success',
+    REFUND_RECEIVER: 'refund_receiver',
+    REFUND_DENOM: 'refund_denom',
+    REFUND_AMOUNT: 'refund_amount',
   };
 
   static ATTRIBUTE_COMPOSITE_KEY = {

src/models/ibc_ics20.ts

@@ -0,0 +1,58 @@
+/* eslint-disable import/no-cycle */
+import { Model } from 'objection';
+import BaseModel from './base';
+import { IbcMessage } from './ibc_message';
+
+export class IbcIcs20 extends BaseModel {
+  id!: number;
+
+  ibc_message_id!: number;
+
+  sender!: string;
+
+  receiver!: string;
+
+  amount!: string;
+
+  denom!: string;
+
+  ack_status!: boolean;
+
+  ibc_message!: IbcMessage;
+
+  static get tableName() {
+    return 'ibc_ics20';
+  }
+
+  static get jsonSchema() {
+    return {
+      type: 'object',
+      required: ['receiver', 'amount', 'denom', 'ibc_message_id'],
+      properties: {
+        receiver: { type: 'string' },
+        denom: { type: 'string' },
+        ibc_message_id: { type: 'number' },
+        amount: { type: 'string' },
+      },
+    };
+  }
+
+  static get relationMappings() {
+    return {
+      ibc_message: {
+        relation: Model.BelongsToOneRelation,
+        modelClass: IbcMessage,
+        join: {
+          from: 'ibc_ics20.ibc_message_id',
+          to: 'ibc_message.id',
+        },
+      },
+    };
+  }
+
+  static EVENT_TYPE = {
+    TIMEOUT: 'timeout',
+    FUNGIBLE_TOKEN_PACKET: 'fungible_token_packet',
+    DENOM_TRACE: 'denomination_trace',
+  };
+}

src/models/ibc_message.ts

@@ -25,6 +25,8 @@ export class IbcMessage extends BaseModel {
 
   data!: any;
 
+  message!: TransactionMessage;
+
   static get tableName() {
     return 'ibc_message';
   }

src/models/index.ts

@@ -29,3 +29,4 @@ export * from './ibc_client';
 export * from './ibc_connection';
 export * from './ibc_channel';
 export * from './ibc_message';
+export * from './ibc_ics20';

src/models/transaction_message.ts

@@ -22,6 +22,8 @@ export class TransactionMessage extends BaseModel {
 
   parent_id!: number;
 
+  events!: Event[];
+
   static get tableName() {
     return 'transaction_message';
   }