import { spotifyClient } from "./spotify-connector.tsx"; export async function handler() { const users = (await Zipper.storage.get[]>("users")) || []; console.log(`got ${users.length} user(s)`); /** Refresh the access tokens for each user. */ const refreshedUsers = await Promise.all( users.map(async (user) => { /** * Check if the access token has expired. * @type {boolean} */ if (new Date().getTime() > user.auth.expires_in) { const refreshedTokens = await spotifyClient.refreshToken( user.auth.refresh_token ); const { access_token } = refreshedTokens; const updatedUser = { ...user, auth: { ...user.auth, access_token } }; /** * Updating user authentication in database * @type {void} */ await Zipper.storage.set( "users", users.map((_user) => _user.data.id === user.data.id ? updatedUser : _user ) ); /** * Return the user with updated access token. * @type {Record} */ return updatedUser; } /** If the access token is not expired, return the user without any updates. */ return { ...user }; }) ); const listeningUsers = (await Promise.all( refreshedUsers.map(async (user: any) => { try { const songMetadata = await spotifyClient.getSongListeningTo( user.auth.access_token ); /** Check if the user is currently listening to a song. */ if (!!songMetadata.item) { return { ...user, song: { name: songMetadata.item.name, artist: songMetadata.item.artists[0].name, albumCover: songMetadata.item.album.images[1].url, }, }; } } catch (err) { console.log(err); } /** * If the user is not listening to a song, return the user without any song information. * @type {Record} */ return { ...user, song: {} }; }) )) as Record[]; return (

{listeningUsers.map((user) => ({ user: ( {user.data.name} ), ["Listening to"]: Object.keys(user.song).length >= 2 ? ( {user.song.name}

by {user.song.artist}

) : ( "In focus 🧘‍♀️" ), }))}

); } export const config: Zipper.HandlerConfig = { description: { title: "Teammate song monitor", subtitle: "A Spotify wrapper that gets what a teammate is listening", }, run: true, };

Help & Docs