mirror of
https://github.com/FAUSheppy/icinga-webhook-gateway
synced 2025-12-06 07:21:38 +01:00
104 lines
3.3 KiB
Python
104 lines
3.3 KiB
Python
import icinga2api
|
|
import icinga2api.client
|
|
|
|
def _create_client(app):
|
|
|
|
api_user = app.config["ICINGA_API_USER"]
|
|
api_pass = app.config["ICINGA_API_PASS"]
|
|
api_url = app.config["ICINGA_API_URL"]
|
|
|
|
client = icinga2api.client.Client(api_url, api_user, api_pass)
|
|
return client
|
|
|
|
def create_master_host(app):
|
|
|
|
client = _create_client(app)
|
|
host_name = app.config["ASYNC_ICINGA_DUMMY_HOST"]
|
|
|
|
try:
|
|
response = client.objects.get("Host", host_name)
|
|
return
|
|
except icinga2api.exceptions.Icinga2ApiException as e:
|
|
ICINGA_NO_OBJECTS_RESPONSE = "No objects found"
|
|
if not len(e.args) >= 1 or ICINGA_NO_OBJECTS_RESPONSE not in e.args[0]:
|
|
raise RuntimeError("Failed to query Icinga Server to check for dummy host: {}".format(e))
|
|
|
|
host_config = {
|
|
"templates": ["generic-host"],
|
|
"attrs": {
|
|
"display_name": "ASYNC_ICINGA_SINK",
|
|
"address": "localhost",
|
|
"check_command": "ping",
|
|
}
|
|
}
|
|
|
|
# Create the host
|
|
response = client.objects.create("Host", host_name, **host_config)
|
|
|
|
def _build_service_name(user, async_service_name):
|
|
|
|
return "{}_async_{}".format(user, async_service_name)
|
|
|
|
def create_service(user, async_service_name, app):
|
|
|
|
if not app.config.get("ICINGA_API_URL"):
|
|
return
|
|
|
|
client = _create_client(app)
|
|
name = _build_service_name(user, async_service_name)
|
|
host_name = app.config["ASYNC_ICINGA_DUMMY_HOST"]
|
|
|
|
service_config = {
|
|
"templates": ["generic-service"],
|
|
"attrs": {
|
|
"display_name": name,
|
|
"check_command": "gateway",
|
|
"host_name" : host_name,
|
|
"vars" : {
|
|
"host" : "async-icinga.atlantishq.de",
|
|
"service_name" : async_service_name,
|
|
"protocol" : "https",
|
|
"owner" : user
|
|
}
|
|
}
|
|
}
|
|
|
|
# Create the service (name is required in this format)
|
|
service_api_helper_name = "{}!{}".format(host_name, name)
|
|
print(service_api_helper_name)
|
|
response = client.objects.create("Service", service_api_helper_name, **service_config)
|
|
|
|
def delete_service(user, async_service_name, app):
|
|
|
|
if not app.config.get("ICINGA_API_URL"):
|
|
return
|
|
|
|
client = _create_client(app)
|
|
name = _build_service_name(user, async_service_name)
|
|
host_name = app.config["ASYNC_ICINGA_DUMMY_HOST"]
|
|
service_api_helper_name = "{}!{}".format(host_name, name)
|
|
|
|
client.objects.delete("Service", service_api_helper_name)
|
|
|
|
def build_icinga_link_for_service(user, service_name, static_configured, app):
|
|
|
|
name = _build_service_name(user, service_name)
|
|
url_fmt = "{base}/icingaweb2/dashboard/#!/icingaweb2/monitoring/service/show?host={host}&service={service}"
|
|
|
|
if static_configured:
|
|
url_fmt = "{base}/icingaweb2/monitoring/list/services?service={service}&modifyFilter=1"
|
|
name = service_name
|
|
|
|
icinga_web_url = app.config.get("ICINGA_WEB_URL")
|
|
if not icinga_web_url:
|
|
icinga_web_url = "ICINGA_WEB_URL_NOT_SET:"
|
|
|
|
dummy_host=app.config.get("ASYNC_ICINGA_DUMMY_HOST")
|
|
if not dummy_host:
|
|
dummy_host = "ASYNC_ICINGA_DUMMY_HOST_NOT_SET:"
|
|
|
|
return url_fmt.format(base=icinga_web_url,
|
|
host=dummy_host,
|
|
service=name)
|
|
|