From f8258117f4bb15020355bf67d119a17e2dd3a823 Mon Sep 17 00:00:00 2001 From: Jean-Marie Mineau Date: Thu, 7 Oct 2021 17:24:13 +0200 Subject: [PATCH] add health endpoint --- src/kassandra/webhook.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/src/kassandra/webhook.py b/src/kassandra/webhook.py index d0c70c4..1a6ef09 100644 --- a/src/kassandra/webhook.py +++ b/src/kassandra/webhook.py @@ -24,13 +24,19 @@ async def run_webhook( Run the webhook endpoint and put the alerts in the queue. """ - async def handler(request:aiohttp.web_request.Request): + async def handler(request:aiohttp.web_request.Request)->aiohttp.web.Response: alert = await request.json() await alert_queue.put(alert) return aiohttp.web.Response() + async def health(request:aiohttp.web_request.Request)->aiohttp.web.Response: + return aiohttp.web.Response(text="OK") + app = aiohttp.web.Application() - app.add_routes([aiohttp.web.post(config.endpoint, handler)]) + app.add_routes([ + aiohttp.web.post(config.endpoint, handler), + aiohttp.web.get("/health", health) + ]) runner = aiohttp.web.AppRunner(app) await runner.setup() ssl_context = None