Implement export cmd (bluesky-social#70)

.gitignore

@@ -9,6 +9,7 @@
 .DS_STORE
 DS_STORE
 node_modules
+yarn-error.log
 dist
 analytics.txt
 

cli/src/commands/index.ts

@@ -1,6 +1,7 @@
 import './interactions/like.js'
 import './interactions/unlike.js'
-// import './net/pull.js'
+// import './repo/pull.js'
+import './repo/export.js'
 import './posts/delete-post.js'
 import './posts/edit-post.js'
 import './posts/feed.js'

cli/src/commands/repo/export.ts

@@ -0,0 +1,20 @@
+import cmd from '../../lib/command.js'
+import path from 'path'
+import { promises as fsp } from 'fs'
+import { loadDelegate } from '../../lib/client.js'
+import { REPO_PATH } from '../../lib/env.js'
+
+export default cmd({
+  name: 'export',
+  category: 'repo',
+  help: 'Export repo as a CAR file',
+  args: [],
+  opts: [],
+  async command(args) {
+    const client = await loadDelegate(REPO_PATH)
+    const car = await client.export()
+    const p = path.join(REPO_PATH, 'export.car')
+    await fsp.writeFile(p, car)
+    console.log('Exported repo to: ', p)
+  },
+})

cli/src/commands/net/pull.ts → cli/src/commands/repo/pull.ts

@@ -2,7 +2,7 @@ import cmd from '../../lib/command.js'
 
 export default cmd({
   name: 'pull',
-  category: 'net',
+  category: 'repo',
   help: 'Pull the latest data for all followed users or for a given user.',
   args: [{ name: 'id', optional: true }],
   opts: [],

cli/src/lib/command.ts

@@ -10,7 +10,7 @@ export const registeredCommands: RegisteredCmd[] = []
 
 export const CATEGORIES = {
   setup: 'Setup',
-  net: 'Networking',
+  repo: 'Repo',
   social: 'Social',
   posts: 'Posts',
   interactions: 'Interactions',

cli/src/lib/usage.ts

@@ -32,7 +32,7 @@ export function usage(err: any) {
     cats.push({ label: CATEGORIES[category], lhs, rhs })
   }
   addcat('setup')
-  addcat('net')
+  addcat('repo')
   addcat('social')
   addcat('posts')
   addcat('interactions')

common/src/microblog/delegator.ts

@@ -425,6 +425,14 @@ export class MicroblogDelegator {
       throw new Error(err.message)
     }
   }
+
+  async export(): Promise<Uint8Array> {
+    const car = await service.pullRepo(this.url, this.did)
+    if (car === null) {
+      throw new Error(`Could not fetch repo ${this.did} from ${this.url}`)
+    }
+    return car
+  }
 }
 
 export default MicroblogDelegator