Skip to content

Commit b645097

Browse files
bryanchriswhitebryanchriswhite
authored
chore: add ESlint (#138)
1 parent 066f679 commit b645097

File tree

17 files changed

+503
-90
lines changed

17 files changed

+503
-90
lines changed

‎.eslintrc.yml

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
env:
2+
browser: true
3+
es2021: true
4+
extends:
5+
- eslint:recommended
6+
- plugin:@typescript-eslint/recommended
7+
overrides: []
8+
parser: '@typescript-eslint/parser'
9+
parserOptions:
10+
ecmaVersion: latest
11+
sourceType: module
12+
plugins:
13+
- '@typescript-eslint'
14+
ignorePatterns:
15+
- "src/types/"
16+
rules:
17+
indent:
18+
- error
19+
- 2
20+
linebreak-style:
21+
- error
22+
- unix
23+
quotes:
24+
- error
25+
- double
26+
semi:
27+
- error
28+
- always

‎.github/workflows/test.yml

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,18 @@ jobs:
1616
- name: Update
1717
run: sudo apt update
1818
- name: Install OS dependencies
19-
run: sudo apt install -y python3-dev
19+
run: sudo apt install -y python3-dev nodejs
2020

2121
- uses: actions/checkout@v3
2222
with:
2323
submodules: recursive
2424

25+
- name: Install linter dependencies
26+
run: yarn install
27+
28+
- name: Lint TypeScript
29+
run: yarn lint
30+
2531
- name: Start-up local test environment
2632
uses: isbang/[email protected]
2733
with:

‎package.json

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44
"description": "This is the Fetch Ledger SubQuery project, an indexer for the Fetch network.",
55
"main": "dist/index.js",
66
"scripts": {
7+
"lint": "yarn eslint ./src",
78
"build": "subql build",
89
"prepack": "rm -rf dist && npm build",
910
"test": "jest",
@@ -22,6 +23,9 @@
2223
"devDependencies": {
2324
"@cosmjs/stargate": "^0.28.9",
2425
"@subql/cli": "^1.1.0",
26+
"@typescript-eslint/eslint-plugin": "^5.40.0",
27+
"@typescript-eslint/parser": "^5.40.0",
28+
"eslint": "^8.25.0",
2529
"typescript": "^4.7.4"
2630
},
2731
"dependencies": {

‎src/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
//Exports all handler functions
2-
export * from './mappings/mappingHandlers'
2+
export * from "./mappings/mappingHandlers";

‎src/mappings/bank/balanceChange.ts

Lines changed: 16 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ import {CosmosEvent} from "@subql/types-cosmos";
22
import {NativeBalanceChange} from "../../types";
33
import {checkBalancesAccount, messageId, parseCoins} from "../utils";
44

5-
export async function saveNativeBalanceEvent(id: string, address: string, amount: BigInt, denom: string, event: CosmosEvent) {
5+
export async function saveNativeBalanceEvent(id: string, address: string, amount: bigint, denom: string, event: CosmosEvent) {
66
await checkBalancesAccount(address, event.block.block.header.chainId);
77
const nativeBalanceChangeEntity = NativeBalanceChange.create({
88
id,
@@ -13,13 +13,13 @@ export async function saveNativeBalanceEvent(id: string, address: string, amount
1313
blockId: event.block.block.id,
1414
transactionId: event.tx.hash,
1515
});
16-
await nativeBalanceChangeEntity.save()
16+
await nativeBalanceChangeEntity.save();
1717
}
1818

1919
export async function handleNativeBalanceDecrement(event: CosmosEvent): Promise<void> {
20-
logger.info(`[handleNativeBalanceDecrement] (tx ${event.tx.hash}): indexing event ${event.idx + 1} / ${event.tx.tx.events.length}`)
21-
logger.debug(`[handleNativeBalanceDecrement] (event.event): ${JSON.stringify(event.event, null, 2)}`)
22-
logger.debug(`[handleNativeBalanceDecrement] (event.log): ${JSON.stringify(event.log, null, 2)}`)
20+
logger.info(`[handleNativeBalanceDecrement] (tx ${event.tx.hash}): indexing event ${event.idx + 1} / ${event.tx.tx.events.length}`);
21+
logger.debug(`[handleNativeBalanceDecrement] (event.event): ${JSON.stringify(event.event, null, 2)}`);
22+
logger.debug(`[handleNativeBalanceDecrement] (event.log): ${JSON.stringify(event.log, null, 2)}`);
2323

2424
// sample event.event.attributes:
2525
// [
@@ -28,29 +28,29 @@ export async function handleNativeBalanceDecrement(event: CosmosEvent): Promise<
2828
// {"key":"spender","value":"fetch1wurz7uwmvchhc8x0yztc7220hxs9jxdjdsrqmn"},
2929
// {"key":"amount","value":"100atestfet"}
3030
// ]
31-
let spendEvents = [];
31+
const spendEvents = [];
3232
for (const [i, e] of Object.entries(event.event.attributes)) {
3333
if (e.key !== "spender") {
34-
continue
34+
continue;
3535
}
3636
const spender = e.value;
3737
const amountStr = event.event.attributes[parseInt(i) + 1].value;
3838

3939
const coin = parseCoins(amountStr)[0];
4040
const amount = BigInt(0) - BigInt(coin.amount); // save a negative amount for a "spend" event
41-
spendEvents.push({spender: spender, amount: amount, denom: coin.denom})
41+
spendEvents.push({spender: spender, amount: amount, denom: coin.denom});
4242
}
43-
;
43+
4444

4545
for (const [i, spendEvent] of Object.entries(spendEvents)) {
4646
await saveNativeBalanceEvent(`${messageId(event)}-spend-${i}`, spendEvent.spender, spendEvent.amount, spendEvent.denom, event);
4747
}
4848
}
4949

5050
export async function handleNativeBalanceIncrement(event: CosmosEvent): Promise<void> {
51-
logger.info(`[handleNativeBalanceIncrement] (tx ${event.tx.hash}): indexing event ${event.idx + 1} / ${event.tx.tx.events.length}`)
52-
logger.debug(`[handleNativeBalanceIncrement] (event.event): ${JSON.stringify(event.event, null, 2)}`)
53-
logger.debug(`[handleNativeBalanceIncrement] (event.log): ${JSON.stringify(event.log, null, 2)}`)
51+
logger.info(`[handleNativeBalanceIncrement] (tx ${event.tx.hash}): indexing event ${event.idx + 1} / ${event.tx.tx.events.length}`);
52+
logger.debug(`[handleNativeBalanceIncrement] (event.event): ${JSON.stringify(event.event, null, 2)}`);
53+
logger.debug(`[handleNativeBalanceIncrement] (event.log): ${JSON.stringify(event.log, null, 2)}`);
5454

5555
// sample event.event.attributes:
5656
// [
@@ -59,19 +59,19 @@ export async function handleNativeBalanceIncrement(event: CosmosEvent): Promise<
5959
// {"key":"receiver","value":"fetch1wurz7uwmvchhc8x0yztc7220hxs9jxdjdsrqmn"},
6060
// {"key":"amount","value":"100atestfet"}
6161
// ]
62-
let receiveEvents = [];
62+
const receiveEvents = [];
6363
for (const [i, e] of Object.entries(event.event.attributes)) {
6464
if (e.key !== "receiver") {
65-
continue
65+
continue;
6666
}
6767
const receiver = e.value;
6868
const amountStr = event.event.attributes[parseInt(i) + 1].value;
6969

7070
const coin = parseCoins(amountStr)[0];
7171
const amount = BigInt(coin.amount);
72-
receiveEvents.push({receiver: receiver, amount: amount, denom: coin.denom})
72+
receiveEvents.push({receiver: receiver, amount: amount, denom: coin.denom});
7373
}
74-
;
74+
7575

7676
for (const [i, receiveEvent] of Object.entries(receiveEvents)) {
7777
await saveNativeBalanceEvent(`${messageId(event)}-receive-${i}`, receiveEvent.receiver, receiveEvent.amount, receiveEvent.denom, event);

‎src/mappings/bank/index.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
1-
export * from "./transfer"
2-
export * from "./balanceChange"
1+
export * from "./transfer";
2+
export * from "./balanceChange";

‎src/mappings/bank/transfer.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,17 +4,17 @@ import {messageId} from "../utils";
44
import {NativeTransfer} from "../../types";
55

66
export async function handleNativeTransfer(event: CosmosEvent): Promise<void> {
7-
const msg: CosmosMessage<NativeTransferMsg> = event.msg
8-
logger.info(`[handleNativeTransfer] (tx ${msg.tx.hash}): indexing message ${msg.idx + 1} / ${msg.tx.decodedTx.body.messages.length}`)
9-
logger.debug(`[handleNativeTransfer] (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
7+
const msg: CosmosMessage<NativeTransferMsg> = event.msg;
8+
logger.info(`[handleNativeTransfer] (tx ${msg.tx.hash}): indexing message ${msg.idx + 1} / ${msg.tx.decodedTx.body.messages.length}`);
9+
logger.debug(`[handleNativeTransfer] (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
1010

1111
const fromAddress = msg.msg?.decodedMsg?.fromAddress;
12-
const toAddress = msg.msg?.decodedMsg?.toAddress
12+
const toAddress = msg.msg?.decodedMsg?.toAddress;
1313
const amounts = msg.msg?.decodedMsg?.amount;
1414

1515
if (!fromAddress || !amounts || !toAddress) {
16-
logger.warn(`[handleNativeTransfer] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`)
17-
return
16+
logger.warn(`[handleNativeTransfer] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`);
17+
return;
1818
}
1919

2020
// workaround: assuming one denomination per transfer message

‎src/mappings/dist/rewards.ts

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -5,16 +5,16 @@ import {DistDelegatorClaim} from "../../types";
55

66
export async function handleDistDelegatorClaim(event: CosmosEvent): Promise<void> {
77
const msg: CosmosMessage<DistDelegatorClaimMsg> = event.msg;
8-
logger.info(`[handleDistDelegatorClaim] (tx ${msg.tx.hash}): indexing DistDelegatorClaim ${messageId(msg)}`)
9-
logger.debug(`[handleDistDelegatorClaim] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
8+
logger.info(`[handleDistDelegatorClaim] (tx ${msg.tx.hash}): indexing DistDelegatorClaim ${messageId(msg)}`);
9+
logger.debug(`[handleDistDelegatorClaim] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
1010

1111
const id = messageId(msg);
1212
const delegatorAddress = msg?.msg?.decodedMsg?.delegatorAddress;
1313
const validatorAddress = msg?.msg?.decodedMsg?.validatorAddress;
1414

1515
if (!delegatorAddress || !validatorAddress) {
16-
logger.warn(`[handleDistDelegatorClaim] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`)
17-
return
16+
logger.warn(`[handleDistDelegatorClaim] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`);
17+
return;
1818
}
1919

2020
const claim = DistDelegatorClaim.create({
@@ -36,17 +36,17 @@ export async function handleDistDelegatorClaim(event: CosmosEvent): Promise<void
3636
}
3737

3838
export async function handleDelegatorWithdrawRewardEvent(event: CosmosEvent): Promise<void> {
39-
logger.debug(`[handleDelegateWithdrawRewardEvent] (event.event): ${JSON.stringify(event.event, null, 2)}`)
40-
logger.debug(`[handleDelegateWithdrawRewardEvent] (event.log): ${JSON.stringify(event.log, null, 2)}`)
39+
logger.debug(`[handleDelegateWithdrawRewardEvent] (event.event): ${JSON.stringify(event.event, null, 2)}`);
40+
logger.debug(`[handleDelegateWithdrawRewardEvent] (event.log): ${JSON.stringify(event.log, null, 2)}`);
4141

42-
const attrs: Record<string, any> = event.event.attributes.reduce((acc, attr) => {
42+
const attrs: Record<string, unknown> = event.event.attributes.reduce((acc, attr) => {
4343
acc[attr.key] = attr.value;
4444
return acc;
4545
}, {});
4646

4747
if (!attrs.amount || !attrs.validator) {
48-
logger.warn(`[handleDelegatorWithdrawRewardEvent] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`)
49-
return
48+
logger.warn(`[handleDelegatorWithdrawRewardEvent] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`);
49+
return;
5050
}
5151

5252
const claims = await DistDelegatorClaim.getByTransactionId(event.tx.hash);

‎src/mappings/gov/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
export * from "./votes"
1+
export * from "./votes";

‎src/mappings/gov/votes.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -5,16 +5,16 @@ import {GovProposalVote, GovProposalVoteOption} from "../../types";
55

66
export async function handleGovProposalVote(event: CosmosEvent): Promise<void> {
77
const msg: CosmosMessage<GovProposalVoteMsg> = event.msg;
8-
logger.info(`[handleGovProposalVote] (tx ${msg.tx.hash}): indexing GovProposalVote ${messageId(msg)}`)
9-
logger.debug(`[handleGovProposalVote] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
8+
logger.info(`[handleGovProposalVote] (tx ${msg.tx.hash}): indexing GovProposalVote ${messageId(msg)}`);
9+
logger.debug(`[handleGovProposalVote] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
1010

1111
const id = messageId(msg);
1212
const option = msg?.msg?.decodedMsg?.option;
1313
const proposalId = msg?.msg?.decodedMsg?.proposalId, voter = msg?.msg?.decodedMsg?.voter;
1414

1515
if (!option || !proposalId || !voter) {
16-
logger.warn(`[handleGovProposalVote] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`)
17-
return
16+
logger.warn(`[handleGovProposalVote] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`);
17+
return;
1818
}
1919

2020
const vote = GovProposalVote.create({

‎src/mappings/ibc/index.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
export * from "./transfer"
1+
export * from "./transfer";

‎src/mappings/ibc/transfer.ts

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,8 +4,8 @@ import {messageId} from "../utils";
44

55
export async function handleIBCTransfer(event: CosmosEvent): Promise<void> {
66
const msg = event.msg;
7-
logger.info(`[handleIBCTransfer] (tx ${msg.tx.hash}): indexing message ${msg.idx + 1} / ${msg.tx.decodedTx.body.messages.length}`)
8-
logger.debug(`[handleIBCTransfer] (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
7+
logger.info(`[handleIBCTransfer] (tx ${msg.tx.hash}): indexing message ${msg.idx + 1} / ${msg.tx.decodedTx.body.messages.length}`);
8+
logger.debug(`[handleIBCTransfer] (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
99

1010
const decodedMsg = msg.msg.decodedMsg;
1111
const sourcePort = decodedMsg.sourcePort;
@@ -16,8 +16,8 @@ export async function handleIBCTransfer(event: CosmosEvent): Promise<void> {
1616
const receiver = decodedMsg.receiver;
1717

1818
if (!sourcePort || !sourceChannel || !tokenAmount || !tokenDenom || !sender || !receiver) {
19-
logger.warn(`[handleIBCTransfer] (tx ${msg.tx.hash}): cannot index message (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
20-
return
19+
logger.warn(`[handleIBCTransfer] (tx ${msg.tx.hash}): cannot index message (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
20+
return;
2121
}
2222

2323
const id = messageId(msg);

‎src/mappings/primitives.ts

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,7 @@ import {createHash} from "crypto";
55
import {toBech32} from "@cosmjs/encoding";
66

77
export async function handleBlock(block: CosmosBlock): Promise<void> {
8-
logger.info(`[handleBlock] (block.header.height): indexing block ${block.block.header.height}`)
8+
logger.info(`[handleBlock] (block.header.height): indexing block ${block.block.header.height}`);
99

1010
const {id, header: {chainId, height, time}} = block.block;
1111
const timestamp = new Date(time);
@@ -16,18 +16,18 @@ export async function handleBlock(block: CosmosBlock): Promise<void> {
1616
timestamp
1717
});
1818

19-
await blockEntity.save()
19+
await blockEntity.save();
2020
}
2121

2222
export async function handleTransaction(tx: CosmosTransaction): Promise<void> {
23-
logger.info(`[handleTransaction] (block ${tx.block.block.header.height}): indexing transaction ${tx.idx + 1} / ${tx.block.txs.length}`)
24-
logger.debug(`[handleTransaction] (tx.decodedTx): ${JSON.stringify(tx.decodedTx, null, 2)}`)
25-
logger.debug(`[handleTransaction] (tx.tx.log): ${tx.tx.log}`)
23+
logger.info(`[handleTransaction] (block ${tx.block.block.header.height}): indexing transaction ${tx.idx + 1} / ${tx.block.txs.length}`);
24+
logger.debug(`[handleTransaction] (tx.decodedTx): ${JSON.stringify(tx.decodedTx, null, 2)}`);
25+
logger.debug(`[handleTransaction] (tx.tx.log): ${tx.tx.log}`);
2626

2727
let status = TxStatus.Error;
2828
if (tx.tx.log) {
2929
try {
30-
JSON.parse(tx.tx.log)
30+
JSON.parse(tx.tx.log);
3131
status = TxStatus.Success;
3232
} catch {
3333
// NB: assume tx failed
@@ -68,8 +68,8 @@ export async function handleTransaction(tx: CosmosTransaction): Promise<void> {
6868
}
6969

7070
export async function handleMessage(msg: CosmosMessage): Promise<void> {
71-
logger.info(`[handleMessage] (tx ${msg.tx.hash}): indexing message ${msg.idx + 1} / ${msg.tx.decodedTx.body.messages.length}`)
72-
logger.debug(`[handleMessage] (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
71+
logger.info(`[handleMessage] (tx ${msg.tx.hash}): indexing message ${msg.idx + 1} / ${msg.tx.decodedTx.body.messages.length}`);
72+
logger.debug(`[handleMessage] (msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
7373

7474
const msgEntity = Message.create({
7575
id: messageId(msg),
@@ -83,9 +83,9 @@ export async function handleMessage(msg: CosmosMessage): Promise<void> {
8383
}
8484

8585
export async function handleEvent(event: CosmosEvent): Promise<void> {
86-
logger.info(`[handleEvent] (tx ${event.tx.hash}): indexing event ${event.idx + 1} / ${event.tx.tx.events.length}`)
87-
logger.debug(`[handleEvent] (event.event): ${JSON.stringify(event.event, null, 2)}`)
88-
logger.debug(`[handleEvent] (event.log): ${JSON.stringify(event.log, null, 2)}`)
86+
logger.info(`[handleEvent] (tx ${event.tx.hash}): indexing event ${event.idx + 1} / ${event.tx.tx.events.length}`);
87+
logger.debug(`[handleEvent] (event.event): ${JSON.stringify(event.event, null, 2)}`);
88+
logger.debug(`[handleEvent] (event.log): ${JSON.stringify(event.log, null, 2)}`);
8989

9090
// NB: sanitize attribute values (may contain non-text characters)
9191
const attributes = event.event.attributes.map((attribute) => {

‎src/mappings/wasm/bridge.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -4,10 +4,10 @@ import {messageId} from "../utils";
44
import {LegacyBridgeSwap} from "../../types";
55

66
export async function handleLegacyBridgeSwap(event: CosmosEvent): Promise<void> {
7-
const msg: CosmosMessage<LegacyBridgeSwapMsg> = event.msg
7+
const msg: CosmosMessage<LegacyBridgeSwapMsg> = event.msg;
88
const id = messageId(msg);
9-
logger.info(`[handleLegacyBridgeSwap] (tx ${msg.tx.hash}): indexing LegacyBridgeSwap ${id}`)
10-
logger.debug(`[handleLegacyBridgeSwap] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
9+
logger.info(`[handleLegacyBridgeSwap] (tx ${msg.tx.hash}): indexing LegacyBridgeSwap ${id}`);
10+
logger.debug(`[handleLegacyBridgeSwap] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
1111

1212
const contract = msg?.msg?.decodedMsg?.contract;
1313
const swapMsg = msg?.msg?.decodedMsg?.msg;
@@ -20,8 +20,8 @@ export async function handleLegacyBridgeSwap(event: CosmosEvent): Promise<void>
2020
// gracefully skip indexing "swap" messages that doesn't fullfill the bridge contract
2121
// otherwise, the node will just crashloop trying to save the message to the db with required null fields.
2222
if (!destination || !amount || !denom || !contract) {
23-
logger.warn(`[handleLegacyBridgeSwap] (tx ${msg.tx.hash}): cannot index message (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
24-
return
23+
logger.warn(`[handleLegacyBridgeSwap] (tx ${msg.tx.hash}): cannot index message (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
24+
return;
2525
}
2626

2727
const legacySwap = LegacyBridgeSwap.create({

‎src/mappings/wasm/contracts.ts

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -4,17 +4,17 @@ import {messageId} from "../utils";
44
import {ExecuteContractMessage} from "../../types";
55

66
export async function handleExecuteContractEvent(event: CosmosEvent): Promise<void> {
7-
const msg: CosmosMessage<ExecuteContractMsg> = event.msg
8-
logger.info(`[handleExecuteContractMessage] (tx ${msg.tx.hash}): indexing ExecuteContractMessage ${messageId(msg)}`)
9-
logger.debug(`[handleExecuteContractMessage] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`)
7+
const msg: CosmosMessage<ExecuteContractMsg> = event.msg;
8+
logger.info(`[handleExecuteContractMessage] (tx ${msg.tx.hash}): indexing ExecuteContractMessage ${messageId(msg)}`);
9+
logger.debug(`[handleExecuteContractMessage] (event.msg.msg): ${JSON.stringify(msg.msg, null, 2)}`);
1010

1111
const id = messageId(msg);
12-
const funds = msg?.msg?.decodedMsg?.funds, contract = msg?.msg?.decodedMsg?.contract
12+
const funds = msg?.msg?.decodedMsg?.funds, contract = msg?.msg?.decodedMsg?.contract;
1313
const method = Object.keys(msg?.msg?.decodedMsg?.msg)[0];
1414

1515
if (!funds || !contract || !method) {
16-
logger.warn(`[handleExecuteContractEvent] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`)
17-
return
16+
logger.warn(`[handleExecuteContractEvent] (tx ${event.tx.hash}): cannot index event (event.event): ${JSON.stringify(event.event, null, 2)}`);
17+
return;
1818
}
1919

2020
const msgEntity = ExecuteContractMessage.create({

0 commit comments

Comments
 (0)