chore(chrome): fix connection overfetching

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@a11ywatch/pagemind",
-  "version": "0.9.35",
+  "version": "0.9.36",
   "description": "Get metrics on your web page with inclusion",
   "main": "./server.js",
   "author": "Jeff Mendez",
@@ -26,14 +26,14 @@
   "dependencies": {
     "@a11ywatch/protos": "^0.4.7",
     "@a11ywatch/website-source-builder": "^0.1.8",
-    "@grpc/grpc-js": "1.8.16",
-    "@grpc/proto-loader": "0.7.7",
+    "@grpc/grpc-js": "1.8.18",
+    "@grpc/proto-loader": "0.7.8",
     "fastq": "1.15.0",
     "get-page-speed": "1.0.1",
-    "kayle": "^0.4.69",
+    "kayle": "^0.4.75",
     "lighthouse": "9.6.8",
     "pb-util": "1.0.3",
-    "playwright": "^1.35.1"
+    "playwright": "^1.36.1"
   },
   "devDependencies": {
     "@swc/core": "^1.3.19",

src/config/chrome.ts

@@ -1,10 +1,17 @@
 import dns from "dns";
+import { EventEmitter } from "node:events";
 import { fetchUrl } from "../core/lib/utils/fetch";
 import { getLoadBalancerDefaults } from "../core/lib/utils/connection/load-balancer";
 
+class LoadEmitter extends EventEmitter {}
+
+const loadEmitter = new LoadEmitter();
+
 // chrome load balancer endpoint
 const chromeLb = process.env.CHROME_LB;
 
+let CONNECTION_FETCHING = false;
+
 // the chrome hostname dns to connect to with lighthouse sockets
 let chromeHost = process.env.CHROME_HOST;
 // the chrome socket connection to connect to
@@ -112,6 +119,15 @@ const getWsEndPoint = async (
   retry?: boolean,
   bindHost?: boolean
 ): Promise<[string, string]> => {
+  if (CONNECTION_FETCHING) {
+    return new Promise((resolve) => {
+      loadEmitter.once("event", () => {
+        resolve([chromeHost, wsChromeEndpointurl]);
+      });
+    });
+  }
+  CONNECTION_FETCHING = true;
+
   // return the load balancer instance of chrome
   if (chromeLb) {
     return new Promise(async (resolve) => {
@@ -124,7 +140,8 @@ const getWsEndPoint = async (
           wsChromeEndpointurl = clb[1];
         }
       }
-
+      CONNECTION_FETCHING = false;
+      loadEmitter.emit("event");
       resolve(clb);
     });
   }
@@ -136,9 +153,13 @@ const getWsEndPoint = async (
     if (retry && !wsChromeEndpointurl) {
       setTimeout(async () => {
         await getWs();
+        CONNECTION_FETCHING = false;
+        loadEmitter.emit("event");
         resolve([chromeHost, wsChromeEndpointurl]);
       }, 33);
     } else {
+      CONNECTION_FETCHING = false;
+      loadEmitter.emit("event");
       resolve([chromeHost, wsChromeEndpointurl]);
     }
   });