refactor: update paths in CI/CD and cloud-init scripts to use /opt/snippetly

Author: ilya776

backend/src/middleware/prometheus.py

@@ -4,50 +4,72 @@
 Tracks HTTP requests, response times, and custom application metrics.
 """
 
-from prometheus_client import Counter, Histogram, Gauge, generate_latest, CONTENT_TYPE_LATEST
+from collections.abc import Callable
+from time import time
+import logging
+
+from prometheus_client import (
+    Counter,
+    Histogram,
+    Gauge,
+    generate_latest,
+    CONTENT_TYPE_LATEST,
+)
 from starlette.middleware.base import BaseHTTPMiddleware
 from starlette.requests import Request
 from starlette.responses import Response
-from time import time
-import logging
 
 logger = logging.getLogger(__name__)
 
 # HTTP Metrics
 http_requests_total = Counter(
-    'http_requests_total',
-    'Total HTTP requests',
-    ['method', 'endpoint', 'status_code']
+    "http_requests_total",
+    "Total HTTP requests",
+    ["method", "endpoint", "status_code"],
 )
 
 http_request_duration_seconds = Histogram(
-    'http_request_duration_seconds',
-    'HTTP request duration in seconds',
-    ['method', 'endpoint'],
-    buckets=(0.01, 0.025, 0.05, 0.075, 0.1, 0.25, 0.5, 0.75, 1.0, 2.5, 5.0, 7.5, 10.0)
+    "http_request_duration_seconds",
+    "HTTP request duration in seconds",
+    ["method", "endpoint"],
+    buckets=(
+        0.01,
+        0.025,
+        0.05,
+        0.075,
+        0.1,
+        0.25,
+        0.5,
+        0.75,
+        1.0,
+        2.5,
+        5.0,
+        7.5,
+        10.0,
+    ),
 )
 
 http_requests_in_progress = Gauge(
-    'http_requests_in_progress',
-    'HTTP requests currently being processed',
-    ['method', 'endpoint']
+    "http_requests_in_progress",
+    "HTTP requests currently being processed",
+    ["method", "endpoint"],
 )
 
 # Application Metrics
 active_users = Gauge(
-    'snippetly_active_users',
-    'Number of active users (logged in last 24h)'
+    "snippetly_active_users",
+    "Number of active users (logged in last 24h)",
 )
 
 total_snippets = Gauge(
-    'snippetly_total_snippets',
-    'Total number of code snippets'
+    "snippetly_total_snippets",
+    "Total number of code snippets",
 )
 
 database_connections = Gauge(
-    'snippetly_database_connections',
-    'Number of active database connections',
-    ['database']
+    "snippetly_database_connections",
+    "Number of active database connections",
+    ["database"],
 )
 
 
@@ -61,7 +83,9 @@ class PrometheusMiddleware(BaseHTTPMiddleware):
     - Requests in progress gauge
     """
 
-    async def dispatch(self, request: Request, call_next):
+    async def dispatch(
+        self, request: Request, call_next: Callable
+    ) -> Response:
         # Skip metrics endpoint itself to avoid recursion
         if request.url.path == "/api/metrics":
             return await call_next(request)
@@ -71,7 +95,9 @@ async def dispatch(self, request: Request, call_next):
         method = request.method
 
         # Track request in progress
-        http_requests_in_progress.labels(method=method, endpoint=endpoint).inc()
+        http_requests_in_progress.labels(
+            method=method, endpoint=endpoint
+        ).inc()
 
         # Start timer
         start_time = time()
@@ -85,32 +111,29 @@ async def dispatch(self, request: Request, call_next):
             status_code = response.status_code
 
             http_requests_total.labels(
-                method=method,
-                endpoint=endpoint,
-                status_code=status_code
+                method=method, endpoint=endpoint, status_code=status_code
             ).inc()
 
             http_request_duration_seconds.labels(
-                method=method,
-                endpoint=endpoint
+                method=method, endpoint=endpoint
             ).observe(duration)
 
             return response
 
         except Exception as e:
             # Record error
             http_requests_total.labels(
-                method=method,
-                endpoint=endpoint,
-                status_code=500
+                method=method, endpoint=endpoint, status_code=500
             ).inc()
 
             logger.error(f"Request failed: {method} {endpoint} - {str(e)}")
             raise
 
         finally:
             # Decrement in-progress counter
-            http_requests_in_progress.labels(method=method, endpoint=endpoint).dec()
+            http_requests_in_progress.labels(
+                method=method, endpoint=endpoint
+            ).dec()
 
     def _get_endpoint_pattern(self, request: Request) -> str:
         """
@@ -124,9 +147,9 @@ def _get_endpoint_pattern(self, request: Request) -> str:
 
         # Common patterns
         patterns = [
-            ('/api/v1/snippets/', '/api/v1/snippets/{id}'),
-            ('/api/v1/users/', '/api/v1/users/{id}'),
-            ('/api/v1/auth/verify/', '/api/v1/auth/verify/{token}'),
+            ("/api/v1/snippets/", "/api/v1/snippets/{id}"),
+            ("/api/v1/users/", "/api/v1/users/{id}"),
+            ("/api/v1/auth/verify/", "/api/v1/auth/verify/{token}"),
         ]
 
         for prefix, pattern in patterns:
@@ -143,6 +166,5 @@ def metrics_endpoint() -> Response:
     Returns metrics in Prometheus format for scraping.
     """
     return Response(
-        content=generate_latest(),
-        media_type=CONTENT_TYPE_LATEST
+        content=generate_latest(), media_type=CONTENT_TYPE_LATEST
     )