Add paging support for spotify service

.changeset/chilled-ducks-give.md

@@ -0,0 +1,5 @@
+---
+'playlist-synchronizer': patch
+---
+
+Add paging support for spotify service

src/services/music-providers/spotify.service.ts

@@ -6,7 +6,7 @@ import { ConfigService } from '../config.service.js';
 import { LogService } from '../log.service.js';
 import { AuthStore, Playlist, Track } from '../../entities.js';
 import { IConfig } from '../../config.js';
-import { retry } from '../../utils.js';
+import { parseUrlToQueryParams, retry } from '../../utils.js';
 
 const scopes = [
     'playlist-read-private',
@@ -73,14 +73,29 @@ export class SpotifyService implements BaseMusicService {
     }
 
     async getPlaylistTracks({ id }: Playlist): Promise<Track[]> {
-        const { body } = await retry<
-            Response<SpotifyApi.PlaylistTrackResponse>
-        >(
-            () => this.client.getPlaylistTracks(id),
-            () => this.refreshAccess(),
-        );
-
-        return body.items.map<Track>(({ track }) => ({
+        const items: SpotifyApi.PlaylistTrackObject[] = [];
+        let nextPage: string | null = null;
+
+        do {
+            const { limit, offset } = nextPage
+                ? parseUrlToQueryParams(nextPage)
+                : { limit: 100, offset: 0 };
+
+            const resp: Response<SpotifyApi.PlaylistTrackResponse> =
+                await retry<Response<SpotifyApi.PlaylistTrackResponse>>(
+                    () =>
+                        this.client.getPlaylistTracks(id, {
+                            limit: Number(limit),
+                            offset: Number(offset),
+                        }),
+                    () => this.refreshAccess(),
+                );
+
+            items.push(...resp.body.items);
+            nextPage = resp.body.next;
+        } while (nextPage);
+
+        return items.map<Track>(({ track }) => ({
             id: track?.uri,
             name: track?.name as string,
             artists: track?.artists.map(({ name }) => name) as string[],

src/utils.ts

@@ -1,2 +1,3 @@
 export * from './utils/cleanup.js';
 export * from './utils/retry.js';
+export * from './utils/url.js';

src/utils/url.ts

@@ -0,0 +1,5 @@
+import { URL } from 'node:url';
+
+export function parseUrlToQueryParams(url: string): Record<string, string> {
+    return Object.fromEntries(new URL(url).searchParams);
+}