Method poster

apps/epg/api_views.py:503–592

Proxy endpoint for SD program poster images. Nginx caches the response.

(self, request, pk=None)

    @action(detail=True, methods=['get'], url_path='poster', permission_classes=[AllowAny])
    def poster(self, request, pk=None):
        """Proxy endpoint for SD program poster images. Nginx caches the response."""
        import requests as http_requests
        from apps.epg.tasks import SD_BASE_URL
        from core.utils import dispatcharr_http_headers

        program = self.get_object()
        poster_sd_url = (program.custom_properties or {}).get('sd_icon')
        if not poster_sd_url:
            return Response(status=status.HTTP_404_NOT_FOUND)

        source = program.epg.epg_source if program.epg else None
        if not source or source.source_type != 'schedules_direct':
            return Response(status=status.HTTP_404_NOT_FOUND)

        error_cache = ProgramViewSet._sd_poster_error_cache.get(source.id)
        if error_cache and time.time() < error_cache['until']:
            return Response(
                {'error': f"SD temporarily unavailable: {error_cache['reason']}"},
                status=status.HTTP_503_SERVICE_UNAVAILABLE,
            )

        cached = ProgramViewSet._sd_poster_token_cache.get(source.id)
        token = cached['token'] if cached and time.time() < cached['expires'] else None

        if not token:
            sha1_password = hashlib.sha1(source.password.encode('utf-8')).hexdigest()
            try:
                auth_resp = http_requests.post(
                    f"{SD_BASE_URL}/token",
                    json={'username': source.username, 'password': sha1_password},
                    headers=dispatcharr_http_headers(),
                    timeout=10,
                )
                auth_data = auth_resp.json()
                token = auth_data.get('token')
                if not token:
                    ProgramViewSet._sd_poster_error_cache[source.id] = {
                        'until': time.time() + 3600,
                        'reason': auth_data.get('message', 'Authentication failed'),
                    }
                    return Response(status=status.HTTP_502_BAD_GATEWAY)
                token_expires = auth_data.get('tokenExpires', time.time() + 86400)
                ProgramViewSet._sd_poster_token_cache[source.id] = {
                    'token': token,
                    'expires': token_expires,
                }
            except http_requests.exceptions.RequestException:
                ProgramViewSet._sd_poster_error_cache[source.id] = {
                    'until': time.time() + 300,
                    'reason': 'Network error reaching Schedules Direct',
                }
                return Response(status=status.HTTP_502_BAD_GATEWAY)

        try:
            img_resp = http_requests.get(
                poster_sd_url,
                headers=dispatcharr_http_headers(token=token, content_type=None),