[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_278":279,"_280":281},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_210":-5,"_20":211,"_22":212,"_213":214,"_215":216,"_26":217,"_24":218,"_219":-5,"_220":-5,"_221":69,"_222":223,"_224":63,"_225":-5,"_226":-5,"_227":228},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5,"_32":-5},"handle","cschick","name","design-database","branchName","main","version","path","scripts/find-duplicate-candidates.ts","project",{"_33":153,"_13":14,"_47":154,"_155":-5,"_156":69,"_157":158,"_159":158,"_160":161,"_162":-5,"_163":164,"_165":60,"_166":63,"_167":-5,"_168":-5,"_169":44,"_170":171,"_172":173,"_174":175,"_176":177,"_178":-5,"_179":180,"_181":180,"_182":183,"_184":183,"_185":183,"_186":180,"_187":180,"_188":189,"_190":191,"_192":193,"_194":69},"tree",[54,55,56,57],"file",{"_33":34,"_35":36,"_37":38,"_13":39,"_40":41,"_42":43,"_17":44,"_45":46,"_47":48,"_49":50,"_51":-5,"_18":52},"contents",[],"upstream","pull","ahead","behind","envVars","id","2ac99863-7bdf-4332-b8f1-6f593c6e8c9d","branchId","f064a77f-da10-40b1-b2c8-85400a044673","fileId","9bae891e-9c10-11f1-82b8-1607ee4eb77e","find-duplicate-candidates.ts","content","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","fileType","script",0,"parentId","c47c07c1-2003-4f8b-8e73-b94386f5691d","createdAt",["D",1787173057040],"branchVersion",30,"label",[53,39],"scripts",{"_33":146,"_13":147,"_37":148,"_45":-5,"_35":36,"_49":149,"_62":63,"_47":150,"_17":44,"_42":83,"_40":-5,"_68":69,"_51":-5,"_70":151,"_18":152},{"_33":80,"_13":53,"_37":46,"_45":-5,"_35":36,"_49":81,"_62":63,"_47":82,"_17":44,"_42":83,"_40":-5,"_68":69,"_51":-5,"_70":84,"_18":85},{"_33":73,"_13":74,"_37":75,"_45":-5,"_35":36,"_49":65,"_62":63,"_47":76,"_17":44,"_42":24,"_40":77,"_68":69,"_51":-5,"_70":78,"_18":79},{"_33":58,"_13":59,"_37":60,"_45":-5,"_35":36,"_49":61,"_62":63,"_47":64,"_17":65,"_42":66,"_40":67,"_68":69,"_51":-5,"_70":71,"_18":72},"c7c45ced-578e-46c5-9bea-3a0d534ed67d","etsy-oauth.http.ts","0a7ef8ee-9c0a-11f1-bbe1-1607ee4eb77e",12,"latest",true,["D",1787170454916],1,"http","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,"children",[],[59],"942b84c6-f715-408f-a5e6-4810ae8b5748","README.md","8f81f6b0-9c08-11f1-9a6b-1607ee4eb77e",["D",1787169600642],"# 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",[],[74],"049c06f1-1fee-48a6-af1b-51f502283359",2,["D",1787170026306],"directory",[86,87,88,89,90,91,92],[53],{"_33":138,"_13":139,"_37":140,"_45":46,"_35":36,"_49":141,"_62":63,"_47":142,"_17":44,"_42":43,"_40":143,"_68":69,"_51":-5,"_70":144,"_18":145},{"_33":129,"_13":130,"_37":131,"_45":46,"_35":36,"_49":132,"_62":63,"_47":133,"_17":134,"_42":43,"_40":135,"_68":69,"_51":-5,"_70":136,"_18":137},{"_33":121,"_13":122,"_37":123,"_45":46,"_35":36,"_49":124,"_62":63,"_47":125,"_17":44,"_42":43,"_40":126,"_68":69,"_51":-5,"_70":127,"_18":128},{"_33":34,"_13":39,"_37":38,"_45":46,"_35":36,"_49":50,"_62":63,"_47":118,"_17":44,"_42":43,"_40":41,"_68":69,"_51":-5,"_70":119,"_18":120},{"_33":110,"_13":111,"_37":112,"_45":46,"_35":36,"_49":113,"_62":63,"_47":114,"_17":44,"_42":43,"_40":115,"_68":69,"_51":-5,"_70":116,"_18":117},{"_33":102,"_13":103,"_37":104,"_45":46,"_35":36,"_49":105,"_62":63,"_47":106,"_17":44,"_42":43,"_40":107,"_68":69,"_51":-5,"_70":108,"_18":109},{"_33":93,"_13":94,"_37":95,"_45":46,"_35":36,"_49":96,"_62":63,"_47":97,"_17":98,"_42":43,"_40":99,"_68":69,"_51":-5,"_70":100,"_18":101},"a7384858-f426-4aa0-8568-ee27f56209f9","test-auth.ts","8d3cca82-9c09-11f1-8c4c-1607ee4eb77e",25,["D",1787172068237],7,"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",[],[53,94],"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",[],[53,103],"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",[],[53,111],["D",1787173057040],[],[53,39],"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",[],[53,122],"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",[],[53,130],"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",[],[53,139],"36dec0b5-6226-473a-9de2-0a60d87e1950","data","0ca9efc2-d8b6-4a26-880b-f9e8ea8eb099",16,["D",1787171668821],[],[147],"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,"_209":205},"org",{"_11":12,"_203":-5,"_204":205,"_163":164,"_206":207,"_208":69},"branch",{"_17":50,"_13":16,"_33":36,"_195":153,"_196":-5,"_197":-5,"_198":-5,"_199":-5,"_200":-5,"_201":14,"_202":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeTY0alNTUThEcXp4czVhYzlySDZIeFBNa1kifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":153,"_13":14,"_47":273,"_155":-5,"_156":69,"_157":158,"_159":158,"_160":161,"_162":-5,"_163":164,"_165":60,"_166":63,"_167":-5,"_168":-5,"_169":44,"_170":171,"_172":173,"_174":175,"_176":274,"_178":-5,"_179":180,"_181":180,"_182":183,"_184":183,"_185":183,"_186":180,"_187":180,"_188":275,"_190":276,"_192":277,"_194":69},[240,241,249,250],"files",[240,241,242,243,244,245,246,247,248,249,250],"counts",{"_231":44,"_232":65,"_233":44,"_32":234,"_235":236},[],{"_33":34,"_35":36,"_37":38,"_13":39,"_40":41,"_42":43,"_17":44,"_45":46,"_47":229,"_49":50,"_51":-5,"_18":230},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1787173057040],[53,39],"pulls","branches","forks",{"_237":81,"_239":44},"connections",{"_237":44,"_238":44},"count","unfilledCount","emptyCount",{"_33":146,"_13":147,"_37":148,"_45":-5,"_35":36,"_49":149,"_62":63,"_47":150,"_17":44,"_42":83,"_40":-5,"_68":69,"_51":-5,"_70":271,"_18":272},{"_33":80,"_13":53,"_37":46,"_45":-5,"_35":36,"_49":81,"_62":63,"_47":82,"_17":44,"_42":83,"_40":-5,"_68":69,"_51":-5,"_70":269,"_18":270},{"_33":138,"_13":139,"_37":140,"_45":46,"_35":36,"_49":141,"_62":63,"_47":142,"_17":44,"_42":43,"_40":143,"_68":69,"_51":-5,"_70":267,"_18":268},{"_33":129,"_13":130,"_37":131,"_45":46,"_35":36,"_49":132,"_62":63,"_47":133,"_17":134,"_42":43,"_40":135,"_68":69,"_51":-5,"_70":265,"_18":266},{"_33":121,"_13":122,"_37":123,"_45":46,"_35":36,"_49":124,"_62":63,"_47":125,"_17":44,"_42":43,"_40":126,"_68":69,"_51":-5,"_70":263,"_18":264},{"_33":34,"_13":39,"_37":38,"_45":46,"_35":36,"_49":50,"_62":63,"_47":118,"_17":44,"_42":43,"_40":41,"_68":69,"_51":-5,"_70":261,"_18":262},{"_33":110,"_13":111,"_37":112,"_45":46,"_35":36,"_49":113,"_62":63,"_47":114,"_17":44,"_42":43,"_40":115,"_68":69,"_51":-5,"_70":259,"_18":260},{"_33":102,"_13":103,"_37":104,"_45":46,"_35":36,"_49":105,"_62":63,"_47":106,"_17":44,"_42":43,"_40":107,"_68":69,"_51":-5,"_70":257,"_18":258},{"_33":93,"_13":94,"_37":95,"_45":46,"_35":36,"_49":96,"_62":63,"_47":97,"_17":98,"_42":43,"_40":99,"_68":69,"_51":-5,"_70":255,"_18":256},{"_33":73,"_13":74,"_37":75,"_45":-5,"_35":36,"_49":65,"_62":63,"_47":76,"_17":44,"_42":24,"_40":77,"_68":69,"_51":-5,"_70":253,"_18":254},{"_33":58,"_13":59,"_37":60,"_45":-5,"_35":36,"_49":61,"_62":63,"_47":64,"_17":65,"_42":66,"_40":67,"_68":69,"_51":-5,"_70":251,"_18":252},[],[59],[],[74],[],[53,94],[],[53,103],[],[53,111],[],[53,39],[],[53,122],[],[53,130],[],[53,139],[242,243,244,245,246,247,248],[53],[],[147],["D",1787169600594],["D",1789517443998],{"_11":12,"_209":205},{"_11":12,"_203":-5,"_204":205,"_163":164,"_206":207,"_208":69},{"_17":50,"_13":16,"_33":36,"_195":153,"_196":-5,"_197":-5,"_198":-5,"_199":-5,"_200":-5,"_201":14,"_202":12},"ctx",{"_188":-5,"_226":311,"_312":313,"_314":315,"_316":69,"_317":69,"_318":69,"_319":63,"_320":-5,"_321":-7,"_322":-7,"_323":44,"_324":69,"_325":69,"_326":-5,"_327":69,"_328":69,"_329":69,"_330":-5},"ENV",{"_282":283,"_284":285,"_286":16,"_287":288,"_289":290,"_291":292,"_293":294,"_295":296,"_297":298,"_299":300,"_301":302,"_303":304,"_305":306,"_307":308,"_309":310},"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"]