Spotify Playlist Search

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_208":209,"_210":211},"routes/_app.x.$handle.$name",{"_109":35,"_39":52,"_117":100,"_34":118,"_13":14,"_119":-5,"_11":120,"_121":122,"_123":124,"_125":126,"_127":128,"_27":-5,"_129":-5,"_130":-5,"_131":33,"_132":133,"_134":33,"_135":-5,"_136":-5,"_137":138},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_55":56,"_39":52,"_43":57,"_58":-5,"_59":33,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":68,"_69":31,"_70":-5,"_71":-5,"_72":73,"_74":75,"_76":77,"_78":79,"_80":81,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":93,"_94":95,"_96":97,"_98":33},"version",4,"changes",[25,26],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","a53d6a7d-c408-458f-a9a0-e74a7fcd45d2","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_27":48,"_29":-7,"_30":33,"_32":33,"_34":49,"_36":50},{"_27":28,"_29":-7,"_30":31,"_32":33,"_34":35,"_36":35},"file",{"_37":38,"_39":35,"_40":41,"_42":-5,"_43":44,"_45":14,"_46":47,"_30":33},"previous","deleted",true,"deletedHere",false,"path","tod","latestPath","fileId","af012c74-26d3-4e73-a64e-fa1c39531cba","name","fileType","directory","content","createdAt",["D",1784245499082],"branchVersion","branchId","8f73afca-9b8b-4154-8dea-7e96834ce4f8",{"_37":51,"_39":52,"_40":27,"_42":53,"_43":54,"_45":14,"_46":47,"_30":33},"tod/spotify-playlist-search","index.html","5b28a984-8170-11f1-96c7-1607ee4eb77e","spotify-playlist-search","\n\n\n \n \n Spotify Playlist Search\n \n\n\n

