mirror of
https://github.com/jeffvli/feishin.git
synced 2026-07-08 19:50:12 +02:00
Improve Jellyfin playlist loading and modification performance times (#2184)
* Remove unneeded Fields from getPlaylistSongList * Add optimized controller function for playlist addition duplication checks * Remove Jellyfin People data handling * move artist map inline --------- Co-authored-by: Kendall Garner <17521368+kgarner7@users.noreply.github.com>
This commit is contained in:
@@ -546,6 +546,18 @@ export const controller: GeneralController = {
|
|||||||
server.type,
|
server.type,
|
||||||
)?.(addContext({ ...args, apiClientProps: { ...args.apiClientProps, server } }));
|
)?.(addContext({ ...args, apiClientProps: { ...args.apiClientProps, server } }));
|
||||||
},
|
},
|
||||||
|
getPlaylistSongIds(args) {
|
||||||
|
const server = getServerById(args.apiClientProps.serverId);
|
||||||
|
|
||||||
|
if (!server) {
|
||||||
|
throw new Error(`${i18n.t('error.apiRouteError')}: getPlaylistSongIds`);
|
||||||
|
}
|
||||||
|
|
||||||
|
return apiController(
|
||||||
|
'getPlaylistSongIds',
|
||||||
|
server.type,
|
||||||
|
)?.(addContext({ ...args, apiClientProps: { ...args.apiClientProps, server } }));
|
||||||
|
},
|
||||||
getPlaylistSongList(args) {
|
getPlaylistSongList(args) {
|
||||||
const server = getServerById(args.apiClientProps.serverId);
|
const server = getServerById(args.apiClientProps.serverId);
|
||||||
|
|
||||||
|
|||||||
@@ -197,8 +197,8 @@ const JF_FIELDS = {
|
|||||||
'SortName',
|
'SortName',
|
||||||
'ProviderIds',
|
'ProviderIds',
|
||||||
],
|
],
|
||||||
ALBUM_DETAIL: ['Genres', 'DateCreated', 'ChildCount', 'People', 'Tags', 'ProviderIds'],
|
ALBUM_DETAIL: ['Genres', 'DateCreated', 'ChildCount', 'Tags', 'ProviderIds'],
|
||||||
ALBUM_LIST: ['People', 'Tags', 'Studios', 'SortName', 'ProviderIds', 'ChildCount'],
|
ALBUM_LIST: ['Tags', 'Studios', 'SortName', 'ProviderIds', 'ChildCount'],
|
||||||
FOLDER: ['Genres', 'DateCreated', 'MediaSources', 'ParentId'],
|
FOLDER: ['Genres', 'DateCreated', 'MediaSources', 'ParentId'],
|
||||||
GENRE: ['ItemCounts'],
|
GENRE: ['ItemCounts'],
|
||||||
PLAYLIST_DETAIL: [
|
PLAYLIST_DETAIL: [
|
||||||
@@ -210,16 +210,7 @@ const JF_FIELDS = {
|
|||||||
'SortName',
|
'SortName',
|
||||||
],
|
],
|
||||||
PLAYLIST_LIST: ['ChildCount', 'Genres', 'DateCreated', 'ParentId', 'Overview'],
|
PLAYLIST_LIST: ['ChildCount', 'Genres', 'DateCreated', 'ParentId', 'Overview'],
|
||||||
SONG: [
|
SONG: ['Genres', 'DateCreated', 'MediaSources', 'ParentId', 'Tags', 'SortName', 'ProviderIds'],
|
||||||
'Genres',
|
|
||||||
'DateCreated',
|
|
||||||
'MediaSources',
|
|
||||||
'ParentId',
|
|
||||||
'People',
|
|
||||||
'Tags',
|
|
||||||
'SortName',
|
|
||||||
'ProviderIds',
|
|
||||||
],
|
|
||||||
} as const;
|
} as const;
|
||||||
|
|
||||||
export const JellyfinController: InternalControllerEndpoint = {
|
export const JellyfinController: InternalControllerEndpoint = {
|
||||||
@@ -1056,6 +1047,35 @@ export const JellyfinController: InternalControllerEndpoint = {
|
|||||||
apiClientProps,
|
apiClientProps,
|
||||||
query: { ...query, limit: 1, startIndex: 0 },
|
query: { ...query, limit: 1, startIndex: 0 },
|
||||||
}).then((result) => result!.totalRecordCount!),
|
}).then((result) => result!.totalRecordCount!),
|
||||||
|
getPlaylistSongIds: async (args) => {
|
||||||
|
const { apiClientProps, query } = args;
|
||||||
|
|
||||||
|
if (!apiClientProps.server?.userId) {
|
||||||
|
throw new Error('No userId found');
|
||||||
|
}
|
||||||
|
|
||||||
|
const res = await jfApiClient(apiClientProps).getPlaylistSongList({
|
||||||
|
params: {
|
||||||
|
id: query.id,
|
||||||
|
},
|
||||||
|
query: {
|
||||||
|
// XXX: No fields are required for only IDs, which saves processing time between
|
||||||
|
// the Jellyfin server query, network (MBs vs KBs), and in-app parsing.
|
||||||
|
IncludeItemTypes: 'Audio',
|
||||||
|
UserId: apiClientProps.server?.userId,
|
||||||
|
},
|
||||||
|
});
|
||||||
|
|
||||||
|
if (res.status !== 200) {
|
||||||
|
throw new Error('Failed to get playlist song list IDs');
|
||||||
|
}
|
||||||
|
|
||||||
|
return {
|
||||||
|
items: res.body.Items.map((item) => item.Id),
|
||||||
|
startIndex: 0,
|
||||||
|
totalRecordCount: res.body.TotalRecordCount,
|
||||||
|
};
|
||||||
|
},
|
||||||
getPlaylistSongList: async (args) => {
|
getPlaylistSongList: async (args) => {
|
||||||
const { apiClientProps, query } = args;
|
const { apiClientProps, query } = args;
|
||||||
|
|
||||||
@@ -1068,7 +1088,7 @@ export const JellyfinController: InternalControllerEndpoint = {
|
|||||||
id: query.id,
|
id: query.id,
|
||||||
},
|
},
|
||||||
query: {
|
query: {
|
||||||
Fields: JF_FIELDS.SONG,
|
Fields: JF_FIELDS.PLAYLIST_DETAIL,
|
||||||
IncludeItemTypes: 'Audio',
|
IncludeItemTypes: 'Audio',
|
||||||
UserId: apiClientProps.server?.userId,
|
UserId: apiClientProps.server?.userId,
|
||||||
},
|
},
|
||||||
|
|||||||
@@ -663,6 +663,11 @@ export const NavidromeController: InternalControllerEndpoint = {
|
|||||||
apiClientProps,
|
apiClientProps,
|
||||||
query: { ...query, limit: 1, startIndex: 0 },
|
query: { ...query, limit: 1, startIndex: 0 },
|
||||||
}).then((result) => result!.totalRecordCount!),
|
}).then((result) => result!.totalRecordCount!),
|
||||||
|
getPlaylistSongIds: async (args) =>
|
||||||
|
NavidromeController.getPlaylistSongList(args).then((result) => ({
|
||||||
|
...result,
|
||||||
|
items: result.items.map((song) => song.id),
|
||||||
|
})),
|
||||||
getPlaylistSongList: async (args: PlaylistSongListArgs): Promise<PlaylistSongListResponse> => {
|
getPlaylistSongList: async (args: PlaylistSongListArgs): Promise<PlaylistSongListResponse> => {
|
||||||
const { apiClientProps, query } = args;
|
const { apiClientProps, query } = args;
|
||||||
|
|
||||||
|
|||||||
@@ -338,6 +338,9 @@ export const queryKeys: Record<
|
|||||||
|
|
||||||
return [serverId, 'playlists', 'songList'] as const;
|
return [serverId, 'playlists', 'songList'] as const;
|
||||||
},
|
},
|
||||||
|
songListIds: (serverId: string, id: string) => {
|
||||||
|
return [serverId, 'playlists', 'songListIds', id] as const;
|
||||||
|
},
|
||||||
},
|
},
|
||||||
radio: {
|
radio: {
|
||||||
list: (serverId: string) => [serverId, 'radio', 'list'] as const,
|
list: (serverId: string) => [serverId, 'radio', 'list'] as const,
|
||||||
|
|||||||
@@ -1229,6 +1229,11 @@ export const SubsonicController: InternalControllerEndpoint = {
|
|||||||
|
|
||||||
return results.length;
|
return results.length;
|
||||||
},
|
},
|
||||||
|
getPlaylistSongIds: async (args) =>
|
||||||
|
SubsonicController.getPlaylistSongList(args).then((result) => ({
|
||||||
|
...result,
|
||||||
|
items: result.items.map((song) => song.id),
|
||||||
|
})),
|
||||||
getPlaylistSongList: async ({ apiClientProps, query }) => {
|
getPlaylistSongList: async ({ apiClientProps, query }) => {
|
||||||
const res = await ssApiClient(apiClientProps).getPlaylist({
|
const res = await ssApiClient(apiClientProps).getPlaylist({
|
||||||
query: {
|
query: {
|
||||||
|
|||||||
@@ -211,11 +211,11 @@ export const AddToPlaylistAction = ({ items, itemType }: AddToPlaylistActionProp
|
|||||||
let songsToAdd: string[] = allSongIds;
|
let songsToAdd: string[] = allSongIds;
|
||||||
|
|
||||||
if (skipDuplicates) {
|
if (skipDuplicates) {
|
||||||
const queryKey = queryKeys.playlists.songList(serverId, playlistId);
|
const queryKey = queryKeys.playlists.songListIds(serverId, playlistId);
|
||||||
|
|
||||||
const playlistSongsRes = await queryClient.fetchQuery({
|
const playlistSongsRes = await queryClient.fetchQuery({
|
||||||
queryFn: ({ signal }) => {
|
queryFn: ({ signal }) => {
|
||||||
return api.controller.getPlaylistSongList({
|
return api.controller.getPlaylistSongIds({
|
||||||
apiClientProps: {
|
apiClientProps: {
|
||||||
serverId,
|
serverId,
|
||||||
signal,
|
signal,
|
||||||
@@ -228,7 +228,7 @@ export const AddToPlaylistAction = ({ items, itemType }: AddToPlaylistActionProp
|
|||||||
queryKey,
|
queryKey,
|
||||||
});
|
});
|
||||||
|
|
||||||
const playlistSongIds = playlistSongsRes?.items?.map((song) => song.id);
|
const playlistSongIds = playlistSongsRes?.items;
|
||||||
const uniqueSongIds: string[] = [];
|
const uniqueSongIds: string[] = [];
|
||||||
|
|
||||||
for (const songId of allSongIds) {
|
for (const songId of allSongIds) {
|
||||||
|
|||||||
@@ -231,11 +231,11 @@ export const AddToPlaylistContextModal = ({
|
|||||||
const uniqueSongIds: string[] = [];
|
const uniqueSongIds: string[] = [];
|
||||||
|
|
||||||
if (values.skipDuplicates) {
|
if (values.skipDuplicates) {
|
||||||
const queryKey = queryKeys.playlists.songList(serverId, playlistId);
|
const queryKey = queryKeys.playlists.songListIds(serverId, playlistId);
|
||||||
|
|
||||||
const playlistSongsRes = await queryClient.fetchQuery({
|
const playlistSongsRes = await queryClient.fetchQuery({
|
||||||
queryFn: ({ signal }) => {
|
queryFn: ({ signal }) => {
|
||||||
return api.controller.getPlaylistSongList({
|
return api.controller.getPlaylistSongIds({
|
||||||
apiClientProps: {
|
apiClientProps: {
|
||||||
serverId,
|
serverId,
|
||||||
signal,
|
signal,
|
||||||
@@ -248,7 +248,7 @@ export const AddToPlaylistContextModal = ({
|
|||||||
queryKey,
|
queryKey,
|
||||||
});
|
});
|
||||||
|
|
||||||
const playlistSongIds = playlistSongsRes?.items?.map((song) => song.id);
|
const playlistSongIds = playlistSongsRes?.items;
|
||||||
|
|
||||||
for (const songId of allSongIds) {
|
for (const songId of allSongIds) {
|
||||||
if (!playlistSongIds?.includes(songId)) {
|
if (!playlistSongIds?.includes(songId)) {
|
||||||
|
|||||||
@@ -10,7 +10,6 @@ import {
|
|||||||
LibraryItem,
|
LibraryItem,
|
||||||
MusicFolder,
|
MusicFolder,
|
||||||
Playlist,
|
Playlist,
|
||||||
RelatedArtist,
|
|
||||||
Song,
|
Song,
|
||||||
} from '/@/shared/types/domain-types';
|
} from '/@/shared/types/domain-types';
|
||||||
import { ServerListItem, ServerType } from '/@/shared/types/types';
|
import { ServerListItem, ServerType } from '/@/shared/types/types';
|
||||||
@@ -19,42 +18,6 @@ const TICKS_PER_MS = 10000;
|
|||||||
|
|
||||||
type AlbumOrSong = z.infer<typeof jfType._response.album> | z.infer<typeof jfType._response.song>;
|
type AlbumOrSong = z.infer<typeof jfType._response.album> | z.infer<typeof jfType._response.song>;
|
||||||
|
|
||||||
const KEYS_TO_OMIT = new Set(['AlbumArtist', 'Artist']);
|
|
||||||
|
|
||||||
const getPeople = (item: AlbumOrSong): null | Record<string, RelatedArtist[]> => {
|
|
||||||
if (item.People) {
|
|
||||||
const participants: Record<string, RelatedArtist[]> = {};
|
|
||||||
|
|
||||||
for (const person of item.People) {
|
|
||||||
const key = person.Type || '';
|
|
||||||
if (KEYS_TO_OMIT.has(key)) {
|
|
||||||
continue;
|
|
||||||
}
|
|
||||||
|
|
||||||
const item: RelatedArtist = {
|
|
||||||
// for other roles, we just want to display this and not filter.
|
|
||||||
// filtering (and links) would require a separate field, PersonIds
|
|
||||||
id: '',
|
|
||||||
imageId: null,
|
|
||||||
imageUrl: null,
|
|
||||||
name: person.Name,
|
|
||||||
userFavorite: false,
|
|
||||||
userRating: null,
|
|
||||||
};
|
|
||||||
|
|
||||||
if (key in participants) {
|
|
||||||
participants[key].push(item);
|
|
||||||
} else {
|
|
||||||
participants[key] = [item];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return participants;
|
|
||||||
}
|
|
||||||
|
|
||||||
return null;
|
|
||||||
};
|
|
||||||
|
|
||||||
const getTags = (item: AlbumOrSong): null | Record<string, string[]> => {
|
const getTags = (item: AlbumOrSong): null | Record<string, string[]> => {
|
||||||
if (item.Tags) {
|
if (item.Tags) {
|
||||||
const tags: Record<string, string[]> = {};
|
const tags: Record<string, string[]> = {};
|
||||||
@@ -106,39 +69,6 @@ const getPlaylistImageId = (item: z.infer<typeof jfType._response.playlist>): nu
|
|||||||
return null;
|
return null;
|
||||||
};
|
};
|
||||||
|
|
||||||
const getArtists = (
|
|
||||||
item: z.infer<typeof jfType._response.song>,
|
|
||||||
participants?: null | Record<string, RelatedArtist[]>,
|
|
||||||
): RelatedArtist[] => {
|
|
||||||
if (!item?.ArtistItems?.length && !item.AlbumArtists && !participants) {
|
|
||||||
return [];
|
|
||||||
}
|
|
||||||
|
|
||||||
const result: RelatedArtist[] = [];
|
|
||||||
|
|
||||||
(item?.ArtistItems?.length ? item.ArtistItems : item.AlbumArtists)?.forEach((entry) => {
|
|
||||||
result.push({
|
|
||||||
id: entry.Id,
|
|
||||||
imageId: null,
|
|
||||||
imageUrl: null,
|
|
||||||
name: entry.Name,
|
|
||||||
userFavorite: false,
|
|
||||||
userRating: null,
|
|
||||||
});
|
|
||||||
});
|
|
||||||
|
|
||||||
if (participants?.['Remixer']) {
|
|
||||||
const existingIds = new Set(result.map((artist) => artist.id));
|
|
||||||
for (const participant of participants['Remixer']) {
|
|
||||||
if (!existingIds.has(participant.id)) {
|
|
||||||
result.push(participant);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return result;
|
|
||||||
};
|
|
||||||
|
|
||||||
const jellyfinPremiereFields = (item: {
|
const jellyfinPremiereFields = (item: {
|
||||||
PremiereDate?: string;
|
PremiereDate?: string;
|
||||||
ProductionYear?: number;
|
ProductionYear?: number;
|
||||||
@@ -189,10 +119,6 @@ const normalizeSong = (
|
|||||||
console.warn('Jellyfin song retrieved with no media sources', item);
|
console.warn('Jellyfin song retrieved with no media sources', item);
|
||||||
}
|
}
|
||||||
|
|
||||||
const participants = getPeople(item);
|
|
||||||
|
|
||||||
const artists = getArtists(item, participants);
|
|
||||||
|
|
||||||
const { releaseDate, releaseYear } = jellyfinPremiereFields(item);
|
const { releaseDate, releaseYear } = jellyfinPremiereFields(item);
|
||||||
|
|
||||||
return {
|
return {
|
||||||
@@ -211,7 +137,16 @@ const normalizeSong = (
|
|||||||
})),
|
})),
|
||||||
albumId: item.AlbumId || `dummy/${item.Id}`,
|
albumId: item.AlbumId || `dummy/${item.Id}`,
|
||||||
artistName: item?.ArtistItems?.map((entry) => entry.Name).join(', ') || '',
|
artistName: item?.ArtistItems?.map((entry) => entry.Name).join(', ') || '',
|
||||||
artists,
|
artists: (item?.ArtistItems?.length ? item.ArtistItems : item.AlbumArtists)?.map(
|
||||||
|
(entry) => ({
|
||||||
|
id: entry.Id,
|
||||||
|
imageId: null,
|
||||||
|
imageUrl: null,
|
||||||
|
name: entry.Name,
|
||||||
|
userFavorite: false,
|
||||||
|
userRating: null,
|
||||||
|
}),
|
||||||
|
),
|
||||||
bitDepth,
|
bitDepth,
|
||||||
bitRate,
|
bitRate,
|
||||||
bpm: null,
|
bpm: null,
|
||||||
@@ -253,7 +188,7 @@ const normalizeSong = (
|
|||||||
mbzRecordingId: null,
|
mbzRecordingId: null,
|
||||||
mbzTrackId: item.ProviderIds?.MusicBrainzTrack || null,
|
mbzTrackId: item.ProviderIds?.MusicBrainzTrack || null,
|
||||||
name: item.Name,
|
name: item.Name,
|
||||||
participants,
|
participants: null,
|
||||||
path: path || '',
|
path: path || '',
|
||||||
peak: null,
|
peak: null,
|
||||||
playCount: (item.UserData && item.UserData.PlayCount) || 0,
|
playCount: (item.UserData && item.UserData.PlayCount) || 0,
|
||||||
@@ -328,7 +263,7 @@ const normalizeAlbum = (
|
|||||||
name: item.Name,
|
name: item.Name,
|
||||||
originalDate: releaseDate,
|
originalDate: releaseDate,
|
||||||
originalYear,
|
originalYear,
|
||||||
participants: getPeople(item),
|
participants: null,
|
||||||
playCount: item.UserData?.PlayCount || 0,
|
playCount: item.UserData?.PlayCount || 0,
|
||||||
recordLabels: item.Studios?.map((entry) => entry.Name) || [],
|
recordLabels: item.Studios?.map((entry) => entry.Name) || [],
|
||||||
releaseDate,
|
releaseDate,
|
||||||
|
|||||||
@@ -636,6 +636,8 @@ export type AlbumInfo = {
|
|||||||
notes: null | string;
|
notes: null | string;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
export type SongIdListResponse = BasePaginatedResponse<string[]>;
|
||||||
|
|
||||||
export type SongListArgs = BaseEndpointArgs & { query: SongListQuery };
|
export type SongListArgs = BaseEndpointArgs & { query: SongListQuery };
|
||||||
|
|
||||||
export type SongListCountArgs = BaseEndpointArgs & { query: ListCountQuery<SongListQuery> };
|
export type SongListCountArgs = BaseEndpointArgs & { query: ListCountQuery<SongListQuery> };
|
||||||
@@ -1522,6 +1524,7 @@ export type ControllerEndpoint = {
|
|||||||
getPlaylistDetail: (args: PlaylistDetailArgs) => Promise<PlaylistDetailResponse>;
|
getPlaylistDetail: (args: PlaylistDetailArgs) => Promise<PlaylistDetailResponse>;
|
||||||
getPlaylistList: (args: PlaylistListArgs) => Promise<PlaylistListResponse>;
|
getPlaylistList: (args: PlaylistListArgs) => Promise<PlaylistListResponse>;
|
||||||
getPlaylistListCount: (args: PlaylistListCountArgs) => Promise<number>;
|
getPlaylistListCount: (args: PlaylistListCountArgs) => Promise<number>;
|
||||||
|
getPlaylistSongIds: (args: PlaylistSongListArgs) => Promise<SongIdListResponse>;
|
||||||
getPlaylistSongList: (args: PlaylistSongListArgs) => Promise<SongListResponse>;
|
getPlaylistSongList: (args: PlaylistSongListArgs) => Promise<SongListResponse>;
|
||||||
getPlayQueue: (args: GetQueueArgs) => Promise<GetQueueResponse>;
|
getPlayQueue: (args: GetQueueArgs) => Promise<GetQueueResponse>;
|
||||||
getRandomSongList: (args: RandomSongListArgs) => Promise<SongListResponse>;
|
getRandomSongList: (args: RandomSongListArgs) => Promise<SongListResponse>;
|
||||||
@@ -1676,6 +1679,9 @@ export type InternalControllerEndpoint = {
|
|||||||
args: ReplaceApiClientProps<PlaylistListArgs>,
|
args: ReplaceApiClientProps<PlaylistListArgs>,
|
||||||
) => Promise<PlaylistListResponse>;
|
) => Promise<PlaylistListResponse>;
|
||||||
getPlaylistListCount: (args: ReplaceApiClientProps<PlaylistListCountArgs>) => Promise<number>;
|
getPlaylistListCount: (args: ReplaceApiClientProps<PlaylistListCountArgs>) => Promise<number>;
|
||||||
|
getPlaylistSongIds: (
|
||||||
|
args: ReplaceApiClientProps<PlaylistSongListArgs>,
|
||||||
|
) => Promise<SongIdListResponse>;
|
||||||
getPlaylistSongList: (
|
getPlaylistSongList: (
|
||||||
args: ReplaceApiClientProps<PlaylistSongListArgs>,
|
args: ReplaceApiClientProps<PlaylistSongListArgs>,
|
||||||
) => Promise<SongListResponse>;
|
) => Promise<SongListResponse>;
|
||||||
|
|||||||
Reference in New Issue
Block a user