chore: updated behaviour of mkdir command

[ci skip]

Author: aryanjassal

src/secrets/CommandMkdir.ts

@@ -11,15 +11,18 @@ class CommandMkdir extends CommandPolykey {
     this.name('mkdir');
     this.description('Create a Directory within a Vault');
     this.argument(
-      '<secretPath>',
+      '<secretPath...>',
       'Path to where the directory to be created, specified as <vaultName>:<directoryPath>',
-      binParsers.parseSecretPathValue,
     );
     this.option('-r, --recursive', 'Create the directory recursively');
     this.addOption(binOptions.nodeId);
     this.addOption(binOptions.clientHost);
     this.addOption(binOptions.clientPort);
-    this.action(async (secretPath, options) => {
+    this.addOption(binOptions.recursive);
+    this.action(async (secretPaths, options) => {
+      secretPaths = secretPaths.map((path: string) =>
+        binParsers.parseSecretPathValue(path),
+      );
       const { default: PolykeyClient } = await import(
         'polykey/dist/PolykeyClient'
       );
@@ -50,16 +53,25 @@ class CommandMkdir extends CommandPolykey {
           },
           logger: this.logger.getChild(PolykeyClient.name),
         });
-        await binUtils.retryAuthentication(
-          (auth) =>
-            pkClient.rpcClient.methods.vaultsSecretsMkdir({
-              metadata: auth,
-              nameOrId: secretPath[0],
-              dirName: secretPath[1],
-              recursive: options.recursive,
-            }),
-          meta,
-        );
+        await binUtils.retryAuthentication(async (auth) => {
+          const response =
+            await pkClient.rpcClient.methods.vaultsSecretsMkdir();
+          const writer = response.writable.getWriter();
+          let first = true;
+          for (const [vault, path] of secretPaths) {
+            await writer.write({
+              nameOrId: vault,
+              dirName: path,
+              metadata: first
+                ? { ...auth, options: { recursive: options.recursive } }
+                : undefined,
+            });
+          }
+          await writer.close();
+          for await (const result of response.readable) {
+            if (result.error != null) console.error(result.error);
+          }
+        }, meta);
       } finally {
         if (pkClient! != null) await pkClient.stop();
       }