mirror of
https://github.com/Dispatcharr/Dispatcharr.git
synced 2026-07-21 09:09:22 +00:00
223dff33ed
Add end-to-end catch-up support for XC clients and native apps: provider proxy with failover and per-viewer session pooling, REST session minting for tokenless playback URLs, catch-up admin stats, combined connection stats, and Stats UI with dedicated cards plus websocket updates. Includes Redis namespace consolidation under timeshift:* (dropping legacy timeshift_ id prefixes), dedicated catch-up stop by session_id, and cleaner channel/client metadata split for stats keys. Closes #133
78 lines
2.6 KiB
Python
78 lines
2.6 KiB
Python
"""Admin API views for catch-up connection statistics."""
|
|
|
|
import json
|
|
import logging
|
|
|
|
from django.http import JsonResponse
|
|
from django.views.decorators.csrf import csrf_exempt
|
|
from rest_framework.decorators import api_view, permission_classes
|
|
|
|
from apps.accounts.permissions import IsAdmin
|
|
from apps.proxy.utils import stop_timeshift_client
|
|
from apps.timeshift.helpers import get_catchup_programmes_for_sessions
|
|
from apps.timeshift.stats import (
|
|
build_timeshift_stats_data,
|
|
find_stats_channel_for_session,
|
|
)
|
|
from core.utils import RedisClient
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
@api_view(["GET"])
|
|
@permission_classes([IsAdmin])
|
|
def timeshift_stats(request):
|
|
"""Return active catch-up viewer sessions for the stats page."""
|
|
redis_client = RedisClient.get_client()
|
|
if not redis_client:
|
|
return JsonResponse({"error": "Redis not available"}, status=500)
|
|
return JsonResponse(build_timeshift_stats_data(redis_client))
|
|
|
|
|
|
@api_view(["POST"])
|
|
@permission_classes([IsAdmin])
|
|
def catchup_programmes(request):
|
|
"""Return EPG metadata for active catch-up sessions (batch)."""
|
|
sessions = request.data.get("sessions")
|
|
if sessions is None:
|
|
return JsonResponse({"error": "sessions is required"}, status=400)
|
|
if not isinstance(sessions, list):
|
|
return JsonResponse({"error": "sessions must be an array"}, status=400)
|
|
return JsonResponse({
|
|
"sessions": get_catchup_programmes_for_sessions(sessions),
|
|
})
|
|
|
|
|
|
@csrf_exempt
|
|
@api_view(["POST"])
|
|
@permission_classes([IsAdmin])
|
|
def stop_timeshift_session(request):
|
|
"""Stop a catch-up viewer by session id (one session = one stats channel)."""
|
|
try:
|
|
data = json.loads(request.body)
|
|
except json.JSONDecodeError:
|
|
return JsonResponse({"error": "Invalid JSON"}, status=400)
|
|
|
|
session_id = data.get("session_id")
|
|
if not session_id:
|
|
return JsonResponse({"error": "No session_id provided"}, status=400)
|
|
|
|
redis_client = RedisClient.get_client()
|
|
if not redis_client:
|
|
return JsonResponse({"error": "Redis not available"}, status=500)
|
|
|
|
stats_channel_id = find_stats_channel_for_session(redis_client, session_id)
|
|
if not stats_channel_id:
|
|
return JsonResponse({"error": "Connection not found"}, status=404)
|
|
|
|
result = stop_timeshift_client(redis_client, stats_channel_id, session_id)
|
|
if result.get("status") != "success":
|
|
return JsonResponse(
|
|
{"error": result.get("message", "Stop failed")},
|
|
status=500,
|
|
)
|
|
|
|
return JsonResponse({
|
|
"message": "Timeshift session stop signal sent",
|
|
"session_id": session_id,
|
|
})
|