Method list

apps/channels/api_views.py:618–652

(self, request, *args, **kwargs)

        )

    def list(self, request, *args, **kwargs):
        queryset = self.filter_queryset(self.get_queryset())

        # Evaluate the queryset once so the annotations and prefetch cache are
        # populated together, then extract IDs from the in-memory objects.
        # A second .values_list() call would fire a separate SQL query.
        groups = list(queryset)
        group_ids = [g.id for g in groups]

        # Pre-aggregate stream counts for all (account, group) pairs in a
        # single query so the nested ChannelGroupM3UAccountSerializer never
        # fires a COUNT per row.
        counts_qs = (
            Stream.objects.filter(channel_group_id__in=group_ids)
            .values('m3u_account_id', 'channel_group_id')
            .annotate(c=Count('id'))
        )
        stream_counts = {
            (row['m3u_account_id'], row['channel_group_id']): row['c']
            for row in counts_qs
        }

        page = self.paginate_queryset(groups)
        if page is not None:
            serializer = self.get_serializer(
                page, many=True,
                context={**self.get_serializer_context(), 'stream_counts': stream_counts},
            )
            return self.get_paginated_response(serializer.data)

        serializer = self.get_serializer(
            groups, many=True,
            context={**self.get_serializer_context(), 'stream_counts': stream_counts},
        )
        return Response(serializer.data)

    def update(self, request, *args, **kwargs):
        """Override update to check M3U associations"""