[tracks] Add mopidy queue button

vrobbler/apps/scrobbles/urls.py

@@ -158,6 +158,11 @@ urlpatterns = [
         views.ScrobbleDetailView.as_view(),
         name="detail",
     ),
+    path(
+        "scrobbles/<slug:uuid>/add-to-mopidy-queue/",
+        views.add_to_mopidy_queue,
+        name="add-to-mopidy-queue",
+    ),
     path("scrobbles/<slug:uuid>/start/", views.scrobble_start, name="start"),
     path("scrobbles/<slug:uuid>/finish/", views.scrobble_finish, name="finish"),
     path("scrobbles/<slug:uuid>/cancel/", views.scrobble_cancel, name="cancel"),

vrobbler/apps/scrobbles/views.py

@@ -4,6 +4,8 @@ import logging
 from datetime import datetime, timedelta
 from uuid import uuid4
 
+import requests
+
 import pendulum
 import pytz
 from dateutil.relativedelta import relativedelta
@@ -30,10 +32,11 @@ from django.http import (
     HttpResponseRedirect,
     JsonResponse,
 )
-from django.shortcuts import redirect
+from django.shortcuts import get_object_or_404, redirect
 from django.urls import reverse_lazy
 from django.utils import timezone
 from django.views.decorators.csrf import csrf_exempt
+from django.views.decorators.http import require_POST
 from django.views.generic import DetailView, FormView, TemplateView
 from django.views.generic.edit import CreateView
 from django.views.generic.list import ListView
@@ -963,6 +966,65 @@ def scrobble_cancel(request, uuid):
     return HttpResponseRedirect(request.META.get("HTTP_REFERER"))
 
 
+@require_POST
+def add_to_mopidy_queue(request, uuid):
+    if not request.user.is_authenticated:
+        return redirect("scrobbles:detail", uuid=uuid)
+
+    scrobble = get_object_or_404(Scrobble, uuid=uuid, user=request.user)
+    mopidy_url = request.user.profile.mopidy_api_url
+
+    if not mopidy_url:
+        messages.add_message(
+            request,
+            messages.ERROR,
+            "Mopidy API URL not configured in your profile settings.",
+        )
+        return redirect("scrobbles:detail", uuid=uuid)
+
+    raw_data = scrobble.log.get("raw_data", {})
+    mopidy_uri = raw_data.get("mopidy_uri")
+    logger.debug(mopidy_uri)
+
+    if not mopidy_uri:
+        messages.add_message(
+            request,
+            messages.ERROR,
+            "No Mopidy URI found for this scrobble.",
+        )
+        return redirect("scrobbles:detail", uuid=uuid)
+
+    rpc_url = mopidy_url.rstrip("/") + "/rpc"
+    payload = {
+        "jsonrpc": "2.0",
+        "id": 1,
+        "method": "core.tracklist.add",
+        "params": {"uris": [mopidy_uri]},
+    }
+
+    try:
+        resp = requests.post(rpc_url, json=payload, timeout=10)
+        resp.raise_for_status()
+        rpc_result = resp.json()
+        if rpc_result.get("error"):
+            messages.add_message(
+                request,
+                messages.ERROR,
+                f'Mopidy error: {rpc_result["error"]}',
+            )
+        else:
+            msg = f'Added "{scrobble.media_obj}" to Mopidy queue.'
+            messages.add_message(request, messages.SUCCESS, msg)
+    except requests.RequestException as e:
+        messages.add_message(
+            request,
+            messages.ERROR,
+            f"Failed to contact Mopidy: {e}",
+        )
+
+    return redirect("scrobbles:detail", uuid=uuid)
+
+
 @api_view(["GET"])
 @permission_classes([IsAuthenticated])
 def export(request):