jaseg/infra
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

deploy/klingel: Add classification support

Browse source
This commit is contained in:
jaseg 2020-01-26 22:38:02 +01:00
parent 6345b9eec6
commit b595518607
1 changed files with 12 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

20
notification_proxy.py
View file

@ -34,10 +34,10 @@ with db as conn:
mail_routes = {}
def mail_route(name, receiver, subject, secret):
def mail_route(name, receiver, secret):
def wrap(func):
global routes
mail_routes[name] = (receiver, subject, func, secret)
mail_routes[name] = (receiver, func, secret)
return func
return wrap
@ -109,9 +109,10 @@ def authenticate(route_name, secret, clock_delta_tolerance:'s'=120):
return msg_time, payload['scope'], payload['d']
@mail_route('klingel', 'computerstuff@jaseg.de', 'It rang!', app.config['SECRET_KLINGEL'])
def klingel(rms=None, capture=None, **kwargs):
return f'rms={rms}\ncapture={capture}\nextra_args={kwargs}'
@mail_route('klingel', 'computerstuff@jaseg.de', app.config['SECRET_KLINGEL'])
def klingel(classification='somewhere', rms=None, capture=None, **kwargs):
return (f'It rang {classification}!',
f'rms={rms}\ncapture={capture}\nextra_args={kwargs}')
def send_mail(route_name, receiver, subject, body):
@ -134,13 +135,16 @@ def send_mail(route_name, receiver, subject, body):
@app.route('/v1/notify/<route_name>', methods=['POST'])
def notify(route_name):
receiver, notify_subject, func, secret = mail_routes[route_name]
receiver, func, secret = mail_routes[route_name]
msg_time, scope, kwargs = authenticate(route_name, secret)
if scope == 'default':
# Exceptions will yield a 500 error
body = func(**kwargs)
send_mail(route_name, receiver, notify_subject, body or 'empty message')
subject, body = func(**kwargs)
send_mail(route_name, receiver, subject, body or 'empty message')
elif scope == 'info':
send_mail(route_name, receiver, f'System info: {kwargs["info_msg"]}', f'Logged data: {kwargs}')
elif scope == 'boot':
formatted = datetime.utcfromtimestamp(msg_time).isoformat()