[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_184":185,"_186":187},"routes/_app.x.$handle.$name",{"_97":96,"_32":45,"_105":87,"_27":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":25,"_120":121,"_122":123,"_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",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":25},"version",52,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","pod-product-meta-sync.js","latestPath","fileId","e33628f0-1d76-11f1-b454-42dde27851f2","name","fileType","interval","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_PRODUCTS = \"195979374\";\nconst TABLE_VARIANTS = \"200811559\";\nconst TABLE_PRODUCT_META = \"207223650\";\n\n// -----------------------------------------------------------------------\n// Extra columns to add to Product Meta (in addition to all Products cols)\n// Add more here as needed — they will be created if they don't exist yet\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\n// Small delay to avoid hitting HubSpot API rate limits\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\n// Fetch all rows from a table (handles pagination)\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\n// Fetch draft table schema (columns)\nasync function fetchDraftSchema(tableId) {\n const response = await hubspotApi.get(`/tables/${tableId}/draft`);\n return response.data;\n}\n\n// Ensure EXTRA_COLUMNS exist in the Product Meta draft table\nasync function ensureExtraColumns() {\n const schema = await fetchDraftSchema(TABLE_PRODUCT_META);\n const existingColumns = schema.columns || [];\n const existingNames = new Set(existingColumns.map((c) => c.name));\n console.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 console.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 const allColumns = [...existingDefs, ...missingColumns];\n\n try {\n await hubspotApi.patch(`/tables/${TABLE_PRODUCT_META}/draft`, {\n columns: allColumns,\n });\n missingColumns.forEach((c) => console.log(` ➕ Added column: ${c.name}`));\n } catch (err) {\n console.error(\n \" ❌ Failed to update schema:\",\n JSON.stringify(err.response?.data || err.message),\n );\n throw err;\n }\n\n const verified = await fetchDraftSchema(TABLE_PRODUCT_META);\n const verifiedNames = (verified.columns || []).map((c) => c.name);\n console.log(`✅ Draft columns confirmed: ${verifiedNames.join(\", \")}`);\n}\n\n// Batch delete all draft rows (100 at a time)\nasync function deleteAllDraftRows(tableId) {\n const rows = await fetchAllRows(tableId);\n if (rows.length === 0) {\n console.log(\"ℹ️ No existing rows to delete.\");\n return;\n }\n console.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 const batch = ids.slice(i, i + 100);\n await hubspotApi.post(\n `/tables/${tableId}/rows/draft/batch/purge`,\n { inputs: batch },\n );\n if (i + 100 < ids.length) await sleep(300);\n }\n console.log(\"✅ All existing rows deleted.\");\n}\n\n// Batch create rows (100 at a time)\nasync function batchCreateRows(tableId, rows) {\n for (let i = 0; i < rows.length; i += 100) {\n const batch = rows.slice(i, i + 100);\n await hubspotApi.post(\n `/tables/${tableId}/rows/draft/batch/create`,\n { inputs: batch },\n );\n console.log(` 📝 Created rows ${i + 1}–${Math.min(i + 100, rows.length)}`);\n if (i + 100 < rows.length) await sleep(300);\n }\n}\n\n// Publish a HubDB table draft\nasync function publishTable(tableId) {\n await hubspotApi.post(`/tables/${tableId}/draft/publish`, {});\n}\n\nasync function main() {\n console.log(\"🚀 Starting HubDB Product Meta full sync...\");\n\n console.log(\"\\n🔧 Ensuring extra columns exist in Product Meta draft...\");\n await ensureExtraColumns();\n\n console.log(\"\\n📡 Fetching Products rows...\");\n const products = await fetchAllRows(TABLE_PRODUCTS);\n console.log(`✅ ${products.length} products fetched.`);\n\n console.log(\"📡 Fetching Product Variants rows...\");\n const variants = await fetchAllRows(TABLE_VARIANTS);\n console.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 console.warn(`⚠️ 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[0];\n highestPrice = prices[0];\n for (const p of prices) {\n if (p < lowestPrice) lowestPrice = p;\n if (p > highestPrice) highestPrice = p;\n }\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 categoryText = extractForeignNames(product.values?.product_category);\n const subcategoryText = extractForeignNames(\n product.values?.product_subcategory,\n );\n\n const rawSearchText = [\n product.values?.product_name || \"\",\n product.values?.product_description || \"\",\n product.values?.meta_description || \"\",\n categoryText,\n subcategoryText,\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 uniqueWords = [...new Set(rawSearchText.split(\" \").filter(Boolean))];\n const searchIndex = uniqueWords.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 console.log(\n ` ✔ \"${slug}\": ${matchedVariants.length} variants, $${lowestPrice} – $${highestPrice}`,\n );\n }\n\n console.log(`\\n📊 ${metaRows.length} rows ready to write.`);\n\n await deleteAllDraftRows(TABLE_PRODUCT_META);\n console.log(`📝 Creating ${metaRows.length} new rows...`);\n await batchCreateRows(TABLE_PRODUCT_META, metaRows);\n console.log(\"✅ All rows created.\");\n\n console.log(\"🚀 Publishing Product Meta table...\");\n await publishTable(TABLE_PRODUCT_META);\n console.log(\"✅ Product Meta table published.\");\n\n console.log(\"\\n🎉 Sync completed successfully!\");\n}\n\n// ─────────────────────────────────────────\n// EXPORTS\n// Cron: Val.town calls cron() on schedule\n// HTTP: Val.town calls default() when endpoint is hit via URL\n// Both call the same main() — no logic changes\n// ─────────────────────────────────────────\nexport const cron = async () => {\n try {\n await main();\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n if (error.response?.data) {\n console.error(\"Details:\", JSON.stringify(error.response.data, null, 2));\n }\n throw error;\n }\n};\n\nexport default async function (req) {\n try {\n await main();\n return new Response(\n JSON.stringify({\n success: true,\n message: \"Product meta sync completed.\",\n }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n return new Response(\n JSON.stringify({ success: false, error: error.message }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n}","script","createdAt",["D",1776443360523],"branchVersion","branchId","e3233cae-1d76-11f1-b454-42dde27851f2","id","e322d67e-1d76-11f1-b454-42dde27851f2","pod-product-meta-sync",["D",1773253187920],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","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",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",63,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","parasbokhari1","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNBb0pwcUx1bXNYMFRYalY1MzZ0VUFBRTZadyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":179,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":180,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":181,"_81":182,"_83":183,"_85":25},"tree",[166,167,168],"files",[166,167,168],"counts",{"_155":60,"_156":157,"_158":60,"_159":160,"_161":162},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":151,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":152,"_13":153,"_33":37,"_35":36,"_24":25,"_141":-5,"_27":154},{"_43":143,"_32":144,"_30":145,"_134":-5,"_41":42,"_40":146,"_136":25,"_38":147,"_13":148,"_33":34,"_35":149,"_24":25,"_141":-5,"_27":150},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":137,"_13":138,"_33":139,"_35":140,"_24":25,"_141":-5,"_27":142},"8db8d6e0-3a7a-11f1-8898-42b51c65c3df","pod-variant-meta-sync.js","dff9506e-23bf-11f1-82cb-42dde27851f2","parentId",51,"latest",["D",1776443346307],12,"http","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\n// -----------------------------------------------------------------------\n// Extra columns to add to Variant Meta (pulled from Products table)\n// Add more here as needed — they will be created if they don't exist yet\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\n// Small delay to avoid hitting HubSpot API rate limits\nconst sleep = (ms) => new Promise((resolve) => setTimeout(resolve, ms));\n\n// Fetch all rows from a table (handles pagination)\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\n// Fetch draft table schema\nasync function fetchDraftSchema(tableId) {\n const response = await hubspotApi.get(`/tables/${tableId}/draft`);\n return response.data;\n}\n\n// Extract name from a foreign key field (single object or array)\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\n// Ensure EXTRA_COLUMNS exist in the Variant Meta draft table\nasync function ensureExtraColumns() {\n const schema = await fetchDraftSchema(TABLE_VARIANT_META);\n const existingColumns = schema.columns || [];\n const existingNames = new Set(existingColumns.map((c) => c.name));\n console.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 console.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 const allColumns = [...existingDefs, ...missingColumns];\n\n try {\n await hubspotApi.patch(`/tables/${TABLE_VARIANT_META}/draft`, {\n columns: allColumns,\n });\n missingColumns.forEach((c) => console.log(` ➕ Added column: ${c.name}`));\n } catch (err) {\n console.error(\n \" ❌ Failed to update schema:\",\n JSON.stringify(err.response?.data || err.message),\n );\n throw err;\n }\n\n const verified = await fetchDraftSchema(TABLE_VARIANT_META);\n const verifiedNames = (verified.columns || []).map((c) => c.name);\n console.log(`✅ Draft columns confirmed: ${verifiedNames.join(\", \")}`);\n}\n\n// Batch delete all draft rows (100 at a time)\nasync function deleteAllDraftRows(tableId) {\n const rows = await fetchAllRows(tableId);\n if (rows.length === 0) {\n console.log(\"ℹ️ No existing rows to delete.\");\n return;\n }\n console.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 const batch = ids.slice(i, i + 100);\n await hubspotApi.post(\n `/tables/${tableId}/rows/draft/batch/purge`,\n { inputs: batch },\n );\n if (i + 100 < ids.length) await sleep(300);\n }\n console.log(\"✅ All existing rows deleted.\");\n}\n\n// Batch create rows (100 at a time)\nasync function batchCreateRows(tableId, rows) {\n for (let i = 0; i < rows.length; i += 100) {\n const batch = rows.slice(i, i + 100);\n await hubspotApi.post(\n `/tables/${tableId}/rows/draft/batch/create`,\n { inputs: batch },\n );\n console.log(` 📝 Created rows ${i + 1}–${Math.min(i + 100, rows.length)}`);\n if (i + 100 < rows.length) await sleep(300);\n }\n}\n\n// Publish a HubDB table draft\nasync function publishTable(tableId) {\n await hubspotApi.post(`/tables/${tableId}/draft/publish`, {});\n}\n\nasync function main() {\n console.log(\"🚀 Starting HubDB Variant Meta sync...\");\n\n console.log(\"\\n🔧 Ensuring extra columns exist in Variant Meta draft...\");\n await ensureExtraColumns();\n\n console.log(\"\\n📡 Fetching Products rows...\");\n const products = await fetchAllRows(TABLE_PRODUCTS);\n console.log(`✅ ${products.length} products fetched.`);\n\n console.log(\"📡 Fetching Variants rows...\");\n const variants = await fetchAllRows(TABLE_VARIANTS);\n console.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 console.warn(\n `⚠️ Variant ID ${variant.id} has no product_slug — skipping.`,\n );\n skipped++;\n continue;\n }\n\n const product = productBySlug[slug];\n if (!product) {\n console.warn(\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 console.log(\n `\\n📊 ${metaRows.length} variant meta rows built (${skipped} skipped).`,\n );\n\n await deleteAllDraftRows(TABLE_VARIANT_META);\n console.log(`📝 Creating ${metaRows.length} new rows...`);\n await batchCreateRows(TABLE_VARIANT_META, metaRows);\n console.log(\"✅ All rows created.\");\n\n console.log(\"🚀 Publishing Variant Meta table...\");\n await publishTable(TABLE_VARIANT_META);\n console.log(\"✅ Variant Meta table published.\");\n\n console.log(\"\\n🎉 Sync completed successfully!\");\n}\n\n// ─────────────────────────────────────────\n// EXPORTS\n// Cron: Val.town calls cron() on schedule\n// HTTP: Val.town calls default() when endpoint is hit via URL\n// Both call the same main() — no logic changes\n// ─────────────────────────────────────────\nexport const cron = async () => {\n try {\n await main();\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n if (error.response?.data) {\n console.error(\"Details:\", JSON.stringify(error.response.data, null, 2));\n }\n throw error;\n }\n};\n\nexport default async function (req) {\n try {\n await main();\n return new Response(\n JSON.stringify({\n success: true,\n message: \"Variant meta sync completed.\",\n }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n return new Response(\n JSON.stringify({ success: false, error: error.message }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n}","label",[132],"196d86e2-3a79-11f1-afdd-42b51c65c3df","pod-sync-watcher.js","fc5b47ec-3a78-11f1-aefa-42b51c65c3df",47,["D",1776442721712],3,"// 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// 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\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 // Row may be array or object\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 — we only need updatedAt, this 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; // ISO string e.g. \"2026-04-17T14:32:00.000Z\"\n}\n\n// ─────────────────────────────────────────\n// TRIGGER SYNC ENDPOINT\n// ─────────────────────────────────────────\nasync function triggerSync(name, url) {\n console.log(`🔁 Triggering ${name} sync at ${url}...`);\n try {\n const response = await fetch(url, { method: \"GET\" });\n const data = await response.json();\n if (data.success) {\n console.log(`✅ ${name} sync triggered successfully.`);\n } else {\n console.error(\n `❌ ${name} sync returned failure:`,\n data.error || \"unknown error\",\n );\n }\n } catch (e) {\n console.error(`❌ Failed to trigger ${name} sync:`, e.message);\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: \"Product Meta\",\n syncUrl: POD_PRODUCT_META_SYNC_URL,\n },\n {\n tableId: TABLE_VARIANTS,\n name: \"Variant Meta\",\n syncUrl: POD_VARIANT_META_SYNC_URL,\n },\n ];\n\n for (const entry of watched) {\n const { tableId, name, syncUrl } = entry;\n\n // Step 1: Fetch current updatedAt from HubSpot (lightweight — no row data)\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; // skip this table, try the next one\n }\n\n if (!currentUpdatedAt) {\n console.warn(`⚠️ No updatedAt returned for ${name} — skipping.`);\n continue;\n }\n\n // Step 2: Compare against last recorded timestamp\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 the timestamp but don't trigger a sync\n // (the daily cron handles the 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 continue;\n }\n\n // Step 3: Table was updated — trigger the sync\n console.log(\n `🆕 ${name}: change detected (${lastSeenAt} → ${currentUpdatedAt})`,\n );\n await triggerSync(name, syncUrl);\n\n // Step 4: Update the recorded timestamp only after triggering\n // If triggerSync throws, we intentionally don't update so we retry next tick\n await setLastSeenAt(tableId, currentUpdatedAt);\n console.log(`💾 ${name}: last_seen_at updated to ${currentUpdatedAt}`);\n }\n\n console.log(\"✅ pod-sync-watcher finished.\");\n}\n\n// ─────────────────────────────────────────\n// EXPORTS\n// Cron: Val.town calls cron() on schedule (every 15 min)\n// ─────────────────────────────────────────\nexport const cron = async () => {\n try {\n await main();\n } catch (error) {\n console.error(\"💥 Unhandled error:\", error.message);\n throw error;\n }\n};\n\nexport default cron;",[144],"9631a842-3a7a-11f1-a035-42b51c65c3df",["D",1776443360523],26,[28],"pulls","branches",1,"forks","envVars",{"_163":148,"_165":60},"connections",{"_163":60,"_164":60},"count","unfilledCount","emptyCount",{"_43":151,"_32":28,"_30":31,"_134":-5,"_41":42,"_40":14,"_136":25,"_38":176,"_13":153,"_33":37,"_35":36,"_24":25,"_141":-5,"_170":177,"_27":178},{"_43":143,"_32":144,"_30":145,"_134":-5,"_41":42,"_40":146,"_136":25,"_38":173,"_13":148,"_33":34,"_35":149,"_24":25,"_141":-5,"_170":174,"_27":175},{"_43":131,"_32":132,"_30":133,"_134":-5,"_41":42,"_40":135,"_136":25,"_38":169,"_13":138,"_33":139,"_35":140,"_24":25,"_141":-5,"_170":171,"_27":172},["D",1776443346307],"children",[],[132],["D",1776442721712],[],[144],["D",1776443360523],[],[28],["D",1773253187920],["D",1789520505489],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":54,"_101":102,"_103":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_125":217,"_218":219,"_220":221,"_222":25,"_223":25,"_224":25,"_225":123,"_226":-5,"_227":-7,"_228":-7,"_229":60,"_230":25,"_231":25,"_232":-5,"_233":25,"_234":25,"_235":25,"_236":-5},"ENV",{"_188":189,"_190":191,"_192":87,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212,"_213":214,"_215":216},"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 · v52