fix : added proper error handling to failure logs

src/lib/utils.ts

@@ -5,28 +5,6 @@ export function sanitizeUrlParam(param: string): string {
   return param.replace(/[;&|`$(){}[\]<>]/g, "");
 }
 
-export interface HarFile {
-  log: {
-    entries: HarEntry[];
-  };
-}
-
-export interface HarEntry {
-  startedDateTime: string;
-  request: {
-    method: string;
-    url: string;
-    queryString?: { name: string; value: string }[];
-  };
-  response: {
-    status: number;
-    statusText?: string;
-    _error?: string;
-  };
-  serverIPAddress?: string;
-  time?: number;
-}
-
 const ONE_MB = 1048576;
 
 //Compresses a base64 image intelligently to keep it under 1 MB if needed.
@@ -56,15 +34,3 @@ export async function assertOkResponse(response: Response, action: string) {
     );
   }
 }
-
-export function filterLinesByKeywords(
-  logText: string,
-  keywords: string[],
-): string[] {
-  return logText
-    .split(/\r?\n/)
-    .map((line) => line.trim())
-    .filter((line) =>
-      keywords.some((keyword) => line.toLowerCase().includes(keyword)),
-    );
-}

src/tools/failurelogs-utils/app-automate.ts

@@ -1,5 +1,9 @@
 import config from "../../config.js";
-import { assertOkResponse, filterLinesByKeywords } from "../../lib/utils.js";
+import {
+  filterLinesByKeywords,
+  validateLogResponse,
+  LogResponse,
+} from "./utils.js";
 
 const auth = Buffer.from(
   `${config.browserstackUsername}:${config.browserstackAccessKey}`,
@@ -9,7 +13,7 @@ const auth = Buffer.from(
 export async function retrieveDeviceLogs(
   sessionId: string,
   buildId: string,
-): Promise<string[]> {
+): Promise<LogResponse> {
   const url = `https://api.browserstack.com/app-automate/builds/${buildId}/sessions/${sessionId}/deviceLogs`;
 
   const response = await fetch(url, {
@@ -19,17 +23,18 @@ export async function retrieveDeviceLogs(
     },
   });
 
-  await assertOkResponse(response, "device logs");
+  const validationResult = validateLogResponse(response, "device logs");
+  if (validationResult) return validationResult;
 
   const logText = await response.text();
-  return filterDeviceFailures(logText);
+  return { logs: filterDeviceFailures(logText) };
 }
 
 // APPIUM LOGS
 export async function retrieveAppiumLogs(
   sessionId: string,
   buildId: string,
-): Promise<string[]> {
+): Promise<LogResponse> {
   const url = `https://api.browserstack.com/app-automate/builds/${buildId}/sessions/${sessionId}/appiumlogs`;
 
   const response = await fetch(url, {
@@ -39,17 +44,18 @@ export async function retrieveAppiumLogs(
     },
   });
 
-  await assertOkResponse(response, "Appium logs");
+  const validationResult = validateLogResponse(response, "Appium logs");
+  if (validationResult) return validationResult;
 
   const logText = await response.text();
-  return filterAppiumFailures(logText);
+  return { logs: filterAppiumFailures(logText) };
 }
 
 // CRASH LOGS
 export async function retrieveCrashLogs(
   sessionId: string,
   buildId: string,
-): Promise<string[]> {
+): Promise<LogResponse> {
   const url = `https://api.browserstack.com/app-automate/builds/${buildId}/sessions/${sessionId}/crashlogs`;
 
   const response = await fetch(url, {
@@ -59,14 +65,14 @@ export async function retrieveCrashLogs(
     },
   });
 
-  await assertOkResponse(response, "crash logs");
+  const validationResult = validateLogResponse(response, "crash logs");
+  if (validationResult) return validationResult;
 
   const logText = await response.text();
-  return filterCrashFailures(logText);
+  return { logs: filterCrashFailures(logText) };
 }
 
 // FILTER HELPERS
-
 export function filterDeviceFailures(logText: string): string[] {
   const keywords = [
     "error",

src/tools/failurelogs-utils/automate.ts

@@ -1,13 +1,20 @@
 import config from "../../config.js";
-import { HarEntry, HarFile } from "../../lib/utils.js";
-import { assertOkResponse, filterLinesByKeywords } from "../../lib/utils.js";
+import {
+  HarEntry,
+  HarFile,
+  filterLinesByKeywords,
+  validateLogResponse,
+  LogResponse,
+} from "./utils.js";
 
 const auth = Buffer.from(
   `${config.browserstackUsername}:${config.browserstackAccessKey}`,
 ).toString("base64");
 
 // NETWORK LOGS
-export async function retrieveNetworkFailures(sessionId: string): Promise<any> {
+export async function retrieveNetworkFailures(
+  sessionId: string,
+): Promise<LogResponse> {
   const url = `https://api.browserstack.com/automate/sessions/${sessionId}/networklogs`;
 
   const response = await fetch(url, {
@@ -18,7 +25,8 @@ export async function retrieveNetworkFailures(sessionId: string): Promise<any> {
     },
   });
 
-  await assertOkResponse(response, "network logs");
+  const validationResult = validateLogResponse(response, "network logs");
+  if (validationResult) return validationResult;
 
   const networklogs: HarFile = await response.json();
 
@@ -33,28 +41,29 @@ export async function retrieveNetworkFailures(sessionId: string): Promise<any> {
     },
   );
 
-  // Return only the failure entries with some context
-  return failureEntries.map((entry: any) => ({
-    startedDateTime: entry.startedDateTime,
-    request: {
-      method: entry.request?.method,
-      url: entry.request?.url,
-      queryString: entry.request?.queryString,
-    },
-    response: {
-      status: entry.response?.status,
-      statusText: entry.response?.statusText,
-      _error: entry.response?._error,
-    },
-    serverIPAddress: entry.serverIPAddress,
-    time: entry.time,
-  }));
+  return {
+    logs: failureEntries.map((entry: any) => ({
+      startedDateTime: entry.startedDateTime,
+      request: {
+        method: entry.request?.method,
+        url: entry.request?.url,
+        queryString: entry.request?.queryString,
+      },
+      response: {
+        status: entry.response?.status,
+        statusText: entry.response?.statusText,
+        _error: entry.response?._error,
+      },
+      serverIPAddress: entry.serverIPAddress,
+      time: entry.time,
+    })),
+  };
 }
 
 // SESSION LOGS
 export async function retrieveSessionFailures(
   sessionId: string,
-): Promise<string[]> {
+): Promise<LogResponse> {
   const url = `https://api.browserstack.com/automate/sessions/${sessionId}/logs`;
 
   const response = await fetch(url, {
@@ -64,16 +73,17 @@ export async function retrieveSessionFailures(
     },
   });
 
-  await assertOkResponse(response, "session logs");
+  const validationResult = validateLogResponse(response, "session logs");
+  if (validationResult) return validationResult;
 
   const logText = await response.text();
-  return filterSessionFailures(logText);
+  return { logs: filterSessionFailures(logText) };
 }
 
 // CONSOLE LOGS
 export async function retrieveConsoleFailures(
   sessionId: string,
-): Promise<string[]> {
+): Promise<LogResponse> {
   const url = `https://api.browserstack.com/automate/sessions/${sessionId}/consolelogs`;
 
   const response = await fetch(url, {
@@ -83,10 +93,11 @@ export async function retrieveConsoleFailures(
     },
   });
 
-  await assertOkResponse(response, "console logs");
+  const validationResult = validateLogResponse(response, "console logs");
+  if (validationResult) return validationResult;
 
   const logText = await response.text();
-  return filterConsoleFailures(logText);
+  return { logs: filterConsoleFailures(logText) };
 }
 
 // FILTER: session logs

src/tools/failurelogs-utils/utils.ts

@@ -0,0 +1,56 @@
+export interface LogResponse {
+  logs?: any[];
+  message?: string;
+}
+
+export interface HarFile {
+  log: {
+    entries: HarEntry[];
+  };
+}
+
+export interface HarEntry {
+  startedDateTime: string;
+  request: {
+    method: string;
+    url: string;
+    queryString?: { name: string; value: string }[];
+  };
+  response: {
+    status: number;
+    statusText?: string;
+    _error?: string;
+  };
+  serverIPAddress?: string;
+  time?: number;
+}
+
+export function validateLogResponse(
+  response: Response,
+  logType: string,
+): LogResponse | null {
+  if (!response.ok) {
+    if (response.status === 404) {
+      return { message: `No ${logType} available for this session` };
+    }
+    if (response.status === 401 || response.status === 403) {
+      return {
+        message: `Unable to access ${logType} - please check your credentials`,
+      };
+    }
+    return { message: `Unable to fetch ${logType} at this time` };
+  }
+  return null;
+}
+
+export function filterLinesByKeywords(
+  logText: string,
+  keywords: string[],
+): string[] {
+  return logText
+    .split(/\r?\n/)
+    .map((line) => line.trim())
+    .filter((line) =>
+      keywords.some((keyword) => line.toLowerCase().includes(keyword)),
+    );
+}