feat: add coverage calculation

Signed-off-by: Charan Kamarapu <kamarapucharan@gmail.com>

Author: charankamarapu

apigateway/.coveragerc

@@ -0,0 +1,18 @@
+[run]
+branch = True
+parallel = True
+source = .
+data_file = /coverage/.coverage.apigateway
+omit =
+	*/migrate.py
+	*/migrations/*
+
+[report]
+show_missing = True
+skip_empty = True
+
+[paths]
+source =
+	.
+	/app
+	/Users/charankamarapu/microservices/apigateway

apigateway/Dockerfile

@@ -3,6 +3,7 @@ WORKDIR /app
 COPY requirements.txt .
 RUN pip install --no-cache-dir -r requirements.txt
 COPY . .
+RUN chmod +x /app/entrypoint.sh || true
 ENV FLASK_RUN_HOST=0.0.0.0
 ENV FLASK_RUN_PORT=8083
-CMD ["python", "app.py"]
+ENTRYPOINT ["/bin/sh", "/app/entrypoint.sh"]

apigateway/app.py

@@ -2,6 +2,8 @@
 import signal
 from flask import Flask, request, Response, jsonify
 import requests
+import coverage as _coverage
+
 
 app = Flask(__name__)
 
@@ -96,17 +98,20 @@ def gw_orders(subpath):
     return _proxy(ORDER_SERVICE_URL, f"orders/{subpath}")
 
 
-@app.route('/health', methods=['GET'])
-def health():
-    return jsonify({'ok': True}), 200
-
 
 if __name__ == '__main__':
-    # Ensure we exit quickly on SIGTERM/SIGINT during docker stop
+    # Ensure we stop/save coverage before exiting on SIGTERM/SIGINT
     def _graceful_exit(signum, frame):
-        # Let Flask/Werkzeug shutdown
-        os._exit(0)
+        if _coverage:
+            try:
+                cov = _coverage.Coverage.current()
+                if cov is not None:
+                    cov.stop()
+                    cov.save()
+            except Exception:
+                pass
+        raise SystemExit(0)
     signal.signal(signal.SIGTERM, _graceful_exit)
     signal.signal(signal.SIGINT, _graceful_exit)
     port = int(os.environ.get('FLASK_RUN_PORT', 8083))
-    app.run(host='0.0.0.0', port=port)
+    app.run(host='0.0.0.0', port=port, use_reloader=False)

apigateway/entrypoint.sh

@@ -0,0 +1,64 @@
+#!/bin/sh
+set -eu
+
+gen_reports() {
+  echo "[entrypoint] Generating apigateway coverage HTML..."
+  PYTHON=python3; command -v python3 >/dev/null 2>&1 || PYTHON=python
+  "$PYTHON" - <<'PY'
+import os, sys, subprocess, time
+data_file = os.environ.get('COVERAGE_FILE', '/coverage/.coverage.apigateway')
+rcfile = '.coveragerc'
+# Write HTML inside the service repo path if mounted
+html_dir = os.environ.get('HTML_DIR', '/svc_coverage/htmlcov')
+cov_dir = os.path.dirname(data_file) or '/coverage'
+prefix = os.path.basename(data_file)
+files = []
+# Poll briefly for coverage files to appear
+for _ in range(10):
+  files = [os.path.join(cov_dir, f) for f in os.listdir(cov_dir) if f.startswith(prefix) and f != prefix]
+  if files or os.path.exists(data_file):
+    break
+  time.sleep(0.5)
+combined = data_file + '.combined'
+try:
+  if files:
+    cmd = [sys.executable, '-m', 'coverage', 'combine', '--data-file', combined]
+    cmd += files
+    subprocess.check_call(cmd)
+    used = combined
+  else:
+    used = data_file if os.path.exists(data_file) else None
+  if not used:
+    print('[entrypoint] No coverage data found for apigateway in', cov_dir)
+  else:
+    os.makedirs(html_dir, exist_ok=True)
+    subprocess.check_call([sys.executable, '-m', 'coverage', 'report', '-m', '--data-file', used, '--rcfile', rcfile])
+  subprocess.check_call([sys.executable, '-m', 'coverage', 'html', '-d', html_dir, '--data-file', used, '--rcfile', rcfile])
+  print('[entrypoint] HTML written to', os.path.join(html_dir, 'index.html'))
+except Exception as e:
+  print('[entrypoint] coverage combine/report/html failed:', e)
+PY
+}
+
+if [ -n "${COVERAGE:-}" ]; then
+  echo "[entrypoint] Running under coverage"
+  export COVERAGE_FILE=${COVERAGE_FILE:-/coverage/.coverage.apigateway}
+  python -m coverage run --rcfile=.coveragerc app.py &
+  APP_PID=$!
+  on_term() {
+    echo "[entrypoint] Caught stop signal; stopping app..."
+    kill -TERM "$APP_PID" 2>/dev/null || true
+    wait "$APP_PID" || true
+    # Give the app a moment to flush coverage
+    sleep 1
+    gen_reports || true
+    exit 0
+  }
+  trap on_term INT TERM
+  wait "$APP_PID" || true
+  # Normal exit
+  sleep 1
+  gen_reports || true
+else
+  python app.py
+fi

apigateway/requirements.txt

@@ -1,2 +1,3 @@
 flask==3.0.3
 requests==2.32.3
+coverage==7.5.4

coverage/.coverage.apigateway.combined

@@ -85,11 +85,15 @@ services:
       ADMIN_EMAIL: admin@example.com
       ADMIN_PASSWORD: admin123
       RESET_ADMIN_PASSWORD: "true"
+      COVERAGE: "1"
     depends_on:
       mysql-users:
         condition: service_healthy
     ports:
       - "8082:8082"
+    volumes:
+      - ./coverage:/coverage
+      - ./user_service/coverage:/svc_coverage
 
   product_service:
     build: ./product_service
@@ -102,11 +106,15 @@ services:
       DB_PASSWORD: password
       DB_NAME: product_db
       FLASK_RUN_PORT: "8081"
+      COVERAGE: "1"
     depends_on:
       mysql-products:
         condition: service_healthy
     ports:
       - "8081:8081"
+    volumes:
+      - ./coverage:/coverage
+      - ./product_service/coverage:/svc_coverage
 
   order_service:
     build: ./order_service
@@ -126,6 +134,7 @@ services:
       AWS_ENDPOINT: http://localstack:4566
       SQS_QUEUE_URL: http://localstack:4566/000000000000/order-events
       FLASK_RUN_PORT: "8080"
+      COVERAGE: "1"
     depends_on:
       mysql-orders:
         condition: service_healthy
@@ -137,6 +146,9 @@ services:
         condition: service_started
     ports:
       - "8080:8080"
+    volumes:
+      - ./coverage:/coverage
+      - ./order_service/coverage:/svc_coverage
 
   apigateway:
     build: ./apigateway
@@ -148,6 +160,7 @@ services:
       PRODUCT_SERVICE_URL: http://product_service:8081/api/v1
       ORDER_SERVICE_URL: http://order_service:8080/api/v1
       FLASK_RUN_PORT: "8083"
+      COVERAGE: "1"
     depends_on:
       user_service:
         condition: service_started
@@ -157,3 +170,6 @@ services:
         condition: service_started
     ports:
       - "8083:8083"
+    volumes:
+      - ./coverage:/coverage
+      - ./apigateway/coverage:/svc_coverage