From a1dad3a0c58fbdf875b2faf9d5fb9a79d35192dd Mon Sep 17 00:00:00 2001 From: Alex Gleason Date: Wed, 3 Jan 2024 12:54:38 -0600 Subject: [PATCH] Memorelay: #events -> #cache --- src/storages/memorelay.ts | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/storages/memorelay.ts b/src/storages/memorelay.ts index 0ab71938..df241083 100644 --- a/src/storages/memorelay.ts +++ b/src/storages/memorelay.ts @@ -5,10 +5,10 @@ import { type EventStore, type GetEventsOpts } from '@/store.ts'; /** In-memory data store for events using microfilters. */ class Memorelay implements EventStore { #debug = Debug('ditto:memorelay'); - #events: LRUCache; + #cache: LRUCache; constructor(...args: ConstructorParameters>) { - this.#events = new LRUCache(...args); + this.#cache = new LRUCache(...args); } /** Get events from memory. */ @@ -21,7 +21,7 @@ class Memorelay implements EventStore { for (const filter of filters) { if (isMicrofilter(filter)) { - const event = this.#events.get(getFilterId(filter)); + const event = this.#cache.get(getFilterId(filter)); if (event) { results.push(event as Event); } @@ -35,9 +35,9 @@ class Memorelay implements EventStore { storeEvent(event: Event): Promise { for (const microfilter of getMicroFilters(event)) { const filterId = getFilterId(microfilter); - const existing = this.#events.get(filterId); + const existing = this.#cache.get(filterId); if (!existing || event.created_at > existing.created_at) { - this.#events.set(filterId, event); + this.#cache.set(filterId, event); } } return Promise.resolve(); @@ -53,11 +53,11 @@ class Memorelay implements EventStore { deleteEvents(filters: Filter[]): Promise { for (const filter of filters) { if (isMicrofilter(filter)) { - this.#events.delete(getFilterId(filter)); + this.#cache.delete(getFilterId(filter)); } } return Promise.resolve(); } } -export { Memorelay }; \ No newline at end of file +export { Memorelay };