Method _background_refresh

apps/channels/api_views.py:3641–3688

(rec_id)

        instance = self.get_object()

        def _background_refresh(rec_id):
            try:
                from .tasks import _resolve_poster_for_program
                from .models import Recording
                from core.utils import send_websocket_update
                from django.db import close_old_connections

                rec = Recording.objects.select_related("channel").get(id=rec_id)
                cp = rec.custom_properties or {}
                program = cp.get("program") or {}

                poster_logo_id, poster_url = _resolve_poster_for_program(
                    rec.channel.name, program, channel_logo_id=rec.channel.logo_id,
                )

                # Refresh and merge to avoid overwriting concurrent changes.
                # Only upgrade — never replace a real poster with a channel logo fallback.
                rec.refresh_from_db()
                fresh_cp = rec.custom_properties or {}
                updated = False
                is_channel_logo_fallback = (
                    poster_logo_id == rec.channel.logo_id
                    and not poster_url
                )
                if program and program.get("id"):
                    fresh_cp["program"] = program
                    updated = True
                if not is_channel_logo_fallback:
                    if poster_logo_id and fresh_cp.get("poster_logo_id") != poster_logo_id:
                        fresh_cp["poster_logo_id"] = poster_logo_id
                        updated = True
                    if poster_url and fresh_cp.get("poster_url") != poster_url:
                        fresh_cp["poster_url"] = poster_url
                        updated = True

                if updated:
                    rec.custom_properties = fresh_cp
                    rec.save(update_fields=["custom_properties"])

                send_websocket_update('updates', 'update', {
                    "success": True,
                    "type": "recording_updated",
                    "recording_id": rec_id,
                })
            except Exception as e:
                logger.debug(f"refresh-artwork background failed for {rec_id}: {e}")
            finally:
                close_old_connections()

        t = threading.Thread(target=_background_refresh, args=(instance.id,), daemon=True)
        t.start()