Method repack_group

apps/m3u/api_views.py:392–456

Manually re-pack visible channels in one of this account's groups into the group's [start, end] range. Override-pinned numbers are treated as reservations and skipped. Hidden channels without overrides have their channel_number set to NULL. Useful when the u

(self, request, pk=None)

    )
    @action(detail=True, methods=["post"], url_path="repack-group")
    def repack_group(self, request, pk=None):
        """
        Manually re-pack visible channels in one of this account's
        groups into the group's [start, end] range. Override-pinned
        numbers are treated as reservations and skipped. Hidden channels
        without overrides have their channel_number set to NULL.

        Useful when the user has just finished customizing channels
        (setting overrides as pins, hiding unwanted streams) and wants
        the result reflected immediately rather than on the next M3U
        refresh. Also acts as a one-shot cleanup for groups that aren't
        running in compact mode but have accumulated gaps.
        """
        account = self.get_object()
        group_id_raw = request.query_params.get("channel_group_id")
        if not group_id_raw:
            return Response(
                {"detail": "channel_group_id is required"},
                status=status.HTTP_400_BAD_REQUEST,
            )
        try:
            group_id = int(group_id_raw)
        except (TypeError, ValueError):
            return Response(
                {"detail": "channel_group_id must be an integer"},
                status=status.HTTP_400_BAD_REQUEST,
            )

        from apps.channels.models import ChannelGroupM3UAccount
        from apps.channels.compact_numbering import repack_group as _repack
        from core.utils import acquire_task_lock, release_task_lock

        # Share the lock that wraps the entire refresh-plus-sync pipeline
        # (`refresh_single_m3u_account`). The narrower
        # `refresh_m3u_account_groups` lock is released before
        # `sync_auto_channels` runs, so it would not protect this writer
        # from racing against the channel_number writes inside sync.
        if not acquire_task_lock("refresh_single_m3u_account", account.id):
            return Response(
                {"detail": "An M3U refresh is in progress for this account."},
                status=status.HTTP_409_CONFLICT,
            )
        try:
            # Re-fetch under the lock so a sync that just released its lock
            # cannot leave the cached group_relation reflecting pre-sync
            # custom_properties (auto_sync_channel_start/end, etc.).
            try:
                group_relation = ChannelGroupM3UAccount.objects.get(
                    m3u_account=account, channel_group_id=group_id
                )
            except ChannelGroupM3UAccount.DoesNotExist:
                return Response(
                    {"detail": "Group is not associated with this account"},
                    status=status.HTTP_404_NOT_FOUND,
                )
            result = _repack(group_relation)
        finally:
            try: