Use listRecords instead of getRepo

bun.lock

···
         "@atcute/cbor": "^2.2.7",
         "@atcute/cid": "^2.2.6",
         "@atcute/client": "^4.0.5",
-        "@atcute/repo": "^0.1.0",
         "@atcute/tid": "^1.0.3",
         "@napi-rs/keyring": "^1.2.0",
         "citty": "^0.1.6",
···
   "packages": {
     "@atcute/atproto": ["@atcute/atproto@3.1.9", "", { "dependencies": { "@atcute/lexicons": "^1.2.2" } }, "sha512-DyWwHCTdR4hY2BPNbLXgVmm7lI+fceOwWbE4LXbGvbvVtSn+ejSVFaAv01Ra3kWDha0whsOmbJL8JP0QPpf1+w=="],
 
-    "@atcute/car": ["@atcute/car@5.0.0", "", { "dependencies": { "@atcute/cbor": "^2.2.7", "@atcute/cid": "^2.2.6", "@atcute/uint8array": "^1.0.5", "@atcute/varint": "^1.0.3" } }, "sha512-OIY2xTXv8lSpZsDSn/UYQtJSMvDw5Hi4Q+uyvmiqSM+fht08QRAEq/nxa5YFciPZ3nfDFnZ3//EgJw7QhkSXLQ=="],
-
     "@atcute/cbor": ["@atcute/cbor@2.2.7", "", { "dependencies": { "@atcute/cid": "^2.2.5", "@atcute/multibase": "^1.1.6", "@atcute/uint8array": "^1.0.5" } }, "sha512-/mwAF0gnokOphceZqFq3uzMGdd8sbw5y6bxF8CRutRkCCUcpjjpJc5fkLwhxyGgOveF3mZuHE6p7t/+IAqb7Aw=="],
 
     "@atcute/cid": ["@atcute/cid@2.2.6", "", { "dependencies": { "@atcute/multibase": "^1.1.6", "@atcute/uint8array": "^1.0.5" } }, "sha512-bTAHHbJ24p+E//V4KCS4xdmd39o211jJswvqQOevj7vk+5IYcgDLx1ryZWZ1sEPOo9x875li/kj5gpKL14RDwQ=="],
 
     "@atcute/client": ["@atcute/client@4.0.5", "", { "dependencies": { "@atcute/identity": "^1.1.1", "@atcute/lexicons": "^1.2.2" } }, "sha512-R8Qen8goGmEkynYGg2m6XFlVmz0GTDvQ+9w+4QqOob+XMk8/WDpF4aImev7WKEde/rV2gjcqW7zM8E6W9NShDA=="],
 
-    "@atcute/crypto": ["@atcute/crypto@2.2.6", "", { "dependencies": { "@atcute/multibase": "^1.1.6", "@atcute/uint8array": "^1.0.5", "@noble/secp256k1": "^3.0.0" } }, "sha512-vkuexF+kmrKE1/Uqzub99Qi4QpnxA2jbu60E6PTgL4XypELQ6rb59MB/J1VbY2gs0kd3ET7+L3+NWpKD5nXyfA=="],
-
     "@atcute/identity": ["@atcute/identity@1.1.2", "", { "dependencies": { "@atcute/lexicons": "^1.2.3", "@badrap/valita": "^0.4.6" } }, "sha512-vn0RN7SUF6N0sEPG9yyT6a0MzpfVS8BhsiLtB8OeS4qp2rLMQW33pelCpNitP1N+fq03MFlDGzs5p7K4qMs4cA=="],
 
     "@atcute/leaflet": ["@atcute/leaflet@1.0.12", "", { "dependencies": { "@atcute/atproto": "^3.1.9", "@atcute/lexicons": "^1.2.2" } }, "sha512-T5laBTl8vwzy0eZXBy07IQSjsLqhbZmRJsffnNQ6XMSc+lnCZ/NHfuKy8TNJbDU6dc26Z7o5l0ELfWz5QESo+w=="],
···
 
     "@atcute/microcosm": ["@atcute/microcosm@1.0.0", "", { "dependencies": { "@atcute/lexicons": "^1.2.3" } }, "sha512-XJW+TMvdktH2maTkVcNU6wKmnHpmNwhmg0Xj4ZY36plHpqNHfxR4kAAcXGSJcjH9CS8I1+cTHiyUQykdeOPeGg=="],
 
-    "@atcute/mst": ["@atcute/mst@0.1.0", "", { "dependencies": { "@atcute/cbor": "^2.2.7", "@atcute/cid": "^2.2.6", "@atcute/uint8array": "^1.0.5" } }, "sha512-h+iDToKEnBpigk2DOHjSqY63vJtjYKUIztqu1CZ0P+I54wV2SrgoqAXAT1xrW6A1Iup8cjTv+U2H5WVG4KxPLw=="],
-
     "@atcute/multibase": ["@atcute/multibase@1.1.6", "", { "dependencies": { "@atcute/uint8array": "^1.0.5" } }, "sha512-HBxuCgYLKPPxETV0Rot4VP9e24vKl8JdzGCZOVsDaOXJgbRZoRIF67Lp0H/OgnJeH/Xpva8Z5ReoTNJE5dn3kg=="],
-
-    "@atcute/repo": ["@atcute/repo@0.1.0", "", { "dependencies": { "@atcute/car": "^5.0.0", "@atcute/cbor": "^2.2.7", "@atcute/cid": "^2.2.6", "@atcute/crypto": "^2.2.5", "@atcute/lexicons": "^1.2.2", "@atcute/mst": "^0.1.0", "@atcute/uint8array": "^1.0.5" } }, "sha512-INiYAuma8dydBu7cqd2WVpcXh3mzhIepYBUqFWAK5MqMulPRLTRCc/9GW3G9pxYrOdlvLCVamG2Jf8XK0nuFEw=="],
 
     "@atcute/tid": ["@atcute/tid@1.0.3", "", {}, "sha512-wfMJx1IMdnu0CZgWl0uR4JO2s6PGT1YPhpytD4ZHzEYKKQVuqV6Eb/7vieaVo1eYNMp2FrY67FZObeR7utRl2w=="],
 
     "@atcute/uint8array": ["@atcute/uint8array@1.0.5", "", {}, "sha512-XLWWxoR2HNl2qU+FCr0rp1APwJXci7HnzbOQLxK55OaMNBXZ19+xNC5ii4QCsThsDxa4JS/JTzuiQLziITWf2Q=="],
-
-    "@atcute/varint": ["@atcute/varint@1.0.3", "", {}, "sha512-fdvMPyBB+McDT+Ai5e9RwEbwYV4yjZ60S2Dn5PTjGqUyxvoCH1z42viuheDZRUDkmfQehXJTZ5az7dSozVNtog=="],
 
     "@babel/generator": ["@babel/generator@7.28.5", "", { "dependencies": { "@babel/parser": "^7.28.5", "@babel/types": "^7.28.5", "@jridgewell/gen-mapping": "^0.3.12", "@jridgewell/trace-mapping": "^0.3.28", "jsesc": "^3.0.2" } }, "sha512-3EwLFhZ38J4VyIP6WNtt2kUdW9dokXA9Cr4IVIFHuCpZ3H8/YFOl5JjZHisrn1fATPBmKKqXzDFvh9fUwHz6CQ=="],
 
···
     "@napi-rs/keyring-win32-x64-msvc": ["@napi-rs/keyring-win32-x64-msvc@1.2.0", "", { "os": "win32", "cpu": "x64" }, "sha512-xFlx/TsmqmCwNU9v+AVnEJgoEAlBYgzFF5Ihz1rMpPAt4qQWWkMd4sCyM1gMJ1A/GnRqRegDiQpwaxGUHFtFbA=="],
 
     "@napi-rs/wasm-runtime": ["@napi-rs/wasm-runtime@1.0.7", "", { "dependencies": { "@emnapi/core": "^1.5.0", "@emnapi/runtime": "^1.5.0", "@tybys/wasm-util": "^0.10.1" } }, "sha512-SeDnOO0Tk7Okiq6DbXmmBODgOAb9dp9gjlphokTUxmt8U3liIP1ZsozBahH69j/RJv+Rfs6IwUKHTgQYJ/HBAw=="],
-
-    "@noble/secp256k1": ["@noble/secp256k1@3.0.0", "", {}, "sha512-NJBaR352KyIvj3t6sgT/+7xrNyF9Xk9QlLSIqUGVUYlsnDTAUqY8LOmwpcgEx4AMJXRITQ5XEVHD+mMaPfr3mg=="],
 
     "@oxc-project/runtime": ["@oxc-project/runtime@0.97.0", "", {}, "sha512-yH0zw7z+jEws4dZ4IUKoix5Lh3yhqIJWF9Dc8PWvhpo7U7O+lJrv7ZZL4BeRO0la8LBQFwcCewtLBnVV7hPe/w=="],
 

package.json

···
     "@atcute/cbor": "^2.2.7",
     "@atcute/cid": "^2.2.6",
     "@atcute/client": "^4.0.5",
-    "@atcute/repo": "^0.1.0",
     "@atcute/tid": "^1.0.3",
     "@napi-rs/keyring": "^1.2.0",
     "citty": "^0.1.6",

src/commands/sync-cmd.ts

···
 import { gatherImages, generateBlocks, replaceInAst } from "../conversion";
 import type { Blob, RecordKey, ResourceUri } from "@atcute/lexicons";
 import { glob, readFile, writeFile } from "node:fs/promises";
-import { fromStream } from "@atcute/repo";
 import * as CID from "@atcute/cid";
 import * as CBOR from "@atcute/cbor";
 import { generateDoc } from "../doc.ts";
···
       }
     }
 
