send message when websocket open and clear store cache on reset

client/lib/patch-db.ts

@@ -20,9 +20,6 @@ export class PatchDB<T> {
     .pipe(
       tap(update => this.store.update(update)),
       concatMap(() => of(this.store.cache)),
-      finalize(() => {
-        this.store.reset()
-      }),
     )
   }
 }

client/lib/source/ws-source.ts

@@ -15,8 +15,7 @@ export class WebsocketSource<T> implements Source<T> {
       url: this.url,
       openObserver: {
         next: () => {
-          console.log('WebSocket connection open')
+          this.websocket$!.next(document.cookie as any)
-          this.websocket$!.next('open message' as any)
         },
       },
     }

client/lib/store.ts

@@ -50,6 +50,7 @@ export class Store<T extends { [key: string]: any }> {
 
   reset (): void {
     Object.values(this.watchedNodes).forEach(node => node.complete())
+    this.watchedNodes = { }
     this.stash.clear()
   }