Method post

apps/epg/api_views.py:1123–1152

(self, request, format=None)

        ),
    )
    def post(self, request, format=None):
        logger.info("EPGImportAPIView: Received request to import EPG data.")
        epg_id = request.data.get("id", None)
        force = bool(request.data.get("force", False))

        # Reject dummy sources with a narrow existence query, no full row load.
        if epg_id is not None:
            from .models import EPGSource

            if EPGSource.objects.filter(
                id=epg_id, source_type="dummy"
            ).exists():
                logger.info(
                    "EPGImportAPIView: Skipping refresh for dummy EPG source %s",
                    epg_id,
                )
                return Response(
                    {
                        "success": False,
                        "message": "Dummy EPG sources do not require refreshing.",
                    },
                    status=status.HTTP_400_BAD_REQUEST,
                )

        refresh_epg_data.delay(epg_id, force=force)  # Trigger Celery task
        logger.info("EPGImportAPIView: Task dispatched to refresh EPG data.")
        return Response(
            {"success": True, "message": "EPG data refresh initiated."},
            status=status.HTTP_202_ACCEPTED,
        )


# ─────────────────────────────