@logtail/node - npm Package Compare versions

Comparing version 0.5.3 to 0.5.4

dist/cjs/node.d.ts

@@ -29,2 +29,3 @@ import { Duplex, Writable } from "stream";
     private createAgent;
+    private getHttpModule;
 }

dist/cjs/node.js

@@ -8,3 +8,2 @@ "use strict";
 const msgpack_1 = require("@msgpack/msgpack");
-const cross_fetch_1 = require("cross-fetch");
 const node_http_1 = __importDefault(require("node:http"));
@@ -20,3 +19,3 @@ const node_https_1 = __importDefault(require("node:https"));
         const sync = async (logs) => {
-            const res = await (0, cross_fetch_1.fetch)(this._options.endpoint, {
+            const request = this.getHttpModule().request(this._options.endpoint, {
                 method: "POST",
@@ -28,10 +27,14 @@ headers: {
                 },
-                body: this.encodeAsMsgpack(logs),
-                // @ts-ignore (cross-fetch does not expose the agent option)
                 agent,
             });
-            if (res.ok) {
+            const response = await new Promise((resolve, reject) => {
+                request.on("response", resolve);
+                request.on("error", reject);
+                request.write(this.encodeAsMsgpack(logs));
+                request.end();
+            });
+            if (response.statusCode && response.statusCode >= 200 && response.statusCode < 300) {
                 return logs;
             }
-            throw new Error(res.statusText);
+            throw new Error(response.statusMessage);
         };
@@ -78,13 +81,11 @@ // Set the throttled sync function
         const family = nodeOptions.useIPv6 ? 6 : 4;
-        if (nodeOptions.endpoint.startsWith("https")) {
-            return new node_https_1.default.Agent({
-                family,
-            });
-        }
-        return new node_http_1.default.Agent({
+        return new (this.getHttpModule().Agent)({
             family,
         });
     }
+    getHttpModule() {
+        return this._options.endpoint.startsWith("https") ? node_https_1.default : node_http_1.default;
+    }
 }
 exports.Node = Node;
 //# sourceMappingURL=node.js.map

dist/cjs/node.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"node.js","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":";;;;;;AAEA,8CAA0C;AAC1C,6CAAoC;AACpC,0DAA6B;AAC7B,4DAA+B;AAG/B,wCAAqC;AAErC,uCAA4C;AAE5C,MAAa,IAAK,SAAQ,WAAI;IAO5B,YAAmB,WAAmB,EAAE,OAAsC;QAC5E,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,MAAM,KAAK,GAAG,IAAI,CAAC,WAAW,EAAE,CAAC;QAEjC,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,GAAG,GAAG,MAAM,IAAA,mBAAK,EAAC,IAAI,CAAC,QAAQ,CAAC,QAAQ,EAAE;gBAC9C,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACP,cAAc,EAAE,qBAAqB;oBACrC,aAAa,EAAE,UAAU,IAAI,CAAC,YAAY,EAAE;oBAC5C,YAAY,EAAE,kBAAkB;iBACjC;gBACD,IAAI,EAAE,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC;gBAChC,4DAA4D;gBAC5D,KAAK;aACN,CAAC,CAAC;YAEH,IAAI,GAAG,CAAC,EAAE,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC;YACd,CAAC;YAED,MAAM,IAAI,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAClC,CAAC,CAAC;QAEF,kCAAkC;QAClC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IACrB,CAAC;IAED;;;;;;;;OAQG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAiB,EACjB,UAAoB,EAAc,EAClC,gBAAmC;QAEnC,yCAAyC;QACzC,OAAO,mCAAQ,IAAA,yBAAe,EAAC,IAAI,EAAE,gBAAgB,CAAC,GAAK,OAAO,CAAE,CAAC;QACrE,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE,CAAC;YACtB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;QAC/D,CAAC;QAED,6BAA6B;QAC7B,OAAO,YAAsC,CAAC;IAChD,CAAC;IAED;;;;OAIG;IACI,IAAI,CAAC,MAAyB;QACnC,IAAI,CAAC,YAAY,GAAG,MAAM,CAAC;QAC3B,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,eAAe,CAAC,IAAmB;QACzC,MAAM,OAAO,GAAG,IAAA,gBAAM,EAAC,IAAI,CAAC,CAAC;QAC7B,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAC;QACnF,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,WAAW;QACjB,MAAM,WAAW,GAAG,IAAI,CAAC,QAA+B,CAAC;QACzD,MAAM,MAAM,GAAG,WAAW,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;QAC3C,IAAI,WAAW,CAAC,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,EAAE,CAAC;YAC7C,OAAO,IAAI,oBAAK,CAAC,KAAK,CAAC;gBACrB,MAAM;aACP,CAAC,CAAC;QACL,CAAC;QAED,OAAO,IAAI,mBAAI,CAAC,KAAK,CAAC;YACpB,MAAM;SACP,CAAC,CAAC;IACL,CAAC;CACF;AA9FD,oBA8FC"}
+{"version":3,"file":"node.js","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":";;;;;;AAEA,8CAA0C;AAC1C,0DAA6B;AAC7B,4DAA+B;AAG/B,wCAAqC;AAErC,uCAA4C;AAE5C,MAAa,IAAK,SAAQ,WAAI;IAO5B,YAAmB,WAAmB,EAAE,OAAsC;QAC5E,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,MAAM,KAAK,GAAG,IAAI,CAAC,WAAW,EAAE,CAAC;QAEjC,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,OAAO,GAAG,IAAI,CAAC,aAAa,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,QAAQ,CAAC,QAAQ,EAAE;gBACnE,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACP,cAAc,EAAE,qBAAqB;oBACrC,aAAa,EAAE,UAAU,IAAI,CAAC,YAAY,EAAE;oBAC5C,YAAY,EAAE,kBAAkB;iBACjC;gBACD,KAAK;aACN,CAAC,CAAC;YAEH,MAAM,QAAQ,GAAyB,MAAM,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBAC3E,OAAO,CAAC,EAAE,CAAC,UAAU,EAAE,OAAO,CAAC,CAAC;gBAChC,OAAO,CAAC,EAAE,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;gBAC5B,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,CAAC,CAAC;gBAC1C,OAAO,CAAC,GAAG,EAAE,CAAC;YAChB,CAAC,CAAC,CAAC;YAEH,IAAI,QAAQ,CAAC,UAAU,IAAI,QAAQ,CAAC,UAAU,IAAI,GAAG,IAAI,QAAQ,CAAC,UAAU,GAAG,GAAG,EAAE,CAAC;gBACnF,OAAO,IAAI,CAAC;YACd,CAAC;YAED,MAAM,IAAI,KAAK,CAAC,QAAQ,CAAC,aAAa,CAAC,CAAC;QAC1C,CAAC,CAAC;QAEF,kCAAkC;QAClC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IACrB,CAAC;IAED;;;;;;;;OAQG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAiB,EACjB,UAAoB,EAAc,EAClC,gBAAmC;QAEnC,yCAAyC;QACzC,OAAO,mCAAQ,IAAA,yBAAe,EAAC,IAAI,EAAE,gBAAgB,CAAC,GAAK,OAAO,CAAE,CAAC;QACrE,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE,CAAC;YACtB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;QAC/D,CAAC;QAED,6BAA6B;QAC7B,OAAO,YAAsC,CAAC;IAChD,CAAC;IAED;;;;OAIG;IACI,IAAI,CAAC,MAAyB;QACnC,IAAI,CAAC,YAAY,GAAG,MAAM,CAAC;QAC3B,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,eAAe,CAAC,IAAmB;QACzC,MAAM,OAAO,GAAG,IAAA,gBAAM,EAAC,IAAI,CAAC,CAAC;QAC7B,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAC;QACnF,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,WAAW;QACjB,MAAM,WAAW,GAAG,IAAI,CAAC,QAA+B,CAAC;QACzD,MAAM,MAAM,GAAG,WAAW,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;QAC3C,OAAO,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,KAAK,CAAC,CAAC;YACtC,MAAM;SACP,CAAC,CAAC;IACL,CAAC;IAEO,aAAa;QACnB,OAAO,IAAI,CAAC,QAAQ,CAAC,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,oBAAK,CAAC,CAAC,CAAC,mBAAI,CAAC;IACnE,CAAC;CACF;AAjGD,oBAiGC"}

dist/es6/node.d.ts

@@ -29,2 +29,3 @@ import { Duplex, Writable } from "stream";
     private createAgent;
+    private getHttpModule;
 }

dist/es6/node.js

 import { encode } from "@msgpack/msgpack";
-import { fetch } from "cross-fetch";
 import http from "node:http";
@@ -13,3 +12,3 @@ import https from "node:https";
         const sync = async (logs) => {
-            const res = await fetch(this._options.endpoint, {
+            const request = this.getHttpModule().request(this._options.endpoint, {
                 method: "POST",
@@ -21,10 +20,14 @@ headers: {
                 },
-                body: this.encodeAsMsgpack(logs),
-                // @ts-ignore (cross-fetch does not expose the agent option)
                 agent,
             });
-            if (res.ok) {
+            const response = await new Promise((resolve, reject) => {
+                request.on("response", resolve);
+                request.on("error", reject);
+                request.write(this.encodeAsMsgpack(logs));
+                request.end();
+            });
+            if (response.statusCode && response.statusCode >= 200 && response.statusCode < 300) {
                 return logs;
             }
-            throw new Error(res.statusText);
+            throw new Error(response.statusMessage);
         };
@@ -71,12 +74,10 @@ // Set the throttled sync function
         const family = nodeOptions.useIPv6 ? 6 : 4;
-        if (nodeOptions.endpoint.startsWith("https")) {
-            return new https.Agent({
-                family,
-            });
-        }
-        return new http.Agent({
+        return new (this.getHttpModule().Agent)({
             family,
         });
     }
+    getHttpModule() {
+        return this._options.endpoint.startsWith("https") ? https : http;
+    }
 }
 //# sourceMappingURL=node.js.map

dist/es6/node.js.map

@@ -1,1 +0,1 @@
-{"version":3,"file":"node.js","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,MAAM,EAAE,MAAM,kBAAkB,CAAC;AAC1C,OAAO,EAAE,KAAK,EAAE,MAAM,aAAa,CAAC;AACpC,OAAO,IAAI,MAAM,WAAW,CAAC;AAC7B,OAAO,KAAK,MAAM,YAAY,CAAC;AAG/B,OAAO,EAAE,IAAI,EAAE,MAAM,eAAe,CAAC;AAErC,OAAO,EAAE,eAAe,EAAE,MAAM,WAAW,CAAC;AAE5C,MAAM,OAAO,IAAK,SAAQ,IAAI;IAO5B,YAAmB,WAAmB,EAAE,OAAsC;QAC5E,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,MAAM,KAAK,GAAG,IAAI,CAAC,WAAW,EAAE,CAAC;QAEjC,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,GAAG,GAAG,MAAM,KAAK,CAAC,IAAI,CAAC,QAAQ,CAAC,QAAQ,EAAE;gBAC9C,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACP,cAAc,EAAE,qBAAqB;oBACrC,aAAa,EAAE,UAAU,IAAI,CAAC,YAAY,EAAE;oBAC5C,YAAY,EAAE,kBAAkB;iBACjC;gBACD,IAAI,EAAE,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC;gBAChC,4DAA4D;gBAC5D,KAAK;aACN,CAAC,CAAC;YAEH,IAAI,GAAG,CAAC,EAAE,EAAE,CAAC;gBACX,OAAO,IAAI,CAAC;YACd,CAAC;YAED,MAAM,IAAI,KAAK,CAAC,GAAG,CAAC,UAAU,CAAC,CAAC;QAClC,CAAC,CAAC;QAEF,kCAAkC;QAClC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IACrB,CAAC;IAED;;;;;;;;OAQG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAiB,EACjB,UAAoB,EAAc,EAClC,gBAAmC;QAEnC,yCAAyC;QACzC,OAAO,mCAAQ,eAAe,CAAC,IAAI,EAAE,gBAAgB,CAAC,GAAK,OAAO,CAAE,CAAC;QACrE,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE,CAAC;YACtB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;QAC/D,CAAC;QAED,6BAA6B;QAC7B,OAAO,YAAsC,CAAC;IAChD,CAAC;IAED;;;;OAIG;IACI,IAAI,CAAC,MAAyB;QACnC,IAAI,CAAC,YAAY,GAAG,MAAM,CAAC;QAC3B,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,eAAe,CAAC,IAAmB;QACzC,MAAM,OAAO,GAAG,MAAM,CAAC,IAAI,CAAC,CAAC;QAC7B,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAC;QACnF,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,WAAW;QACjB,MAAM,WAAW,GAAG,IAAI,CAAC,QAA+B,CAAC;QACzD,MAAM,MAAM,GAAG,WAAW,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;QAC3C,IAAI,WAAW,CAAC,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,EAAE,CAAC;YAC7C,OAAO,IAAI,KAAK,CAAC,KAAK,CAAC;gBACrB,MAAM;aACP,CAAC,CAAC;QACL,CAAC;QAED,OAAO,IAAI,IAAI,CAAC,KAAK,CAAC;YACpB,MAAM;SACP,CAAC,CAAC;IACL,CAAC;CACF"}
+{"version":3,"file":"node.js","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":"AAEA,OAAO,EAAE,MAAM,EAAE,MAAM,kBAAkB,CAAC;AAC1C,OAAO,IAAI,MAAM,WAAW,CAAC;AAC7B,OAAO,KAAK,MAAM,YAAY,CAAC;AAG/B,OAAO,EAAE,IAAI,EAAE,MAAM,eAAe,CAAC;AAErC,OAAO,EAAE,eAAe,EAAE,MAAM,WAAW,CAAC;AAE5C,MAAM,OAAO,IAAK,SAAQ,IAAI;IAO5B,YAAmB,WAAmB,EAAE,OAAsC;QAC5E,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,MAAM,KAAK,GAAG,IAAI,CAAC,WAAW,EAAE,CAAC;QAEjC,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,OAAO,GAAG,IAAI,CAAC,aAAa,EAAE,CAAC,OAAO,CAAC,IAAI,CAAC,QAAQ,CAAC,QAAQ,EAAE;gBACnE,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACP,cAAc,EAAE,qBAAqB;oBACrC,aAAa,EAAE,UAAU,IAAI,CAAC,YAAY,EAAE;oBAC5C,YAAY,EAAE,kBAAkB;iBACjC;gBACD,KAAK;aACN,CAAC,CAAC;YAEH,MAAM,QAAQ,GAAyB,MAAM,IAAI,OAAO,CAAC,CAAC,OAAO,EAAE,MAAM,EAAE,EAAE;gBAC3E,OAAO,CAAC,EAAE,CAAC,UAAU,EAAE,OAAO,CAAC,CAAC;gBAChC,OAAO,CAAC,EAAE,CAAC,OAAO,EAAE,MAAM,CAAC,CAAC;gBAC5B,OAAO,CAAC,KAAK,CAAC,IAAI,CAAC,eAAe,CAAC,IAAI,CAAC,CAAC,CAAC;gBAC1C,OAAO,CAAC,GAAG,EAAE,CAAC;YAChB,CAAC,CAAC,CAAC;YAEH,IAAI,QAAQ,CAAC,UAAU,IAAI,QAAQ,CAAC,UAAU,IAAI,GAAG,IAAI,QAAQ,CAAC,UAAU,GAAG,GAAG,EAAE,CAAC;gBACnF,OAAO,IAAI,CAAC;YACd,CAAC;YAED,MAAM,IAAI,KAAK,CAAC,QAAQ,CAAC,aAAa,CAAC,CAAC;QAC1C,CAAC,CAAC;QAEF,kCAAkC;QAClC,IAAI,CAAC,OAAO,CAAC,IAAI,CAAC,CAAC;IACrB,CAAC;IAED;;;;;;;;OAQG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAiB,EACjB,UAAoB,EAAc,EAClC,gBAAmC;QAEnC,yCAAyC;QACzC,OAAO,mCAAQ,eAAe,CAAC,IAAI,EAAE,gBAAgB,CAAC,GAAK,OAAO,CAAE,CAAC;QACrE,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE,CAAC;YACtB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;QAC/D,CAAC;QAED,6BAA6B;QAC7B,OAAO,YAAsC,CAAC;IAChD,CAAC;IAED;;;;OAIG;IACI,IAAI,CAAC,MAAyB;QACnC,IAAI,CAAC,YAAY,GAAG,MAAM,CAAC;QAC3B,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,eAAe,CAAC,IAAmB;QACzC,MAAM,OAAO,GAAG,MAAM,CAAC,IAAI,CAAC,CAAC;QAC7B,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAC;QACnF,OAAO,MAAM,CAAC;IAChB,CAAC;IAEO,WAAW;QACjB,MAAM,WAAW,GAAG,IAAI,CAAC,QAA+B,CAAC;QACzD,MAAM,MAAM,GAAG,WAAW,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC,CAAC;QAC3C,OAAO,IAAI,CAAC,IAAI,CAAC,aAAa,EAAE,CAAC,KAAK,CAAC,CAAC;YACtC,MAAM;SACP,CAAC,CAAC;IACL,CAAC;IAEO,aAAa;QACnB,OAAO,IAAI,CAAC,QAAQ,CAAC,QAAQ,CAAC,UAAU,CAAC,OAAO,CAAC,CAAC,CAAC,CAAC,KAAK,CAAC,CAAC,CAAC,IAAI,CAAC;IACnE,CAAC;CACF"}

package.json

 {
   "name": "@logtail/node",
-  "version": "0.5.3",
+  "version": "0.5.4",
   "description": "Better Stack Node.js logger (formerly Logtail)",
@@ -42,15 +42,13 @@ "keywords": [
     "@types/nock": "^11.1.0",
-    "nock": "^13.3.3"
+    "nock": "^14.0.1"
   },
   "dependencies": {
-    "@logtail/core": "^0.5.3",
+    "@logtail/core": "^0.5.4",
     "@logtail/types": "^0.5.3",
     "@msgpack/msgpack": "^2.5.1",
     "@types/stack-trace": "^0.0.33",
-    "cross-fetch": "^4.0.0",
     "minimatch": "^9.0.5",
-    "serialize-error": "8.1.0",
     "stack-trace": "0.0.10"
   },
-  "gitHead": "4e656e66560fa1a16f82bbb12df7ba6769ed15eb"
+  "gitHead": "0f816cacc21b352576a5707741f9151aa1481041"
 }

src/node.ts

 import { Duplex, Writable } from "stream";
 
 import { encode } from "@msgpack/msgpack";
-import { fetch } from "cross-fetch";
 import http from "node:http";
@@ -27,3 +26,3 @@ import https from "node:https";
     const sync = async (logs: ILogtailLog[]): Promise<ILogtailLog[]> => {
-      const res = await fetch(this._options.endpoint, {
+      const request = this.getHttpModule().request(this._options.endpoint, {
         method: "POST",
@@ -35,12 +34,17 @@ headers: {
         },
-        body: this.encodeAsMsgpack(logs),
-        // @ts-ignore (cross-fetch does not expose the agent option)
         agent,
       });
 
-      if (res.ok) {
+      const response: http.IncomingMessage = await new Promise((resolve, reject) => {
+        request.on("response", resolve);
+        request.on("error", reject);
+        request.write(this.encodeAsMsgpack(logs));
+        request.end();
+      });
+
+      if (response.statusCode && response.statusCode >= 200 && response.statusCode < 300) {
         return logs;
       }
 
-      throw new Error(res.statusText);
+      throw new Error(response.statusMessage);
     };
@@ -99,12 +103,10 @@
     const family = nodeOptions.useIPv6 ? 6 : 4;
-    if (nodeOptions.endpoint.startsWith("https")) {
-      return new https.Agent({
-        family,
-      });
-    }
-
-    return new http.Agent({
+    return new (this.getHttpModule().Agent)({
       family,
     });
   }
+
+  private getHttpModule(): typeof http | typeof https {
+    return this._options.endpoint.startsWith("https") ? https : http;
+  }
 }

New alerts

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Fixed alerts

Network access

Supply chain risk

This module accesses the network.

Found 1 instance in 1 package

Filesystem access

Supply chain risk

Accesses the file system, and could potentially read sensitive data.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

59383

2.02%

Dependency count

6

-25%

Lines of code

942

0.53%

Number of medium supply chain risk alerts

0

-100%

Dependency changes

• - Removed

  cross-fetch@^4.0.0

• - Removed

  serialize-error@8.1.0

• - Removed

  cross-fetch@4.1.0
  (transitive)

• - Removed

  node-fetch@2.7.0
  (transitive)

• - Removed

  tr46@0.0.3
  (transitive)

• - Removed

  webidl-conversions@3.0.1
  (transitive)

• - Removed

  whatwg-url@5.0.0
  (transitive)

• Updated

  @logtail/core@^0.5.4