Method sd_lineups

apps/epg/api_views.py:247–406

GET — list lineups currently on the SD account POST — add a lineup (body: {"lineup": "USA-NJ29486-X"}) DELETE — remove a lineup (body: {"lineup": "USA-NJ29486-X"})

(self, request, pk=None)

    @action(detail=True, methods=["get", "post", "delete"], url_path="sd-lineups")
    def sd_lineups(self, request, pk=None):
        """
        GET    — list lineups currently on the SD account
        POST   — add a lineup (body: {"lineup": "USA-NJ29486-X"})
        DELETE — remove a lineup (body: {"lineup": "USA-NJ29486-X"})
        """
        import requests as http_requests
        from apps.epg.tasks import SD_BASE_URL
        from core.utils import dispatcharr_http_headers

        source = self.get_object()
        if source.source_type != 'schedules_direct':
            return Response(
                {"error": "This action is only available for Schedules Direct sources."},
                status=status.HTTP_400_BAD_REQUEST
            )

        token, error = self._sd_authenticate(source)
        if error:
            return error

        headers = dispatcharr_http_headers(token=token)

        if request.method == "GET":
            countries = self._fetch_sd_countries()
            try:
                resp = http_requests.get(
                    f"{SD_BASE_URL}/lineups",
                    headers=headers,
                    timeout=15,
                )
                if resp.status_code == 400:
                    sd_data = resp.json()
                    sd_code = sd_data.get('code')
                    if sd_code == 4102:
                        return Response({
                            "lineups": [],
                            "max_lineups": 4,
                            "changes_remaining": self._get_sd_changes_remaining(source),
                            "changes_reset_at": self._get_sd_reset_at(source),
                            "notice": "No lineups are currently configured on this Schedules Direct account. Use the search below to add one.",
                            "countries": countries,
                        })
                resp.raise_for_status()
                data = resp.json()
                lineups = [l for l in data.get('lineups', []) if not l.get('isDeleted', False)]
                return Response({
                    "lineups": lineups,
                    "max_lineups": 4,
                    "changes_remaining": self._get_sd_changes_remaining(source),
                    "changes_reset_at": self._get_sd_reset_at(source),
                    "countries": countries,
                })
            except http_requests.exceptions.RequestException as e:
                return Response(
                    {"error": f"Failed to fetch lineups: {str(e)}"},
                    status=status.HTTP_502_BAD_GATEWAY
                )