style: 💄 run Prettier

Author: streamich

src/json-crdt-repo/local/server-crud/ServerCrudLocalHistory.ts

@@ -18,7 +18,11 @@ export class ServerCrudLocalHistory implements LocalHistory {
     this.sync = new ServerCrudLocalHistorySync(opts.sync ?? {}, this.core);
   }
 
-  public async create(collection: string[], log: Log, id: string = genId()): Promise<{id: string, remote: Promise<void>}> {
+  public async create(
+    collection: string[],
+    log: Log,
+    id: string = genId(),
+  ): Promise<{id: string; remote: Promise<void>}> {
     if (log.end.clock.time <= 1) throw new Error('EMPTY_LOG');
     const blob = this.encode(log);
     await this.lockForWrite({collection, id}, async () => {
@@ -91,10 +95,16 @@ export class ServerCrudLocalHistory implements LocalHistory {
     // };
   }
 
-  protected async lockForWrite({collection, id}: {
-    collection: string[];
-    id: string;
-  }, fn: () => Promise<void>): Promise<void> {
+  protected async lockForWrite(
+    {
+      collection,
+      id,
+    }: {
+      collection: string[];
+      id: string;
+    },
+    fn: () => Promise<void>,
+  ): Promise<void> {
     const key = ['write', collection, id].join('/');
     await this.core.locks.lock(key, 300, 300)(fn);
   }

src/json-crdt-repo/local/server-crud/ServerCrudLocalHistoryCore.ts

@@ -45,12 +45,12 @@ export class ServerCrudLocalHistoryCore implements ServerCrudLocalHistoryCoreOpt
     const blob = await this.crud.get(crudCollection, DATA_FILE_NAME);
     return blob;
   }
-  
+
   public async create(collection: string[], id: string, blob: Uint8Array): Promise<void> {
     const crudCollection = this.crudCollection(collection, id);
     await this.crud.put(crudCollection, DATA_FILE_NAME, blob, {throwIf: 'exists'});
   }
-  
+
   public async update(collection: string[], id: string, blob: Uint8Array): Promise<void> {
     const crudCollection = this.crudCollection(collection, id);
     await this.crud.put(crudCollection, DATA_FILE_NAME, blob, {throwIf: 'missing'});

src/json-crdt-repo/local/server-crud/ServerCrudLocalHistorySync.ts

@@ -1,7 +1,7 @@
 import {timeout} from 'thingies/lib/timeout';
-import type {RemoteBlockPatch} from "../../remote/types";
-import type {ServerCrudLocalHistoryCore} from "./ServerCrudLocalHistoryCore";
-import type {BlockSyncMetadata} from "./types";
+import type {RemoteBlockPatch} from '../../remote/types';
+import type {ServerCrudLocalHistoryCore} from './ServerCrudLocalHistoryCore';
+import type {BlockSyncMetadata} from './types';
 
 const SYNC_FILE_NAME = 'sync.cbor';
 
@@ -91,10 +91,16 @@ export class ServerCrudLocalHistorySync {
     await this.putMeta(collection, id, {time, ts: Date.now()});
   }
 
-  public async lock<T>({collection, id}: {
-    collection: string[];
-    id: string;
-  }, fn: () => Promise<T>): Promise<T> {
+  public async lock<T>(
+    {
+      collection,
+      id,
+    }: {
+      collection: string[];
+      id: string;
+    },
+    fn: () => Promise<T>,
+  ): Promise<T> {
     const key = ['sync', collection, id].join('/');
     const locker = this.core.locks.lock(key, this.remoteTimeout() + 200, 200);
     return await locker<T>(fn);
@@ -135,8 +141,7 @@ export class ServerCrudLocalHistorySync {
       await this.core.crud.info(dir, id);
       return true;
     } catch (error) {
-      if (error instanceof DOMException && error.name === 'ResourceNotFound')
-        return false;
+      if (error instanceof DOMException && error.name === 'ResourceNotFound') return false;
       throw error;
     }
   }

src/json-crdt-repo/local/server-crud/__tests__/ServerCrudLocalHistory.spec.ts

@@ -9,10 +9,12 @@ import {BehaviorSubject} from 'rxjs';
 import {setup as remoteSetup} from '../../../remote/__tests__/setup';
 import {tick} from 'thingies';
 
-const setup = async (opts: {
-  remote?: ReturnType<typeof remoteSetup>;
-  local?: Partial<ServerCrudLocalHistoryOpts>;
-} = {}) => {
+const setup = async (
+  opts: {
+    remote?: ReturnType<typeof remoteSetup>;
+    local?: Partial<ServerCrudLocalHistoryOpts>;
+  } = {},
+) => {
   const remote = opts.remote ?? remoteSetup();
   const {fs, vol} = memfs();
   const printFs = () => console.log(toTreeSync(fs));
@@ -65,7 +67,7 @@ describe('.create()', () => {
     const res = await kit.local.create(['collection'], kit.log, kit.id);
     expect(res).toMatchObject({
       id: kit.id,
-      remote: expect.any(Promise)
+      remote: expect.any(Promise),
     });
   });
 
@@ -91,11 +93,12 @@ describe('.create()', () => {
   });
 
   describe('when not connected', () => {
-    const setupNotConnected = () => setup({
-      local: {
-        connected$: new BehaviorSubject(false),
-      }
-    });
+    const setupNotConnected = () =>
+      setup({
+        local: {
+          connected$: new BehaviorSubject(false),
+        },
+      });
 
     test('throws on empty log', async () => {
       const kit = await setupNotConnected();
@@ -108,16 +111,16 @@ describe('.create()', () => {
         expect(err).toEqual(new Error('EMPTY_LOG'));
       }
     });
-  
+
     test('can create a new block', async () => {
       const kit = await setupNotConnected();
       const res = await kit.local.create(['collection'], kit.log, kit.id);
       expect(res).toMatchObject({
         id: kit.id,
-        remote: expect.any(Promise)
+        remote: expect.any(Promise),
       });
     });
-  
+
     test('does not store the block on remote, throws on remote sync', async () => {
       const kit = await setupNotConnected();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);
@@ -130,7 +133,7 @@ describe('.create()', () => {
       }
       expect(kit.remote.services.blocks.stats().blocks).toBe(0);
     });
-  
+
     test('marks item as "dirty" for sync', async () => {
       const kit = await setupNotConnected();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);
@@ -168,16 +171,16 @@ describe('.create()', () => {
         expect(err).toEqual(new Error('EMPTY_LOG'));
       }
     });
-  
+
     test('can create a new block', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['collection'], kit.log, kit.id);
       expect(res).toMatchObject({
         id: kit.id,
-        remote: expect.any(Promise)
+        remote: expect.any(Promise),
       });
     });
-  
+
     test('does not store the block on remote, throws on remote sync', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);
@@ -190,7 +193,7 @@ describe('.create()', () => {
       }
       expect(kit.remote.services.blocks.stats().blocks).toBe(0);
     });
-  
+
     test('marks item as "dirty" for sync', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);
@@ -236,16 +239,16 @@ describe('.create()', () => {
         expect(err).toEqual(new Error('EMPTY_LOG'));
       }
     });
-  
+
     test('can create a new block', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['collection'], kit.log, kit.id);
       expect(res).toMatchObject({
         id: kit.id,
-        remote: expect.any(Promise)
+        remote: expect.any(Promise),
       });
     });
-  
+
     test('does not store the block on remote, throws on remote sync', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);
@@ -258,7 +261,7 @@ describe('.create()', () => {
       }
       expect(kit.remote.services.blocks.stats().blocks).toBe(0);
     });
-  
+
     test('marks item as "dirty" for sync', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);
@@ -304,16 +307,16 @@ describe('.create()', () => {
         expect(err).toEqual(new Error('EMPTY_LOG'));
       }
     });
-  
+
     test('can create a new block', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['collection'], kit.log, kit.id);
       expect(res).toMatchObject({
         id: kit.id,
-        remote: expect.any(Promise)
+        remote: expect.any(Promise),
       });
     });
-  
+
     test('marks item as "dirty" for sync, but synchronizes over time', async () => {
       const kit = await setupFaultyConnection();
       const res = await kit.local.create(['my', 'col'], kit.log, kit.id);

src/json-crdt-repo/local/types.ts

@@ -2,7 +2,7 @@ import type {Patch} from 'json-joy/lib/json-crdt-patch';
 import type {Log} from 'json-joy/lib/json-crdt/log/Log';
 
 export interface LocalHistory {
-  create(collection: string[], log: Log, id?: string): Promise<{id: string, remote: Promise<void>}>;
+  create(collection: string[], log: Log, id?: string): Promise<{id: string; remote: Promise<void>}>;
   read(collection: string[], id: string): Promise<{log: Log; cursor: string}>;
   readHistory(collection: string[], id: string, cursor: string): Promise<{log: Log; cursor: string}>;
   update(collection: string[], id: string, patches: Patch[]): Promise<void>;