-    const publications = new Map<RecordKey, string>();
     const uploadedDocuments = new Map<RecordKey, { cid: string; publishedAt?: string }>();
 
-    const carReq = await fetch(`${miniDoc.pds}/xrpc/com.atproto.sync.getRepo?did=${miniDoc.did}`);
-    await using repo = fromStream(carReq.body!);
+    let docCursor: string | undefined = undefined;
+
+    do {
+      const res = await ok(
+        client.get("com.atproto.repo.listRecords", {
+          params: {
+            collection: "pub.leaflet.document",
+            repo: miniDoc.did,
+            limit: 100,
+            cursor: docCursor,
+          },
+        })
+      );
 
-    for await (const entry of repo) {
-      if (entry.collection == "pub.leaflet.document") {
-        uploadedDocuments.set(entry.rkey, {
-          cid: entry.cid.$link,
-          publishedAt: (entry.record as PubLeafletDocument.Main).publishedAt,
+      for (const doc of res.records) {
+        uploadedDocuments.set(doc.uri.split("/").at(-1)!, {
+          cid: doc.cid,
+          publishedAt: (doc.value as PubLeafletDocument.Main).publishedAt,
         });
-      } else if (entry.collection == "pub.leaflet.publication") {
-        publications.set(entry.rkey, (entry.record as PubLeafletPublication.Main).name);
       }
-    }
 
-    repo.dispose();
+      docCursor = res.cursor;
+      if (res.records.length == 0) docCursor = undefined;
+    } while (docCursor);
 
     let publicationUri: ResourceUri;
     let publicationName: string;
 
     if (config.publicationUri) {
       const rkey = config.publicationUri.split("/").at(-1) as string;
-      if (!publications.has(rkey)) throw new Error("Could not find publication from the config.");
+
+      const res = await client.get("com.atproto.repo.getRecord", {
+        params: { collection: "pub.leaflet.publication", repo: miniDoc.did, rkey: rkey },
+      });
 
+      if (!res.ok) throw new Error("Could not find publication from the config.");
       publicationUri = config.publicationUri;
-      publicationName = publications.get(rkey)!;
+      publicationName = (res.data.value as PubLeafletPublication.Main).name;
     } else {
-      if (publications.size > 0) {
-        const publication = publications.entries().next().value!;
-        publicationUri = `at://${miniDoc.did}/pub.leaflet.publication/${publication[0]}`;
-        publicationName = publication[1];
+      const res = await ok(
+        client.get("com.atproto.repo.listRecords", {
+          params: { collection: "pub.leaflet.publication", repo: miniDoc.did, limit: 3 },
+        })
+      );
+
+      if (res.records.length > 0) {
+        if (res.records.length > 1)
+          throw new Error(
+            "There are more then 1 publications in your repo.\nPlease specify which one to use in your config."
+          );
+
+        publicationUri = `at://${miniDoc.did}/pub.leaflet.publication/${res.records[0]!.uri.split("/").at(-1)}`;
+        publicationName = (res.records[0]!.value as PubLeafletPublication.Main).name;
       } else {
         throw new Error("Could not find any publications in your repo.");
       }

tsconfig.json

···
 {
+  "$schema": "https://www.schemastore.org/tsconfig.json",
   "compilerOptions": {
     // Environment setup & latest features
     "lib": [
···
       "@atcute/atproto",
       "@atcute/microcosm",
       "@types/bun"
-    ]
+    ],
+    "noImplicitAny": false
   }
 }