@agenshield/interceptor - npm Package Compare versions

Comparing version 0.4.3 to 0.4.4

events/reporter.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"reporter.d.ts","sourceRoot":"","sources":["../../src/events/reporter.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,0BAA0B,CAAC;AAE5D,MAAM,WAAW,oBAAoB;IACnC,MAAM,EAAE,WAAW,CAAC;IACpB,QAAQ,EAAE,OAAO,GAAG,MAAM,GAAG,MAAM,GAAG,OAAO,CAAC;CAC/C;AAED,MAAM,WAAW,gBAAgB;IAC/B,IAAI,EAAE,WAAW,GAAG,OAAO,GAAG,MAAM,GAAG,OAAO,CAAC;IAC/C,SAAS,EAAE,MAAM,CAAC;IAClB,MAAM,EAAE,MAAM,CAAC;IACf,SAAS,EAAE,IAAI,CAAC;IAChB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB;AAED,qBAAa,aAAa;IACxB,OAAO,CAAC,MAAM,CAAc;IAC5B,OAAO,CAAC,QAAQ,CAAmC;IACnD,OAAO,CAAC,KAAK,CAA0B;IACvC,OAAO,CAAC,aAAa,CAA+B;IACpD,OAAO,CAAC,gBAAgB,CAAK;IAE7B,OAAO,CAAC,MAAM,CAAC,QAAQ,CAAC,cAAc,CAAO;IAC7C,OAAO,CAAC,MAAM,CAAC,QAAQ,CAAC,WAAW,CAAK;IAExC,OAAO,CAAC,QAAQ,CAAC,aAAa,CAK5B;gBAEU,OAAO,EAAE,oBAAoB;IAQzC;;OAEG;IACH,MAAM,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI;IAqBrC;;OAEG;IACH,SAAS,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,GAAG,IAAI;IASlD;;OAEG;IACH,KAAK,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,GAAG,IAAI;IAWpF;;OAEG;IACH,IAAI,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,MAAM,GAAG,IAAI;IAWjF;;OAEG;IACH,KAAK,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,GAAG,IAAI;IAU7D;;OAEG;IACG,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IAsB5B;;OAEG;IACH,IAAI,IAAI,IAAI;IAUZ;;OAEG;IACH,OAAO,CAAC,WAAW;IAenB;;OAEG;IACH,OAAO,CAAC,SAAS;CAGlB"}
+{"version":3,"file":"reporter.d.ts","sourceRoot":"","sources":["../../src/events/reporter.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,0BAA0B,CAAC;AAE5D,MAAM,WAAW,oBAAoB;IACnC,MAAM,EAAE,WAAW,CAAC;IACpB,QAAQ,EAAE,OAAO,GAAG,MAAM,GAAG,MAAM,GAAG,OAAO,CAAC;CAC/C;AAED,MAAM,WAAW,gBAAgB;IAC/B,IAAI,EAAE,WAAW,GAAG,OAAO,GAAG,MAAM,GAAG,OAAO,CAAC;IAC/C,SAAS,EAAE,MAAM,CAAC;IAClB,MAAM,EAAE,MAAM,CAAC;IACf,SAAS,EAAE,IAAI,CAAC;IAChB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,QAAQ,CAAC,EAAE,MAAM,CAAC;IAClB,KAAK,CAAC,EAAE,MAAM,CAAC;CAChB;AAED,qBAAa,aAAa;IACxB,OAAO,CAAC,MAAM,CAAc;IAC5B,OAAO,CAAC,QAAQ,CAAmC;IACnD,OAAO,CAAC,KAAK,CAA0B;IACvC,OAAO,CAAC,aAAa,CAA+B;IACpD,OAAO,CAAC,gBAAgB,CAAK;IAE7B,OAAO,CAAC,MAAM,CAAC,QAAQ,CAAC,cAAc,CAAO;IAC7C,OAAO,CAAC,MAAM,CAAC,QAAQ,CAAC,WAAW,CAAK;IAExC,OAAO,CAAC,QAAQ,CAAC,aAAa,CAK5B;gBAEU,OAAO,EAAE,oBAAoB;IASzC;;OAEG;IACH,MAAM,CAAC,KAAK,EAAE,gBAAgB,GAAG,IAAI;IAqBrC;;OAEG;IACH,SAAS,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,GAAG,IAAI;IASlD;;OAEG;IACH,KAAK,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,GAAG,IAAI;IAWpF;;OAEG;IACH,IAAI,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,QAAQ,CAAC,EAAE,MAAM,EAAE,MAAM,CAAC,EAAE,MAAM,GAAG,IAAI;IAWjF;;OAEG;IACH,KAAK,CAAC,SAAS,EAAE,MAAM,EAAE,MAAM,EAAE,MAAM,EAAE,KAAK,EAAE,MAAM,GAAG,IAAI;IAU7D;;OAEG;IACG,KAAK,IAAI,OAAO,CAAC,IAAI,CAAC;IAsB5B;;OAEG;IACH,IAAI,IAAI,IAAI;IAUZ;;OAEG;IACH,OAAO,CAAC,WAAW;IAenB;;OAEG;IACH,OAAO,CAAC,SAAS;CAGlB"}

index.js

@@ -112,2 +112,3 @@ "use strict";
   installed = false;
+  brokerHttpPort;
   constructor(options) {
@@ -118,4 +119,20 @@ this.client = options.client;
     this.failOpen = options.failOpen;
+    this.brokerHttpPort = options.brokerHttpPort ?? 5201;
   }
   /**
+   * Check if a URL targets the broker or daemon (should not be intercepted)
+   */
+  isBrokerUrl(url) {
+    try {
+      const parsed = new URL(url);
+      if (parsed.hostname !== "localhost" && parsed.hostname !== "127.0.0.1") {
+        return false;
+      }
+      const port = parsed.port;
+      return port === String(this.brokerHttpPort) || port === "5200";
+    } catch {
+      return false;
+    }
+  }
+  /**
    * Check if the interceptor is installed
@@ -253,10 +270,2 @@ */
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -354,10 +363,2 @@
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -405,10 +406,2 @@
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -1031,2 +1024,3 @@
     this.flushInterval = setInterval(() => this.flush(), 5e3);
+    this.flushInterval.unref();
   }
