conf/example/config.json

@@ -24,6 +24,10 @@
         "User": "sir",
         "Password": "sir"
     },
+    "Logstash": {
+        "Host": "10.0.0.2",
+        "Port": "4000"
+    },
     "ChanKeep": {
         "MaxRelay": 30,
         "SigSwitch": 20

modules/monitor.py

@@ -3,6 +3,7 @@ from json import dumps
 
 import main
 from core.relay import sendRelayNotification
+from core.logstash import sendLogstashNotification
 from modules import userinfo
 from modules import regproc
 from utils.dedup import dedup
@@ -47,4 +48,7 @@ def event(numName, c): # yes I'm using a short variable because otherwise it goe
 
     if "muser" in c.keys():
         del c["muser"]
-    sendRelayNotification({k: c[k] for k in order if k in c}) # Sort dict keys according to order
+    sortedKeys = {k: c[k] for k in order if k in c} # Sort dict keys according to order
+    sortedKeys["src"] = "irc"
+    sendLogstashNotification(sortedKeys)
+    sendRelayNotification(sortedKeys)

threshold

@@ -25,6 +25,8 @@ from core.server import Server, ServerFactory
 from core.relay import Relay, RelayFactory
 import modules.counters
 loadCommands()
+import core.logstash
+core.logstash.init_logstash()
 
 if __name__ == "__main__":
     listener = ServerFactory()