[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_176":177,"_178":179},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_133":-5,"_20":134,"_22":135,"_136":137,"_138":139,"_25":140,"_24":-5,"_141":-5,"_142":-5,"_143":54,"_144":145,"_146":45,"_147":-5,"_148":-5,"_149":150},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","adom","name","MusiCatch","branchName","main","version","path","","project",{"_34":75,"_13":14,"_46":76,"_77":-5,"_78":54,"_79":80,"_81":80,"_82":19,"_83":-5,"_84":85,"_86":-5,"_87":54,"_88":-5,"_89":-5,"_90":91,"_92":93,"_94":95,"_96":97,"_98":99,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":111,"_112":113,"_114":115,"_116":54},"tree",[66,67],"file","contents",[32,33],"upstream","pull","ahead","behind","envVars",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_18":65},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":56},"id","1bde87a0-ce1f-4756-8b6b-5ce35130a79b","main.ts","fileId","54ced9e2-6720-11f1-b1f5-1607ee4eb77e","parentId","branchId","9afff4f6-c5cb-4f07-85a2-da5bf7859d0d","branchVersion",48,"latest",true,"createdAt",["D",1787572798727],22,"fileType","http","content","// ──────────────────────────────────────────────────────────────\n// BACKEND — da incollare nel val HTTP \"MusiCatch\" (sostituisce il precedente)\n// • Ricerca artisti (?search=) e uscite personali (?artists=id1,id2,...)\n// • Lista \"in evidenza\" letta da SQLite condiviso (std/sqlite/global.ts),\n// popolato a rotazione dal val Cron separato — vedi cron-val-1.js.\n// ?refresh=1 forza un ricalcolo live e riscrive il DB subito.\n// • Gestione lista artisti curati ORA in tabella SQLite condivisa\n// (musicatch_artists), non più hardcoded — niente da tenere in sync\n// tra questo file e cron-val-1.js. Si gestisce dall'app, tab\n// Impostazioni (endpoint ?curatedList=1 / ?curatedAdd= / ?curatedRemove=).\n// La lista SEED_ARTISTS qui sotto serve SOLO a popolare la tabella la\n// prima volta che gira questo codice (se la tabella è già piena viene\n// ignorata) — dopo il primo avvio modifica la lista dall'app, non qui.\n// ──────────────────────────────────────────────────────────────\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n\nconst IDS_KEY = \"musicatch_artistids_v3\";\nconst PERSONAL_TTL_MS = 60 * 60 * 1000;\nconst WINDOW_MS = 200 * 24 * 60 * 60 * 1000;\n\nconst SEED_ARTISTS = [\n // ── Trap / Drill / nuova scuola ──\n \"Sfera Ebbasta\",\n \"Lazza\",\n \"Geolier\",\n \"Tedua\",\n \"Capo Plaza\",\n \"Shiva\",\n \"Baby Gang\",\n \"Simba La Rue\",\n \"Rondodasosa\",\n \"Neima Ezza\",\n \"Sacky\",\n \"Vale Pain\",\n \"Pak\",\n \"Paky\",\n \"Massimo Pericolo\",\n \"Anna\",\n \"Tony Effe\",\n \"Rose Villain\",\n \"Artie 5ive\",\n \"Tony Boy\",\n \"Kid Yugi\",\n \"Nerissima Serpe\",\n \"Digital Astro\",\n \"Astro\",\n \"Papa V\",\n \"Sarah Toscano\",\n \"Mida\",\n \"Holden\",\n \"Petit\",\n \"Lil Jolie\",\n \"Mew\",\n \"Ayle\",\n \"bnkr44\",\n \"Wayne Santana\",\n \"Dark Pyrex\",\n \"Side Baby\",\n \"Vegas Jones\",\n \"Lowlow\",\n \"Mostro\",\n \"DrefGold\",\n \"Nitro\",\n \"Dani Faiv\",\n \"tha Supreme\",\n \"Mara Sattei\",\n \"Speranza\",\n \"Taxi B\",\n \"Drast\",\n \"Beba\",\n \"Chadia Rodriguez\",\n \"FSK Satellite\",\n \"Boro\",\n \"Rhove\",\n \"Kilimangiaro\",\n \"Sethu\",\n \"Disme\",\n \"Noli\",\n \"Vaz Tè\",\n \"Izi\",\n \"Bresh\",\n \"FreshMula\",\n \"Niky Savage\",\n \"Tredici Pietro\",\n \"Sayf\",\n \"Nayt\",\n \"Drane\",\n \"Asco\",\n // ── Rap affermato ──\n \"Marracash\",\n \"Fabri Fibra\",\n \"Club Dogo\",\n \"Guè\",\n \"Jake La Furia\",\n \"Don Joe\",\n \"Salmo\",\n \"Noyz Narcos\",\n \"Ensi\",\n \"Clementino\",\n \"Luchè\",\n \"Gemitaiz\",\n \"MadMan\",\n \"Emis Killa\",\n \"Mecna\",\n \"Coez\",\n \"Franco126\",\n \"Carl Brave\",\n \"Ketama126\",\n \"Rancore\",\n \"Murubutu\",\n \"Claver Gold\",\n \"Egreen\",\n \"Mezzosangue\",\n \"Jack The Smoker\",\n \"Mondo Marcio\",\n \"Bassi Maestro\",\n \"Inoki\",\n \"Colle der Fomento\",\n \"Kaos One\",\n \"Mistaman\",\n \"Frankie hi-nrg mc\",\n \"Neffa\",\n \"Cor Veleno\",\n \"Priestess\",\n \"Quentin 40\",\n \"Rocco Hunt\",\n \"Baby K\",\n \"Fred De Palma\",\n \"Willie Peyote\",\n \"Ernia\",\n \"Rkomi\",\n \"Madame\",\n \"BigMama\",\n \"Silent Bob\",\n // ── Producer ──\n \"Charlie Charles\",\n \"Sick Luke\",\n \"Night Skinny\",\n \"Mace\",\n \"Shablo\",\n \"Chris Nolan\",\n \"Zef\",\n \"Finesse\",\n \"Takagi & Ketra\",\n \"Merk & Kremont\",\n \"Crookers\",\n // ── Pop ──\n \"Marco Mengoni\",\n \"Mahmood\",\n \"Blanco\",\n \"Elodie\",\n \"Annalisa\",\n \"Angelina Mango\",\n \"Tananai\",\n \"Irama\",\n \"Achille Lauro\",\n \"Ghali\",\n \"Olly\",\n \"Alfa\",\n \"Sangiovanni\",\n \"Aka 7even\",\n \"LDA\",\n \"The Kolors\",\n \"Emma Marrone\",\n \"Alessandra Amoroso\",\n \"Giusy Ferreri\",\n \"Noemi\",\n \"Francesca Michielin\",\n \"Michele Bravi\",\n \"Gaia\",\n \"Francesco Gabbani\",\n \"Diodato\",\n \"Ermal Meta\",\n \"Arisa\",\n \"Malika Ayane\",\n \"Mr.Rain\",\n \"Fedez\",\n \"Tommaso Paradiso\",\n \"Dargen D'Amico\",\n \"Lucio Corsi\",\n \"Clara\",\n \"Rosa Chemical\",\n \"Wax\",\n \"Aaron\",\n \"Matteo Paolillo\",\n \"Settembre\",\n \"Joan Thiele\",\n \"Serena Brancale\",\n \"Ditonellapiaga\",\n \"Elettra Lamborghini\",\n \"Shari\",\n \"Will\",\n \"Riki\",\n \"Lele\",\n \"Deddy\",\n \"Tancredi\",\n \"Enula\",\n \"Giordana Angi\",\n \"Alberto Urso\",\n \"Deborah Iurato\",\n \"Moreno\",\n \"Marco Carta\",\n \"Valerio Scanu\",\n \"Chiara Galiazzo\",\n \"Lorenzo Fragola\",\n \"Anastasio\",\n \"Leo Gassmann\",\n \"Yuman\",\n \"Nicolò Filippucci\",\n \"Boomdabash\",\n \"gIANMARIA\",\n \"Il Tre\",\n // ── Sanremo / storici big ──\n \"Sal Da Vinci\",\n \"Marcella Bella\",\n \"Massimo Ranieri\",\n \"Patty Pravo\",\n \"Raf\",\n \"Marco Masini\",\n \"Francesco Renga\",\n \"Enrico Nigiotti\",\n \"Modà\",\n \"Negramaro\",\n \"Tiromancino\",\n // ── Indie / cantautorato nuovo ──\n \"Calcutta\",\n \"Brunori Sas\",\n \"Gazzelle\",\n \"Ariete\",\n \"Fulminacci\",\n \"Colapesce\",\n \"Dimartino\",\n \"giorgio poi\",\n \"Cosmo\",\n \"I Cani\",\n \"Motta\",\n \"Galeffi\",\n \"Pinguini Tattici Nucleari\",\n \"Lo Stato Sociale\",\n \"Ex-Otago\",\n \"Canova\",\n \"Eugenio in Via Di Gioia\",\n \"Tropico\",\n \"Santi Francesi\",\n \"Whitemary\",\n \"Venerus\",\n \"Generic Animal\",\n \"Populous\",\n \"Coma_Cose\",\n \"Frah Quintale\",\n \"Levante\",\n \"Pop X\",\n // ── Rock / band ──\n \"Måneskin\",\n \"Vasco Rossi\",\n \"Luciano Ligabue\",\n \"Subsonica\",\n \"Afterhours\",\n \"Verdena\",\n \"Marlene Kuntz\",\n \"Bluvertigo\",\n \"Morgan\",\n \"Baustelle\",\n \"The Zen Circus\",\n \"Fast Animals and Slow Kids\",\n \"Negrita\",\n \"Litfiba\",\n \"Le Vibrazioni\",\n \"Nomadi\",\n \"Stadio\",\n \"Pooh\",\n \"Lacuna Coil\",\n // ── Dance / elettronica ──\n \"Gigi D'Agostino\",\n \"Gabry Ponte\",\n \"Benny Benassi\",\n \"Prezioso\",\n \"Eiffel 65\",\n \"Meduza\",\n \"Anfisa Letyago\",\n // ── Urban napoletano ──\n \"Liberato\",\n \"Co'Sang\",\n \"Enzo Dong\",\n \"Lele Blade\",\n \"Yung Snapp\",\n \"MV Killa\",\n \"Vale Lambo\",\n \"Nino D'Angelo\",\n \"Gigi D'Alessio\",\n // ── Classici / cantautori storici ──\n \"Fabrizio De André\",\n \"Francesco Guccini\",\n \"Lucio Dalla\",\n \"Lucio Battisti\",\n \"Franco Battiato\",\n \"Rino Gaetano\",\n \"Francesco De Gregori\",\n \"Antonello Venditti\",\n \"Claudio Baglioni\",\n \"Renato Zero\",\n \"Adriano Celentano\",\n \"Mina\",\n \"Ornella Vanoni\",\n \"Gianna Nannini\",\n \"Pino Daniele\",\n \"Andrea Bocelli\",\n \"Max Gazzè\",\n \"Daniele Silvestri\",\n \"Niccolò Fabi\",\n \"Samuele Bersani\",\n \"Biagio Antonacci\",\n \"Nek\",\n \"Zucchero\",\n \"Eros Ramazzotti\",\n \"Laura Pausini\",\n \"Tiziano Ferro\",\n \"Giorgia\",\n \"Elisa\",\n \"Cesare Cremonini\",\n \"Jovanotti\",\n \"Max Pezzali\",\n \"883\",\n \"Articolo 31\",\n \"J-Ax\",\n \"Grido\",\n \"Paolo Conte\",\n \"Vinicio Capossela\",\n \"Roberto Vecchioni\",\n \"Ivano Fossati\",\n \"Loredana Bertè\",\n \"Fiorella Mannoia\",\n \"Gianni Morandi\",\n \"Riccardo Cocciante\",\n \"Umberto Tozzi\",\n \"Edoardo Bennato\",\n \"Anna Oxa\",\n \"Mango\",\n \"Matia Bazar\",\n \"Ricchi e Poveri\",\n \"Pupo\",\n];\n\nfunction classify(a) {\n const name = a.collectionName || \"\",\n artist = a.artistName || \"\",\n tc = a.trackCount || 0;\n if (\n /various artists|artisti vari/i.test(artist) ||\n /compilation|raccolta/i.test(name)\n ) return \"Compilation\";\n if (/remix/i.test(name)) return \"Remix\";\n if (/deluxe/i.test(name)) return \"Deluxe\";\n if (/ - single$|\$single\$| - single /i.test(name)) return \"Singolo\";\n if (/ - ep$|\$ep\$| - ep /i.test(name)) return \"EP\";\n if (tc > 0 && tc <= 2) return \"Singolo\";\n if (tc >= 3 && tc <= 6) return \"EP\";\n return \"Album\";\n}\n\nfunction mapItem(a) {\n return {\n id: a.collectionId,\n title: a.collectionName,\n artist: a.artistName,\n genre: a.primaryGenreName || \"Altro\",\n type: classify(a),\n date: a.releaseDate || \"\",\n art: (a.artworkUrl100 || \"\").replace(\"100x100bb\", \"600x600bb\"),\n url: a.collectionViewUrl || \"\",\n };\n}\n\nasync function resolveId(name) {\n const u = `https://itunes.apple.com/search?term=${\n encodeURIComponent(name)\n }&entity=musicArtist&attribute=artistTerm&limit=1&country=IT`;\n try {\n const r = await fetch(u);\n if (!r.ok) return null;\n const d = await r.json();\n const a = (d.results || [])[0];\n return a && a.artistId ? a.artistId : null;\n } catch {\n return null;\n }\n}\nasync function albumsOf(artistId) {\n const u =\n `https://itunes.apple.com/lookup?id=${artistId}&entity=album&limit=200&country=IT&lang=it_it`;\n try {\n const r = await fetch(u);\n if (!r.ok) return [];\n const d = await r.json();\n return (d.results || []).filter((x) => x.wrapperType === \"collection\");\n } catch {\n return [];\n }\n}\n\nasync function releasesForIds(ids) {\n const CONC = 5;\n const seen = new Set();\n const out = [];\n for (let i = 0; i < ids.length; i += CONC) {\n const batch = ids.slice(i, i + CONC);\n const res = await Promise.allSettled(batch.map(albumsOf));\n for (const r of res) {\n if (r.status !== \"fulfilled\") continue;\n for (const a of r.value) {\n if (!a.collectionId || seen.has(a.collectionId)) continue;\n seen.add(a.collectionId);\n out.push(mapItem(a));\n }\n }\n await new Promise((r) => setTimeout(r, 150));\n }\n\n const cutoff = Date.now() - WINDOW_MS;\n const filtered = out.filter((x) => {\n const t = Date.parse(x.date);\n return !isNaN(t) && t >= cutoff;\n });\n filtered.sort((x, y) => (y.date || \"\").localeCompare(x.date || \"\"));\n return filtered;\n}\n\nasync function ensureArtistsTable() {\n await sqlite.execute(`create table if not exists musicatch_artists (\n name text primary key, added_at text\n )`);\n const res = await sqlite.execute(\n `select count(*) as c from musicatch_artists`,\n );\n const count = res.rows[0][0];\n if (count === 0) {\n const now = new Date().toISOString();\n const uniqueSeed = [\n ...new Set(SEED_ARTISTS.map((n) => n.trim()).filter(Boolean)),\n ];\n const stmts = uniqueSeed.map((n) => ({\n sql:\n `insert or ignore into musicatch_artists (name, added_at) values (?, ?)`,\n args: [n, now],\n }));\n for (let i = 0; i < stmts.length; i += 200) {\n await sqlite.batch(stmts.slice(i, i + 200));\n }\n }\n}\n\nasync function readArtistNames() {\n const res = await sqlite.execute(\n `select name from musicatch_artists order by name`,\n );\n return res.rows.map((r) => r[0]);\n}\n\nasync function addCuratedArtist(name) {\n const n = (name || \"\").trim();\n if (!n) return;\n await sqlite.execute({\n sql:\n `insert or ignore into musicatch_artists (name, added_at) values (?, ?)`,\n args: [n, new Date().toISOString()],\n });\n}\n\nasync function removeCuratedArtist(name) {\n await sqlite.execute({\n sql: `delete from musicatch_artists where name = ?`,\n args: [(name || \"\").trim()],\n });\n}\n\nasync function buildAll() {\n await ensureArtistsTable();\n const namesRaw = await readArtistNames();\n const names = [\n ...new Map(\n namesRaw.map((s) => s.trim()).filter(Boolean).map(\n (n) => [n.toLowerCase(), n]\n ),\n ).values(),\n ];\n\n let ids = {};\n try {\n ids = (await blob.getJSON(IDS_KEY)) || {};\n } catch {\n ids = {};\n }\n const missing = names.filter((n) => !(n.toLowerCase() in ids));\n const CONC = 5;\n for (let i = 0; i < missing.length; i += CONC) {\n const batch = missing.slice(i, i + CONC);\n const res = await Promise.allSettled(batch.map(resolveId));\n batch.forEach((n, j) => {\n ids[n.toLowerCase()] = res[j].status === \"fulfilled\"\n ? res[j].value\n : null;\n });\n try {\n await blob.setJSON(IDS_KEY, ids);\n } catch {} // salvataggio incrementale\n await new Promise((r) => setTimeout(r, 150));\n }\n\n const validIds = names.map((n) => ids[n.toLowerCase()]).filter(Boolean);\n return releasesForIds(validIds);\n}\n\nasync function ensureTable() {\n await sqlite.execute(`create table if not exists musicatch_releases (\n id integer primary key, title text, artist text, genre text, type text,\n date text, art text, url text, updated_at text\n )`);\n}\n\nasync function upsertReleases(items) {\n if (!items.length) return;\n const now = new Date().toISOString();\n const BATCH = 200; // sqlite.batch scrive N righe in un giro di rete solo, molto più veloce di execute() una per una\n for (let i = 0; i < items.length; i += BATCH) {\n const stmts = items.slice(i, i + BATCH).map((it) => ({\n sql:\n `insert into musicatch_releases (id,title,artist,genre,type,date,art,url,updated_at)\n values (?,?,?,?,?,?,?,?,?)\n on conflict(id) do update set title=excluded.title, artist=excluded.artist,\n genre=excluded.genre, type=excluded.type, date=excluded.date, art=excluded.art,\n url=excluded.url, updated_at=excluded.updated_at`,\n args: [\n it.id,\n it.title,\n it.artist,\n it.genre,\n it.type,\n it.date,\n it.art,\n it.url,\n now,\n ],\n }));\n await sqlite.batch(stmts);\n }\n}\n\nasync function readCuratedFromDB() {\n const cutoffIso = new Date(Date.now() - WINDOW_MS).toISOString();\n const res = await sqlite.execute({\n sql:\n `select id,title,artist,genre,type,date,art,url from musicatch_releases where date >= ? order by date desc`,\n args: [cutoffIso],\n });\n return res.rows.map((r) => ({\n id: r[0],\n title: r[1],\n artist: r[2],\n genre: r[3],\n type: r[4],\n date: r[5],\n art: r[6],\n url: r[7],\n }));\n}\n\nasync function searchArtists(term) {\n const u = `https://itunes.apple.com/search?term=${\n encodeURIComponent(term)\n }&entity=musicArtist&attribute=artistTerm&limit=10&country=IT`;\n const r = await fetch(u);\n if (!r.ok) return null;\n const d = await r.json();\n return (d.results || []).map((a) => ({\n id: a.artistId,\n name: a.artistName,\n genre: a.primaryGenreName || \"\",\n }));\n}\n\nexport default async function (req) {\n const cors = { \"Access-Control-Allow-Origin\": \"*\" };\n try {\n const url = new URL(req.url);\n const albumId = url.searchParams.get(\"album\");\n const searchTerm = url.searchParams.get(\"search\");\n const artistsParam = url.searchParams.get(\"artists\");\n const curatedAdd = url.searchParams.get(\"curatedAdd\");\n const curatedRemove = url.searchParams.get(\"curatedRemove\");\n\n if (url.searchParams.get(\"curatedList\") === \"1\") {\n await ensureArtistsTable();\n return Response.json({ artists: await readArtistNames() }, {\n headers: cors,\n });\n }\n\n if (curatedAdd) {\n await ensureArtistsTable();\n await addCuratedArtist(curatedAdd);\n return Response.json({ artists: await readArtistNames() }, {\n headers: cors,\n });\n }\n\n if (curatedRemove) {\n await ensureArtistsTable();\n await removeCuratedArtist(curatedRemove);\n return Response.json({ artists: await readArtistNames() }, {\n headers: cors,\n });\n }\n\n if (searchTerm) {\n const results = await searchArtists(searchTerm.trim());\n if (results === null) {\n return Response.json({ error: \"apple\" }, {\n status: 502,\n headers: cors,\n });\n }\n return Response.json({ results }, { headers: cors });\n }\n\n if (artistsParam) {\n const ids = [\n ...new Set(\n artistsParam.split(\",\").map((s) => s.trim()).filter(Boolean),\n ),\n ].slice(0, 150);\n if (!ids.length) {\n return Response.json({ count: 0, items: [] }, { headers: cors });\n }\n\n const force = url.searchParams.get(\"refresh\") === \"1\";\n const key = \"musicatch_personal_\" + ids.slice().sort().join(\"_\");\n let cached = null;\n try {\n cached = await blob.getJSON(key);\n } catch {\n cached = null;\n }\n if (\n !force && cached && cached.items &&\n (Date.now() - cached.ts) < PERSONAL_TTL_MS\n ) {\n return Response.json({\n count: cached.items.length,\n items: cached.items,\n cached: true,\n }, { headers: cors });\n }\n\n const items = await releasesForIds(ids);\n try {\n await blob.setJSON(key, { ts: Date.now(), items });\n } catch {}\n return Response.json({ count: items.length, items, cached: false }, {\n headers: cors,\n });\n }\n\n if (albumId) {\n const u = `https://itunes.apple.com/lookup?id=${\n encodeURIComponent(albumId)\n }&entity=song&country=IT&lang=it_it&limit=80`;\n const r = await fetch(u);\n if (!r.ok) {\n return Response.json({ error: \"apple\", status: r.status }, {\n status: 502,\n headers: cors,\n });\n }\n const d = await r.json();\n const res = d.results || [];\n const album = res.find((x) => x.wrapperType === \"collection\") || res[0] ||\n {};\n const tracks = res.filter((x) => x.wrapperType === \"track\").sort((a, b) =>\n (a.trackNumber || 0) - (b.trackNumber || 0)\n )\n .map((t) => ({\n n: t.trackNumber || 0,\n title: t.trackName || \"—\",\n durationMs: t.trackTimeMillis || 0,\n preview: t.previewUrl || \"\",\n }));\n return Response.json({\n album: {\n title: album.collectionName || \"\",\n artist: album.artistName || \"\",\n art: (album.artworkUrl100 || \"\").replace(\"100x100bb\", \"600x600bb\"),\n url: album.collectionViewUrl || \"\",\n date: album.releaseDate || \"\",\n },\n tracks,\n }, { headers: cors });\n }\n\n const force = url.searchParams.get(\"refresh\") === \"1\";\n await ensureTable();\n\n let items;\n if (force) {\n items = await buildAll();\n await upsertReleases(items);\n } else {\n items = await readCuratedFromDB();\n if (!items.length) {\n items = await buildAll();\n await upsertReleases(items);\n }\n }\n\n if (!items.length) {\n return Response.json({ error: \"apple\", status: 0 }, {\n status: 502,\n headers: cors,\n });\n }\n return Response.json({ count: items.length, items, cached: !force }, {\n headers: cors,\n });\n } catch (e) {\n return Response.json({ error: String(e) }, { status: 500, headers: cors });\n }\n}","deleted",false,"label",[36],"35504072-51b2-491f-9890-56c3be49873f","cron-val-1.ts","abecdffc-9fa7-11f1-9626-1607ee4eb77e",47,["D",1787572786685],7,"interval","// ──────────────────────────────────────────────────────────────\n// CRON VAL — nuovo val separato su Val.town, tipo \"Cron\"\n// (crealo da zero, NON sostituisce il val HTTP \"MusiCatch\")\n//\n// Ad ogni esecuzione: risolve gli ID Apple di una FETTA (100) della\n// lista artisti curati, scarica il loro catalogo album e lo scrive\n// (upsert) nella tabella SQLite condivisa `musicatch_releases` — la\n// stessa che il val HTTP legge per la tab \"in evidenza\". Un cursore\n// in Blob ricorda dove riprendere al giro successivo, così l'intera\n// lista gira a rotazione senza mai superare il limite di 60s del\n// piano free di Val.town. Non filtra per data: accumula tutto lo\n// storico visto, così l'app diventa progressivamente più completa.\n//\n// Programma il trigger Cron ogni 15 minuti (il minimo sul piano\n// free) così l'intera lista si aggiorna in circa 1 ora e poi ricomincia.\n//\n// La lista artisti NON è più hardcoded qui: viene letta dalla tabella\n// SQLite condivisa `musicatch_artists` (stessa tabella gestita dal val\n// HTTP tramite l'app, tab Impostazioni). Se quella tabella è vuota\n// (val HTTP non ancora avviato una prima volta), questo giro non\n// processa nulla — si autocorregge al giro dopo, senza errori.\n// ──────────────────────────────────────────────────────────────\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/global.ts\";\n\nconst IDS_KEY = \"musicatch_artistids_v3\";\nconst CURSOR_KEY = \"musicatch_cron_cursor\";\nconst CHUNK = 100; // artisti processati per esecuzione — resta ben sotto il limite di 60s del piano free\n\nasync function readArtistNames() {\n await sqlite.execute(`create table if not exists musicatch_artists (\n name text primary key, added_at text\n )`);\n const res = await sqlite.execute(\n `select name from musicatch_artists order by name`,\n );\n return res.rows.map((r) => r[0]);\n}\n\nfunction classify(a) {\n const name = a.collectionName || \"\",\n artist = a.artistName || \"\",\n tc = a.trackCount || 0;\n if (\n /various artists|artisti vari/i.test(artist) ||\n /compilation|raccolta/i.test(name)\n ) return \"Compilation\";\n if (/remix/i.test(name)) return \"Remix\";\n if (/deluxe/i.test(name)) return \"Deluxe\";\n if (/ - single$|\$single\$| - single /i.test(name)) return \"Singolo\";\n if (/ - ep$|\$ep\$| - ep /i.test(name)) return \"EP\";\n if (tc > 0 && tc <= 2) return \"Singolo\";\n if (tc >= 3 && tc <= 6) return \"EP\";\n return \"Album\";\n}\n\nfunction mapItem(a) {\n return {\n id: a.collectionId,\n title: a.collectionName,\n artist: a.artistName,\n genre: a.primaryGenreName || \"Altro\",\n type: classify(a),\n date: a.releaseDate || \"\",\n art: (a.artworkUrl100 || \"\").replace(\"100x100bb\", \"600x600bb\"),\n url: a.collectionViewUrl || \"\",\n };\n}\n\nasync function resolveId(name) {\n const u = `https://itunes.apple.com/search?term=${\n encodeURIComponent(name)\n }&entity=musicArtist&attribute=artistTerm&limit=1&country=IT`;\n try {\n const r = await fetch(u);\n if (!r.ok) return null;\n const d = await r.json();\n const a = (d.results || [])[0];\n return a && a.artistId ? a.artistId : null;\n } catch {\n return null;\n }\n}\nasync function albumsOf(artistId) {\n const u =\n `https://itunes.apple.com/lookup?id=${artistId}&entity=album&limit=200&country=IT&lang=it_it`;\n try {\n const r = await fetch(u);\n if (!r.ok) return [];\n const d = await r.json();\n return (d.results || []).filter((x) => x.wrapperType === \"collection\");\n } catch {\n return [];\n }\n}\n\nasync function ensureTable() {\n await sqlite.execute(`create table if not exists musicatch_releases (\n id integer primary key, title text, artist text, genre text, type text,\n date text, art text, url text, updated_at text\n )`);\n}\n\nasync function upsertReleases(items) {\n if (!items.length) return;\n const now = new Date().toISOString();\n const BATCH = 200; // sqlite.batch scrive N righe in un giro di rete solo, molto più veloce di execute() una per una\n for (let i = 0; i < items.length; i += BATCH) {\n const stmts = items.slice(i, i + BATCH).map((it) => ({\n sql:\n `insert into musicatch_releases (id,title,artist,genre,type,date,art,url,updated_at)\n values (?,?,?,?,?,?,?,?,?)\n on conflict(id) do update set title=excluded.title, artist=excluded.artist,\n genre=excluded.genre, type=excluded.type, date=excluded.date, art=excluded.art,\n url=excluded.url, updated_at=excluded.updated_at`,\n args: [\n it.id,\n it.title,\n it.artist,\n it.genre,\n it.type,\n it.date,\n it.art,\n it.url,\n now,\n ],\n }));\n await sqlite.batch(stmts);\n }\n}\n\nexport default async function (interval) {\n await ensureTable();\n\n const namesRaw = await readArtistNames();\n const names = [\n ...new Map(\n namesRaw.map((s) => s.trim()).filter(Boolean).map(\n (n) => [n.toLowerCase(), n]\n ),\n ).values(),\n ];\n if (!names.length) {\n console.log(\n \"Cron MusiCatch: tabella artisti vuota, niente da fare in questo giro.\",\n );\n return;\n }\n\n // Elabora solo una fetta della lista per giro (il piano free di Val.town\n // termina l'esecuzione dopo 60s — con 300+ artisti in un colpo solo si\n // supera il limite). Il cursore ricorda dove riprendere al giro dopo.\n let cursor = 0;\n try {\n cursor = (await blob.getJSON(CURSOR_KEY)) ?? 0;\n } catch {\n cursor = 0;\n }\n if (!(cursor >= 0 && cursor < names.length)) cursor = 0;\n const slice = names.slice(cursor, cursor + CHUNK);\n const nextCursor = cursor + CHUNK >= names.length ? 0 : cursor + CHUNK;\n\n let ids = {};\n try {\n ids = (await blob.getJSON(IDS_KEY)) || {};\n } catch {\n ids = {};\n }\n const missing = slice.filter((n) => !(n.toLowerCase() in ids));\n const CONC = 5;\n for (let i = 0; i < missing.length; i += CONC) {\n const batch = missing.slice(i, i + CONC);\n const res = await Promise.allSettled(batch.map(resolveId));\n batch.forEach((n, j) => {\n ids[n.toLowerCase()] = res[j].status === \"fulfilled\"\n ? res[j].value\n : null;\n });\n await new Promise((r) => setTimeout(r, 150));\n }\n try {\n await blob.setJSON(IDS_KEY, ids);\n } catch {}\n\n const sliceIds = slice.map((n) => ids[n.toLowerCase()]).filter(Boolean);\n let total = 0;\n for (let i = 0; i < sliceIds.length; i += CONC) {\n const batch = sliceIds.slice(i, i + CONC);\n const res = await Promise.allSettled(batch.map(albumsOf));\n const items = [];\n for (const r of res) {\n if (r.status !== \"fulfilled\") continue;\n for (const a of r.value) if (a.collectionId) items.push(mapItem(a));\n }\n if (items.length) {\n await upsertReleases(items);\n total += items.length;\n }\n await new Promise((r) => setTimeout(r, 150));\n }\n\n try {\n await blob.setJSON(CURSOR_KEY, nextCursor);\n } catch {}\n\n console.log(\n `Cron MusiCatch: elaborati artisti ${cursor}-${\n cursor + slice.length\n } di ${names.length}, ${total} release scritte/aggiornate. Prossimo giro riparte da ${nextCursor}.`,\n );\n}",[58],{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":72,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_69":73,"_18":74},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":68,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_69":70,"_18":71},["D",1787572798727],"children",[],[36],["D",1787572786685],[],[58],"dd913874-c9fb-4744-abb7-33de98d97c1c",["D",1781351784570],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","0b176875-8832-4c2a-8955-d2b302658d57","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ec0d5-4427-72b2-8a1f-e237572b3029","tursoName","dd913874c9fb4744abb733de98d97c1c","tursoHostname","dd913874c9fb4744abb733de98d97c1c-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789451469231],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_132":128},"org",{"_11":12,"_125":126,"_127":128,"_84":85,"_129":130,"_131":54},"branch",{"_17":43,"_13":16,"_34":41,"_117":75,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":14,"_124":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Winston Osei Adom","avatar","https://lh3.googleusercontent.com/a/ACg8ocI3Y85E59fTC_ciuRYUEQ1F0TquLQuWnRZMF2hrxemkan90l0nO=s96-c","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_34":75,"_13":14,"_46":171,"_77":-5,"_78":54,"_79":80,"_81":80,"_82":19,"_83":-5,"_84":85,"_86":-5,"_87":54,"_88":-5,"_89":-5,"_90":91,"_92":93,"_94":95,"_96":97,"_98":172,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":173,"_112":174,"_114":175,"_116":54},[165,166],"files",[165,166],"counts",{"_155":91,"_156":157,"_158":91,"_31":159,"_160":161},[151,152],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":61,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_18":154},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":47,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_18":153},[36],[58],"pulls","branches",1,"forks",{"_162":91,"_164":91},"connections",{"_162":91,"_163":91},"count","unfilledCount","emptyCount",{"_34":57,"_13":58,"_37":59,"_39":-5,"_40":41,"_42":60,"_44":45,"_46":72,"_17":62,"_49":63,"_51":64,"_53":54,"_55":-5,"_69":169,"_18":170},{"_34":35,"_13":36,"_37":38,"_39":-5,"_40":41,"_42":43,"_44":45,"_46":68,"_17":48,"_49":50,"_51":52,"_53":54,"_55":-5,"_69":167,"_18":168},[],[36],[],[58],["D",1781351784570],["D",1789451469231],{"_11":12,"_132":128},{"_11":12,"_125":126,"_127":128,"_84":85,"_129":130,"_131":54},{"_17":43,"_13":16,"_34":41,"_117":75,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":14,"_124":12},"ctx",{"_110":-5,"_148":209,"_210":211,"_212":213,"_214":54,"_215":54,"_216":54,"_217":45,"_218":-5,"_219":-7,"_220":-7,"_221":91,"_222":54,"_223":54,"_224":-5,"_225":54,"_226":54,"_227":54,"_228":-5},"ENV",{"_180":181,"_182":183,"_184":16,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208},"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"]

Code