@logtail/node - npm Package Compare versions

Comparing version 0.1.2 to 0.1.3

dist/cjs/node.d.ts

@@ -36,2 +36,3 @@ /// <reference types="node" />
     private relativeToMainModule;
+    private encodeAsMsgpack;
 }

dist/cjs/node.js

@@ -10,5 +10,4 @@ "use strict";
 const stack_trace_1 = __importDefault(require("stack-trace"));
+const msgpack_1 = require("@msgpack/msgpack");
 const core_1 = require("@logtail/core");
-// Namespace the msgpack library
-// const msgpack = Msgpack();
 class Node extends core_1.Base {
@@ -22,11 +21,7 @@ constructor(accessToken, options) {
                 headers: {
-                    // "Content-Type": "application/msgpack",
-                    "Content-Type": "application/json",
+                    "Content-Type": "application/msgpack",
                     Authorization: `Bearer ${this._accessToken}`,
                     "User-Agent": "logtail-js(node)"
                 },
-                // body: logs.map(log => `${log.level}: ${log.message}`).join("\n")
-                // body: msgpack.encode(logsWithSchema).slice()
-                // TODO - using JSON for now; switch to msgpack later
-                body: JSON.stringify(logs)
+                body: this.encodeAsMsgpack(logs)
             });
@@ -36,6 +31,2 @@ if (res.ok) {
             }
-            /**
-             * TODO: if status is 50x throw custom ServerError
-             * to be used in retry logic
-             */
             throw new Error(res.statusText);
@@ -57,3 +48,2 @@ };
         context = Object.assign(Object.assign({}, this.getStackContext()), context);
-        console.log(context);
         const processedLog = await super.log(message, level, context);
@@ -107,4 +97,10 @@ // Push the processed log to the stream, for piping
     }
+    encodeAsMsgpack(logs) {
+        const logsWithISODateFormat = logs.map((log) => (Object.assign(Object.assign({}, log), { dt: log.dt.toISOString() })));
+        const encoded = msgpack_1.encode(logsWithISODateFormat);
+        const buffer = Buffer.from(encoded.buffer, encoded.byteOffset, encoded.byteLength);
+        return buffer;
+    }
 }
 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":";;;;;;AACA,+BAAyC;AAEzC,8DAAgC;AAChC,8DAAqD;AAIrD,wCAAqC;AAErC,gCAAgC;AAChC,6BAA6B;AAE7B,MAAa,IAAK,SAAQ,WAAI;IAO5B,YACE,WAAmB,EACnB,OAAkC;QAElC,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,GAAG,GAAG,MAAM,qBAAK,CACrB,IAAI,CAAC,QAAQ,CAAC,QAAQ,EACtB;gBACE,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACP,yCAAyC;oBACzC,cAAc,EAAE,kBAAkB;oBAClC,aAAa,EAAE,UAAU,IAAI,CAAC,YAAY,EAAE;oBAC5C,YAAY,EAAE,kBAAkB;iBACjC;gBACD,mEAAmE;gBACnE,+CAA+C;gBAE/C,qDAAqD;gBACrD,IAAI,EAAE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC;aAC3B,CACF,CAAC;YAEF,IAAI,GAAG,CAAC,EAAE,EAAE;gBACV,OAAO,IAAI,CAAC;aACb;YAED;;;eAGG;YACH,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;;;;;;;OAOG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAgB,EAChB,UAAoB,EAAc;QAElC,yCAAyC;QACzC,OAAO,mCAAQ,IAAI,CAAC,eAAe,EAAE,GAAK,OAAO,CAAE,CAAC;QACpD,OAAO,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE;YACrB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;SAC9D;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;IAED;;;;;OAKG;IACK,eAAe;QACrB,MAAM,UAAU,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAC1C,IAAI,UAAU,KAAK,IAAI;YAAE,OAAO,EAAE,CAAC;QAEnC,OAAO;YACL,QAAQ,EAAE,IAAI,CAAC,oBAAoB,CAAC,UAAU,CAAC,WAAW,EAAE,CAAC;YAC7D,UAAU,EAAE,UAAU,CAAC,aAAa,EAAE;SACvC,CAAC;IACJ,CAAC;IAEO,eAAe;QACrB,MAAM,KAAK,GAAG,qBAAU,CAAC,GAAG,EAAE,CAAC;QAC/B,IAAI,KAAK,KAAK,IAAI;YAAE,OAAO,IAAI,CAAC;QAEhC,MAAM,eAAe,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,CAAC;QAC/C,KAAK,IAAI,KAAK,IAAI,KAAK,EAAE;YACvB,IAAI,KAAK,CAAC,WAAW,EAAE,KAAK,eAAe;gBAAE,OAAO,KAAK,CAAC;SAC3D;QAED,OAAO,IAAI,CAAC;IACd,CAAC;IAEO,oBAAoB,CAAC,QAAgB;;QAC3C,MAAM,QAAQ,GAAG,cAAO,aAAC,OAAO,CAAC,IAAI,0CAAE,QAAQ,mCAAI,EAAE,CAAC,CAAC;QACvD,OAAO,eAAQ,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IACtC,CAAC;CACF;AArHD,oBAqHC"}
