upload feedbackto server

app/app.py

@@ -1,3 +1,25 @@
+# Player feedback API
+from models.player_feedback import PlayerFeedback
+# --- API route to receive player feedback ---
+@app.route('/api/player-feedback', methods=['POST'])
+def api_player_feedback():
+    data = request.get_json()
+    required_fields = ['player_name', 'quickconnect_code', 'message', 'status', 'timestamp']
+    if not all(field in data for field in required_fields):
+        return jsonify({'error': 'Missing required fields'}), 400
+
+    feedback = PlayerFeedback(
+        player_name=data['player_name'],
+        quickconnect_code=data['quickconnect_code'],
+        message=data['message'],
+        status=data['status'],
+        timestamp=data['timestamp'],
+        playlist_version=data.get('playlist_version'),
+        error_details=data.get('error_details')
+    )
+    db.session.add(feedback)
+    db.session.commit()
+    return jsonify({'success': True, 'feedback_id': feedback.id}), 200
 import os
 import click
 import psutil

app/models/__init__.py

@@ -2,4 +2,5 @@ from .user import User
 from .player import Player
 from .group import Group, group_player
 from .content import Content
-from .server_log import ServerLog
+from .server_log import ServerLog
+from .player_feedback import PlayerFeedback

app/models/player_feedback.py

@@ -0,0 +1,11 @@
+from extensions import db
+
+class PlayerFeedback(db.Model):
+    id = db.Column(db.Integer, primary_key=True)
+    player_name = db.Column(db.String(255), nullable=False)
+    quickconnect_code = db.Column(db.String(255), nullable=False)
+    message = db.Column(db.Text, nullable=False)
+    status = db.Column(db.String(50), nullable=False)
+    timestamp = db.Column(db.DateTime, nullable=False)
+    playlist_version = db.Column(db.Integer, nullable=True)
+    error_details = db.Column(db.Text, nullable=True)

app/templates/upload_content.html

@@ -223,61 +223,82 @@
 
     <script src="https://cdn.jsdelivr.net/npm/bootstrap@5.3.0-alpha3/dist/js/bootstrap.bundle.min.js"></script>
     <script>
