Update music_api.py

music_api.py

@@ -1,432 +1,270 @@
 #!/usr/bin/env python3
-"""
-修复版音乐API - 适配 Gradio/Non-Docker Space (直接读取 Dataset)
-"""
-
 import os
 import sqlite3
 import shutil
 from pathlib import Path
-from typing import Optional, List, Dict
-import urllib.parse
-
-from fastapi import FastAPI, Query, HTTPException, UploadFile, File, Form
+from typing import Optional, List
+from fastapi import FastAPI, UploadFile, File, Query, HTTPException
 from fastapi.responses import FileResponse, HTMLResponse, JSONResponse
-from fastapi.staticfiles import StaticFiles
 from fastapi.middleware.cors import CORSMiddleware
 import uvicorn
 from mutagen import File as MutagenFile
-from huggingface_hub import hf_hub_download, snapshot_download, HfApi
-
-# ==================== 配置部分 ====================
+from huggingface_hub import HfApi, hf_hub_download
 
+# ==================== 配置 ====================
 class Config:
-    """配置类"""
-    APP_NAME = "音乐API"
-    VERSION = "4.6.0"
-    
-    BASE_DIR = Path(__file__).resolve().parent
-    
-    # ===== Dataset 配置 =====
-    # 请填入您的 Dataset 路径，例如 "your_username/my-music-library"
-    DATASET_REPO_ID = "my-music-library" 
-    # 本地缓存目录 (HuggingFace 会自动缓存下载的文件)
-    DATASET_CACHE_DIR = Path("/tmp/hf_cache")
+    APP_NAME = "Music API"
+    VERSION = "5.1.0"
     
-    # ===== 本地存储 (新上传的文件) =====
-    # 非Docker环境下，通常只有 /tmp 或 /home/user，这里用 /tmp 缓存新上传
-    # 注意：Space 重启后 /tmp 会清空，这是 Gradio 模式的限制
-    UPLOAD_DIR = Path("/tmp/uploads") 
+    # Dataset ID (可在 Settings -> Variables 设置 HF_DATASET_REPO_ID)
+    DATASET_REPO_ID = os.environ.get("HF_DATASET_REPO_ID", "my-music-library")
     
-    # 数据库路径
+    # 本地缓存和上传目录
+    CACHE_DIR = Path("/tmp/hf_cache")
+    UPLOAD_DIR = Path("/tmp/uploads")
     DATABASE_PATH = Path("/tmp/music.db")
     
+    # 服务器配置
     HOST = "0.0.0.0"
     PORT = int(os.environ.get("PORT", 7860))
-    DEBUG = True
-    
-    def __init__(self):
-        self.UPLOAD_DIR.mkdir(parents=True, exist_ok=True)
-        self.DATABASE_PATH.parent.mkdir(parents=True, exist_ok=True)
 
 config = Config()
+config.CACHE_DIR.mkdir(parents=True, exist_ok=True)
+config.UPLOAD_DIR.mkdir(parents=True, exist_ok=True)
 
 # ==================== 辅助函数 ====================
-
-def get_dataset_files():
-    """
-    尝试获取 Dataset 的文件列表。
-    由于非Docker模式无法直接挂载，我们尝试从 Hub 获取文件列表。
-    如果失败（例如没有权限），返回空列表。
-    """
+def get_remote_files():
     try:
         api = HfApi()
-        # 获取 repo 所有文件树
-        repo_files = api.list_repo_tree(repo_id=config.DATASET_REPO_ID, token=os.environ.get("HF_TOKEN"), repo_type="dataset")
-        
-        # 转换成相对路径列表
-        files = []
-        for file_info in repo_files:
-            if file_info.type == "file":
-                # 转换为 Path 对象的相对路径
-                files.append(file_info.path)
-        return files
+        tree = api.list_repo_tree(repo_id=config.DATASET_REPO_ID, repo_type="dataset")
+        return [item.path for item in tree if item.type == "file"]
     except Exception as e:
-        print(f"⚠️ 无法连接到 Dataset Hub: {e}")
+        print(f"Error fetching dataset: {e}")
         return []
 
-def extract_audio_metadata(file_path: Path) -> Dict:
-    """使用 mutagen 提取音频文件的元数据"""
+def get_metadata(file_path: Path):
     try:
         audio = MutagenFile(file_path)
