[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_292":293,"_294":295},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_219":-5,"_20":220,"_22":221,"_222":223,"_224":225,"_25":226,"_24":-5,"_227":-5,"_228":-5,"_229":56,"_230":231,"_232":47,"_233":-5,"_234":-5,"_235":236},"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","cschick","name","design-database","branchName","main","version","path","","project",{"_36":162,"_13":14,"_48":163,"_164":-5,"_165":56,"_166":167,"_168":167,"_169":170,"_171":-5,"_172":173,"_174":40,"_175":47,"_176":-5,"_177":-5,"_178":63,"_179":180,"_181":182,"_183":184,"_185":186,"_187":-5,"_188":189,"_190":189,"_191":192,"_193":192,"_194":192,"_195":189,"_196":189,"_197":198,"_199":200,"_201":202,"_203":56},"tree",[79,80,81,82],"file","contents",[32,33,34,35],"upstream","pull","ahead","behind","envVars",{"_36":73,"_13":74,"_39":75,"_41":-5,"_42":43,"_44":76,"_46":47,"_48":77,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_18":78},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":70,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_18":72},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":62,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_18":65},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":49,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_18":58},"id","c7c45ced-578e-46c5-9bea-3a0d534ed67d","etsy-oauth.http.ts","fileId","0a7ef8ee-9c0a-11f1-bbe1-1607ee4eb77e","parentId","branchId","f064a77f-da10-40b1-b2c8-85400a044673","branchVersion",12,"latest",true,"createdAt",["D",1787170454916],1,"fileType","http","content","import { Hono } from \"npm:hono\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst apiKey = Deno.env.get(\"ETSY_API_KEY\")!;\n\nasync function ensureTables() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS etsy_oauth_state (\n state TEXT PRIMARY KEY,\n code_verifier TEXT,\n created_at INTEGER\n )\n `);\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS etsy_oauth (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n access_token TEXT,\n refresh_token TEXT,\n expires_at INTEGER\n )\n `);\n}\n\nfunction base64url(bytes: Uint8Array): string {\n return btoa(String.fromCharCode(...bytes))\n .replace(/\\+/g, \"-\")\n .replace(/\\//g, \"_\")\n .replace(/=+$/, \"\");\n}\n\nfunction randomString(len: number): string {\n const bytes = new Uint8Array(len);\n crypto.getRandomValues(bytes);\n return base64url(bytes).slice(0, len);\n}\n\nasync function codeChallenge(verifier: string): Promise {\n const digest = await crypto.subtle.digest(\"SHA-256\", new TextEncoder().encode(verifier));\n return base64url(new Uint8Array(digest));\n}\n\napp.get(\"/etsy/login\", async (c) => {\n await ensureTables();\n const state = randomString(32);\n const verifier = randomString(64);\n const challenge = await codeChallenge(verifier);\n\n await sqlite.execute(\n `INSERT INTO etsy_oauth_state (state, code_verifier, created_at) VALUES (?, ?, ?)`,\n [state, verifier, Date.now()],\n );\n\n const redirectUri = new URL(\"/etsy/callback\", c.req.url).toString();\n const authUrl = new URL(\"https://www.etsy.com/oauth/connect\");\n authUrl.searchParams.set(\"response_type\", \"code\");\n authUrl.searchParams.set(\"redirect_uri\", redirectUri);\n authUrl.searchParams.set(\"scope\", \"listings_r shops_r\");\n authUrl.searchParams.set(\"client_id\", apiKey);\n authUrl.searchParams.set(\"state\", state);\n authUrl.searchParams.set(\"code_challenge\", challenge);\n authUrl.searchParams.set(\"code_challenge_method\", \"S256\");\n\n return new Response(null, { status: 302, headers: { Location: authUrl.toString() } });\n});\n\napp.get(\"/etsy/callback\", async (c) => {\n await ensureTables();\n const code = c.req.query(\"code\");\n const state = c.req.query(\"state\");\n const err = c.req.query(\"error\");\n if (err) return c.text(`Etsy returned an error: ${err} - ${c.req.query(\"error_description\")}`, 400);\n if (!code || !state) return c.text(\"Missing code or state\", 400);\n\n const row = await sqlite.execute(`SELECT code_verifier FROM etsy_oauth_state WHERE state = ?`, [state]);\n if (row.rows.length === 0) return c.text(\"Unknown or expired state\", 400);\n const verifier = row.rows[0].code_verifier as string;\n\n const redirectUri = new URL(\"/etsy/callback\", c.req.url).toString();\n const tokenRes = await fetch(\"https://api.etsy.com/v3/public/oauth/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n grant_type: \"authorization_code\",\n client_id: apiKey,\n redirect_uri: redirectUri,\n code,\n code_verifier: verifier,\n }),\n });\n\n if (!tokenRes.ok) {\n return c.text(`Token exchange failed: ${tokenRes.status} ${await tokenRes.text()}`, 500);\n }\n const tokenData = await tokenRes.json();\n const expiresAt = Date.now() + tokenData.expires_in * 1000;\n\n await sqlite.execute(\n `INSERT INTO etsy_oauth (id, access_token, refresh_token, expires_at) VALUES (1, ?, ?, ?)\n ON CONFLICT(id) DO UPDATE SET access_token = excluded.access_token, refresh_token = excluded.refresh_token, expires_at = excluded.expires_at`,\n [tokenData.access_token, tokenData.refresh_token, expiresAt],\n );\n await sqlite.execute(`DELETE FROM etsy_oauth_state WHERE state = ?`, [state]);\n\n return c.text(\"Etsy authorized (listings_r + shops_r). You can close this tab.\");\n});\n\nexport default app.fetch;\n","deleted",false,"label",[38],"942b84c6-f715-408f-a5e6-4810ae8b5748","README.md","8f81f6b0-9c08-11f1-9a6b-1607ee4eb77e",["D",1787169600642],0,"# design-database\n\nOffline, durable copy of the Grey and Slate Etsy catalog (active listings only).\n\n- SQLite tables `listings` and `images` hold metadata; see schema below.\n- Actual image files are archived locally on disk (iCloud: Folder for Claude/Etsy Store/Design Database/images/), not in Val.town storage.\n- Populated by a local extraction script (Etsy Open API v3), not by an HTTP endpoint on this val.\n\nSee HANDOFF_DESIGN_DATABASE.md in the same iCloud folder for full scope/context.\n",[60],"049c06f1-1fee-48a6-af1b-51f502283359","scripts","c47c07c1-2003-4f8b-8e73-b94386f5691d",2,["D",1787170026306],"directory",[67],"36dec0b5-6226-473a-9de2-0a60d87e1950","data","0ca9efc2-d8b6-4a26-880b-f9e8ea8eb099",16,["D",1787171668821],[74],{"_36":73,"_13":74,"_39":75,"_41":-5,"_42":43,"_44":76,"_46":47,"_48":159,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_84":160,"_18":161},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":90,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_84":91,"_18":92},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":87,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_84":88,"_18":89},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":83,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_84":85,"_18":86},["D",1787170454916],"children",[],[38],["D",1787169600642],[],[60],["D",1787170026306],[93,94,95,96,97,98,99],[67],{"_36":151,"_13":152,"_39":153,"_41":68,"_42":43,"_44":154,"_46":47,"_48":155,"_17":63,"_51":106,"_53":156,"_55":56,"_57":-5,"_84":157,"_18":158},{"_36":142,"_13":143,"_39":144,"_41":68,"_42":43,"_44":145,"_46":47,"_48":146,"_17":147,"_51":106,"_53":148,"_55":56,"_57":-5,"_84":149,"_18":150},{"_36":134,"_13":135,"_39":136,"_41":68,"_42":43,"_44":137,"_46":47,"_48":138,"_17":63,"_51":106,"_53":139,"_55":56,"_57":-5,"_84":140,"_18":141},{"_36":126,"_13":127,"_39":128,"_41":68,"_42":43,"_44":129,"_46":47,"_48":130,"_17":63,"_51":106,"_53":131,"_55":56,"_57":-5,"_84":132,"_18":133},{"_36":118,"_13":119,"_39":120,"_41":68,"_42":43,"_44":121,"_46":47,"_48":122,"_17":63,"_51":106,"_53":123,"_55":56,"_57":-5,"_84":124,"_18":125},{"_36":110,"_13":111,"_39":112,"_41":68,"_42":43,"_44":113,"_46":47,"_48":114,"_17":63,"_51":106,"_53":115,"_55":56,"_57":-5,"_84":116,"_18":117},{"_36":100,"_13":101,"_39":102,"_41":68,"_42":43,"_44":103,"_46":47,"_48":104,"_17":105,"_51":106,"_53":107,"_55":56,"_57":-5,"_84":108,"_18":109},"a7384858-f426-4aa0-8568-ee27f56209f9","test-auth.ts","8d3cca82-9c09-11f1-8c4c-1607ee4eb77e",25,["D",1787172068237],7,"script","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst apiKey = Deno.env.get(\"ETSY_API_KEY\");\nconst sharedSecret = Deno.env.get(\"ETSY_SHARED_SECRET\");\nconst tokenRow = await sqlite.execute(`SELECT access_token FROM etsy_oauth WHERE id = 1`);\nconst { access_token } = tokenRow.rows[0] as { access_token: string };\n\nconst headers = {\n \"x-api-key\": `${apiKey}:${sharedSecret}`,\n \"Authorization\": `Bearer ${access_token}`,\n};\n\nconst listingId = 4300506570;\nconst res = await fetch(`https://openapi.etsy.com/v3/application/listings/${listingId}/videos`, { headers });\nconsole.log(\"videos endpoint ->\", res.status);\nconsole.log((await res.text()).slice(0, 1500));\n",[],[67,101],"a6cbed9c-8d84-4753-905b-b36b1b96c331","ingest-videos.ts","10aad7d2-9c10-11f1-b87d-1607ee4eb77e",28,["D",1787172823817],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\n\ntype Row = {\n listing_id: number;\n etsy_video_id: number;\n video_hash: string;\n local_file_path: string;\n original_etsy_url: string;\n width: number;\n height: number;\n};\n\nconst rows = JSON.parse(await readFile(\"/data/video_results.json\", import.meta.url)) as Row[];\nconsole.log(\"total rows:\", rows.length);\n\nconst videos = new Map();\nfor (const r of rows) {\n if (!videos.has(r.video_hash)) {\n videos.set(r.video_hash, {\n local_file_path: r.local_file_path,\n original_etsy_url: r.original_etsy_url,\n width: r.width,\n height: r.height,\n });\n }\n}\nconsole.log(\"unique videos:\", videos.size);\n\nconst statements: { sql: string; args: any[] }[] = [];\nfor (const [hash, v] of videos) {\n statements.push({\n sql: `INSERT OR IGNORE INTO videos (video_hash, local_file_path, original_etsy_url, width, height) VALUES (?, ?, ?, ?, ?)`,\n args: [hash, v.local_file_path, v.original_etsy_url, v.width, v.height],\n });\n}\n// one video per listing, so a straight per-row update is fine (no need to sort/aggregate)\nfor (const r of rows) {\n statements.push({\n sql: `UPDATE listings SET video_hash = ? WHERE listing_id = ?`,\n args: [r.video_hash, r.listing_id],\n });\n}\n\nconsole.log(\"total statements:\", statements.length);\nconst CHUNK = 500;\nfor (let i = 0; i < statements.length; i += CHUNK) {\n await sqlite.batch(statements.slice(i, i + CHUNK));\n console.log(`batched ${Math.min(i + CHUNK, statements.length)}/${statements.length}`);\n}\n\nconst vidCount = await sqlite.execute(`SELECT COUNT(*) as c FROM videos`);\nconst withVideo = await sqlite.execute(`SELECT COUNT(*) as c FROM listings WHERE video_hash IS NOT NULL`);\nconsole.log(\"videos table rows:\", vidCount.rows[0].c);\nconsole.log(\"listings with video_hash set:\", withVideo.rows[0].c);\n",[],[67,111],"64b6047c-378a-4030-9ea0-da7e2bcd2977","ingest-images.ts","a1b3ca48-9c0d-11f1-a0f8-1607ee4eb77e",20,["D",1787171778645],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\n\n// Each row: [listing_id, listing_image_id, rank, image_hash, local_file_path, original_etsy_url, width, height]\ntype Row = [number, number, number, string, string, string, number, number];\n\nconst part1 = JSON.parse(await readFile(\"/data/image_results_part1.json\", import.meta.url)) as Row[];\nconst part2 = JSON.parse(await readFile(\"/data/image_results_part2.json\", import.meta.url)) as Row[];\nconst rows = [...part1, ...part2];\nconsole.log(\"total rows:\", rows.length);\n\n// Unique images (first occurrence per hash)\nconst images = new Map();\nfor (const [, , , hash, local_file_path, original_etsy_url, width, height] of rows) {\n if (!images.has(hash)) images.set(hash, { local_file_path, original_etsy_url, width, height });\n}\nconsole.log(\"unique images:\", images.size);\n\n// Per-listing hash lists, ordered by rank\nconst byListing = new Map();\nfor (const [listing_id, , rank, hash] of rows) {\n if (!byListing.has(listing_id)) byListing.set(listing_id, []);\n byListing.get(listing_id)!.push({ rank, hash });\n}\n\nconst statements: { sql: string; args: any[] }[] = [];\n\nfor (const [hash, img] of images) {\n statements.push({\n sql: `INSERT OR IGNORE INTO images (image_hash, local_file_path, original_etsy_url, width, height) VALUES (?, ?, ?, ?, ?)`,\n args: [hash, img.local_file_path, img.original_etsy_url, img.width, img.height],\n });\n}\n\nfor (const [listing_id, imgs] of byListing) {\n imgs.sort((a, b) => a.rank - b.rank);\n const hashes = imgs.map((i) => i.hash);\n statements.push({\n sql: `UPDATE listings SET primary_image_hash = ?, image_hashes = ? WHERE listing_id = ?`,\n args: [hashes[0], JSON.stringify(hashes), listing_id],\n });\n}\n\nconsole.log(\"total statements:\", statements.length);\n\nconst CHUNK = 500;\nfor (let i = 0; i < statements.length; i += CHUNK) {\n const chunk = statements.slice(i, i + CHUNK);\n await sqlite.batch(chunk);\n console.log(`batched ${Math.min(i + CHUNK, statements.length)}/${statements.length}`);\n}\n\nconst imgCount = await sqlite.execute(`SELECT COUNT(*) as c FROM images`);\nconst withPrimary = await sqlite.execute(`SELECT COUNT(*) as c FROM listings WHERE primary_image_hash IS NOT NULL`);\nconsole.log(\"images table rows:\", imgCount.rows[0].c);\nconsole.log(\"listings with primary_image_hash set:\", withPrimary.rows[0].c);\n",[],[67,119],"2ac99863-7bdf-4332-b8f1-6f593c6e8c9d","find-duplicate-candidates.ts","9bae891e-9c10-11f1-82b8-1607ee4eb77e",30,["D",1787173057040],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst res = await sqlite.execute(`SELECT listing_id, title, image_hashes FROM listings`);\nconst listings = res.rows.map((r) => ({\n listing_id: r.listing_id as number,\n title: r.title as string,\n hashes: JSON.parse(r.image_hashes as string) as string[],\n}));\n\n// frequency of each image hash across all listings\nconst freq = new Map();\nfor (const l of listings) {\n for (const h of l.hashes) freq.set(h, (freq.get(h) ?? 0) + 1);\n}\n\nconsole.log(\"hash frequency distribution (freq -> count of hashes at that freq):\");\nconst distro = new Map();\nfor (const f of freq.values()) distro.set(f, (distro.get(f) ?? 0) + 1);\nconsole.log(JSON.stringify([...distro.entries()].sort((a, b) => a[0] - b[0])));\n\n// Boilerplate = images shared by many listings (care instructions, sizing chart, hand-drawn info, logo etc)\n// Rare-shared = images shared by a small handful of listings - likely the SAME design reused across listing variants\nconst BOILERPLATE_MIN = 15;\nconst rareShared = new Set([...freq.entries()].filter(([, c]) => c >= 2 && c < BOILERPLATE_MIN).map(([h]) => h));\n\n// meaningful (non-boilerplate) hash count per listing, for ratio calc\nconst meaningfulCount = new Map();\nfor (const l of listings) {\n meaningfulCount.set(l.listing_id, l.hashes.filter((h) => freq.get(h)! < BOILERPLATE_MIN).length);\n}\n\n// pairwise: for each rare-shared hash, connect the listings that share it\nconst pairShared = new Map(); // \"id1|id2\" (id1 shared rare hash count\nconst hashToListings = new Map();\nfor (const l of listings) {\n for (const h of l.hashes) {\n if (!rareShared.has(h)) continue;\n if (!hashToListings.has(h)) hashToListings.set(h, []);\n hashToListings.get(h)!.push(l.listing_id);\n }\n}\nfor (const ids of hashToListings.values()) {\n for (let i = 0; i < ids.length; i++) {\n for (let j = i + 1; j < ids.length; j++) {\n const key = ids[i] < ids[j] ? `${ids[i]}|${ids[j]}` : `${ids[j]}|${ids[i]}`;\n pairShared.set(key, (pairShared.get(key) ?? 0) + 1);\n }\n }\n}\n\nconst titleById = new Map(listings.map((l) => [l.listing_id, l.title]));\nconst rows = [...pairShared.entries()].map(([key, shared]) => {\n const [a, b] = key.split(\"|\").map(Number);\n const ratio = shared / Math.min(meaningfulCount.get(a)!, meaningfulCount.get(b)!);\n return { a, b, shared, ratio, titleA: titleById.get(a), titleB: titleById.get(b) };\n});\nrows.sort((x, y) => y.ratio - x.ratio || y.shared - x.shared);\n\nconsole.log(\"total candidate pairs (sharing >=1 rare image):\", rows.length);\nconst highConfidence = rows.filter((r) => r.ratio >= 0.5);\nconsole.log(\"high-confidence pairs (ratio >= 0.5):\", highConfidence.length);\nfor (const r of highConfidence) {\n console.log(`${(r.ratio * 100).toFixed(0)}% shared=${r.shared} | ${r.a} \"${r.titleA}\" <-> ${r.b} \"${r.titleB}\"`);\n}\n",[],[67,127],"6b9e72fc-1fa1-49d9-8f43-4bf0a79911d5","extract-videos.ts","63c5fc50-9c0e-11f1-9e88-1607ee4eb77e",26,["D",1787172104248],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst apiKey = Deno.env.get(\"ETSY_API_KEY\");\nconst sharedSecret = Deno.env.get(\"ETSY_SHARED_SECRET\");\n\nconst tokenRow = await sqlite.execute(`SELECT access_token, refresh_token, expires_at FROM etsy_oauth WHERE id = 1`);\nlet { access_token, refresh_token, expires_at } = tokenRow.rows[0] as {\n access_token: string;\n refresh_token: string;\n expires_at: number;\n};\n\nif (Date.now() > Number(expires_at) - 60_000) {\n const res = await fetch(\"https://api.etsy.com/v3/public/oauth/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ grant_type: \"refresh_token\", client_id: apiKey, refresh_token }),\n });\n if (!res.ok) throw new Error(`Token refresh failed: ${res.status} ${await res.text()}`);\n const data = await res.json();\n access_token = data.access_token;\n refresh_token = data.refresh_token;\n await sqlite.execute(\n `UPDATE etsy_oauth SET access_token = ?, refresh_token = ?, expires_at = ? WHERE id = 1`,\n [access_token, refresh_token, Date.now() + data.expires_in * 1000],\n );\n}\n\nconst headers = {\n \"x-api-key\": `${apiKey}:${sharedSecret}`,\n \"Authorization\": `Bearer ${access_token}`,\n};\n\nconst BATCH_SIZE = 80;\nconst pending = await sqlite.execute(\n `SELECT listing_id FROM listings WHERE videos_fetched = 0 LIMIT ?`,\n [BATCH_SIZE],\n);\n\nlet done = 0;\nlet videosInserted = 0;\n\nfor (const row of pending.rows) {\n const listingId = row.listing_id;\n let res = await fetch(`https://openapi.etsy.com/v3/application/listings/${listingId}/videos`, { headers });\n if (res.status === 429) {\n await new Promise((r) => setTimeout(r, 2000));\n res = await fetch(`https://openapi.etsy.com/v3/application/listings/${listingId}/videos`, { headers });\n }\n if (!res.ok) {\n console.log(`listing ${listingId} videos ERROR ${res.status}`, await res.text());\n continue;\n }\n const data = await res.json();\n for (const v of data.results) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO listing_videos_raw\n (listing_id, etsy_video_id, video_url, width, height)\n VALUES (?, ?, ?, ?, ?)`,\n [listingId, v.video_id, v.video_url, v.width, v.height],\n );\n videosInserted++;\n }\n await sqlite.execute(`UPDATE listings SET videos_fetched = 1 WHERE listing_id = ?`, [listingId]);\n done++;\n}\n\nconst remaining = await sqlite.execute(`SELECT COUNT(*) as c FROM listings WHERE videos_fetched = 0`);\nconsole.log(`processed ${done} listings this batch, inserted ${videosInserted} video rows`);\nconsole.log(`remaining listings without videos: ${remaining.rows[0].c}`);\n",[],[67,135],"4fe36903-ed01-4177-a82f-761826651b90","extract-listings.ts","d9d383ae-9c09-11f1-aea5-1607ee4eb77e",14,["D",1787170539854],3,"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst SHOP_ID = \"55933970\";\nconst apiKey = Deno.env.get(\"ETSY_API_KEY\");\nconst sharedSecret = Deno.env.get(\"ETSY_SHARED_SECRET\");\n\nconst tokenRow = await sqlite.execute(`SELECT access_token, refresh_token, expires_at FROM etsy_oauth WHERE id = 1`);\nif (tokenRow.rows.length === 0) throw new Error(\"No Etsy OAuth token found - run /etsy/login first\");\nlet { access_token, refresh_token, expires_at } = tokenRow.rows[0] as {\n access_token: string;\n refresh_token: string;\n expires_at: number;\n};\n\nif (Date.now() > Number(expires_at) - 60_000) {\n const res = await fetch(\"https://api.etsy.com/v3/public/oauth/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ grant_type: \"refresh_token\", client_id: apiKey, refresh_token }),\n });\n if (!res.ok) throw new Error(`Token refresh failed: ${res.status} ${await res.text()}`);\n const data = await res.json();\n access_token = data.access_token;\n refresh_token = data.refresh_token;\n const newExpiresAt = Date.now() + data.expires_in * 1000;\n await sqlite.execute(\n `UPDATE etsy_oauth SET access_token = ?, refresh_token = ?, expires_at = ? WHERE id = 1`,\n [access_token, refresh_token, newExpiresAt],\n );\n console.log(\"refreshed token\");\n}\n\nconst headers = {\n \"x-api-key\": `${apiKey}:${sharedSecret}`,\n \"Authorization\": `Bearer ${access_token}`,\n};\n\nawait sqlite.execute(`\n CREATE TABLE IF NOT EXISTS listing_images_raw (\n listing_id INTEGER,\n listing_image_id INTEGER,\n rank INTEGER,\n url_fullxfull TEXT,\n full_width INTEGER,\n full_height INTEGER,\n PRIMARY KEY (listing_id, listing_image_id)\n )\n`);\nawait sqlite.execute(`ALTER TABLE listings ADD COLUMN images_fetched INTEGER DEFAULT 0`).catch(() => {});\n\nlet offset = 0;\nlet total = Infinity;\nlet inserted = 0;\n\nwhile (offset < total) {\n const res = await fetch(\n `https://openapi.etsy.com/v3/application/shops/${SHOP_ID}/listings?state=active&limit=100&offset=${offset}`,\n { headers },\n );\n if (!res.ok) {\n console.log(\"ERROR\", res.status, await res.text());\n break;\n }\n const data = await res.json();\n total = data.count;\n\n for (const l of data.results) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO listings\n (listing_id, platform, title, description, tags, section_id, section_name, status, price, created_date, images_fetched)\n VALUES (?, 'etsy', ?, ?, ?, ?, NULL, ?, ?, ?, 0)`,\n [\n l.listing_id,\n l.title,\n l.description,\n JSON.stringify(l.tags ?? []),\n l.shop_section_id ?? null,\n l.state,\n (l.price.amount / l.price.divisor).toFixed(2),\n new Date(l.original_creation_timestamp * 1000).toISOString(),\n ],\n );\n inserted++;\n }\n offset += 100;\n}\n\nconsole.log(`inserted/updated ${inserted} listings, api total=${total}`);\nconst count = await sqlite.execute(`SELECT COUNT(*) as c FROM listings`);\nconsole.log(\"rows now in listings table:\", count.rows[0].c);\n",[],[67,143],"03800e24-42ec-42ea-8868-c068536d8004","extract-images.ts","da8ed162-9c0a-11f1-8adf-1607ee4eb77e",15,["D",1787170585549],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst apiKey = Deno.env.get(\"ETSY_API_KEY\");\nconst sharedSecret = Deno.env.get(\"ETSY_SHARED_SECRET\");\n\nconst tokenRow = await sqlite.execute(`SELECT access_token, refresh_token, expires_at FROM etsy_oauth WHERE id = 1`);\nlet { access_token, refresh_token, expires_at } = tokenRow.rows[0] as {\n access_token: string;\n refresh_token: string;\n expires_at: number;\n};\n\nif (Date.now() > Number(expires_at) - 60_000) {\n const res = await fetch(\"https://api.etsy.com/v3/public/oauth/token\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ grant_type: \"refresh_token\", client_id: apiKey, refresh_token }),\n });\n if (!res.ok) throw new Error(`Token refresh failed: ${res.status} ${await res.text()}`);\n const data = await res.json();\n access_token = data.access_token;\n refresh_token = data.refresh_token;\n await sqlite.execute(\n `UPDATE etsy_oauth SET access_token = ?, refresh_token = ?, expires_at = ? WHERE id = 1`,\n [access_token, refresh_token, Date.now() + data.expires_in * 1000],\n );\n}\n\nconst headers = {\n \"x-api-key\": `${apiKey}:${sharedSecret}`,\n \"Authorization\": `Bearer ${access_token}`,\n};\n\nconst BATCH_SIZE = 60;\nconst pending = await sqlite.execute(\n `SELECT listing_id FROM listings WHERE images_fetched = 0 LIMIT ?`,\n [BATCH_SIZE],\n);\n\nlet done = 0;\nlet imagesInserted = 0;\n\nfor (const row of pending.rows) {\n const listingId = row.listing_id;\n let res = await fetch(`https://openapi.etsy.com/v3/application/listings/${listingId}/images`, { headers });\n if (res.status === 429) {\n await new Promise((r) => setTimeout(r, 2000));\n res = await fetch(`https://openapi.etsy.com/v3/application/listings/${listingId}/images`, { headers });\n }\n if (!res.ok) {\n console.log(`listing ${listingId} images ERROR ${res.status}`, await res.text());\n continue;\n }\n const data = await res.json();\n for (const img of data.results) {\n await sqlite.execute(\n `INSERT OR REPLACE INTO listing_images_raw\n (listing_id, listing_image_id, rank, url_fullxfull, full_width, full_height)\n VALUES (?, ?, ?, ?, ?, ?)`,\n [listingId, img.listing_image_id, img.rank, img.url_fullxfull, img.full_width, img.full_height],\n );\n imagesInserted++;\n }\n await sqlite.execute(`UPDATE listings SET images_fetched = 1 WHERE listing_id = ?`, [listingId]);\n done++;\n}\n\nconst remaining = await sqlite.execute(`SELECT COUNT(*) as c FROM listings WHERE images_fetched = 0`);\nconsole.log(`processed ${done} listings this batch, inserted ${imagesInserted} image rows`);\nconsole.log(`remaining listings without images: ${remaining.rows[0].c}`);\n",[],[67,152],["D",1787171668821],[],[74],"7615b982-4ecc-4be8-ba7a-c3d6aed0dd32",["D",1787169600594],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Offline design DB for Grey and Slate catalog","imageUrl","userId","442cb420-422c-11f0-bbe8-8f3f0ddc6612","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","675fd955-734f-4afa-a1fc-de0c0cf86139","tursoName","7615b9824ecc4be8ba7ac3d6aed0dd32","tursoHostname","7615b9824ecc4be8ba7ac3d6aed0dd32-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789517443998],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_218":214},"org",{"_11":12,"_212":-5,"_213":214,"_172":173,"_215":216,"_217":56},"branch",{"_17":129,"_13":16,"_36":43,"_204":162,"_205":-5,"_206":-5,"_207":-5,"_208":-5,"_209":-5,"_210":14,"_211":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeTY0alNTUThEcXp4czVhYzlySDZIeFBNa1kifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_36":162,"_13":14,"_48":287,"_164":-5,"_165":56,"_166":167,"_168":167,"_169":170,"_171":-5,"_172":173,"_174":40,"_175":47,"_176":-5,"_177":-5,"_178":63,"_179":180,"_181":182,"_183":184,"_185":288,"_187":-5,"_188":189,"_190":189,"_191":192,"_193":192,"_194":192,"_195":189,"_196":189,"_197":289,"_199":290,"_201":291,"_203":56},[254,255,263,264],"files",[254,255,256,257,258,259,260,261,262,263,264],"counts",{"_245":63,"_246":50,"_247":63,"_31":248,"_249":250},[237,238,239,240],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_36":73,"_13":74,"_39":75,"_41":-5,"_42":43,"_44":76,"_46":47,"_48":77,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_18":244},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":70,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_18":243},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":62,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_18":242},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":49,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_18":241},[38],[60],[67],[74],"pulls","branches","forks",{"_251":69,"_253":63},"connections",{"_251":63,"_252":63},"count","unfilledCount","emptyCount",{"_36":73,"_13":74,"_39":75,"_41":-5,"_42":43,"_44":76,"_46":47,"_48":159,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_84":285,"_18":286},{"_36":66,"_13":67,"_39":68,"_41":-5,"_42":43,"_44":69,"_46":47,"_48":90,"_17":63,"_51":71,"_53":-5,"_55":56,"_57":-5,"_84":283,"_18":284},{"_36":151,"_13":152,"_39":153,"_41":68,"_42":43,"_44":154,"_46":47,"_48":155,"_17":63,"_51":106,"_53":156,"_55":56,"_57":-5,"_84":281,"_18":282},{"_36":142,"_13":143,"_39":144,"_41":68,"_42":43,"_44":145,"_46":47,"_48":146,"_17":147,"_51":106,"_53":148,"_55":56,"_57":-5,"_84":279,"_18":280},{"_36":134,"_13":135,"_39":136,"_41":68,"_42":43,"_44":137,"_46":47,"_48":138,"_17":63,"_51":106,"_53":139,"_55":56,"_57":-5,"_84":277,"_18":278},{"_36":126,"_13":127,"_39":128,"_41":68,"_42":43,"_44":129,"_46":47,"_48":130,"_17":63,"_51":106,"_53":131,"_55":56,"_57":-5,"_84":275,"_18":276},{"_36":118,"_13":119,"_39":120,"_41":68,"_42":43,"_44":121,"_46":47,"_48":122,"_17":63,"_51":106,"_53":123,"_55":56,"_57":-5,"_84":273,"_18":274},{"_36":110,"_13":111,"_39":112,"_41":68,"_42":43,"_44":113,"_46":47,"_48":114,"_17":63,"_51":106,"_53":115,"_55":56,"_57":-5,"_84":271,"_18":272},{"_36":100,"_13":101,"_39":102,"_41":68,"_42":43,"_44":103,"_46":47,"_48":104,"_17":105,"_51":106,"_53":107,"_55":56,"_57":-5,"_84":269,"_18":270},{"_36":59,"_13":60,"_39":61,"_41":-5,"_42":43,"_44":50,"_46":47,"_48":87,"_17":63,"_51":24,"_53":64,"_55":56,"_57":-5,"_84":267,"_18":268},{"_36":37,"_13":38,"_39":40,"_41":-5,"_42":43,"_44":45,"_46":47,"_48":83,"_17":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_84":265,"_18":266},[],[38],[],[60],[],[67,101],[],[67,111],[],[67,119],[],[67,127],[],[67,135],[],[67,143],[],[67,152],[256,257,258,259,260,261,262],[67],[],[74],["D",1787169600594],["D",1789517443998],{"_11":12,"_218":214},{"_11":12,"_212":-5,"_213":214,"_172":173,"_215":216,"_217":56},{"_17":129,"_13":16,"_36":43,"_204":162,"_205":-5,"_206":-5,"_207":-5,"_208":-5,"_209":-5,"_210":14,"_211":12},"ctx",{"_197":-5,"_234":325,"_326":327,"_328":329,"_330":56,"_331":56,"_332":56,"_333":47,"_334":-5,"_335":-7,"_336":-7,"_337":63,"_338":56,"_339":56,"_340":-5,"_341":56,"_342":56,"_343":56,"_344":-5},"ENV",{"_296":297,"_298":299,"_300":16,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310,"_311":312,"_313":314,"_315":316,"_317":318,"_319":320,"_321":322,"_323":324},"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"]