[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_192":193,"_194":195},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_89":-7,"_90":91,"_29":-7,"_92":-5,"_15":93,"_94":95,"_96":97,"_98":99,"_100":101,"_102":-5,"_103":-5,"_104":-5,"_105":38,"_106":107,"_108":109,"_110":-5,"_111":-5,"_112":113},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","parasbokhari1","name","pod-product-meta-sync","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":-5,"_61":62,"_63":62,"_64":65,"_66":65,"_67":65,"_68":62,"_69":62,"_70":71,"_72":73,"_74":75,"_76":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","e3233cae-1d76-11f1-b454-42dde27851f2","createdAt",["D",1773253187920],"updatedAt",["D",1778601582243],"main","projectId","e322d67e-1d76-11f1-b454-42dde27851f2","version",63,"forkedBranchId","forkedBranchVersion","lockfileKey","1778601582862-esm.town_v_parasbokhari1_pod-product-meta-sync@63-main","deletedAt",["D",1773253187920],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","imageUrl","userId","019cde20-33be-747f-aebe-b90bf02ff690","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019cde20-33be-747f-aebe-bc0944a399e3","tursoName","e322d67e1d7611f1b45442dde27851f2","tursoHostname","e322d67e1d7611f1b45442dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789520505489],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_88":84},"org",{"_11":12,"_82":-5,"_83":84,"_44":45,"_85":86,"_87":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBb0pwcUx1bXNYMFRYalY1MzZ0VUFBRTZadyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":187,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":38,"_48":-5,"_49":-5,"_50":51,"_52":53,"_54":55,"_56":57,"_58":188,"_60":-5,"_61":62,"_63":62,"_64":65,"_66":65,"_67":65,"_68":62,"_69":62,"_70":189,"_72":190,"_74":191,"_76":38},"tree",[170,171,172,173],"files",[170,171,172,173],"counts",{"_160":51,"_17":161,"_162":51,"_163":164,"_165":166},"contents",[114,115,116,117],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":152,"_13":153,"_120":154,"_122":-5,"_123":21,"_124":155,"_125":109,"_22":156,"_29":157,"_128":141,"_130":158,"_132":38,"_133":-5,"_90":159},{"_20":144,"_13":145,"_120":146,"_122":-5,"_123":21,"_124":147,"_125":109,"_22":148,"_29":149,"_128":129,"_130":150,"_132":38,"_133":-5,"_90":151},{"_20":135,"_13":136,"_120":137,"_122":-5,"_123":21,"_124":138,"_125":109,"_22":139,"_29":140,"_128":141,"_130":142,"_132":38,"_133":-5,"_90":143},{"_20":118,"_13":119,"_120":121,"_122":-5,"_123":21,"_124":30,"_125":109,"_22":126,"_29":127,"_128":129,"_130":131,"_132":38,"_133":-5,"_90":134},"96940eb0-4e1b-11f1-9ef3-ee650bb23af1","pod-variant-meta-sync.js","fileId","dff9506e-23bf-11f1-82cb-42dde27851f2","parentId","branchId","branchVersion","latest",["D",1778601582243],14,"fileType","http","content","import axios from \"npm:axios\";\nimport dotenv from \"npm:dotenv\";\n\ndotenv.config();\n\nconst HUBSPOT_API_KEY = process.env.HUBSPOT_API_KEY;\n\nconst TABLE_VARIANTS = \"200811559\";\nconst TABLE_PRODUCTS = \"195979374\";\nconst TABLE_VARIANT_META = \"218928983\";\n\nconst EXTRA_COLUMNS = [\n { name: \"product_slug\", label: \"Product Slug\", type: \"TEXT\" },\n { name: \"sku\", label: \"SKU\", type: \"TEXT\" },\n { name: \"attributes\", label: \"Attributes\", type: \"TEXT\" },\n { name: \"price\", label: \"Price\", type: \"NUMBER\" },\n { name: \"product_name\", label: \"Product Name\", type: \"TEXT\" },\n { name: \"product_category\", label: \"Product Category\", type: \"TEXT\" },\n { name: \"product_subcategory\", label: \"Product Subcategory\", type: \"TEXT\" },\n {\n name: \"product_featured_image\",\n label: \"Product Featured Image\",\n type: \"IMAGE\",\n },\n];\n\nconst hubspotApi = axios.create({\n baseURL: \"https://api.hubapi.com/cms/v3/hubdb\",\n headers: {\n Authorization: `Bearer ${HUBSPOT_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n});\n\nconst sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));\n\nasync function fetchAllRows(tableId) {\n const allRows = [];\n let after = null;\n do {\n const params = { limit: 100 };\n if (after) params.after = after;\n const response = await hubspotApi.get(`/tables/${tableId}/rows`, {\n params,\n });\n allRows.push(...(response.data.results || []));\n after = response.data.paging?.next?.after || null;\n } while (after);\n return allRows;\n}\n\nasync function fetchDraftSchema(tableId) {\n const response = await hubspotApi.get(`/tables/${tableId}/draft`);\n return response.data;\n}\n\nfunction extractForeignName(field) {\n if (!field) return \"\";\n const first = Array.isArray(field) ? field[0] : field;\n if (!first) return \"\";\n if (typeof first === \"object\") return (first?.name || \"\").replace(/_/g, \" \");\n return String(first).replace(/_/g, \" \");\n}\n\nasync function ensureExtraColumns(log) {\n const schema = await fetchDraftSchema(TABLE_VARIANT_META);\n const existingColumns = schema.columns || [];\n const existingNames = new Set(existingColumns.map((c) => c.name));\n log(`📋 Existing draft columns: ${[...existingNames].join(\", \")}`);\n\n const missingColumns = EXTRA_COLUMNS.filter((c) =>\n !existingNames.has(c.name)\n );\n if (missingColumns.length === 0) {\n log(\"✅ All extra columns already exist.\");\n return;\n }\n\n const existingDefs = existingColumns.map((col) => {\n const def = {\n id: col.id,\n name: col.name,\n label: col.label,\n type: col.type,\n };\n if (col.options) def.options = col.options;\n if (col.foreignTableId) def.foreignTableId = col.foreignTableId;\n if (col.foreignColumnId) def.foreignColumnId = col.foreignColumnId;\n return def;\n });\n\n try {\n await hubspotApi.patch(`/tables/${TABLE_VARIANT_META}/draft`, {\n columns: [...existingDefs, ...missingColumns],\n });\n missingColumns.forEach((c) => log(` ➕ Added column: ${c.name}`));\n } catch (err) {\n log(\n ` ❌ Failed to update schema: ${\n JSON.stringify(err.response?.data || err.message)\n }`,\n );\n throw err;\n }\n\n const verified = await fetchDraftSchema(TABLE_VARIANT_META);\n log(\n `✅ Draft columns confirmed: ${\n (verified.columns || []).map((c) => c.name).join(\", \")\n }`,\n );\n}\n\nasync function deleteAllDraftRows(tableId, log) {\n const rows = await fetchAllRows(tableId);\n if (rows.length === 0) {\n log(\"ℹ️ No existing rows to delete.\");\n return;\n }\n log(`🗑️ Deleting ${rows.length} existing rows...`);\n const ids = rows.map((r) => r.id);\n for (let i = 0; i < ids.length; i += 100) {\n await hubspotApi.post(`/tables/${tableId}/rows/draft/batch/purge`, {\n inputs: ids.slice(i, i + 100),\n });\n if (i + 100 < ids.length) await sleep(300);\n }\n log(\"✅ All existing rows deleted.\");\n}\n\nasync function batchCreateRows(tableId, rows, log) {\n for (let i = 0; i < rows.length; i += 100) {\n await hubspotApi.post(`/tables/${tableId}/rows/draft/batch/create`, {\n inputs: rows.slice(i, i + 100),\n });\n log(` 📝 Created rows ${i + 1}–${Math.min(i + 100, rows.length)}`);\n if (i + 100 < rows.length) await sleep(300);\n }\n}\n\nasync function publishTable(tableId) {\n await hubspotApi.post(`/tables/${tableId}/draft/publish`, {});\n}\n\nasync function main(log) {\n log(\"🚀 Starting HubDB Variant Meta sync...\");\n\n log(\"\\n🔧 Ensuring extra columns exist in Variant Meta draft...\");\n await ensureExtraColumns(log);\n\n log(\"\\n📡 Fetching Products rows...\");\n const products = await fetchAllRows(TABLE_PRODUCTS);\n log(`✅ ${products.length} products fetched.`);\n\n log(\"📡 Fetching Variants rows...\");\n const variants = await fetchAllRows(TABLE_VARIANTS);\n log(`✅ ${variants.length} variants fetched.`);\n\n const productBySlug = {};\n for (const product of products) {\n const slug = product.path;\n if (!slug) continue;\n productBySlug[slug] = product;\n }\n\n const metaRows = [];\n let skipped = 0;\n\n for (const variant of variants) {\n const slug = variant.values?.product_slug;\n if (!slug) {\n log(`⚠️ Variant ID ${variant.id} has no product_slug — skipping.`);\n skipped++;\n continue;\n }\n\n const product = productBySlug[slug];\n if (!product) {\n log(\n `⚠️ Variant ID ${variant.id} — no matching product for slug \"${slug}\" — skipping.`,\n );\n skipped++;\n continue;\n }\n\n const productName = product.values?.product_name || product.name || \"\";\n const productCategory = extractForeignName(\n product.values?.product_category,\n );\n const productSubcategory = extractForeignName(\n product.values?.product_subcategory,\n );\n const featuredImageRaw = product.values?.featured_image;\n const productFeaturedImage = featuredImageRaw?.url\n ? { url: featuredImageRaw.url, width: null, height: null, type: \"image\" }\n : null;\n\n metaRows.push({\n path: variant.path,\n name: variant.name,\n values: {\n ...variant.values,\n product_name: productName,\n product_category: productCategory,\n product_subcategory: productSubcategory,\n product_featured_image: productFeaturedImage,\n },\n });\n }\n\n log(`\\n📊 ${metaRows.length} variant meta rows built (${skipped} skipped).`);\n\n await deleteAllDraftRows(TABLE_VARIANT_META, log);\n log(`📝 Creating ${metaRows.length} new rows...`);\n await batchCreateRows(TABLE_VARIANT_META, metaRows, log);\n log(\"✅ All rows created.\");\n\n log(\"🚀 Publishing Variant Meta table...\");\n await publishTable(TABLE_VARIANT_META);\n log(\"✅ Variant Meta table published.\");\n\n log(\"\\n🎉 Sync completed successfully!\");\n}\n\n// ─────────────────────────────────────────\n// HTTP ENDPOINT\n// Ignores favicon requests to prevent double-runs when opening in browser.\n// Returns { success, logs[] } so the full run output is visible in the response.\n// ─────────────────────────────────────────\nexport default async function (req) {\n // Browsers automatically request /favicon.ico alongside the main URL —\n // short-circuit it here so it doesn't trigger a full sync.\n const url = new URL(req.url);\n if (url.pathname === \"/favicon.ico\") {\n return new Response(null, { status: 204 });\n }\n\n const logs = [];\n const log = (msg) => {\n console.log(msg);\n logs.push(msg);\n };\n\n try {\n await main(log);\n return new Response(\n JSON.stringify({ success: true, logs }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n log(`💥 Unhandled error: ${error.message}`);\n if (error.response?.data) {\n log(`Details: ${JSON.stringify(error.response.data)}`);\n }\n return new Response(\n JSON.stringify({ success: false, error: error.message, logs }, null, 2),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}","deleted","label",[119],"97360050-3a7d-11f1-9deb-42b51c65c3df","pod-sync-watcher.js","fc5b47ec-3a78-11f1-aefa-42b51c65c3df",62,["D",1776444650718],6,"interval","// Val.town cron job: pod-sync-watcher\n// Runs every 15 minutes. Checks the updatedAt timestamp of the two source\n// HubDB tables (Products and Variants). If either has been updated since the\n// last recorded timestamp in SQLite, it triggers the corresponding sync\n// endpoint and saves the new timestamp.\n//\n// Product meta sync always runs before variant meta sync.\n//\n// Environment variables required:\n// HUBSPOT_API_KEY — HubSpot Private App access token\n// POD_PRODUCT_META_SYNC_URL — HTTP endpoint URL for pod-product-meta-sync\n// POD_VARIANT_META_SYNC_URL — HTTP endpoint URL for pod-variant-meta-sync\n//\n// SQLite table used: pod_sync_state\n// CREATE TABLE IF NOT EXISTS pod_sync_state (\n// table_id TEXT PRIMARY KEY,\n// last_seen_at TEXT NOT NULL\n// );\n//\n// Rows: one per watched table ID (TABLE_PRODUCTS, TABLE_VARIANTS)\n\nimport sqlite from \"https://esm.town/v/std/sqlite@14-main/main.ts\";\nimport axios from \"npm:axios\";\n\nconst HUBSPOT_API_KEY = process.env.HUBSPOT_API_KEY;\nconst POD_PRODUCT_META_SYNC_URL = process.env.POD_PRODUCT_META_SYNC_URL;\nconst POD_VARIANT_META_SYNC_URL = process.env.POD_VARIANT_META_SYNC_URL;\n\n// The two source tables we watch for changes — order matters: product before variant\nconst TABLE_PRODUCTS = \"195979374\";\nconst TABLE_VARIANTS = \"200811559\";\n\nconst PORTAL_ID = \"39614771\";\n\nconst hubspotApi = axios.create({\n baseURL: \"https://api.hubapi.com/cms/v3/hubdb\",\n headers: {\n Authorization: `Bearer ${HUBSPOT_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n});\n\n// ─────────────────────────────────────────\n// SQLITE HELPERS\n// ─────────────────────────────────────────\n\n// Ensure pod_sync_state table exists\nasync function ensureSyncStateTable() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pod_sync_state (\n table_id TEXT PRIMARY KEY,\n last_seen_at TEXT NOT NULL\n )\n `);\n}\n\n// Get last seen timestamp for a table ID — returns null if not yet recorded\nasync function getLastSeenAt(tableId) {\n try {\n const result = await sqlite.execute(\n `SELECT last_seen_at FROM pod_sync_state WHERE table_id = ?`,\n [tableId],\n );\n const rows = Array.isArray(result) ? result : (result.rows || []);\n if (!rows.length) return null;\n return Array.isArray(rows[0]) ? rows[0][0] : rows[0].last_seen_at;\n } catch (e) {\n console.error(`❌ Failed to read last_seen_at for ${tableId}:`, e.message);\n return null;\n }\n}\n\n// Upsert last seen timestamp for a table ID\nasync function setLastSeenAt(tableId, timestamp) {\n await sqlite.execute(\n `INSERT INTO pod_sync_state (table_id, last_seen_at)\n VALUES (?, ?)\n ON CONFLICT(table_id) DO UPDATE SET last_seen_at = excluded.last_seen_at`,\n [tableId, timestamp],\n );\n}\n\n// ─────────────────────────────────────────\n// HUBSPOT HELPERS\n// ─────────────────────────────────────────\n\n// Fetch table metadata — only needs updatedAt, fetches no row data\nasync function getTableUpdatedAt(tableId) {\n const response = await hubspotApi.get(`/tables/${tableId}`, {\n params: { portalId: PORTAL_ID },\n });\n return response.data.updatedAt || null;\n}\n\n// ─────────────────────────────────────────\n// TRIGGER SYNC ENDPOINT\n// Throws on failure so the timestamp is not updated and we retry next tick\n// ─────────────────────────────────────────\nasync function triggerSync(name, url) {\n console.log(`🔁 Triggering ${name} sync...`);\n const start = Date.now();\n\n const response = await fetch(url, { method: \"GET\" });\n const data = await response.json();\n const elapsed = ((Date.now() - start) / 1000).toFixed(1);\n\n if (data.success) {\n console.log(`✅ ${name} sync completed in ${elapsed}s.`);\n } else {\n throw new Error(`${name} sync failed: ${data.error || \"unknown error\"}`);\n }\n}\n\n// ─────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────\nasync function main() {\n console.log(\"👀 pod-sync-watcher starting...\");\n\n await ensureSyncStateTable();\n\n const watched = [\n {\n tableId: TABLE_PRODUCTS,\n name: \"Products\",\n syncUrl: null, // source table only — no direct sync endpoint\n },\n {\n tableId: TABLE_VARIANTS,\n name: \"Variants\",\n syncUrl: null,\n },\n ];\n\n const syncs = [\n { name: \"Product Meta\", syncUrl: POD_PRODUCT_META_SYNC_URL },\n { name: \"Variant Meta\", syncUrl: POD_VARIANT_META_SYNC_URL },\n ];\n\n // ── Phase 1: Check both source tables for changes ────────────────────────\n // If EITHER table changed, both sync scripts run (product before variant).\n // Timestamps are tracked per source table so we correctly detect future changes.\n let anyChanged = false;\n const newTimestamps = {}; // tableId → currentUpdatedAt, saved only after successful sync\n\n for (const entry of watched) {\n const { tableId, name } = entry;\n\n let currentUpdatedAt;\n try {\n currentUpdatedAt = await getTableUpdatedAt(tableId);\n console.log(\n `📋 ${name} (${tableId}) — HubSpot updatedAt: ${currentUpdatedAt}`,\n );\n } catch (e) {\n console.error(\n `❌ Failed to fetch metadata for ${name} (${tableId}):`,\n e.message,\n );\n continue;\n }\n\n if (!currentUpdatedAt) {\n console.warn(`⚠️ No updatedAt returned for ${name} — skipping.`);\n continue;\n }\n\n const lastSeenAt = await getLastSeenAt(tableId);\n console.log(\n `📋 ${name} (${tableId}) — last seen: ${lastSeenAt || \"never\"}`,\n );\n\n if (lastSeenAt === null) {\n // First run — record timestamp, skip sync (daily cron handles initial state)\n console.log(\n `ℹ️ ${name}: first run — recording timestamp, skipping sync.`,\n );\n await setLastSeenAt(tableId, currentUpdatedAt);\n continue;\n }\n\n const currentMs = new Date(currentUpdatedAt).getTime();\n const lastSeenMs = new Date(lastSeenAt).getTime();\n\n if (currentMs <= lastSeenMs) {\n console.log(`✅ ${name}: no changes detected.`);\n } else {\n console.log(\n `🆕 ${name}: change detected (${lastSeenAt} → ${currentUpdatedAt})`,\n );\n anyChanged = true;\n }\n\n // Always store the latest timestamp so we have it ready for after the sync\n newTimestamps[tableId] = currentUpdatedAt;\n }\n\n if (!anyChanged) {\n console.log(\"✅ pod-sync-watcher finished — no syncs needed.\");\n return;\n }\n\n // ── Phase 2: Run both sync scripts in order (product always before variant) ──\n // Both run regardless of which source table changed — the meta tables\n // are derived from both sources so either change can affect either meta table.\n console.log(\"\\n🔄 Change detected — running both sync scripts...\");\n\n for (const sync of syncs) {\n await triggerSync(sync.name, sync.syncUrl);\n }\n\n // ── Phase 3: Update timestamps for all source tables now that sync succeeded ─\n for (const [tableId, timestamp] of Object.entries(newTimestamps)) {\n await setLastSeenAt(tableId, timestamp);\n console.log(`💾 ${tableId}: last_seen_at updated to ${timestamp}`);\n }\n\n console.log(\"✅ pod-sync-watcher finished.\");\n}\n\n// ─────────────────────────────────────────\n// EXPORT\n// Cron: Val.town calls default() on schedule (every 15 min)\n// ─────────────────────────────────────────\nexport default async function () {\n try {\n await main();\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n throw error;\n }\n}",[136],"71742550-3a7c-11f1-b0c6-42b51c65c3df","pod-product-meta-sync.js","e33628f0-1d76-11f1-b454-42dde27851f2",60,["D",1776444157868],28,"import axios from \"npm:axios\";\nimport dotenv from \"npm:dotenv\";\n\ndotenv.config();\n\nconst HUBSPOT_API_KEY = process.env.HUBSPOT_API_KEY;\n\nconst TABLE_PRODUCTS = \"195979374\";\nconst TABLE_VARIANTS = \"200811559\";\nconst TABLE_PRODUCT_META = \"207223650\";\n\nconst EXTRA_COLUMNS = [\n { name: \"product_slug\", label: \"Product Slug\", type: \"TEXT\" },\n { name: \"variant_count\", label: \"Variant Count\", type: \"NUMBER\" },\n { name: \"lowest_price\", label: \"Lowest Price\", type: \"NUMBER\" },\n { name: \"highest_price\", label: \"Highest Price\", type: \"NUMBER\" },\n { name: \"available_attributes\", label: \"Available Attributes\", type: \"TEXT\" },\n { name: \"search_index\", label: \"Search Index\", type: \"TEXT\" },\n];\n\nconst sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));\n\nconst hubspotApi = axios.create({\n baseURL: \"https://api.hubapi.com/cms/v3/hubdb\",\n headers: {\n Authorization: `Bearer ${HUBSPOT_API_KEY}`,\n \"Content-Type\": \"application/json\",\n },\n});\n\nasync function fetchAllRows(tableId) {\n const allRows = [];\n let after = null;\n do {\n const params = { limit: 100 };\n if (after) params.after = after;\n const response = await hubspotApi.get(`/tables/${tableId}/rows`, {\n params,\n });\n allRows.push(...(response.data.results || []));\n after = response.data.paging?.next?.after || null;\n } while (after);\n return allRows;\n}\n\nasync function fetchDraftSchema(tableId) {\n const response = await hubspotApi.get(`/tables/${tableId}/draft`);\n return response.data;\n}\n\nasync function ensureExtraColumns(log) {\n const schema = await fetchDraftSchema(TABLE_PRODUCT_META);\n const existingColumns = schema.columns || [];\n const existingNames = new Set(existingColumns.map((c) => c.name));\n log(`📋 Existing draft columns: ${[...existingNames].join(\", \")}`);\n\n const missingColumns = EXTRA_COLUMNS.filter((c) =>\n !existingNames.has(c.name)\n );\n if (missingColumns.length === 0) {\n log(\"✅ All extra columns already exist.\");\n return;\n }\n\n const existingDefs = existingColumns.map((col) => {\n const def = {\n id: col.id,\n name: col.name,\n label: col.label,\n type: col.type,\n };\n if (col.options) def.options = col.options;\n if (col.foreignTableId) def.foreignTableId = col.foreignTableId;\n if (col.foreignColumnId) def.foreignColumnId = col.foreignColumnId;\n return def;\n });\n\n try {\n await hubspotApi.patch(`/tables/${TABLE_PRODUCT_META}/draft`, {\n columns: [...existingDefs, ...missingColumns],\n });\n missingColumns.forEach((c) => log(` ➕ Added column: ${c.name}`));\n } catch (err) {\n log(\n ` ❌ Failed to update schema: ${\n JSON.stringify(err.response?.data || err.message)\n }`,\n );\n throw err;\n }\n\n const verified = await fetchDraftSchema(TABLE_PRODUCT_META);\n log(\n `✅ Draft columns confirmed: ${\n (verified.columns || []).map((c) => c.name).join(\", \")\n }`,\n );\n}\n\nasync function deleteAllDraftRows(tableId, log) {\n const rows = await fetchAllRows(tableId);\n if (rows.length === 0) {\n log(\"ℹ️ No existing rows to delete.\");\n return;\n }\n log(`🗑️ Deleting ${rows.length} existing rows...`);\n const ids = rows.map((r) => r.id);\n for (let i = 0; i < ids.length; i += 100) {\n await hubspotApi.post(`/tables/${tableId}/rows/draft/batch/purge`, {\n inputs: ids.slice(i, i + 100),\n });\n if (i + 100 < ids.length) await sleep(300);\n }\n log(\"✅ All existing rows deleted.\");\n}\n\nasync function batchCreateRows(tableId, rows, log) {\n for (let i = 0; i < rows.length; i += 100) {\n await hubspotApi.post(`/tables/${tableId}/rows/draft/batch/create`, {\n inputs: rows.slice(i, i + 100),\n });\n log(` 📝 Created rows ${i + 1}–${Math.min(i + 100, rows.length)}`);\n if (i + 100 < rows.length) await sleep(300);\n }\n}\n\nasync function publishTable(tableId) {\n await hubspotApi.post(`/tables/${tableId}/draft/publish`, {});\n}\n\nasync function main(log) {\n log(\"🚀 Starting HubDB Product Meta full sync...\");\n\n log(\"\\n🔧 Ensuring extra columns exist in Product Meta draft...\");\n await ensureExtraColumns(log);\n\n log(\"\\n📡 Fetching Products rows...\");\n const products = await fetchAllRows(TABLE_PRODUCTS);\n log(`✅ ${products.length} products fetched.`);\n\n log(\"📡 Fetching Product Variants rows...\");\n const variants = await fetchAllRows(TABLE_VARIANTS);\n log(`✅ ${variants.length} variants fetched.`);\n\n const variantsBySlug = {};\n for (const variant of variants) {\n const slug = variant.values?.product_slug;\n if (!slug) continue;\n if (!variantsBySlug[slug]) variantsBySlug[slug] = [];\n variantsBySlug[slug].push(variant);\n }\n\n const metaRows = [];\n for (const product of products) {\n const slug = product.path;\n if (!slug) {\n log(`⚠️ Product ID ${product.id} has no path — skipping.`);\n continue;\n }\n\n const matchedVariants = variantsBySlug[slug] || [];\n const prices = matchedVariants\n .map((v) => parseFloat(v.values?.price))\n .filter((p) => !isNaN(p));\n\n let lowestPrice = 0;\n let highestPrice = 0;\n if (prices.length > 0) {\n lowestPrice = prices.reduce((a, b) => Math.min(a, b), prices[0]);\n highestPrice = prices.reduce((a, b) => Math.max(a, b), prices[0]);\n }\n\n const attributeSet = new Set();\n for (const v of matchedVariants) {\n const attrs = v.values?.attributes;\n if (!attrs) continue;\n for (const attr of attrs.split(\"|\")) {\n const trimmed = attr.trim();\n if (trimmed) attributeSet.add(trimmed);\n }\n }\n const availableAttributes = [...attributeSet].join(\"|\");\n\n const attributeValues = [...attributeSet]\n .map((attr) => {\n const colonIdx = attr.indexOf(\":\");\n return colonIdx !== -1 ? attr.slice(colonIdx + 1).trim() : attr.trim();\n })\n .join(\" \");\n\n const extractForeignNames = (field) => {\n if (!field) return \"\";\n if (Array.isArray(field)) {\n return field.map((f) => (f?.name || \"\").replace(/_/g, \" \")).join(\" \");\n }\n if (typeof field === \"object\") {\n return (field?.name || \"\").replace(/_/g, \" \");\n }\n return String(field).replace(/_/g, \" \");\n };\n\n const rawSearchText = [\n product.values?.product_name || \"\",\n product.values?.product_description || \"\",\n product.values?.meta_description || \"\",\n extractForeignNames(product.values?.product_category),\n extractForeignNames(product.values?.product_subcategory),\n product.path || \"\",\n attributeValues,\n ]\n .join(\" \")\n .toLowerCase()\n .replace(/<[^>]*>/g, \" \")\n .replace(/_/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n\n const searchIndex = [...new Set(rawSearchText.split(\" \").filter(Boolean))]\n .join(\" \");\n\n metaRows.push({\n path: product.path,\n name: product.name,\n values: {\n ...product.values,\n product_slug: product.path,\n variant_count: matchedVariants.length,\n lowest_price: lowestPrice,\n highest_price: highestPrice,\n available_attributes: availableAttributes,\n search_index: searchIndex,\n },\n });\n\n log(\n ` ✔ \"${slug}\": ${matchedVariants.length} variants, $${lowestPrice} – $${highestPrice}`,\n );\n }\n\n log(`\\n📊 ${metaRows.length} rows ready to write.`);\n\n await deleteAllDraftRows(TABLE_PRODUCT_META, log);\n log(`📝 Creating ${metaRows.length} new rows...`);\n await batchCreateRows(TABLE_PRODUCT_META, metaRows, log);\n log(\"✅ All rows created.\");\n\n log(\"🚀 Publishing Product Meta table...\");\n await publishTable(TABLE_PRODUCT_META);\n log(\"✅ Product Meta table published.\");\n\n log(\"\\n🎉 Sync completed successfully!\");\n}\n\n// ─────────────────────────────────────────\n// HTTP ENDPOINT\n// Ignores favicon requests to prevent double-runs when opening in browser.\n// Returns { success, logs[] } so the full run output is visible in the response.\n// ─────────────────────────────────────────\nexport default async function (req) {\n // Browsers automatically request /favicon.ico alongside the main URL —\n // short-circuit it here so it doesn't trigger a full sync.\n const url = new URL(req.url);\n if (url.pathname === \"/favicon.ico\") {\n return new Response(null, { status: 204 });\n }\n\n const logs = [];\n const log = (msg) => {\n console.log(msg);\n logs.push(msg);\n };\n\n try {\n await main(log);\n return new Response(\n JSON.stringify({ success: true, logs }, null, 2),\n { status: 200, headers: { \"Content-Type\": \"application/json\" } },\n );\n } catch (error) {\n log(`💥 Unhandled error: ${error.message}`);\n if (error.response?.data) {\n log(`Details: ${JSON.stringify(error.response.data)}`);\n }\n return new Response(\n JSON.stringify({ success: false, error: error.message, logs }, null, 2),\n { status: 500, headers: { \"Content-Type\": \"application/json\" } },\n );\n }\n}",[145],"58b23ef4-3a7b-11f1-bc9a-42b51c65c3df","pod-daily-sync.js","49bc21da-3a7b-11f1-9c18-42b51c65c3df",57,["D",1776443686850],3,"// Val.town cron job: pod-daily-sync\n// Calls the product meta sync endpoint first, waits for it to complete,\n// then calls the variant meta sync endpoint.\n//\n// Set this val's cron schedule to your preferred daily time (e.g. 3pm CT).\n//\n// Environment variables required:\n// POD_PRODUCT_META_SYNC_URL — HTTP endpoint URL for pod-product-meta-sync\n// POD_VARIANT_META_SYNC_URL — HTTP endpoint URL for pod-variant-meta-sync\n\nconst POD_PRODUCT_META_SYNC_URL = process.env.POD_PRODUCT_META_SYNC_URL;\nconst POD_VARIANT_META_SYNC_URL = process.env.POD_VARIANT_META_SYNC_URL;\n\nasync function triggerSync(name, url) {\n console.log(`\\n🔁 Triggering ${name} sync...`);\n const start = Date.now();\n\n const response = await fetch(url, { method: \"GET\" });\n const data = await response.json();\n const elapsed = ((Date.now() - start) / 1000).toFixed(1);\n\n if (data.success) {\n console.log(`✅ ${name} sync completed in ${elapsed}s.`);\n } else {\n throw new Error(`${name} sync failed: ${data.error || \"unknown error\"}`);\n }\n}\n\nasync function main() {\n console.log(\"🚀 Starting pod daily sync...\");\n\n // Step 1: Product meta sync — must complete before variant meta runs\n await triggerSync(\"Product Meta\", POD_PRODUCT_META_SYNC_URL);\n\n // Step 2: Variant meta sync\n await triggerSync(\"Variant Meta\", POD_VARIANT_META_SYNC_URL);\n\n console.log(\"\\n🎉 Daily sync completed successfully!\");\n}\n\nexport default async function () {\n try {\n await main();\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n throw error;\n }\n}",[153],"pulls",1,"forks","envVars",{"_167":157,"_169":51},"connections",{"_167":51,"_168":51},"count","unfilledCount","emptyCount",{"_20":152,"_13":153,"_120":154,"_122":-5,"_123":21,"_124":155,"_125":109,"_22":184,"_29":157,"_128":141,"_130":158,"_132":38,"_133":-5,"_175":185,"_90":186},{"_20":144,"_13":145,"_120":146,"_122":-5,"_123":21,"_124":147,"_125":109,"_22":181,"_29":149,"_128":129,"_130":150,"_132":38,"_133":-5,"_175":182,"_90":183},{"_20":135,"_13":136,"_120":137,"_122":-5,"_123":21,"_124":138,"_125":109,"_22":178,"_29":140,"_128":141,"_130":142,"_132":38,"_133":-5,"_175":179,"_90":180},{"_20":118,"_13":119,"_120":121,"_122":-5,"_123":21,"_124":30,"_125":109,"_22":174,"_29":127,"_128":129,"_130":131,"_132":38,"_133":-5,"_175":176,"_90":177},["D",1778601582243],"children",[],[119],["D",1776444650718],[],[136],["D",1776444157868],[],[145],["D",1776443686850],[],[153],["D",1773253187920],["D",1789520505489],{"_11":12,"_88":84},{"_11":12,"_82":-5,"_83":84,"_44":45,"_85":86,"_87":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"ctx",{"_70":-5,"_111":225,"_226":227,"_228":229,"_230":38,"_231":38,"_232":38,"_233":109,"_234":-5,"_235":-7,"_236":-7,"_237":51,"_238":38,"_239":38,"_240":-5,"_241":38,"_242":38,"_243":38,"_244":-5},"ENV",{"_196":197,"_198":199,"_200":26,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216,"_217":218,"_219":220,"_221":222,"_223":224},"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"]

Branches1

Branches
1