From ab9305fc92e083b1c3e08d0ed54fbeec5cfa5fce Mon Sep 17 00:00:00 2001
From: Drew Ansbacher <drew.ansbacher@spiredigital.com>
Date: Mon, 11 Oct 2021 15:49:14 -0600
Subject: [PATCH] patch client reset

---
 client/lib/patch-db.ts | 3 ++-
 client/lib/store.ts    | 4 ++++
 2 files changed, 6 insertions(+), 1 deletion(-)

diff --git a/client/lib/patch-db.ts b/client/lib/patch-db.ts
index 0ffb947..f1b2d90 100644
--- a/client/lib/patch-db.ts
+++ b/client/lib/patch-db.ts
@@ -1,5 +1,5 @@
 import { merge, Observable, of } from 'rxjs'
-import { concatMap, tap } from 'rxjs/operators'
+import { concatMap, finalize, tap } from 'rxjs/operators'
 import { Source } from './source/source'
 import { Store } from './store'
 import { DBCache, Http } from './types'
@@ -20,6 +20,7 @@ export class PatchDB<T> {
     .pipe(
       tap(update => this.store.update(update)),
       concatMap(() => of(this.store.cache)),
+      finalize(() => this.store.reset()),
     )
   }
 }
diff --git a/client/lib/store.ts b/client/lib/store.ts
index a0bc2b9..e8c229d 100644
--- a/client/lib/store.ts
+++ b/client/lib/store.ts
@@ -52,6 +52,10 @@ export class Store<T extends { [key: string]: any }> {
     this.watchedNodes = { }
     this.stash.clear()
     this.sequence$.next(0)
+    this.cache = {
+      sequence: 0,
+      data: { } as any,
+    }
   }
 
   private handleRevision (revision: Revision): void {