api: implement getting all patches associate to a document

Author: williamstein

src/packages/conat/core/client.ts

@@ -1450,14 +1450,13 @@ export class Client extends EventEmitter {
   sync = {
     dkv: async <T,>(opts: DKVOptions): Promise<DKV<T>> =>
       await dkv<T>({ ...opts, client: this }),
-    akv: async <T,>(opts: DKVOptions): Promise<AKV<T>> =>
-      await akv<T>({ ...opts, client: this }),
+    akv: <T,>(opts: DKVOptions): AKV<T> => akv<T>({ ...opts, client: this }),
     dko: async <T,>(opts: DKVOptions): Promise<DKO<T>> =>
       await dko<T>({ ...opts, client: this }),
     dstream: async <T,>(opts: DStreamOptions): Promise<DStream<T>> =>
       await dstream<T>({ ...opts, client: this }),
-    astream: async <T,>(opts: DStreamOptions): Promise<AStream<T>> =>
-      await astream<T>({ ...opts, client: this }),
+    astream: <T,>(opts: DStreamOptions): AStream<T> =>
+      astream<T>({ ...opts, client: this }),
     synctable: async (opts: SyncTableOptions): Promise<ConatSyncTable> =>
       await createSyncTable({ ...opts, client: this }),
   };

src/packages/conat/sync/astream.ts

@@ -99,7 +99,7 @@ export class AStream<T = any> {
   // or network is flaky, but will return all data properly in order
   // then throw an exception with code 503 rather than returning data
   // with something skipped.
-  async *getAll(opts): AsyncGenerator<
+  async *getAll(opts?): AsyncGenerator<
     {
       mesg: T;
       headers?: Headers;

src/packages/server/conat/api/sync.ts

@@ -1,20 +1,44 @@
-//import { conat } from "@cocalc/backend/conat";
+import { conat } from "@cocalc/backend/conat";
 import isCollaborator from "@cocalc/server/projects/is-collaborator";
+import { patchesStreamName } from "@cocalc/conat/sync/synctable-stream";
 
 export async function history({
   account_id,
   project_id,
   path,
+  start_seq = 0,
 }: {
   account_id?: string;
   project_id: string;
   path: string;
+  start_seq: number;
 }): Promise<any[]> {
   if (!account_id || !(await isCollaborator({ account_id, project_id }))) {
     throw Error("user must be collaborator on source project");
   }
 
-  // const client = conat();
-  // this will be much easier once the fs2 branch is merged
-  throw Error(`not implemented yet -- can't get history of ${path} yet`);
+  const client = conat();
+  const name = patchesStreamName({ project_id, path });
+  const astream = client.sync.astream({
+    name,
+    project_id,
+    noInventory: true,
+  });
+  const patches: {
+    seq: number;
+    time: number;
+    mesg: {
+      time: number;
+      wall: number;
+      patch: string;
+      user_id: number;
+      is_snapshot?: boolean;
+      parents: number[];
+      version?: number;
+    };
+  }[] = [];
+  for await (const patch of await astream.getAll({ start_seq })) {
+    patches.push(patch);
+  }
+  return { patches };
 }