db/events: respect the signal

This commit is contained in:
Alex Gleason
2023-12-31 21:01:30 -06:00
parent f665c5f825
commit e341ec7b36

View File

@@ -257,6 +257,7 @@ async function getEvents<K extends number>(
filters: DittoFilter<K>[],
opts: GetEventsOpts = {},
): Promise<DittoEvent<K>[]> {
if (opts.signal?.aborted) return Promise.resolve([]);
if (!filters.length) return Promise.resolve([]);
debug('REQ', JSON.stringify(filters));
let query = getEventsQuery(filters);