2.9

Author: TejeshKumarReddyCTR

order-service/app.py

@@ -1,31 +1,27 @@
 from flask import Flask, jsonify, request
+from werkzeug.middleware.dispatcher import DispatcherMiddleware
 import boto3, os, json
 
-app = Flask(__name__)
+flask_app = Flask(__name__)
 
-# Initialize SQS
-region = "ap-south-1"
-sqs = boto3.client("sqs", region_name=region)
+sqs = boto3.client("sqs", region_name="ap-south-1")
 queue_url = os.environ.get("ORDER_QUEUE_URL", "")
 
-@app.route('/order', methods=['POST'])
+@flask_app.route('/order', methods=['POST'])
 def place_order():
-    if not queue_url:
-        return jsonify({"error": "ORDER_QUEUE_URL not configured"}), 500
-
     data = request.get_json()
-    try:
-        sqs.send_message(QueueUrl=queue_url, MessageBody=json.dumps(data))
-        return jsonify({"message": "Order placed successfully"}), 201
-    except Exception as e:
-        return jsonify({"error": str(e)}), 500
+    sqs.send_message(QueueUrl=queue_url, MessageBody=json.dumps(data))
+    return jsonify({"message": "Order placed successfully"}), 201
 
-@app.route('/orders', methods=['GET'])
+@flask_app.route('/orders', methods=['GET'])
 def list_orders():
-    return jsonify([
-        {"id": 1, "product_id": 1, "status": "confirmed"}
-    ]), 200
+    return jsonify([{"id": 1, "product_id": 1, "status": "confirmed"}])
 
-@app.route('/health', methods=['GET'])
+@flask_app.route('/health', methods=['GET'])
 def health():
-    return "Order service is healthy", 200
+    return "Order service healthy", 200
+
+# Dispatcher to map /order prefix
+app = DispatcherMiddleware(Flask('dummy_root'), {
+    '/order': flask_app
+})

product-service/app.py

@@ -1,26 +1,25 @@
 from flask import Flask, jsonify, request
+from werkzeug.middleware.dispatcher import DispatcherMiddleware
 
-app = Flask(__name__)
+flask_app = Flask(__name__)
 
-# In-memory list for demo purposes
-products = [
-    {"id": 1, "name": "Laptop"},
-    {"id": 2, "name": "Phone"}
-]
-
-@app.route('/products', methods=['GET'])
+@flask_app.route('/products', methods=['GET'])
 def list_products():
-    return jsonify(products), 200
+    return jsonify([
+        {"id": 1, "name": "Laptop"},
+        {"id": 2, "name": "Phone"}
+    ])
 
-@app.route('/products', methods=['POST'])
+@flask_app.route('/products', methods=['POST'])
 def add_product():
     data = request.get_json()
-    product_name = data.get('name')
-    new_id = len(products) + 1
-    new_product = {"id": new_id, "name": product_name}
-    products.append(new_product)
-    return jsonify({"message": f"Product '{product_name}' added"}), 201
+    return jsonify({"message": f"Product '{data.get('name')}' added"}), 201
 
-@app.route('/health', methods=['GET'])
+@flask_app.route('/health', methods=['GET'])
 def health():
-    return "Product service is healthy", 200
+    return "Product service healthy", 200
+
+# Dispatcher to map /product prefix
+app = DispatcherMiddleware(Flask('dummy_root'), {
+    '/product': flask_app
+})

user-service/app.py

@@ -1,19 +1,23 @@
 from flask import Flask, jsonify, request
+from werkzeug.middleware.dispatcher import DispatcherMiddleware
 
-app = Flask(__name__)
+flask_app = Flask(__name__)
 
-@app.route('/register', methods=['POST'])
-def register():
+@flask_app.route('/login', methods=['POST'])
+def login():
     data = request.get_json()
-    username = data.get('username')
-    return jsonify({"message": f"User {username} registered"}), 201
+    return jsonify({"token": "dummy-token-for-" + data.get("username")})
 
-@app.route('/login', methods=['POST'])
-def login():
+@flask_app.route('/register', methods=['POST'])
+def register():
     data = request.get_json()
-    username = data.get('username')
-    return jsonify({"token": f"dummy-token-for-{username}"}), 200
+    return jsonify({"message": f"User {data.get('username')} registered"}), 201
 
-@app.route('/health', methods=['GET'])
+@flask_app.route('/health', methods=['GET'])
 def health():
-    return "User service is Healthy", 200
+    return "User service healthy", 200
+
+# Dispatcher to map /user prefix
+app = DispatcherMiddleware(Flask('dummy_root'), {
+    '/user': flask_app
+})