mirror of
https://github.com/wkulhanek/bonob.git
synced 2025-12-21 17:33:29 +01:00
pull subsonic out into proper class (#217)
This commit is contained in:
@@ -1,4 +1,4 @@
|
|||||||
FROM node:20-bullseye-slim as build
|
FROM node:20-bullseye-slim AS build
|
||||||
|
|
||||||
WORKDIR /bonob
|
WORKDIR /bonob
|
||||||
|
|
||||||
|
|||||||
10
src/app.ts
10
src/app.ts
@@ -6,9 +6,10 @@ import logger from "./logger";
|
|||||||
import {
|
import {
|
||||||
axiosImageFetcher,
|
axiosImageFetcher,
|
||||||
cachingImageFetcher,
|
cachingImageFetcher,
|
||||||
Subsonic,
|
SubsonicMusicService,
|
||||||
TranscodingCustomPlayers,
|
TranscodingCustomPlayers,
|
||||||
NO_CUSTOM_PLAYERS
|
NO_CUSTOM_PLAYERS,
|
||||||
|
Subsonic
|
||||||
} from "./subsonic";
|
} from "./subsonic";
|
||||||
import { InMemoryAPITokens, sha256 } from "./api_tokens";
|
import { InMemoryAPITokens, sha256 } from "./api_tokens";
|
||||||
import { InMemoryLinkCodes } from "./link_codes";
|
import { InMemoryLinkCodes } from "./link_codes";
|
||||||
@@ -40,10 +41,13 @@ const artistImageFetcher = config.subsonic.artistImageCache
|
|||||||
? cachingImageFetcher(config.subsonic.artistImageCache, axiosImageFetcher)
|
? cachingImageFetcher(config.subsonic.artistImageCache, axiosImageFetcher)
|
||||||
: axiosImageFetcher;
|
: axiosImageFetcher;
|
||||||
|
|
||||||
const subsonic = new Subsonic(
|
const subsonic = new SubsonicMusicService(
|
||||||
|
new Subsonic(
|
||||||
config.subsonic.url,
|
config.subsonic.url,
|
||||||
customPlayers,
|
customPlayers,
|
||||||
artistImageFetcher
|
artistImageFetcher
|
||||||
|
),
|
||||||
|
customPlayers
|
||||||
);
|
);
|
||||||
|
|
||||||
const featureFlagAwareMusicService: MusicService = {
|
const featureFlagAwareMusicService: MusicService = {
|
||||||
|
|||||||
812
src/subsonic.ts
812
src/subsonic.ts
@@ -22,6 +22,7 @@ import {
|
|||||||
AuthFailure,
|
AuthFailure,
|
||||||
PlaylistSummary,
|
PlaylistSummary,
|
||||||
Encoding,
|
Encoding,
|
||||||
|
AuthSuccess,
|
||||||
} from "./music_service";
|
} from "./music_service";
|
||||||
import sharp from "sharp";
|
import sharp from "sharp";
|
||||||
import _ from "underscore";
|
import _ from "underscore";
|
||||||
@@ -469,17 +470,441 @@ type SubsonicCredentials = Credentials & {
|
|||||||
|
|
||||||
export const asToken = (credentials: SubsonicCredentials) =>
|
export const asToken = (credentials: SubsonicCredentials) =>
|
||||||
b64Encode(JSON.stringify(credentials));
|
b64Encode(JSON.stringify(credentials));
|
||||||
|
|
||||||
export const parseToken = (token: string): SubsonicCredentials =>
|
export const parseToken = (token: string): SubsonicCredentials =>
|
||||||
JSON.parse(b64Decode(token));
|
JSON.parse(b64Decode(token));
|
||||||
|
|
||||||
interface SubsonicMusicLibrary extends MusicLibrary {
|
export class SubsonicMusicLibrary implements MusicLibrary {
|
||||||
flavour(): string;
|
subsonic: Subsonic;
|
||||||
bearerToken(
|
|
||||||
credentials: Credentials
|
credentials: Credentials
|
||||||
): TE.TaskEither<Error, string | undefined>;
|
customPlayers: CustomPlayers
|
||||||
|
|
||||||
|
constructor(
|
||||||
|
subsonic: Subsonic,
|
||||||
|
credentials: Credentials,
|
||||||
|
customPlayers: CustomPlayers
|
||||||
|
) {
|
||||||
|
this.subsonic = subsonic
|
||||||
|
this.credentials = credentials
|
||||||
|
this.customPlayers = customPlayers
|
||||||
}
|
}
|
||||||
|
|
||||||
export class Subsonic implements MusicService {
|
flavour = () => "subsonic"
|
||||||
|
|
||||||
|
bearerToken = (_: Credentials) => TE.right<AuthFailure, string | undefined>(undefined)
|
||||||
|
|
||||||
|
artists = (q: ArtistQuery): Promise<Result<ArtistSummary>> =>
|
||||||
|
this.subsonic
|
||||||
|
.getArtists(this.credentials)
|
||||||
|
.then(slice2(q))
|
||||||
|
.then(([page, total]) => ({
|
||||||
|
total,
|
||||||
|
results: page.map((it) => ({
|
||||||
|
id: it.id,
|
||||||
|
name: it.name,
|
||||||
|
image: it.image,
|
||||||
|
})),
|
||||||
|
}))
|
||||||
|
|
||||||
|
artist = async (id: string): Promise<Artist> =>
|
||||||
|
this.subsonic.getArtistWithInfo(this.credentials, id)
|
||||||
|
|
||||||
|
albums = async (q: AlbumQuery): Promise<Result<AlbumSummary>> =>
|
||||||
|
this.subsonic.getAlbumList2(this.credentials, q)
|
||||||
|
|
||||||
|
album = (id: string): Promise<Album> => this.subsonic.getAlbum(this.credentials, id)
|
||||||
|
|
||||||
|
genres = () =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetGenresResponse>(this.credentials, "/rest/getGenres")
|
||||||
|
.then((it) =>
|
||||||
|
pipe(
|
||||||
|
it.genres.genre || [],
|
||||||
|
A.filter((it) => it.albumCount > 0),
|
||||||
|
A.map((it) => it.value),
|
||||||
|
A.sort(ordString),
|
||||||
|
A.map((it) => ({ id: b64Encode(it), name: it }))
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
tracks = (albumId: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetAlbumResponse>(this.credentials, "/rest/getAlbum", {
|
||||||
|
id: albumId,
|
||||||
|
})
|
||||||
|
.then((it) => it.album)
|
||||||
|
.then((album) =>
|
||||||
|
(album.song || []).map((song) => asTrack(asAlbum(album), song, this.customPlayers))
|
||||||
|
)
|
||||||
|
|
||||||
|
track = (trackId: string) => this.subsonic.getTrack(this.credentials, trackId)
|
||||||
|
|
||||||
|
rate = (trackId: string, rating: Rating) =>
|
||||||
|
Promise.resolve(true)
|
||||||
|
.then(() => {
|
||||||
|
if (rating.stars >= 0 && rating.stars <= 5) {
|
||||||
|
return this.subsonic.getTrack(this.credentials, trackId);
|
||||||
|
} else {
|
||||||
|
throw `Invalid rating.stars value of ${rating.stars}`;
|
||||||
|
}
|
||||||
|
})
|
||||||
|
.then((track) => {
|
||||||
|
const thingsToUpdate = [];
|
||||||
|
if (track.rating.love != rating.love) {
|
||||||
|
thingsToUpdate.push(
|
||||||
|
this.subsonic.getJSON(
|
||||||
|
this.credentials,
|
||||||
|
`/rest/${rating.love ? "star" : "unstar"}`,
|
||||||
|
{
|
||||||
|
id: trackId,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
);
|
||||||
|
}
|
||||||
|
if (track.rating.stars != rating.stars) {
|
||||||
|
thingsToUpdate.push(
|
||||||
|
this.subsonic.getJSON(this.credentials, `/rest/setRating`, {
|
||||||
|
id: trackId,
|
||||||
|
rating: rating.stars,
|
||||||
|
})
|
||||||
|
);
|
||||||
|
}
|
||||||
|
return Promise.all(thingsToUpdate);
|
||||||
|
})
|
||||||
|
.then(() => true)
|
||||||
|
.catch(() => false)
|
||||||
|
|
||||||
|
stream = async ({
|
||||||
|
trackId,
|
||||||
|
range,
|
||||||
|
}: {
|
||||||
|
trackId: string;
|
||||||
|
range: string | undefined;
|
||||||
|
}) =>
|
||||||
|
this.subsonic.getTrack(this.credentials, trackId).then((track) =>
|
||||||
|
this.subsonic
|
||||||
|
.get(
|
||||||
|
this.credentials,
|
||||||
|
`/rest/stream`,
|
||||||
|
{
|
||||||
|
id: trackId,
|
||||||
|
c: track.encoding.player,
|
||||||
|
},
|
||||||
|
{
|
||||||
|
headers: pipe(
|
||||||
|
range,
|
||||||
|
O.fromNullable,
|
||||||
|
O.map((range) => ({
|
||||||
|
"User-Agent": USER_AGENT,
|
||||||
|
Range: range,
|
||||||
|
})),
|
||||||
|
O.getOrElse(() => ({
|
||||||
|
"User-Agent": USER_AGENT,
|
||||||
|
}))
|
||||||
|
),
|
||||||
|
responseType: "stream",
|
||||||
|
}
|
||||||
|
)
|
||||||
|
.then((stream) => ({
|
||||||
|
status: stream.status,
|
||||||
|
headers: {
|
||||||
|
"content-type": stream.headers["content-type"],
|
||||||
|
"content-length": stream.headers["content-length"],
|
||||||
|
"content-range": stream.headers["content-range"],
|
||||||
|
"accept-ranges": stream.headers["accept-ranges"],
|
||||||
|
},
|
||||||
|
stream: stream.data,
|
||||||
|
}))
|
||||||
|
)
|
||||||
|
|
||||||
|
coverArt = async (coverArtURN: BUrn, size?: number) =>
|
||||||
|
Promise.resolve(coverArtURN)
|
||||||
|
.then((it) => assertSystem(it, "subsonic"))
|
||||||
|
.then((it) => this.subsonic.getCoverArt(this.credentials, it.resource.split(":")[1]!, size))
|
||||||
|
.then((res) => ({
|
||||||
|
contentType: res.headers["content-type"],
|
||||||
|
data: Buffer.from(res.data, "binary"),
|
||||||
|
}))
|
||||||
|
.catch((e) => {
|
||||||
|
logger.error(
|
||||||
|
`Failed getting coverArt for urn:'${coverArtURN}': ${e}`
|
||||||
|
);
|
||||||
|
return undefined;
|
||||||
|
})
|
||||||
|
|
||||||
|
scrobble = async (id: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON(this.credentials, `/rest/scrobble`, {
|
||||||
|
id,
|
||||||
|
submission: true,
|
||||||
|
})
|
||||||
|
.then((_) => true)
|
||||||
|
.catch(() => false)
|
||||||
|
|
||||||
|
nowPlaying = async (id: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON(this.credentials, `/rest/scrobble`, {
|
||||||
|
id,
|
||||||
|
submission: false,
|
||||||
|
})
|
||||||
|
.then((_) => true)
|
||||||
|
.catch(() => false)
|
||||||
|
|
||||||
|
searchArtists = async (query: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.search3(this.credentials, { query, artistCount: 20 })
|
||||||
|
.then(({ artists }) =>
|
||||||
|
artists.map((artist) => ({
|
||||||
|
id: artist.id,
|
||||||
|
name: artist.name,
|
||||||
|
image: artistImageURN({
|
||||||
|
artistId: artist.id,
|
||||||
|
artistImageURL: artist.artistImageUrl,
|
||||||
|
}),
|
||||||
|
}))
|
||||||
|
)
|
||||||
|
|
||||||
|
searchAlbums = async (query: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.search3(this.credentials, { query, albumCount: 20 })
|
||||||
|
.then(({ albums }) => this.subsonic.toAlbumSummary(albums))
|
||||||
|
|
||||||
|
searchTracks = async (query: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.search3(this.credentials, { query, songCount: 20 })
|
||||||
|
.then(({ songs }) =>
|
||||||
|
Promise.all(
|
||||||
|
songs.map((it) => this.subsonic.getTrack(this.credentials, it.id))
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
playlists = async () =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetPlaylistsResponse>(this.credentials, "/rest/getPlaylists")
|
||||||
|
.then(({ playlists }) => (playlists.playlist || []).map(asPlayListSummary))
|
||||||
|
|
||||||
|
playlist = async (id: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetPlaylistResponse>(this.credentials, "/rest/getPlaylist", {
|
||||||
|
id,
|
||||||
|
})
|
||||||
|
.then(({ playlist }) => {
|
||||||
|
let trackNumber = 1;
|
||||||
|
return {
|
||||||
|
id: playlist.id,
|
||||||
|
name: playlist.name,
|
||||||
|
coverArt: coverArtURN(playlist.coverArt),
|
||||||
|
entries: (playlist.entry || []).map((entry) => ({
|
||||||
|
...asTrack(
|
||||||
|
{
|
||||||
|
id: entry.albumId!,
|
||||||
|
name: entry.album!,
|
||||||
|
year: entry.year,
|
||||||
|
genre: maybeAsGenre(entry.genre),
|
||||||
|
artistName: entry.artist,
|
||||||
|
artistId: entry.artistId,
|
||||||
|
coverArt: coverArtURN(entry.coverArt),
|
||||||
|
},
|
||||||
|
entry,
|
||||||
|
this.customPlayers
|
||||||
|
),
|
||||||
|
number: trackNumber++,
|
||||||
|
})),
|
||||||
|
};
|
||||||
|
})
|
||||||
|
|
||||||
|
createPlaylist = async (name: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetPlaylistResponse>(this.credentials, "/rest/createPlaylist", {
|
||||||
|
name,
|
||||||
|
})
|
||||||
|
.then(({ playlist }) => ({
|
||||||
|
id: playlist.id,
|
||||||
|
name: playlist.name,
|
||||||
|
coverArt: coverArtURN(playlist.coverArt),
|
||||||
|
}))
|
||||||
|
|
||||||
|
deletePlaylist = async (id: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetPlaylistResponse>(this.credentials, "/rest/deletePlaylist", {
|
||||||
|
id,
|
||||||
|
})
|
||||||
|
.then((_) => true)
|
||||||
|
|
||||||
|
addToPlaylist = async (playlistId: string, trackId: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetPlaylistResponse>(this.credentials, "/rest/updatePlaylist", {
|
||||||
|
playlistId,
|
||||||
|
songIdToAdd: trackId,
|
||||||
|
})
|
||||||
|
.then((_) => true)
|
||||||
|
|
||||||
|
removeFromPlaylist = async (playlistId: string, indicies: number[]) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetPlaylistResponse>(this.credentials, "/rest/updatePlaylist", {
|
||||||
|
playlistId,
|
||||||
|
songIndexToRemove: indicies,
|
||||||
|
})
|
||||||
|
.then((_) => true)
|
||||||
|
|
||||||
|
similarSongs = async (id: string) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetSimilarSongsResponse>(
|
||||||
|
this.credentials,
|
||||||
|
"/rest/getSimilarSongs2",
|
||||||
|
{ id, count: 50 }
|
||||||
|
)
|
||||||
|
.then((it) => it.similarSongs2.song || [])
|
||||||
|
.then((songs) =>
|
||||||
|
Promise.all(
|
||||||
|
songs.map((song) =>
|
||||||
|
this.subsonic
|
||||||
|
.getAlbum(this.credentials, song.albumId!)
|
||||||
|
.then((album) => asTrack(album, song, this.customPlayers))
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
topSongs = async (artistId: string) =>
|
||||||
|
this.subsonic.getArtist(this.credentials, artistId).then(({ name }) =>
|
||||||
|
this.subsonic
|
||||||
|
.getJSON<GetTopSongsResponse>(this.credentials, "/rest/getTopSongs", {
|
||||||
|
artist: name,
|
||||||
|
count: 50,
|
||||||
|
})
|
||||||
|
.then((it) => it.topSongs.song || [])
|
||||||
|
.then((songs) =>
|
||||||
|
Promise.all(
|
||||||
|
songs.map((song) =>
|
||||||
|
this.subsonic
|
||||||
|
.getAlbum(this.credentials, song.albumId!)
|
||||||
|
.then((album) => asTrack(album, song, this.customPlayers))
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
)
|
||||||
|
|
||||||
|
radioStations = async () => this.subsonic
|
||||||
|
.getJSON<GetInternetRadioStationsResponse>(
|
||||||
|
this.credentials,
|
||||||
|
"/rest/getInternetRadioStations"
|
||||||
|
)
|
||||||
|
.then((it) => it.internetRadioStations.internetRadioStation || [])
|
||||||
|
.then((stations) => stations.map((it) => ({
|
||||||
|
id: it.id,
|
||||||
|
name: it.name,
|
||||||
|
url: it.streamUrl,
|
||||||
|
homePage: it.homePageUrl
|
||||||
|
})))
|
||||||
|
|
||||||
|
radioStation = async (id: string) => this.radioStations()
|
||||||
|
.then(it =>
|
||||||
|
it.find(station => station.id === id)!
|
||||||
|
)
|
||||||
|
|
||||||
|
years = async () => {
|
||||||
|
const q: AlbumQuery = {
|
||||||
|
_index: 0,
|
||||||
|
_count: 100000, // FIXME: better than this ?
|
||||||
|
type: "alphabeticalByArtist",
|
||||||
|
};
|
||||||
|
const years = this.subsonic.getAlbumList2(this.credentials, q)
|
||||||
|
.then(({ results }) =>
|
||||||
|
results.map((album) => album.year || "?")
|
||||||
|
.filter((item, i, ar) => ar.indexOf(item) === i)
|
||||||
|
.sort()
|
||||||
|
.map((year) => ({
|
||||||
|
...asYear(year)
|
||||||
|
}))
|
||||||
|
.reverse()
|
||||||
|
);
|
||||||
|
return years;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
export class SubsonicMusicService implements MusicService {
|
||||||
|
subsonic: Subsonic;
|
||||||
|
customPlayers: CustomPlayers;
|
||||||
|
|
||||||
|
constructor(
|
||||||
|
subsonic: Subsonic,
|
||||||
|
customPlayers: CustomPlayers = NO_CUSTOM_PLAYERS
|
||||||
|
) {
|
||||||
|
this.subsonic = subsonic;
|
||||||
|
this.customPlayers = customPlayers;
|
||||||
|
}
|
||||||
|
|
||||||
|
generateToken = (credentials: Credentials): TE.TaskEither<AuthFailure, AuthSuccess> => {
|
||||||
|
const x: TE.TaskEither<AuthFailure, PingResponse> = TE.tryCatch(
|
||||||
|
() =>
|
||||||
|
this.subsonic.getJSON<PingResponse>(
|
||||||
|
_.pick(credentials, "username", "password"),
|
||||||
|
"/rest/ping.view"
|
||||||
|
),
|
||||||
|
(e) => new AuthFailure(e as string)
|
||||||
|
)
|
||||||
|
return pipe(
|
||||||
|
x,
|
||||||
|
TE.flatMap(({ type }) =>
|
||||||
|
pipe(
|
||||||
|
TE.tryCatch(
|
||||||
|
() => this.libraryFor({ ...credentials, type }),
|
||||||
|
() => new AuthFailure("Failed to get library")
|
||||||
|
),
|
||||||
|
TE.map((library) => ({ type, library }))
|
||||||
|
)
|
||||||
|
),
|
||||||
|
TE.flatMap(({ library, type }) =>
|
||||||
|
pipe(
|
||||||
|
library.bearerToken(credentials),
|
||||||
|
TE.map((bearer) => ({ bearer, type }))
|
||||||
|
)
|
||||||
|
),
|
||||||
|
TE.map(({ bearer, type }) => ({
|
||||||
|
serviceToken: asToken({ ...credentials, bearer, type }),
|
||||||
|
userId: credentials.username,
|
||||||
|
nickname: credentials.username,
|
||||||
|
}))
|
||||||
|
)
|
||||||
|
}
|
||||||
|
|
||||||
|
refreshToken = (serviceToken: string) =>
|
||||||
|
this.generateToken(parseToken(serviceToken));
|
||||||
|
|
||||||
|
login = async (token: string) => this.libraryFor(parseToken(token));
|
||||||
|
|
||||||
|
private libraryFor = (
|
||||||
|
credentials: Credentials & { type: string }
|
||||||
|
): Promise<SubsonicMusicLibrary> => {
|
||||||
|
const genericSubsonic = new SubsonicMusicLibrary(this.subsonic, credentials, this.customPlayers);
|
||||||
|
// return Promise.resolve(genericSubsonic);
|
||||||
|
|
||||||
|
if (credentials.type == "navidrome") {
|
||||||
|
// todo: there does not seem to be a test for this??
|
||||||
|
const nd: SubsonicMusicLibrary = {
|
||||||
|
...genericSubsonic,
|
||||||
|
flavour: () => "navidrome",
|
||||||
|
bearerToken: (credentials: Credentials) =>
|
||||||
|
pipe(
|
||||||
|
TE.tryCatch(
|
||||||
|
() =>
|
||||||
|
axios.post(
|
||||||
|
this.subsonic.url.append({ pathname: "/auth/login" }).href(),
|
||||||
|
_.pick(credentials, "username", "password")
|
||||||
|
),
|
||||||
|
() => new AuthFailure("Failed to get bearerToken")
|
||||||
|
),
|
||||||
|
TE.map((it) => it.data.token as string | undefined)
|
||||||
|
),
|
||||||
|
}
|
||||||
|
return Promise.resolve(nd);
|
||||||
|
} else {
|
||||||
|
return Promise.resolve(genericSubsonic);
|
||||||
|
}
|
||||||
|
};
|
||||||
|
}
|
||||||
|
|
||||||
|
export class Subsonic {
|
||||||
url: URLBuilder;
|
url: URLBuilder;
|
||||||
customPlayers: CustomPlayers;
|
customPlayers: CustomPlayers;
|
||||||
externalImageFetcher: ImageFetcher;
|
externalImageFetcher: ImageFetcher;
|
||||||
@@ -536,41 +961,6 @@ export class Subsonic implements MusicService {
|
|||||||
else return json as unknown as T;
|
else return json as unknown as T;
|
||||||
});
|
});
|
||||||
|
|
||||||
generateToken = (credentials: Credentials) =>
|
|
||||||
pipe(
|
|
||||||
TE.tryCatch(
|
|
||||||
() =>
|
|
||||||
this.getJSON<PingResponse>(
|
|
||||||
_.pick(credentials, "username", "password"),
|
|
||||||
"/rest/ping.view"
|
|
||||||
),
|
|
||||||
(e) => new AuthFailure(e as string)
|
|
||||||
),
|
|
||||||
TE.chain(({ type }) =>
|
|
||||||
pipe(
|
|
||||||
TE.tryCatch(
|
|
||||||
() => this.libraryFor({ ...credentials, type }),
|
|
||||||
() => new AuthFailure("Failed to get library")
|
|
||||||
),
|
|
||||||
TE.map((library) => ({ type, library }))
|
|
||||||
)
|
|
||||||
),
|
|
||||||
TE.chain(({ library, type }) =>
|
|
||||||
pipe(
|
|
||||||
library.bearerToken(credentials),
|
|
||||||
TE.map((bearer) => ({ bearer, type }))
|
|
||||||
)
|
|
||||||
),
|
|
||||||
TE.map(({ bearer, type }) => ({
|
|
||||||
serviceToken: asToken({ ...credentials, bearer, type }),
|
|
||||||
userId: credentials.username,
|
|
||||||
nickname: credentials.username,
|
|
||||||
}))
|
|
||||||
);
|
|
||||||
|
|
||||||
refreshToken = (serviceToken: string) =>
|
|
||||||
this.generateToken(parseToken(serviceToken));
|
|
||||||
|
|
||||||
getArtists = (
|
getArtists = (
|
||||||
credentials: Credentials
|
credentials: Credentials
|
||||||
): Promise<(IdName & { albumCount: number; image: BUrn | undefined })[]> =>
|
): Promise<(IdName & { albumCount: number; image: BUrn | undefined })[]> =>
|
||||||
@@ -744,346 +1134,4 @@ export class Subsonic implements MusicService {
|
|||||||
// albums: it.album.map(asAlbum),
|
// albums: it.album.map(asAlbum),
|
||||||
// }));
|
// }));
|
||||||
|
|
||||||
login = async (token: string) => this.libraryFor(parseToken(token));
|
|
||||||
|
|
||||||
private libraryFor = (
|
|
||||||
credentials: Credentials & { type: string }
|
|
||||||
): Promise<SubsonicMusicLibrary> => {
|
|
||||||
const subsonic = this;
|
|
||||||
|
|
||||||
const genericSubsonic: SubsonicMusicLibrary = {
|
|
||||||
flavour: () => "subsonic",
|
|
||||||
bearerToken: (_: Credentials) => TE.right(undefined),
|
|
||||||
artists: (q: ArtistQuery): Promise<Result<ArtistSummary>> =>
|
|
||||||
subsonic
|
|
||||||
.getArtists(credentials)
|
|
||||||
.then(slice2(q))
|
|
||||||
.then(([page, total]) => ({
|
|
||||||
total,
|
|
||||||
results: page.map((it) => ({
|
|
||||||
id: it.id,
|
|
||||||
name: it.name,
|
|
||||||
image: it.image,
|
|
||||||
})),
|
|
||||||
})),
|
|
||||||
artist: async (id: string): Promise<Artist> =>
|
|
||||||
subsonic.getArtistWithInfo(credentials, id),
|
|
||||||
albums: async (q: AlbumQuery): Promise<Result<AlbumSummary>> =>
|
|
||||||
subsonic.getAlbumList2(credentials, q),
|
|
||||||
album: (id: string): Promise<Album> => subsonic.getAlbum(credentials, id),
|
|
||||||
genres: () =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetGenresResponse>(credentials, "/rest/getGenres")
|
|
||||||
.then((it) =>
|
|
||||||
pipe(
|
|
||||||
it.genres.genre || [],
|
|
||||||
A.filter((it) => it.albumCount > 0),
|
|
||||||
A.map((it) => it.value),
|
|
||||||
A.sort(ordString),
|
|
||||||
A.map((it) => ({ id: b64Encode(it), name: it }))
|
|
||||||
)
|
|
||||||
),
|
|
||||||
tracks: (albumId: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetAlbumResponse>(credentials, "/rest/getAlbum", {
|
|
||||||
id: albumId,
|
|
||||||
})
|
|
||||||
.then((it) => it.album)
|
|
||||||
.then((album) =>
|
|
||||||
(album.song || []).map((song) => asTrack(asAlbum(album), song, this.customPlayers))
|
|
||||||
),
|
|
||||||
track: (trackId: string) => subsonic.getTrack(credentials, trackId),
|
|
||||||
rate: (trackId: string, rating: Rating) =>
|
|
||||||
Promise.resolve(true)
|
|
||||||
.then(() => {
|
|
||||||
if (rating.stars >= 0 && rating.stars <= 5) {
|
|
||||||
return subsonic.getTrack(credentials, trackId);
|
|
||||||
} else {
|
|
||||||
throw `Invalid rating.stars value of ${rating.stars}`;
|
|
||||||
}
|
|
||||||
})
|
|
||||||
.then((track) => {
|
|
||||||
const thingsToUpdate = [];
|
|
||||||
if (track.rating.love != rating.love) {
|
|
||||||
thingsToUpdate.push(
|
|
||||||
subsonic.getJSON(
|
|
||||||
credentials,
|
|
||||||
`/rest/${rating.love ? "star" : "unstar"}`,
|
|
||||||
{
|
|
||||||
id: trackId,
|
|
||||||
}
|
|
||||||
)
|
|
||||||
);
|
|
||||||
}
|
|
||||||
if (track.rating.stars != rating.stars) {
|
|
||||||
thingsToUpdate.push(
|
|
||||||
subsonic.getJSON(credentials, `/rest/setRating`, {
|
|
||||||
id: trackId,
|
|
||||||
rating: rating.stars,
|
|
||||||
})
|
|
||||||
);
|
|
||||||
}
|
|
||||||
return Promise.all(thingsToUpdate);
|
|
||||||
})
|
|
||||||
.then(() => true)
|
|
||||||
.catch(() => false),
|
|
||||||
stream: async ({
|
|
||||||
trackId,
|
|
||||||
range,
|
|
||||||
}: {
|
|
||||||
trackId: string;
|
|
||||||
range: string | undefined;
|
|
||||||
}) =>
|
|
||||||
subsonic.getTrack(credentials, trackId).then((track) =>
|
|
||||||
subsonic
|
|
||||||
.get(
|
|
||||||
credentials,
|
|
||||||
`/rest/stream`,
|
|
||||||
{
|
|
||||||
id: trackId,
|
|
||||||
c: track.encoding.player,
|
|
||||||
},
|
|
||||||
{
|
|
||||||
headers: pipe(
|
|
||||||
range,
|
|
||||||
O.fromNullable,
|
|
||||||
O.map((range) => ({
|
|
||||||
"User-Agent": USER_AGENT,
|
|
||||||
Range: range,
|
|
||||||
})),
|
|
||||||
O.getOrElse(() => ({
|
|
||||||
"User-Agent": USER_AGENT,
|
|
||||||
}))
|
|
||||||
),
|
|
||||||
responseType: "stream",
|
|
||||||
}
|
|
||||||
)
|
|
||||||
.then((stream) => ({
|
|
||||||
status: stream.status,
|
|
||||||
headers: {
|
|
||||||
"content-type": stream.headers["content-type"],
|
|
||||||
"content-length": stream.headers["content-length"],
|
|
||||||
"content-range": stream.headers["content-range"],
|
|
||||||
"accept-ranges": stream.headers["accept-ranges"],
|
|
||||||
},
|
|
||||||
stream: stream.data,
|
|
||||||
}))
|
|
||||||
),
|
|
||||||
coverArt: async (coverArtURN: BUrn, size?: number) =>
|
|
||||||
Promise.resolve(coverArtURN)
|
|
||||||
.then((it) => assertSystem(it, "subsonic"))
|
|
||||||
.then((it) => it.resource.split(":")[1]!)
|
|
||||||
.then((it) => subsonic.getCoverArt(credentials, it, size))
|
|
||||||
.then((res) => ({
|
|
||||||
contentType: res.headers["content-type"],
|
|
||||||
data: Buffer.from(res.data, "binary"),
|
|
||||||
}))
|
|
||||||
.catch((e) => {
|
|
||||||
logger.error(
|
|
||||||
`Failed getting coverArt for urn:'${coverArtURN}': ${e}`
|
|
||||||
);
|
|
||||||
return undefined;
|
|
||||||
}),
|
|
||||||
scrobble: async (id: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON(credentials, `/rest/scrobble`, {
|
|
||||||
id,
|
|
||||||
submission: true,
|
|
||||||
})
|
|
||||||
.then((_) => true)
|
|
||||||
.catch(() => false),
|
|
||||||
nowPlaying: async (id: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON(credentials, `/rest/scrobble`, {
|
|
||||||
id,
|
|
||||||
submission: false,
|
|
||||||
})
|
|
||||||
.then((_) => true)
|
|
||||||
.catch(() => false),
|
|
||||||
searchArtists: async (query: string) =>
|
|
||||||
subsonic
|
|
||||||
.search3(credentials, { query, artistCount: 20 })
|
|
||||||
.then(({ artists }) =>
|
|
||||||
artists.map((artist) => ({
|
|
||||||
id: artist.id,
|
|
||||||
name: artist.name,
|
|
||||||
image: artistImageURN({
|
|
||||||
artistId: artist.id,
|
|
||||||
artistImageURL: artist.artistImageUrl,
|
|
||||||
}),
|
|
||||||
}))
|
|
||||||
),
|
|
||||||
searchAlbums: async (query: string) =>
|
|
||||||
subsonic
|
|
||||||
.search3(credentials, { query, albumCount: 20 })
|
|
||||||
.then(({ albums }) => subsonic.toAlbumSummary(albums)),
|
|
||||||
searchTracks: async (query: string) =>
|
|
||||||
subsonic
|
|
||||||
.search3(credentials, { query, songCount: 20 })
|
|
||||||
.then(({ songs }) =>
|
|
||||||
Promise.all(
|
|
||||||
songs.map((it) => subsonic.getTrack(credentials, it.id))
|
|
||||||
)
|
|
||||||
),
|
|
||||||
playlists: async () =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetPlaylistsResponse>(credentials, "/rest/getPlaylists")
|
|
||||||
.then((it) => it.playlists.playlist || [])
|
|
||||||
.then((playlists) => playlists.map(asPlayListSummary)),
|
|
||||||
playlist: async (id: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetPlaylistResponse>(credentials, "/rest/getPlaylist", {
|
|
||||||
id,
|
|
||||||
})
|
|
||||||
.then((it) => it.playlist)
|
|
||||||
.then((playlist) => {
|
|
||||||
let trackNumber = 1;
|
|
||||||
return {
|
|
||||||
id: playlist.id,
|
|
||||||
name: playlist.name,
|
|
||||||
coverArt: coverArtURN(playlist.coverArt),
|
|
||||||
entries: (playlist.entry || []).map((entry) => ({
|
|
||||||
...asTrack(
|
|
||||||
{
|
|
||||||
id: entry.albumId!,
|
|
||||||
name: entry.album!,
|
|
||||||
year: entry.year,
|
|
||||||
genre: maybeAsGenre(entry.genre),
|
|
||||||
artistName: entry.artist,
|
|
||||||
artistId: entry.artistId,
|
|
||||||
coverArt: coverArtURN(entry.coverArt),
|
|
||||||
},
|
|
||||||
entry,
|
|
||||||
this.customPlayers
|
|
||||||
),
|
|
||||||
number: trackNumber++,
|
|
||||||
})),
|
|
||||||
};
|
|
||||||
}),
|
|
||||||
createPlaylist: async (name: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetPlaylistResponse>(credentials, "/rest/createPlaylist", {
|
|
||||||
name,
|
|
||||||
})
|
|
||||||
.then((it) => it.playlist)
|
|
||||||
// todo: why is this line so similar to other playlist lines??
|
|
||||||
.then((it) => ({
|
|
||||||
id: it.id,
|
|
||||||
name: it.name,
|
|
||||||
coverArt: coverArtURN(it.coverArt),
|
|
||||||
})),
|
|
||||||
deletePlaylist: async (id: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetPlaylistResponse>(credentials, "/rest/deletePlaylist", {
|
|
||||||
id,
|
|
||||||
})
|
|
||||||
.then((_) => true),
|
|
||||||
addToPlaylist: async (playlistId: string, trackId: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetPlaylistResponse>(credentials, "/rest/updatePlaylist", {
|
|
||||||
playlistId,
|
|
||||||
songIdToAdd: trackId,
|
|
||||||
})
|
|
||||||
.then((_) => true),
|
|
||||||
removeFromPlaylist: async (playlistId: string, indicies: number[]) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetPlaylistResponse>(credentials, "/rest/updatePlaylist", {
|
|
||||||
playlistId,
|
|
||||||
songIndexToRemove: indicies,
|
|
||||||
})
|
|
||||||
.then((_) => true),
|
|
||||||
similarSongs: async (id: string) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetSimilarSongsResponse>(
|
|
||||||
credentials,
|
|
||||||
"/rest/getSimilarSongs2",
|
|
||||||
{ id, count: 50 }
|
|
||||||
)
|
|
||||||
.then((it) => it.similarSongs2.song || [])
|
|
||||||
.then((songs) =>
|
|
||||||
Promise.all(
|
|
||||||
songs.map((song) =>
|
|
||||||
subsonic
|
|
||||||
.getAlbum(credentials, song.albumId!)
|
|
||||||
.then((album) => asTrack(album, song, this.customPlayers))
|
|
||||||
)
|
|
||||||
)
|
|
||||||
),
|
|
||||||
topSongs: async (artistId: string) =>
|
|
||||||
subsonic.getArtist(credentials, artistId).then(({ name }) =>
|
|
||||||
subsonic
|
|
||||||
.getJSON<GetTopSongsResponse>(credentials, "/rest/getTopSongs", {
|
|
||||||
artist: name,
|
|
||||||
count: 50,
|
|
||||||
})
|
|
||||||
.then((it) => it.topSongs.song || [])
|
|
||||||
.then((songs) =>
|
|
||||||
Promise.all(
|
|
||||||
songs.map((song) =>
|
|
||||||
subsonic
|
|
||||||
.getAlbum(credentials, song.albumId!)
|
|
||||||
.then((album) => asTrack(album, song, this.customPlayers))
|
|
||||||
)
|
|
||||||
)
|
|
||||||
)
|
|
||||||
),
|
|
||||||
radioStations: async () => subsonic
|
|
||||||
.getJSON<GetInternetRadioStationsResponse>(
|
|
||||||
credentials,
|
|
||||||
"/rest/getInternetRadioStations"
|
|
||||||
)
|
|
||||||
.then((it) => it.internetRadioStations.internetRadioStation || [])
|
|
||||||
.then((stations) => stations.map((it) => ({
|
|
||||||
id: it.id,
|
|
||||||
name: it.name,
|
|
||||||
url: it.streamUrl,
|
|
||||||
homePage: it.homePageUrl
|
|
||||||
}))),
|
|
||||||
radioStation: async (id: string) => genericSubsonic
|
|
||||||
.radioStations()
|
|
||||||
.then(it =>
|
|
||||||
it.find(station => station.id === id)!
|
|
||||||
),
|
|
||||||
years: async () => {
|
|
||||||
const q: AlbumQuery = {
|
|
||||||
_index: 0,
|
|
||||||
_count: 100000, // FIXME: better than this ?
|
|
||||||
type: "alphabeticalByArtist",
|
|
||||||
};
|
|
||||||
const years = subsonic.getAlbumList2(credentials, q)
|
|
||||||
.then(({ results }) =>
|
|
||||||
results.map((album) => album.year || "?")
|
|
||||||
.filter((item, i, ar) => ar.indexOf(item) === i)
|
|
||||||
.sort()
|
|
||||||
.map((year) => ({
|
|
||||||
...asYear(year)
|
|
||||||
}))
|
|
||||||
.reverse()
|
|
||||||
);
|
|
||||||
return years;
|
|
||||||
}
|
|
||||||
};
|
|
||||||
|
|
||||||
if (credentials.type == "navidrome") {
|
|
||||||
// todo: there does not seem to be a test for this??
|
|
||||||
return Promise.resolve({
|
|
||||||
...genericSubsonic,
|
|
||||||
flavour: () => "navidrome",
|
|
||||||
bearerToken: (credentials: Credentials) =>
|
|
||||||
pipe(
|
|
||||||
TE.tryCatch(
|
|
||||||
() =>
|
|
||||||
axios.post(
|
|
||||||
this.url.append({ pathname: "/auth/login" }).href(),
|
|
||||||
_.pick(credentials, "username", "password")
|
|
||||||
),
|
|
||||||
() => new AuthFailure("Failed to get bearerToken")
|
|
||||||
),
|
|
||||||
TE.map((it) => it.data.token as string | undefined)
|
|
||||||
),
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
return Promise.resolve(genericSubsonic);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
}
|
}
|
||||||
|
|||||||
File diff suppressed because it is too large
Load Diff
Reference in New Issue
Block a user