Add repository.clear

2024-05-20 16:45:22 -07:00
parent b80b8d264b
commit fe0475281d
1 changed files with 10 additions and 0 deletions
@@ -38,6 +38,8 @@ export class Repository extends Emitter implements IReadable<TrustedEvent[]> {
  }

  async set(events: TrustedEvent[], chunkSize = 1000) {
+    this.clear()
+
    for (const eventsChunk of chunk(chunkSize, events)) {
      for (const event of eventsChunk) {
        this.publish(event)
@@ -49,6 +51,14 @@ export class Repository extends Emitter implements IReadable<TrustedEvent[]> {
    }
  }

+  clear() {
+    this.eventsById.clear()
+    this.eventsByAddress.clear()
+    this.eventsByTag.clear()
+    this.eventsByDay.clear()
+    this.eventsByAuthor.clear()
+    this.deletes.clear()
+  }

  subscribe(f: Subscriber<TrustedEvent[]>, invalidate?: Invalidator<TrustedEvent[]>) {
    this.subs.push(f)