+{"version":3,"file":"node.js","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":";;;;;;AACA,+BAAyC;AAEzC,8DAAgC;AAChC,8DAAqD;AACrD,8CAA0C;AAG1C,wCAAqC;AAErC,MAAa,IAAK,SAAQ,WAAI;IAO5B,YACE,WAAmB,EACnB,OAAkC;QAElC,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,GAAG,GAAG,MAAM,qBAAK,CACrB,IAAI,CAAC,QAAQ,CAAC,QAAQ,EACtB;gBACE,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;aACjC,CACF,CAAC;YAEF,IAAI,GAAG,CAAC,EAAE,EAAE;gBACV,OAAO,IAAI,CAAC;aACb;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;;;;;;;OAOG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAgB,EAChB,UAAoB,EAAc;QAElC,yCAAyC;QACzC,OAAO,mCAAQ,IAAI,CAAC,eAAe,EAAE,GAAK,OAAO,CAAE,CAAC;QACpD,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE;YACrB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;SAC9D;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;IAED;;;;;OAKG;IACK,eAAe;QACrB,MAAM,UAAU,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAC1C,IAAI,UAAU,KAAK,IAAI;YAAE,OAAO,EAAE,CAAC;QAEnC,OAAO;YACL,QAAQ,EAAE,IAAI,CAAC,oBAAoB,CAAC,UAAU,CAAC,WAAW,EAAE,CAAC;YAC7D,UAAU,EAAE,UAAU,CAAC,aAAa,EAAE;SACvC,CAAC;IACJ,CAAC;IAEO,eAAe;QACrB,MAAM,KAAK,GAAG,qBAAU,CAAC,GAAG,EAAE,CAAC;QAC/B,IAAI,KAAK,KAAK,IAAI;YAAE,OAAO,IAAI,CAAC;QAEhC,MAAM,eAAe,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,CAAC;QAC/C,KAAK,IAAI,KAAK,IAAI,KAAK,EAAE;YACvB,IAAI,KAAK,CAAC,WAAW,EAAE,KAAK,eAAe;gBAAE,OAAO,KAAK,CAAC;SAC3D;QAED,OAAO,IAAI,CAAC;IACd,CAAC;IAEO,oBAAoB,CAAC,QAAgB;;QAC3C,MAAM,QAAQ,GAAG,cAAO,aAAC,OAAO,CAAC,IAAI,0CAAE,QAAQ,mCAAI,EAAE,CAAC,CAAC;QACvD,OAAO,eAAQ,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IACtC,CAAC;IAEO,eAAe,CAAC,IAAmB;QACzC,MAAM,qBAAqB,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,iCAAM,GAAG,KAAE,EAAE,EAAE,GAAG,CAAC,EAAE,CAAC,WAAW,EAAE,IAAG,CAAC,CAAC;QACxF,MAAM,OAAO,GAAG,gBAAM,CAAC,qBAAqB,CAAC,CAAC;QAC9C,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QAClF,OAAO,MAAM,CAAC;IAChB,CAAC;CACF;AAlHD,oBAkHC"}

dist/es6/node.d.ts

@@ -36,2 +36,3 @@ /// <reference types="node" />
     private relativeToMainModule;
+    private encodeAsMsgpack;
 }

dist/es6/node.js

 import { dirname, relative } from "path";
 import fetch from "cross-fetch";
 import stackTrace from 'stack-trace';
+import { encode } from "@msgpack/msgpack";
 import { Base } from "@logtail/core";
