Automatically configuring video settings for the Talk project.

src/pretalx/api/urls.py

@@ -30,4 +30,5 @@
         "events/<event>/favourite-talk/",
         submission.SubmissionFavouriteDeprecatedView.as_view(),
     ),
+    path("configure-video-settings/", event.configure_video_settings),
 ]

src/pretalx/api/views/event.py

@@ -1,9 +1,27 @@
+import logging
+from http import HTTPMethod, HTTPStatus
+
+import jwt
+from django.conf import settings
 from django.http import Http404
+from django_scopes import scopes_disabled
+from pretalx_venueless.forms import VenuelessSettingsForm
 from rest_framework import viewsets
+from rest_framework.authentication import get_authorization_header
+from rest_framework.decorators import (
+    api_view,
+    authentication_classes,
+    permission_classes,
+)
+from rest_framework.response import Response
 
 from pretalx.api.serializers.event import EventSerializer
+from pretalx.common import exceptions
+from pretalx.common.exceptions import AuthenticationFailedError
 from pretalx.event.models import Event
 
+logger = logging.getLogger(__name__)
+
 
 class EventViewSet(viewsets.ReadOnlyModelViewSet):
     serializer_class = EventSerializer
@@ -24,3 +42,126 @@ def get_object(self):
         if self.request.user.has_perm(self.permission_required, self.request.event):
             return self.request.event
         raise Http404()
+
+
+@api_view(http_method_names=[HTTPMethod.POST])
+@authentication_classes([])
+@permission_classes([])
+def configure_video_settings(request):
+    """
+    Configure video settings for an event
+    @param request: request object
+    @return response object
+    """
+    try:
+        video_settings = request.data.get("video_settings")
+
+        if not video_settings or "secret" not in video_settings:
+            raise ValueError("Video settings are missing or secret is not provided")
+
+        payload = get_payload_from_token(request, video_settings)
+        event_slug = payload.get("event_slug")
+        video_tokens = payload.get("video_tokens")
+
+        with scopes_disabled():
+            event_instance = Event.objects.get(slug=event_slug)
+            save_video_settings_information(event_slug, video_tokens, event_instance)
+    except Event.DoesNotExist:
+        logger.error("Event with slug %s does not exist.", event_slug)
+        return Response(
+            {
+                "status": "error",
+                "message": "Event with slug {} not found.".format(event_slug),
+            },
+            status=HTTPStatus.NOT_FOUND,
+        )
+    except ValueError as e:
+        logger.error("Error configuring video settings: %s", e)
+        return Response(
+            {"status": "error", "message": "Error configuring video settings."},
+            status=HTTPStatus.BAD_REQUEST,
+        )
+    except AuthenticationFailedError as e:
+        logger.error("Authentication failed: %s", e)
+        return Response(
+            {"status": "error", "message": "Authentication failed."},
+            status=HTTPStatus.UNAUTHORIZED,
+        )
+
+
+def get_payload_from_token(request, video_settings):
+    """
+    Verify the token and return the payload
+    @param request: request object
+    @param video_settings: dict containing video settings
+    @return: dict containing payload data from the token
+    """
+    try:
+        auth_header = get_authorization_header(request).split()
+        if not auth_header:
+            raise exceptions.AuthenticationFailedError("No authorization header")
+
+        if len(auth_header) != 2 or auth_header[0].lower() != b"bearer":
+            raise exceptions.AuthenticationFailedError(
+                "Invalid token format. Must be 'Bearer <token>'"
+            )
+
+        token_decode = jwt.decode(
+            auth_header[1], video_settings.get("secret"), algorithms=["HS256"]
+        )
+
+        event_slug = token_decode.get("slug")
+        video_tokens = token_decode.get("video_tokens")
+
+        if not event_slug or not video_tokens:
+            raise exceptions.AuthenticationFailedError("Invalid token payload")
+
+        return {"event_slug": event_slug, "video_tokens": video_tokens}
+
+    except jwt.ExpiredSignatureError:
+        raise exceptions.AuthenticationFailedError("Token has expired")
+    except jwt.InvalidTokenError:
+        raise exceptions.AuthenticationFailedError("Invalid token")
+
+
+def save_video_settings_information(event_slug, video_tokens, event_instance):
+    """
+    Save video settings information
+    @param event_slug:  A string representing the event slug
+    @param video_tokens: A list of video tokens
+    @param event_instance: An instance of the event
+    @return: Response object
+    """
+
+    if not video_tokens:
+        raise ValueError("Video tokens list is empty")
+
+    video_settings_data = {
+        "token": video_tokens[0],
+        "url": "{}/api/v1/worlds/{}/".format(
+            settings.EVENTYAY_VIDEO_BASE_PATH, event_slug
+        ),
+    }
+
+    video_settings_form = VenuelessSettingsForm(
+        event=event_instance, data=video_settings_data
+    )
+
+    if video_settings_form.is_valid():
+        video_settings_form.save()
+        logger.info("Video settings configured successfully for event %s.", event_slug)
+        return Response({"status": "success"}, status=200)
+    else:
+        logger.error(
+            "Failed to configure video settings for event %s - Validation errors: %s.",
+            event_slug,
+            video_settings_form.errors,
+        )
+        return Response(
+            {
+                "status": "error",
+                "message": "Validation errors",
+                "errors": video_settings_form.errors,
+            },
+            status=400,
+        )

src/pretalx/settings.py

@@ -689,6 +689,9 @@ def merge_csp(*options, config=None):
 EVENTYAY_TICKET_BASE_PATH = config.get(
     "urls", "eventyay-ticket", fallback="https://app-test.eventyay.com/tickets"
 )
+EVENTYAY_VIDEO_BASE_PATH = config.get(
+    "urls", "eventyay-video", fallback="https://app-test.eventyay.com/video"
+)
 
 SITE_ID = 1
 # for now, customer must verified their email at eventyay-ticket, so this check not required

src/tests/agenda/test_agenda_schedule_export.py

@@ -39,27 +39,6 @@ def test_schedule_xsd_is_up_to_date():
     assert response.data.decode() == schema_content
 
 
-@pytest.mark.skipif(
-    "CI" not in os.environ or not os.environ["CI"],
-    reason="No need to bother with this outside of CI.",
-)
-def test_schedule_json_schema_is_up_to_date():
-    """If this test fails:
-
-    http -d https://raw.githubusercontent.com/voc/schedule/master/validator/json/schema.json >! tests/fixtures/schedule.json
-    """
-    http = urllib3.PoolManager()
-    response = http.request(
-        "GET",
-        "https://raw.githubusercontent.com/voc/schedule/master/validator/json/schema.json",
-    )
-    assert response.status == 200
-    path = Path(__file__).parent / "../fixtures/schedule.json"
-    with open(path) as schema:
-        schema_content = schema.read()
-    assert response.data.decode() == schema_content
-
-
 @pytest.mark.django_db
 def test_schedule_frab_xml_export(
     slot,