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

Disable mixer, just take events from the db

Browse source
This commit is contained in:
Alex Gleason 2023-10-09 11:37:35 -05:00
parent 49b056a4bd
commit 1c51e3b27c
No known key found for this signature in database
GPG key ID: 7211D1F99744FBB7
1 changed files with 3 additions and 49 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

52
src/mixer.ts
View file

@ -1,63 +1,17 @@
import { type Event, matchFilters } from '@/deps.ts';
import { type Event } from '@/deps.ts';
import * as client from '@/client.ts';
import * as eventsDB from '@/db/events.ts';
import { dedupeEvents, eventDateComparator } from '@/utils.ts';
import type { DittoFilter, GetFiltersOpts } from '@/filter.ts';
/** Get filters from the database and pool, and mix the best results together. */
async function getFilters<K extends number>(
function getFilters<K extends number>(
filters: DittoFilter<K>[],
opts?: GetFiltersOpts,
): Promise<Event<K>[]> {
if (!filters.length) return Promise.resolve([]);
const results = await Promise.allSettled([
client.getFilters(filters.filter((filter) => !filter.local), opts),
eventsDB.getFilters(filters, opts),
]);
const events = results
.filter((result): result is PromiseFulfilledResult<Event<K>[]> => result.status === 'fulfilled')
.flatMap((result) => result.value);
return unmixEvents(events, filters);
}
/** Combine and sort events to match the filters. */
function unmixEvents<K extends number>(events: Event<K>[], filters: DittoFilter<K>[]): Event<K>[] {
events = dedupeEvents(events);
events = takeNewestEvents(events);
events = events.filter((event) => matchFilters(filters, event));
events.sort(eventDateComparator);
return events;
}
/** Take the newest events among replaceable ones. */
function takeNewestEvents<K extends number>(events: Event<K>[]): Event<K>[] {
const isReplaceable = (kind: number) =>
kind === 0 || kind === 3 || (10000 <= kind && kind < 20000) || (30000 <= kind && kind < 40000);
// Group events by author and kind.
const groupedEvents = events.reduce<Map<string, Event<K>[]>>((acc, event) => {
const key = `${event.pubkey}:${event.kind}`;
const group = acc.get(key) || [];
acc.set(key, [...group, event]);
return acc;
}, new Map());
// Process each group.
const processedEvents = Array.from(groupedEvents.values()).flatMap((group) => {
if (isReplaceable(group[0].kind)) {
// Sort by `created_at` and take the latest event.
return group.sort(eventDateComparator)[0];
}
return group;
});
return processedEvents;
return eventsDB.getFilters(filters, opts);
}
export { getFilters };