-// Namespace the msgpack library
-// const msgpack = Msgpack();
 export class Node extends Base {
@@ -15,11 +14,7 @@ constructor(accessToken, options) {
                 headers: {
-                    // "Content-Type": "application/msgpack",
-                    "Content-Type": "application/json",
+                    "Content-Type": "application/msgpack",
                     Authorization: `Bearer ${this._accessToken}`,
                     "User-Agent": "logtail-js(node)"
                 },
-                // body: logs.map(log => `${log.level}: ${log.message}`).join("\n")
-                // body: msgpack.encode(logsWithSchema).slice()
-                // TODO - using JSON for now; switch to msgpack later
-                body: JSON.stringify(logs)
+                body: this.encodeAsMsgpack(logs)
             });
@@ -29,6 +24,2 @@ if (res.ok) {
             }
-            /**
-             * TODO: if status is 50x throw custom ServerError
-             * to be used in retry logic
-             */
             throw new Error(res.statusText);
@@ -50,3 +41,2 @@ };
         context = Object.assign(Object.assign({}, this.getStackContext()), context);
-        console.log(context);
         const processedLog = await super.log(message, level, context);
@@ -100,3 +90,9 @@ // Push the processed log to the stream, for piping
     }
+    encodeAsMsgpack(logs) {
+        const logsWithISODateFormat = logs.map((log) => (Object.assign(Object.assign({}, log), { dt: log.dt.toISOString() })));
+        const encoded = encode(logsWithISODateFormat);
+        const buffer = Buffer.from(encoded.buffer, encoded.byteOffset, encoded.byteLength);
+        return buffer;
+    }
 }
 //# 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":"AACA,OAAO,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,MAAM,CAAC;AAEzC,OAAO,KAAK,MAAM,aAAa,CAAC;AAChC,OAAO,UAA0B,MAAM,aAAa,CAAC;AAIrD,OAAO,EAAE,IAAI,EAAE,MAAM,eAAe,CAAC;AAErC,gCAAgC;AAChC,6BAA6B;AAE7B,MAAM,OAAO,IAAK,SAAQ,IAAI;IAO5B,YACE,WAAmB,EACnB,OAAkC;QAElC,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,GAAG,GAAG,MAAM,KAAK,CACrB,IAAI,CAAC,QAAQ,CAAC,QAAQ,EACtB;gBACE,MAAM,EAAE,MAAM;gBACd,OAAO,EAAE;oBACP,yCAAyC;oBACzC,cAAc,EAAE,kBAAkB;oBAClC,aAAa,EAAE,UAAU,IAAI,CAAC,YAAY,EAAE;oBAC5C,YAAY,EAAE,kBAAkB;iBACjC;gBACD,mEAAmE;gBACnE,+CAA+C;gBAE/C,qDAAqD;gBACrD,IAAI,EAAE,IAAI,CAAC,SAAS,CAAC,IAAI,CAAC;aAC3B,CACF,CAAC;YAEF,IAAI,GAAG,CAAC,EAAE,EAAE;gBACV,OAAO,IAAI,CAAC;aACb;YAED;;;eAGG;YACH,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;;;;;;;OAOG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAgB,EAChB,UAAoB,EAAc;QAElC,yCAAyC;QACzC,OAAO,mCAAQ,IAAI,CAAC,eAAe,EAAE,GAAK,OAAO,CAAE,CAAC;QACpD,OAAO,CAAC,GAAG,CAAC,OAAO,CAAC,CAAC;QACrB,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE;YACrB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;SAC9D;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;IAED;;;;;OAKG;IACK,eAAe;QACrB,MAAM,UAAU,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAC1C,IAAI,UAAU,KAAK,IAAI;YAAE,OAAO,EAAE,CAAC;QAEnC,OAAO;YACL,QAAQ,EAAE,IAAI,CAAC,oBAAoB,CAAC,UAAU,CAAC,WAAW,EAAE,CAAC;YAC7D,UAAU,EAAE,UAAU,CAAC,aAAa,EAAE;SACvC,CAAC;IACJ,CAAC;IAEO,eAAe;QACrB,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;QAC/B,IAAI,KAAK,KAAK,IAAI;YAAE,OAAO,IAAI,CAAC;QAEhC,MAAM,eAAe,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,CAAC;QAC/C,KAAK,IAAI,KAAK,IAAI,KAAK,EAAE;YACvB,IAAI,KAAK,CAAC,WAAW,EAAE,KAAK,eAAe;gBAAE,OAAO,KAAK,CAAC;SAC3D;QAED,OAAO,IAAI,CAAC;IACd,CAAC;IAEO,oBAAoB,CAAC,QAAgB;;QAC3C,MAAM,QAAQ,GAAG,OAAO,aAAC,OAAO,CAAC,IAAI,0CAAE,QAAQ,mCAAI,EAAE,CAAC,CAAC;QACvD,OAAO,QAAQ,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IACtC,CAAC;CACF"}
