Function stream_vod

apps/proxy/vod_proxy/views.py:390–630

Stream VOD content (movies or series episodes) with session-based connection reuse Args: content_type: 'movie', 'series', or 'episode' content_id: ID of the content session_id: Optional session ID from URL path (for persistent connections) profile_id: Option

(request, content_type, content_id, session_id=None, profile_id=None, user=None)

@authentication_classes([JWTAuthentication, ApiKeyAuthentication, QueryParamJWTAuthentication])
@permission_classes([AllowAny])
def stream_vod(request, content_type, content_id, session_id=None, profile_id=None, user=None):
    """
    Stream VOD content (movies or series episodes) with session-based connection reuse

    Args:
        content_type: 'movie', 'series', or 'episode'
        content_id: ID of the content
        session_id: Optional session ID from URL path (for persistent connections)
        profile_id: Optional M3U profile ID for authentication
    """
    if not network_access_allowed(request, "STREAMS"):
        return JsonResponse({"error": "Forbidden"}, status=403)
    if user is None and hasattr(request, "user") and request.user.is_authenticated:
        user = request.user
    logger.info(f"[VOD-REQUEST] Starting VOD stream request: {content_type}/{content_id}, session: {session_id}, profile: {profile_id}")
    logger.info(f"[VOD-REQUEST] Full request path: {request.get_full_path()}")
    logger.info(f"[VOD-REQUEST] Request method: {request.method}")
    logger.info(f"[VOD-REQUEST] Request headers: {dict(request.headers)}")

    try:
        client_ip, client_user_agent = get_client_info(request)

        # Extract timeshift parameters from query string
        # Support multiple timeshift parameter formats
        utc_start = request.GET.get('utc_start') or request.GET.get('start') or request.GET.get('playliststart')
        utc_end = request.GET.get('utc_end') or request.GET.get('end') or request.GET.get('playlistend')
        offset = request.GET.get('offset') or request.GET.get('seek') or request.GET.get('t')

        # VLC specific timeshift parameters
        if not utc_start and not offset:
            # Check for VLC-style timestamp parameters
            if 'timestamp' in request.GET:
                offset = request.GET.get('timestamp')
            elif 'time' in request.GET:
                offset = request.GET.get('time')

        # Session ID now comes from URL path parameter
        # Remove legacy query parameter extraction since we're using path-based routing

        # Extract Range header for seeking support
        range_header = request.META.get('HTTP_RANGE')

        logger.info(f"[VOD-TIMESHIFT] Timeshift params - utc_start: {utc_start}, utc_end: {utc_end}, offset: {offset}")
        logger.info(f"[VOD-SESSION] Session ID: {session_id}")

        # Log all query parameters for debugging
        if request.GET:
            logger.debug(f"[VOD-PARAMS] All query params: {dict(request.GET)}")

        if range_header:
            logger.info(f"[VOD-RANGE] Range header: {range_header}")

            # Parse the range to understand what position VLC is seeking to
            try:
                if 'bytes=' in range_header:
                    range_part = range_header.replace('bytes=', '')
                    if '-' in range_part:
                        start_byte, end_byte = range_part.split('-', 1)