feat(client): remove data mutation

client/lib/json-patch-lib.ts

@@ -1,4 +1,4 @@
-import { PatchOp } from './types'
+import { DBCache, PatchOp } from './types'
 
 export interface Validator<T> {
   (operation: Operation, index: number, doc: T, existingPathFragment: string): void
@@ -15,6 +15,7 @@ export interface AddOperation<T> extends BaseOperation {
 
 export interface RemoveOperation extends BaseOperation {
   op: PatchOp.REMOVE
+  value?: undefined
 }
 
 export interface ReplaceOperation<T> extends BaseOperation {
@@ -22,67 +23,60 @@ export interface ReplaceOperation<T> extends BaseOperation {
   value: T
 }
 
-export type Doc = { [key: string]: any }
-
 export type Operation = AddOperation<any> | RemoveOperation | ReplaceOperation<any>
 
-export function getValueByPointer (doc: any, pointer: string): any {
+export function getValueByPointer (doc: Record<string, any>, pointer: string): any {
   if (pointer === '/') return doc
-  const pathArr = pointer.split('/')
+
-  pathArr.shift()
   try {
-    return pathArr.reduce((acc, next) => acc[next], doc)
+    return pointer.split('/').slice(1).reduce((acc, next) => acc[next], doc)
   } catch (e) {
     return undefined
   }
 }
 
-export function applyOperation (doc: Doc, op: Operation): Operation | null {
+export function applyOperation (doc: DBCache<Record<string, any>>, { path, op, value }: Operation): Operation | null {
-  let undo: Operation | null = null
+  const current = getValueByPointer(doc.data, path)
-  const pathArr = op.path.split('/')
+  const remove = { op: PatchOp.REMOVE, path} as const
-  pathArr.shift()
+  const add = { op: PatchOp.ADD, path, value: current} as const
-  pathArr.reduce((node, key, i) => {
+  const replace = { op: PatchOp.REPLACE, path, value: current } as const
-    if (!isObject) {
-      throw Error('patch cannot be applied.  Path contains non object')
-    }
 
-    if (i < pathArr.length - 1) {
+  doc.data = recursiveApply(doc.data, path.split('/').slice(1), value)
-      // iterate node
-      return node[key]
-    }
 
-    // if last key
+  switch (op) {
-    const curVal = node[key]
+    case PatchOp.REMOVE:
-    if (op.op === 'add' || op.op === 'replace') {
+      return current === undefined
-      node[key] = op.value
+        ? null
-      if (curVal) {
+        : add
-        undo = {
+    case PatchOp.REPLACE:
-          op: PatchOp.REPLACE,
+    case PatchOp.ADD:
-          path: op.path,
+      return current === undefined
-          value: curVal,
+        ? remove
-        }
+        : replace
-      } else {
+  }
-        undo = {
-          op: PatchOp.REMOVE,
-          path: op.path,
-        }
-      }
-    } else {
-      delete node[key]
-      if (curVal) {
-        undo = {
-          op: PatchOp.ADD,
-          path: op.path,
-          value: curVal,
-        }
-      }
-    }
-  }, doc)
-
-  return undo
 }
 
-function isObject (val: any): val is Doc {
+function recursiveApply<T extends Record<string, T>> (data: T, path: readonly string[], value?: any): T {
+  if (!path.length) return value
+
+  if (!isObject(data)) {
+    throw Error('Patch cannot be applied. Path contains non object')
+  }
+
+  const updated = recursiveApply(data[path[0]], path.slice(1), value)
+  const result = {
+    ...data,
+    [path[0]]: updated,
+  }
+
+  if (updated === undefined) {
+    delete result[path[0]]
+  }
+
+  return result
+}
+
+function isObject (val: any): val is Record<string, any> {
   return typeof val === 'object' && !Array.isArray(val) && val !== null
 }
 

client/lib/patch-db.ts

@@ -36,8 +36,6 @@ export class PatchDB<T> {
 
   clean () {
     this.sourcesSub.unsubscribe()
-    if (this.updatesSub) {
+    this.updatesSub?.unsubscribe()
-      this.updatesSub.unsubscribe()
-    }
   }
 }

client/lib/store.ts

@@ -70,20 +70,12 @@ export class Store<T extends { [key: string]: any }> {
     this.processStashed(revision.id)
   }
 
-  private handleDump (dump: Dump<T>): void {
+  private handleDump ({ value, id }: Dump<T>): void {
-    Object.keys(this.cache.data).forEach(key => {
+    this.cache.data = { ...value }
-      if (dump.value[key] === undefined) {
+    this.stash.deleteRange(this.cache.sequence, id, false)
-        delete this.cache.data[key]
-      }
-    })
-
-    Object.entries(dump.value).forEach(([key, val]) => {
-      (this.cache.data as any)[key] = val
-    })
-    this.stash.deleteRange(this.cache.sequence, dump.id, false)
     this.updateWatchedNodes('')
-    this.updateSequence(dump.id)
+    this.updateSequence(id)
-    this.processStashed(dump.id + 1)
+    this.processStashed(id + 1)
   }
 
   private processStashed (id: number): void {
@@ -95,9 +87,7 @@ export class Store<T extends { [key: string]: any }> {
     let stashEntry = this.stash.get(this.stash.maxKey() as number)
 
     while (stashEntry && stashEntry.revision.id > id) {
-      stashEntry.undo.forEach(u => {
+      stashEntry.undo.forEach(u => applyOperation(this.cache, u))
-        applyOperation(this.cache.data, u)
-      })
       stashEntry = this.stash.nextLowerPair(stashEntry.revision.id)?.[1]
     }
   }
@@ -106,18 +96,16 @@ export class Store<T extends { [key: string]: any }> {
     let revision = this.stash.get(id)?.revision
     while (revision) {
       let undo: Operation[] = []
-
       let success = false
+
       try {
         revision.patch.forEach(op => {
-          const u = applyOperation(this.cache.data, op)
+          const u = applyOperation(this.cache, op)
           if (u) undo.push(u)
         })
         success = true
       } catch (e) {
-        undo.forEach(u => {
+        undo.forEach(u => applyOperation(this.cache, u))
-          applyOperation(this.cache.data, u)
-        })
         undo = []
       }
 
@@ -163,6 +151,6 @@ export class Store<T extends { [key: string]: any }> {
   }
 
   private isRevision (update: Update<T>): update is Revision {
-    return !!(update as Revision).patch
+    return 'patch' in update
   }
 }

client/lib/types.ts

@@ -23,7 +23,7 @@ export interface Bootstrapper<T> {
   update (cache: DBCache<T>): Promise<void>
 }
 
-export interface DBCache<T extends { [key: string]: any }>{
+export interface DBCache<T extends Record<string, any>>{
   sequence: number,
   data: T
 }