Create a metric for counting new users. (#827)

* Create a metric for counting new users.

* Lazily initialize the meter and counter creation.

* Avoid global call.

* Change the strategy to acquire the new user creation metric.

* Reset the ContextVar on each request.

Author: decko

deploy/clowdapp.yaml

@@ -1256,7 +1256,7 @@ parameters:
     value: "/api/pulp/assets/"
   - name: PULP_MIDDLEWARE
     description: List of Middleware
-    value: "@merge ['pulp_service.app.middleware.ActiveConnectionsMetricMiddleware', 'pulp_service.app.middleware.ProfilerMiddleware', 'pulp_service.app.middleware.RhEdgeHostMiddleware', 'pulp_service.app.middleware.RHSamlAuthHeaderMiddleware']"
+    value: "@merge ['pulp_service.app.middleware.RequestPathMiddleware', 'pulp_service.app.middleware.ActiveConnectionsMetricMiddleware', 'pulp_service.app.middleware.ProfilerMiddleware', 'pulp_service.app.middleware.RhEdgeHostMiddleware', 'pulp_service.app.middleware.RHSamlAuthHeaderMiddleware']"
   - name: PULP_PYPI_API_HOSTNAME
     description: The hostname used to form the distribution's `base_url`.
     value: "http://pulp-content:8000"

pulp_service/pulp_service/app/middleware.py

@@ -24,6 +24,7 @@
 repository_name_var = ContextVar('repository_name')
 x_quay_auth_var = ContextVar('x_quay_auth')
 x_task_diagnostics_var = ContextVar('x_profile_task')
+request_path_var = ContextVar('request_path', default=None)
 
 
 class ProfilerMiddleware(MiddlewareMixin):
@@ -99,6 +100,24 @@ def process_view(self, request, *args, **kwargs):
                         _logger.warning("Failed to authenticate user from RH Identity header")
 
 
+class RequestPathMiddleware(MiddlewareMixin):
+    """
+    Middleware to store the request path in a context variable.
+
+    This allows signals to access the request path when processing model changes.
+    """
+
+    def process_view(self, request, *args, **kwargs):
+        request_path_var.set(request.get_full_path())
+
+    def process_response(self, request, response):
+        request_path_var.set(None)
+        return response
+
+    def process_exception(self, request, exception):
+        request_path_var.set(None)
+
+
 class ActiveConnectionsMetricMiddleware(MiddlewareMixin):
     """
     Middleware to track the number of active/concurrent HTTP connections to the API.

pulp_service/pulp_service/app/signals.py

@@ -1,3 +1,6 @@
+import logging
+
+from django.conf import settings
 from django.db.models.signals import post_save
 from django.dispatch import receiver
 from django.contrib.auth import get_user_model
@@ -7,6 +10,21 @@
 from pulp_service.app.models import DomainOrg
 
 
+_logger = logging.getLogger(__name__)
+
+
+@receiver(post_save, sender=settings.AUTH_USER_MODEL)
+def log_new_user(sender, instance, created, **kwargs):
+    """Log when a new user is created, including the route they first accessed."""
+    if created:
+        from pulp_service.app.middleware import request_path_var
+
+        request_path = request_path_var.get(None)
+        _logger.info(
+            f"New user created: username={instance.username}, route={request_path or 'unknown'}"
+        )
+
+
 @receiver(post_save, sender=Domain)
 def post_create_domain(sender, **kwargs):
     if kwargs['created']: