feat: adding secrets remove handler

feat: deleted old secrets delete handlers

feat: added tests

feat: performed requested changes

chore: added more tests for vaultOps.deleteSecret

fix: case

src/client/callers/index.ts

@@ -63,7 +63,6 @@ import vaultsPermissionUnset from './vaultsPermissionUnset';
 import vaultsPull from './vaultsPull';
 import vaultsRename from './vaultsRename';
 import vaultsScan from './vaultsScan';
-import vaultsSecretsDelete from './vaultsSecretsDelete';
 import vaultsSecretsEdit from './vaultsSecretsEdit';
 import vaultsSecretsEnv from './vaultsSecretsEnv';
 import vaultsSecretsGet from './vaultsSecretsGet';
@@ -72,6 +71,7 @@ import vaultsSecretsMkdir from './vaultsSecretsMkdir';
 import vaultsSecretsNew from './vaultsSecretsNew';
 import vaultsSecretsNewDir from './vaultsSecretsNewDir';
 import vaultsSecretsRename from './vaultsSecretsRename';
+import vaultsSecretsRemove from './vaultsSecretsRemove';
 import vaultsSecretsStat from './vaultsSecretsStat';
 import vaultsVersion from './vaultsVersion';
 
@@ -144,7 +144,6 @@ const clientManifest = {
   vaultsPull,
   vaultsRename,
   vaultsScan,
-  vaultsSecretsDelete,
   vaultsSecretsEdit,
   vaultsSecretsEnv,
   vaultsSecretsGet,
@@ -153,6 +152,7 @@ const clientManifest = {
   vaultsSecretsNew,
   vaultsSecretsNewDir,
   vaultsSecretsRename,
+  vaultsSecretsRemove,
   vaultsSecretsStat,
   vaultsVersion,
 };
@@ -224,7 +224,6 @@ export {
   vaultsPull,
   vaultsRename,
   vaultsScan,
-  vaultsSecretsDelete,
   vaultsSecretsEdit,
   vaultsSecretsEnv,
   vaultsSecretsGet,
@@ -233,6 +232,7 @@ export {
   vaultsSecretsNew,
   vaultsSecretsNewDir,
   vaultsSecretsRename,
+  vaultsSecretsRemove,
   vaultsSecretsStat,
   vaultsVersion,
 };

src/client/callers/vaultsSecretsRemove.ts

@@ -0,0 +1,12 @@
+import type { HandlerTypes } from '@matrixai/rpc';
+import type VaultsSecretsRemove from '../handlers/VaultsSecretsRemove';
+import { UnaryCaller } from '@matrixai/rpc';
+
+type CallerTypes = HandlerTypes<VaultsSecretsRemove>;
+
+const vaultsSecretsRemove = new UnaryCaller<
+  CallerTypes['input'],
+  CallerTypes['output']
+>();
+
+export default vaultsSecretsRemove;

src/client/handlers/VaultsSecretsDelete.ts → src/client/handlers/VaultsSecretsRemove.ts

@@ -2,25 +2,25 @@ import type { DB } from '@matrixai/db';
 import type {
   ClientRPCRequestParams,
   ClientRPCResponseResult,
-  SecretIdentifierMessage,
   SuccessMessage,
+  SecretRemoveMessage,
 } from '../types';
 import type VaultManager from '../../vaults/VaultManager';
 import { UnaryHandler } from '@matrixai/rpc';
 import * as vaultsUtils from '../../vaults/utils';
 import * as vaultsErrors from '../../vaults/errors';
 import * as vaultOps from '../../vaults/VaultOps';
 
-class VaultsSecretsDelete extends UnaryHandler<
+class VaultsSecretsRemove extends UnaryHandler<
   {
     vaultManager: VaultManager;
     db: DB;
   },
-  ClientRPCRequestParams<SecretIdentifierMessage>,
+  ClientRPCRequestParams<SecretRemoveMessage>,
   ClientRPCResponseResult<SuccessMessage>
 > {
   public handle = async (
-    input: ClientRPCRequestParams<SecretIdentifierMessage>,
+    input: ClientRPCRequestParams<SecretRemoveMessage>,
   ): Promise<ClientRPCResponseResult<SuccessMessage>> => {
     const { vaultManager, db } = this.container;
     await db.withTransactionF(async (tran) => {
@@ -30,21 +30,20 @@ class VaultsSecretsDelete extends UnaryHandler<
       );
       const vaultId =
         vaultIdFromName ?? vaultsUtils.decodeVaultId(input.nameOrId);
-      if (vaultId == null) {
-        throw new vaultsErrors.ErrorVaultsVaultUndefined();
-      }
+      if (vaultId == null) throw new vaultsErrors.ErrorVaultsVaultUndefined();
       await vaultManager.withVaults(
         [vaultId],
         async (vault) => {
-          await vaultOps.deleteSecret(vault, input.secretName);
+          await vaultOps.deleteSecret(vault, input.secretNames, {
+            recursive: input.options?.recursive,
+          });
         },
         tran,
       );
     });
-    return {
-      success: true,
-    };
+
+    return { success: true };
   };
 }
 
-export default VaultsSecretsDelete;
+export default VaultsSecretsRemove;

src/client/handlers/index.ts

@@ -80,7 +80,6 @@ import VaultsPermissionUnset from './VaultsPermissionUnset';
 import VaultsPull from './VaultsPull';
 import VaultsRename from './VaultsRename';
 import VaultsScan from './VaultsScan';
-import VaultsSecretsDelete from './VaultsSecretsDelete';
 import VaultsSecretsEdit from './VaultsSecretsEdit';
 import VaultsSecretsEnv from './VaultsSecretsEnv';
 import VaultsSecretsGet from './VaultsSecretsGet';
@@ -89,6 +88,7 @@ import VaultsSecretsMkdir from './VaultsSecretsMkdir';
 import VaultsSecretsNew from './VaultsSecretsNew';
 import VaultsSecretsNewDir from './VaultsSecretsNewDir';
 import VaultsSecretsRename from './VaultsSecretsRename';
+import VaultsSecretsRemove from './VaultsSecretsRemove';
 import VaultsSecretsStat from './VaultsSecretsStat';
 import VaultsVersion from './VaultsVersion';
 
@@ -184,7 +184,6 @@ const serverManifest = (container: {
     vaultsPull: new VaultsPull(container),
     vaultsRename: new VaultsRename(container),
     vaultsScan: new VaultsScan(container),
-    vaultsSecretsDelete: new VaultsSecretsDelete(container),
     vaultsSecretsEdit: new VaultsSecretsEdit(container),
     vaultsSecretsEnv: new VaultsSecretsEnv(container),
     vaultsSecretsGet: new VaultsSecretsGet(container),
@@ -193,6 +192,7 @@ const serverManifest = (container: {
     vaultsSecretsNew: new VaultsSecretsNew(container),
     vaultsSecretsNewDir: new VaultsSecretsNewDir(container),
     vaultsSecretsRename: new VaultsSecretsRename(container),
+    vaultsSecretsRemove: new VaultsSecretsRemove(container),
     vaultsSecretsStat: new VaultsSecretsStat(container),
     vaultsVersion: new VaultsVersion(container),
   };
@@ -266,7 +266,6 @@ export {
   VaultsPull,
   VaultsRename,
   VaultsScan,
-  VaultsSecretsDelete,
   VaultsSecretsEdit,
   VaultsSecretsEnv,
   VaultsSecretsGet,
@@ -275,6 +274,7 @@ export {
   VaultsSecretsNew,
   VaultsSecretsNewDir,
   VaultsSecretsRename,
+  VaultsSecretsRemove,
   VaultsSecretsStat,
   VaultsVersion,
 };

src/client/types.ts

@@ -306,6 +306,13 @@ type SecretPathMessage = {
 
 type SecretIdentifierMessage = VaultIdentifierMessage & SecretPathMessage;
 
+type SecretRemoveMessage = VaultIdentifierMessage & {
+  secretNames: Array<string>;
+  options?: {
+    recursive?: boolean;
+  };
+};
+
 // Contains binary content as a binary string 'toString('binary')'
 type ContentMessage = {
   secretContent: string;
@@ -416,6 +423,7 @@ export type {
   VaultsLatestVersionMessage,
   SecretPathMessage,
   SecretIdentifierMessage,
+  SecretRemoveMessage,
   ContentMessage,
   SecretContentMessage,
   SecretMkdirMessage,

src/vaults/VaultOps.ts

@@ -129,37 +129,39 @@ async function statSecret(vault: Vault, secretName: string): Promise<Stat> {
  */
 async function deleteSecret(
   vault: Vault,
-  secretName: string,
+  secretNames: Array<string>,
   fileOptions?: FileOptions,
   logger?: Logger,
 ): Promise<void> {
-  try {
-    await vault.writeF(async (efs) => {
-      const stat = await efs.stat(secretName);
-      if (stat.isDirectory()) {
-        await efs.rmdir(secretName, fileOptions);
-        logger?.info(`Deleted directory at '${secretName}'`);
-      } else {
-        // Remove the specified file
-        await efs.unlink(secretName);
-        logger?.info(`Deleted secret at '${secretName}'`);
+  await vault.writeF(async (efs) => {
+    for (const secretName of secretNames) {
+      try {
+        const stat = await efs.stat(secretName);
+        if (stat.isDirectory()) {
+          await efs.rmdir(secretName, fileOptions);
+          logger?.info(`Deleted directory at '${secretName}'`);
+        } else {
+          // Remove the specified file
+          await efs.unlink(secretName);
+          logger?.info(`Deleted secret at '${secretName}'`);
+        }
+      } catch (e) {
+        if (e.code === 'ENOENT') {
+          throw new vaultsErrors.ErrorSecretsSecretUndefined(
+            `Secret with name: ${secretName} does not exist`,
+            { cause: e },
+          );
+        }
+        if (e.code === 'ENOTEMPTY') {
+          throw new vaultsErrors.ErrorVaultsRecursive(
+            `Could not delete directory '${secretName}' without recursive option`,
+            { cause: e },
+          );
+        }
+        throw e;
       }
-    });
-  } catch (e) {
-    if (e.code === 'ENOENT') {
-      throw new vaultsErrors.ErrorSecretsSecretUndefined(
-        `Secret with name: ${secretName} does not exist`,
-        { cause: e },
-      );
-    }
-    if (e.code === 'ENOTEMPTY') {
-      throw new vaultsErrors.ErrorVaultsRecursive(
-        `Could not delete directory '${secretName}' without recursive option`,
-        { cause: e },
-      );
     }
-    throw e;
-  }
+  });
 }
 
 /**