\n \n\n\n",["D",1784245499082],"id","62af4618-56c9-46d3-91f0-9f34eee0a526",["D",1784245417983],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Full-text search across all your Spotify playlists","imageUrl","666a7e32-624c-44a1-9017-c098238b910d","pinnedFileId","6a42df98-8170-11f1-8580-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","3bbc0830-e929-4c19-b058-a1674c911b22","tursoName","62af461856c946d391f09f34eee0a526","tursoHostname","62af461856c946d391f09f34eee0a526-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789489305251],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_109":35,"_116":112},"org",{"_109":35,"_110":-5,"_111":112,"_19":66,"_113":114,"_115":33},"branch",{"_13":99,"_39":100,"_55":47,"_101":56,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":52,"_108":35},"isOwned",22,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","handle","displayName","avatar","https://secure.gravatar.com/avatar/8effe5d6ffbba460f8a5617306c9ba5b&d=identicon","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_55":56,"_39":52,"_43":203,"_58":-5,"_59":33,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":68,"_69":31,"_70":-5,"_71":-5,"_72":73,"_74":75,"_76":77,"_78":79,"_80":204,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":205,"_94":206,"_96":207,"_98":33},"tree",[181,183,184,185],"files",[181,182,183,184,185],"counts",{"_171":73,"_172":157,"_173":73,"_174":175,"_176":177},"contents",[139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_55":168,"_39":35,"_37":38,"_146":-5,"_46":47,"_45":14,"_148":33,"_43":169,"_13":73,"_40":41,"_42":-5,"_30":33,"_152":-5,"_34":170},{"_55":161,"_39":162,"_37":163,"_146":-5,"_46":47,"_45":164,"_148":31,"_43":165,"_13":73,"_40":150,"_42":166,"_30":33,"_152":-5,"_34":167},{"_55":154,"_39":155,"_37":156,"_146":-5,"_46":47,"_45":157,"_148":33,"_43":158,"_13":73,"_40":150,"_42":159,"_30":33,"_152":-5,"_34":160},{"_55":143,"_39":144,"_37":145,"_146":-5,"_46":47,"_45":147,"_148":33,"_43":149,"_13":73,"_40":150,"_42":151,"_30":33,"_152":-5,"_34":153},"f0271347-df28-4d12-ae0e-a017194cb0d6","sync.ts","3ff57e62-8170-11f1-88a5-1607ee4eb77e","parentId",3,"latest",["D",1784245453448],"script","import { fetchAllPlaylists, fetchPlaylistTracks } from \"./spotify.ts\";\nimport { initDB, reindexTracks } from \"./db.ts\";\n\nexport interface SyncProgress {\n playlistsTotal: number;\n playlistsDone: number;\n tracksTotal: number;\n tracksDone: number;\n currentPlaylist: string;\n done: boolean;\n error?: string;\n}\n\n/**\n * Sync all playlists and tracks from Spotify into the FTS index.\n * Returns a summary of what was synced.\n */\nexport async function syncAll(): Promise<{\n playlists: number;\n tracks: number;\n}> {\n await initDB();\n\n // 1. Fetch all playlists\n const playlists = await fetchAllPlaylists();\n\n // 2. Fetch tracks for each playlist, collecting into one array\n const allTracks = [];\n for (const playlist of playlists) {\n const tracks = await fetchPlaylistTracks(playlist);\n allTracks.push(...tracks);\n }\n\n // 3. Re-index everything\n await reindexTracks(allTracks);\n\n return { playlists: playlists.length, tracks: allTracks.length };\n}\n","label",[144],"dc71db32-3c05-4809-9321-8d9487c1cf1c","spotify.ts","3443b7d2-8170-11f1-b0aa-1607ee4eb77e",1,["D",1784245433829],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nconst SPOTIFY_AUTH = \"https://accounts.spotify.com/authorize\";\nconst SPOTIFY_TOKEN = \"https://accounts.spotify.com/api/token\";\nconst SPOTIFY_API = \"https://api.spotify.com/v1\";\n\nconst SCOPES = \"playlist-read-private playlist-read-collaborative\";\nconst TOKEN_KEY = \"spotify_tokens\";\n\ninterface TokenData {\n access_token: string;\n refresh_token: string;\n expires_at: number; // unix ms\n}\n\n/** Build the Spotify OAuth authorize URL */\nexport function getAuthorizeURL(redirectUri: string, state: string): string {\n const params = new URLSearchParams({\n client_id: Deno.env.get(\"SPOTIFY_CLIENT_ID\")!,\n response_type: \"code\",\n redirect_uri: redirectUri,\n scope: SCOPES,\n state,\n });\n return `${SPOTIFY_AUTH}?${params}`;\n}\n\n/** Exchange authorization code for access + refresh tokens */\nexport async function exchangeCode(code: string, redirectUri: string): Promise {\n const res = await fetch(SPOTIFY_TOKEN, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"authorization_code\",\n code,\n redirect_uri: redirectUri,\n client_id: Deno.env.get(\"SPOTIFY_CLIENT_ID\")!,\n client_secret: Deno.env.get(\"SPOTIFY_CLIENT_SECRET\")!,\n }),\n });\n if (!res.ok) {\n const body = await res.text();\n throw new Error(`Spotify token exchange failed: ${res.status} ${body}`);\n }\n const data = await res.json();\n const tokens: TokenData = {\n access_token: data.access_token,\n refresh_token: data.refresh_token,\n expires_at: Date.now() + data.expires_in * 1000,\n };\n await blob.setJSON(TOKEN_KEY, tokens);\n return tokens;\n}\n\n/** Refresh an expired access token using the refresh token */\nasync function refreshToken(refreshToken: string): Promise {\n const res = await fetch(SPOTIFY_TOKEN, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"refresh_token\",\n refresh_token: refreshToken,\n client_id: Deno.env.get(\"SPOTIFY_CLIENT_ID\")!,\n client_secret: Deno.env.get(\"SPOTIFY_CLIENT_SECRET\")!,\n }),\n });\n if (!res.ok) {\n const body = await res.text();\n throw new Error(`Spotify token refresh failed: ${res.status} ${body}`);\n }\n const data = await res.json();\n const tokens: TokenData = {\n access_token: data.access_token,\n refresh_token: data.refresh_token ?? refreshToken, // Spotify may issue a new one\n expires_at: Date.now() + data.expires_in * 1000,\n };\n await blob.setJSON(TOKEN_KEY, tokens);\n return tokens;\n}\n\n/** Get a valid access token, refreshing if necessary */\nexport async function getAccessToken(): Promise {\n const tokens = await blob.getJSON(TOKEN_KEY);\n if (!tokens) throw new Error(\"Not authenticated with Spotify\");\n // Refresh if token expires in the next 5 minutes\n if (Date.now() > tokens.expires_at - 5 * 60 * 1000) {\n const refreshed = await refreshToken(tokens.refresh_token);\n return refreshed.access_token;\n }\n return tokens.access_token;\n}\n\n/** Check if user has stored Spotify tokens */\nexport async function isAuthenticated(): Promise {\n const tokens = await blob.getJSON(TOKEN_KEY);\n return !!tokens;\n}\n\nexport interface Playlist {\n id: string;\n name: string;\n description: string;\n uri: string;\n image: string | null;\n tracksHref: string;\n trackCount: number;\n}\n\nexport interface Track {\n name: string;\n artist: string;\n album: string;\n uri: string;\n playlistName: string;\n playlistUri: string;\n playlistImage: string | null;\n addedAt: string;\n}\n\n/** Fetch all playlists for the authenticated user (paginated) */\nexport async function fetchAllPlaylists(): Promise {\n const accessToken = await getAccessToken();\n const playlists: Playlist[] = [];\n let url: string | null =\n `${SPOTIFY_API}/me/playlists?limit=50&offset=0`;\n\n while (url) {\n const res = await fetch(url, {\n headers: { Authorization: `Bearer ${accessToken}` },\n });\n if (!res.ok) {\n const body = await res.text();\n throw new Error(`Spotify playlists fetch failed: ${res.status} ${body}`);\n }\n const data = await res.json();\n for (const p of data.items) {\n playlists.push({\n id: p.id,\n name: p.name,\n description: p.description ?? \"\",\n uri: p.uri,\n image: p.images?.[0]?.url ?? null,\n tracksHref: p.tracks.href,\n trackCount: p.tracks.total,\n });\n }\n url = data.next;\n }\n return playlists;\n}\n\n/** Fetch all tracks for a single playlist (paginated) */\nexport async function fetchPlaylistTracks(\n playlist: Playlist,\n onProgress?: (fetched: number, total: number) => void,\n): Promise {\n const accessToken = await getAccessToken();\n const tracks: Track[] = [];\n let url: string | null =\n `${SPOTIFY_API}/playlists/${playlist.id}/tracks?limit=100&offset=0&fields=items(added_at,track(name,uri,artists(name),album(name))),next,total`;\n\n while (url) {\n const res = await fetch(url, {\n headers: { Authorization: `Bearer ${accessToken}` },\n });\n if (!res.ok) {\n const body = await res.text();\n throw new Error(`Spotify tracks fetch failed: ${res.status} ${body}`);\n }\n const data = await res.json();\n for (const item of data.items) {\n // Skip null tracks (e.g., local files that Spotify can't resolve)\n if (!item?.track?.name) continue;\n tracks.push({\n name: item.track.name,\n artist: item.track.artists.map((a: { name: string }) => a.name).join(\", \"),\n album: item.track.album?.name ?? \"\",\n uri: item.track.uri,\n playlistName: playlist.name,\n playlistUri: playlist.uri,\n playlistImage: playlist.image,\n addedAt: item.added_at ?? \"\",\n });\n }\n onProgress?.(tracks.length, data.total ?? playlist.trackCount);\n url = data.next;\n }\n return tracks;\n}\n",[155],"45aa685c-b05d-4f90-b386-28b752569aaf","db.ts","3c917014-8170-11f1-8990-1607ee4eb77e",2,["D",1784245447761],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { Track } from \"./spotify.ts\";\n\n/** Create the FTS5 table if it doesn't exist */\nexport async function initDB() {\n await sqlite.execute(`\n CREATE VIRTUAL TABLE IF NOT EXISTS tracks_fts USING fts5(\n track_name,\n artist_name,\n album_name,\n playlist_name,\n track_uri UNINDEXED,\n playlist_uri UNINDEXED,\n playlist_image UNINDEXED,\n added_at UNINDEXED\n )\n `);\n}\n\n/** Wipe and re-index all tracks */\nexport async function reindexTracks(tracks: Track[]) {\n await sqlite.execute(`DELETE FROM tracks_fts`);\n\n // Insert in batches of 100 for efficiency\n const BATCH_SIZE = 100;\n for (let i = 0; i < tracks.length; i += BATCH_SIZE) {\n const batch = tracks.slice(i, i + BATCH_SIZE);\n const statements = batch.map((t) => ({\n sql: `INSERT INTO tracks_fts\n (track_name, artist_name, album_name, playlist_name, track_uri, playlist_uri, playlist_image, added_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n t.name,\n t.artist,\n t.album,\n t.playlistName,\n t.uri,\n t.playlistUri,\n t.playlistImage,\n t.addedAt,\n ],\n }));\n await sqlite.batch(statements);\n }\n}\n\nexport interface SearchResult {\n track_name: string;\n artist_name: string;\n album_name: string;\n playlist_name: string;\n track_uri: string;\n playlist_uri: string;\n playlist_image: string | null;\n added_at: string;\n rank: number;\n}\n\n/** Full-text search across all indexed tracks */\nexport async function searchTracks(query: string, limit = 50): Promise {\n // Escape double quotes in the query to prevent FTS5 syntax errors\n const escaped = query.replace(/\"/g, '\"\"');\n const ftsQuery = `\"${escaped}\" *`; // prefix match on last term\n\n const result = await sqlite.execute({\n sql: `SELECT track_name, artist_name, album_name, playlist_name,\n track_uri, playlist_uri, playlist_image, added_at,\n bm25(tracks_fts) as rank\n FROM tracks_fts\n WHERE tracks_fts MATCH ?\n ORDER BY rank\n LIMIT ?`,\n args: [ftsQuery, limit],\n });\n\n return result.rows as unknown as SearchResult[];\n}\n\n/** Count total indexed tracks */\nexport async function getTrackCount(): Promise {\n const result = await sqlite.execute(`SELECT count(*) as count FROM tracks_fts`);\n const row = result.rows[0] as { count: number };\n return row.count;\n}\n",[162],"cb4dcc8f-8a03-4968-b1e7-102c8fa13702",["D",1784245499082],[35],"pulls","branches","forks","envVars",{"_178":164,"_180":73},"connections",{"_178":73,"_179":73},"count","unfilledCount","emptyCount",{"_55":168,"_39":35,"_37":38,"_146":-5,"_46":47,"_45":14,"_148":33,"_43":200,"_13":73,"_40":41,"_42":-5,"_30":33,"_152":-5,"_187":201,"_34":202},{"_55":196,"_39":52,"_37":51,"_146":38,"_46":47,"_45":14,"_148":33,"_43":197,"_13":73,"_40":27,"_42":53,"_30":33,"_152":-5,"_187":198,"_34":199},{"_55":161,"_39":162,"_37":163,"_146":-5,"_46":47,"_45":164,"_148":31,"_43":193,"_13":73,"_40":150,"_42":166,"_30":33,"_152":-5,"_187":194,"_34":195},{"_55":154,"_39":155,"_37":156,"_146":-5,"_46":47,"_45":157,"_148":33,"_43":190,"_13":73,"_40":150,"_42":159,"_30":33,"_152":-5,"_187":191,"_34":192},{"_55":143,"_39":144,"_37":145,"_146":-5,"_46":47,"_45":147,"_148":33,"_43":186,"_13":73,"_40":150,"_42":151,"_30":33,"_152":-5,"_187":188,"_34":189},["D",1784245453448],"children",[],[144],["D",1784245433829],[],[155],["D",1784245447761],[],[162],"cfcb4eec-2982-4654-98fd-ac6af77e1467",["D",1784245499082],[],[35,52],["D",1784245499082],[182],[35],["D",1784245417983],["D",1789489305251],{"_109":35,"_116":112},{"_109":35,"_110":-5,"_111":112,"_19":66,"_113":114,"_115":33},{"_13":99,"_39":100,"_55":47,"_101":56,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":52,"_108":35},"ctx",{"_92":-5,"_136":241,"_242":243,"_244":245,"_246":33,"_247":33,"_248":33,"_249":31,"_250":-5,"_251":-7,"_252":-7,"_253":73,"_254":33,"_255":33,"_256":-5,"_257":33,"_258":33,"_259":33,"_260":-5},"ENV",{"_212":213,"_214":215,"_216":100,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v4