mirror/ditto
mirror/ditto
1
0
Fork 0
mirror of https://gitlab.com/soapbox-pub/ditto.git synced 2025-12-06 03:19:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

DittoPgStore: remove fulfillment batching

Browse source
This commit is contained in:
Alex Gleason 2025-05-08 19:42:10 -05:00
parent fd87bad238
commit 984f76d184
No known key found for this signature in database
GPG key ID: 7211D1F99744FBB7
1 changed files with 1 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
packages/ditto/storages/DittoPgStore.ts
View file

@ -61,8 +61,6 @@ interface DittoPgStoreOpts {
pure?: boolean; pure?: boolean;
/** Chunk size for streaming events. Defaults to 20. */ /** Chunk size for streaming events. Defaults to 20. */
chunkSize?: number; chunkSize?: number;
/** Batch size for fulfilling subscriptions. Defaults to 500. */
batchSize?: number;
/** Max age (in **seconds**) an event can be to be fulfilled to realtime subscribers. */ /** Max age (in **seconds**) an event can be to be fulfilled to realtime subscribers. */
maxAge?: number; maxAge?: number;
/** Whether to listen for events from the database with NOTIFY. */ /** Whether to listen for events from the database with NOTIFY. */
@ -190,7 +188,7 @@ export class DittoPgStore extends NPostgres {
/** Fulfill active subscriptions with this event. */ /** Fulfill active subscriptions with this event. */
protected async fulfill(event: NostrEvent): Promise<void> { protected async fulfill(event: NostrEvent): Promise<void> {
const { maxAge = 60, batchSize = 500 } = this.opts; const { maxAge = 60 } = this.opts;
const now = Math.floor(Date.now() / 1000); const now = Math.floor(Date.now() / 1000);
const age = now - event.created_at; const age = now - event.created_at;
@ -205,21 +203,12 @@ export class DittoPgStore extends NPostgres {
} }
} }
let count = 0;
for (const [subId, { filters, machina }] of this.subs.entries()) { for (const [subId, { filters, machina }] of this.subs.entries()) {
for (const filter of filters) { for (const filter of filters) {
count++;
if (this.matchesFilter(event, filter)) { if (this.matchesFilter(event, filter)) {
machina.push(['EVENT', subId, event]); machina.push(['EVENT', subId, event]);
break; break;
} }
// Yield to event loop.
if (count % batchSize === 0) {
await new Promise((resolve) => setTimeout(resolve, 0));
}
} }
} }
} }