Navidrome-MCP

/** * Navidrome MCP Server - API Client * Copyright (C) 2025 * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU Affero General Public License as published * by the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU Affero General Public License for more details. * * You should have received a copy of the GNU Affero General Public License * along with this program. If not, see <https://www.gnu.org/licenses/>. */ import type { Config } from '../config.js'; import { AuthManager } from './auth-manager.js'; import { logger } from '../utils/logger.js'; import { ErrorFormatter } from '../utils/error-formatter.js'; import { libraryManager } from '../services/library-manager.js'; export class NavidromeClient { private readonly authManager: AuthManager; private readonly baseUrl: string; private readonly config: Config; constructor(config: Config) { this.baseUrl = config.navidromeUrl; this.authManager = new AuthManager(config); this.config = config; } async initialize(): Promise<void> { await this.authManager.authenticate(); logger.info('Navidrome client initialized'); } async request<T>(endpoint: string, options: RequestInit = {}): Promise<T> { const token = await this.authManager.getToken(); const defaultHeaders: Record<string, string> = { 'X-ND-Authorization': `Bearer ${token}`, }; // Only set Content-Type for non-GET requests if (options.method !== null && options.method !== undefined && options.method !== 'GET') { defaultHeaders['Content-Type'] = 'application/json'; } const response = await fetch(`${this.baseUrl}/api${endpoint}`, { ...options, headers: { ...defaultHeaders, ...options.headers, }, }); if (!response.ok) { const errorText = await response.text(); throw new Error(ErrorFormatter.httpRequest('navidrome API', response, errorText)); } // Handle different content types const contentType = response.headers.get('content-type'); if (contentType?.includes('application/json') === true) { return response.json() as Promise<T>; } else { return response.text() as Promise<T>; } } /** * Make a request with automatic library filtering applied. * This method automatically adds library_id parameters for active libraries. */ async requestWithLibraryFilter<T>(endpoint: string, options: RequestInit = {}): Promise<T> { // Parse the endpoint to extract path and existing query parameters const url = new URL(endpoint, 'http://localhost'); // Base doesn't matter, we just need to parse const path = url.pathname; const existingParams = url.searchParams; // Add library filtering if LibraryManager is initialized and has active libraries if (libraryManager.isInitialized()) { const libraryParams = libraryManager.getLibraryQueryParams(); // Add library_id parameters (duplicate parameters as discovered from frontend) for (const [key, value] of libraryParams.entries()) { existingParams.append(key, value); } } // Reconstruct the endpoint with library filters const filteredEndpoint = existingParams.toString() ? `${path}?${existingParams.toString()}` : path; logger.debug(`Request with library filter: ${filteredEndpoint}`); return this.request<T>(filteredEndpoint, options); } async subsonicRequest(endpoint: string, params: Record<string, string> = {}): Promise<unknown> { // Build Subsonic REST API parameters const queryParams = new URLSearchParams({ u: this.config.navidromeUsername, p: this.config.navidromePassword, v: '1.16.1', c: 'navidrome-mcp', f: 'json', ...params, }); const response = await fetch(`${this.baseUrl}/rest${endpoint}?${queryParams}`); if (!response.ok) { throw new Error(ErrorFormatter.subsonicApi(response)); } const data = await response.json() as { 'subsonic-response'?: { status?: string; error?: { message?: string } } }; if (data['subsonic-response']?.status !== 'ok') { throw new Error(ErrorFormatter.subsonicResponse(data['subsonic-response']?.error?.message)); } return data['subsonic-response']; } }