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

Compare commits

base: tornado-packages:49a5ba7a2d8c5f04dc43961f9bd16b782a6fce13
Branches Tags
tornado-packages:main
..
compare: tornado-packages:6ac1025bc17867469af5ecd2e3d4f1a7d8edd9e7
Branches Tags
tornado-packages:main

1 Commits
49a5ba7a2d ... 6ac1025bc1

Author SHA1 Message Date
tornadocontrib
6ac1025bc1
Add BaseMultiTornadoService 2024-11-19 00:57:05 +00:00
6 changed files with 12 additions and 10 deletions
Show Stats Expand all files Collapse all files

4
dist/events/base.d.ts vendored
View File

@ -58,7 +58,9 @@ export declare class BaseEventsService<EventType extends MinimalEvents> {
/** /**
* Handle saving events * Handle saving events
*/ */
saveEvents({ events, lastBlock }: BaseEvents<EventType>): Promise<void>; saveEvents({ events, newEvents, lastBlock }: BaseEvents<EventType> & {
newEvents: EventType[];
}): Promise<void>;
/** /**
* Trigger saving and receiving latest events * Trigger saving and receiving latest events
*/ */

4
dist/index.js vendored
View File

@ -2244,7 +2244,7 @@ class BaseEventsService {
* Handle saving events * Handle saving events
*/ */
// eslint-disable-next-line @typescript-eslint/no-unused-vars // eslint-disable-next-line @typescript-eslint/no-unused-vars
async saveEvents({ events, lastBlock }) { async saveEvents({ events, newEvents, lastBlock }) {
} }
/** /**
* Trigger saving and receiving latest events * Trigger saving and receiving latest events
@ -2275,7 +2275,7 @@ class BaseEventsService {
lastBlock lastBlock
}); });
if (savedEvents.fromCache || newEvents.events.length) { if (savedEvents.fromCache || newEvents.events.length) {
await this.saveEvents({ events: allEvents, lastBlock }); await this.saveEvents({ events: allEvents, newEvents: newEvents.events, lastBlock });
} }
return { return {
events: allEvents, events: allEvents,

4
dist/index.mjs vendored
View File

@ -2222,7 +2222,7 @@ class BaseEventsService {
* Handle saving events * Handle saving events
*/ */
// eslint-disable-next-line @typescript-eslint/no-unused-vars // eslint-disable-next-line @typescript-eslint/no-unused-vars
async saveEvents({ events, lastBlock }) { async saveEvents({ events, newEvents, lastBlock }) {
} }
/** /**
* Trigger saving and receiving latest events * Trigger saving and receiving latest events
@ -2253,7 +2253,7 @@ class BaseEventsService {
lastBlock lastBlock
}); });
if (savedEvents.fromCache || newEvents.events.length) { if (savedEvents.fromCache || newEvents.events.length) {
await this.saveEvents({ events: allEvents, lastBlock }); await this.saveEvents({ events: allEvents, newEvents: newEvents.events, lastBlock });
} }
return { return {
events: allEvents, events: allEvents,

4
dist/tornado.umd.js vendored
View File

@ -90514,7 +90514,7 @@ class BaseEventsService {
* Handle saving events * Handle saving events
*/ */
// eslint-disable-next-line @typescript-eslint/no-unused-vars // eslint-disable-next-line @typescript-eslint/no-unused-vars
async saveEvents({ events, lastBlock }) { async saveEvents({ events, newEvents, lastBlock }) {
} }
/** /**
* Trigger saving and receiving latest events * Trigger saving and receiving latest events
@ -90545,7 +90545,7 @@ class BaseEventsService {
lastBlock lastBlock
}); });
if (savedEvents.fromCache || newEvents.events.length) { if (savedEvents.fromCache || newEvents.events.length) {
await this.saveEvents({ events: allEvents, lastBlock }); await this.saveEvents({ events: allEvents, newEvents: newEvents.events, lastBlock });
} }
return { return {
events: allEvents, events: allEvents,

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

File diff suppressed because one or more lines are too long

4
src/events/base.ts
View File

@ -241,7 +241,7 @@ export class BaseEventsService<EventType extends MinimalEvents> {
*/ */
// eslint-disable-next-line @typescript-eslint/no-unused-vars // eslint-disable-next-line @typescript-eslint/no-unused-vars
async saveEvents({ events, lastBlock }: BaseEvents<EventType>) {} async saveEvents({ events, newEvents, lastBlock }: BaseEvents<EventType> & { newEvents: EventType[] }) {}
/** /**
* Trigger saving and receiving latest events * Trigger saving and receiving latest events
@ -284,7 +284,7 @@ export class BaseEventsService<EventType extends MinimalEvents> {
// 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) { if ((savedEvents as CachedEvents<EventType>).fromCache || newEvents.events.length) {
await this.saveEvents({ events: allEvents, lastBlock }); await this.saveEvents({ events: allEvents, newEvents: newEvents.events, lastBlock });
} }
return { return {