mirror of
https://github.com/ZHANGTIANYAO1/teamspeak-music-bot.git
synced 2026-10-02 13:02:49 +08:00
Merge PR #87: local favorites feature
# Conflicts: # web/src/stores/player.ts
This commit is contained in:
commit
140020f63a
9 files changed
+391
-4
No files matched your search
@@ -0,0 +1,76 @@
|
||||
import { Router } from "express";
|
||||
import type { BotDatabase } from "../../data/database.js";
|
||||
import type { Logger } from "../../logger.js";
|
||||
|
||||
export function createFavoritesRouter(database: BotDatabase, logger: Logger): Router {
|
||||
const router = Router();
|
||||
|
||||
// GET /api/favorites — 获取当前用户的所有收藏
|
||||
router.get("/", (req, res) => {
|
||||
const userId = req.user!.id;
|
||||
const favorites = database.getFavorites(userId);
|
||||
res.json({ favorites });
|
||||
});
|
||||
|
||||
// POST /api/favorites — 添加收藏
|
||||
router.post("/", (req, res) => {
|
||||
const userId = req.user!.id;
|
||||
const { platform, playlistId, name, coverUrl, songCount } = req.body;
|
||||
if (!platform || !playlistId || !name) {
|
||||
res.status(400).json({ error: "platform, playlistId, name are required" });
|
||||
return;
|
||||
}
|
||||
try {
|
||||
database.addFavorite(userId, {
|
||||
platform,
|
||||
playlistId,
|
||||
name,
|
||||
coverUrl: coverUrl ?? "",
|
||||
songCount: songCount ?? 0,
|
||||
});
|
||||
logger.info({ userId, platform, playlistId, name }, "Playlist favorited");
|
||||
res.json({ success: true });
|
||||
} catch (err: unknown) {
|
||||
const e = err as { code?: string };
|
||||
if (e?.code === "SQLITE_CONSTRAINT_UNIQUE") {
|
||||
res.status(409).json({ error: "already favorited" });
|
||||
return;
|
||||
}
|
||||
logger.error({ err }, "Failed to add favorite");
|
||||
res.status(500).json({ error: "internal error" });
|
||||
}
|
||||
});
|
||||
|
||||
// DELETE /api/favorites/:id — 取消收藏(只允许删除自己的)
|
||||
router.delete("/:id", (req, res) => {
|
||||
const userId = req.user!.id;
|
||||
const favId = parseInt(req.params.id, 10);
|
||||
if (isNaN(favId)) {
|
||||
res.status(400).json({ error: "invalid id" });
|
||||
return;
|
||||
}
|
||||
const favorites = database.getFavorites(userId);
|
||||
const fav = favorites.find((f) => f.id === favId);
|
||||
if (!fav) {
|
||||
res.status(404).json({ error: "favorite not found" });
|
||||
return;
|
||||
}
|
||||
database.removeFavorite(userId, fav.playlistId, fav.platform);
|
||||
logger.info({ userId, playlistId: fav.playlistId, platform: fav.platform }, "Playlist unfavorited");
|
||||
res.json({ success: true });
|
||||
});
|
||||
|
||||
// GET /api/favorites/check?platform=netease&playlistId=xxx — 检查是否已收藏
|
||||
router.get("/check", (req, res) => {
|
||||
const userId = req.user!.id;
|
||||
const { platform, playlistId } = req.query;
|
||||
if (!platform || !playlistId) {
|
||||
res.status(400).json({ error: "platform and playlistId required" });
|
||||
return;
|
||||
}
|
||||
const favorited = database.isFavorited(userId, playlistId as string, platform as string);
|
||||
res.json({ favorited });
|
||||
});
|
||||
|
||||
return router;
|
||||
}
|
||||
@@ -18,6 +18,7 @@ import { createSessionRouter } from "./api/session.js";
|
||||
import { createUsersRouter } from "./api/users.js";
|
||||
import { createAuditStore } from "../data/audit.js";
|
||||
import { createAuditRouter } from "./api/audit.js";
|
||||
import { createFavoritesRouter } from "./api/favorites.js";
|
||||
import { setupWebSocket } from "./websocket.js";
|
||||
import { createUserStore } from "../data/users.js";
|
||||
import { createSessionStore } from "../data/sessions.js";
|
||||
@@ -123,6 +124,8 @@ export function createWebServer(options: WebServerOptions): WebServer {
|
||||
"/api/auth",
|
||||
createAuthRouter(options.neteaseProvider, options.qqProvider, options.bilibiliProvider, logger, options.cookieStore)
|
||||
);
|
||||
app.use("/api/favorites", createFavoritesRouter(options.database, logger));
|
||||
|
||||
// admin-only routes
|
||||
app.use("/api/users", requireAdmin, createUsersRouter(users, sessions, audit, logger));
|
||||
app.use("/api/audit", requireAdmin, createAuditRouter(audit));
|
||||
|
||||
Reference in new issue
Block a user