sheppy/atlantis-event-dispatcher
1
0
Fork 0
mirror of https://github.com/FAUSheppy/atlantis-event-dispatcher synced 2025-12-10 00:08:33 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Compare commits

base: sheppy:df1dfd8b0c4329acf4d846e6685f1510257b149a
Branches Tags
sheppy:master sheppy:dev sheppy:ldap-ng-dev
...
compare: sheppy:178ba5451de324f673f663f98f3a85093a204033
Branches Tags
sheppy:master sheppy:dev sheppy:ldap-ng-dev

2 Commits
df1dfd8b0c ... 178ba5451d

Author SHA1 Message Date
Yannik Schmidt
178ba5451d fix: make os header optional
Some checks failed
ci / docker (push) Failing after 47s
Details
2024-11-23 23:22:14 +01:00
Yannik Schmidt
14612016af feat: add opensearch support 2024-11-23 23:15:31 +01:00
1 changed files with 24 additions and 7 deletions
Expand all files Collapse all files

21
server/interface.py
View File

@@ -20,7 +20,7 @@ import sqlalchemy
from flask_sqlalchemy import SQLAlchemy from flask_sqlalchemy import SQLAlchemy
from sqlalchemy.sql.expression import func from sqlalchemy.sql.expression import func
OPENSEARCH_HEADER_SEPERATOR = ","
HOST = "icinga.atlantishq.de" HOST = "icinga.atlantishq.de"
app = flask.Flask("Signal Notification Gateway") app = flask.Flask("Signal Notification Gateway")
app.config["SQLALCHEMY_DATABASE_URI"] = "sqlite:///sqlite.db" app.config["SQLALCHEMY_DATABASE_URI"] = "sqlite:///sqlite.db"
@@ -357,8 +357,25 @@ def smart_send_to_clients(path=None):
- supported struct of type "ICINGA|ZABBIX|GENERIC" (see docs) in field "data" - supported struct of type "ICINGA|ZABBIX|GENERIC" (see docs) in field "data"
''' '''
instructions = flask.request.json if flask.request.headers.get("opensearch"):
instructions = {}
users = flask.request.headers.get("opensearch-users")
groups = flask.request.headers.get("opensearch-groups")
if groups and OPENSEARCH_HEADER_SEPERATOR in groups:
groups = groups.split(OPENSEARCH_HEADER_SEPERATOR)
if users and OPENSEARCH_HEADER_SEPERATOR in users:
users = users.split(OPENSEARCH_HEADER_SEPERATOR)
message = flask.request.get_data(as_text=True)
title = "Opensearch Alert"
method = None
else:
instructions = flask.request.json
users = instructions.get("users") users = instructions.get("users")
groups = instructions.get("groups") groups = instructions.get("groups")
message = instructions.get("msg") message = instructions.get("msg")