+
         function showStatusModal() {
             console.log("Processing popup triggered");
             const statusModal = new bootstrap.Modal(document.getElementById('statusModal'));
             statusModal.show();
-            
+
             // Update status message based on media type
             const mediaType = document.getElementById('media_type').value;
             const statusMessage = document.getElementById('status-message');
-            
-            switch(mediaType) {
-                case 'image':
-                    statusMessage.textContent = 'Uploading images...';
-                    break;
-                case 'video':
-                    statusMessage.textContent = 'Uploading and processing video. This may take a while...';
-                    break;
-                case 'pdf':
-                    statusMessage.textContent = 'Converting PDF to 4K images. This may take a while...';
-                    break;
-                case 'ppt':
-                    statusMessage.textContent = 'Converting PowerPoint to images (PPTX → PDF → Images). This may take 2-5 minutes...';
-                    break;
-                default:
-                    statusMessage.textContent = 'Uploading and processing your files. Please wait...';
-            }
-            
-            // Start system monitoring updates in modal
-            {% if system_info %}
-            startModalSystemMonitoring();
-            {% endif %}
-            
-            // Simulate progress updates
             const progressBar = document.getElementById('progress-bar');
             let progress = 0;
-            const interval = setInterval(() => {
-                // For slow processes, increment more slowly
-                const increment = (mediaType === 'image') ? 20 : 5;
-                progress += increment;
-                
-                if (progress >= 100) {
-                    clearInterval(interval);
-                    statusMessage.textContent = 'Files uploaded and processed successfully!';
-                    
-                    // Stop system monitoring updates
-                    {% if system_info %}
-                    stopModalSystemMonitoring();
-                    {% endif %}
-                    
-                    // Enable the close button
-                    document.querySelector('[data-bs-dismiss="modal"]').disabled = false;
-                } else {
-                    progressBar.style.width = `${progress}%`;
-                    progressBar.setAttribute('aria-valuenow', progress);
+
+            if (mediaType === 'video') {
+                statusMessage.textContent = 'Uploading video...';
+                // Stage 1: Uploading (0-40%)
+                let uploadInterval = setInterval(() => {
+                    progress += 8;
+                    if (progress >= 40) {
+                        clearInterval(uploadInterval);
+                        progress = 40;
+                        progressBar.style.width = `${progress}%`;
+                        progressBar.setAttribute('aria-valuenow', progress);
+                        // Stage 2: Converting
+                        statusMessage.textContent = 'Converting video to standard format (29.97 fps, 1080p)...';
+                        let convertProgress = 40;
+                        let convertInterval = setInterval(() => {
+                            convertProgress += 3;
+                            progressBar.style.width = `${convertProgress}%`;
+                            progressBar.setAttribute('aria-valuenow', convertProgress);
+                            if (convertProgress >= 100) {
+                                clearInterval(convertInterval);
+                                statusMessage.textContent = 'Video uploaded and converted successfully!';
+                                // Stop system monitoring updates
+                                {% if system_info %}
+                                stopModalSystemMonitoring();
+                                {% endif %}
+                                document.querySelector('[data-bs-dismiss="modal"]').disabled = false;
+                            }
+                        }, 600);
+                    } else {
+                        progressBar.style.width = `${progress}%`;
+                        progressBar.setAttribute('aria-valuenow', progress);
+                    }
+                }, 400);
+            } else {
+                // Default for other media types
+                switch(mediaType) {
+                    case 'image':
+                        statusMessage.textContent = 'Uploading images...';
+                        break;
+                    case 'pdf':
+                        statusMessage.textContent = 'Converting PDF to 4K images. This may take a while...';
+                        break;
+                    case 'ppt':
+                        statusMessage.textContent = 'Converting PowerPoint to images (PPTX → PDF → Images). This may take 2-5 minutes...';
+                        break;
+                    default:
+                        statusMessage.textContent = 'Uploading and processing your files. Please wait...';
                 }
-            }, 500);
+                // Simulate progress updates
+                let interval = setInterval(() => {
+                    const increment = (mediaType === 'image') ? 20 : 5;
+                    progress += increment;
+                    if (progress >= 100) {
+                        clearInterval(interval);
+                        statusMessage.textContent = 'Files uploaded and processed successfully!';
+                        {% if system_info %}
+                        stopModalSystemMonitoring();
+                        {% endif %}
+                        document.querySelector('[data-bs-dismiss="modal"]').disabled = false;
+                    } else {
+                        progressBar.style.width = `${progress}%`;
+                        progressBar.setAttribute('aria-valuenow', progress);
+                    }
+                }, 500);
+            }
         }
 
         {% if system_info %}

app/utils/uploads.py

@@ -1,4 +1,4 @@
-import os
+ import os
 import subprocess
 from flask import Flask
 from werkzeug.utils import secure_filename
@@ -56,8 +56,39 @@ def convert_video(input_file, output_folder):
     return input_file
 
 def convert_video_and_update_playlist(app, file_path, original_filename, target_type, target_id, duration):
-    print(f"Video conversion skipped for: {file_path}")
-    return None
+    import shutil
+    import tempfile
+    print(f"Starting video normalization for: {file_path}")
+    # Only process .mp4 files
+    if not file_path.lower().endswith('.mp4'):
+        print(f"Skipping non-mp4 file: {file_path}")
+        return None
+
+    # Prepare temp output file
+    temp_dir = tempfile.gettempdir()
+    temp_output = os.path.join(temp_dir, f"normalized_{os.path.basename(file_path)}")
+    ffmpeg_cmd = [
+        'ffmpeg', '-y', '-i', file_path,
+        '-c:v', 'libx264', '-profile:v', 'main',
+        # Bitrate is not forced, so we allow lower bitrates
+        '-vf', 'scale=1920:1080,fps=29.97',
+        '-c:a', 'copy',
+        temp_output
+    ]
+    print(f"Running ffmpeg: {' '.join(ffmpeg_cmd)}")
+    try:
+        result = subprocess.run(ffmpeg_cmd, capture_output=True, text=True, timeout=1800)
+        if result.returncode != 0:
+            print(f"ffmpeg error: {result.stderr}")
+            return None
+        # Replace original file with normalized one
+        shutil.move(temp_output, file_path)
+        print(f"Video normalized and replaced: {file_path}")
+    except Exception as e:
+        print(f"Error during video normalization: {e}")
+        return None
+    # No need to update playlist, as filename remains the same
+    return True
 
 # PDF conversion functions
 def convert_pdf_to_images(pdf_file, output_folder, delete_pdf=True, dpi=300):

code player/get_playlists.py

@@ -0,0 +1,336 @@
+import os
+import json
+import requests
+import bcrypt
+import re
+import datetime
+from logging_config import Logger
+
+def send_player_feedback(config, message, status="active", playlist_version=None, error_details=None):
+    """
+    Send feedback to the server about player status.
+    
+    Args:
+        config (dict): Configuration containing server details
+        message (str): Main feedback message
+        status (str): Player status - "active", "playing", "error", "restarting"
+        playlist_version (int, optional): Current playlist version being played
+        error_details (str, optional): Error details if status is "error"
+    
+    Returns:
+        bool: True if feedback sent successfully, False otherwise
+    """
+    try:
+        server = config.get("server_ip", "")
+        host = config.get("screen_name", "")
+        quick = config.get("quickconnect_key", "")
+        port = config.get("port", "")
+        
+        # Construct server URL
+        ip_pattern = r'^\d+\.\d+\.\d+\.\d+$'
+        if re.match(ip_pattern, server):
+            feedback_url = f'http://{server}:{port}/api/player-feedback'
+        else:
+            feedback_url = f'http://{server}/api/player-feedback'
+        
+        # Prepare feedback data
+        feedback_data = {
+            'player_name': host,
+            'quickconnect_code': quick,
+            'message': message,
+            'status': status,
+            'timestamp': datetime.datetime.now().isoformat(),
+            'playlist_version': playlist_version,
+            'error_details': error_details
+        }
+        
+        Logger.info(f"Sending feedback to {feedback_url}: {feedback_data}")
+        
+        # Send POST request
+        response = requests.post(feedback_url, json=feedback_data, timeout=10)
+        
+        if response.status_code == 200:
+            Logger.info(f"Feedback sent successfully: {message}")
+            return True
+        else:
+            Logger.warning(f"Feedback failed with status {response.status_code}: {response.text}")
+            return False
+            
+    except requests.exceptions.RequestException as e:
+        Logger.error(f"Failed to send feedback: {e}")
+        return False
+    except Exception as e:
+        Logger.error(f"Unexpected error sending feedback: {e}")
+        return False
+
+def send_playlist_check_feedback(config, playlist_version=None):
+    """
+    Send feedback when playlist is checked for updates.
+    
+    Args:
+        config (dict): Configuration containing server details
+        playlist_version (int, optional): Current playlist version
+    
+    Returns:
+        bool: True if feedback sent successfully, False otherwise
+    """
+    player_name = config.get("screen_name", "unknown")
+    version_info = f"v{playlist_version}" if playlist_version else "unknown"
+    message = f"player {player_name}, is active, Playing {version_info}"
+    
+    return send_player_feedback(
+        config=config,
+        message=message,
+        status="active",
+        playlist_version=playlist_version
+    )
+
+def send_playlist_restart_feedback(config, playlist_version=None):
+    """
+    Send feedback when playlist loop ends and restarts.
+    
+    Args:
+        config (dict): Configuration containing server details
+        playlist_version (int, optional): Current playlist version
+    
+    Returns:
+        bool: True if feedback sent successfully, False otherwise
+    """
+    player_name = config.get("screen_name", "unknown")
+    version_info = f"v{playlist_version}" if playlist_version else "unknown"
+    message = f"player {player_name}, playlist loop completed, restarting {version_info}"
+    
+    return send_player_feedback(
+        config=config,
+        message=message,
+        status="restarting",
+        playlist_version=playlist_version
+    )
+
+def send_player_error_feedback(config, error_message, playlist_version=None):
+    """
+    Send feedback when an error occurs in the player.
+    
+    Args:
+        config (dict): Configuration containing server details
+        error_message (str): Description of the error
+        playlist_version (int, optional): Current playlist version
+    
+    Returns:
+        bool: True if feedback sent successfully, False otherwise
+    """
+    player_name = config.get("screen_name", "unknown")
+    message = f"player {player_name}, error occurred"
+    
+    return send_player_feedback(
+        config=config,
+        message=message,
+        status="error",
+        playlist_version=playlist_version,
+        error_details=error_message
+    )
+
+def send_playing_status_feedback(config, playlist_version=None, current_media=None):
+    """
+    Send feedback about current playing status.
+    
+    Args:
+        config (dict): Configuration containing server details
+        playlist_version (int, optional): Current playlist version
+        current_media (str, optional): Currently playing media file
+    
+    Returns:
+        bool: True if feedback sent successfully, False otherwise
+    """
+    player_name = config.get("screen_name", "unknown")
+    version_info = f"v{playlist_version}" if playlist_version else "unknown"
+    media_info = f" - {current_media}" if current_media else ""
+    message = f"player {player_name}, is active, Playing {version_info}{media_info}"
+    
+    return send_player_feedback(
+        config=config,
+        message=message,
+        status="playing",
+        playlist_version=playlist_version
+    )
+
+def is_playlist_up_to_date(local_playlist_path, config):
+    """
+    Compare the version of the local playlist with the server playlist.
+    Returns True if up-to-date, False otherwise.
+    """
+    import json
+    if not os.path.exists(local_playlist_path):
+        Logger.info(f"Local playlist file not found: {local_playlist_path}")
+        return False
+    with open(local_playlist_path, 'r') as f:
+        local_data = json.load(f)
+    local_version = local_data.get('version', 0)
+    server_data = fetch_server_playlist(config)
+    server_version = server_data.get('version', 0)
+    Logger.info(f"Local playlist version: {local_version}, Server playlist version: {server_version}")
+    return local_version == server_version
+
+def fetch_server_playlist(config):
+    """Fetch the updated playlist from the server using a config dict."""
+    server = config.get("server_ip", "")
+    host = config.get("screen_name", "")
+    quick = config.get("quickconnect_key", "")
+    port = config.get("port", "")
+    try:
+        ip_pattern = r'^\d+\.\d+\.\d+\.\d+$'
+        if re.match(ip_pattern, server):
+            server_url = f'http://{server}:{port}/api/playlists'
+        else:
+            server_url = f'http://{server}/api/playlists'
+        params = {
+            'hostname': host,
+            'quickconnect_code': quick
+        }
+        Logger.info(f"Fetching playlist from URL: {server_url} with params: {params}")
+        response = requests.get(server_url, params=params)
+        if response.status_code == 200:
+            response_data = response.json()
+            Logger.info(f"Server response: {response_data}")
+            playlist = response_data.get('playlist', [])
+            version = response_data.get('playlist_version', None)
+            hashed_quickconnect = response_data.get('hashed_quickconnect', None)
+            if version is not None and hashed_quickconnect is not None:
+                if bcrypt.checkpw(quick.encode('utf-8'), hashed_quickconnect.encode('utf-8')):
+                    Logger.info("Fetched updated playlist from server.")
+                    return {'playlist': playlist, 'version': version}
+                else:
+                    Logger.error("Quickconnect code validation failed.")
+            else:
+                Logger.error("Failed to retrieve playlist or hashed quickconnect from the response.")
+        else:
+            Logger.error(f"Failed to fetch playlist. Status Code: {response.status_code}")
+    except requests.exceptions.RequestException as e:
+        Logger.error(f"Failed to fetch playlist: {e}")
+    return {'playlist': [], 'version': 0}
+
+def save_playlist_with_version(playlist_data, playlist_dir):
+    version = playlist_data.get('version', 0)
+    playlist_file = os.path.join(playlist_dir, f'server_playlist_v{version}.json')
+    with open(playlist_file, 'w') as f:
+        json.dump(playlist_data, f, indent=2)
+    print(f"Playlist saved to {playlist_file}")
+    return playlist_file
+
+
+def download_media_files(playlist, media_dir):
+    """Download media files from the server and save them to media_dir."""
+    if not os.path.exists(media_dir):
+        os.makedirs(media_dir)
+        Logger.info(f"Created directory {media_dir} for media files.")
+
+    updated_playlist = []
+    for media in playlist:
+        file_name = media.get('file_name', '')
+        file_url = media.get('url', '')
+        duration = media.get('duration', 10)
+        local_path = os.path.join(media_dir, file_name)
+        Logger.info(f"Preparing to download {file_name} from {file_url}...")
+        if os.path.exists(local_path):
+            Logger.info(f"File {file_name} already exists. Skipping download.")
+        else:
+            try:
+                response = requests.get(file_url, timeout=10)
+                if response.status_code == 200:
+                    with open(local_path, 'wb') as file:
+                        file.write(response.content)
+                    Logger.info(f"Successfully downloaded {file_name} to {local_path}")
+                else:
+                    Logger.error(f"Failed to download {file_name}. Status Code: {response.status_code}")
+                    continue
+            except requests.exceptions.RequestException as e:
+                Logger.error(f"Error downloading {file_name}: {e}")
+                continue
+        updated_media = {
+            'file_name': file_name,
+            'url': os.path.relpath(local_path, os.path.dirname(media_dir)),
+            'duration': duration
+        }
+        updated_playlist.append(updated_media)
+    return updated_playlist
+
+def delete_old_playlists_and_media(current_version, playlist_dir, media_dir, keep_versions=1):
+    """
+    Delete old playlist files and media files not referenced by the latest playlist version.
+    keep_versions: number of latest versions to keep (default 1)
+    """
+    # Find all playlist files
+    playlist_files = [f for f in os.listdir(playlist_dir) if f.startswith('server_playlist_v') and f.endswith('.json')]
+    # Keep only the latest N versions
+    versions = sorted([int(f.split('_v')[-1].split('.json')[0]) for f in playlist_files], reverse=True)
+    keep = set(versions[:keep_versions])
+    # Delete old playlist files
+    for f in playlist_files:
+        v = int(f.split('_v')[-1].split('.json')[0])
+        if v not in keep:
+            os.remove(os.path.join(playlist_dir, f))
+    # Collect all media files referenced by the kept playlists
+    referenced = set()
+    for v in keep:
+        path = os.path.join(playlist_dir, f'server_playlist_v{v}.json')
+        if os.path.exists(path):
+            with open(path, 'r') as f:
+                data = json.load(f)
+            for item in data.get('playlist', []):
+                referenced.add(item.get('file_name'))
+    # Delete media files not referenced
+    for f in os.listdir(media_dir):
+        if f not in referenced:
+            try:
+                os.remove(os.path.join(media_dir, f))
+            except Exception as e:
+                Logger.warning(f"Failed to delete media file {f}: {e}")
+
+def update_playlist_if_needed(local_playlist_path, config, media_dir, playlist_dir):
+    """
+    Fetch the server playlist once, compare versions, and update if needed.
+    Returns True if updated, False if already up to date.
+    Also sends feedback to server about playlist check.
+    """
+    import json
+    server_data = fetch_server_playlist(config)
+    server_version = server_data.get('version', 0)
+    if not os.path.exists(local_playlist_path):
+        local_version = 0
+    else:
+        with open(local_playlist_path, 'r') as f:
+            local_data = json.load(f)
+        local_version = local_data.get('version', 0)
+    
+    Logger.info(f"Local playlist version: {local_version}, Server playlist version: {server_version}")
+    
+    # Send feedback about playlist check
+    send_playlist_check_feedback(config, server_version if server_version > 0 else local_version)
+    
+    if local_version != server_version:
+        if server_data and server_data.get('playlist'):
+            updated_playlist = download_media_files(server_data['playlist'], media_dir)
+            server_data['playlist'] = updated_playlist
+            save_playlist_with_version(server_data, playlist_dir)
+            # Delete old playlists and unreferenced media
+            delete_old_playlists_and_media(server_version, playlist_dir, media_dir)
+            
+            # Send feedback about playlist update
+            player_name = config.get("screen_name", "unknown")
+            update_message = f"player {player_name}, playlist updated to v{server_version}"
+            send_player_feedback(config, update_message, "active", server_version)
+            
+            return True
+        else:
+            Logger.warning("No playlist data fetched from server or playlist is empty.")
+            
+            # Send error feedback
+            send_player_error_feedback(config, "No playlist data fetched from server or playlist is empty", local_version)
+            
+            return False
+    else:
+        Logger.info("Local playlist is already up to date.")
+        return False
+
+
+

docker-compose.yml

@@ -16,8 +16,11 @@ services:
       - ADMIN_PASSWORD=Initial01!
       - SECRET_KEY=Ma_Duc_Dupa_Merele_Lui_Ana
     volumes:
-      # Bind mount the app folder for easier development and debugging
-      - ./data:/app
+  # Persistent data volumes
+    - ./app:/app
+    - ./data/instance:/app/instance
+    - ./data/uploads:/app/static/uploads
+    - ./data/resurse:/app/static/resurse
     restart: unless-stopped
     healthcheck:
       test: ["CMD", "curl", "-f", "http://localhost:5000/"]