import { ipcMain } from 'electron'; import { InternetProviderLyricResponse, InternetProviderLyricSearchResponse, LyricSearchQuery, QueueSong, LyricGetQuery, LyricSource, } from '../../../../renderer/api/types'; import { store } from '../settings/index'; import { query as queryGenius, getSearchResults as searchGenius, getLyricsBySongId as getGenius, } from './genius'; import { query as queryNetease, getSearchResults as searchNetease, getLyricsBySongId as getNetease, } from './netease'; type SongFetcher = (params: LyricSearchQuery) => Promise; type SearchFetcher = ( params: LyricSearchQuery, ) => Promise; type GetFetcher = (id: string) => Promise; type CachedLyrics = Record; const FETCHERS: Record = { [LyricSource.GENIUS]: queryGenius, [LyricSource.NETEASE]: queryNetease, }; const SEARCH_FETCHERS: Record = { [LyricSource.GENIUS]: searchGenius, [LyricSource.NETEASE]: searchNetease, }; const GET_FETCHERS: Record = { [LyricSource.GENIUS]: getGenius, [LyricSource.NETEASE]: getNetease, }; const MAX_CACHED_ITEMS = 10; const lyricCache = new Map(); const getRemoteLyrics = async (song: QueueSong) => { const sources = store.get('lyrics', []) as LyricSource[]; const cached = lyricCache.get(song.id); if (cached) { for (const source of sources) { const data = cached[source]; if (data) return data; } } let lyricsFromSource = null; for (const source of sources) { const params = { artist: song.artistName, name: song.name }; const response = await FETCHERS[source](params); if (response) { const newResult = cached ? { ...cached, [source]: response, } : ({ [source]: response } as CachedLyrics); if (lyricCache.size === MAX_CACHED_ITEMS && cached === undefined) { const toRemove = lyricCache.keys().next().value; lyricCache.delete(toRemove); } lyricCache.set(song.id, newResult); lyricsFromSource = response; break; } } return lyricsFromSource; }; const searchRemoteLyrics = async (params: LyricSearchQuery) => { const sources = store.get('lyrics', []) as LyricSource[]; const results: Record = { [LyricSource.GENIUS]: [], [LyricSource.NETEASE]: [], }; for (const source of sources) { const response = await SEARCH_FETCHERS[source](params); if (response) { response.forEach((result) => { results[source].push(result); }); } } return results; }; const getRemoteLyricsById = async (params: LyricGetQuery): Promise => { const { remoteSongId, remoteSource } = params; const response = await GET_FETCHERS[remoteSource](remoteSongId); if (!response) { return null; } return response; }; ipcMain.handle('lyric-by-song', async (_event, song: QueueSong) => { const lyric = await getRemoteLyrics(song); return lyric; }); ipcMain.handle('lyric-search', async (_event, params: LyricSearchQuery) => { const lyricResults = await searchRemoteLyrics(params); return lyricResults; }); ipcMain.handle('lyric-by-remote-id', async (_event, params: LyricGetQuery) => { const lyricResults = await getRemoteLyricsById(params); return lyricResults; });