/api/events endpoint can be used to receive events not only from client

cvat/apps/events/permissions.py

@@ -10,10 +10,12 @@
 from cvat.apps.iam.permissions import OpenPolicyAgentPermission, StrEnum
 from cvat.utils.http import make_requests_session
 
+
 class EventsPermission(OpenPolicyAgentPermission):
     class Scopes(StrEnum):
         SEND_EVENTS = 'send:events'
         DUMP_EVENTS = 'dump:events'
+        SEND_EXTERNAL_EVENTS = 'send-external:events'
 
     @classmethod
     def create(cls, request, view, obj, iam_context):
@@ -49,6 +51,7 @@ def get_scopes(request, view, obj):
         Scopes = __class__.Scopes
         return [{
             ('create', 'POST'): Scopes.SEND_EVENTS,
+            ('external', 'POST'): Scopes.SEND_EXTERNAL_EVENTS,
             ('list', 'GET'): Scopes.DUMP_EVENTS,
         }[(view.action, request.method)]]
 

cvat/apps/events/views.py

@@ -1,12 +1,14 @@
 # Copyright (C) 2023-2024 CVAT.ai Corporation
 #
 # SPDX-License-Identifier: MIT
+import json
 
 from django.conf import settings
 from drf_spectacular.types import OpenApiTypes
 from drf_spectacular.utils import (OpenApiParameter, OpenApiResponse,
                                    extend_schema)
 from rest_framework import status, viewsets
+from rest_framework.decorators import action
 from rest_framework.renderers import JSONRenderer
 from rest_framework.response import Response
 
@@ -15,8 +17,10 @@
 from cvat.apps.events.serializers import ClientEventsSerializer
 from cvat.apps.iam.filters import ORGANIZATION_OPEN_API_PARAMETERS
 
+from .event import record_server_event
 from .export import export
-from .handlers import handle_client_events_push
+from .handlers import handle_client_events_push, request_id
+from .serializers import EventSerializer
 
 
 class EventsViewSet(viewsets.ViewSet):
@@ -44,6 +48,26 @@ def create(self, request):
 
         return Response(serializer.validated_data, status=status.HTTP_201_CREATED)
 
+    @extend_schema(summary='Log external events',
+        description='Sends logs to the Clickhouse if it is connected',
+        responses={'201': EventSerializer()})
+    @action(
+        detail=False,
+        url_path='external',
+        methods=['POST'],
+        serializer_class=EventSerializer,
+    )
+    def external(self, request):
+        serializer = EventSerializer(data=request.data)
+        serializer.is_valid(raise_exception=True)
+        data = dict(
+            serializer.validated_data,
+            payload=json.loads(serializer.validated_data['payload']),
+        )
+        record_server_event(request_id=request_id(), **data)
+
+        return Response(serializer.validated_data, status=status.HTTP_201_CREATED)
+
     @extend_schema(summary='Get an event log',
         methods=['GET'],
         description='The log is returned in the CSV format.',

cvat/schema.yml

@@ -1168,6 +1168,32 @@ paths:
               schema:
                 $ref: '#/components/schemas/ClientEvents'
           description: ''
+  /api/events/external:
+    post:
+      operationId: events_create_external
+      description: Sends logs to the Clickhouse if it is connected
+      summary: Log external events
+      tags:
+      - events
+      requestBody:
+        content:
+          application/json:
+            schema:
+              $ref: '#/components/schemas/EventRequest'
+        required: true
+      security:
+      - sessionAuth: []
+        csrfAuth: []
+        tokenAuth: []
+      - signatureAuth: []
+      - basicAuth: []
+      responses:
+        '201':
+          content:
+            application/vnd.cvat+json:
+              schema:
+                $ref: '#/components/schemas/Event'
+          description: ''
   /api/guides:
     post:
       operationId: guides_create