feat(reactive-rpc): 🎸 return whole history on block read

Author: streamich

src/server/__tests__/blocks.spec.ts

@@ -422,4 +422,67 @@ describe('blocks.*', () => {
       });
     });
   });
+
+  describe('blocks.get', () => {
+    test('returns whole history when block is loaded', async () => {
+      const {client} = setup();
+      const model = Model.withLogicalClock();
+      model.api.root({
+        text: 'Hell',
+      });
+      const patch1 = model.api.flush();
+      await client.call('blocks.create', {
+        id: 'my-block',
+        patches: [
+          {
+            seq: 0,
+            created: Date.now(),
+            blob: patch1.toBinary(),
+          },
+        ],
+      });
+      model.api.str(['text']).ins(4, 'o');
+      const patch2 = model.api.flush();
+      model.api.obj([]).set({
+        age: 26,
+      });
+      const patch3 = model.api.flush();
+      await client.call('blocks.edit', {
+        id: 'my-block',
+        patches: [
+          {
+            seq: 1,
+            created: Date.now(),
+            blob: patch2.toBinary(),
+          },
+          {
+            seq: 2,
+            created: Date.now(),
+            blob: patch3.toBinary(),
+          },
+        ],
+      });
+      const result = await client.call('blocks.get', {id: 'my-block'});
+      expect(result).toMatchObject({
+        block: expect.any(Object),
+        patches: [
+          {
+            seq: 0,
+            created: expect.any(Number),
+            blob: patch1.toBinary(),
+          },
+          {
+            seq: 1,
+            created: expect.any(Number),
+            blob: patch2.toBinary(),
+          },
+          {
+            seq: 2,
+            created: expect.any(Number),
+            blob: patch3.toBinary(),
+          },
+        ],
+      });
+    });
+  });
 });

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

@@ -1,6 +1,6 @@
 import type {RoutesBase, TypeRouter} from '../../../../json-type/system/TypeRouter';
 import type {RouteDeps} from '../../types';
-import type {Block, BlockId} from '../schema';
+import type {Block, BlockId, BlockPatch} from '../schema';
 
 export const get =
   ({services}: RouteDeps) =>
@@ -14,7 +14,13 @@ export const get =
       }),
     );
 
-    const Response = t.Object(t.prop('block', t.Ref<typeof Block>('Block').options({})));
+    const Response = t.Object(
+      t.prop('block', t.Ref<typeof Block>('Block').options({})),
+      t.prop('patches', t.Array(t.Ref<typeof BlockPatch>('BlockPatch'))).options({
+        title: 'Patches',
+        description: 'The list of all patches.',
+      }),
+    );
 
     const Func = t
       .Function(Request, Response)
@@ -24,9 +30,10 @@ export const get =
         description: 'Fetches a block by ID.',
       })
       .implement(async ({id}) => {
-        const {block} = await services.blocks.get(id);
+        const {block, patches} = await services.blocks.get(id);
         return {
-          block: block,
+          block,
+          patches,
         };
       });
 

src/server/services/blocks/BlocksServices.ts

@@ -37,8 +37,9 @@ export class BlocksServices {
     const {store} = this;
     const result = await store.get(id);
     if (!result) throw RpcError.fromCode(RpcErrorCodes.NOT_FOUND);
+    const patches = await store.history(id, 0, result.block.seq);
     const {block} = result;
-    return {block};
+    return {block, patches};
   }
 
   public async remove(id: string) {