COM-1135: Fix brevo error handling

.changeset/large-mice-sort.md

@@ -0,0 +1,7 @@
+---
+"@comet/brevo-api": patch
+---
+
+Fix brevo error handling error
+
+Fix brevo error handling causing contact import to fail if contact does not exists in brevo yet

packages/api/src/brevo-api/brevo-api-contact.service.ts

@@ -75,7 +75,14 @@ export class BrevoApiContactsService {
         try {
             const idAsString = id.toString(); // brevo expects a string, because it can be an email or the id, so we have to transform the id to string
             await this.getContactsApi(scope).updateContact(idAsString, { emailBlacklisted: blocked, attributes, listIds, unlinkListIds });
-            return this.findContact(id, scope);
+
+            const brevoContact = await this.findContact(id, scope);
+
+            if (!brevoContact) {
+                throw new Error(`The brevo contact with the id ${id} not found`);
+            }
+
+            return brevoContact;
         } catch (error) {
             handleBrevoError(error);
         }
@@ -101,13 +108,18 @@ export class BrevoApiContactsService {
         }
     }
 
-    public async findContact(idOrEmail: string | number, scope: EmailCampaignScopeInterface): Promise<BrevoContactInterface> {
+    public async findContact(idOrEmail: string | number, scope: EmailCampaignScopeInterface): Promise<BrevoContactInterface | undefined> {
         try {
             const idAsString = String(idOrEmail); // brevo expects a string, because it can be an email or the id
             const { body } = await this.getContactsApi(scope).getContactInfo(idAsString);
 
             return body;
         } catch (error) {
+            // Brevo returns a 404 error if no contact is found and a 400 error if an invalid email is provided.
+            if (isErrorFromBrevo(error) && (error.response.statusCode === 404 || error.response.statusCode === 400)) {
+                return undefined;
+            }
+
             handleBrevoError(error);
         }
     }

packages/api/src/brevo-contact/brevo-contact-import.service.ts

@@ -7,7 +7,6 @@ import isEqual from "lodash.isequal";
 import { TargetGroupInterface } from "src/target-group/entity/target-group-entity.factory";
 import { Readable } from "stream";
 
-import { isErrorFromBrevo } from "../brevo-api/brevo-api.utils";
 import { BrevoApiContactsService, CreateDoubleOptInContactData } from "../brevo-api/brevo-api-contact.service";
 import { BrevoContactsService } from "../brevo-contact/brevo-contacts.service";
 import { BrevoModuleConfig } from "../config/brevo-module.config";
@@ -129,18 +128,8 @@ export class BrevoContactImportService {
         targetGroupBrevoIds: number[],
     ): Promise<"created" | "updated" | "error"> {
         try {
-            let brevoContact;
-            try {
-                brevoContact = await this.brevoApiContactsService.findContact(contact.email, scope);
-            } catch (error) {
-                if (!isErrorFromBrevo(error)) {
-                    throw error;
-                }
-                // Brevo throws 404 error if no contact was found
-                if (error.response.statusCode !== 404) {
-                    throw error;
-                }
-            }
+            const brevoContact = await this.brevoApiContactsService.findContact(contact.email, scope);
+
             const mainTargetGroupForScope = await this.targetGroupsService.createIfNotExistMainTargetGroupForScope(scope);
             if (brevoContact && !brevoContact.emailBlacklisted) {
                 const updatedBrevoContact = await this.brevoApiContactsService.updateContact(

packages/api/src/brevo-contact/brevo-contact.resolver.ts

@@ -57,7 +57,13 @@ export function createBrevoContactResolver({
             @Args("id", { type: () => Int }) id: number,
             @Args("scope", { type: () => Scope }, new DynamicDtoValidationPipe(Scope)) scope: typeof Scope,
         ): Promise<BrevoContactInterface> {
-            return this.brevoContactsApiService.findContact(id, scope);
+            const brevoContact = await this.brevoContactsApiService.findContact(id, scope);
+
+            if (!brevoContact) {
+                throw new Error(`Brevo contact with id ${id} not found`);
+            }
+
+            return brevoContact;
         }
 
         @Query(() => PaginatedBrevoContacts)

packages/api/src/target-group/target-group.resolver.ts

@@ -140,6 +140,10 @@ export function createTargetGroupsResolver({
                 throw new Error("No assigned contacts target group found");
             }
 
+            if (!brevoContact) {
+                throw new Error(`Brevo contact with id ${input.brevoContactId} not found`);
+            }
+
             const contactIsInTargetGroupByAttributes = this.targetGroupsService.checkIfContactIsInTargetGroup(
                 brevoContact.attributes,
                 targetGroup.filters,