Merge pull request #1 from ruturaj-browserstack/main

Sync with Develop

Author: ruturaj-browserstack

.github/workflows/mcp-ci.yml

@@ -4,7 +4,6 @@ on:
   pull_request_review:
     types: [submitted]
 
-
 jobs:
   test:
     if: github.event.pull_request.base.ref == 'main' && github.event.review.state == 'approved'

jest.config.js

@@ -2,17 +2,18 @@
 
 import { McpServer } from "@modelcontextprotocol/sdk/server/mcp.js";
 import { StdioServerTransport } from "@modelcontextprotocol/sdk/server/stdio.js";
-import packageJson from "../package.json";
+import packageJson from "../package.json" with { type: "json" };
 import "dotenv/config";
-import logger from "./logger";
-import addSDKTools from "./tools/bstack-sdk";
-import addAppLiveTools from "./tools/applive";
-import addObservabilityTools from "./tools/observability";
-import addBrowserLiveTools from "./tools/live";
-import addAccessibilityTools from "./tools/accessibility";
-import addAutomateTools from "./tools/automate";
-import addTestManagementTools from "./tools/testmanagement";
-import { trackMCP } from "./lib/instrumentation";
+import logger from "./logger.js";
+import addSDKTools from "./tools/bstack-sdk.js";
+import addAppLiveTools from "./tools/applive.js";
+import addObservabilityTools from "./tools/observability.js";
+import addBrowserLiveTools from "./tools/live.js";
+import addAccessibilityTools from "./tools/accessibility.js";
+import addAutomateTools from "./tools/automate.js";
+import addTestManagementTools from "./tools/testmanagement.js";
+import addAppAutomationTools from "./tools/appautomate.js";
+import { trackMCP } from "./lib/instrumentation.js";
 
 function registerTools(server: McpServer) {
   addSDKTools(server);
@@ -22,6 +23,7 @@ function registerTools(server: McpServer) {
   addAccessibilityTools(server);
   addAutomateTools(server);
   addTestManagementTools(server);
+  addAppAutomationTools(server);
 }
 
 // Create an MCP server

src/index.ts

@@ -1,5 +1,5 @@
-import config from "../config";
-import { HarEntry, HarFile } from "./utils";
+import config from "../config.js";
+import { HarEntry, HarFile } from "./utils.js";
 
 export async function getLatestO11YBuildInfo(
   buildName: string,

src/lib/api.ts

@@ -6,17 +6,26 @@ const CACHE_DIR = path.join(os.homedir(), ".browserstack", "combined_cache");
 const CACHE_FILE = path.join(CACHE_DIR, "data.json");
 const TTL_MS = 24 * 60 * 60 * 1000; // 1 day
 
-const URLS = {
-  live: "https://www.browserstack.com/list-of-browsers-and-platforms/live.json",
-  app_live:
+export enum BrowserStackProducts {
+  LIVE = "live",
+  APP_LIVE = "app_live",
+  APP_AUTOMATE = "app_automate",
+}
+
+const URLS: Record<BrowserStackProducts, string> = {
+  [BrowserStackProducts.LIVE]:
+    "https://www.browserstack.com/list-of-browsers-and-platforms/live.json",
+  [BrowserStackProducts.APP_LIVE]:
     "https://www.browserstack.com/list-of-browsers-and-platforms/app_live.json",
+  [BrowserStackProducts.APP_AUTOMATE]:
+    "https://www.browserstack.com/list-of-browsers-and-platforms/app_automate.json",
 };
 
 /**
- * Fetches and caches both BrowserStack datasets (live + app_live) with a shared TTL.
+ * Fetches and caches BrowserStack datasets (live + app_live + app_automate) with a shared TTL.
  */
 export async function getDevicesAndBrowsers(
-  type: "live" | "app_live",
+  type: BrowserStackProducts,
 ): Promise<any> {
   if (!fs.existsSync(CACHE_DIR)) {
     fs.mkdirSync(CACHE_DIR, { recursive: true });
@@ -29,31 +38,29 @@ export async function getDevicesAndBrowsers(
     if (Date.now() - stats.mtimeMs < TTL_MS) {
       try {
         cache = JSON.parse(fs.readFileSync(CACHE_FILE, "utf8"));
-        return cache[type];
+        if (cache[type]) {
+          return cache[type];
+        }
       } catch (error) {
         console.error("Error parsing cache file:", error);
         // Continue with fetching fresh data
       }
     }
   }
 
-  const [liveRes, appLiveRes] = await Promise.all([
-    fetch(URLS.live),
-    fetch(URLS.app_live),
-  ]);
+  const liveRes = await fetch(URLS[type]);
 
-  if (!liveRes.ok || !appLiveRes.ok) {
+  if (!liveRes.ok) {
     throw new Error(
-      `Failed to fetch configuration from BrowserStack : live=${liveRes.statusText}, app_live=${appLiveRes.statusText}`,
+      `Failed to fetch configuration from BrowserStack : ${type}=${liveRes.statusText}`,
     );
   }
 
-  const [liveData, appLiveData] = await Promise.all([
-    liveRes.json(),
-    appLiveRes.json(),
-  ]);
+  const data = await liveRes.json();
 
-  cache = { live: liveData, app_live: appLiveData };
+  cache = {
+    [type]: data,
+  };
   fs.writeFileSync(CACHE_FILE, JSON.stringify(cache), "utf8");
 
   return cache[type];

src/lib/device-cache.ts

@@ -1,6 +1,6 @@
-import logger from "../logger";
-import config from "../config";
-import packageJson from "../../package.json";
+import logger from "../logger.js";
+import config from "../config.js";
+import packageJson from "../../package.json" with { type: "json" };
 import axios from "axios";
 
 interface MCPEventPayload {

src/lib/instrumentation.ts

@@ -1,7 +1,7 @@
-import logger from "../logger";
+import logger from "../logger.js";
 import { execSync } from "child_process";
 import { Local } from "browserstack-local";
-import config from "../config";
+import config from "../config.js";
 
 async function isBrowserStackLocalRunning() {
   // Check if BrowserStackLocal binary is already running

src/lib/local.ts

@@ -1,3 +1,5 @@
+import sharp from "sharp";
+
 export function sanitizeUrlParam(param: string): string {
   // Remove any characters that could be used for command injection
   return param.replace(/[;&|`$(){}[\]<>]/g, "");
@@ -24,3 +26,22 @@ export interface HarEntry {
   serverIPAddress?: string;
   time?: number;
 }
+
+/**
+ * Compresses a base64 image intelligently to keep it under 1 MB if needed.
+ */
+export async function maybeCompressBase64(base64: string): Promise<string> {
+  const buffer = Buffer.from(base64, "base64");
+
+  if (buffer.length <= 1048576) {
+    return base64;
+  }
+
+  const sizeRatio = 1048576 / buffer.length;
+  const estimatedQuality = Math.floor(sizeRatio * 100);
+  const quality = Math.min(95, Math.max(30, estimatedQuality));
+
+  const compressedBuffer = await sharp(buffer).png({ quality }).toBuffer();
+
+  return compressedBuffer.toString("base64");
+}

src/lib/utils.ts

@@ -1,4 +1,4 @@
-import pino from "pino";
+import { pino } from "pino";
 
 let logger: pino.Logger;
 

src/logger.ts

@@ -4,8 +4,8 @@ import { CallToolResult } from "@modelcontextprotocol/sdk/types.js";
 import {
   startAccessibilityScan,
   AccessibilityScanResponse,
-} from "./accessiblity-utils/accessibility";
-import { trackMCP } from "../lib/instrumentation";
+} from "./accessiblity-utils/accessibility.js";
+import { trackMCP } from "../lib/instrumentation.js";
 
 async function runAccessibilityScan(
   name: string,