fix(logstash-http,logstash-udp): Fix extra logs in logstash

tsedio · Apr 2, 2021 · d9140c3 · d9140c3
1 parent f6a5dfc
commit d9140c3
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 4 deletions.
diff --git a/packages/logstash-http/src/LogStashHttpAppender.ts b/packages/logstash-http/src/LogStashHttpAppender.ts
@@ -55,14 +55,13 @@ export class LogStashHttpAppender extends BaseAppender {
           },
         },
         {
-          ...isMessage ? loggingEvent.data[0] : {},
+          ...!isMessage ? loggingEvent.data[0] : {},
           message: isMessage ? format(loggingEvent.data) : undefined,
           context: loggingEvent.context.toJSON(),
           level: loggingEvent.level.level / 100,
           level_name: level,
           channel: logChannel,
-          datetime: (new Date(loggingEvent.startTime)).toISOString(),
-          extra: {},
+          datetime: (new Date(loggingEvent.startTime)).toISOString()
         },
       ];
 

diff --git a/packages/logstash-udp/src/LogStashUdpAppender.ts b/packages/logstash-udp/src/LogStashUdpAppender.ts
@@ -37,7 +37,7 @@ export class LogStashUdpAppender extends BaseAppender {
     if (level !== "off") {
       const isMessage = loggingEvent.data.length && typeof loggingEvent.data[0] !== "object";
       const oriLogObject = {
-        ...isMessage ? loggingEvent.data[0] : {},
+        ...!isMessage ? loggingEvent.data[0] : {},
         "@version": defaultVersion,
         "@timestamp": (new Date(loggingEvent.startTime)).toISOString(),
         "host": os.hostname(),