mirror of
https://github.com/ZHANGTIANYAO1/teamspeak-music-bot.git
synced 2026-10-02 04:52:50 +08:00
Compare commits
6
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
8cccf2ed24 | ||
|
|
f6b82b8e21 | ||
|
|
51d7ce61bd | ||
|
|
20f4cfacea | ||
|
|
7d9081efc1 | ||
|
|
a2453784c1 |
No files matched your search
@@ -16,7 +16,6 @@ import type { Logger } from "../logger.js";
|
|||||||
import type { BotDatabase, ProfileConfig } from "../data/database.js";
|
import type { BotDatabase, ProfileConfig } from "../data/database.js";
|
||||||
import type { BotConfig } from "../data/config.js";
|
import type { BotConfig } from "../data/config.js";
|
||||||
import { BotProfileManager } from "./profile.js";
|
import { BotProfileManager } from "./profile.js";
|
||||||
import type { AvatarStore } from "../data/avatars.js";
|
|
||||||
|
|
||||||
export interface BotInstanceOptions {
|
export interface BotInstanceOptions {
|
||||||
id: string;
|
id: string;
|
||||||
@@ -29,7 +28,6 @@ export interface BotInstanceOptions {
|
|||||||
database: BotDatabase;
|
database: BotDatabase;
|
||||||
config: BotConfig;
|
config: BotConfig;
|
||||||
logger: Logger;
|
logger: Logger;
|
||||||
avatarStore: AvatarStore;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export interface BotStatus {
|
export interface BotStatus {
|
||||||
@@ -59,7 +57,6 @@ export class BotInstance extends EventEmitter {
|
|||||||
private database: BotDatabase;
|
private database: BotDatabase;
|
||||||
private config: BotConfig;
|
private config: BotConfig;
|
||||||
private logger: Logger;
|
private logger: Logger;
|
||||||
private avatarStore: AvatarStore;
|
|
||||||
private connected = false;
|
private connected = false;
|
||||||
private disconnectEmitted = false;
|
private disconnectEmitted = false;
|
||||||
private voteSkipUsers = new Set<string>();
|
private voteSkipUsers = new Set<string>();
|
||||||
@@ -80,7 +77,6 @@ export class BotInstance extends EventEmitter {
|
|||||||
this.database = options.database;
|
this.database = options.database;
|
||||||
this.config = options.config;
|
this.config = options.config;
|
||||||
this.logger = options.logger.child({ botId: this.id });
|
this.logger = options.logger.child({ botId: this.id });
|
||||||
this.avatarStore = options.avatarStore;
|
|
||||||
|
|
||||||
this.tsClient = new TS3Client(options.tsOptions, this.logger);
|
this.tsClient = new TS3Client(options.tsOptions, this.logger);
|
||||||
this.player = new AudioPlayer(this.logger);
|
this.player = new AudioPlayer(this.logger);
|
||||||
@@ -94,17 +90,6 @@ export class BotInstance extends EventEmitter {
|
|||||||
options.tsOptions.nickname,
|
options.tsOptions.nickname,
|
||||||
);
|
);
|
||||||
|
|
||||||
// Best-effort: a corrupted/locked avatar file must not block bot startup.
|
|
||||||
try {
|
|
||||||
const relPath = this.database.getCustomAvatarPath(this.id);
|
|
||||||
if (relPath) {
|
|
||||||
const buf = this.avatarStore.read(relPath);
|
|
||||||
if (buf) this.profileManager.setCustomAvatar(buf);
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
this.logger.warn({ err }, "Failed to load custom avatar — skipping");
|
|
||||||
}
|
|
||||||
|
|
||||||
this.setupPlayerEvents();
|
this.setupPlayerEvents();
|
||||||
this.setupTsEvents();
|
this.setupTsEvents();
|
||||||
}
|
}
|
||||||
|
|||||||
+3
-10
@@ -11,7 +11,6 @@ import type { BotConfig } from "../data/config.js";
|
|||||||
import type { Logger } from "../logger.js";
|
import type { Logger } from "../logger.js";
|
||||||
|
|
||||||
import type { ServerProtocol } from "../ts-protocol/client.js";
|
import type { ServerProtocol } from "../ts-protocol/client.js";
|
||||||
import type { AvatarStore } from "../data/avatars.js";
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Run bot.connect() with a hard deadline. If the handshake hangs (e.g. the
|
* Run bot.connect() with a hard deadline. If the handshake hangs (e.g. the
|
||||||
@@ -75,7 +74,6 @@ export class BotManager extends EventEmitter {
|
|||||||
private database: BotDatabase;
|
private database: BotDatabase;
|
||||||
private config: BotConfig;
|
private config: BotConfig;
|
||||||
private logger: Logger;
|
private logger: Logger;
|
||||||
private avatarStore: AvatarStore;
|
|
||||||
|
|
||||||
constructor(
|
constructor(
|
||||||
neteaseProvider: MusicProvider,
|
neteaseProvider: MusicProvider,
|
||||||
@@ -83,8 +81,7 @@ export class BotManager extends EventEmitter {
|
|||||||
bilibiliProvider: MusicProvider,
|
bilibiliProvider: MusicProvider,
|
||||||
database: BotDatabase,
|
database: BotDatabase,
|
||||||
config: BotConfig,
|
config: BotConfig,
|
||||||
logger: Logger,
|
logger: Logger
|
||||||
avatarStore: AvatarStore
|
|
||||||
) {
|
) {
|
||||||
super();
|
super();
|
||||||
this.neteaseProvider = neteaseProvider;
|
this.neteaseProvider = neteaseProvider;
|
||||||
@@ -94,7 +91,6 @@ export class BotManager extends EventEmitter {
|
|||||||
this.database = database;
|
this.database = database;
|
||||||
this.config = config;
|
this.config = config;
|
||||||
this.logger = logger;
|
this.logger = logger;
|
||||||
this.avatarStore = avatarStore;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
async createBot(params: CreateBotParams): Promise<BotInstance> {
|
async createBot(params: CreateBotParams): Promise<BotInstance> {
|
||||||
@@ -121,7 +117,6 @@ export class BotManager extends EventEmitter {
|
|||||||
database: this.database,
|
database: this.database,
|
||||||
config: this.config,
|
config: this.config,
|
||||||
logger: this.logger,
|
logger: this.logger,
|
||||||
avatarStore: this.avatarStore,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
this.bots.set(id, bot);
|
this.bots.set(id, bot);
|
||||||
@@ -234,11 +229,10 @@ export class BotManager extends EventEmitter {
|
|||||||
neteaseProvider: this.neteaseProvider,
|
neteaseProvider: this.neteaseProvider,
|
||||||
qqProvider: this.qqProvider,
|
qqProvider: this.qqProvider,
|
||||||
bilibiliProvider: this.bilibiliProvider,
|
bilibiliProvider: this.bilibiliProvider,
|
||||||
youtubeProvider: this.youtubeProvider,
|
youtubeProvider: this.youtubeProvider,
|
||||||
database: this.database,
|
database: this.database,
|
||||||
config: this.config,
|
config: this.config,
|
||||||
logger: this.logger,
|
logger: this.logger,
|
||||||
avatarStore: this.avatarStore,
|
|
||||||
});
|
});
|
||||||
this.bots.set(id, bot);
|
this.bots.set(id, bot);
|
||||||
this.emit("botInstance", bot);
|
this.emit("botInstance", bot);
|
||||||
@@ -285,11 +279,10 @@ export class BotManager extends EventEmitter {
|
|||||||
neteaseProvider: this.neteaseProvider,
|
neteaseProvider: this.neteaseProvider,
|
||||||
qqProvider: this.qqProvider,
|
qqProvider: this.qqProvider,
|
||||||
bilibiliProvider: this.bilibiliProvider,
|
bilibiliProvider: this.bilibiliProvider,
|
||||||
youtubeProvider: this.youtubeProvider,
|
youtubeProvider: this.youtubeProvider,
|
||||||
database: this.database,
|
database: this.database,
|
||||||
config: this.config,
|
config: this.config,
|
||||||
logger: this.logger,
|
logger: this.logger,
|
||||||
avatarStore: this.avatarStore,
|
|
||||||
});
|
});
|
||||||
|
|
||||||
this.bots.set(saved.id, bot);
|
this.bots.set(saved.id, bot);
|
||||||
|
|||||||
@@ -1,147 +0,0 @@
|
|||||||
import { describe, it, expect, beforeEach, vi } from "vitest";
|
|
||||||
import { BotProfileManager } from "./profile.js";
|
|
||||||
import type { TS3Client } from "../ts-protocol/client.js";
|
|
||||||
import type { QueuedSong } from "../audio/queue.js";
|
|
||||||
|
|
||||||
function makeMockTs(): TS3Client & {
|
|
||||||
uploadCalls: Buffer[];
|
|
||||||
clearCalls: number;
|
|
||||||
} {
|
|
||||||
const calls: Buffer[] = [];
|
|
||||||
let clears = 0;
|
|
||||||
const ts: any = {
|
|
||||||
uploadCalls: calls,
|
|
||||||
get clearCalls() { return clears; },
|
|
||||||
getHost: () => "127.0.0.1",
|
|
||||||
getHttpQuery: () => null,
|
|
||||||
fileTransferInitUpload: vi.fn().mockResolvedValue({}),
|
|
||||||
uploadFileData: vi.fn().mockImplementation(async (_h: any, _i: any, stream: any) => {
|
|
||||||
const chunks: Buffer[] = [];
|
|
||||||
for await (const c of stream) chunks.push(c as Buffer);
|
|
||||||
calls.push(Buffer.concat(chunks));
|
|
||||||
}),
|
|
||||||
fileTransferDeleteFile: vi.fn().mockResolvedValue(undefined),
|
|
||||||
sendCommandNoWait: vi.fn().mockImplementation(async (cmd: string) => {
|
|
||||||
if (/client_flag_avatar=$/.test(cmd)) clears++;
|
|
||||||
}),
|
|
||||||
};
|
|
||||||
return ts;
|
|
||||||
}
|
|
||||||
|
|
||||||
const noopLogger: any = { child: () => noopLogger, info: () => {}, debug: () => {}, warn: () => {}, error: () => {} };
|
|
||||||
|
|
||||||
const cfgOn = { avatarEnabled: true, descriptionEnabled: false, nicknameEnabled: false, awayStatusEnabled: false, channelDescEnabled: false, nowPlayingMsgEnabled: false };
|
|
||||||
const cfgOff = { ...cfgOn, avatarEnabled: false };
|
|
||||||
|
|
||||||
const fakeSong: QueuedSong = {
|
|
||||||
id: "1",
|
|
||||||
name: "X",
|
|
||||||
artist: "Y",
|
|
||||||
album: "Z",
|
|
||||||
platform: "netease",
|
|
||||||
url: "u",
|
|
||||||
coverUrl: "c",
|
|
||||||
duration: 100,
|
|
||||||
};
|
|
||||||
|
|
||||||
const flush = () => new Promise((r) => setImmediate(r));
|
|
||||||
|
|
||||||
describe("BotProfileManager custom avatar precedence", () => {
|
|
||||||
let ts: ReturnType<typeof makeMockTs>;
|
|
||||||
beforeEach(() => { ts = makeMockTs(); });
|
|
||||||
|
|
||||||
it("setCustomAvatar uploads immediately on a fresh idle bot (sync on)", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOn, "Bot");
|
|
||||||
pm.setCustomAvatar(Buffer.from([1, 2, 3]));
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(1);
|
|
||||||
expect(ts.uploadCalls[0].equals(Buffer.from([1, 2, 3]))).toBe(true);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("setCustomAvatar uploads immediately when sync is off (always idle)", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOff, "Bot");
|
|
||||||
pm.setCustomAvatar(Buffer.from([7]));
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(1);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("setCustomAvatar while playing + sync on does NOT push (cover wins)", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOn, "Bot");
|
|
||||||
// Simulate the bot playing a song. We can't actually run updateAvatar's
|
|
||||||
// full HTTP fetch path, but onSongChange records currentSong before
|
|
||||||
// updateAvatar runs, which is enough for this assertion.
|
|
||||||
void pm.onSongChange(fakeSong);
|
|
||||||
await flush();
|
|
||||||
const uploadsBefore = ts.uploadCalls.length;
|
|
||||||
pm.setCustomAvatar(Buffer.from([42]));
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(uploadsBefore); // no new upload
|
|
||||||
});
|
|
||||||
|
|
||||||
it("setCustomAvatar while playing + sync off DOES push (sync-off is idle)", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOff, "Bot");
|
|
||||||
void pm.onSongChange(fakeSong);
|
|
||||||
await flush();
|
|
||||||
const uploadsBefore = ts.uploadCalls.length;
|
|
||||||
pm.setCustomAvatar(Buffer.from([42]));
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(uploadsBefore + 1);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("setCustomAvatar(null) while idle clears the TS3 avatar", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOn, "Bot");
|
|
||||||
pm.setCustomAvatar(Buffer.from([1]));
|
|
||||||
await flush();
|
|
||||||
const clearsBefore = ts.clearCalls;
|
|
||||||
pm.setCustomAvatar(null);
|
|
||||||
await flush();
|
|
||||||
expect(ts.clearCalls).toBe(clearsBefore + 1);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("on stop with custom avatar set + sync on, restores custom (does not clear)", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOn, "Bot");
|
|
||||||
pm.setCustomAvatar(Buffer.from([1, 2, 3, 4]));
|
|
||||||
await flush();
|
|
||||||
const clearsBefore = ts.clearCalls;
|
|
||||||
await pm.onSongChange(null);
|
|
||||||
expect(ts.uploadCalls.at(-1)?.equals(Buffer.from([1, 2, 3, 4]))).toBe(true);
|
|
||||||
expect(ts.clearCalls).toBe(clearsBefore); // no extra clear
|
|
||||||
});
|
|
||||||
|
|
||||||
it("on stop with no custom avatar, falls back to clear", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOn, "Bot");
|
|
||||||
await pm.onSongChange(null);
|
|
||||||
expect(ts.clearCalls).toBe(1);
|
|
||||||
expect(ts.uploadCalls.length).toBe(0);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("on connect with custom avatar set + sync ON, applies custom (spec matrix row 1)", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOn, "Bot");
|
|
||||||
pm.setCustomAvatar(Buffer.from([5, 5]));
|
|
||||||
await flush();
|
|
||||||
ts.uploadCalls.length = 0; // reset
|
|
||||||
pm.onConnect();
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(1);
|
|
||||||
expect(ts.uploadCalls[0].equals(Buffer.from([5, 5]))).toBe(true);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("on connect with custom avatar set + sync OFF, applies custom", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOff, "Bot");
|
|
||||||
pm.setCustomAvatar(Buffer.from([9, 9]));
|
|
||||||
await flush();
|
|
||||||
ts.uploadCalls.length = 0;
|
|
||||||
pm.onConnect();
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(1);
|
|
||||||
expect(ts.uploadCalls[0].equals(Buffer.from([9, 9]))).toBe(true);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("on connect with no custom avatar, does not touch avatar", async () => {
|
|
||||||
const pm = new BotProfileManager(ts as any, noopLogger, cfgOff, "Bot");
|
|
||||||
pm.onConnect();
|
|
||||||
await flush();
|
|
||||||
expect(ts.uploadCalls.length).toBe(0);
|
|
||||||
expect(ts.clearCalls).toBe(0);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
+1
-51
@@ -25,13 +25,6 @@ export class BotProfileManager {
|
|||||||
private logger: Logger;
|
private logger: Logger;
|
||||||
private config: ProfileConfig;
|
private config: ProfileConfig;
|
||||||
private defaultNickname: string;
|
private defaultNickname: string;
|
||||||
private customAvatar: Buffer | null = null;
|
|
||||||
/**
|
|
||||||
* Tracks the last song handed to onSongChange. null means stopped/idle.
|
|
||||||
* Used by setCustomAvatar to decide whether the new buffer should be
|
|
||||||
* pushed immediately (idle) or wait for the next stop event (playing).
|
|
||||||
*/
|
|
||||||
private currentSong: QueuedSong | null = null;
|
|
||||||
|
|
||||||
/** Per-feature permission-denied flags. Reset on reconnect. */
|
/** Per-feature permission-denied flags. Reset on reconnect. */
|
||||||
private permDenied = {
|
private permDenied = {
|
||||||
@@ -65,26 +58,6 @@ export class BotProfileManager {
|
|||||||
|
|
||||||
// --- Public API ---
|
// --- Public API ---
|
||||||
|
|
||||||
/**
|
|
||||||
* Set/clear the persistent idle avatar. Pass null to remove.
|
|
||||||
*
|
|
||||||
* If the bot is currently in an idle state (no song playing OR
|
|
||||||
* avatarEnabled is off), the new buffer is pushed to TS3 right away;
|
|
||||||
* otherwise the cover-art sync is in charge until the next stop event,
|
|
||||||
* at which point clearAvatar restores from this.customAvatar.
|
|
||||||
*/
|
|
||||||
setCustomAvatar(buffer: Buffer | null): void {
|
|
||||||
this.customAvatar = buffer;
|
|
||||||
const idle = this.currentSong === null || !this.config.avatarEnabled;
|
|
||||||
if (!idle) return;
|
|
||||||
const gen = ++this.generation;
|
|
||||||
if (buffer && buffer.length > 0) {
|
|
||||||
void this.applyIdleAvatar(gen);
|
|
||||||
} else {
|
|
||||||
void this.clearAvatar(gen);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Called when a new song starts playing (song != null) or playback
|
* Called when a new song starts playing (song != null) or playback
|
||||||
* stops (song == null).
|
* stops (song == null).
|
||||||
@@ -98,7 +71,6 @@ export class BotProfileManager {
|
|||||||
*/
|
*/
|
||||||
async onSongChange(song: QueuedSong | null): Promise<void> {
|
async onSongChange(song: QueuedSong | null): Promise<void> {
|
||||||
const gen = ++this.generation;
|
const gen = ++this.generation;
|
||||||
this.currentSong = song;
|
|
||||||
|
|
||||||
// 1. Avatar first — file transfer uses its own response tracker and
|
// 1. Avatar first — file transfer uses its own response tracker and
|
||||||
// must run before sendCommandNoWait calls whose orphaned responses
|
// must run before sendCommandNoWait calls whose orphaned responses
|
||||||
@@ -119,7 +91,6 @@ export class BotProfileManager {
|
|||||||
/** Reset permission-denied flags and bump generation on new connection. */
|
/** Reset permission-denied flags and bump generation on new connection. */
|
||||||
onConnect(): void {
|
onConnect(): void {
|
||||||
this.generation++;
|
this.generation++;
|
||||||
this.currentSong = null;
|
|
||||||
this.permDenied = {
|
this.permDenied = {
|
||||||
avatar: false,
|
avatar: false,
|
||||||
description: false,
|
description: false,
|
||||||
@@ -128,12 +99,6 @@ export class BotProfileManager {
|
|||||||
channelDesc: false,
|
channelDesc: false,
|
||||||
nowPlayingMsg: false,
|
nowPlayingMsg: false,
|
||||||
};
|
};
|
||||||
// No song is playing on a fresh connect, so the matrix says the
|
|
||||||
// custom avatar should be visible regardless of avatarEnabled.
|
|
||||||
if (this.customAvatar) {
|
|
||||||
const gen = this.generation;
|
|
||||||
void this.applyIdleAvatar(gen);
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
getConfig(): ProfileConfig {
|
getConfig(): ProfileConfig {
|
||||||
@@ -206,10 +171,6 @@ export class BotProfileManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private async clearAvatar(gen: number): Promise<void> {
|
private async clearAvatar(gen: number): Promise<void> {
|
||||||
if (this.customAvatar && this.customAvatar.length > 0) {
|
|
||||||
await this.applyIdleAvatar(gen);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
try {
|
try {
|
||||||
await this.withTimeout(
|
await this.withTimeout(
|
||||||
this.tsClient.fileTransferDeleteFile(0n, ["/avatar"]),
|
this.tsClient.fileTransferDeleteFile(0n, ["/avatar"]),
|
||||||
@@ -218,6 +179,7 @@ export class BotProfileManager {
|
|||||||
} catch {
|
} catch {
|
||||||
// File may not exist or transfer timed out — that's fine
|
// File may not exist or transfer timed out — that's fine
|
||||||
}
|
}
|
||||||
|
// Bail if a newer song started while we were deleting
|
||||||
if (this.generation !== gen) return;
|
if (this.generation !== gen) return;
|
||||||
try {
|
try {
|
||||||
await this.tsClient.sendCommandNoWait("clientupdate client_flag_avatar=");
|
await this.tsClient.sendCommandNoWait("clientupdate client_flag_avatar=");
|
||||||
@@ -226,18 +188,6 @@ export class BotProfileManager {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private async applyIdleAvatar(gen: number): Promise<void> {
|
|
||||||
if (!this.customAvatar || this.customAvatar.length === 0) return;
|
|
||||||
if (this.permDenied.avatar) return;
|
|
||||||
try {
|
|
||||||
await this.withTimeout(this.doAvatarUpload(this.customAvatar), FILE_TRANSFER_TIMEOUT_MS);
|
|
||||||
if (this.generation !== gen) return;
|
|
||||||
this.logger.info({ bytes: this.customAvatar.length }, "Idle (custom) avatar applied");
|
|
||||||
} catch (err) {
|
|
||||||
this.handleFeatureError("avatar", err);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private async updateDescription(song: QueuedSong | null): Promise<void> {
|
private async updateDescription(song: QueuedSong | null): Promise<void> {
|
||||||
if (!this.config.descriptionEnabled || this.permDenied.description) return;
|
if (!this.config.descriptionEnabled || this.permDenied.description) return;
|
||||||
try {
|
try {
|
||||||
|
|||||||
@@ -1,61 +0,0 @@
|
|||||||
import { describe, it, expect, beforeEach } from "vitest";
|
|
||||||
import { mkdtempSync, rmSync, existsSync, readFileSync } from "node:fs";
|
|
||||||
import { tmpdir } from "node:os";
|
|
||||||
import { join } from "node:path";
|
|
||||||
import { createAvatarStore } from "./avatars.js";
|
|
||||||
|
|
||||||
let dir: string;
|
|
||||||
|
|
||||||
beforeEach(() => {
|
|
||||||
dir = mkdtempSync(join(tmpdir(), "avatar-test-"));
|
|
||||||
});
|
|
||||||
|
|
||||||
describe("createAvatarStore", () => {
|
|
||||||
it("write returns a relative path under the store dir", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
const buf = Buffer.from("fake-png");
|
|
||||||
const rel = store.write("bot-1", "image/png", buf);
|
|
||||||
expect(rel).toBe("bot-1.png");
|
|
||||||
expect(readFileSync(join(dir, "bot-1.png")).equals(buf)).toBe(true);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("write picks correct extension for jpeg / webp", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
expect(store.write("a", "image/jpeg", Buffer.from(""))).toBe("a.jpg");
|
|
||||||
expect(store.write("b", "image/webp", Buffer.from(""))).toBe("b.webp");
|
|
||||||
});
|
|
||||||
|
|
||||||
it("write rejects unsupported MIME types", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
expect(() => store.write("c", "image/gif", Buffer.from(""))).toThrow(/unsupported/i);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("read returns the bytes for an existing file", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
store.write("bot-1", "image/png", Buffer.from("hello"));
|
|
||||||
const buf = store.read("bot-1.png");
|
|
||||||
expect(buf?.equals(Buffer.from("hello"))).toBe(true);
|
|
||||||
});
|
|
||||||
|
|
||||||
it("read returns null when path is missing", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
expect(store.read("missing.png")).toBeNull();
|
|
||||||
});
|
|
||||||
|
|
||||||
it("remove deletes the file (idempotent)", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
store.write("bot-1", "image/png", Buffer.from("x"));
|
|
||||||
store.remove("bot-1.png");
|
|
||||||
expect(existsSync(join(dir, "bot-1.png"))).toBe(false);
|
|
||||||
expect(() => store.remove("bot-1.png")).not.toThrow();
|
|
||||||
});
|
|
||||||
|
|
||||||
it("write replaces any existing file for the same botId regardless of old extension", () => {
|
|
||||||
const store = createAvatarStore(dir);
|
|
||||||
store.write("bot-1", "image/png", Buffer.from("old"));
|
|
||||||
const rel = store.write("bot-1", "image/jpeg", Buffer.from("new"));
|
|
||||||
expect(rel).toBe("bot-1.jpg");
|
|
||||||
expect(existsSync(join(dir, "bot-1.png"))).toBe(false);
|
|
||||||
expect(existsSync(join(dir, "bot-1.jpg"))).toBe(true);
|
|
||||||
});
|
|
||||||
});
|
|
||||||
@@ -1,43 +0,0 @@
|
|||||||
import { mkdirSync, writeFileSync, readFileSync, rmSync, readdirSync, existsSync } from "node:fs";
|
|
||||||
import { join } from "node:path";
|
|
||||||
|
|
||||||
const MIME_TO_EXT: Record<string, string> = {
|
|
||||||
"image/png": "png",
|
|
||||||
"image/jpeg": "jpg",
|
|
||||||
"image/webp": "webp",
|
|
||||||
};
|
|
||||||
|
|
||||||
export interface AvatarStore {
|
|
||||||
/** Returns the relative path written (e.g. "bot-1.png"). */
|
|
||||||
write(botId: string, mime: string, buffer: Buffer): string;
|
|
||||||
read(relPath: string): Buffer | null;
|
|
||||||
remove(relPath: string): void;
|
|
||||||
getDir(): string;
|
|
||||||
}
|
|
||||||
|
|
||||||
export function createAvatarStore(dir: string): AvatarStore {
|
|
||||||
if (!existsSync(dir)) mkdirSync(dir, { recursive: true });
|
|
||||||
return {
|
|
||||||
write(botId, mime, buffer) {
|
|
||||||
const ext = MIME_TO_EXT[mime];
|
|
||||||
if (!ext) throw new Error(`unsupported avatar MIME: ${mime}`);
|
|
||||||
for (const name of readdirSync(dir)) {
|
|
||||||
if (name.startsWith(`${botId}.`)) rmSync(join(dir, name), { force: true });
|
|
||||||
}
|
|
||||||
const rel = `${botId}.${ext}`;
|
|
||||||
writeFileSync(join(dir, rel), buffer);
|
|
||||||
return rel;
|
|
||||||
},
|
|
||||||
read(relPath) {
|
|
||||||
const full = join(dir, relPath);
|
|
||||||
if (!existsSync(full)) return null;
|
|
||||||
return readFileSync(full);
|
|
||||||
},
|
|
||||||
remove(relPath) {
|
|
||||||
rmSync(join(dir, relPath), { force: true });
|
|
||||||
},
|
|
||||||
getDir() {
|
|
||||||
return dir;
|
|
||||||
},
|
|
||||||
};
|
|
||||||
}
|
|
||||||
@@ -98,26 +98,4 @@ describe("database", () => {
|
|||||||
expect(botDb.getBotInstances()).toHaveLength(0);
|
expect(botDb.getBotInstances()).toHaveLength(0);
|
||||||
expect(botDb.deleteBotInstance("nonexistent")).toBe(false);
|
expect(botDb.deleteBotInstance("nonexistent")).toBe(false);
|
||||||
});
|
});
|
||||||
|
|
||||||
it("persists and clears customAvatarPath on a bot instance", () => {
|
|
||||||
const inst = {
|
|
||||||
id: "bot-1",
|
|
||||||
name: "B",
|
|
||||||
serverAddress: "x",
|
|
||||||
serverPort: 9987,
|
|
||||||
nickname: "n",
|
|
||||||
defaultChannel: "",
|
|
||||||
channelPassword: "",
|
|
||||||
autoStart: false,
|
|
||||||
serverProtocol: "",
|
|
||||||
ts6ApiKey: "",
|
|
||||||
serverPassword: "",
|
|
||||||
};
|
|
||||||
botDb.saveBotInstance(inst);
|
|
||||||
expect(botDb.getCustomAvatarPath("bot-1")).toBeNull();
|
|
||||||
botDb.setCustomAvatarPath("bot-1", "avatars/bot-1.png");
|
|
||||||
expect(botDb.getCustomAvatarPath("bot-1")).toBe("avatars/bot-1.png");
|
|
||||||
botDb.setCustomAvatarPath("bot-1", null);
|
|
||||||
expect(botDb.getCustomAvatarPath("bot-1")).toBeNull();
|
|
||||||
});
|
|
||||||
});
|
});
|
||||||
@@ -60,8 +60,6 @@ export interface BotDatabase {
|
|||||||
deleteBotInstance(id: string): boolean;
|
deleteBotInstance(id: string): boolean;
|
||||||
getProfileConfig(botId: string): ProfileConfig;
|
getProfileConfig(botId: string): ProfileConfig;
|
||||||
saveProfileConfig(botId: string, config: ProfileConfig): void;
|
saveProfileConfig(botId: string, config: ProfileConfig): void;
|
||||||
getCustomAvatarPath(botId: string): string | null;
|
|
||||||
setCustomAvatarPath(botId: string, path: string | null): void;
|
|
||||||
close(): void;
|
close(): void;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -94,9 +92,6 @@ function migrateSchema(db: Database.Database): void {
|
|||||||
db.exec(`ALTER TABLE bot_instances ADD COLUMN ${col} INTEGER NOT NULL DEFAULT 1`);
|
db.exec(`ALTER TABLE bot_instances ADD COLUMN ${col} INTEGER NOT NULL DEFAULT 1`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
if (!names.includes("custom_avatar_path")) {
|
|
||||||
db.exec("ALTER TABLE bot_instances ADD COLUMN custom_avatar_path TEXT");
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
function initTables(db: Database.Database): void {
|
function initTables(db: Database.Database): void {
|
||||||
@@ -184,9 +179,6 @@ export function createDatabase(dbPath: string): BotDatabase {
|
|||||||
WHERE id = @id
|
WHERE id = @id
|
||||||
`);
|
`);
|
||||||
|
|
||||||
const selectCustomAvatar = db.prepare(`SELECT custom_avatar_path FROM bot_instances WHERE id = ?`);
|
|
||||||
const updateCustomAvatar = db.prepare(`UPDATE bot_instances SET custom_avatar_path = ? WHERE id = ?`);
|
|
||||||
|
|
||||||
return {
|
return {
|
||||||
db,
|
db,
|
||||||
|
|
||||||
@@ -250,14 +242,6 @@ export function createDatabase(dbPath: string): BotDatabase {
|
|||||||
});
|
});
|
||||||
},
|
},
|
||||||
|
|
||||||
getCustomAvatarPath(botId) {
|
|
||||||
const row = selectCustomAvatar.get(botId) as { custom_avatar_path: string | null } | undefined;
|
|
||||||
return row?.custom_avatar_path ?? null;
|
|
||||||
},
|
|
||||||
setCustomAvatarPath(botId, path) {
|
|
||||||
updateCustomAvatar.run(path, botId);
|
|
||||||
},
|
|
||||||
|
|
||||||
close() {
|
close() {
|
||||||
db.close();
|
db.close();
|
||||||
},
|
},
|
||||||
|
|||||||
+1
-6
@@ -8,7 +8,6 @@ import { NeteaseProvider } from "./music/netease.js";
|
|||||||
import { QQMusicProvider } from "./music/qq.js";
|
import { QQMusicProvider } from "./music/qq.js";
|
||||||
import { BiliBiliProvider } from "./music/bilibili.js";
|
import { BiliBiliProvider } from "./music/bilibili.js";
|
||||||
import { createCookieStore } from "./music/auth.js";
|
import { createCookieStore } from "./music/auth.js";
|
||||||
import { createAvatarStore } from "./data/avatars.js";
|
|
||||||
import { BotManager } from "./bot/manager.js";
|
import { BotManager } from "./bot/manager.js";
|
||||||
import { createWebServer } from "./web/server.js";
|
import { createWebServer } from "./web/server.js";
|
||||||
|
|
||||||
@@ -19,7 +18,6 @@ const CONFIG_PATH = path.join(ROOT_DIR, "config.json");
|
|||||||
const DB_PATH = path.join(DATA_DIR, "tsmusicbot.db");
|
const DB_PATH = path.join(DATA_DIR, "tsmusicbot.db");
|
||||||
const LOG_DIR = path.join(DATA_DIR, "logs");
|
const LOG_DIR = path.join(DATA_DIR, "logs");
|
||||||
const COOKIE_DIR = path.join(DATA_DIR, "cookies");
|
const COOKIE_DIR = path.join(DATA_DIR, "cookies");
|
||||||
const AVATAR_DIR = path.join(DATA_DIR, "avatars");
|
|
||||||
const STATIC_DIR = path.join(ROOT_DIR, "web", "dist");
|
const STATIC_DIR = path.join(ROOT_DIR, "web", "dist");
|
||||||
|
|
||||||
async function main() {
|
async function main() {
|
||||||
@@ -48,7 +46,6 @@ async function main() {
|
|||||||
const bilibiliProvider = new BiliBiliProvider();
|
const bilibiliProvider = new BiliBiliProvider();
|
||||||
|
|
||||||
const cookieStore = createCookieStore(COOKIE_DIR);
|
const cookieStore = createCookieStore(COOKIE_DIR);
|
||||||
const avatarStore = createAvatarStore(AVATAR_DIR);
|
|
||||||
const neteaseCookie = cookieStore.load("netease");
|
const neteaseCookie = cookieStore.load("netease");
|
||||||
if (neteaseCookie) neteaseProvider.setCookie(neteaseCookie);
|
if (neteaseCookie) neteaseProvider.setCookie(neteaseCookie);
|
||||||
const qqCookie = cookieStore.load("qq");
|
const qqCookie = cookieStore.load("qq");
|
||||||
@@ -62,8 +59,7 @@ async function main() {
|
|||||||
bilibiliProvider,
|
bilibiliProvider,
|
||||||
db,
|
db,
|
||||||
config,
|
config,
|
||||||
logger,
|
logger
|
||||||
avatarStore
|
|
||||||
);
|
);
|
||||||
await botManager.loadSavedBots();
|
await botManager.loadSavedBots();
|
||||||
|
|
||||||
@@ -74,7 +70,6 @@ async function main() {
|
|||||||
qqProvider,
|
qqProvider,
|
||||||
bilibiliProvider,
|
bilibiliProvider,
|
||||||
database: db,
|
database: db,
|
||||||
avatarStore,
|
|
||||||
config,
|
config,
|
||||||
configPath: CONFIG_PATH,
|
configPath: CONFIG_PATH,
|
||||||
logger,
|
logger,
|
||||||
|
|||||||
@@ -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("");
|
||||||
|
});
|
||||||
|
});
|
||||||
+31
-6
@@ -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,
|
req_album: {
|
||||||
num_per_page: Math.min(limit, 50),
|
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> {
|
||||||
|
|||||||
+1
-69
@@ -3,16 +3,12 @@ import type { BotManager } from "../../bot/manager.js";
|
|||||||
import type { BotConfig } from "../../data/config.js";
|
import type { BotConfig } from "../../data/config.js";
|
||||||
import { saveConfig } from "../../data/config.js";
|
import { saveConfig } from "../../data/config.js";
|
||||||
import type { Logger } from "../../logger.js";
|
import type { Logger } from "../../logger.js";
|
||||||
import type { BotDatabase } from "../../data/database.js";
|
|
||||||
import type { AvatarStore } from "../../data/avatars.js";
|
|
||||||
|
|
||||||
export function createBotRouter(
|
export function createBotRouter(
|
||||||
botManager: BotManager,
|
botManager: BotManager,
|
||||||
config: BotConfig,
|
config: BotConfig,
|
||||||
configPath: string,
|
configPath: string,
|
||||||
logger: Logger,
|
logger: Logger
|
||||||
botDb: BotDatabase,
|
|
||||||
avatarStore: AvatarStore,
|
|
||||||
): Router {
|
): Router {
|
||||||
const router = Router();
|
const router = Router();
|
||||||
|
|
||||||
@@ -40,70 +36,6 @@ export function createBotRouter(
|
|||||||
res.json(saved);
|
res.json(saved);
|
||||||
});
|
});
|
||||||
|
|
||||||
router.get("/:id/avatar", (req, res) => {
|
|
||||||
const path = botDb.getCustomAvatarPath(req.params.id);
|
|
||||||
if (!path) {
|
|
||||||
res.status(404).end();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const buf = avatarStore.read(path);
|
|
||||||
if (!buf) {
|
|
||||||
res.status(404).end();
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const ext = path.split(".").pop() ?? "";
|
|
||||||
const mime = ext === "png"
|
|
||||||
? "image/png"
|
|
||||||
: ext === "webp"
|
|
||||||
? "image/webp"
|
|
||||||
: "image/jpeg";
|
|
||||||
res.set("Content-Type", mime);
|
|
||||||
res.set("Cache-Control", "no-cache");
|
|
||||||
res.send(buf);
|
|
||||||
});
|
|
||||||
|
|
||||||
router.put("/:id/avatar", (req, res) => {
|
|
||||||
const exists =
|
|
||||||
botManager.getBot(req.params.id) ||
|
|
||||||
botDb.getBotInstances().some((b) => b.id === req.params.id);
|
|
||||||
if (!exists) {
|
|
||||||
res.status(404).json({ error: "Bot not found" });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const { dataUrl } = req.body as { dataUrl?: string };
|
|
||||||
if (typeof dataUrl !== "string") {
|
|
||||||
res.status(400).json({ error: "dataUrl required" });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const m = /^data:(image\/(?:png|jpeg|webp));base64,(.+)$/.exec(dataUrl);
|
|
||||||
if (!m) {
|
|
||||||
res.status(400).json({ error: "dataUrl must be image/png|jpeg|webp base64" });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const mime = m[1] as string;
|
|
||||||
const buf = Buffer.from(m[2] ?? "", "base64");
|
|
||||||
if (buf.length === 0) {
|
|
||||||
res.status(400).json({ error: "empty image" });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (buf.length > 200 * 1024) {
|
|
||||||
res.status(413).json({ error: "avatar exceeds 200KB limit" });
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
const rel = avatarStore.write(req.params.id, mime, buf);
|
|
||||||
botDb.setCustomAvatarPath(req.params.id, rel);
|
|
||||||
botManager.getBot(req.params.id)?.getProfileManager().setCustomAvatar(buf);
|
|
||||||
res.json({ path: rel });
|
|
||||||
});
|
|
||||||
|
|
||||||
router.delete("/:id/avatar", (req, res) => {
|
|
||||||
const path = botDb.getCustomAvatarPath(req.params.id);
|
|
||||||
if (path) avatarStore.remove(path);
|
|
||||||
botDb.setCustomAvatarPath(req.params.id, null);
|
|
||||||
botManager.getBot(req.params.id)?.getProfileManager().setCustomAvatar(null);
|
|
||||||
res.status(204).end();
|
|
||||||
});
|
|
||||||
|
|
||||||
router.post("/", async (req, res) => {
|
router.post("/", async (req, res) => {
|
||||||
try {
|
try {
|
||||||
const {
|
const {
|
||||||
|
|||||||
+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 {
|
||||||
|
|||||||
+2
-11
@@ -8,7 +8,6 @@ import type { BotDatabase } from "../data/database.js";
|
|||||||
import type { BotConfig } from "../data/config.js";
|
import type { BotConfig } from "../data/config.js";
|
||||||
import type { Logger } from "../logger.js";
|
import type { Logger } from "../logger.js";
|
||||||
import type { CookieStore } from "../music/auth.js";
|
import type { CookieStore } from "../music/auth.js";
|
||||||
import type { AvatarStore } from "../data/avatars.js";
|
|
||||||
import { createBotRouter } from "./api/bot.js";
|
import { createBotRouter } from "./api/bot.js";
|
||||||
import { createMusicRouter } from "./api/music.js";
|
import { createMusicRouter } from "./api/music.js";
|
||||||
import { createPlayerRouter } from "./api/player.js";
|
import { createPlayerRouter } from "./api/player.js";
|
||||||
@@ -26,7 +25,6 @@ export interface WebServerOptions {
|
|||||||
configPath: string;
|
configPath: string;
|
||||||
logger: Logger;
|
logger: Logger;
|
||||||
cookieStore?: CookieStore;
|
cookieStore?: CookieStore;
|
||||||
avatarStore: AvatarStore;
|
|
||||||
staticDir?: string;
|
staticDir?: string;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -45,7 +43,7 @@ export function createWebServer(options: WebServerOptions): WebServer {
|
|||||||
app.set("trust proxy", true);
|
app.set("trust proxy", true);
|
||||||
}
|
}
|
||||||
|
|
||||||
app.use(express.json({ limit: "400kb" }));
|
app.use(express.json());
|
||||||
|
|
||||||
app.get("/api/config/public-url", (_req, res) => {
|
app.get("/api/config/public-url", (_req, res) => {
|
||||||
const raw = (options.config.publicUrl ?? "").trim();
|
const raw = (options.config.publicUrl ?? "").trim();
|
||||||
@@ -54,14 +52,7 @@ export function createWebServer(options: WebServerOptions): WebServer {
|
|||||||
|
|
||||||
app.use(
|
app.use(
|
||||||
"/api/bot",
|
"/api/bot",
|
||||||
createBotRouter(
|
createBotRouter(options.botManager, options.config, options.configPath, logger)
|
||||||
options.botManager,
|
|
||||||
options.config,
|
|
||||||
options.configPath,
|
|
||||||
logger,
|
|
||||||
options.database,
|
|
||||||
options.avatarStore,
|
|
||||||
)
|
|
||||||
);
|
);
|
||||||
app.use(
|
app.use(
|
||||||
"/api/music",
|
"/api/music",
|
||||||
|
|||||||
@@ -1,99 +0,0 @@
|
|||||||
<template>
|
|
||||||
<div class="avatar-upload">
|
|
||||||
<div class="preview" :class="{ empty: !previewUrl }">
|
|
||||||
<img v-if="previewUrl" :src="previewUrl" alt="avatar" />
|
|
||||||
<Icon v-else icon="mdi:account-circle-outline" />
|
|
||||||
</div>
|
|
||||||
<div class="actions">
|
|
||||||
<input
|
|
||||||
ref="fileInput"
|
|
||||||
type="file"
|
|
||||||
accept="image/png,image/jpeg,image/webp"
|
|
||||||
class="hidden"
|
|
||||||
@change="onFile"
|
|
||||||
/>
|
|
||||||
<button type="button" class="btn-sm" @click="fileInput?.click()">
|
|
||||||
{{ previewUrl ? '更换' : '上传' }}
|
|
||||||
</button>
|
|
||||||
<button v-if="previewUrl" type="button" class="btn-sm btn-danger" @click="clear">
|
|
||||||
删除
|
|
||||||
</button>
|
|
||||||
</div>
|
|
||||||
<p v-if="error" class="hint error">{{ error }}</p>
|
|
||||||
<p v-else class="hint">PNG / JPG / WebP,≤200 KB</p>
|
|
||||||
</div>
|
|
||||||
</template>
|
|
||||||
|
|
||||||
<script setup lang="ts">
|
|
||||||
import { ref, watch } from 'vue';
|
|
||||||
import { Icon } from '@iconify/vue';
|
|
||||||
|
|
||||||
const props = defineProps<{ modelValue: string | null }>();
|
|
||||||
const emit = defineEmits<{ 'update:modelValue': [value: string | null] }>();
|
|
||||||
|
|
||||||
const previewUrl = ref<string | null>(props.modelValue);
|
|
||||||
const error = ref<string | null>(null);
|
|
||||||
const fileInput = ref<HTMLInputElement | null>(null);
|
|
||||||
|
|
||||||
watch(() => props.modelValue, (v) => { previewUrl.value = v; });
|
|
||||||
|
|
||||||
function onFile(ev: Event) {
|
|
||||||
const file = (ev.target as HTMLInputElement).files?.[0];
|
|
||||||
if (!file) return;
|
|
||||||
if (!['image/png', 'image/jpeg', 'image/webp'].includes(file.type)) {
|
|
||||||
error.value = '仅支持 PNG / JPG / WebP';
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
if (file.size > 200 * 1024) {
|
|
||||||
error.value = `图片 ${(file.size / 1024).toFixed(0)} KB 超过 200 KB 上限`;
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
error.value = null;
|
|
||||||
const reader = new FileReader();
|
|
||||||
reader.onload = () => {
|
|
||||||
const dataUrl = reader.result as string;
|
|
||||||
previewUrl.value = dataUrl;
|
|
||||||
emit('update:modelValue', dataUrl);
|
|
||||||
};
|
|
||||||
reader.readAsDataURL(file);
|
|
||||||
}
|
|
||||||
|
|
||||||
function clear() {
|
|
||||||
previewUrl.value = null;
|
|
||||||
emit('update:modelValue', null);
|
|
||||||
if (fileInput.value) fileInput.value.value = '';
|
|
||||||
}
|
|
||||||
</script>
|
|
||||||
|
|
||||||
<style lang="scss" scoped>
|
|
||||||
.avatar-upload { display: flex; flex-direction: column; gap: 8px; align-items: flex-start; }
|
|
||||||
|
|
||||||
.preview {
|
|
||||||
width: 80px; height: 80px; border-radius: 50%;
|
|
||||||
background: var(--bg-card); display: flex; align-items: center; justify-content: center;
|
|
||||||
overflow: hidden;
|
|
||||||
|
|
||||||
img { width: 100%; height: 100%; object-fit: cover; }
|
|
||||||
&.empty :deep(svg) { font-size: 48px; opacity: 0.4; }
|
|
||||||
}
|
|
||||||
|
|
||||||
.actions { display: flex; gap: 8px; }
|
|
||||||
.hidden { display: none; }
|
|
||||||
|
|
||||||
.btn-sm {
|
|
||||||
padding: 6px 14px;
|
|
||||||
background: var(--hover-bg);
|
|
||||||
border-radius: var(--radius-sm);
|
|
||||||
font-size: 12px;
|
|
||||||
font-weight: 600;
|
|
||||||
transition: all var(--transition-fast);
|
|
||||||
&:hover { background: var(--color-primary); color: white; }
|
|
||||||
}
|
|
||||||
|
|
||||||
.btn-danger {
|
|
||||||
&:hover { background: #f44336; color: white; }
|
|
||||||
}
|
|
||||||
|
|
||||||
.hint { font-size: 12px; opacity: 0.6; margin: 0; }
|
|
||||||
.hint.error { color: #f44336; opacity: 1; }
|
|
||||||
</style>
|
|
||||||
@@ -1,59 +0,0 @@
|
|||||||
<template>
|
|
||||||
<AvatarUpload v-model="avatarDataUrl" />
|
|
||||||
</template>
|
|
||||||
|
|
||||||
<script setup lang="ts">
|
|
||||||
import { ref, onMounted, watch, nextTick } from 'vue';
|
|
||||||
import axios from 'axios';
|
|
||||||
import AvatarUpload from './AvatarUpload.vue';
|
|
||||||
|
|
||||||
const props = defineProps<{ botId: string }>();
|
|
||||||
const avatarDataUrl = ref<string | null>(null);
|
|
||||||
// Stays true until the watcher queued by the load-time assignment has run,
|
|
||||||
// so the initial null → loaded-data-url transition does not fire a redundant
|
|
||||||
// PUT echoing the just-fetched bytes back to the server.
|
|
||||||
let initializing = true;
|
|
||||||
|
|
||||||
async function loadCurrent() {
|
|
||||||
try {
|
|
||||||
const res = await axios.get(`/api/bot/${props.botId}/avatar`, { responseType: 'blob' });
|
|
||||||
const blob = res.data as Blob;
|
|
||||||
avatarDataUrl.value = await blobToDataUrl(blob);
|
|
||||||
} catch (err: any) {
|
|
||||||
if (err?.response?.status !== 404) {
|
|
||||||
console.warn('failed to load avatar', err);
|
|
||||||
}
|
|
||||||
avatarDataUrl.value = null;
|
|
||||||
} finally {
|
|
||||||
// Wait for the watcher's flush queue to drain (it'll see initializing=true
|
|
||||||
// and bail), then release for real user-driven changes.
|
|
||||||
await nextTick();
|
|
||||||
initializing = false;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
function blobToDataUrl(blob: Blob): Promise<string> {
|
|
||||||
return new Promise((resolve, reject) => {
|
|
||||||
const reader = new FileReader();
|
|
||||||
reader.onload = () => resolve(reader.result as string);
|
|
||||||
reader.onerror = () => reject(reader.error);
|
|
||||||
reader.readAsDataURL(blob);
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
watch(avatarDataUrl, async (newVal, oldVal) => {
|
|
||||||
if (initializing) return;
|
|
||||||
if (newVal === oldVal) return;
|
|
||||||
try {
|
|
||||||
if (newVal && newVal.startsWith('data:')) {
|
|
||||||
await axios.put(`/api/bot/${props.botId}/avatar`, { dataUrl: newVal });
|
|
||||||
} else if (newVal === null) {
|
|
||||||
await axios.delete(`/api/bot/${props.botId}/avatar`);
|
|
||||||
}
|
|
||||||
} catch (err) {
|
|
||||||
console.warn('avatar update failed', err);
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
onMounted(loadCurrent);
|
|
||||||
</script>
|
|
||||||
@@ -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';
|
||||||
await store.playPlaylist(id, platform);
|
if (kind === 'album') {
|
||||||
|
await store.playAlbum(id, platform);
|
||||||
|
} else {
|
||||||
|
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;
|
||||||
|
|||||||
+79
-22
@@ -20,22 +20,54 @@
|
|||||||
|
|
||||||
<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">
|
||||||
<SongCard
|
<section v-if="albums.length" class="result-section">
|
||||||
v-for="(song, i) in results"
|
<h2 class="section-title">专辑</h2>
|
||||||
:key="`${song.platform}-${song.id}`"
|
<div class="card-grid">
|
||||||
:song="song"
|
<router-link
|
||||||
:index="i + 1"
|
v-for="al in albums"
|
||||||
:active="store.currentSong?.id === song.id"
|
:key="`${al.platform}-${al.id}`"
|
||||||
@play="store.playSong(song)"
|
:to="`/album/${al.id}?platform=${al.platform}`"
|
||||||
@playNext="store.playNextSong(song)"
|
class="card hover-scale"
|
||||||
@add="store.addSong(song)"
|
>
|
||||||
/>
|
<CoverArt :url="al.coverUrl" :size="160" :radius="10" :show-shadow="true" />
|
||||||
</div>
|
<div class="card-name">{{ al.name }}</div>
|
||||||
|
<div class="card-sub">{{ al.artist }}</div>
|
||||||
|
</router-link>
|
||||||
|
</div>
|
||||||
|
</section>
|
||||||
|
|
||||||
<div v-else-if="searched" class="empty">
|
<section v-if="playlists.length" class="result-section">
|
||||||
未找到相关结果
|
<h2 class="section-title">歌单</h2>
|
||||||
</div>
|
<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
|
||||||
|
v-for="(song, i) in songs"
|
||||||
|
:key="`${song.platform}-${song.id}`"
|
||||||
|
:song="song"
|
||||||
|
:index="i + 1"
|
||||||
|
:active="store.currentSong?.id === song.id"
|
||||||
|
@play="store.playSong(song)"
|
||||||
|
@playNext="store.playNextSong(song)"
|
||||||
|
@add="store.addSong(song)"
|
||||||
|
/>
|
||||||
|
</section>
|
||||||
|
</template>
|
||||||
|
|
||||||
|
<div v-else-if="searched" class="empty">未找到相关结果</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>
|
||||||
@@ -116,10 +116,6 @@
|
|||||||
<label>服务器密码(可选)</label>
|
<label>服务器密码(可选)</label>
|
||||||
<input v-model="newBotServerPassword" class="input" type="password" placeholder="服务器有密码时填写" />
|
<input v-model="newBotServerPassword" class="input" type="password" placeholder="服务器有密码时填写" />
|
||||||
</div>
|
</div>
|
||||||
<div class="form-group">
|
|
||||||
<label>自定义头像(可选)</label>
|
|
||||||
<AvatarUpload v-model="newBotAvatar" />
|
|
||||||
</div>
|
|
||||||
<button class="btn-primary" @click="createBot">创建</button>
|
<button class="btn-primary" @click="createBot">创建</button>
|
||||||
</div>
|
</div>
|
||||||
</section>
|
</section>
|
||||||
@@ -443,13 +439,6 @@
|
|||||||
@change="updateProfile(bot.id, t.key, ($event.target as HTMLInputElement).checked)"
|
@change="updateProfile(bot.id, t.key, ($event.target as HTMLInputElement).checked)"
|
||||||
/>
|
/>
|
||||||
</label>
|
</label>
|
||||||
<div v-if="profileConfigs[bot.id]" class="profile-toggle profile-toggle-static">
|
|
||||||
<div class="profile-toggle-text">
|
|
||||||
<div class="profile-toggle-label">自定义头像</div>
|
|
||||||
<div class="profile-toggle-hint">无论封面同步是否开启,停播时都会回到这张图</div>
|
|
||||||
</div>
|
|
||||||
<CustomAvatarRow :bot-id="bot.id" />
|
|
||||||
</div>
|
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
</div>
|
</div>
|
||||||
@@ -461,8 +450,6 @@
|
|||||||
import { ref, reactive, onMounted, onUnmounted } from 'vue';
|
import { ref, reactive, onMounted, onUnmounted } from 'vue';
|
||||||
import { Icon } from '@iconify/vue';
|
import { Icon } from '@iconify/vue';
|
||||||
import axios from 'axios';
|
import axios from 'axios';
|
||||||
import AvatarUpload from '../components/AvatarUpload.vue';
|
|
||||||
import CustomAvatarRow from '../components/CustomAvatarRow.vue';
|
|
||||||
import QRCode from 'qrcode';
|
import QRCode from 'qrcode';
|
||||||
import { usePlayerStore } from '../stores/player.js';
|
import { usePlayerStore } from '../stores/player.js';
|
||||||
|
|
||||||
@@ -488,7 +475,6 @@ const newBotPort = ref(9987);
|
|||||||
const newBotNickname = ref('MusicBot');
|
const newBotNickname = ref('MusicBot');
|
||||||
const newBotChannel = ref('');
|
const newBotChannel = ref('');
|
||||||
const newBotServerPassword = ref('');
|
const newBotServerPassword = ref('');
|
||||||
const newBotAvatar = ref<string | null>(null);
|
|
||||||
|
|
||||||
// Edit bot
|
// Edit bot
|
||||||
const editingBot = ref<string | null>(null);
|
const editingBot = ref<string | null>(null);
|
||||||
@@ -649,7 +635,7 @@ async function pollQrStatus(platform: string) {
|
|||||||
async function createBot() {
|
async function createBot() {
|
||||||
if (!newBotName.value || !newBotServer.value) return;
|
if (!newBotName.value || !newBotServer.value) return;
|
||||||
try {
|
try {
|
||||||
const res = await axios.post('/api/bot', {
|
await axios.post('/api/bot', {
|
||||||
name: newBotName.value,
|
name: newBotName.value,
|
||||||
serverAddress: newBotServer.value,
|
serverAddress: newBotServer.value,
|
||||||
serverPort: newBotPort.value || 9987,
|
serverPort: newBotPort.value || 9987,
|
||||||
@@ -658,20 +644,12 @@ async function createBot() {
|
|||||||
serverPassword: newBotServerPassword.value || undefined,
|
serverPassword: newBotServerPassword.value || undefined,
|
||||||
autoStart: false,
|
autoStart: false,
|
||||||
});
|
});
|
||||||
if (newBotAvatar.value && res.data?.id) {
|
|
||||||
try {
|
|
||||||
await axios.put(`/api/bot/${res.data.id}/avatar`, { dataUrl: newBotAvatar.value });
|
|
||||||
} catch (err) {
|
|
||||||
console.warn('failed to set avatar on new bot', err);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
newBotName.value = '';
|
newBotName.value = '';
|
||||||
newBotServer.value = '';
|
newBotServer.value = '';
|
||||||
newBotPort.value = 9987;
|
newBotPort.value = 9987;
|
||||||
newBotNickname.value = 'MusicBot';
|
newBotNickname.value = 'MusicBot';
|
||||||
newBotChannel.value = '';
|
newBotChannel.value = '';
|
||||||
newBotServerPassword.value = '';
|
newBotServerPassword.value = '';
|
||||||
newBotAvatar.value = null;
|
|
||||||
await store.fetchBots();
|
await store.fetchBots();
|
||||||
} catch {
|
} catch {
|
||||||
// Ignore
|
// Ignore
|
||||||
@@ -1430,11 +1408,6 @@ onUnmounted(() => {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
.profile-toggle-static {
|
|
||||||
cursor: default;
|
|
||||||
align-items: flex-start;
|
|
||||||
}
|
|
||||||
|
|
||||||
@media (max-width: 768px) {
|
@media (max-width: 768px) {
|
||||||
.profile-bot-header {
|
.profile-bot-header {
|
||||||
padding: 14px 12px;
|
padding: 14px 12px;
|
||||||
|
|||||||
Reference in new issue
Block a user