crypto/chain-client
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

update event

Browse Source
This commit is contained in:
zhl 2023-04-14 15:49:28 +08:00
parent cf01804e48
commit eb5421b9ce
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/config/events.json
View File

@ -3,7 +3,7 @@
"address": "0x8135D4F16A7AAA269cbf61CE9659D3A272BF541f", "address": "0x8135D4F16A7AAA269cbf61CE9659D3A272BF541f",
"event": "Confirmation", "event": "Confirmation",
"abi": "BEMultiSigWallet", "abi": "BEMultiSigWallet",
"fromBlock": 34225225, "fromBlock": 34353697,
"eventProcesser": "ScheduleConfirmEvent" "eventProcesser": "ScheduleConfirmEvent"
} }
] ]

3
src/models/ScheduleConfirmEvent.ts
View File

@ -1,5 +1,6 @@
import { getModelForClass, index, modelOptions, prop } from '@typegoose/typegoose' import { getModelForClass, index, modelOptions, prop } from '@typegoose/typegoose'
import { dbconn } from 'decorators/dbconn' import { dbconn } from 'decorators/dbconn'
import logger from 'logger/logger'
import { TaskSvr } from 'service/task.service' import { TaskSvr } from 'service/task.service'
import { BaseModule } from './Base' import { BaseModule } from './Base'
@ -31,6 +32,7 @@ export class ScheduleConfirmEventClass extends BaseModule {
public version: number public version: number
public static async saveEvent(event: any) { public static async saveEvent(event: any) {
logger.info(JSON.stringify(event))
if (!event.success) { if (!event.success) {
return return
} }
@ -48,6 +50,7 @@ export class ScheduleConfirmEventClass extends BaseModule {
let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.hash }, data) let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.hash }, data)
if (record.version === 1) { if (record.version === 1) {
logger.log('receive events: ' + JSON.stringify(event.ids))
for (let id of event.ids) { for (let id of event.ids) {
await new TaskSvr().parseOneSchedule(id) await new TaskSvr().parseOneSchedule(id)
} }