[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_195":196,"_197":198},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_91":-7,"_92":93,"_29":-7,"_94":-5,"_15":95,"_96":97,"_98":99,"_100":101,"_102":103,"_104":-5,"_105":-5,"_106":-5,"_107":38,"_108":109,"_110":111,"_112":-5,"_113":-5,"_114":115},"routes/_app.x.$handle.$name.branches",{"_11":12,"_13":14,"_15":16,"_17":18},"handle","erictianwei","name","vesta-ops-24","project",{"_20":28,"_13":14,"_22":36,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":60,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":72,"_73":74,"_75":76,"_77":38},"branches",[19],{"_20":21,"_22":23,"_24":25,"_13":26,"_27":28,"_29":30,"_31":-5,"_32":-5,"_33":34,"_35":-5},"id","e7e4f78c-1495-4f0a-a85c-9eda7d940cb6","createdAt",["D",1781576701578],"updatedAt",["D",1783023744676],"main","projectId","f50decd2-e158-495f-ae93-4830dd5f3ee0","version",30,"forkedBranchId","forkedBranchVersion","lockfileKey","1783023817595-esm.town_v_erictianwei_vesta-ops-24@30-main","deletedAt",["D",1781576701574],"legacyEnvVars",false,"privacy","public","httpPrivacy","description","Process Order，Create Label","imageUrl","userId","507af6ad-0c04-4923-8c8e-26e260ab1b3b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019ece35-396a-7440-a5bb-fff64ecf0104","tursoName","f50decd2e158495fae934830dd5f3ee0","tursoHostname","f50decd2e158495fae934830dd5f3ee0-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789510872811],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_90":86},"org",{"_11":12,"_83":84,"_85":86,"_45":46,"_87":88,"_89":38},"branch",{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"isOwned","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Eric-Tianwei","avatar","https://avatars.githubusercontent.com/u/133830397?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","path","","adoptOrgId",{"_20":28,"_13":14,"_22":190,"_35":-5,"_37":38,"_39":40,"_41":40,"_42":43,"_44":-5,"_45":46,"_47":-5,"_48":38,"_49":-5,"_50":-5,"_51":52,"_53":54,"_55":56,"_57":58,"_59":191,"_61":-5,"_62":63,"_64":63,"_65":66,"_67":66,"_68":66,"_69":63,"_70":63,"_71":192,"_73":193,"_75":194,"_77":38},"tree",[173,174,175,176],"files",[173,174,175,176],"counts",{"_162":52,"_17":163,"_164":52,"_165":166,"_167":168},"contents",[116,117,118,119],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_20":154,"_13":155,"_122":156,"_124":-5,"_125":21,"_126":157,"_128":111,"_22":158,"_29":130,"_131":159,"_133":160,"_135":38,"_136":-5,"_92":161},{"_20":147,"_13":148,"_122":149,"_124":-5,"_125":21,"_126":30,"_128":111,"_22":150,"_29":151,"_131":144,"_133":152,"_135":38,"_136":-5,"_92":153},{"_20":138,"_13":139,"_122":140,"_124":-5,"_125":21,"_126":141,"_128":111,"_22":142,"_29":143,"_131":144,"_133":145,"_135":38,"_136":-5,"_92":146},{"_20":120,"_13":121,"_122":123,"_124":-5,"_125":21,"_126":127,"_128":111,"_22":129,"_29":130,"_131":132,"_133":134,"_135":38,"_136":-5,"_92":137},"c40e150c-72a0-4070-9d0d-9723242186c4","worker.ts","fileId","7edd0b12-69d9-11f1-9918-1607ee4eb77e","parentId","branchId","branchVersion",21,"latest",["D",1781655138122],4,"fileType","interval","content","// Worker — runs every minute, claims one pending job at a time, processes end-to-end.\n//\n// Why one at a time: GDE rate-limits aggressive bursts; Shopify Admin token shared too.\n// If the queue backs up, raise the cron frequency (down to 1 min minimum) or drain\n// in a `while (await claimNextJob())` loop here.\n\nimport {\n claimNextJob,\n collectErrorMessages,\n finishJob,\n markSlackNotified,\n postSlack,\n processFulfillmentOrder,\n} from \"./services.ts\";\n\nexport default async function (_interval: { lastRunAt?: Date }) {\n const job = await claimNextJob();\n if (!job) {\n console.log(\"no pending jobs\");\n return;\n }\n const tag = `job ${job.id} (FO ${job.fulfillment_order_id}, attempt ${job.attempts})`;\n console.log(`processing ${tag}`);\n\n try {\n const result = await processFulfillmentOrder(job.fulfillment_order_id);\n // Full result also lives in jobs.result_json — this stdout line is just for\n // realtime tailing in Val Town logs.\n console.log(`result ${tag}: ${JSON.stringify(result)}`);\n\n const errs = collectErrorMessages(result);\n if (errs.length > 0) {\n const msg = `Order ${result.orderNbr} worker partial failure (${errs.length} error${errs.length > 1 ? \"s\" : \"\"}):\\n${errs.map((e) => `• ${e}`).join(\"\\n\")}`;\n console.error(`errors ${tag}:\\n${errs.join(\"\\n\")}`);\n await postSlack(msg);\n await markSlackNotified(job.id);\n }\n\n await finishJob(job.id, result.ok ? \"done\" : \"failed\", result, errs.join(\"\\n\") || null);\n console.log(`${tag} → ${result.ok ? \"done\" : \"failed\"}`);\n } catch (err: any) {\n // Hard failure — Shopify fetch / token / metafield write / etc.\n const msg = err?.message ?? String(err);\n console.error(`fatal ${tag}: ${msg}`);\n await postSlack(`Order FO ${job.fulfillment_order_id} worker FATAL: ${msg}`);\n await markSlackNotified(job.id);\n await finishJob(job.id, \"failed\", null, msg);\n }\n}\n","deleted","label",[121],"4b49850f-5372-4666-905d-ccee4f2d2a55","services.ts","4e561290-69d9-11f1-85a0-1607ee4eb77e",28,["D",1781657415760],16,"script","// I/O layer: GDE, Shopify Admin GraphQL, sqlite jobs queue.\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport {\n buildRatesBody,\n CARRIER_PRESETS,\n collectBoxesByCarrier,\n partitionByStock,\n planLabels,\n type Box,\n} from \"./payload.ts\";\n\n// ============ GDE ============\nconst AUTH_URL = \"http://authorization.iot-easy.cn/connect/token\";\nconst RATES_API = \"http://apis.gde56.com/api/gts/CalculateRates\";\nconst LABEL_API = \"http://apis.gde56.com/api/gts/ShippingLabel\";\n\nexport async function fetchAccessToken(clientId: string, clientSecret: string): Promise {\n const res = await fetch(AUTH_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"client_credentials\",\n client_id: clientId,\n client_secret: clientSecret,\n }),\n });\n if (!res.ok) {\n throw new Error(`token HTTP ${res.status}: ${(await res.text()).slice(0, 200)}`);\n }\n const data = await res.json();\n if (!data?.access_token) {\n throw new Error(`token response missing access_token: ${JSON.stringify(data).slice(0, 200)}`);\n }\n return String(data.access_token);\n}\n\nasync function postJson(url: string, token: string, body: Record) {\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n Authorization: `Bearer ${token}`,\n },\n body: JSON.stringify(body),\n });\n const raw = await res.text();\n let data: any = null;\n try {\n data = JSON.parse(raw);\n } catch {\n /* keep null */\n }\n return { data, status: res.status, raw };\n}\n\nexport type RatesResult = {\n ok: boolean;\n totalCharge: string;\n productName: string;\n ratesList: any[];\n error: string | null;\n};\n\nexport async function callRates(\n token: string,\n boxes: Box[],\n addr: any,\n dedupe: string,\n preset: { productId: number; warehouseId: number },\n label: string,\n): Promise {\n try {\n const { data, status, raw } = await postJson(RATES_API, token, buildRatesBody(boxes, addr, dedupe, preset));\n if (!data) return { ok: false, totalCharge: \"\", productName: \"\", ratesList: [], error: `${label}: HTTP ${status} non-JSON: ${raw.slice(0, 200)}` };\n if (!data.IsSuccess) return { ok: false, totalCharge: \"\", productName: \"\", ratesList: [], error: `${label}: [${data.ErrorCode ?? \"\"}] ${data.Message ?? \"unknown\"}` };\n const r = Array.isArray(data.Result) ? data.Result[0] : null;\n return {\n ok: true,\n totalCharge: String(r?.TotalCharge ?? \"\"),\n productName: String(r?.ProductName ?? \"\"),\n ratesList: Array.isArray(r?.RatesList) ? r.RatesList : [],\n error: null,\n };\n } catch (err: any) {\n return { ok: false, totalCharge: \"\", productName: \"\", ratesList: [], error: `${label}: ${err?.message ?? String(err)}` };\n }\n}\n\nexport type LabelResult = {\n ok: boolean;\n tracking: string;\n labelUrl: string;\n identifier: string;\n error: string | null;\n};\n\nexport async function callLabel(token: string, body: Record, label: string): Promise {\n try {\n const { data, status, raw } = await postJson(LABEL_API, token, body);\n if (!data) return { ok: false, tracking: \"\", labelUrl: \"\", identifier: \"\", error: `${label}: HTTP ${status} non-JSON: ${raw.slice(0, 200)}` };\n if (!data.IsSuccess) return { ok: false, tracking: \"\", labelUrl: \"\", identifier: \"\", error: `${label}: [${data.ErrorCode ?? \"\"}] ${data.Message ?? \"unknown\"}` };\n return {\n ok: true,\n tracking: String(data.Result?.MasterTrackingNbr ?? \"\"),\n labelUrl: String(data.Result?.MasterLabelUrl ?? \"\"),\n identifier: String(data.Result?.Identifier ?? \"\"),\n error: null,\n };\n } catch (err: any) {\n return { ok: false, tracking: \"\", labelUrl: \"\", identifier: \"\", error: `${label}: ${err?.message ?? String(err)}` };\n }\n}\n\n// ============ Shopify Admin GraphQL ============\n// Auth: OAuth client_credentials grant (no manual admin token).\n// POST https:///admin/oauth/access_token\n// body: grant_type=client_credentials&client_id=...&client_secret=...\n// → { access_token: \"shpat_...\" }\n// Mirrors vesta/shopify-ai-cli/src/shopify.ts.\nconst SHOPIFY_API_VERSION = \"2025-01\";\n\nexport type ShopifyEnv = { domain: string; clientId: string; clientSecret: string };\n\nexport function shopifyEnv(): ShopifyEnv {\n // Trim — Val Town UI paste sometimes brings leading/trailing whitespace; Shopify\n // OAuth then 400s with `application_cannot_be_found`. Defensive trim is cheap.\n const domain = Deno.env.get(\"SHOPIFY_SHOP_DOMAIN\")?.trim();\n const clientId = Deno.env.get(\"SHOPIFY_CLIENT_ID\")?.trim();\n const clientSecret = Deno.env.get(\"SHOPIFY_CLIENT_SECRET\")?.trim();\n if (!domain) throw new Error(\"missing SHOPIFY_SHOP_DOMAIN env var\");\n if (!clientId) throw new Error(\"missing SHOPIFY_CLIENT_ID env var\");\n if (!clientSecret) throw new Error(\"missing SHOPIFY_CLIENT_SECRET env var\");\n return { domain, clientId, clientSecret };\n}\n\n// Module-level cache — if Val Town keeps the worker hot across cron runs we save\n// a round trip; if not, harmless (refetched). Client_credentials grant is\n// stateless and cheap to repeat.\nlet cachedShopifyToken: { shop: string; token: string } | null = null;\n\nasync function fetchShopifyAccessToken(env: ShopifyEnv): Promise {\n if (cachedShopifyToken?.shop === env.domain) return cachedShopifyToken.token;\n const res = await fetch(`https://${env.domain}/admin/oauth/access_token`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n grant_type: \"client_credentials\",\n client_id: env.clientId,\n client_secret: env.clientSecret,\n }),\n });\n if (!res.ok) {\n throw new Error(`shopify oauth HTTP ${res.status}: ${(await res.text()).slice(0, 300)}`);\n }\n const data = await res.json();\n if (!data?.access_token) {\n throw new Error(`shopify oauth missing access_token: ${JSON.stringify(data).slice(0, 200)}`);\n }\n cachedShopifyToken = { shop: env.domain, token: String(data.access_token) };\n return cachedShopifyToken.token;\n}\n\nasync function shopifyGraphql(env: ShopifyEnv, query: string, variables: Record) {\n const token = await fetchShopifyAccessToken(env);\n const url = `https://${env.domain}/admin/api/${SHOPIFY_API_VERSION}/graphql.json`;\n const res = await fetch(url, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Shopify-Access-Token\": token,\n },\n body: JSON.stringify({ query, variables }),\n });\n if (!res.ok) {\n // 401: token may have rotated — drop cache, let next call refetch.\n if (res.status === 401) cachedShopifyToken = null;\n throw new Error(`shopify HTTP ${res.status}: ${(await res.text()).slice(0, 300)}`);\n }\n const data = await res.json();\n if (data.errors) {\n throw new Error(`shopify GraphQL errors: ${JSON.stringify(data.errors).slice(0, 300)}`);\n }\n return data.data;\n}\n\nconst FETCH_FO_QUERY = `\n query($id: ID!) {\n fulfillmentOrder(id: $id) {\n id\n lineItems(first: 50) {\n edges { node {\n totalQuantity\n variant {\n sku\n inventoryQuantity\n packageConfig: metafield(namespace: \"custom\", key: \"package_config\") { value }\n }\n }}\n }\n order {\n id\n name\n shippingAddress {\n name\n phone\n address1\n address2\n city\n zip\n provinceCode\n province\n countryCodeV2\n country\n }\n }\n }\n }\n`;\n\nexport type ShopifyFulfillmentOrder = {\n id: string;\n lineItems: any[];\n order: { id: string; name: string; shippingAddress: any };\n};\n\nexport async function fetchFulfillmentOrder(env: ShopifyEnv, fulfillmentOrderId: string): Promise {\n const data = await shopifyGraphql(env, FETCH_FO_QUERY, { id: fulfillmentOrderId });\n const fo = data?.fulfillmentOrder;\n if (!fo) throw new Error(`fulfillmentOrder not found: ${fulfillmentOrderId}`);\n return {\n id: fo.id,\n order: fo.order,\n lineItems: (fo.lineItems?.edges ?? []).map((e: any) => e.node),\n };\n}\n\nconst METAFIELDS_SET_MUTATION = `\n mutation($metafields: [MetafieldsSetInput!]!) {\n metafieldsSet(metafields: $metafields) {\n metafields { id key namespace }\n userErrors { field message }\n }\n }\n`;\n\nexport type MetafieldInput = {\n ownerId: string;\n namespace: string;\n key: string;\n type: string;\n value: string;\n};\n\nexport async function setMetafields(env: ShopifyEnv, metafields: MetafieldInput[]) {\n const data = await shopifyGraphql(env, METAFIELDS_SET_MUTATION, { metafields });\n const errs = data?.metafieldsSet?.userErrors ?? [];\n if (errs.length > 0) {\n throw new Error(`metafieldsSet userErrors: ${JSON.stringify(errs).slice(0, 300)}`);\n }\n return data?.metafieldsSet?.metafields ?? [];\n}\n\n// ============ Jobs queue ============\n// jobs table stores both queue state and a structured archive of each run.\n// Wide columns (tracking_numbers_json / fedexng_charge / etc) make reporting\n// queries trivial without JSON_EXTRACT on result_json.\n\nconst ADDITIONAL_COLUMNS: string[] = [\n \"ALTER TABLE jobs ADD COLUMN tracking_numbers_json TEXT\",\n \"ALTER TABLE jobs ADD COLUMN label_urls_json TEXT\",\n \"ALTER TABLE jobs ADD COLUMN out_of_stock_skus_json TEXT\",\n \"ALTER TABLE jobs ADD COLUMN fedexng_charge REAL\",\n \"ALTER TABLE jobs ADD COLUMN fedexsmp_charge REAL\",\n \"ALTER TABLE jobs ADD COLUMN fedexng_package_count INTEGER\",\n \"ALTER TABLE jobs ADD COLUMN fedexsmp_package_count INTEGER\",\n \"ALTER TABLE jobs ADD COLUMN slack_notified_at INTEGER\",\n];\n\nlet schemaReady = false;\nexport async function initSchema() {\n if (schemaReady) return;\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS jobs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n fulfillment_order_id TEXT NOT NULL UNIQUE,\n order_name TEXT,\n status TEXT NOT NULL DEFAULT 'pending',\n attempts INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL,\n started_at INTEGER,\n finished_at INTEGER,\n result_json TEXT,\n error TEXT,\n tracking_numbers_json TEXT,\n label_urls_json TEXT,\n out_of_stock_skus_json TEXT,\n fedexng_charge REAL,\n fedexsmp_charge REAL,\n fedexng_package_count INTEGER,\n fedexsmp_package_count INTEGER,\n slack_notified_at INTEGER\n )\n `);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_jobs_status ON jobs(status)`);\n // For pre-existing tables created before the wider schema — best-effort add.\n // SQLite has no \"ADD COLUMN IF NOT EXISTS\"; duplicate column error is expected\n // on second run and is swallowed.\n for (const ddl of ADDITIONAL_COLUMNS) {\n try {\n await sqlite.execute(ddl);\n } catch {\n /* column already exists */\n }\n }\n schemaReady = true;\n}\n\nexport type EnqueueResult = { jobId: number; created: boolean; status: string };\n\nexport async function enqueueJob(fulfillmentOrderId: string, orderName: string | null): Promise {\n await initSchema();\n const now = Date.now();\n // INSERT OR IGNORE — idempotent on fulfillment_order_id UNIQUE.\n const ins = await sqlite.execute({\n sql: `INSERT OR IGNORE INTO jobs (fulfillment_order_id, order_name, status, created_at)\n VALUES (?, ?, 'pending', ?)`,\n args: [fulfillmentOrderId, orderName, now],\n });\n if ((ins.rowsAffected ?? 0) > 0) {\n return { jobId: Number(ins.lastInsertRowid), created: true, status: \"pending\" };\n }\n // already existed — fetch state\n const row = await sqlite.execute({\n sql: `SELECT id, status FROM jobs WHERE fulfillment_order_id = ?`,\n args: [fulfillmentOrderId],\n });\n const r: any = row.rows[0];\n return { jobId: Number(r.id), created: false, status: String(r.status) };\n}\n\nexport type Job = {\n id: number;\n fulfillment_order_id: string;\n order_name: string | null;\n status: string;\n attempts: number;\n};\n\nexport async function claimNextJob(): Promise {\n await initSchema();\n // Pick the oldest pending and try to atomically flip it to processing.\n const pick = await sqlite.execute(\n `SELECT id, fulfillment_order_id, order_name, attempts\n FROM jobs WHERE status = 'pending' ORDER BY id ASC LIMIT 1`,\n );\n if (pick.rows.length === 0) return null;\n const row: any = pick.rows[0];\n const upd = await sqlite.execute({\n sql: `UPDATE jobs SET status = 'processing', started_at = ?, attempts = attempts + 1\n WHERE id = ? AND status = 'pending'`,\n args: [Date.now(), row.id],\n });\n if ((upd.rowsAffected ?? 0) === 0) return null;\n return {\n id: Number(row.id),\n fulfillment_order_id: String(row.fulfillment_order_id),\n order_name: row.order_name ? String(row.order_name) : null,\n status: \"processing\",\n attempts: Number(row.attempts) + 1,\n };\n}\n\nfunction toCharge(v: string): number | null {\n const n = parseFloat(v);\n return Number.isFinite(n) ? n : null;\n}\n\nexport async function finishJob(\n id: number,\n status: \"done\" | \"failed\",\n result: ProcessResult | null,\n error: string | null,\n) {\n const allTracking = result\n ? [...result.fedexng.trackingNumbers, ...result.fedexsmp.trackingNumbers].filter(Boolean)\n : [];\n const allLabelUrls = result\n ? [...result.fedexng.labelUrls, ...result.fedexsmp.labelUrls].filter(Boolean)\n : [];\n await sqlite.execute({\n sql: `UPDATE jobs SET\n status = ?,\n finished_at = ?,\n result_json = ?,\n error = ?,\n tracking_numbers_json = ?,\n label_urls_json = ?,\n out_of_stock_skus_json = ?,\n fedexng_charge = ?,\n fedexsmp_charge = ?,\n fedexng_package_count = ?,\n fedexsmp_package_count = ?\n WHERE id = ?`,\n args: [\n status,\n Date.now(),\n result ? JSON.stringify(result) : null,\n error,\n JSON.stringify(allTracking),\n JSON.stringify(allLabelUrls),\n result ? JSON.stringify(result.outOfStockSkus) : null,\n result?.fedexng.has ? toCharge(result.fedexng.rates.totalCharge) : null,\n result?.fedexsmp.has ? toCharge(result.fedexsmp.rates.totalCharge) : null,\n result?.fedexng.has ? result.fedexng.packageCount : null,\n result?.fedexsmp.has ? result.fedexsmp.packageCount : null,\n id,\n ],\n });\n}\n\nexport async function markSlackNotified(id: number) {\n await sqlite.execute({\n sql: `UPDATE jobs SET slack_notified_at = ? WHERE id = ?`,\n args: [Date.now(), id],\n });\n}\n\n// ============ Orchestration: process one job end-to-end ============\nexport type CarrierResult = {\n has: boolean;\n packageCount: number;\n rates: RatesResult;\n trackingNumbers: string[];\n labelUrls: string[];\n identifiers: string[];\n errors: (string | null)[];\n};\n\nconst EMPTY_CARRIER: CarrierResult = {\n has: false,\n packageCount: 0,\n rates: { ok: false, totalCharge: \"\", productName: \"\", ratesList: [], error: null },\n trackingNumbers: [],\n labelUrls: [],\n identifiers: [],\n errors: [],\n};\n\nasync function processCarrier(\n carrierKey: string,\n boxes: Box[],\n addr: any,\n baseOrderNbr: string,\n dedupe: string,\n token: string,\n): Promise {\n const preset = CARRIER_PRESETS[carrierKey];\n const rates = await callRates(token, boxes, addr, dedupe, preset, `${carrierKey} rates`);\n const plans = planLabels(boxes, addr, baseOrderNbr, dedupe, preset);\n\n const labels: LabelResult[] = [];\n for (let i = 0; i < plans.length; i++) {\n labels.push(await callLabel(token, plans[i].body, `${carrierKey} label ${i + 1}`));\n }\n return {\n has: true,\n packageCount: boxes.length,\n rates,\n trackingNumbers: labels.map((r) => r.tracking),\n labelUrls: labels.map((r) => r.labelUrl),\n identifiers: labels.map((r) => r.identifier),\n errors: labels.map((r) => r.error),\n };\n}\n\nexport type ProcessResult = {\n ok: boolean;\n orderNbr: string;\n outOfStockSkus: string[];\n hasOutOfStock: boolean;\n fedexng: CarrierResult;\n fedexsmp: CarrierResult;\n error?: string;\n};\n\nexport async function processFulfillmentOrder(fulfillmentOrderId: string): Promise {\n const sEnv = shopifyEnv();\n const clientId = Deno.env.get(\"GDE_CLIENT_ID\")?.trim();\n const clientSecret = Deno.env.get(\"GDE_CLIENT_SECRET\")?.trim();\n if (!clientId || !clientSecret) throw new Error(\"missing GDE_CLIENT_ID / GDE_CLIENT_SECRET\");\n\n const fo = await fetchFulfillmentOrder(sEnv, fulfillmentOrderId);\n const addr = fo.order.shippingAddress;\n const dedupe = Math.random().toString(36).slice(2, 8);\n const baseOrderNbr = fo.order.name || `TEST${dedupe}`;\n\n const { inStock, outOfStockSkus } = partitionByStock(fo.lineItems);\n const byCarrier = collectBoxesByCarrier(inStock);\n const hasAny = Object.values(byCarrier).some((bs) => bs.length > 0);\n\n if (!hasAny) {\n const result: ProcessResult = {\n ok: false,\n orderNbr: baseOrderNbr,\n outOfStockSkus,\n hasOutOfStock: outOfStockSkus.length > 0,\n fedexng: EMPTY_CARRIER,\n fedexsmp: EMPTY_CARRIER,\n error: \"no shippable boxes (all line items lack packageConfig or are out of stock)\",\n };\n await handleOrderUpdates(sEnv, fo.order.id, result);\n return result;\n }\n\n const token = await fetchAccessToken(clientId, clientSecret);\n\n const [fedexng, fedexsmp] = await Promise.all([\n byCarrier.FEDEXNG.length > 0\n ? processCarrier(\"FEDEXNG\", byCarrier.FEDEXNG, addr, baseOrderNbr, dedupe, token)\n : Promise.resolve(EMPTY_CARRIER),\n byCarrier.FEDEXSMP.length > 0\n ? processCarrier(\"FEDEXSMP\", byCarrier.FEDEXSMP, addr, baseOrderNbr, dedupe, token)\n : Promise.resolve(EMPTY_CARRIER),\n ]);\n\n const labelErrors = [...fedexng.errors, ...fedexsmp.errors];\n const ok = labelErrors.length > 0 && labelErrors.every((e) => e === null) &&\n (!fedexng.has || fedexng.rates.ok) && (!fedexsmp.has || fedexsmp.rates.ok);\n\n const result: ProcessResult = {\n ok,\n orderNbr: baseOrderNbr,\n outOfStockSkus,\n hasOutOfStock: outOfStockSkus.length > 0,\n fedexng,\n fedexsmp,\n };\n await handleOrderUpdates(sEnv, fo.order.id, result);\n return result;\n}\n\n// ============ Order-side updates ============\n// All append semantics — never overwrite existing data.\n//\n// Per-carrier label URL metafields (custom namespace, type list.url):\n// FEDEXNG → custom.shipping_label\n// FEDEXSMP → custom.shippo_shipping_label\n// Tags: append \"Backorder\" on out-of-stock SKUs, \"Label Created\" on full success.\n// Note: append a `Backorder SKUs: ...` line when applicable.\n\nconst CARRIER_LABEL_META: Record = {\n FEDEXNG: { namespace: \"custom\", key: \"shipping_label\" },\n FEDEXSMP: { namespace: \"custom\", key: \"shippo_shipping_label\" },\n};\n\nasync function appendListUrlMetafield(\n env: ShopifyEnv,\n orderId: string,\n namespace: string,\n key: string,\n newUrls: string[],\n) {\n if (newUrls.length === 0) return;\n const r = await shopifyGraphql(\n env,\n `query($id: ID!) { order(id: $id) { metafield(namespace: \"${namespace}\", key: \"${key}\") { value } } }`,\n { id: orderId },\n );\n const existing = r?.order?.metafield?.value;\n let previous: string[] = [];\n if (existing) {\n try {\n const parsed = JSON.parse(existing);\n if (Array.isArray(parsed)) previous = parsed.map(String);\n } catch {\n /* malformed → start fresh */\n }\n }\n const merged = [...previous, ...newUrls];\n await setMetafields(env, [{\n ownerId: orderId,\n namespace,\n key,\n type: \"list.url\",\n value: JSON.stringify(merged),\n }]);\n}\n\nasync function appendOrderNote(env: ShopifyEnv, orderId: string, text: string, separator = \"\\n\\n\") {\n const r = await shopifyGraphql(\n env,\n `query($id: ID!) { order(id: $id) { note } }`,\n { id: orderId },\n );\n const previous = r?.order?.note || \"\";\n const newNote = previous ? `${previous}${separator}${text}` : text;\n const upd = await shopifyGraphql(\n env,\n `mutation($input: OrderInput!) {\n orderUpdate(input: $input) {\n order { id }\n userErrors { field message }\n }\n }`,\n { input: { id: orderId, note: newNote } },\n );\n const errs = upd?.orderUpdate?.userErrors ?? [];\n if (errs.length > 0) throw new Error(`orderUpdate(note) userErrors: ${JSON.stringify(errs).slice(0, 300)}`);\n}\n\nasync function addOrderTags(env: ShopifyEnv, orderId: string, tags: string[]) {\n if (tags.length === 0) return;\n const r = await shopifyGraphql(\n env,\n `mutation($id: ID!, $tags: [String!]!) {\n tagsAdd(id: $id, tags: $tags) {\n node { id }\n userErrors { field message }\n }\n }`,\n { id: orderId, tags },\n );\n const errs = r?.tagsAdd?.userErrors ?? [];\n if (errs.length > 0) throw new Error(`tagsAdd userErrors: ${JSON.stringify(errs).slice(0, 300)}`);\n}\n\nasync function handleOrderUpdates(env: ShopifyEnv, orderId: string, r: ProcessResult) {\n // 1. Per-carrier label URLs → append to custom.shipping_label / shippo_shipping_label.\n for (const carrierKey of [\"FEDEXNG\", \"FEDEXSMP\"] as const) {\n const cr = carrierKey === \"FEDEXNG\" ? r.fedexng : r.fedexsmp;\n if (!cr.has) continue;\n const urls = cr.labelUrls.filter((u): u is string => Boolean(u));\n const meta = CARRIER_LABEL_META[carrierKey];\n await appendListUrlMetafield(env, orderId, meta.namespace, meta.key, urls);\n }\n\n // 2. Out-of-stock SKUs → append to note + add \"Backorder\" tag.\n if (r.outOfStockSkus.length > 0) {\n await appendOrderNote(env, orderId, `Backorder SKUs: ${r.outOfStockSkus.join(\", \")}`);\n await addOrderTags(env, orderId, [\"Backorder\"]);\n }\n\n // 3. Full success → add \"Label Created\" tag.\n if (r.ok) {\n await addOrderTags(env, orderId, [\"Label Created\"]);\n }\n}\n\n// ============ Slack notification ============\nexport async function postSlack(text: string): Promise {\n const url = Deno.env.get(\"SLACK_WEBHOOK_URL\");\n if (!url) {\n console.warn(\"SLACK_WEBHOOK_URL not set — slack message dropped\");\n return;\n }\n try {\n const res = await fetch(url, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ text }),\n });\n if (!res.ok) {\n console.error(`slack HTTP ${res.status}: ${(await res.text()).slice(0, 200)}`);\n }\n } catch (e: any) {\n console.error(`slack post failed: ${e?.message ?? String(e)}`);\n }\n}\n\nexport function collectErrorMessages(r: ProcessResult): string[] {\n const carrierErrs = [...r.fedexng.errors, ...r.fedexsmp.errors].filter((e): e is string => e !== null);\n const rateErrs = [r.fedexng.rates.error, r.fedexsmp.rates.error].filter((e): e is string => e !== null);\n return [r.error, ...rateErrs, ...carrierErrs].filter((e): e is string => Boolean(e));\n}\n",[139],"534c554a-4750-4ef1-9e48-625ff9067e75","payload.ts","2206df6c-69d9-11f1-a225-1607ee4eb77e",["D",1783023744676],2,"// Pure logic — parsing, packing, GDE payload construction.\n// No I/O. Importable by main.ts and worker.ts.\n\nexport const SHIPPER = {\n Name: \"Vesta Fitness\",\n Phone: \"3106966222\",\n Address1: \"8808 Pioneer Blvd\",\n Address2: \"\",\n City: \"Santa Fe Springs\",\n StateProvince: \"CA\",\n PostalCode: \"90670\",\n Country: \"US\",\n};\n\nexport const COMMON_CONFIG = {\n CustomerID: 228524,\n OwnershipID: 150903,\n OrderType: 20120,\n};\n\n// Per-carrier behavior:\n// labelMode \"single\" — one ShippingLabel call, all Packages in one body (FEDEXNG)\n// labelMode \"split\" — one ShippingLabel call per Package (FEDEXSMP rejects multi)\nexport const CARRIER_PRESETS: Record<\n string,\n {\n productId: number;\n warehouseId: number;\n name: string;\n labelMode: \"single\" | \"split\";\n }\n> = {\n FEDEXNG: {\n productId: 569599,\n warehouseId: 221121,\n name: \"Fedex NG末端-N\",\n labelMode: \"single\",\n },\n FEDEXSMP: {\n productId: 568995,\n warehouseId: 221121,\n name: \"Fedex-Economy-SMP-TY\",\n labelMode: \"split\",\n },\n // USPSA: { productId: 349428, warehouseId: 217170, name: \"USPS GA - A价_906不预上网\", labelMode: \"single\" },\n};\n\nexport const DECLARE_DEFAULTS = {\n DeclareValue: 1,\n DeclareCnName: \"健身器材\",\n DeclareEnName: \"Fitness\",\n HSCode: \"0000000\",\n DeclareItemType: \"IN\",\n OriginCountry: \"CN\",\n DeclareCurrency: \"USD\",\n DeclareUnit: \"USD\",\n Description: \"Fitness\",\n};\n\nexport type Box = {\n Length: number;\n Width: number;\n Height: number;\n LengthUnit: string;\n Weight: number;\n WeightUnit: string;\n sku?: string;\n};\n\nexport type Config = { qty: number; carrier: string; boxes: Box[] };\n\nexport function parseBox(s: string): Box {\n const [dim, wt] = s.split(\",\");\n const dm = dim.trim().match(/^([\\d.]+)x([\\d.]+)x([\\d.]+)([A-Za-z]+)$/);\n const wm = wt.trim().match(/^([\\d.]+)([A-Za-z]+)$/);\n if (!dm || !wm) throw new Error(`Invalid box spec: ${s}`);\n return {\n Length: parseFloat(dm[1]),\n Width: parseFloat(dm[2]),\n Height: parseFloat(dm[3]),\n LengthUnit: dm[4].toUpperCase(),\n Weight: parseFloat(wm[1]),\n WeightUnit: wm[2].toUpperCase(),\n };\n}\n\nexport function parseConfig(text: string): Config {\n const idx = text.indexOf(\":\");\n if (idx < 0) throw new Error(`Invalid package config: ${text}`);\n const head = text.slice(0, idx).trim();\n const hm = head.match(/^(\\d+)-([A-Za-z]+)$/);\n if (!hm) {\n throw new Error(\n `Invalid package config head (expect \"-\"): ${head}`,\n );\n }\n return {\n qty: parseInt(hm[1], 10),\n carrier: hm[2].toUpperCase(),\n boxes: text.slice(idx + 1).split(\";\").map(parseBox),\n };\n}\n\nexport function parseConfigList(value: unknown): Config[] {\n if (!value) return [];\n let arr: unknown[];\n if (Array.isArray(value)) {\n arr = value;\n } else if (typeof value === \"string\") {\n const t = value.trim();\n if (t.startsWith(\"[\")) {\n try {\n arr = JSON.parse(t);\n } catch {\n arr = [t];\n }\n } else {\n arr = [t];\n }\n } else {\n return [];\n }\n return arr\n .filter(Boolean)\n .map((s) => parseConfig(String(s)))\n .filter((c) => CARRIER_PRESETS[c.carrier]);\n}\n\nexport function packLineItem(totalQuantity: number, configs: Config[]): Box[] {\n const sorted = [...configs].sort((a, b) => b.qty - a.qty);\n const smallest = sorted[sorted.length - 1];\n let remaining = totalQuantity;\n const boxes: Box[] = [];\n while (remaining > 0) {\n const usable = sorted.find((c) => c.qty <= remaining);\n if (!usable) {\n boxes.push(...smallest.boxes);\n remaining = 0;\n break;\n }\n boxes.push(...usable.boxes);\n remaining -= usable.qty;\n }\n return boxes;\n}\n\nexport function partitionByStock(lineItems: any[]) {\n const inStock: any[] = [];\n const outOfStockSkus: string[] = [];\n for (const li of lineItems) {\n const available = li.variant?.inventoryQuantity;\n if (typeof available === \"number\" && available < 0) {\n outOfStockSkus.push(li.variant?.sku || \"\");\n } else {\n inStock.push(li);\n }\n }\n return { inStock, outOfStockSkus };\n}\n\nexport function collectBoxesByCarrier(lineItems: any[]): Record {\n const buckets: Record = {};\n for (const key of Object.keys(CARRIER_PRESETS)) buckets[key] = [];\n\n for (const li of lineItems) {\n const sku = li.variant?.sku || \"\";\n const allConfigs = parseConfigList(li.variant?.packageConfig?.value);\n if (allConfigs.length === 0) continue;\n\n const byCarrier: Record = {};\n for (const c of allConfigs) {\n (byCarrier[c.carrier] = byCarrier[c.carrier] || []).push(c);\n }\n for (const [carrier, configs] of Object.entries(byCarrier)) {\n const boxes = packLineItem(li.totalQuantity || 1, configs);\n for (const box of boxes) buckets[carrier].push({ ...box, sku });\n }\n }\n return buckets;\n}\n\nfunction addressFields(addr: any) {\n return {\n ShipperAddress1: SHIPPER.Address1,\n ShipperAddress2: SHIPPER.Address2,\n ShipperCity: SHIPPER.City,\n ShipperStateProvince: SHIPPER.StateProvince,\n ShipperPostalCode: SHIPPER.PostalCode,\n ShipperCountry: SHIPPER.Country,\n ShipToName: addr.name,\n ShipToPhone: addr.phone || \"0000000000\",\n ShipToCompany: \"\",\n ShipToAddress1: addr.address1,\n ShipToAddress2: addr.address2 || \"\",\n ShipToCity: addr.city,\n ShipToStateProvince: addr.provinceCode || addr.province,\n ShipToPostalCode: addr.zip,\n ShipToCountry: addr.countryCodeV2 || addr.country,\n NeedSignService: \"\",\n };\n}\n\nfunction ratesPackage(box: Box, dedupe: string, i: number) {\n return {\n PackageIdentifier: `PK${dedupe}${i + 1}`,\n Length: box.Length,\n Width: box.Width,\n Height: box.Height,\n Weight: box.Weight,\n LengthUnit: box.LengthUnit,\n WeightUnit: box.WeightUnit,\n SKU: box.sku ?? \"\",\n Qty: 1,\n DeclareValue: DECLARE_DEFAULTS.DeclareValue,\n DeclareCnName: DECLARE_DEFAULTS.DeclareCnName,\n DeclareEnName: DECLARE_DEFAULTS.DeclareEnName,\n DeclareItemType: DECLARE_DEFAULTS.DeclareItemType,\n OriginCountry: DECLARE_DEFAULTS.OriginCountry,\n DeclareCurrency: DECLARE_DEFAULTS.DeclareCurrency,\n };\n}\n\nfunction labelPackage(\n box: Box,\n dedupe: string,\n i: number,\n referenceNbr: string,\n) {\n return {\n ...ratesPackage(box, dedupe, i),\n Reference1: referenceNbr,\n Reference2: \"\",\n Description: DECLARE_DEFAULTS.Description,\n DeclareUnit: DECLARE_DEFAULTS.DeclareUnit,\n HSCode: DECLARE_DEFAULTS.HSCode,\n };\n}\n\nexport function buildRatesBody(\n boxes: Box[],\n addr: any,\n dedupe: string,\n preset: { productId: number; warehouseId: number },\n) {\n return {\n CustomerID: COMMON_CONFIG.CustomerID,\n WarehouseID: preset.warehouseId,\n OwnershipID: COMMON_CONFIG.OwnershipID,\n OrderType: COMMON_CONFIG.OrderType,\n ...addressFields(addr),\n Packages: boxes.map((b, i) => ratesPackage(b, dedupe, i)),\n Products: [{ ID: preset.productId }],\n };\n}\n\nfunction buildLabelBody(\n boxes: Box[],\n addr: any,\n orderNbr: string,\n dedupe: string,\n referenceNbr: string,\n pkgOffset: number,\n preset: { productId: number; warehouseId: number },\n) {\n return {\n OrderNbr: orderNbr,\n ServiceID: 0,\n CustomerID: COMMON_CONFIG.CustomerID,\n WarehouseID: preset.warehouseId,\n OwnershipID: COMMON_CONFIG.OwnershipID,\n ProductID: preset.productId,\n OrderType: COMMON_CONFIG.OrderType,\n ShipperName: SHIPPER.Name,\n ShipperPhone: SHIPPER.Phone,\n ...addressFields(addr),\n IsBuyInsurance: 0,\n IsReturn: 0,\n Packages: boxes.map((b, i) =>\n labelPackage(b, dedupe, pkgOffset + i, referenceNbr)\n ),\n };\n}\n\n// FEDEXNG 一次合包；FEDEXSMP 每箱一次。\nexport function planLabels(\n boxes: Box[],\n addr: any,\n baseOrderNbr: string,\n dedupe: string,\n preset: {\n productId: number;\n warehouseId: number;\n labelMode: \"single\" | \"split\";\n },\n): { orderNbr: string; body: Record }[] {\n const referenceNbr = `${baseOrderNbr}-shopify`;\n if (preset.labelMode === \"single\") {\n const orderNbr = `${baseOrderNbr}-${dedupe}-shopify`;\n return [{\n orderNbr,\n body: buildLabelBody(\n boxes,\n addr,\n orderNbr,\n dedupe,\n referenceNbr,\n 0,\n preset,\n ),\n }];\n }\n return boxes.map((box, i) => {\n const orderNbr = `${baseOrderNbr}-${dedupe}${i + 1}-shopify`;\n return {\n orderNbr,\n body: buildLabelBody(\n [box],\n addr,\n orderNbr,\n dedupe,\n referenceNbr,\n i,\n preset,\n ),\n };\n });\n}",[148],"d9b633a2-9eda-429f-9135-846523b43d0e","main.ts","93e658c4-692a-11f1-bbf0-1607ee4eb77e",7,["D",1781651769560],"http","// HTTP webhook receiver — Shopify Flow posts here when a Fulfillment Order is ready.\n// We just enqueue and return 200 immediately; worker.ts (interval) does the work.\n//\n// Request (POST, JSON):\n// { fulfillmentOrderId: \"gid://shopify/FulfillmentOrder/\", orderName?: \"#1234\" }\n//\n// Response (always 200 if validated):\n// { ok: true, jobId: number, status: \"pending\" | \"processing\" | \"done\" | \"failed\", created: boolean }\n//\n// Idempotency: same fulfillmentOrderId never enqueues twice (UNIQUE constraint).\n\nimport { enqueueJob } from \"./services.ts\";\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") {\n return Response.json({ ok: false, error: \"POST only\" }, { status: 405 });\n }\n\n let input: any;\n try {\n input = await req.json();\n } catch {\n return Response.json({ ok: false, error: \"body must be JSON\" }, { status: 400 });\n }\n\n const fulfillmentOrderId = input?.fulfillmentOrderId;\n if (!fulfillmentOrderId || typeof fulfillmentOrderId !== \"string\") {\n return Response.json({ ok: false, error: \"missing fulfillmentOrderId (string, gid://...)\" }, { status: 400 });\n }\n const orderName = typeof input?.orderName === \"string\" ? input.orderName : null;\n\n try {\n const r = await enqueueJob(fulfillmentOrderId, orderName);\n return Response.json({ ok: true, jobId: r.jobId, status: r.status, created: r.created });\n } catch (err: any) {\n return Response.json({ ok: false, error: `enqueue failed: ${err?.message ?? String(err)}` }, { status: 500 });\n }\n}\n",[155],"pulls",1,"forks","envVars",{"_169":171,"_172":52},"connections",{"_169":151,"_170":52},"count","unfilledCount",6,"emptyCount",{"_20":154,"_13":155,"_122":156,"_124":-5,"_125":21,"_126":157,"_128":111,"_22":187,"_29":130,"_131":159,"_133":160,"_135":38,"_136":-5,"_178":188,"_92":189},{"_20":147,"_13":148,"_122":149,"_124":-5,"_125":21,"_126":30,"_128":111,"_22":184,"_29":151,"_131":144,"_133":152,"_135":38,"_136":-5,"_178":185,"_92":186},{"_20":138,"_13":139,"_122":140,"_124":-5,"_125":21,"_126":141,"_128":111,"_22":181,"_29":143,"_131":144,"_133":145,"_135":38,"_136":-5,"_178":182,"_92":183},{"_20":120,"_13":121,"_122":123,"_124":-5,"_125":21,"_126":127,"_128":111,"_22":177,"_29":130,"_131":132,"_133":134,"_135":38,"_136":-5,"_178":179,"_92":180},["D",1781655138122],"children",[],[121],["D",1781657415760],[],[139],["D",1783023744676],[],[148],["D",1781651769560],[],[155],["D",1781576701574],["D",1789510872811],{"_11":12,"_90":86},{"_11":12,"_83":84,"_85":86,"_45":46,"_87":88,"_89":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_78":-5,"_79":-5,"_80":-5,"_81":14,"_82":12},"ctx",{"_71":-5,"_113":228,"_229":230,"_231":232,"_233":38,"_234":38,"_235":38,"_236":111,"_237":-5,"_238":-7,"_239":-7,"_240":52,"_241":38,"_242":38,"_243":-5,"_244":38,"_245":38,"_246":38,"_247":-5},"ENV",{"_199":200,"_201":202,"_203":26,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223,"_224":225,"_226":227},"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