moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Memorelay: #events -> #cache

This commit is contained in:
Alex Gleason 2024-01-03 12:54:38 -06:00
parent 24c405b9b9
commit a1dad3a0c5
No known key found for this signature in database
GPG Key ID: 7211D1F99744FBB7
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/storages/memorelay.ts
View File

@ -5,10 +5,10 @@ import { type EventStore, type GetEventsOpts } from '@/store.ts';
/** In-memory data store for events using microfilters. */ /** In-memory data store for events using microfilters. */
class Memorelay implements EventStore { class Memorelay implements EventStore {
#debug = Debug('ditto:memorelay'); #debug = Debug('ditto:memorelay');
#events: LRUCache<string, Event>; #cache: LRUCache<string, Event>;
constructor(...args: ConstructorParameters<typeof LRUCache<string, Event>>) { constructor(...args: ConstructorParameters<typeof LRUCache<string, Event>>) {
this.#events = new LRUCache<string, Event>(...args); this.#cache = new LRUCache<string, Event>(...args);
} }
/** Get events from memory. */ /** Get events from memory. */
@ -21,7 +21,7 @@ class Memorelay implements EventStore {
for (const filter of filters) { for (const filter of filters) {
if (isMicrofilter(filter)) { if (isMicrofilter(filter)) {
const event = this.#events.get(getFilterId(filter)); const event = this.#cache.get(getFilterId(filter));
if (event) { if (event) {
results.push(event as Event<K>); results.push(event as Event<K>);
} }
@ -35,9 +35,9 @@ class Memorelay implements EventStore {
storeEvent(event: Event): Promise<void> { storeEvent(event: Event): Promise<void> {
for (const microfilter of getMicroFilters(event)) { for (const microfilter of getMicroFilters(event)) {
const filterId = getFilterId(microfilter); const filterId = getFilterId(microfilter);
const existing = this.#events.get(filterId); const existing = this.#cache.get(filterId);
if (!existing || event.created_at > existing.created_at) { if (!existing || event.created_at > existing.created_at) {
this.#events.set(filterId, event); this.#cache.set(filterId, event);
} }
} }
return Promise.resolve(); return Promise.resolve();
@ -53,11 +53,11 @@ class Memorelay implements EventStore {
deleteEvents(filters: Filter[]): Promise<void> { deleteEvents(filters: Filter[]): Promise<void> {
for (const filter of filters) { for (const filter of filters) {
if (isMicrofilter(filter)) { if (isMicrofilter(filter)) {
this.#events.delete(getFilterId(filter)); this.#cache.delete(getFilterId(filter));
} }
} }
return Promise.resolve(); return Promise.resolve();
} }
} }
export { Memorelay }; export { Memorelay };