tornado-packages/tornado-core
1
0
Fork 1
Code Pull Requests Activity

Compare commits

base: tornado-packages:219341e677c474a3902ac35414f223f71dea88ff
Branches Tags
tornado-packages:main
..
compare: tornado-packages:62a7d9a6aa6ffb1f08f1eabfb82de411f8d14781
Branches Tags
tornado-packages:main

1 Commits
219341e677 ... 62a7d9a6aa

Author SHA1 Message Date
tornadocontrib
62a7d9a6aa
Validate fetched events from relayer 2024-09-30 11:16:40 +00:00
5 changed files with 9 additions and 5 deletions
Show Stats Expand all files Collapse all files

3
dist/index.js vendored
View File

@ -3235,7 +3235,8 @@ class BaseEventsService {
}); });
const lastBlock = newEvents.lastBlock || ((_a = allEvents[allEvents.length - 1]) == null ? void 0 : _a.blockNumber); const lastBlock = newEvents.lastBlock || ((_a = allEvents[allEvents.length - 1]) == null ? void 0 : _a.blockNumber);
this.validateEvents({ events: allEvents, lastBlock }); this.validateEvents({ events: allEvents, lastBlock });
if (savedEvents.fromCache || newEvents.events.length) { const saveCache = Boolean(savedEvents.fromCache && savedEvents.events.length);
if (saveCache || newEvents.events.length) {
yield this.saveEvents({ events: allEvents, lastBlock }); yield this.saveEvents({ events: allEvents, lastBlock });
} }
return { return {

3
dist/index.mjs vendored
View File

@ -3214,7 +3214,8 @@ class BaseEventsService {
}); });
const lastBlock = newEvents.lastBlock || ((_a = allEvents[allEvents.length - 1]) == null ? void 0 : _a.blockNumber); const lastBlock = newEvents.lastBlock || ((_a = allEvents[allEvents.length - 1]) == null ? void 0 : _a.blockNumber);
this.validateEvents({ events: allEvents, lastBlock }); this.validateEvents({ events: allEvents, lastBlock });
if (savedEvents.fromCache || newEvents.events.length) { const saveCache = Boolean(savedEvents.fromCache && savedEvents.events.length);
if (saveCache || newEvents.events.length) {
yield this.saveEvents({ events: allEvents, lastBlock }); yield this.saveEvents({ events: allEvents, lastBlock });
} }
return { return {

3
dist/tornado.umd.js vendored
View File

@ -59335,7 +59335,8 @@ class BaseEventsService {
}); });
const lastBlock = newEvents.lastBlock || ((_a = allEvents[allEvents.length - 1]) == null ? void 0 : _a.blockNumber); const lastBlock = newEvents.lastBlock || ((_a = allEvents[allEvents.length - 1]) == null ? void 0 : _a.blockNumber);
this.validateEvents({ events: allEvents, lastBlock }); this.validateEvents({ events: allEvents, lastBlock });
if (savedEvents.fromCache || newEvents.events.length) { const saveCache = Boolean(savedEvents.fromCache && savedEvents.events.length);
if (saveCache || newEvents.events.length) {
yield this.saveEvents({ events: allEvents, lastBlock }); yield this.saveEvents({ events: allEvents, lastBlock });
} }
return { return {

2
dist/tornado.umd.min.js vendored
View File

File diff suppressed because one or more lines are too long

3
src/events/base.ts
View File

@ -336,7 +336,8 @@ export class BaseEventsService<EventType extends MinimalEvents> {
this.validateEvents({ events: allEvents, lastBlock }); this.validateEvents({ events: allEvents, lastBlock });
// If the events are loaded from cache or we have found new events, save them // If the events are loaded from cache or we have found new events, save them
if ((savedEvents as CachedEvents<EventType>).fromCache || newEvents.events.length) { const saveCache = Boolean((savedEvents as CachedEvents<EventType>).fromCache && savedEvents.events.length);
if (saveCache || newEvents.events.length) {
await this.saveEvents({ events: allEvents, lastBlock }); await this.saveEvents({ events: allEvents, lastBlock });
} }