+{"version":3,"file":"node.js","sourceRoot":"","sources":["../../src/node.ts"],"names":[],"mappings":"AACA,OAAO,EAAE,OAAO,EAAE,QAAQ,EAAE,MAAM,MAAM,CAAC;AAEzC,OAAO,KAAK,MAAM,aAAa,CAAC;AAChC,OAAO,UAA0B,MAAM,aAAa,CAAC;AACrD,OAAO,EAAE,MAAM,EAAE,MAAM,kBAAkB,CAAC;AAG1C,OAAO,EAAE,IAAI,EAAE,MAAM,eAAe,CAAC;AAErC,MAAM,OAAO,IAAK,SAAQ,IAAI;IAO5B,YACE,WAAmB,EACnB,OAAkC;QAElC,KAAK,CAAC,WAAW,EAAE,OAAO,CAAC,CAAC;QAE5B,gBAAgB;QAChB,MAAM,IAAI,GAAG,KAAK,EAAE,IAAmB,EAA0B,EAAE;YACjE,MAAM,GAAG,GAAG,MAAM,KAAK,CACrB,IAAI,CAAC,QAAQ,CAAC,QAAQ,EACtB;gBACE,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;aACjC,CACF,CAAC;YAEF,IAAI,GAAG,CAAC,EAAE,EAAE;gBACV,OAAO,IAAI,CAAC;aACb;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;;;;;;;OAOG;IACI,KAAK,CAAC,GAAG,CACd,OAAe,EACf,KAAgB,EAChB,UAAoB,EAAc;QAElC,yCAAyC;QACzC,OAAO,mCAAQ,IAAI,CAAC,eAAe,EAAE,GAAK,OAAO,CAAE,CAAC;QACpD,MAAM,YAAY,GAAG,MAAM,KAAK,CAAC,GAAG,CAAC,OAAO,EAAE,KAAK,EAAE,OAAO,CAAC,CAAC;QAE9D,mDAAmD;QACnD,IAAI,IAAI,CAAC,YAAY,EAAE;YACrB,IAAI,CAAC,YAAY,CAAC,KAAK,CAAC,IAAI,CAAC,SAAS,CAAC,YAAY,CAAC,GAAG,IAAI,CAAC,CAAC;SAC9D;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;IAED;;;;;OAKG;IACK,eAAe;QACrB,MAAM,UAAU,GAAG,IAAI,CAAC,eAAe,EAAE,CAAC;QAC1C,IAAI,UAAU,KAAK,IAAI;YAAE,OAAO,EAAE,CAAC;QAEnC,OAAO;YACL,QAAQ,EAAE,IAAI,CAAC,oBAAoB,CAAC,UAAU,CAAC,WAAW,EAAE,CAAC;YAC7D,UAAU,EAAE,UAAU,CAAC,aAAa,EAAE;SACvC,CAAC;IACJ,CAAC;IAEO,eAAe;QACrB,MAAM,KAAK,GAAG,UAAU,CAAC,GAAG,EAAE,CAAC;QAC/B,IAAI,KAAK,KAAK,IAAI;YAAE,OAAO,IAAI,CAAC;QAEhC,MAAM,eAAe,GAAG,KAAK,CAAC,CAAC,CAAC,CAAC,WAAW,EAAE,CAAC;QAC/C,KAAK,IAAI,KAAK,IAAI,KAAK,EAAE;YACvB,IAAI,KAAK,CAAC,WAAW,EAAE,KAAK,eAAe;gBAAE,OAAO,KAAK,CAAC;SAC3D;QAED,OAAO,IAAI,CAAC;IACd,CAAC;IAEO,oBAAoB,CAAC,QAAgB;;QAC3C,MAAM,QAAQ,GAAG,OAAO,aAAC,OAAO,CAAC,IAAI,0CAAE,QAAQ,mCAAI,EAAE,CAAC,CAAC;QACvD,OAAO,QAAQ,CAAC,QAAQ,EAAE,QAAQ,CAAC,CAAC;IACtC,CAAC;IAEO,eAAe,CAAC,IAAmB;QACzC,MAAM,qBAAqB,GAAG,IAAI,CAAC,GAAG,CAAC,CAAC,GAAG,EAAE,EAAE,CAAC,iCAAM,GAAG,KAAE,EAAE,EAAE,GAAG,CAAC,EAAE,CAAC,WAAW,EAAE,IAAG,CAAC,CAAC;QACxF,MAAM,OAAO,GAAG,MAAM,CAAC,qBAAqB,CAAC,CAAC;QAC9C,MAAM,MAAM,GAAG,MAAM,CAAC,IAAI,CAAC,OAAO,CAAC,MAAM,EAAE,OAAO,CAAC,UAAU,EAAE,OAAO,CAAC,UAAU,CAAC,CAAA;QAClF,OAAO,MAAM,CAAC;IAChB,CAAC;CACF"}

