histausse/kassandra
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

setup the structure to use ssl

Browse source
This commit is contained in:
histausse 2021-10-07 17:18:55 +02:00
parent cb55318b91
commit d89c0a2626
Signed by: histausse
GPG key ID: 67486F107F62E9E9
1 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/kassandra/webhook.py
View file

@ -5,6 +5,7 @@ The webhook receiving the alerts from alertmanager.
import asyncio import asyncio
import aiohttp.web import aiohttp.web
import aiohttp.web_request import aiohttp.web_request
import ssl
from typing import ( from typing import (
Any, Any,
@ -12,6 +13,9 @@ from typing import (
) )
from .config import Config from .config import Config
def load_ssl_context(config:Config)->ssl.SSLContext:
pass
async def run_webhook( async def run_webhook(
alert_queue: asyncio.Queue[dict[str, Any]], alert_queue: asyncio.Queue[dict[str, Any]],
config: Config config: Config
@ -29,5 +33,8 @@ async def run_webhook(
app.add_routes([aiohttp.web.post(config.endpoint, handler)]) app.add_routes([aiohttp.web.post(config.endpoint, handler)])
runner = aiohttp.web.AppRunner(app) runner = aiohttp.web.AppRunner(app)
await runner.setup() await runner.setup()
site = aiohttp.web.TCPSite(runner, config.host, config.port) ssl_context = None
if config.tls:
ssl_context = load_ssl_context(config)
site = aiohttp.web.TCPSite(runner, config.host, config.port, ssl_context=ssl_context)
await site.start() await site.start()