From 00aa136ae664675d6632c56af7d33e650167211b Mon Sep 17 00:00:00 2001 From: Rob Kooper Date: Wed, 17 Apr 2024 08:40:48 -0500 Subject: [PATCH] catch exception on cdrhook failure --- CHANGELOG.md | 3 +++ server/server.py | 7 ++++++- 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index aeaf432..fa59606 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -6,6 +6,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/). ## [0.1.0] - 2024-04-16 +### Added +- if cdrhook fails, push message to cdrhook.error + ### Changed - uploaded will now load cdr json and add cog_id, system and system_version. diff --git a/server/server.py b/server/server.py index 7a5c73f..0ae3c85 100644 --- a/server/server.py +++ b/server/server.py @@ -100,7 +100,12 @@ def hook(): if data.get("event") == "ping": logging.debug("Received ping") elif data.get("event") == "map.process": - process_map(data["payload"]["cog_id"], data["payload"]["cog_url"]) + try: + process_map(data["payload"]["cog_id"], data["payload"]["cog_url"]) + except: + logging.exception("Could not process hook") + data["x-cdr-signature-256"] = request.data, request.headers.get("x-cdr-signature-256") + send_message(data, "cdrhook.error") else: logging.debug("Unknown event: %s", data.get("event"))