fix(*): fixed issues

ballerine-io · Nov 21, 2024 · ba28ff0 · ba28ff0
1 parent 0992cac
commit ba28ff0
Show file tree

Hide file tree

Showing 7 changed files with 75 additions and 87 deletions.
diff --git a/apps/backoffice-v2/src/common/utils/fetcher/fetcher.ts b/apps/backoffice-v2/src/common/utils/fetcher/fetcher.ts
@@ -69,7 +69,7 @@ export const fetcher: IFetcher = async ({
       return await handlePromise(res.blob());
     }
 
-    if (!res.headers.get('content-length') || res.headers.get('content-length') > '0') {
+    if (!res.headers.get('content-length') || Number(res.headers.get('content-length')) > 0) {
       // TODO: make sure its json by checking the content-type in order to safe access to json method
       return await handlePromise(res.json());
     }

diff --git a/packages/ui/package.json b/packages/ui/package.json
@@ -62,7 +62,7 @@
     "react-phone-input-2": "^2.15.1",
     "string-ts": "^1.2.0",
     "tailwind-merge": "^1.10.0",
-    "zod": "^3.22.4"
+    "zod": "^3.23.4"
   },
   "devDependencies": {
     "@ballerine/config": "^1.1.24",

diff --git a/packages/workflow-core/src/lib/plugins/external-plugin/api-plugin.ts b/packages/workflow-core/src/lib/plugins/external-plugin/api-plugin.ts
@@ -159,6 +159,7 @@ export class ApiPlugin {
     ok: boolean;
     json: () => Promise<unknown>;
     statusText: string;
+    headers: Headers;
   }> {
     let _url: string = url;
 
@@ -189,6 +190,7 @@ export class ApiPlugin {
         ok: true,
         json: () => Promise.resolve({ statusCode: res.status }),
         statusText: 'OK',
+        headers: res.headers,
       };
     }
 

diff --git a/...lugins/external-plugin/individuals-sanctions-v2-plugin/individuals-sanctions-v2-plugin.ts b/...lugins/external-plugin/individuals-sanctions-v2-plugin/individuals-sanctions-v2-plugin.ts
@@ -281,14 +281,21 @@ export class IndividualsSanctionsV2Plugin extends ApiPlugin {
 
       const apiResponse = await this.makeApiRequest(url, this.method, requestPayload, {
         ...this.headers,
-        Authorization: `Bearer ${process.env.UNIFIED_API_TOKEN}`,
+        Authorization: `Bearer ${env.UNIFIED_API_TOKEN}`,
       });
 
       logger.log('Individuals Sanctions V2 Plugin - Received response', {
         status: apiResponse.statusText,
         url,
       });
 
+      const contentLength = apiResponse.headers.get('content-length');
+
+      invariant(
+        !contentLength || Number(contentLength) > 0,
+        'Individuals Sanctions V2 Plugin - Received an empty response',
+      );
+
       if (!apiResponse.ok) {
         const errorResponse = await apiResponse.json();
 

diff --git a/pnpm-lock.yaml b/pnpm-lock.yaml
diff --git a/services/workflows-service/src/common/app-logger/app-logger.service.ts b/services/workflows-service/src/common/app-logger/app-logger.service.ts
@@ -27,9 +27,15 @@ export class AppLoggerService implements LoggerService, OnModuleDestroy {
 
   error(error: unknown, logData: LogPayload = {}) {
     const payload: any = { ...this.getLogMetadata(), logData };
+    const STACK_FRAMES_TO_REMOVE = 1;
 
     if (typeof error === 'string') {
-      payload.stack = new Error().stack;
+      const stack = new Error().stack;
+      const stackFrames = stack?.split('\n');
+
+      stackFrames?.splice(1, STACK_FRAMES_TO_REMOVE);
+
+      payload.stack = stackFrames ? stackFrames.join('\n') : stack;
     }
 
     this.logger.error(error, payload);

diff --git a/services/workflows-service/src/customer/customer.service.ts b/services/workflows-service/src/customer/customer.service.ts
@@ -50,6 +50,10 @@ export class CustomerService {
     return (await this.repository.findById(id, args)) as unknown as TCustomerWithFeatures;
   }
 
+  async getByName(name: string, args?: Parameters<CustomerRepository['findById']>[1]) {
+    return (await this.repository.findByName(name, args)) as unknown as TCustomerWithFeatures;
+  }
+
   async getByProjectId(projectId: string, args?: Omit<Prisma.CustomerFindFirstArgsBase, 'where'>) {
     return (await this.repository.findByProjectId(
       projectId,