added logType

index.js

@@ -340,28 +340,38 @@ Logsene.prototype.diskBuffer = function (enabled, dir) {
  */
 Logsene.prototype.log = function (level, message, fields, callback) {
   this.logCount = this.logCount + 1
-  var type = fields ? fields._type : this.type
+  let type = 'logs'
+  let logType = 'logs'
+
+  if (fields) {
+    logType = fields._type
+  }
+
   if (this.options.useIndexInBulkUrl) {
     // not a Sematext service -> use only one type per index
     // Elasticsearch > 6.x allows only one type per index
     type = this.type
   }
-  var elasticsearchDocId = null
-  if (fields && fields._type) {
-    delete fields._type
-  }
-  if (fields && fields._id) {
-    elasticsearchDocId = fields._id
-  }
+
   var msg = {
     '@timestamp': new Date(),
-    message: message,
     severity: level,
+    message,
+    logType,
     os: {
       host: this.hostname,
       hostip: ipAddress
     }
   }
+
+  var elasticsearchDocId = null
+  if (fields && fields._type) {
+    delete fields._type
+  }
+  if (fields && fields._id) {
+    elasticsearchDocId = fields._id
+  }
+
   if (disableJsonEnrichment) {
     msg = {}
   }