new module

Author: Abhinav Gautam

app.ts

@@ -3,7 +3,8 @@ import pm2 from "pm2";
 import os from "os";
 import winston from "winston";
 import stripAnsi from "strip-ansi";
-import LogstashTransport from "winston-logstash/lib/winston-logstash-latest.js";
+//import LogstashTransport from "winston-logstash/lib/winston-logstash-latest.js";
+import { LogserverTransport } from "winston-logserver-transport";
 
 dotenv.config();
 
@@ -14,13 +15,9 @@ const hostname = os.hostname();
 const logger = winston.createLogger();
 
 logger.add(
-  new LogstashTransport({
-    port: LOGSTASH_PORT,
-    host: LOGSTASH_HOST,
-    ssl_enable: true,
-    ssl_key: SSL_KEY_PATH,
-    ssl_cert: SSL_CERT_PATH,
-    rejectUnauthorized: false, //Does Not Work Without This Apparently
+  new LogserverTransport({
+    apiBaseUrl: process.env.LOGSERVER_BASEURL,
+    apiKey: process.env.LOGSERVER_API_KEY,
   })
 );
 
@@ -55,8 +52,8 @@ pm2.launchBus(function (err, bus) {
           service: "PM2",
           application: log.process.name,
           environment: errorFlag ? "error" : "output",
-          level: errorFlag ? "error" : "info",
-          user: hostname,
+          logLevel: errorFlag ? "error" : "info",
+          host: hostname,
           message: log.data,
         };
         logger.info(message);
@@ -73,8 +70,8 @@ pm2.launchBus(function (err, bus) {
         service: "PM2",
         application: log.process.name,
         environment: "error",
-        level: "error",
-        user: hostname,
+        logLevel: "error",
+        host: hostname,
         message: log.data,
       };
       logger.error(message);

dist/app.js

@@ -3,18 +3,15 @@ import pm2 from "pm2";
 import os from "os";
 import winston from "winston";
 import stripAnsi from "strip-ansi";
-import LogstashTransport from "winston-logstash/lib/winston-logstash-latest.js";
+//import LogstashTransport from "winston-logstash/lib/winston-logstash-latest.js";
+import { LogserverTransport } from "winston-logserver-transport";
 dotenv.config();
 const { LOGSTASH_HOST, LOGSTASH_PORT, SSL_CERT_PATH, SSL_KEY_PATH } = process.env;
 const hostname = os.hostname();
 const logger = winston.createLogger();
-logger.add(new LogstashTransport({
-    port: LOGSTASH_PORT,
-    host: LOGSTASH_HOST,
-    ssl_enable: true,
-    ssl_key: SSL_KEY_PATH,
-    ssl_cert: SSL_CERT_PATH,
-    rejectUnauthorized: false, //Does Not Work Without This Apparently
+logger.add(new LogserverTransport({
+    apiBaseUrl: process.env.LOGSERVER_BASEURL,
+    apiKey: process.env.LOGSERVER_API_KEY,
 }));
 logger.on("error", (error) => {
     console.log(error);
@@ -35,8 +32,8 @@ pm2.launchBus(function (err, bus) {
                     service: "PM2",
                     application: log.process.name,
                     environment: errorFlag ? "error" : "output",
-                    level: errorFlag ? "error" : "info",
-                    user: hostname,
+                    logLevel: errorFlag ? "error" : "info",
+                    host: hostname,
                     message: log.data,
                 };
                 logger.info(message);
@@ -52,8 +49,8 @@ pm2.launchBus(function (err, bus) {
                 service: "PM2",
                 application: log.process.name,
                 environment: "error",
-                level: "error",
-                user: hostname,
+                logLevel: "error",
+                host: hostname,
                 message: log.data,
             };
             logger.error(message);

package.json

@@ -9,6 +9,7 @@
     "pm2": "^5.3.1",
     "strip-ansi": "^7.1.0",
     "winston": "^3.13.0",
+    "winston-logserver-transport": "github:Codebucket-Solutions/Winston-Logstash-Batch-Server-Transport",
     "winston-logstash": "^1.2.1"
   },
   "name": "pm2-logstash-typescript",