@@ -1183,3 +1177,4 @@ /**
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1194,3 +1189,4 @@ installed.fetch.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1205,3 +1201,4 @@ installed.http.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1216,3 +1213,4 @@ installed.websocket.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1227,3 +1225,4 @@ installed.childProcess.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1230,0 +1229,0 @@ installed.fs.install();

installer.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"installer.d.ts","sourceRoot":"","sources":["../src/installer.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,iBAAiB,EAAE,MAAM,aAAa,CAAC;AAOrD,OAAO,EAAE,WAAW,EAAE,MAAM,yBAAyB,CAAC;AAiBtD;;GAEG;AACH,wBAAgB,mBAAmB,CACjC,eAAe,CAAC,EAAE,OAAO,CAAC,iBAAiB,CAAC,GAC3C,IAAI,CAwFN;AAED;;GAEG;AACH,wBAAgB,qBAAqB,IAAI,IAAI,CA6B5C;AAED;;GAEG;AACH,wBAAgB,WAAW,IAAI,OAAO,CAErC;AAED;;GAEG;AACH,wBAAgB,SAAS,IAAI,WAAW,GAAG,IAAI,CAE9C"}
+{"version":3,"file":"installer.d.ts","sourceRoot":"","sources":["../src/installer.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,iBAAiB,EAAE,MAAM,aAAa,CAAC;AAOrD,OAAO,EAAE,WAAW,EAAE,MAAM,yBAAyB,CAAC;AAiBtD;;GAEG;AACH,wBAAgB,mBAAmB,CACjC,eAAe,CAAC,EAAE,OAAO,CAAC,iBAAiB,CAAC,GAC3C,IAAI,CA6FN;AAED;;GAEG;AACH,wBAAgB,qBAAqB,IAAI,IAAI,CA6B5C;AAED;;GAEG;AACH,wBAAgB,WAAW,IAAI,OAAO,CAErC;AAED;;GAEG;AACH,wBAAgB,SAAS,IAAI,WAAW,GAAG,IAAI,CAE9C"}

interceptors/base.d.ts

@@ -14,2 +14,4 @@ /**
     failOpen: boolean;
+    /** HTTP port used by the broker (to skip interception of broker traffic) */
+    brokerHttpPort?: number;
 }
