[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_170":171,"_172":173},"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":25,"_123":-5,"_124":-5,"_125":126},"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",41,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","pod-variant-meta-sync.js","latestPath","fileId","dff9506e-23bf-11f1-82cb-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_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 // Base variant columns (copied from Variants table)\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 // Enriched columns from Products table\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 if (Array.isArray(field)) {\n return field.map((f) => (f?.name || \"\").replace(/_/g, \" \")).join(\", \");\n }\n if (typeof field === \"object\") return (field?.name || \"\").replace(/_/g, \" \");\n return String(field).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 // Build full column list: existing (with their ids) + new ones\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 // Re-fetch to confirm\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 // Step 1: Ensure extra columns exist in draft\n console.log(\"\\n🔧 Ensuring extra columns exist in Variant Meta draft...\");\n await ensureExtraColumns();\n\n // Step 2: Fetch Products and Variants\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 // Step 3: Build product lookup map keyed by path (slug)\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 // Step 4: Build Variant Meta rows\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 // Extract product fields to enrich the variant\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 // Pass the full image object for IMAGE column type, or null if not present\n const productFeaturedImage =\n featuredImageRaw && typeof featuredImageRaw === \"object\"\n ? {\n url: featuredImageRaw.url || \"\",\n width: featuredImageRaw.width || 0,\n height: featuredImageRaw.height || 0,\n altText: featuredImageRaw.altText || \"\",\n fileId: featuredImageRaw.fileId || 0,\n }\n : null;\n\n metaRows.push({\n path: variant.path,\n name: variant.name,\n values: {\n // Copy all existing variant columns\n ...variant.values,\n // Enrich with product data\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 // Step 5: Wipe existing draft rows and write fresh ones\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 // Step 6: Publish\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\nexport default async function () {\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}","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 // Base variant columns (copied from Variants table)\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 // Enriched columns from Products table\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 if (Array.isArray(field)) {\n return field.map((f) => (f?.name || \"\").replace(/_/g, \" \")).join(\", \");\n }\n if (typeof field === \"object\") return (field?.name || \"\").replace(/_/g, \" \");\n return String(field).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 // Build full column list: existing (with their ids) + new ones\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 // Re-fetch to confirm\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 // Step 1: Ensure extra columns exist in draft\n console.log(\"\\n🔧 Ensuring extra columns exist in Variant Meta draft...\");\n await ensureExtraColumns();\n\n // Step 2: Fetch Products and Variants\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 // Step 3: Build product lookup map keyed by path (slug)\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 // Step 4: Build Variant Meta rows\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 // Extract product fields to enrich the variant\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 // IMAGE columns via the API accept a URL string for writing\n const productFeaturedImage = featuredImageRaw?.url ||\n (typeof featuredImageRaw === \"string\" ? featuredImageRaw : null);\n\n metaRows.push({\n path: variant.path,\n name: variant.name,\n values: {\n // Copy all existing variant columns\n ...variant.values,\n // Enrich with product data\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 // Step 5: Wipe existing draft rows and write fresh ones\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 // Step 6: Publish\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\nexport default async function () {\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}","createdAt",["D",1773944713664],"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":165,"_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":166,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":167,"_81":168,"_83":169,"_85":25},"tree",[156,157],"files",[156,157],"counts",{"_144":60,"_145":146,"_147":60,"_148":149,"_150":151},"contents",[127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":136,"_32":137,"_30":138,"_130":-5,"_41":42,"_40":139,"_131":25,"_38":140,"_13":141,"_33":34,"_35":142,"_24":25,"_134":-5,"_27":143},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":132,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_27":135},"f89b2d76-23c0-11f1-a93a-42dde27851f2","parentId","latest",["D",1773944713664],7,"label",[28],"aa1690d6-2173-11f1-bfd2-42dde27851f2","pod-product-meta-sync.js","e33628f0-1d76-11f1-b454-42dde27851f2",33,["D",1773691608358],24,"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`, { params });\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\n// Uses PATCH /tables/{id}/draft with the full column list (required by HubSpot)\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 // Check which extra columns are missing\n const missingColumns = EXTRA_COLUMNS.filter((c) => !existingNames.has(c.name));\n if (missingColumns.length === 0) {\n console.log(\"✅ All extra columns already exist.\");\n return;\n }\n\n // Build full column list: existing (with their ids) + new ones\n const existingDefs = existingColumns.map((col) => {\n const def = { id: col.id, name: col.name, label: col.label, type: col.type };\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(\" ❌ Failed to update schema:\", JSON.stringify(err.response?.data || err.message));\n throw err;\n }\n\n // Re-fetch draft schema to confirm\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 // Step 1: Ensure extra columns exist in draft before anything else\n console.log(\"\\n🔧 Ensuring extra columns exist in Product Meta draft...\");\n await ensureExtraColumns();\n\n // Step 2: Fetch Products and Variants\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 // Step 3: Group variants by product_slug for lookup\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 // Step 4: Build new Product Meta rows\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 // Build deduplicated list of all attribute key:value pairs across variants\n // e.g. \"Size:11 oz|Size:15 oz|Color:Black|Color:White\"\n const attributeSet = new Set();\n for (const v of matchedVariants) {\n const attrs = v.values?.attributes;\n if (!attrs) continue;\n // Each variant has attrs like \"Size:11 oz|Color:Black\" — split and collect\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 // Build search index — lowercase, deduplicated words from all relevant fields\n // Attribute values only (strip keys like \"Color:\", \"Size:\", \"Orientation:\" etc.)\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 // Extract names from foreign key fields (product_category, product_subcategory)\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\") return (field?.name || \"\").replace(/_/g, \" \");\n return String(field).replace(/_/g, \" \");\n };\n\n const categoryText = extractForeignNames(product.values?.product_category);\n const subcategoryText = extractForeignNames(product.values?.product_subcategory);\n\n // Combine all searchable text fields\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 // Strip HTML tags from product_description\n .replace(/<[^>]*>/g, \" \")\n // Replace underscores with spaces\n .replace(/_/g, \" \")\n // Collapse extra whitespace\n .replace(/\\s+/g, \" \")\n .trim();\n\n // Deduplicate words to keep the index lean\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 // Step 5: Wipe existing draft rows and write fresh ones\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 // Step 6: Publish\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\nexport default async function () {\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}",[137],"pulls","branches",1,"forks","envVars",{"_152":154,"_155":60},"connections",{"_152":60,"_153":60},"count","unfilledCount",3,"emptyCount",{"_43":136,"_32":137,"_30":138,"_130":-5,"_41":42,"_40":139,"_131":25,"_38":162,"_13":141,"_33":34,"_35":142,"_24":25,"_134":-5,"_159":163,"_27":164},{"_43":129,"_32":28,"_30":31,"_130":-5,"_41":42,"_40":14,"_131":25,"_38":158,"_13":133,"_33":34,"_35":37,"_24":25,"_134":-5,"_159":160,"_27":161},["D",1773944713664],"children",[],[28],["D",1773691608358],[],[137],["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,"_124":203,"_204":205,"_206":207,"_208":25,"_209":25,"_210":25,"_211":212,"_213":-5,"_214":-7,"_215":-7,"_216":60,"_217":25,"_218":25,"_219":-5,"_220":25,"_221":25,"_222":25,"_223":-5},"ENV",{"_174":175,"_176":177,"_178":87,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v41