From 0854c6d60d925bed223f0d7cea2a79e77b8e819f Mon Sep 17 00:00:00 2001
From: Mark Veidemanis <mark.veidemanis@pathogen.is>
Date: Tue, 24 Aug 2021 20:08:18 +0000
Subject: [PATCH] Add Logstash file

---
 core/logstash.py | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)
 create mode 100644 core/logstash.py

diff --git a/core/logstash.py b/core/logstash.py
new file mode 100644
index 0000000..aa5924b
--- /dev/null
+++ b/core/logstash.py
@@ -0,0 +1,19 @@
+import logstash
+import logging
+
+from json import dumps, loads
+import main
+from utils.logging.log import *
+
+logger = None
+def init_logstash():
+    global logger
+    logger = logging.getLogger('ingest')
+    logger.setLevel(logging.INFO)
+    logger.addHandler(logstash.TCPLogstashHandler(main.config["Logstash"]["Host"], int(main.config["Logstash"]["Port"]), version=1))
+
+def sendLogstashNotification(text):
+    if not logger == None:
+        logger.info(dumps(text))
+        return True
+    return False