165 lines
4.7 KiB
Python
165 lines
4.7 KiB
Python
"""Soundboard routes."""
|
|
|
|
from flask import Blueprint, jsonify, request
|
|
|
|
from app.models.sound import Sound, SoundType
|
|
from app.models.sound_played import SoundPlayed
|
|
from app.services.decorators import (
|
|
get_current_user,
|
|
require_auth,
|
|
require_credits,
|
|
)
|
|
from app.services.vlc_service import vlc_service
|
|
|
|
bp = Blueprint("soundboard", __name__)
|
|
|
|
|
|
@bp.route("/sounds", methods=["GET"])
|
|
@require_auth
|
|
def get_sounds():
|
|
"""Get all soundboard sounds."""
|
|
try:
|
|
# Get filter parameters
|
|
sound_type = request.args.get("type", "SDB")
|
|
|
|
# Validate sound type
|
|
if sound_type not in [t.value for t in SoundType]:
|
|
return jsonify({"error": "Invalid sound type"}), 400
|
|
|
|
# Get sounds from database
|
|
sounds = Sound.find_by_type(sound_type)
|
|
|
|
# Order by name
|
|
sounds = sorted(sounds, key=lambda s: s.name.lower())
|
|
|
|
# Convert to dict format
|
|
sounds_data = [sound.to_dict() for sound in sounds]
|
|
|
|
return jsonify(
|
|
{
|
|
"sounds": sounds_data,
|
|
"total": len(sounds_data),
|
|
"type": sound_type,
|
|
},
|
|
)
|
|
except Exception as e:
|
|
return jsonify({"error": str(e)}), 500
|
|
|
|
|
|
@bp.route("/sounds/<int:sound_id>/play", methods=["POST"])
|
|
@require_auth
|
|
@require_credits(1)
|
|
def play_sound(sound_id: int):
|
|
"""Play a specific sound."""
|
|
try:
|
|
# Get current user for tracking
|
|
user = get_current_user()
|
|
user_id = int(user["id"]) if user else None
|
|
|
|
success = vlc_service.play_sound(
|
|
sound_id=sound_id,
|
|
user_id=user_id,
|
|
)
|
|
|
|
if success:
|
|
# Get updated sound data to emit the new play count
|
|
sound = Sound.query.get(sound_id)
|
|
if sound:
|
|
# Emit sound_changed event to all connected clients
|
|
try:
|
|
from app.services.socketio_service import SocketIOService
|
|
|
|
SocketIOService.emit_sound_play_count_changed(
|
|
sound_id, sound.play_count
|
|
)
|
|
except Exception as e:
|
|
# Don't fail the request if socket emission fails
|
|
import logging
|
|
|
|
logger = logging.getLogger(__name__)
|
|
logger.warning(
|
|
f"Failed to emit sound_play_count_changed event: {e}"
|
|
)
|
|
|
|
return jsonify({"message": "Sound playing", "sound_id": sound_id})
|
|
return (
|
|
jsonify({"error": "Sound not found or cannot be played"}),
|
|
404,
|
|
)
|
|
except Exception as e:
|
|
return jsonify({"error": str(e)}), 500
|
|
|
|
|
|
@bp.route("/stop-all", methods=["POST"])
|
|
@require_auth
|
|
def stop_all_sounds():
|
|
"""Stop all currently playing sounds."""
|
|
try:
|
|
# Try normal stop first
|
|
vlc_service.stop_all()
|
|
|
|
# Wait a moment and check if any are still playing
|
|
import time
|
|
|
|
time.sleep(0.2)
|
|
|
|
# If there are still instances, force stop them
|
|
if vlc_service.get_playing_count() > 0:
|
|
stopped_count = vlc_service.force_stop_all()
|
|
return jsonify(
|
|
{
|
|
"message": f"Force stopped {stopped_count} sounds",
|
|
"forced": True,
|
|
},
|
|
)
|
|
|
|
return jsonify({"message": "All sounds stopped"})
|
|
except Exception as e:
|
|
return jsonify({"error": str(e)}), 500
|
|
|
|
|
|
@bp.route("/force-stop", methods=["POST"])
|
|
@require_auth
|
|
def force_stop_all_sounds():
|
|
"""Force stop all sounds with aggressive cleanup."""
|
|
try:
|
|
stopped_count = vlc_service.force_stop_all()
|
|
return jsonify(
|
|
{
|
|
"message": f"Force stopped {stopped_count} sound instances",
|
|
"stopped_count": stopped_count,
|
|
},
|
|
)
|
|
except Exception as e:
|
|
return jsonify({"error": str(e)}), 500
|
|
|
|
|
|
@bp.route("/status", methods=["GET"])
|
|
@require_auth
|
|
def get_status():
|
|
"""Get current playback status."""
|
|
try:
|
|
playing_count = vlc_service.get_playing_count()
|
|
|
|
# Get detailed process information
|
|
with vlc_service.lock:
|
|
processes = []
|
|
for process_id, process in vlc_service.processes.items():
|
|
processes.append(
|
|
{
|
|
"id": process_id,
|
|
"pid": process.pid,
|
|
"running": process.poll() is None,
|
|
},
|
|
)
|
|
|
|
return jsonify(
|
|
{
|
|
"playing_count": playing_count,
|
|
"is_playing": playing_count > 0,
|
|
"processes": processes,
|
|
},
|
|
)
|
|
except Exception as e:
|
|
return jsonify({"error": str(e)}), 500
|