122 lines
3.9 KiB
TypeScript
122 lines
3.9 KiB
TypeScript
import { describe, it, expect } from 'vitest'
|
|
import { SubsonicClient, SubsonicError } from '../src/subsonic.js'
|
|
|
|
function subsonicResponse(body: object, status = 200): Response {
|
|
return new Response(JSON.stringify(body), {
|
|
status,
|
|
headers: { 'content-type': 'application/json' },
|
|
})
|
|
}
|
|
|
|
function albumPage(count: number, offset: number) {
|
|
return {
|
|
'subsonic-response': {
|
|
status: 'ok',
|
|
albumList2: {
|
|
album: Array.from({ length: count }, (_, i) => ({
|
|
id: offset + i + 1,
|
|
name: `Album ${offset + i + 1}`,
|
|
artist: `Artist ${Math.floor((offset + i) / 10)}`,
|
|
})),
|
|
},
|
|
},
|
|
}
|
|
}
|
|
|
|
describe('SubsonicClient', () => {
|
|
it('ping sends auth params and succeeds', async () => {
|
|
const seen: string[] = []
|
|
const c = new SubsonicClient({
|
|
url: 'http://navidrome.local',
|
|
username: 'sam',
|
|
password: 'pass',
|
|
fetchImpl: (async (input: any) => {
|
|
seen.push(String(input))
|
|
return subsonicResponse({ 'subsonic-response': { status: 'ok' } })
|
|
}) as typeof fetch,
|
|
})
|
|
await c.ping()
|
|
expect(seen[0]!).toContain('/rest/ping')
|
|
expect(seen[0]!).toContain('u=sam')
|
|
expect(seen[0]!).toContain('v=1.16.1')
|
|
expect(seen[0]!).toContain('c=record-shop')
|
|
expect(seen[0]!).toContain('f=json')
|
|
expect(seen[0]!).toMatch(/t=[0-9a-f]{32}/)
|
|
})
|
|
|
|
it('ping raises auth error on failed status with code 40', async () => {
|
|
const c = new SubsonicClient({
|
|
url: 'http://x',
|
|
username: 'sam',
|
|
password: 'bad',
|
|
fetchImpl: (async () =>
|
|
subsonicResponse({
|
|
'subsonic-response': {
|
|
status: 'failed',
|
|
error: { code: 40, message: 'Wrong username or password.' },
|
|
},
|
|
})) as typeof fetch,
|
|
})
|
|
const err = await c.ping().catch((e) => e)
|
|
expect(err).toBeInstanceOf(SubsonicError)
|
|
expect((err as SubsonicError).code).toBe('auth')
|
|
})
|
|
|
|
it('getAllAlbums paginates until a short page', async () => {
|
|
const seen: string[] = []
|
|
const c = new SubsonicClient({
|
|
url: 'http://navidrome.local',
|
|
username: 'sam',
|
|
password: 'pass',
|
|
fetchImpl: (async (input: any) => {
|
|
const url = new URL(String(input))
|
|
seen.push(url.searchParams.get('offset') ?? '')
|
|
const offset = Number(url.searchParams.get('offset') ?? 0)
|
|
// first page: 500 albums, second: 3, third never requested
|
|
return subsonicResponse(offset === 0 ? albumPage(500, 0) : albumPage(3, 500))
|
|
}) as typeof fetch,
|
|
})
|
|
const albums = await c.getAllAlbums()
|
|
expect(seen).toEqual(['0', '500'])
|
|
expect(albums).toHaveLength(503)
|
|
expect(albums[0]!).toEqual({ id: '1', title: 'Album 1', artist: 'Artist 0' })
|
|
})
|
|
|
|
it('getAllAlbums reports progress', async () => {
|
|
const c = new SubsonicClient({
|
|
url: 'http://x',
|
|
username: 'sam',
|
|
password: 'pass',
|
|
fetchImpl: (async (input: any) => {
|
|
const offset = Number(new URL(String(input)).searchParams.get('offset') ?? 0)
|
|
return subsonicResponse(offset === 0 ? albumPage(500, 0) : albumPage(3, 500))
|
|
}) as typeof fetch,
|
|
})
|
|
const progress: number[] = []
|
|
await c.getAllAlbums((_albums, done) => progress.push(done))
|
|
expect(progress[progress.length - 1]!).toBe(503)
|
|
})
|
|
|
|
it('getAllAlbums skips null album entries', async () => {
|
|
const c = new SubsonicClient({
|
|
url: 'http://x',
|
|
username: 'sam',
|
|
password: 'pass',
|
|
fetchImpl: (async () =>
|
|
subsonicResponse({
|
|
'subsonic-response': {
|
|
status: 'ok',
|
|
albumList2: {
|
|
album: [{ id: 1, name: 'Album 1', artist: 'Artist 0' }, null, { id: 2, name: 'Album 2', artist: 'Artist 0' }],
|
|
},
|
|
},
|
|
})) as typeof fetch,
|
|
})
|
|
const albums = await c.getAllAlbums()
|
|
expect(albums).toEqual([
|
|
{ id: '1', title: 'Album 1', artist: 'Artist 0' },
|
|
{ id: '2', title: 'Album 2', artist: 'Artist 0' },
|
|
])
|
|
})
|
|
})
|