From 28441c0a6139ed803147f0cdb24aa9d0fc579617 Mon Sep 17 00:00:00 2001 From: Jiri Vrany Date: Tue, 25 Feb 2025 15:21:06 +0100 Subject: [PATCH 1/2] fixed json output for route if exabgp process http api is used --- flowapp/output.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flowapp/output.py b/flowapp/output.py index e286827..18da6d5 100644 --- a/flowapp/output.py +++ b/flowapp/output.py @@ -45,7 +45,9 @@ def announce_route(route: Route): if current_app.config.get("EXA_API") == "RABBIT": announce_to_rabbitmq(asdict(route)) else: - announce_to_http(asdict(route)) + route_dict = asdict(route) + print("route", route_dict) + announce_to_http(json.dumps(route_dict)) def announce_to_http(route): From 4a119840475aa9583bb56f889e4452c7e1dc9d70 Mon Sep 17 00:00:00 2001 From: Jiri Vrany Date: Tue, 25 Feb 2025 15:28:52 +0100 Subject: [PATCH 2/2] fixed json output for route if exabgp process http api is used --- flowapp/output.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/flowapp/output.py b/flowapp/output.py index 18da6d5..3dde822 100644 --- a/flowapp/output.py +++ b/flowapp/output.py @@ -45,9 +45,7 @@ def announce_route(route: Route): if current_app.config.get("EXA_API") == "RABBIT": announce_to_rabbitmq(asdict(route)) else: - route_dict = asdict(route) - print("route", route_dict) - announce_to_http(json.dumps(route_dict)) + announce_to_http(asdict(route)) def announce_to_http(route): @@ -56,7 +54,7 @@ def announce_to_http(route): """ if not current_app.config["TESTING"]: try: - resp = requests.post(current_app.config["EXA_API_URL"], data={"command": route}) + resp = requests.post(current_app.config["EXA_API_URL"], data={"command": json.dumps(route)}) resp.raise_for_status() except requests.exceptions.HTTPError as err: current_app.logger.error("ExaAPI HTTP Error: ", err)