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

Compare commits

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

1 Commits
6ac1025bc1 ... 49a5ba7a2d

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

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

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

4
dist/index.js vendored
View File

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

4
dist/index.mjs vendored
View File

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

4
dist/tornado.umd.js vendored
View File

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