From e65fc0134f868cdd64854186e9e523e665620a28 Mon Sep 17 00:00:00 2001
From: dzdidi <deniszalessky@gmail.com>
Date: Tue, 6 Feb 2024 13:38:35 +0000
Subject: [PATCH] cli for getting list of repos

Signed-off-by: dzdidi <deniszalessky@gmail.com>
---
 src/cli.js         |  7 ++++--
 src/list-remote.js | 53 ++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 58 insertions(+), 2 deletions(-)
 create mode 100644 src/list-remote.js

diff --git a/src/cli.js b/src/cli.js
index 4a5361b..7044267 100755
--- a/src/cli.js
+++ b/src/cli.js
@@ -224,10 +224,13 @@ program
 program
   .command('list')
   .description('list all gitpear repos')
+  .addArgument(new commander.Argument('[u]', 'url to remote pear').default(''))
   .option('-s, --shared', 'list only shared repos')
-  .action((p, options) => {
+  .action((u, options) => {
+    if (u) return require('./list-remote')(u)
+
     const k = home.readPk()
-    const s = options.opts().shared
+    const s = options.shared
     home.list(s).forEach(n => console.log(n, ...(s ? ['\t', `pear://${k}/${n}`] : [])))
   })
 
diff --git a/src/list-remote.js b/src/list-remote.js
new file mode 100644
index 0000000..576fadb
--- /dev/null
+++ b/src/list-remote.js
@@ -0,0 +1,53 @@
+const ProtomuxRPC = require('protomux-rpc')
+
+const Hyperswarm = require('hyperswarm')
+const crypto = require('hypercore-crypto')
+
+const home = require('./home')
+const auth = require('./auth')
+
+module.exports = async function listRemote (url) {
+  const matches = url.match(/pear:\/\/([a-f0-9]{64})/)
+
+  if (!matches || matches.length < 2) {
+    console.error('Invalid URL')
+    process.exit(1)
+  }
+
+  const targetKey = matches[1]
+  console.log('Connecting to:', targetKey)
+
+  const swarmOpts = {}
+  if (process.env.GIT_PEAR_AUTH && process.env.GIT_PEAR_AUTH !== 'native') {
+    swarmOpts.keyPair = home.getKeyPair()
+  }
+  const swarm = new Hyperswarm(swarmOpts)
+
+  swarm.join(crypto.discoveryKey(Buffer.from(targetKey, 'hex')), { server: false })
+
+  swarm.on('connection', async (socket) => {
+    const rpc = new ProtomuxRPC(socket)
+
+    let payload = { body: { url, method: 'get-repos' } }
+    if (process.env.GIT_PEAR_AUTH && process.env.GIT_PEAR_AUTH !== 'native') {
+      payload.header = await auth.getToken(payload.body)
+      console.debug('Retreiving data using authenticated access')
+    } else {
+      console.debug('Retreiving data using un-authenticated access')
+    }
+    console.log()
+
+    const reposRes = await rpc.request('get-repos', Buffer.from(JSON.stringify(payload)))
+    const repositories = JSON.parse(reposRes.toString())
+    if (!repositories) {
+      console.error('Failed to retrieve repositories')
+      process.exit(1)
+    }
+
+    console.log('Repositories:', '\t', 'HEAD')
+    for (const repo in repositories) {
+      console.log(repo, '\t', repositories[repo])
+    }
+    process.exit(0)
+  })
+}