From 99d7ac6a2d6530c52e2ffa8dcf0c3ff6c3414862 Mon Sep 17 00:00:00 2001 From: David Eder Date: Fri, 11 Jun 2021 19:58:58 +0200 Subject: [PATCH] Add index to event store call --- components/x_way/x_way_server.py | 11 ++--------- 1 file changed, 2 insertions(+), 9 deletions(-) diff --git a/components/x_way/x_way_server.py b/components/x_way/x_way_server.py index a3b6d9e..3c6954b 100644 --- a/components/x_way/x_way_server.py +++ b/components/x_way/x_way_server.py @@ -12,18 +12,12 @@ ENTITY_IDENT_URL = 'http://entityident:5002/api/v1/resources/' EVENT_STORE_URL = 'http://eventstore:5001/api/keys/' -@app.route('/') -def hello_world(): - return 'Hello World' - - - @app.route('/api/v1/resources/car_events', methods=['GET']) def get_cars_events(): vin = request.args.get('vin') try: - response = requests.get(EVENT_STORE_URL + 'DAF:' + vin + '/') + response = requests.get(EVENT_STORE_URL + 'DAF:' + vin + '/0/') cars = json.loads(response.text) except requests.exceptions.ConnectionError as e: @@ -32,9 +26,9 @@ def get_cars_events(): return json_util.dumps({'cursor': cars}) + @app.route('/api/v1/resources/cars', methods=['GET']) def get_cars(): - try: response = requests.get(ENTITY_IDENT_URL + 'cars') cars = response.json()['cursor'] @@ -48,7 +42,6 @@ def get_cars(): @app.route('/api/v1/resources/traffic_lights', methods=['GET']) def get_traffic_lights(): - try: response = requests.get(ENTITY_IDENT_URL + 'traffic_lights') traffic_lights = response.json()['cursor']