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

Compare commits

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

1 Commits
62a7d9a6aa ... 219341e677

Author SHA1 Message Date
tornadocontrib
219341e677
Validate fetched events from relayer 2024-09-30 12:02:20 +00:00
5 changed files with 5 additions and 9 deletions
Show Stats Expand all files Collapse all files

3
dist/index.js vendored
View File

@ -3235,8 +3235,7 @@ 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 });
const saveCache = Boolean(savedEvents.fromCache && savedEvents.events.length); if (savedEvents.fromCache || newEvents.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,8 +3214,7 @@ 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 });
const saveCache = Boolean(savedEvents.fromCache && savedEvents.events.length); if (savedEvents.fromCache || newEvents.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,8 +59335,7 @@ 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 });
const saveCache = Boolean(savedEvents.fromCache && savedEvents.events.length); if (savedEvents.fromCache || newEvents.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,8 +336,7 @@ 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
const saveCache = Boolean((savedEvents as CachedEvents<EventType>).fromCache && savedEvents.events.length); if ((savedEvents as CachedEvents<EventType>).fromCache || newEvents.events.length) {
if (saveCache || newEvents.events.length) {
await this.saveEvents({ events: allEvents, lastBlock }); await this.saveEvents({ events: allEvents, lastBlock });
} }