Lazuli/src/routes/api/users/[userId]/recommendations/+server.ts

import type { RequestHandler } from '@sveltejs/kit'
import { SECRET_INTERNAL_API_KEY } from '$env/static/private'
import { Jellyfin } from '$lib/services'
import { YouTubeMusic } from '$lib/service-managers/youtube-music'

// This is temporary functionally for the sake of developing the app.
// In the future will implement more robust algorithm for offering recommendations
export const GET: RequestHandler = async ({ params, fetch }) => {
    const userId = params.userId!

    const connectionsResponse = await fetch(`/api/users/${userId}/connections`, { headers: { apikey: SECRET_INTERNAL_API_KEY } })
    const userConnections = await connectionsResponse.json()

    const recommendations: MediaItem[] = []

    for (const connection of userConnections.connections) {
        const { type, service, tokens } = connection as Connection<serviceType>

        switch (type) {
            case 'jellyfin':
                const mostPlayedSongsSearchParams = new URLSearchParams({
                    SortBy: 'PlayCount',
                    SortOrder: 'Descending',
                    IncludeItemTypes: 'Audio',
                    Recursive: 'true',
                    limit: '10',
                })

                const mostPlayedSongsURL = new URL(`/Users/${service.userId}/Items?${mostPlayedSongsSearchParams.toString()}`, service.urlOrigin).href
                const requestHeaders = new Headers({ Authorization: `MediaBrowser Token="${tokens.accessToken}"` })

                const mostPlayedResponse = await fetch(mostPlayedSongsURL, { headers: requestHeaders })
                const mostPlayedData = await mostPlayedResponse.json()

                for (const song of mostPlayedData.Items) recommendations.push(Jellyfin.songFactory(song, connection))
                break
            case 'youtube-music':
                const youtubeMusic = new YouTubeMusic(connection)
                await youtubeMusic
                    .getHome()
                    .then(({ listenAgain, quickPicks, newReleases }) => {
                        for (const mediaItem of listenAgain) recommendations.push(mediaItem)
                    })
                    .catch()
                break
        }
    }

    return Response.json({ recommendations })
}