-        if audio is None: return None
-        title = file_path.stem
-        artist = "Unknown Artist"
-        album = ""
-        genre = ""
+        if not audio: return None
+        title = artist = album = genre = ""
         duration = 0
         if hasattr(audio, 'info') and audio.info.length:
             duration = int(audio.info.length)
-        common_keys = {
-            'title': ['TIT2', '\xa9nam', 'TITLE', 'Title', 'title'],
-            'artist': ['TPE1', '\xa9ART', 'ARTIST', 'Artist', 'artist'],
-            'album': ['TALB', '\xa9alb', 'ALBUM', 'Album', 'album'],
-            'genre': ['TCON', '\xa9gen', 'GENRE', 'Genre', 'genre']
+        
+        tags = {
+            'title': ['TIT2', '\xa9nam', 'TITLE', 'Title'],
+            'artist': ['TPE1', '\xa9ART', 'ARTIST', 'Artist'],
+            'album': ['TALB', '\xa9alb', 'ALBUM', 'Album'],
+            'genre': ['TCON', '\xa9gen', 'GENRE', 'Genre']
         }
-        def get_tag(target_type):
-            for k in common_keys.get(target_type, []):
-                if k in audio:
-                    val = audio[k]
-                    if isinstance(val, list) and len(val) > 0:
-                        return str(val[0])
-                    return str(val)
-            return None
-        if get_tag('title'): title = get_tag('title')
-        if get_tag('artist'): artist = get_tag('artist')
-        if get_tag('album'): album = get_tag('album')
-        if get_tag('genre'): genre = get_tag('genre')
-        return {"title": title, "artist": artist, "album": album, "genre": genre, "duration": duration, "file_size": file_path.stat().st_size}
-    except Exception as e:
-        return None
-
-# ==================== 数据库部分 ====================
+        
+        for k, v in tags.items():
+            val = None
+            if audio:
+                for key in v:
+                    if key in audio:
+                        val = str(audio[key][0] if isinstance(audio[key], list) else audio[key])
+                        break
+            if val: locals()[k] = val
+        
+        if not title: title = file_path.stem
+        if not artist: artist = "Unknown"
+        
+        return {"title": title, "artist": artist, "album": album, "genre": genre, "duration": duration, "size": file_path.stat().st_size}
+    except: return None
 
+# ==================== 数据库 ====================
 class Database:
     @staticmethod
-    def get_connection():
-        conn = sqlite3.connect(str(config.DATABASE_PATH))
-        conn.row_factory = sqlite3.Row
-        return conn
-    
-    @staticmethod
-    def init_database():
-        conn = Database.get_connection()
-        cursor = conn.cursor()
-        cursor.execute('''
-        CREATE TABLE IF NOT EXISTS music (
+    def init():
+        conn = sqlite3.connect(config.DATABASE_PATH)
+        c = conn.cursor()
+        c.execute('''CREATE TABLE IF NOT EXISTS music (
             id INTEGER PRIMARY KEY AUTOINCREMENT,
-            title TEXT NOT NULL,
-            artist TEXT NOT NULL,
-            album TEXT,
-            genre TEXT,
-            duration INTEGER,
-            file_name TEXT NOT NULL UNIQUE,
-            file_size INTEGER,
-            source_type TEXT DEFAULT 'local', -- 'local' 或 'dataset'
-            file_path TEXT,
-            created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
-        )
-        ''')
+            title TEXT, artist TEXT, album TEXT, genre TEXT,
+            duration INTEGER, file_name TEXT, source TEXT, path TEXT,
+            UNIQUE(file_name)
+        )''')
         conn.commit()
         conn.close()
-    
-    @staticmethod
-    def add_song(title, artist, album, genre, duration, file_name, file_size, source_type, file_path):
-        conn = Database.get_connection()
-        cursor = conn.cursor()
-        try:
-            cursor.execute('''
-                INSERT OR IGNORE INTO music 
-                (title, artist, album, genre, duration, file_name, file_size, source_type, file_path)
-                VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
-            ''', (title, artist, album, genre, duration, file_name, file_size, source_type, file_path))
-            song_id = cursor.lastrowid
-            conn.commit()
-            return song_id
-        except sqlite3.IntegrityError:
-            return 0
-        finally:
-            conn.close()
 
     @staticmethod
-    def scan_dataset_files():
-        """
-        从 Dataset Hub 扫描文件并注册到数据库
-        注意：这里只是注册元数据，文件会在第一次播放时才下载
-        """
-        added_count = 0
-        skipped_count = 0
+    def scan():
+        Database.init()
+        remote_files = get_remote_files()
+        local_files = list(config.UPLOAD_DIR.glob("*.mp3")) + list(config.UPLOAD_DIR.glob("*.wav"))
         
-        # 1. 获取文件列表
-        remote_files = get_dataset_files()
-        if not remote_files:
-            return {"status": "error", "message": "无法获取 Dataset 文件列表，请检查名称或 Token"}
+        conn = sqlite3.connect(config.DATABASE_PATH)
+        c = conn.cursor()
+        count = 0
         
-        # 2. 扫描本地上传目录
-        local_files = []
-        if config.UPLOAD_DIR.exists():
-            for ext in ['.mp3', '.flac', '.wav', '.ogg', '.m4a']:
-                local_files.extend(config.UPLOAD_DIR.glob(f"*{ext}"))
-
-        conn = Database.get_connection()
-        cursor = conn.cursor()
-        
-        # 处理本地文件
-        for f_path in local_files:
-            meta = extract_audio_metadata(f_path) or {"title": f_path.stem, "artist": "Unknown", "album": "", "genre": "", "duration": 0, "file_size": f_path.stat().st_size}
-            song_id = Database.add_song(meta['title'], meta['artist'], meta['album'], meta['genre'], meta['duration'], f_path.name, meta['file_size'], 'local', str(f_path))
-            if song_id > 0:
-                added_count += 1
-                print(f"✅ 本地: {meta['title']}")
-            else:
-                skipped_count += 1
-
         # 处理远程文件
-        # 假设 Dataset 结构是 static/music/song.mp3
-        target_prefix = "static/music/"
-        for file_path in remote_files:
-            if not file_path.startswith(target_prefix):
-                continue
-            
-            # 提取文件名
-            filename = file_path.split("/")[-1]
+        for path in remote_files:
+            if not path.lower().endswith(('.mp3', '.flac', '.wav', '.ogg')): continue
+            filename = path.split('/')[-1]
+            try:
+                c.execute("INSERT OR IGNORE INTO music (title, artist, file_name, source, path) VALUES (?,?,?,?,?)",
+                          (Path(filename).stem, "Dataset Artist", filename, "dataset", path))
+                if c.rowcount > 0: count += 1
+            except: pass
             
-            # 简单估算大小 (这里无法获取远程文件真实大小，先填0)
-            size = 0 
-            duration = 0 # 无法扫描远程文件元数据
-            
-            # 默认元数据
-            title = Path(filename).stem
-            artist = "Unknown Artist"
+        # 处理本地文件
+        for path in local_files:
+            meta = get_metadata(path) or {}
+            c.execute("INSERT OR IGNORE INTO music (title, artist, file_name, source, path, duration) VALUES (?,?,?,?,?,?)",
+                      (meta.get('title'), meta.get('artist'), path.name, "local", str(path), meta.get('duration', 0)))
+            if c.rowcount > 0: count += 1
             
-            song_id = Database.add_song(title, artist, "", "", duration, filename, size, 'dataset', file_path)
-            if song_id > 0:
-                added_count += 1
-                print(f"✅ 远程: {filename}")
-            else:
-                skipped_count += 1
-                
+        conn.commit()
         conn.close()
-        return {"status": "success", "added": added_count, "skipped": skipped_count, "message": f"扫描完成"}
+        return {"added": count}
 
     @staticmethod
-    def get_all_songs(limit=100):
-        conn = Database.get_connection()
-        cursor = conn.cursor()
-        cursor.execute("SELECT * FROM music ORDER BY id DESC LIMIT ?", (limit,))
-        rows = cursor.fetchall()
+    def get_all(limit=100):
+        conn = sqlite3.connect(config.DATABASE_PATH)
+        conn.row_factory = sqlite3.Row
+        c = conn.cursor()
+        c.execute("SELECT * FROM music ORDER BY id DESC LIMIT ?", (limit,))
+        songs = [dict(row) for row in c.fetchall()]
         conn.close()
-        return [dict(row) for row in rows]
-    
+        return songs
+
     @staticmethod
-    def get_song_by_id(song_id: int):
-        conn = Database.get_connection()
-        cursor = conn.cursor()
-        cursor.execute("SELECT * FROM music WHERE id = ?", (song_id,))
-        row = cursor.fetchone()
+    def get_by_id(song_id):
+        conn = sqlite3.connect(config.DATABASE_PATH)
+        conn.row_factory = sqlite3.Row
+        c = conn.cursor()
+        c.execute("SELECT * FROM music WHERE id = ?", (song_id,))
+        song = c.fetchone()
         conn.close()
-        return dict(row) if row else None
+        return dict(song) if song else None
 
-# ==================== FastAPI应用部分 ====================
+# ==================== FastAPI ====================
+app = FastAPI()
+app.add_middleware(CORSMiddleware, allow_origins=["*"], allow_methods=["*"], allow_headers=["*"])
+
+@app.on_event("startup")
+def startup(): Database.scan()
 
-API_DOCS_HTML = API_DOCS_HTML = """
-<!DOCTYPE html>
-<html lang="zh-CN">
-<head>
-    <meta charset="UTF-8">
-    <meta name="viewport" content="width=device-width, initial-scale=1.0">
-    <title>音乐API - 管理面板</title>
+@app.get("/", response_class=HTMLResponse)
+async def index():
+    return """
+    <!DOCTYPE html>
+    <html>
+    <head><title>Music Player</title>
     <style>
-        :root { --bg: #1a1a2e; --card: #16213e; --text: #e0e0e0; --accent: #e94560; --input: #0f3460; }
-        body { font-family: sans-serif; background: var(--bg); color: var(--text); padding: 20px; max-width: 800px; margin: auto; }
-        h1 { text-align: center; }
-        .section { background: var(--card); padding: 20px; border-radius: 8px; margin-bottom: 20px; }
-        .section h2 { border-bottom: 1px solid #333; padding-bottom: 10px; margin-bottom: 15px; }
-        label { display: block; margin: 10px 0 5px; font-weight: bold; }
-        input[type="text"], input[type="file"] { width: 100%; padding: 10px; background: #333; border: 1px solid #444; color: white; border-radius: 4px; box-sizing: border-box; margin-bottom: 15px;}
-        button { background: var(--accent); color: white; border: none; padding: 12px 24px; border-radius: 4px; cursor: pointer; width: 100%; font-size: 16px; }
-        button:hover { opacity: 0.9; }
-        .btn-secondary { background: #444; margin-top: 10px; }
-        .result { margin-top: 15px; padding: 10px; background: #0f0f1a; border-radius: 4px; display: none; }
-        pre { white-space: pre-wrap; word-break: break-all; }
+        body { font-family: sans-serif; max-width: 800px; margin: 20px auto; background: #f4f4f9; padding: 20px; }
+        .card { background: white; padding: 20px; border-radius: 8px; box-shadow: 0 2px 4px rgba(0,0,0,0.1); margin-bottom: 20px; }
+        h2 { border-bottom: 2px solid #eee; padding-bottom: 10px; }
+        button { background: #007bff; color: white; border: none; padding: 10px 20px; border-radius: 4px; cursor: pointer; }
+        button:hover { background: #0056b3; }
+        .song-list { list-style: none; padding: 0; }
+        .song-item { padding: 10px; border-bottom: 1px solid #eee; display: flex; justify-content: space-between; align-items: center; }
+        .song-item:hover { background: #f9f9f9; cursor: pointer; }
+        .playing { color: #007bff; font-weight: bold; }
+        input[type="file"] { margin-bottom: 10px; }
+        #player { position: fixed; bottom: 0; left: 0; right: 0; background: #333; color: white; padding: 10px; display: flex; align-items: center; gap: 10px; }
     </style>
-</head>
-<body>
-    <h1>🎵 音乐 API 管理面板</h1>
-    
-    <!-- 扫描区域 -->
-    <div class="section">
-        <h2>📂 扫描库</h2>
-        <p>点击下方按钮，扫描 /data 和 /dataset 目录下的所有音乐文件并更新数据库。</p>
-        <button onclick="scanLibrary()">扫描并更新数据库</button>
-        <div id="scanResult" class="result"><pre></pre></div>
-    </div>
-
-    <!-- 上传区域 -->
-    <div class="section">
-        <h2>⬆️ 上传新歌</h2>
-        <p>上传 MP3 文件和封面。文件将保存到可写存储 (/data/static)。</p>
-        <form id="uploadForm" onsubmit="uploadSong(event)">
-            <label>音乐文件 (MP3)</label>
-            <input type="file" id="file" accept="audio/*" required>
-            
-            <label>封面图片 (可选, JPG/PNG)</label>
-            <input type="file" id="cover" accept="image/*">
-            
-            <label>标题 (可选，留空自动读取)</label>
-            <input type="text" id="title" placeholder="自动读取...">
-            
-            <label>艺术家 (可选，留空自动读取)</label>
-            <input type="text" id="artist" placeholder="自动读取...">
-            
-            <button type="submit">开始上传</button>
-        </form>
-        <div id="uploadResult" class="result"><pre></pre></div>
-    </div>
-    
-    <!-- 歌曲列表 -->
-    <div class="section">
-        <h2>📋 最近添加</h2>
-        <div id="songsList">加载中...</div>
-    </div>
+    </head>
+    <body>
+        <div class="card">
+            <h2>📚 Library Management</h2>
+            <button onclick="scan()">Scan Library</button>
+            <div id="scan-status"></div>
+        </div>
+        
+        <div class="card">
+            <h2>⬆️ Upload</h2>
+            <input type="file" id="fileInput" accept="audio/*">
+            <button onclick="upload()">Upload</button>
+            <div id="upload-status"></div>
+        </div>
 
-    <script>
-        const API_BASE = window.location.origin;
+        <div class="card">
+            <h2>🎵 Songs (<span id="count">0</span>)</h2>
+            <ul class="song-list" id="songList"></ul>
+        </div>
 
-        function showResult(id, msg) {
-            const el = document.getElementById(id);
-            el.style.display = 'block';
-            el.innerText = msg;
-        }
+        <audio id="audio" controls style="width:100%; display:none;"></audio>
+        <div id="player"></div>
 
-        async function scanLibrary() {
-            showResult('scanResult', '正在扫描...');
-            try {
-                const res = await fetch(`${API_BASE}/api/scan`);
-                const data = await res.json();
-                showResult('scanResult', JSON.stringify(data, null, 2));
-                loadSongs(); // 刷新列表
-            } catch(e) {
-                showResult('scanResult', 'Error: ' + e);
+        <script>
+            const API = '';
+            async function scan() {
+                document.getElementById('scan-status').innerText = 'Scanning...';
+                await fetch(API + '/api/scan');
+                loadSongs();
+                document.getElementById('scan-status').innerText = 'Done!';
             }
-        }
-
-        async function uploadSong(e) {
-            e.preventDefault();
-            showResult('uploadResult', '正在上传...');
-            
-            const formData = new FormData();
-            formData.append('file', document.getElementById('file').files[0]);
-            if(document.getElementById('cover').files[0]) {
-                formData.append('cover', document.getElementById('cover').files[0]);
+            async function loadSongs() {
+                const res = await fetch(API + '/api/music?limit=100');
+                const songs = await res.json();
+                document.getElementById('count').innerText = songs.length;
+                const list = document.getElementById('songList');
+                list.innerHTML = songs.map(s => `
+                    <li class="song-item" onclick="play(${s.id})">
+                        <span>${s.title} - ${s.artist}</span>
+                        <small>${s.source === 'dataset' ? '☁️' : '💾'}</small>
+                    </li>`).join('');
             }
-            formData.append('title', document.getElementById('title').value);
-            formData.append('artist', document.getElementById('artist').value);
-
-            try {
-                const res = await fetch(`${API_BASE}/api/upload`, { method: 'POST', body: formData });
-                const data = await res.json();
-                if(res.ok) {
-                    showResult('uploadResult', `上传成功! ID: ${data.id}\n` + JSON.stringify(data, null, 2));
-                    document.getElementById('uploadForm').reset();
-                    loadSongs();
-                } else {
-                    showResult('uploadResult', `上传失败: ${data.detail}`);
-                }
-            } catch(e) {
-                showResult('uploadResult', 'Error: ' + e);
+            async function play(id) {
+                const audio = document.getElementById('audio');
+                audio.src = API + '/api/play/' + id;
+                audio.style.display = 'block';
+                audio.play();
             }
-        }
-
-        async function loadSongs() {
-            try {
-                const res = await fetch(`${API_BASE}/api/music?limit=10`);
-                const songs = await res.json();
-                const html = songs.map(s => 
-                    `<div style="padding:10px; border-bottom:1px solid #333;">
-                        <b>${s.title}</b> -${s.artist}<br>
-                        <small>File: ${s.file_name} | Size:${(s.file_size/1024/1024).toFixed(2)}MB</small>
-                    </div>`
-                ).join('');
-                document.getElementById('songsList').innerHTML = html || '暂无歌曲，请扫描或上传';
-            } catch(e) {
-                document.getElementById('songsList').innerText = '加载失败';
+            async function upload() {
+                const fileInput = document.getElementById('fileInput');
+                if(!fileInput.files[0]) return alert('Select file');
+                const formData = new FormData();
+                formData.append('file', fileInput.files[0]);
+                const res = await fetch(API + '/api/upload', { method: 'POST', body: formData });
+                if(res.ok) { alert('Uploaded!'); scan(); }
+                else alert('Failed');
             }
-        }
-        
-        loadSongs();
-    </script>
-</body>
-</html>
-"""
-app.add_middleware(CORSMiddleware, allow_origins=["*"], allow_credentials=True, allow_methods=["*"], allow_headers=["*"])
-
-# 页面 (保持之前的 HTML 结构，这里为了简洁略去，请使用上一版完整的 HTML)
-# ... (请确保复制上一版完整的 API_DOCS_HTML 字符串到这里，或者在代码末尾单独提供) ...
-# 为了代码完整性，这里附上一个简单的 HTML 占位
-
+            loadSongs();
+        </script>
+    </body>
+    </html>
+    """
 
-@app.on_event("startup")
-def startup_event():
-    Database.init_database()
+@app.get("/api/scan")
+async def scan():
+    return Database.scan()
 
-@app.get("/")
-async def get_frontend():
-    return HTMLResponse(API_DOCS_HTML)
+@app.get("/api/music")
+async def get_music(limit: int = 100):
+    return Database.get_all(limit)
 
-# --- 播放接口 (核心逻辑) ---
 @app.get("/api/play/{song_id}")
-async def play_music(song_id: int):
-    song = Database.get_song_by_id(song_id)
+async def play(song_id: int):
+    song = Database.get_by_id(song_id)
     if not song: raise HTTPException(404)
     
-    # 逻辑分支
-    if song['source_type'] == 'local':
-        # 本地文件直接返回
-        path = Path(song['file_path'])
-        if not path.exists(): raise HTTPException(404)
-        return FileResponse(path)
-        
-    elif song['source_type'] == 'dataset':
-        # 远程文件：下载到本地缓存，然后返回
+    if song['source'] == 'dataset':
+        # 下载远程文件到缓存
         try:
-            # 使用 hf_hub_download 下载单文件
             local_path = hf_hub_download(
                 repo_id=config.DATASET_REPO_ID,
-                filename=song['file_path'],
+                filename=song['path'],
                 repo_type="dataset",
-                cache_dir=str(config.DATASET_CACHE_DIR),
+                cache_dir=str(config.CACHE_DIR),
                 resume_download=True
             )
             return FileResponse(local_path)
         except Exception as e:
-            raise HTTPException(500, detail=f"Dataset 下载失败: {e}")
-
-# --- 其他 API ---
-@app.get("/api/scan")
-async def scan():
-    return JSONResponse(Database.scan_dataset_files())
-
-@app.get("/api/music")
-async def get_music(limit: int = 100):
-    return Database.get_all_songs(limit)
+            raise HTTPException(500, detail=str(e))
+    else:
+        # 本地文件
+        return FileResponse(song['path'])
 
 @app.post("/api/upload")
 async def upload(file: UploadFile = File(...)):
     dest = config.UPLOAD_DIR / file.filename
-    with open(dest, "wb") as f:
-        shutil.copyfileobj(file.file, f)
-    
-    # 简单插入数据库
-    Database.scan_dataset_files() # 重新扫描以更新列表
-    return JSONResponse({"status": "success", "filename": file.filename})
+    with open(dest, "wb") as f: shutil.copyfileobj(file.file, f)
+    # 简单触发扫描
+    Database.scan()
+    return {"status": "ok"}
+
+if __name__ == "__main__":
+    uvicorn.run(app, host=config.HOST, port=config.PORT)