mirror of
https://github.com/ZHANGTIANYAO1/teamspeak-music-bot.git
synced 2026-10-02 13:02:49 +08:00
Compare commits
15
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
ecdb2d253e | ||
|
|
8860347bfe | ||
|
|
beb99f1d8e | ||
|
|
63f1ced2bc | ||
|
|
fa6013d22e | ||
|
|
6b60792277 | ||
|
|
c562fe05b0 | ||
|
|
9efa818bbb | ||
|
|
d757e69bf4 | ||
|
|
8cccf2ed24 | ||
|
|
f6b82b8e21 | ||
|
|
51d7ce61bd | ||
|
|
20f4cfacea | ||
|
|
7d9081efc1 | ||
|
|
a2453784c1 |
No files matched your search
@@ -253,6 +253,7 @@ sudo systemctl start tsmusicbot
|
|||||||
| `!stop` | 停止播放并清空队列 |
|
| `!stop` | 停止播放并清空队列 |
|
||||||
| `!vol <0-100>` | 设置音量 |
|
| `!vol <0-100>` | 设置音量 |
|
||||||
| `!queue` | 查看播放队列 |
|
| `!queue` | 查看播放队列 |
|
||||||
|
| `!remove <位置>` | 从队列中删除指定位置的歌曲(位置从 1 开始,见 `!queue`) |
|
||||||
| `!mode <seq\|loop\|random\|rloop>` | 切换播放模式 |
|
| `!mode <seq\|loop\|random\|rloop>` | 切换播放模式 |
|
||||||
| `!playlist <歌单名或ID>` | 加载歌单(支持名称模糊搜索和 ID) |
|
| `!playlist <歌单名或ID>` | 加载歌单(支持名称模糊搜索和 ID) |
|
||||||
| `!playlist -q <歌单名>` | 从 QQ 音乐搜索并加载歌单 |
|
| `!playlist -q <歌单名>` | 从 QQ 音乐搜索并加载歌单 |
|
||||||
|
|||||||
+8
-1
@@ -279,8 +279,12 @@ export class AudioPlayer extends EventEmitter {
|
|||||||
this.emit("error", err);
|
this.emit("error", err);
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// Mark playing but DO NOT start the frame loop here — the loop's
|
||||||
|
// "no ffmpeg + empty buffer → trackEnd" branch would fire on the very
|
||||||
|
// first tick, before the PowerShell download even completes. The
|
||||||
|
// frame loop is started inside spawnFfmpegFromFile() once ffmpeg is
|
||||||
|
// alive and producing PCM.
|
||||||
this.state = "playing";
|
this.state = "playing";
|
||||||
this.startFrameLoop();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private spawnFfmpegFromFile(tempFile: string, seekSeconds: number, sessionId: number): void {
|
private spawnFfmpegFromFile(tempFile: string, seekSeconds: number, sessionId: number): void {
|
||||||
@@ -329,6 +333,9 @@ export class AudioPlayer extends EventEmitter {
|
|||||||
this.emit("error", err);
|
this.emit("error", err);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// Now that ffmpeg is producing PCM, run the frame loop.
|
||||||
|
this.startFrameLoop();
|
||||||
}
|
}
|
||||||
|
|
||||||
stop(): void {
|
stop(): void {
|
||||||
|
|||||||
+27
-4
@@ -22,6 +22,7 @@ export class PlayQueue {
|
|||||||
private mode: PlayMode = PlayMode.Sequential;
|
private mode: PlayMode = PlayMode.Sequential;
|
||||||
private playedIndices = new Set<number>();
|
private playedIndices = new Set<number>();
|
||||||
private history: number[] = [];
|
private history: number[] = [];
|
||||||
|
private forwardStack: number[] = [];
|
||||||
private static readonly HISTORY_LIMIT = 50;
|
private static readonly HISTORY_LIMIT = 50;
|
||||||
|
|
||||||
private pushHistory(idx: number): void {
|
private pushHistory(idx: number): void {
|
||||||
@@ -100,12 +101,14 @@ export class PlayQueue {
|
|||||||
this.currentIndex = -1;
|
this.currentIndex = -1;
|
||||||
this.playedIndices.clear();
|
this.playedIndices.clear();
|
||||||
this.history = [];
|
this.history = [];
|
||||||
|
this.forwardStack = [];
|
||||||
}
|
}
|
||||||
|
|
||||||
play(): QueuedSong | null {
|
play(): QueuedSong | null {
|
||||||
if (this.songs.length === 0) return null;
|
if (this.songs.length === 0) return null;
|
||||||
this.playedIndices.clear();
|
this.playedIndices.clear();
|
||||||
this.history = [];
|
this.history = [];
|
||||||
|
this.forwardStack = [];
|
||||||
this.currentIndex = 0;
|
this.currentIndex = 0;
|
||||||
this.playedIndices.add(0);
|
this.playedIndices.add(0);
|
||||||
return this.songs[0];
|
return this.songs[0];
|
||||||
@@ -118,6 +121,7 @@ export class PlayQueue {
|
|||||||
// shuffle from this point. History tracking is independent and
|
// shuffle from this point. History tracking is independent and
|
||||||
// unaffected by this clear.
|
// unaffected by this clear.
|
||||||
this.playedIndices.clear();
|
this.playedIndices.clear();
|
||||||
|
this.forwardStack = [];
|
||||||
this.currentIndex = index;
|
this.currentIndex = index;
|
||||||
this.playedIndices.add(index);
|
this.playedIndices.add(index);
|
||||||
return this.songs[index];
|
return this.songs[index];
|
||||||
@@ -139,7 +143,20 @@ export class PlayQueue {
|
|||||||
this.currentIndex = (this.currentIndex + 1) % this.songs.length;
|
this.currentIndex = (this.currentIndex + 1) % this.songs.length;
|
||||||
return this.songs[this.currentIndex];
|
return this.songs[this.currentIndex];
|
||||||
}
|
}
|
||||||
case PlayMode.Random: {
|
case PlayMode.Random:
|
||||||
|
case PlayMode.RandomLoop: {
|
||||||
|
// 优先回到前进栈记录的位置(prev 退回的歌)
|
||||||
|
if (this.forwardStack.length > 0) {
|
||||||
|
const target = this.forwardStack.pop()!;
|
||||||
|
if (target !== this.currentIndex) {
|
||||||
|
this.pushHistory(this.currentIndex);
|
||||||
|
this.currentIndex = target;
|
||||||
|
this.playedIndices.add(target);
|
||||||
|
return this.songs[target];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
// 前进栈为空,走纯随机逻辑
|
||||||
|
if (this.mode === PlayMode.Random) {
|
||||||
const unplayed: number[] = [];
|
const unplayed: number[] = [];
|
||||||
for (let i = 0; i < this.songs.length; i++) {
|
for (let i = 0; i < this.songs.length; i++) {
|
||||||
if (!this.playedIndices.has(i)) unplayed.push(i);
|
if (!this.playedIndices.has(i)) unplayed.push(i);
|
||||||
@@ -151,8 +168,7 @@ export class PlayQueue {
|
|||||||
this.currentIndex = nextIndex;
|
this.currentIndex = nextIndex;
|
||||||
this.playedIndices.add(nextIndex);
|
this.playedIndices.add(nextIndex);
|
||||||
return this.songs[nextIndex];
|
return this.songs[nextIndex];
|
||||||
}
|
} else {
|
||||||
case PlayMode.RandomLoop: {
|
|
||||||
if (this.songs.length === 1) {
|
if (this.songs.length === 1) {
|
||||||
this.pushHistory(this.currentIndex);
|
this.pushHistory(this.currentIndex);
|
||||||
this.currentIndex = 0;
|
this.currentIndex = 0;
|
||||||
@@ -168,17 +184,23 @@ export class PlayQueue {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
prev(): QueuedSong | null {
|
prev(): QueuedSong | null {
|
||||||
if (this.songs.length === 0) return null;
|
if (this.songs.length === 0) return null;
|
||||||
|
|
||||||
|
// 记录当前位置到前进栈,供 next 优先返回
|
||||||
|
if (this.currentIndex >= 0 && this.forwardStack.length < PlayQueue.HISTORY_LIMIT) {
|
||||||
|
this.forwardStack.push(this.currentIndex);
|
||||||
|
}
|
||||||
|
|
||||||
// Preferred: pop from the back-stack so prev means "the song I
|
// Preferred: pop from the back-stack so prev means "the song I
|
||||||
// actually played before this one," not "the previous array slot."
|
// actually played before this one," not "the previous array slot."
|
||||||
while (this.history.length > 0) {
|
while (this.history.length > 0) {
|
||||||
const idx = this.history.pop()!;
|
const idx = this.history.pop()!;
|
||||||
if (idx >= 0 && idx < this.songs.length) {
|
if (idx >= 0 && idx < this.songs.length) {
|
||||||
this.currentIndex = idx;
|
this.currentIndex = idx;
|
||||||
this.playedIndices.add(idx);
|
this.playedIndices = new Set([...this.history, this.currentIndex]);
|
||||||
return this.songs[idx];
|
return this.songs[idx];
|
||||||
}
|
}
|
||||||
// Stale entry (song removed) — keep popping.
|
// Stale entry (song removed) — keep popping.
|
||||||
@@ -227,6 +249,7 @@ export class PlayQueue {
|
|||||||
this.mode = mode;
|
this.mode = mode;
|
||||||
this.playedIndices.clear();
|
this.playedIndices.clear();
|
||||||
this.history = [];
|
this.history = [];
|
||||||
|
this.forwardStack = [];
|
||||||
if (this.currentIndex >= 0) {
|
if (this.currentIndex >= 0) {
|
||||||
this.playedIndices.add(this.currentIndex);
|
this.playedIndices.add(this.currentIndex);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -778,6 +778,7 @@ export class BotInstance extends EventEmitter {
|
|||||||
`${p}stop — Stop and clear queue`,
|
`${p}stop — Stop and clear queue`,
|
||||||
`${p}vol <0-100> — Set volume`,
|
`${p}vol <0-100> — Set volume`,
|
||||||
`${p}queue — Show queue`,
|
`${p}queue — Show queue`,
|
||||||
|
`${p}remove <pos> — Remove song at position (see ${p}queue)`,
|
||||||
`${p}mode <seq|loop|random|rloop> — Play mode`,
|
`${p}mode <seq|loop|random|rloop> — Play mode`,
|
||||||
`${p}playlist <name or id> — Load playlist by name or ID`,
|
`${p}playlist <name or id> — Load playlist by name or ID`,
|
||||||
`${p}playlist -q <name or id> — Load playlist from QQ Music`,
|
`${p}playlist -q <name or id> — Load playlist from QQ Music`,
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
import { describe, it, expect } from "vitest";
|
import { describe, it, expect } from "vitest";
|
||||||
import { parseLyrics } from "./netease.js";
|
import { parseLyrics, mapNeteaseAlbums } from "./netease.js";
|
||||||
|
|
||||||
describe("NetEase adapter", () => {
|
describe("NetEase adapter", () => {
|
||||||
it("parses LRC format lyrics", () => {
|
it("parses LRC format lyrics", () => {
|
||||||
@@ -28,4 +28,32 @@ describe("NetEase adapter", () => {
|
|||||||
expect(lines[0].text).toBe("Hello world");
|
expect(lines[0].text).toBe("Hello world");
|
||||||
expect(lines[0].translation).toBe("你好世界");
|
expect(lines[0].translation).toBe("你好世界");
|
||||||
});
|
});
|
||||||
|
|
||||||
|
it("mapNeteaseAlbums maps raw cloudsearch albums to Album shape", () => {
|
||||||
|
const raw = [
|
||||||
|
{
|
||||||
|
id: 42,
|
||||||
|
name: "Album A",
|
||||||
|
picUrl: "https://x/p.jpg",
|
||||||
|
artists: [{ name: "Artist X" }, { name: "Featured Y" }],
|
||||||
|
size: 12,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
id: 99,
|
||||||
|
name: "Album B",
|
||||||
|
picUrl: "",
|
||||||
|
artists: [],
|
||||||
|
},
|
||||||
|
];
|
||||||
|
expect(mapNeteaseAlbums(raw)).toEqual([
|
||||||
|
{ id: "42", name: "Album A", artist: "Artist X / Featured Y", coverUrl: "https://x/p.jpg", songCount: 12, platform: "netease" },
|
||||||
|
{ id: "99", name: "Album B", artist: "", coverUrl: "", songCount: 0, platform: "netease" },
|
||||||
|
]);
|
||||||
|
});
|
||||||
|
|
||||||
|
it("mapNeteaseAlbums returns [] for empty/null input", () => {
|
||||||
|
expect(mapNeteaseAlbums([])).toEqual([]);
|
||||||
|
expect(mapNeteaseAlbums(null as any)).toEqual([]);
|
||||||
|
expect(mapNeteaseAlbums(undefined as any)).toEqual([]);
|
||||||
|
});
|
||||||
});
|
});
|
||||||
+20
-2
@@ -8,6 +8,7 @@ import type {
|
|||||||
SearchResult,
|
SearchResult,
|
||||||
QrCodeResult,
|
QrCodeResult,
|
||||||
AuthStatus,
|
AuthStatus,
|
||||||
|
Album,
|
||||||
} from "./provider.js";
|
} from "./provider.js";
|
||||||
|
|
||||||
export function parseLyrics(lrc: string, tlyric?: string): LyricLine[] {
|
export function parseLyrics(lrc: string, tlyric?: string): LyricLine[] {
|
||||||
@@ -55,6 +56,18 @@ export function parseLyrics(lrc: string, tlyric?: string): LyricLine[] {
|
|||||||
return lines.sort((a, b) => a.time - b.time);
|
return lines.sort((a, b) => a.time - b.time);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
export function mapNeteaseAlbums(raw: any[] | null | undefined): Album[] {
|
||||||
|
if (!Array.isArray(raw)) return [];
|
||||||
|
return raw.map((a) => ({
|
||||||
|
id: String(a.id),
|
||||||
|
name: a.name ?? "",
|
||||||
|
artist: (a.artists ?? []).map((x: any) => x.name).join(" / "),
|
||||||
|
coverUrl: a.picUrl ?? "",
|
||||||
|
songCount: a.size ?? 0,
|
||||||
|
platform: "netease",
|
||||||
|
}));
|
||||||
|
}
|
||||||
|
|
||||||
// NetEase quality levels: standard(128k) higher(192k) exhigh(320k) lossless(flac) hires(hi-res) jyeffect jymaster
|
// NetEase quality levels: standard(128k) higher(192k) exhigh(320k) lossless(flac) hires(hi-res) jyeffect jymaster
|
||||||
export const NETEASE_QUALITY_LEVELS = [
|
export const NETEASE_QUALITY_LEVELS = [
|
||||||
{ value: "standard", label: "标准 (128kbps)", bitrate: 128 },
|
{ value: "standard", label: "标准 (128kbps)", bitrate: 128 },
|
||||||
@@ -91,7 +104,7 @@ export class NeteaseProvider implements MusicProvider {
|
|||||||
}
|
}
|
||||||
|
|
||||||
async search(query: string, limit = 20): Promise<SearchResult> {
|
async search(query: string, limit = 20): Promise<SearchResult> {
|
||||||
const [songRes, playlistRes] = await Promise.all([
|
const [songRes, playlistRes, albumRes] = await Promise.all([
|
||||||
this.api.get("/cloudsearch", {
|
this.api.get("/cloudsearch", {
|
||||||
params: { keywords: query, type: 1, limit, ...this.cookieParams },
|
params: { keywords: query, type: 1, limit, ...this.cookieParams },
|
||||||
}),
|
}),
|
||||||
@@ -103,6 +116,9 @@ export class NeteaseProvider implements MusicProvider {
|
|||||||
...this.cookieParams,
|
...this.cookieParams,
|
||||||
},
|
},
|
||||||
}),
|
}),
|
||||||
|
this.api.get("/cloudsearch", {
|
||||||
|
params: { keywords: query, type: 10, limit: 5, ...this.cookieParams },
|
||||||
|
}),
|
||||||
]);
|
]);
|
||||||
|
|
||||||
const songs: Song[] = (songRes.data?.result?.songs ?? []).map(
|
const songs: Song[] = (songRes.data?.result?.songs ?? []).map(
|
||||||
@@ -127,7 +143,9 @@ export class NeteaseProvider implements MusicProvider {
|
|||||||
platform: "netease",
|
platform: "netease",
|
||||||
}));
|
}));
|
||||||
|
|
||||||
return { songs, playlists, albums: [] };
|
const albums = mapNeteaseAlbums(albumRes.data?.result?.albums);
|
||||||
|
|
||||||
|
return { songs, playlists, albums };
|
||||||
}
|
}
|
||||||
|
|
||||||
async getSongUrl(songId: string, quality?: string): Promise<string | null> {
|
async getSongUrl(songId: string, quality?: string): Promise<string | null> {
|
||||||
|
|||||||
@@ -0,0 +1,43 @@
|
|||||||
|
import { describe, it, expect } from "vitest";
|
||||||
|
import { mapQqAlbums } from "./qq.js";
|
||||||
|
|
||||||
|
describe("QQ adapter", () => {
|
||||||
|
it("mapQqAlbums maps albumMID-style raw entries", () => {
|
||||||
|
const raw = [
|
||||||
|
{
|
||||||
|
albumMID: "abc",
|
||||||
|
albumName: "Aero",
|
||||||
|
singerName: "Singer A",
|
||||||
|
},
|
||||||
|
{
|
||||||
|
albumMID: "xyz",
|
||||||
|
albumName: "Beta",
|
||||||
|
singer: [{ name: "Singer B" }, { name: "Singer C" }],
|
||||||
|
},
|
||||||
|
];
|
||||||
|
const out = mapQqAlbums(raw);
|
||||||
|
expect(out).toHaveLength(2);
|
||||||
|
expect(out[0]).toMatchObject({
|
||||||
|
id: "abc",
|
||||||
|
name: "Aero",
|
||||||
|
artist: "Singer A",
|
||||||
|
platform: "qq",
|
||||||
|
});
|
||||||
|
expect(out[0].coverUrl).toContain("T002R300x300M000abc.jpg");
|
||||||
|
expect(out[1].artist).toBe("Singer B / Singer C");
|
||||||
|
expect(out[1].coverUrl).toContain("xyz");
|
||||||
|
});
|
||||||
|
|
||||||
|
it("mapQqAlbums returns [] for empty/null input", () => {
|
||||||
|
expect(mapQqAlbums([])).toEqual([]);
|
||||||
|
expect(mapQqAlbums(null as any)).toEqual([]);
|
||||||
|
expect(mapQqAlbums(undefined as any)).toEqual([]);
|
||||||
|
});
|
||||||
|
|
||||||
|
it("mapQqAlbums falls back to albumPic when no albumMID", () => {
|
||||||
|
const raw = [{ albumName: "C", albumPic: "https://x/p.jpg", singerName: "S" }];
|
||||||
|
const out = mapQqAlbums(raw);
|
||||||
|
expect(out[0].coverUrl).toBe("https://x/p.jpg");
|
||||||
|
expect(out[0].id).toBe("");
|
||||||
|
});
|
||||||
|
});
|
||||||
+30
-5
@@ -8,6 +8,7 @@ import type {
|
|||||||
SearchResult,
|
SearchResult,
|
||||||
QrCodeResult,
|
QrCodeResult,
|
||||||
AuthStatus,
|
AuthStatus,
|
||||||
|
Album,
|
||||||
} from "./provider.js";
|
} from "./provider.js";
|
||||||
import { parseLyrics } from "./netease.js";
|
import { parseLyrics } from "./netease.js";
|
||||||
|
|
||||||
@@ -27,6 +28,26 @@ const qqFavApi = axios.create({
|
|||||||
headers: { referer: "https://y.qq.com/" },
|
headers: { referer: "https://y.qq.com/" },
|
||||||
});
|
});
|
||||||
|
|
||||||
|
export function mapQqAlbums(raw: any[] | null | undefined): Album[] {
|
||||||
|
if (!Array.isArray(raw)) return [];
|
||||||
|
return raw.map((a) => {
|
||||||
|
const id = String(a.albumMID ?? a.mid ?? a.albumID ?? "");
|
||||||
|
const artist = a.singerName
|
||||||
|
?? (Array.isArray(a.singer) ? a.singer.map((s: any) => s.name).join(" / ") : "");
|
||||||
|
const coverUrl = id
|
||||||
|
? `https://y.gtimg.cn/music/photo_new/T002R300x300M000${id}.jpg`
|
||||||
|
: (a.albumPic ?? "");
|
||||||
|
return {
|
||||||
|
id,
|
||||||
|
name: a.albumName ?? a.title ?? "",
|
||||||
|
artist,
|
||||||
|
coverUrl,
|
||||||
|
songCount: a.song_count ?? a.songCount ?? 0,
|
||||||
|
platform: "qq" as const,
|
||||||
|
};
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
function computeGtk(pSkey: string): number {
|
function computeGtk(pSkey: string): number {
|
||||||
let hash = 5381;
|
let hash = 5381;
|
||||||
for (let i = 0; i < pSkey.length; i++) {
|
for (let i = 0; i < pSkey.length; i++) {
|
||||||
@@ -65,11 +86,12 @@ export class QQMusicProvider implements MusicProvider {
|
|||||||
req_0: {
|
req_0: {
|
||||||
module: "music.search.SearchCgiService",
|
module: "music.search.SearchCgiService",
|
||||||
method: "DoSearchForQQMusicDesktop",
|
method: "DoSearchForQQMusicDesktop",
|
||||||
param: {
|
param: { searchid: "1", query, num_per_page: Math.min(limit, 50), search_type: 0 },
|
||||||
searchid: "1",
|
|
||||||
query,
|
|
||||||
num_per_page: Math.min(limit, 50),
|
|
||||||
},
|
},
|
||||||
|
req_album: {
|
||||||
|
module: "music.search.SearchCgiService",
|
||||||
|
method: "DoSearchForQQMusicDesktop",
|
||||||
|
param: { searchid: "1", query, num_per_page: 5, search_type: 8 },
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
const res = await qqDirectApi.get("/cgi-bin/musicu.fcg", {
|
const res = await qqDirectApi.get("/cgi-bin/musicu.fcg", {
|
||||||
@@ -90,7 +112,10 @@ export class QQMusicProvider implements MusicProvider {
|
|||||||
platform: "qq",
|
platform: "qq",
|
||||||
}));
|
}));
|
||||||
|
|
||||||
return { songs, playlists: [], albums: [] };
|
const albumList: any[] = res.data?.req_album?.data?.body?.album?.list ?? [];
|
||||||
|
const albums = mapQqAlbums(albumList);
|
||||||
|
|
||||||
|
return { songs, playlists: [], albums };
|
||||||
}
|
}
|
||||||
|
|
||||||
async getSongUrl(songId: string, quality?: string): Promise<string | null> {
|
async getSongUrl(songId: string, quality?: string): Promise<string | null> {
|
||||||
|
|||||||
+10
-4
@@ -52,14 +52,20 @@ export function createMusicRouter(
|
|||||||
]);
|
]);
|
||||||
|
|
||||||
const songs = [
|
const songs = [
|
||||||
...(neteaseResult.status === "fulfilled"
|
...(neteaseResult.status === "fulfilled" ? neteaseResult.value.songs : []),
|
||||||
? neteaseResult.value.songs
|
|
||||||
: []),
|
|
||||||
...(qqResult.status === "fulfilled" ? qqResult.value.songs : []),
|
...(qqResult.status === "fulfilled" ? qqResult.value.songs : []),
|
||||||
...(bilibiliResult.status === "fulfilled" ? bilibiliResult.value.songs : []),
|
...(bilibiliResult.status === "fulfilled" ? bilibiliResult.value.songs : []),
|
||||||
];
|
];
|
||||||
|
const albums = [
|
||||||
|
...(neteaseResult.status === "fulfilled" ? neteaseResult.value.albums : []),
|
||||||
|
...(qqResult.status === "fulfilled" ? qqResult.value.albums : []),
|
||||||
|
];
|
||||||
|
const playlists = [
|
||||||
|
...(neteaseResult.status === "fulfilled" ? neteaseResult.value.playlists : []),
|
||||||
|
...(qqResult.status === "fulfilled" ? qqResult.value.playlists : []),
|
||||||
|
];
|
||||||
|
|
||||||
res.json({ songs });
|
res.json({ songs, albums, playlists });
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
logger.error({ err }, "Unified search failed");
|
logger.error({ err }, "Unified search failed");
|
||||||
res.status(500).json({ error: (err as Error).message });
|
res.status(500).json({ error: (err as Error).message });
|
||||||
|
|||||||
@@ -313,6 +313,78 @@ export function createPlayerRouter(
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
|
// Play an album by ID — mirrors play-playlist but calls getAlbumSongs
|
||||||
|
router.post("/:botId/play-album", async (req, res) => {
|
||||||
|
try {
|
||||||
|
const bot = (req as any).bot;
|
||||||
|
const { albumId, platform } = req.body;
|
||||||
|
const provider = bot.getProviderFor(
|
||||||
|
platform === "bilibili" || platform === "qq" || platform === "youtube"
|
||||||
|
? platform
|
||||||
|
: "netease"
|
||||||
|
);
|
||||||
|
|
||||||
|
// Stop current playback
|
||||||
|
bot.getPlayer().stop();
|
||||||
|
bot.getPlayer().resetFailures();
|
||||||
|
|
||||||
|
const songs = await provider.getAlbumSongs(albumId);
|
||||||
|
if (songs.length === 0) {
|
||||||
|
res.json({ message: "Album is empty" });
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
// QQ-specific optimization: batch-resolve playable IDs to avoid
|
||||||
|
// wasting retries on region/copyright-restricted tracks.
|
||||||
|
let queueable: { id: string }[] = songs;
|
||||||
|
const totalCount = songs.length;
|
||||||
|
const qqLike = provider as { getPlayableSongIds?: (ids: string[]) => Promise<Set<string> | null> };
|
||||||
|
if (typeof qqLike.getPlayableSongIds === "function") {
|
||||||
|
const playable = await qqLike.getPlayableSongIds(songs.map((s: { id: string }) => s.id));
|
||||||
|
if (playable !== null) {
|
||||||
|
queueable = songs.filter((s: { id: string }) => playable.has(s.id));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (queueable.length === 0) {
|
||||||
|
res.json({ ok: false, message: `专辑 ${totalCount} 首歌曲均无版权可播放(区域/版权限制)` });
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
const queue = bot.getQueueManager();
|
||||||
|
queue.clear();
|
||||||
|
for (const song of queueable) {
|
||||||
|
queue.add({ ...song, platform: provider.platform });
|
||||||
|
}
|
||||||
|
|
||||||
|
const mode = queue.getMode();
|
||||||
|
let first;
|
||||||
|
if (mode === "random" || mode === "rloop") {
|
||||||
|
const idx = Math.floor(Math.random() * queue.size());
|
||||||
|
first = queue.playAt(idx);
|
||||||
|
} else {
|
||||||
|
first = queue.play();
|
||||||
|
}
|
||||||
|
|
||||||
|
let started = first ? await bot.resolveAndPlay(first) : false;
|
||||||
|
if (first && !started) {
|
||||||
|
started = await bot.playNext(20);
|
||||||
|
}
|
||||||
|
|
||||||
|
const playing = queue.current();
|
||||||
|
const loadedMsg = queueable.length < totalCount
|
||||||
|
? `已加载 ${queueable.length}/${totalCount} 首(其余区域/版权限制)`
|
||||||
|
: `已加载 ${queueable.length} 首`;
|
||||||
|
if (started && playing) {
|
||||||
|
res.json({ ok: true, message: `${loadedMsg},正在播放:${playing.name}` });
|
||||||
|
} else {
|
||||||
|
res.json({ ok: false, message: `${loadedMsg},但无法开始播放。` });
|
||||||
|
}
|
||||||
|
} catch (err) {
|
||||||
|
logger.error({ err }, "play-album failed");
|
||||||
|
res.status(500).json({ error: (err as Error).message });
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
// Play a single song by ID — resolves URL on demand
|
// Play a single song by ID — resolves URL on demand
|
||||||
router.post("/:botId/play-song", async (req, res) => {
|
router.post("/:botId/play-song", async (req, res) => {
|
||||||
try {
|
try {
|
||||||
|
|||||||
@@ -22,6 +22,13 @@ const router = createRouter({
|
|||||||
path: '/playlist/:id',
|
path: '/playlist/:id',
|
||||||
name: 'playlist',
|
name: 'playlist',
|
||||||
component: () => import('../views/Playlist.vue'),
|
component: () => import('../views/Playlist.vue'),
|
||||||
|
meta: { kind: 'playlist' },
|
||||||
|
},
|
||||||
|
{
|
||||||
|
path: '/album/:id',
|
||||||
|
name: 'album',
|
||||||
|
component: () => import('../views/Playlist.vue'),
|
||||||
|
meta: { kind: 'album' },
|
||||||
},
|
},
|
||||||
{
|
{
|
||||||
path: '/lyrics',
|
path: '/lyrics',
|
||||||
|
|||||||
@@ -322,6 +322,16 @@ export const usePlayerStore = defineStore('player', {
|
|||||||
this._syncAfterAction();
|
this._syncAfterAction();
|
||||||
},
|
},
|
||||||
|
|
||||||
|
async playAlbum(albumId: string, platform = 'netease') {
|
||||||
|
if (!this.activeBotId) return;
|
||||||
|
const res = await axios.post(`/api/player/${this.activeBotId}/play-album`, { albumId, platform });
|
||||||
|
if (res.data?.message) {
|
||||||
|
this.notify(res.data.message, res.data.ok === false ? 'error' : 'info');
|
||||||
|
}
|
||||||
|
this._setTiming(this.activeBotId, { serverElapsed: 0 });
|
||||||
|
this._syncAfterAction();
|
||||||
|
},
|
||||||
|
|
||||||
async pause() {
|
async pause() {
|
||||||
if (!this.activeBotId) return;
|
if (!this.activeBotId) return;
|
||||||
// Freeze elapsed at current interpolated value
|
// Freeze elapsed at current interpolated value
|
||||||
|
|||||||
@@ -38,7 +38,7 @@
|
|||||||
</div>
|
</div>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
<div v-else class="loading">歌单不存在或加载失败</div>
|
<div v-else class="loading">{{ kind === 'album' ? '专辑' : '歌单' }}不存在或加载失败</div>
|
||||||
</div>
|
</div>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
@@ -64,6 +64,8 @@ interface PlaylistDetail {
|
|||||||
songCount: number;
|
songCount: number;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const kind = (route.meta.kind as string) ?? 'playlist'; // 'playlist' | 'album'
|
||||||
|
|
||||||
const playlist = ref<PlaylistDetail | null>(null);
|
const playlist = ref<PlaylistDetail | null>(null);
|
||||||
const songs = ref<Song[]>([]);
|
const songs = ref<Song[]>([]);
|
||||||
const loading = ref(true);
|
const loading = ref(true);
|
||||||
@@ -71,20 +73,32 @@ const loading = ref(true);
|
|||||||
async function playAll() {
|
async function playAll() {
|
||||||
const id = route.params.id as string;
|
const id = route.params.id as string;
|
||||||
const platform = (route.query.platform as string) || 'netease';
|
const platform = (route.query.platform as string) || 'netease';
|
||||||
|
if (kind === 'album') {
|
||||||
|
await store.playAlbum(id, platform);
|
||||||
|
} else {
|
||||||
await store.playPlaylist(id, platform);
|
await store.playPlaylist(id, platform);
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
onMounted(async () => {
|
onMounted(async () => {
|
||||||
const id = route.params.id as string;
|
const id = route.params.id as string;
|
||||||
const platform = (route.query.platform as string) || 'netease';
|
const platform = (route.query.platform as string) || 'netease';
|
||||||
|
|
||||||
|
const detailUrl = kind === 'album'
|
||||||
|
? `/api/music/album/${id}/detail`
|
||||||
|
: `/api/music/playlist/${id}/detail`;
|
||||||
|
const songsUrl = kind === 'album'
|
||||||
|
? `/api/music/album/${id}`
|
||||||
|
: `/api/music/playlist/${id}`;
|
||||||
|
|
||||||
// allSettled, not Promise.all — if detail 404s but songs is fine
|
// allSettled, not Promise.all — if detail 404s but songs is fine
|
||||||
// (e.g., a QQ playlist whose detail endpoint flaked but the song
|
// (e.g., a QQ playlist whose detail endpoint flaked but the song
|
||||||
// list resolved), we still want to show the songs rather than
|
// list resolved), we still want to show the songs rather than
|
||||||
// the "歌单不存在" empty state.
|
// the "不存在" empty state. For albums, detail always 404s — that
|
||||||
|
// is intentional; the fallback stub below handles it.
|
||||||
const [detailRes, songsRes] = await Promise.allSettled([
|
const [detailRes, songsRes] = await Promise.allSettled([
|
||||||
axios.get(`/api/music/playlist/${id}/detail`, { params: { platform } }),
|
axios.get(detailUrl, { params: { platform } }),
|
||||||
axios.get(`/api/music/playlist/${id}`, { params: { platform } }),
|
axios.get(songsUrl, { params: { platform } }),
|
||||||
]);
|
]);
|
||||||
|
|
||||||
const detail = detailRes.status === 'fulfilled' ? detailRes.value.data?.playlist : null;
|
const detail = detailRes.status === 'fulfilled' ? detailRes.value.data?.playlist : null;
|
||||||
@@ -93,10 +107,14 @@ onMounted(async () => {
|
|||||||
if (detail) {
|
if (detail) {
|
||||||
playlist.value = detail;
|
playlist.value = detail;
|
||||||
} else if (songList.length > 0) {
|
} else if (songList.length > 0) {
|
||||||
// Fall back to a stub built from the route + first song's cover.
|
// Fall back to a stub built from the route + first song. For albums,
|
||||||
|
// every song's `album` field carries the real album name.
|
||||||
|
const fallbackName = kind === 'album'
|
||||||
|
? (songList[0]?.album || '专辑')
|
||||||
|
: '歌单';
|
||||||
playlist.value = {
|
playlist.value = {
|
||||||
id,
|
id,
|
||||||
name: '歌单',
|
name: fallbackName,
|
||||||
description: '',
|
description: '',
|
||||||
coverUrl: songList[0]?.coverUrl ?? '',
|
coverUrl: songList[0]?.coverUrl ?? '',
|
||||||
songCount: songList.length,
|
songCount: songList.length,
|
||||||
@@ -104,7 +122,7 @@ onMounted(async () => {
|
|||||||
} else {
|
} else {
|
||||||
playlist.value = null;
|
playlist.value = null;
|
||||||
if (detailRes.status === 'rejected') {
|
if (detailRes.status === 'rejected') {
|
||||||
console.error('Failed to load playlist detail:', (detailRes.reason as any)?.response?.status, (detailRes.reason as any)?.message);
|
console.error('Failed to load detail:', (detailRes.reason as any)?.response?.status, (detailRes.reason as any)?.message);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
songs.value = songList;
|
songs.value = songList;
|
||||||
|
|||||||
+70
-13
@@ -20,9 +20,42 @@
|
|||||||
|
|
||||||
<div v-if="loading" class="loading">搜索中...</div>
|
<div v-if="loading" class="loading">搜索中...</div>
|
||||||
|
|
||||||
<div v-else-if="results.length > 0" class="results">
|
<template v-else-if="songs.length || albums.length || playlists.length">
|
||||||
|
<section v-if="albums.length" class="result-section">
|
||||||
|
<h2 class="section-title">专辑</h2>
|
||||||
|
<div class="card-grid">
|
||||||
|
<router-link
|
||||||
|
v-for="al in albums"
|
||||||
|
:key="`${al.platform}-${al.id}`"
|
||||||
|
:to="`/album/${al.id}?platform=${al.platform}`"
|
||||||
|
class="card hover-scale"
|
||||||
|
>
|
||||||
|
<CoverArt :url="al.coverUrl" :size="160" :radius="10" :show-shadow="true" />
|
||||||
|
<div class="card-name">{{ al.name }}</div>
|
||||||
|
<div class="card-sub">{{ al.artist }}</div>
|
||||||
|
</router-link>
|
||||||
|
</div>
|
||||||
|
</section>
|
||||||
|
|
||||||
|
<section v-if="playlists.length" class="result-section">
|
||||||
|
<h2 class="section-title">歌单</h2>
|
||||||
|
<div class="card-grid">
|
||||||
|
<router-link
|
||||||
|
v-for="pl in playlists"
|
||||||
|
:key="`${pl.platform}-${pl.id}`"
|
||||||
|
:to="`/playlist/${pl.id}?platform=${pl.platform}`"
|
||||||
|
class="card hover-scale"
|
||||||
|
>
|
||||||
|
<CoverArt :url="pl.coverUrl" :size="160" :radius="10" :show-shadow="true" />
|
||||||
|
<div class="card-name">{{ pl.name }}</div>
|
||||||
|
</router-link>
|
||||||
|
</div>
|
||||||
|
</section>
|
||||||
|
|
||||||
|
<section v-if="songs.length" class="result-section">
|
||||||
|
<h2 class="section-title">单曲</h2>
|
||||||
<SongCard
|
<SongCard
|
||||||
v-for="(song, i) in results"
|
v-for="(song, i) in songs"
|
||||||
:key="`${song.platform}-${song.id}`"
|
:key="`${song.platform}-${song.id}`"
|
||||||
:song="song"
|
:song="song"
|
||||||
:index="i + 1"
|
:index="i + 1"
|
||||||
@@ -31,11 +64,10 @@
|
|||||||
@playNext="store.playNextSong(song)"
|
@playNext="store.playNextSong(song)"
|
||||||
@add="store.addSong(song)"
|
@add="store.addSong(song)"
|
||||||
/>
|
/>
|
||||||
</div>
|
</section>
|
||||||
|
</template>
|
||||||
|
|
||||||
<div v-else-if="searched" class="empty">
|
<div v-else-if="searched" class="empty">未找到相关结果</div>
|
||||||
未找到相关结果
|
|
||||||
</div>
|
|
||||||
</div>
|
</div>
|
||||||
</template>
|
</template>
|
||||||
|
|
||||||
@@ -45,15 +77,21 @@ import { useRoute } from 'vue-router';
|
|||||||
import { Icon } from '@iconify/vue';
|
import { Icon } from '@iconify/vue';
|
||||||
import axios from 'axios';
|
import axios from 'axios';
|
||||||
import { usePlayerStore } from '../stores/player.js';
|
import { usePlayerStore } from '../stores/player.js';
|
||||||
|
import type { Song } from '../stores/player.js';
|
||||||
import SongCard from '../components/SongCard.vue';
|
import SongCard from '../components/SongCard.vue';
|
||||||
|
import CoverArt from '../components/CoverArt.vue';
|
||||||
|
|
||||||
const store = usePlayerStore();
|
const store = usePlayerStore();
|
||||||
const route = useRoute();
|
const route = useRoute();
|
||||||
|
|
||||||
const query = ref((route.query.q as string) || '');
|
const query = ref((route.query.q as string) || '');
|
||||||
import { Song } from '../stores/player.js';
|
|
||||||
|
|
||||||
const results = ref<Song[]>([]);
|
interface Album { id: string; name: string; artist: string; coverUrl: string; songCount?: number; platform: string; }
|
||||||
|
interface Playlist { id: string; name: string; coverUrl: string; songCount?: number; platform: string; }
|
||||||
|
|
||||||
|
const songs = ref<Song[]>([]);
|
||||||
|
const albums = ref<Album[]>([]);
|
||||||
|
const playlists = ref<Playlist[]>([]);
|
||||||
const loading = ref(false);
|
const loading = ref(false);
|
||||||
const searched = ref(false);
|
const searched = ref(false);
|
||||||
|
|
||||||
@@ -62,12 +100,12 @@ async function doSearch() {
|
|||||||
loading.value = true;
|
loading.value = true;
|
||||||
searched.value = true;
|
searched.value = true;
|
||||||
try {
|
try {
|
||||||
const res = await axios.get('/api/music/search/all', {
|
const res = await axios.get('/api/music/search/all', { params: { q: query.value } });
|
||||||
params: { q: query.value },
|
songs.value = res.data.songs ?? [];
|
||||||
});
|
albums.value = res.data.albums ?? [];
|
||||||
results.value = res.data.songs;
|
playlists.value = res.data.playlists ?? [];
|
||||||
} catch {
|
} catch {
|
||||||
results.value = [];
|
songs.value = []; albums.value = []; playlists.value = [];
|
||||||
} finally {
|
} finally {
|
||||||
loading.value = false;
|
loading.value = false;
|
||||||
}
|
}
|
||||||
@@ -141,4 +179,23 @@ onMounted(() => {
|
|||||||
flex-direction: column;
|
flex-direction: column;
|
||||||
gap: 2px;
|
gap: 2px;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
.result-section {
|
||||||
|
margin-bottom: 32px;
|
||||||
|
.section-title { font-size: 18px; margin: 0 0 12px; opacity: 0.85; }
|
||||||
|
}
|
||||||
|
.card-grid {
|
||||||
|
display: grid;
|
||||||
|
grid-template-columns: repeat(auto-fill, minmax(140px, 1fr));
|
||||||
|
gap: 16px;
|
||||||
|
}
|
||||||
|
.card {
|
||||||
|
display: flex;
|
||||||
|
flex-direction: column;
|
||||||
|
gap: 6px;
|
||||||
|
text-decoration: none;
|
||||||
|
color: inherit;
|
||||||
|
.card-name { font-size: 14px; line-height: 1.3; max-height: 2.6em; overflow: hidden; }
|
||||||
|
.card-sub { font-size: 12px; opacity: 0.6; }
|
||||||
|
}
|
||||||
</style>
|
</style>
|
||||||
@@ -80,6 +80,10 @@
|
|||||||
<label>服务器密码(可选)</label>
|
<label>服务器密码(可选)</label>
|
||||||
<input v-model="editForm.serverPassword" class="input" type="password" placeholder="服务器有密码时填写" />
|
<input v-model="editForm.serverPassword" class="input" type="password" placeholder="服务器有密码时填写" />
|
||||||
</div>
|
</div>
|
||||||
|
<div class="form-group">
|
||||||
|
<label>自定义头像</label>
|
||||||
|
<CustomAvatarRow :bot-id="editingBot" />
|
||||||
|
</div>
|
||||||
<div class="modal-actions">
|
<div class="modal-actions">
|
||||||
<button class="btn-secondary" @click="editingBot = null">取消</button>
|
<button class="btn-secondary" @click="editingBot = null">取消</button>
|
||||||
<button class="btn-primary" @click="saveEditBot">保存(需重启机器人生效)</button>
|
<button class="btn-primary" @click="saveEditBot">保存(需重启机器人生效)</button>
|
||||||
|
|||||||
Reference in new issue
Block a user