Fixes pull profile to only pull files for the specified data silo

package.json

@@ -2,7 +2,7 @@
   "author": "Transcend Inc.",
   "name": "@transcend-io/cli",
   "description": "Small package containing useful typescript utilities.",
-  "version": "6.13.0",
+  "version": "6.13.1",
   "homepage": "https://github.com/transcend-io/cli",
   "repository": {
     "type": "git",

src/cli-cron-pull-profiles.ts

@@ -131,16 +131,26 @@ async function main(): Promise<void> {
   const results = await map(
     uniq(requestIds),
     async (requestId) => {
-      const results = await fetchRequestFilesForRequest(client, { requestId });
-      return results.map(({ fileName, remoteId }) => ({
-        RecordId: remoteId,
-        Object: fileName
-          .replace('.json', '')
-          .split('/')
-          .pop()
-          ?.replace(' Information', ''),
-        Comment: 'Customer data deletion request submitted via transcend.io',
-      }));
+      const results = await fetchRequestFilesForRequest(client, {
+        requestId,
+        dataSiloId: targetDataSiloId,
+      });
+      return results.map(({ fileName, remoteId }) => {
+        if (!remoteId) {
+          throw new Error(
+            `Failed to find remoteId for ${fileName} request: ${requestId}`,
+          );
+        }
+        return {
+          RecordId: remoteId,
+          Object: fileName
+            .replace('.json', '')
+            .split('/')
+            .pop()
+            ?.replace(' Information', ''),
+          Comment: 'Customer data deletion request submitted via transcend.io',
+        };
+      });
     },
     {
       concurrency: 10,

src/graphql/fetchRequestFilesForRequest.ts

@@ -23,6 +23,8 @@ export async function fetchRequestFilesForRequest(
   filterBy: {
     /** Filter by request ID */
     requestId: string;
+    /** Filter by data silo ID */
+    dataSiloId?: string;
   },
 ): Promise<RequestFile[]> {
   const requestFiles: RequestFile[] = [];