style: 💄 run Prettier

Author: streamich

src/server/__tests__/blocks.spec.ts

@@ -292,7 +292,7 @@ describe('blocks.*', () => {
       await tick(11);
       const emits: any[] = [];
       caller.call$('blocks.listen', of({id: 'my-block'}), {}).subscribe((data) => emits.push(data));
-      const model = Model.withLogicalClock(); 
+      const model = Model.withLogicalClock();
       model.api.root({
         text: 'Hell',
       });
@@ -321,20 +321,23 @@ describe('blocks.*', () => {
       const {call, caller} = setup();
       const emits: any[] = [];
       caller.call$('blocks.listen', of({id: 'my-block'}), {}).subscribe((data) => emits.push(data));
-      const model = Model.withLogicalClock(); 
+      const model = Model.withLogicalClock();
       model.api.root({
         text: 'Hell',
       });
       const patch1 = model.api.flush();
       await tick(12);
       expect(emits.length).toBe(0);
-      await call('blocks.create', {id: 'my-block', patches: [
-        {
-          seq: 0,
-          created: Date.now(),
-          blob: patch1.toBinary(),
-        },
-      ]});
+      await call('blocks.create', {
+        id: 'my-block',
+        patches: [
+          {
+            seq: 0,
+            created: Date.now(),
+            blob: patch1.toBinary(),
+          },
+        ],
+      });
       await until(() => emits.length === 1);
       expect(emits.length).toBe(1);
       expect(emits[0].data.patches.length).toBe(1);

src/server/routes/blocks/methods/listen.ts

@@ -38,9 +38,7 @@ export const listen =
         description: 'Subscribe to a block to receive updates when it changes.',
       })
       .implement((req$) => {
-        return req$.pipe(
-          switchMap(({id}) => services.pubsub.listen$(`__block:${id}`)),
-        ) as any;
+        return req$.pipe(switchMap(({id}) => services.pubsub.listen$(`__block:${id}`))) as any;
       });
 
     return router.fn$('blocks.listen', Func);

src/server/services/blocks/BlocksServices.ts

@@ -15,7 +15,7 @@ export class BlocksServices {
       block,
       patches,
     };
-    this.services.pubsub.publish(`__block:${id}`, data).catch(error => {
+    this.services.pubsub.publish(`__block:${id}`, data).catch((error) => {
       console.error('Error publishing block patches', error);
     });
     return {block};
@@ -31,7 +31,7 @@ export class BlocksServices {
 
   public async remove(id: string) {
     await this.store.remove(id);
-    this.services.pubsub.publish(`__block:${id}`, {deleted: true}).catch(error => {
+    this.services.pubsub.publish(`__block:${id}`, {deleted: true}).catch((error) => {
       console.error('Error publishing block deletion', error);
     });
   }
@@ -42,7 +42,7 @@ export class BlocksServices {
     const seq = patches[0].seq;
     const {store} = this;
     const {block} = await store.edit(id, patches);
-    this.services.pubsub.publish(`__block:${id}`, {patches}).catch(error => {
+    this.services.pubsub.publish(`__block:${id}`, {patches}).catch((error) => {
       console.error('Error publishing block patches', error);
     });
     const expectedBlockSeq = seq + patches.length - 1;