[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_255":256,"_257":258},"routes/_app.x.$handle.$name",{"_98":97,"_31":44,"_106":88,"_26":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":24,"_121":122,"_123":58,"_124":-5,"_125":-5,"_126":127},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",30,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","scripts/find-duplicate-candidates.ts","latestPath","fileId","9bae891e-9c10-11f1-82b8-1607ee4eb77e","name","find-duplicate-candidates.ts","fileType","script","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","createdAt",["D",1787173057040],"branchVersion","branchId","f064a77f-da10-40b1-b2c8-85400a044673","id","7615b982-4ecc-4be8-ba7a-c3d6aed0dd32","design-database",["D",1787169600594],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Offline design DB for Grey and Slate catalog","imageUrl","442cb420-422c-11f0-bbe8-8f3f0ddc6612","pinnedFileId","0a7ef8ee-9c0a-11f1-bbe1-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"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",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":54,"_102":103,"_104":24},"branch",{"_13":14,"_31":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","cschick","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yeTY0alNTUThEcXp4czVhYzlySDZIeFBNa1kifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_42":43,"_31":44,"_37":250,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":251,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":252,"_83":253,"_85":254,"_87":24},"tree",[172,173,181,182],"files",[172,173,174,175,176,177,178,179,180,181,182],"counts",{"_162":62,"_163":138,"_164":62,"_165":166,"_167":168},"contents",[128,129,130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":156,"_31":157,"_29":158,"_134":-5,"_40":41,"_39":159,"_136":58,"_37":160,"_13":62,"_33":154,"_35":-5,"_23":24,"_141":-5,"_26":161},{"_42":149,"_31":150,"_29":151,"_134":-5,"_40":41,"_39":152,"_136":58,"_37":153,"_13":62,"_33":154,"_35":-5,"_23":24,"_141":-5,"_26":155},{"_42":143,"_31":144,"_29":145,"_134":-5,"_40":41,"_39":138,"_136":58,"_37":146,"_13":62,"_33":20,"_35":147,"_23":24,"_141":-5,"_26":148},{"_42":132,"_31":133,"_29":56,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":137,"_13":138,"_33":139,"_35":140,"_23":24,"_141":-5,"_26":142},"c7c45ced-578e-46c5-9bea-3a0d534ed67d","etsy-oauth.http.ts","parentId",12,"latest",["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","label",[133],"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",[144],"049c06f1-1fee-48a6-af1b-51f502283359","scripts","c47c07c1-2003-4f8b-8e73-b94386f5691d",2,["D",1787170026306],"directory",[150],"36dec0b5-6226-473a-9de2-0a60d87e1950","data","0ca9efc2-d8b6-4a26-880b-f9e8ea8eb099",16,["D",1787171668821],[157],"pulls","branches","forks","envVars",{"_169":152,"_171":62},"connections",{"_169":62,"_170":62},"count","unfilledCount","emptyCount",{"_42":156,"_31":157,"_29":158,"_134":-5,"_40":41,"_39":159,"_136":58,"_37":247,"_13":62,"_33":154,"_35":-5,"_23":24,"_141":-5,"_184":248,"_26":249},{"_42":149,"_31":150,"_29":151,"_134":-5,"_40":41,"_39":152,"_136":58,"_37":244,"_13":62,"_33":154,"_35":-5,"_23":24,"_141":-5,"_184":245,"_26":246},{"_42":236,"_31":237,"_29":238,"_134":151,"_40":41,"_39":239,"_136":58,"_37":240,"_13":62,"_33":34,"_35":241,"_23":24,"_141":-5,"_184":242,"_26":243},{"_42":227,"_31":228,"_29":229,"_134":151,"_40":41,"_39":230,"_136":58,"_37":231,"_13":232,"_33":34,"_35":233,"_23":24,"_141":-5,"_184":234,"_26":235},{"_42":219,"_31":220,"_29":221,"_134":151,"_40":41,"_39":222,"_136":58,"_37":223,"_13":62,"_33":34,"_35":224,"_23":24,"_141":-5,"_184":225,"_26":226},{"_42":215,"_31":32,"_29":30,"_134":151,"_40":41,"_39":14,"_136":58,"_37":216,"_13":62,"_33":34,"_35":36,"_23":24,"_141":-5,"_184":217,"_26":218},{"_42":207,"_31":208,"_29":209,"_134":151,"_40":41,"_39":210,"_136":58,"_37":211,"_13":62,"_33":34,"_35":212,"_23":24,"_141":-5,"_184":213,"_26":214},{"_42":199,"_31":200,"_29":201,"_134":151,"_40":41,"_39":202,"_136":58,"_37":203,"_13":62,"_33":34,"_35":204,"_23":24,"_141":-5,"_184":205,"_26":206},{"_42":190,"_31":191,"_29":192,"_134":151,"_40":41,"_39":193,"_136":58,"_37":194,"_13":195,"_33":34,"_35":196,"_23":24,"_141":-5,"_184":197,"_26":198},{"_42":143,"_31":144,"_29":145,"_134":-5,"_40":41,"_39":138,"_136":58,"_37":187,"_13":62,"_33":20,"_35":147,"_23":24,"_141":-5,"_184":188,"_26":189},{"_42":132,"_31":133,"_29":56,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":183,"_13":138,"_33":139,"_35":140,"_23":24,"_141":-5,"_184":185,"_26":186},["D",1787170454916],"children",[],[133],["D",1787169600642],[],[144],"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",[],[150,191],"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",[],[150,200],"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",[],[150,208],"2ac99863-7bdf-4332-b8f1-6f593c6e8c9d",["D",1787173057040],[],[150,32],"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",[],[150,220],"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",[],[150,228],"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",[],[150,237],["D",1787170026306],[174,175,176,177,178,179,180],[150],["D",1787171668821],[],[157],["D",1787169600594],["D",1789517443998],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":54,"_102":103,"_104":24},{"_13":14,"_31":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_81":-5,"_125":288,"_289":290,"_291":292,"_293":24,"_294":24,"_295":24,"_296":58,"_297":-5,"_298":-7,"_299":-7,"_300":62,"_301":24,"_302":24,"_303":-5,"_304":24,"_305":24,"_306":24,"_307":-5},"ENV",{"_259":260,"_261":262,"_263":88,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v30