package.json

 {
   "name": "@logtail/node",
-  "version": "0.1.2",
+  "version": "0.1.3",
   "description": "Logtail.com - Node.js logger",
@@ -48,10 +48,9 @@ "keywords": [
     "@logtail/types": "^0.1.1",
-    "@types/msgpack5": "^3.4.1",
+    "@msgpack/msgpack": "^2.5.1",
     "@types/stack-trace": "^0.0.29",
     "cross-fetch": "^3.0.4",
     "minimatch": "^3.0.4",
-    "msgpack5": "^4.2.1",
     "stack-trace": "^0.0.10"
   },
-  "gitHead": "873fa10329cdfae0bd2f8d0d80fc7e595c0ff2b6"
+  "gitHead": "65148cfaceb530f4cef925e74cf1ade256dfc579"
 }

src/node.ts

@@ -6,3 +6,3 @@ import { Duplex, Writable } from "stream";
 import stackTrace, { StackFrame } from 'stack-trace';
-// import Msgpack from "msgpack5";
+import { encode } from "@msgpack/msgpack";
 
@@ -12,5 +12,2 @@ import { ILogtailLog, Context, ILogtailOptions, LogLevel } from "@logtail/types";
 
-// Namespace the msgpack library
-// const msgpack = Msgpack();
-
 export class Node extends Base {
@@ -36,12 +33,7 @@ /**
           headers: {
-            // "Content-Type": "application/msgpack",
-            "Content-Type": "application/json",
+            "Content-Type": "application/msgpack",
             Authorization: `Bearer ${this._accessToken}`,
             "User-Agent": "logtail-js(node)"
           },
-          // body: logs.map(log => `${log.level}: ${log.message}`).join("\n")
-          // body: msgpack.encode(logsWithSchema).slice()
-
-          // TODO - using JSON for now; switch to msgpack later
-          body: JSON.stringify(logs)
+          body: this.encodeAsMsgpack(logs)
         }
@@ -54,6 +46,2 @@ );
 
-      /**
-       * TODO: if status is 50x throw custom ServerError
-       * to be used in retry logic
-       */
       throw new Error(res.statusText);
@@ -81,3 +69,2 @@ };
     context = { ...this.getStackContext(), ...context };
-    console.log(context);
     const processedLog = await super.log(message, level, context);
@@ -136,2 +123,9 @@
   }
+
+  private encodeAsMsgpack(logs: ILogtailLog[]): Buffer {
+    const logsWithISODateFormat = logs.map((log) => ({ ...log, dt: log.dt.toISOString() }));
+    const encoded = encode(logsWithISODateFormat);
+    const buffer = Buffer.from(encoded.buffer, encoded.byteOffset, encoded.byteLength)
+    return buffer;
+  }
 }

New 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

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

45655

0.33%

Dependency count

7

-12.5%

Worsened metrics

Lines of code

758

-1.43%

Dependency changes

• + Added

  @msgpack/msgpack@^2.5.1

• + Added

  @msgpack/msgpack@2.8.0
  (transitive)

• - Removed

  @types/msgpack5@^3.4.1

• - Removed

  msgpack5@^4.2.1

• - Removed

  @types/msgpack5@3.4.6
  (transitive)

• - Removed

  @types/node@25.6.0
  (transitive)

• - Removed

  @types/readable-stream@4.0.23
  (transitive)

• - Removed

  bl@2.2.17.0.0
  (transitive)

• - Removed

  core-util-is@1.0.3
  (transitive)

• - Removed

  inherits@2.0.4
  (transitive)

• - Removed

  isarray@1.0.0
  (transitive)

• - Removed

  msgpack5@4.5.1
  (transitive)

• - Removed

  process-nextick-args@2.0.1
  (transitive)

• - Removed

  readable-stream@2.3.8
  (transitive)

• - Removed

  safe-buffer@5.1.25.2.1
  (transitive)

• - Removed

  string_decoder@1.1.1
  (transitive)

• - Removed

  undici-types@7.19.2
  (transitive)

• - Removed

  util-deprecate@1.0.2
  (transitive)