style: 💄 run Prettier

Author: streamich

src/__demos__/ui-text/main.tsx

@@ -16,7 +16,6 @@ const main = async () => {
   const view = model.view();
   if (typeof view !== 'string') model.api.root('');
 
-
   const Demo: React.FC = () => {
     const [remote, setRemote] = React.useState<Model | null>(null);
     const ref = React.useRef<HTMLTextAreaElement | null>(null);

src/json-crdt-repo/local/level/LevelLocalRepo.ts

@@ -734,12 +734,11 @@ export class LevelLocalRepo implements LocalRepo {
   private async _syncMerge(req: LocalRepoSyncRequest): Promise<LocalRepoSyncResponse> {
     const {id, patches} = req;
     let lastKnownTime: number = 0;
-    const reqTime = req.time
+    const reqTime = req.time;
     if (typeof reqTime === 'number') {
       lastKnownTime = reqTime;
       const firstPatch = patches?.[0];
-      if (firstPatch?.getId()?.sid === SESSION.GLOBAL)
-        lastKnownTime = firstPatch.getId()!.time + firstPatch.span() - 1;
+      if (firstPatch?.getId()?.sid === SESSION.GLOBAL) lastKnownTime = firstPatch.getId()!.time + firstPatch.span() - 1;
     } else if (patches?.length) {
       const firstPatchTime = patches?.[0]?.getId()?.time;
       if (typeof firstPatchTime === 'number') lastKnownTime = firstPatchTime - 1;

src/json-crdt-repo/session/EditSession.ts

@@ -93,7 +93,7 @@ export class EditSession<N extends JsonNode = JsonNode<any>> {
           patches,
           time,
           cursor: this.cursor,
-          session: this.session
+          session: this.session,
         });
         if (this._stopped) return null;
         // TODO: After sync call succeeds, remove the patches from the log.
@@ -123,7 +123,7 @@ export class EditSession<N extends JsonNode = JsonNode<any>> {
             if (this._stopped) return;
             const get = await this.repo.getIf({
               id: this.id,
-              cursor: this.cursor
+              cursor: this.cursor,
             });
             if (this._stopped) return;
             if (!get) return;
@@ -149,11 +149,13 @@ export class EditSession<N extends JsonNode = JsonNode<any>> {
   public syncLog(): void {
     if (!this.log.patches.size()) return;
     this._syncRace(() => {
-      this.sync().then((error) => {
-        this.onsyncerror?.(error);
-      }).catch(error => {
-        this.onsyncerror?.(error);
-      });
+      this.sync()
+        .then((error) => {
+          this.onsyncerror?.(error);
+        })
+        .catch((error) => {
+          this.onsyncerror?.(error);
+        });
     });
   }
 

src/json-crdt-repo/session/EditSessionFactory.ts

@@ -61,14 +61,19 @@ export class EditSessionFactory {
             const {model, cursor} = await (typeof timeoutMs === 'number'
               ? timeout(timeoutMs, repo.pull(id))
               : repo.pull(id));
-              if (remote.throwIf === 'exists') throw new Error('EXISTS');
-              const session = new EditSession(repo, id, model, cursor, opts.session);
-              session.log.end.api.autoFlush();
-              return session;
-            } catch (error) {
+            if (remote.throwIf === 'exists') throw new Error('EXISTS');
+            const session = new EditSession(repo, id, model, cursor, opts.session);
+            session.log.end.api.autoFlush();
+            return session;
+          } catch (error) {
             if (!!error && typeof error === 'object' && (error as Record<string, unknown>).message === 'TIMEOUT') {
               if (!opts.make) throw error;
-            } else if (!!error && typeof error === 'object' && ((error as Record<string, unknown>).message === 'NOT_FOUND' || (error as Record<string, unknown>).code === 'NOT_FOUND')) {
+            } else if (
+              !!error &&
+              typeof error === 'object' &&
+              ((error as Record<string, unknown>).message === 'NOT_FOUND' ||
+                (error as Record<string, unknown>).code === 'NOT_FOUND')
+            ) {
               if (remote.throwIf === 'missing') throw error;
             } else throw error;
           }