@@ -22,4 +24,9 @@ export declare abstract class BaseInterceptor {
     protected installed: boolean;
+    private brokerHttpPort;
     constructor(options: BaseInterceptorOptions);
     /**
+     * Check if a URL targets the broker or daemon (should not be intercepted)
+     */
+    protected isBrokerUrl(url: string): boolean;
+    /**
      * Install the interceptor
@@ -26,0 +33,0 @@ */

interceptors/base.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"base.d.ts","sourceRoot":"","sources":["../../src/interceptors/base.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,0BAA0B,CAAC;AAC5D,OAAO,KAAK,EAAE,eAAe,EAAE,MAAM,wBAAwB,CAAC;AAC9D,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,uBAAuB,CAAC;AAG3D,MAAM,WAAW,sBAAsB;IACrC,MAAM,EAAE,WAAW,CAAC;IACpB,eAAe,EAAE,eAAe,CAAC;IACjC,aAAa,EAAE,aAAa,CAAC;IAC7B,QAAQ,EAAE,OAAO,CAAC;CACnB;AAED,8BAAsB,eAAe;IACnC,SAAS,CAAC,MAAM,EAAE,WAAW,CAAC;IAC9B,SAAS,CAAC,eAAe,EAAE,eAAe,CAAC;IAC3C,SAAS,CAAC,aAAa,EAAE,aAAa,CAAC;IACvC,SAAS,CAAC,QAAQ,EAAE,OAAO,CAAC;IAC5B,SAAS,CAAC,SAAS,EAAE,OAAO,CAAS;gBAEzB,OAAO,EAAE,sBAAsB;IAO3C;;OAEG;IACH,QAAQ,CAAC,OAAO,IAAI,IAAI;IAExB;;OAEG;IACH,QAAQ,CAAC,SAAS,IAAI,IAAI;IAE1B;;OAEG;IACH,WAAW,IAAI,OAAO;IAItB;;OAEG;cACa,WAAW,CACzB,SAAS,EAAE,MAAM,EACjB,MAAM,EAAE,MAAM,GACb,OAAO,CAAC,IAAI,CAAC;IA0ChB;;OAEG;IACH,SAAS,CAAC,KAAK,CAAC,OAAO,EAAE,MAAM,GAAG,IAAI;CAGvC"}
+{"version":3,"file":"base.d.ts","sourceRoot":"","sources":["../../src/interceptors/base.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,0BAA0B,CAAC;AAC5D,OAAO,KAAK,EAAE,eAAe,EAAE,MAAM,wBAAwB,CAAC;AAC9D,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,uBAAuB,CAAC;AAG3D,MAAM,WAAW,sBAAsB;IACrC,MAAM,EAAE,WAAW,CAAC;IACpB,eAAe,EAAE,eAAe,CAAC;IACjC,aAAa,EAAE,aAAa,CAAC;IAC7B,QAAQ,EAAE,OAAO,CAAC;IAClB,4EAA4E;IAC5E,cAAc,CAAC,EAAE,MAAM,CAAC;CACzB;AAED,8BAAsB,eAAe;IACnC,SAAS,CAAC,MAAM,EAAE,WAAW,CAAC;IAC9B,SAAS,CAAC,eAAe,EAAE,eAAe,CAAC;IAC3C,SAAS,CAAC,aAAa,EAAE,aAAa,CAAC;IACvC,SAAS,CAAC,QAAQ,EAAE,OAAO,CAAC;IAC5B,SAAS,CAAC,SAAS,EAAE,OAAO,CAAS;IACrC,OAAO,CAAC,cAAc,CAAS;gBAEnB,OAAO,EAAE,sBAAsB;IAQ3C;;OAEG;IACH,SAAS,CAAC,WAAW,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO;IAa3C;;OAEG;IACH,QAAQ,CAAC,OAAO,IAAI,IAAI;IAExB;;OAEG;IACH,QAAQ,CAAC,SAAS,IAAI,IAAI;IAE1B;;OAEG;IACH,WAAW,IAAI,OAAO;IAItB;;OAEG;cACa,WAAW,CACzB,SAAS,EAAE,MAAM,EACjB,MAAM,EAAE,MAAM,GACb,OAAO,CAAC,IAAI,CAAC;IA0ChB;;OAEG;IACH,SAAS,CAAC,KAAK,CAAC,OAAO,EAAE,MAAM,GAAG,IAAI;CAGvC"}

interceptors/fetch.d.ts

@@ -13,4 +13,3 @@ /**
     private interceptedFetch;
-    private isBrokerUrl;
 }
 //# sourceMappingURL=fetch.d.ts.map

interceptors/fetch.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"fetch.d.ts","sourceRoot":"","sources":["../../src/interceptors/fetch.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,EAAE,eAAe,EAAE,KAAK,sBAAsB,EAAE,MAAM,WAAW,CAAC;AAEzE,qBAAa,gBAAiB,SAAQ,eAAe;IACnD,OAAO,CAAC,aAAa,CAA6B;gBAEtC,OAAO,EAAE,sBAAsB;IAI3C,OAAO,IAAI,IAAI;IAYf,SAAS,IAAI,IAAI;YAQH,gBAAgB;IA0F9B,OAAO,CAAC,WAAW;CAWpB"}
+{"version":3,"file":"fetch.d.ts","sourceRoot":"","sources":["../../src/interceptors/fetch.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,EAAE,eAAe,EAAE,KAAK,sBAAsB,EAAE,MAAM,WAAW,CAAC;AAEzE,qBAAa,gBAAiB,SAAQ,eAAe;IACnD,OAAO,CAAC,aAAa,CAA6B;gBAEtC,OAAO,EAAE,sBAAsB;IAI3C,OAAO,IAAI,IAAI;IAYf,SAAS,IAAI,IAAI;YAQH,gBAAgB;CA0F/B"}

interceptors/http.d.ts

@@ -17,4 +17,3 @@ /**
     private createInterceptedGet;
-    private isBrokerUrl;
 }
 //# sourceMappingURL=http.d.ts.map

interceptors/http.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"http.d.ts","sourceRoot":"","sources":["../../src/interceptors/http.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAGH,OAAO,EAAE,eAAe,EAAE,KAAK,sBAAsB,EAAE,MAAM,WAAW,CAAC;AAQzE,qBAAa,eAAgB,SAAQ,eAAe;IAClD,OAAO,CAAC,mBAAmB,CAAoC;IAC/D,OAAO,CAAC,eAAe,CAAgC;IACvD,OAAO,CAAC,oBAAoB,CAAoC;IAChE,OAAO,CAAC,gBAAgB,CAAgC;gBAE5C,OAAO,EAAE,sBAAsB;IAI3C,OAAO,IAAI,IAAI;IAkBf,SAAS,IAAI,IAAI;IAuBjB,OAAO,CAAC,wBAAwB;IA0DhC,OAAO,CAAC,oBAAoB;IAoB5B,OAAO,CAAC,WAAW;CAWpB"}
+{"version":3,"file":"http.d.ts","sourceRoot":"","sources":["../../src/interceptors/http.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAGH,OAAO,EAAE,eAAe,EAAE,KAAK,sBAAsB,EAAE,MAAM,WAAW,CAAC;AAQzE,qBAAa,eAAgB,SAAQ,eAAe;IAClD,OAAO,CAAC,mBAAmB,CAAoC;IAC/D,OAAO,CAAC,eAAe,CAAgC;IACvD,OAAO,CAAC,oBAAoB,CAAoC;IAChE,OAAO,CAAC,gBAAgB,CAAgC;gBAE5C,OAAO,EAAE,sBAAsB;IAI3C,OAAO,IAAI,IAAI;IAkBf,SAAS,IAAI,IAAI;IAuBjB,OAAO,CAAC,wBAAwB;IA0DhC,OAAO,CAAC,oBAAoB;CAoB7B"}

interceptors/websocket.d.ts

@@ -12,4 +12,3 @@ /**
     uninstall(): void;
-    private isBrokerUrl;
 }
 //# sourceMappingURL=websocket.d.ts.map

interceptors/websocket.d.ts.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"websocket.d.ts","sourceRoot":"","sources":["../../src/interceptors/websocket.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,EAAE,eAAe,EAAE,KAAK,sBAAsB,EAAE,MAAM,WAAW,CAAC;AAGzE,qBAAa,oBAAqB,SAAQ,eAAe;IACvD,OAAO,CAAC,iBAAiB,CAAiC;gBAE9C,OAAO,EAAE,sBAAsB;IAI3C,OAAO,IAAI,IAAI;IAiDf,SAAS,IAAI,IAAI;IAQjB,OAAO,CAAC,WAAW;CAWpB"}
+{"version":3,"file":"websocket.d.ts","sourceRoot":"","sources":["../../src/interceptors/websocket.ts"],"names":[],"mappings":"AAAA;;;;GAIG;AAEH,OAAO,EAAE,eAAe,EAAE,KAAK,sBAAsB,EAAE,MAAM,WAAW,CAAC;AAGzE,qBAAa,oBAAqB,SAAQ,eAAe;IACvD,OAAO,CAAC,iBAAiB,CAAiC;gBAE9C,OAAO,EAAE,sBAAsB;IAI3C,OAAO,IAAI,IAAI;IAiDf,SAAS,IAAI,IAAI;CAQlB"}

package.json

 {
   "name": "@agenshield/interceptor",
-  "version": "0.4.3",
+  "version": "0.4.4",
   "type": "module",
@@ -28,3 +28,3 @@ "description": "Node.js runtime interception via ESM loader and CJS preload",
   "dependencies": {
-    "@agenshield/ipc": "0.4.3"
+    "@agenshield/ipc": "0.4.4"
   },
@@ -31,0 +31,0 @@ "devDependencies": {

register.js

@@ -87,2 +87,3 @@ "use strict";
   installed = false;
+  brokerHttpPort;
   constructor(options) {
@@ -93,4 +94,20 @@ this.client = options.client;
     this.failOpen = options.failOpen;
+    this.brokerHttpPort = options.brokerHttpPort ?? 5201;
   }
   /**
+   * Check if a URL targets the broker or daemon (should not be intercepted)
+   */
+  isBrokerUrl(url) {
+    try {
+      const parsed = new URL(url);
+      if (parsed.hostname !== "localhost" && parsed.hostname !== "127.0.0.1") {
+        return false;
+      }
+      const port = parsed.port;
+      return port === String(this.brokerHttpPort) || port === "5200";
+    } catch {
+      return false;
+    }
+  }
+  /**
    * Check if the interceptor is installed
@@ -228,10 +245,2 @@ */
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -329,10 +338,2 @@
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -380,10 +381,2 @@
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -1006,2 +999,3 @@
     this.flushInterval = setInterval(() => this.flush(), 5e3);
+    this.flushInterval.unref();
   }
@@ -1158,3 +1152,4 @@ /**
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1169,3 +1164,4 @@ installed.fetch.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1180,3 +1176,4 @@ installed.http.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1191,3 +1188,4 @@ installed.websocket.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1202,3 +1200,4 @@ installed.childProcess.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1205,0 +1204,0 @@ installed.fs.install();

require.js

@@ -87,2 +87,3 @@ "use strict";
   installed = false;
+  brokerHttpPort;
   constructor(options) {
@@ -93,4 +94,20 @@ this.client = options.client;
     this.failOpen = options.failOpen;
+    this.brokerHttpPort = options.brokerHttpPort ?? 5201;
   }
   /**
+   * Check if a URL targets the broker or daemon (should not be intercepted)
+   */
+  isBrokerUrl(url) {
+    try {
+      const parsed = new URL(url);
+      if (parsed.hostname !== "localhost" && parsed.hostname !== "127.0.0.1") {
+        return false;
+      }
+      const port = parsed.port;
+      return port === String(this.brokerHttpPort) || port === "5200";
+    } catch {
+      return false;
+    }
+  }
+  /**
    * Check if the interceptor is installed
@@ -228,10 +245,2 @@ */
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -329,10 +338,2 @@
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -380,10 +381,2 @@
   }
