chore: added error handling for invalid patterns

src/client/errors.ts

@@ -18,6 +18,11 @@ class ErrorClientAuthDenied<T> extends ErrorClient<T> {
   exitCode = sysexits.NOPERM;
 }
 
+class ErrorClientFileReadFailed<T> extends ErrorClient<T> {
+  static description = 'Failed to read file or directory';
+  exitCode = sysexits.IOERR;
+}
+
 class ErrorClientService<T> extends ErrorClient<T> {}
 
 class ErrorClientServiceRunning<T> extends ErrorClientService<T> {
@@ -45,6 +50,7 @@ export {
   ErrorClientAuthMissing,
   ErrorClientAuthFormat,
   ErrorClientAuthDenied,
+  ErrorClientFileReadFailed,
   ErrorClientService,
   ErrorClientServiceRunning,
   ErrorClientServiceNotRunning,

src/client/handlers/VaultsSecretsGetFileTree.ts

@@ -7,6 +7,7 @@ import { ServerHandler } from '@matrixai/rpc';
 import { generateStats } from '../../vaults/fileTree';
 import * as vaultsUtils from '../../vaults/utils';
 import * as vaultsErrors from '../../vaults/errors';
+import * as clientErrors from '../errors';
 
 class VaultsSecretsGetFileTree extends ServerHandler<
   {
@@ -38,18 +39,32 @@ class VaultsSecretsGetFileTree extends ServerHandler<
         void,
         void
       > {
-        // @ts-ignore: While the types don't fully match, it matches enough for our usage.
-        let files: Array<string> = await fs.promises.readdir(input.pattern);
-        files = files.map((file) => path.join(input.pattern, file));
+        try {
+          // @ts-ignore: While the types don't fully match, it matches enough for our usage.
+          let files: Array<string> = await fs.promises.readdir(input.pattern);
+          files = files.map((file) => path.join(input.pattern, file));
 
-        for await (const file of files) {
-          const stat = await fs.promises.stat(file);
-          const type = stat.isFile() ? 'FILE' : 'DIRECTORY';
-          yield {
-            path: file,
-            type: type,
-            stat: input.yieldStats ? generateStats(stat) : undefined,
-          };
+          for await (const file of files) {
+            try {
+              const stat = await fs.promises.stat(file);
+              const type = stat.isFile() ? 'FILE' : 'DIRECTORY';
+              yield {
+                path: file,
+                type: type,
+                stat: input.yieldStats ? generateStats(stat) : undefined,
+              };
+            } catch (e) {
+              throw new clientErrors.ErrorClientFileReadFailed(
+                `Failed to read file: ${file}`,
+                { cause: e },
+              );
+            }
+          }
+        } catch (e) {
+          throw new clientErrors.ErrorClientFileReadFailed(
+            `Failed to read directory: ${input.pattern}`,
+            { cause: e },
+          );
         }
       });
     });

tests/client/handlers/vaults.test.ts

@@ -69,6 +69,7 @@ import * as nodesUtils from '@/nodes/utils';
 import * as vaultsUtils from '@/vaults/utils';
 import * as vaultsErrors from '@/vaults/errors';
 import * as networkUtils from '@/network/utils';
+import * as clientErrors from '@/client/errors';
 import * as testsUtils from '../../utils';
 
 describe('vaultsClone', () => {
@@ -1588,6 +1589,20 @@ describe('vaultsSecretsNewDir and vaultsSecretsList', () => {
     });
     expect(addResponse.success).toBeTruthy();
 
+    expect(async () => {
+      const files = await rpcClient.methods.vaultsSecretsGetFileTree({
+        nameOrId: vaultsIdEncoded,
+        pattern: 'doesntExist',
+        yieldStats: false,
+      });
+      try {
+        for await (const _ of files); // Consume values
+      }
+      catch (e) {
+        throw e.cause;
+      }
+    }).rejects.toThrow(clientErrors.ErrorClientFileReadFailed);
+
     // List secrets with names of directories
     const secrets = await rpcClient.methods.vaultsSecretsGetFileTree({
       nameOrId: vaultsIdEncoded,