From 5d337d6d258e7c1881062bdf9d53c8b4e36d8066 Mon Sep 17 00:00:00 2001 From: David Eder Date: Wed, 9 Jun 2021 22:15:42 +0200 Subject: [PATCH] Add event store connection --- components/x_way/requirements.txt | 3 ++- components/x_way/x_way_server.py | 18 ++++++++++++++++++ 2 files changed, 20 insertions(+), 1 deletion(-) diff --git a/components/x_way/requirements.txt b/components/x_way/requirements.txt index 9a6b8ec..55c2263 100644 --- a/components/x_way/requirements.txt +++ b/components/x_way/requirements.txt @@ -1,2 +1,3 @@ flask -Flask-Cors \ No newline at end of file +Flask-Cors +requests \ No newline at end of file diff --git a/components/x_way/x_way_server.py b/components/x_way/x_way_server.py index b094262..a3b6d9e 100644 --- a/components/x_way/x_way_server.py +++ b/components/x_way/x_way_server.py @@ -2,11 +2,14 @@ import requests from bson import json_util from flask import Flask from flask_cors import CORS +from flask import request +import json; app = Flask(__name__) CORS(app) ENTITY_IDENT_URL = 'http://entityident:5002/api/v1/resources/' +EVENT_STORE_URL = 'http://eventstore:5001/api/keys/' @app.route('/') @@ -14,6 +17,21 @@ 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 + '/') + cars = json.loads(response.text) + + except requests.exceptions.ConnectionError as e: + print("Is the EVENT_STORE_URL running and reachable?") + raise e + + return json_util.dumps({'cursor': cars}) + @app.route('/api/v1/resources/cars', methods=['GET']) def get_cars():