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

修改event的解析

Browse Source
This commit is contained in:
zhl 2023-04-14 16:08:29 +08:00
parent eb5421b9ce
commit cf60c09596
3 changed files with 28 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/models/ScheduleConfirmEvent.ts
View File

@ -33,22 +33,22 @@ export class ScheduleConfirmEventClass extends BaseModule {
public static async saveEvent(event: any) { public static async saveEvent(event: any) {
logger.info(JSON.stringify(event)) logger.info(JSON.stringify(event))
if (!event.success) { if (event.removed) {
return return
} }
const data = { const data = {
address: event.tokenAddress, address: event.address,
blockNumber: event.blockHeight, blockNumber: event.blockNumber,
removed: event.removed, removed: event.removed,
operater: event.sender, operater: event.returnValues.sender,
scheduleIds: event.ids, scheduleIds: event.returnValues.ids,
transactionHash: event.hash, transactionHash: event.transactionHash,
blockTime: new Date(event.time).getTime(), blockTime: new Date(event.timestamp).getTime(),
$inc: { version: 1 }, $inc: { version: 1 },
} }
let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.hash }, data) let record = await ScheduleConfirmEvent.insertOrUpdate({ transactionHash: event.transactionHash }, data)
if (record.version === 1) { if (record.version === 1) {
logger.log('receive events: ' + JSON.stringify(event.ids)) logger.log('receive events: ' + JSON.stringify(event.ids))
for (let id of event.ids) { for (let id of event.ids) {

17
src/models/ScheduleExecutedEvent.ts
View File

@ -30,21 +30,24 @@ export class ScheduleExecutedEventClass extends BaseModule {
public version: number public version: number
public static async saveEvent(event: any) { public static async saveEvent(event: any) {
if (!event.success) { if (event.removed) {
return return
} }
const data = { const data = {
address: event.tokenAddress, address: event.address,
blockNumber: event.blockHeight, blockNumber: event.blockNumber,
removed: event.removed, removed: event.removed,
operater: event.sender, operater: event.returnValues.sender,
transactionHash: event.hash, transactionHash: event.transactionHash,
blockTime: new Date(event.time).getTime(), blockTime: new Date(event.timestamp).getTime(),
$inc: { version: 1 }, $inc: { version: 1 },
} }
return ScheduleExecutedEvent.insertOrUpdate({ transactionHash: event.hash, scheduleId: event.id }, data) return ScheduleExecutedEvent.insertOrUpdate(
{ transactionHash: event.transactionHash, scheduleId: event.returnValues.id },
data,
)
} }
} }

17
src/models/ScheduledAddedEvent.ts
View File

@ -30,21 +30,24 @@ export class ScheduledAddedEventClass extends BaseModule {
public version: number public version: number
public static async saveEvent(event: any) { public static async saveEvent(event: any) {
if (!event.success) { if (event.removed) {
return return
} }
const data = { const data = {
address: event.tokenAddress, address: event.address,
blockNumber: event.blockHeight, blockNumber: event.blockNumber,
removed: event.removed, removed: event.removed,
operater: event.sender, operater: event.returnValues.sender,
transactionHash: event.hash, transactionHash: event.transactionHash,
blockTime: new Date(event.time).getTime(), blockTime: new Date(event.timestamp).getTime(),
$inc: { version: 1 }, $inc: { version: 1 },
} }
return ScheduledAddedEvent.insertOrUpdate({ transactionHash: event.hash, scheduleId: event.id }, data) return ScheduledAddedEvent.insertOrUpdate(
{ transactionHash: event.transactionHash, scheduleId: event.returnValues.id },
data,
)
} }
} }