From fdda247120def9173a8a65be444db7c49600f240 Mon Sep 17 00:00:00 2001
From: Akhil Mohan <akhilmhdh@gmail.com>
Date: Fri, 3 May 2024 17:51:02 +0530
Subject: [PATCH] feat: added a catch and override error message for ping check

---
 .../audit-log-stream-service.ts               | 26 +++++++++++--------
 1 file changed, 15 insertions(+), 11 deletions(-)

diff --git a/backend/src/ee/services/audit-log-stream/audit-log-stream-service.ts b/backend/src/ee/services/audit-log-stream/audit-log-stream-service.ts
index b82ce04ae..0e313b59b 100644
--- a/backend/src/ee/services/audit-log-stream/audit-log-stream-service.ts
+++ b/backend/src/ee/services/audit-log-stream/audit-log-stream-service.ts
@@ -140,17 +140,21 @@ export const auditLogStreamServiceFactory = ({
         streamHeaders[key] = value;
       });
 
-    await request.post(
-      url || logStream.url,
-      { ping: "ok" },
-      {
-        headers: streamHeaders,
-        // request timeout
-        timeout: AUDIT_LOG_STREAM_TIMEOUT,
-        // connection timeout
-        signal: AbortSignal.timeout(AUDIT_LOG_STREAM_TIMEOUT)
-      }
-    );
+    await request
+      .post(
+        url || logStream.url,
+        { ping: "ok" },
+        {
+          headers: streamHeaders,
+          // request timeout
+          timeout: AUDIT_LOG_STREAM_TIMEOUT,
+          // connection timeout
+          signal: AbortSignal.timeout(AUDIT_LOG_STREAM_TIMEOUT)
+        }
+      )
+      .catch((err) => {
+        throw new Error(`Failed to connect with the source ${(err as Error)?.message}`);
+      });
 
     const encryptedHeaders = headers ? infisicalSymmetricEncypt(JSON.stringify(headers)) : undefined;
     const updatedLogStream = await auditLogStreamDAL.updateById(id, {