-  isBrokerUrl(url) {
-    try {
-      const parsed = new URL(url);
-      return (parsed.hostname === "localhost" || parsed.hostname === "127.0.0.1") && parsed.port === "5200";
-    } catch {
-      return false;
-    }
-  }
 };
@@ -1006,2 +999,3 @@
     this.flushInterval = setInterval(() => this.flush(), 5e3);
+    this.flushInterval.unref();
   }
@@ -1158,3 +1152,4 @@ /**
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1169,3 +1164,4 @@ installed.fetch.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1180,3 +1176,4 @@ installed.http.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1191,3 +1188,4 @@ installed.websocket.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1202,3 +1200,4 @@ installed.childProcess.install();
       eventReporter,
-      failOpen: config.failOpen
+      failOpen: config.failOpen,
+      brokerHttpPort: config.httpPort
     });
@@ -1205,0 +1204,0 @@ installed.fs.install();

New alerts

AI-detected potential code anomaly

Supply chain risk

AI has identified unusual behaviors that may pose a security risk.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

152825

0.29%

Lines of code

4121

0.02%

Worsened metrics

Number of low supply chain risk alerts

6

20%

Dependency changes

• + Added

  @agenshield/ipc@0.4.4
  (transitive)

• - Removed

  @agenshield/ipc@0.4.3
  (transitive)

• Updated

  @agenshield/ipc@0.4.4