[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_106":107,"_108":109},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","wnewton","name","production-command-center","path","monday.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/wnewton/production-command-center/code/monday.ts","extension","id","0fc916f7-c58e-4779-aaa9-6a7100895d32","fileId","3c282dc8-a814-11f1-ac25-1607ee4eb77e","parentId","branchId","be1fb918-ad42-444d-9d39-35276cd47cc6","branchVersion",44,"latest",true,"createdAt",["D",1788494111282],"version",1,"fileType","script","content","import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/**\n * Monday.com Utility Schedule integration (server-side).\n *\n * The MONDAY_TOKEN is read ONLY from the environment and is never returned,\n * logged, or exposed to the browser. All error messages are generic — they\n * never include the token.\n */\n\nconst MONDAY_API = \"https://api.monday.com/v2\";\nconst MONDAY_API_VERSION = \"2023-10\";\nconst UTILITY_RE = /utility\\s*schedule/i;\n\nexport interface MondayColumn {\n id: string;\n title: string;\n type: string;\n}\nexport interface MondayGroup {\n id: string;\n title: string;\n}\nexport interface BoardMeta {\n id: string;\n name: string;\n groups: MondayGroup[];\n columns: MondayColumn[];\n}\nexport interface SyncResult {\n ok: boolean;\n error?: string;\n added: number;\n updated: number;\n ignoredCompleted: number;\n totalItems: number;\n jobs: { id: number; name: string }[];\n}\n\n/** Run a Monday GraphQL query. Never surfaces the token in any error. */\nasync function mondayGraphQL(token: string, query: string, variables: Record = {}) {\n const res = await fetch(MONDAY_API, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Bearer ${token}`,\n \"API-Version\": MONDAY_API_VERSION,\n },\n body: JSON.stringify({ query, variables }),\n });\n if (!res.ok) {\n throw new Error(\"Unable to reach Monday.com. Check that the board access is configured.\");\n }\n const body = await res.json();\n if (body.errors && body.errors.length) {\n const msg = String(body.errors[0]?.message ?? \"Monday.com request failed\");\n if (/authentication|authorization|invalid.*token|unauthorized/i.test(msg)) {\n throw new Error(\"Monday.com authentication failed. The connection token is invalid or expired.\");\n }\n throw new Error(\"Monday.com returned an error for this request.\");\n }\n return body.data;\n}\n\n/** Accessible boards the token can read (read-only). */\nexport async function listBoards(token: string): Promise<{ id: string; name: string }[]> {\n const data = await mondayGraphQL(token, `query { boards(limit: 100) { id name } }`);\n return (data?.boards ?? []) as { id: string; name: string }[];\n}\n\n/** Discover the Utility Schedule board id by name. */\nexport async function discoverUtilityBoardId(token: string): Promise<{ boardId: string | null; name: string | null; error?: string }> {\n const explicit = Deno.env.get(\"MONDAY_BOARD_ID\");\n if (explicit && /^\\d+$/.test(explicit)) {\n return { boardId: explicit, name: null };\n }\n try {\n const boards = await listBoards(token);\n const match = boards.find((b) => UTILITY_RE.test(b.name));\n if (match) return { boardId: match.id, name: match.name };\n return { boardId: null, name: null, error: \"No Utility Schedule board was found for this account.\" };\n } catch (err) {\n return { boardId: null, name: null, error: err instanceof Error ? err.message : \"Unable to read Monday.com.\" };\n }\n}\n\n/** Fetch board groups and columns (the metadata used for validation/mapping). */\nexport async function fetchBoardMeta(token: string, boardId: string): Promise<{ meta: BoardMeta | null; error?: string }> {\n const query = `query BoardMeta($boardId: ID!) {\n boards(ids: [$boardId]) {\n id name\n groups { id title }\n columns { id title type }\n }\n }`;\n try {\n const data = await mondayGraphQL(token, query, { boardId });\n const board = data?.boards?.[0];\n if (!board) return { meta: null, error: \"The configured Monday board could not be found.\" };\n const meta: BoardMeta = {\n id: board.id,\n name: board.name,\n groups: board.groups ?? [],\n columns: board.columns ?? [],\n };\n return { meta };\n } catch (err) {\n return { meta: null, error: err instanceof Error ? err.message : \"Unable to read Monday board metadata.\" };\n }\n}\n\n/** Normalise a group title for the Completed. filter. */\nfunction normalized(title: string): string {\n return title.trim().toLowerCase().replace(/\\.+$/, \"\").trim();\n}\nconst isCompletedGroup = (title: string): boolean => normalized(title) === \"completed\";\n\n/** Map Monday columns to job fields by matching their titles. */\ntype FieldKey =\n | \"job_number\" | \"status\" | \"superintendent\" | \"project_manager\" | \"estimator\"\n | \"location\" | \"jurisdiction\" | \"general_contractor\" | \"foreman\"\n | \"prevailing_wage\" | \"permit_number\";\n\nconst RULES: [FieldKey, RegExp][] = [\n [\"job_number\", /job\\s*#|job\\s*numb|job\\s*id|jobno/i],\n [\"status\", /^\\s*status\\s*$/i],\n [\"superintendent\", /superintend/i],\n [\"project_manager\", /project\\s*manager|^project$|^pm\\b/i],\n [\"estimator\", /estimator/i],\n [\"location\", /location|site\\s*address|city/i],\n [\"jurisdiction\", /jurisdiction/i],\n [\"general_contractor\", /general\\s*contractor|^gc\\b|contractor/i],\n [\"foreman\", /foreman/i],\n [\"prevailing_wage\", /prevailing|prev\\s*wage/i],\n [\"permit_number\", /permit/i],\n];\n\nfunction buildFieldMap(columns: MondayColumn[]): Record {\n const map = {} as Record;\n for (const key of Object.keys(RULES) as FieldKey[]) map[key] = null;\n // Assign each column to the first matching field (longest group first).\n const used = new Set();\n const ordered = [...columns].sort((a, b) => b.title.length - a.title.length);\n for (const col of ordered) {\n for (const [key, re] of RULES) {\n if (!used.has(key) && re.test(col.title)) {\n map[key] = col.id;\n used.add(key);\n break;\n }\n }\n }\n return map;\n}\n\nfunction colText(values: { column: { id: string }; text?: string | null }[], columnId: string | null): string {\n if (!columnId) return \"\";\n const v = values.find((x) => x.column?.id === columnId);\n if (!v) return \"\";\n const t = String(v.text ?? \"\").trim();\n if (t === \"{}\" || t === \"[]\" || t === \"false\") return \"\";\n return t;\n}\n\n/**\n * Import the Utility Schedule board. This is the write operation — callers\n * that only want to validate the connection should use fetchBoardMeta instead.\n */\nexport async function syncUtilitySchedule(token: string): Promise {\n const empty: SyncResult = { ok: false, added: 0, updated: 0, ignoredCompleted: 0, totalItems: 0, jobs: [] };\n\n const discovered = await discoverUtilityBoardId(token);\n if (discovered.error || !discovered.boardId) {\n return { ...empty, error: discovered.error ?? \"No Utility Schedule board is configured.\" };\n }\n\n const query = `query BoardItems($boardId: ID!) {\n boards(ids: [$boardId]) {\n id name\n columns { id title }\n items_page(limit: 500) {\n cursor\n items {\n id name url\n group { id title }\n column_values { column { id } text }\n }\n }\n }\n }`;\n\n let data;\n try {\n data = await mondayGraphQL(token, query, { boardId: discovered.boardId });\n } catch (err) {\n return { ...empty, error: err instanceof Error ? err.message : \"Unable to load the Utility Schedule board.\" };\n }\n const board = data?.boards?.[0];\n const items = board?.items_page?.items ?? [];\n const columns: MondayColumn[] = board?.columns ?? [];\n const fieldMap = buildFieldMap(columns);\n\n let added = 0;\n let updated = 0;\n let ignoredCompleted = 0;\n const jobs: { id: number; name: string }[] = [];\n\n for (const item of items) {\n const groupTitle = String(item.group?.title ?? \"\").trim();\n if (isCompletedGroup(groupTitle)) {\n ignoredCompleted += 1;\n continue;\n }\n const itemId = String(item.id);\n const values = item.column_values ?? [];\n const text = (col: string | null) => colText(values, col);\n const fields: Record = {\n name: String(item.name ?? \"\").trim() || \"Untitled Utility Job\",\n job_number: text(fieldMap.job_number),\n status: text(fieldMap.status),\n superintendent: text(fieldMap.superintendent),\n project_manager: text(fieldMap.project_manager),\n estimator: text(fieldMap.estimator),\n location: text(fieldMap.location),\n jurisdiction: text(fieldMap.jurisdiction),\n general_contractor: text(fieldMap.general_contractor),\n foreman: text(fieldMap.foreman),\n prevailing_wage: text(fieldMap.prevailing_wage),\n permit_number: text(fieldMap.permit_number),\n schedule_group: groupTitle,\n monday_url: String(item.url ?? \"\").trim(),\n };\n\n // Look for an existing synced job by its permanent Monday item id.\n const existing = await sqlite.execute(\n `SELECT id FROM jobs WHERE monday_item_id = ? AND source = 'monday'`,\n [itemId],\n );\n if (existing.rows.length > 0) {\n const jobId = Number((existing.rows[0] as { id: number }).id);\n const cols = Object.keys(fields).map((k) => `${k} = ?`).join(\", \");\n const args = Object.values(fields).concat([jobId]);\n await sqlite.execute(`UPDATE jobs SET ${cols} WHERE id = ?`, args);\n jobs.push({ id: jobId, name: fields.name });\n updated += 1;\n } else {\n // Insert a new Monday-sourced job. Never overwrites manual jobs.\n const result = await sqlite.execute(\n `INSERT INTO jobs (name, source, monday_item_id, job_number, status, superintendent,\n project_manager, estimator, location, jurisdiction, general_contractor, foreman,\n prevailing_wage, permit_number, schedule_group, monday_url)\n VALUES (?, 'monday', ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n [\n fields.name, itemId, fields.job_number, fields.status, fields.superintendent,\n fields.project_manager, fields.estimator, fields.location, fields.jurisdiction,\n fields.general_contractor, fields.foreman, fields.prevailing_wage, fields.permit_number,\n fields.schedule_group, fields.monday_url,\n ],\n );\n jobs.push({ id: Number(result.lastInsertRowid), name: fields.name });\n added += 1;\n }\n }\n\n return { ok: true, added, updated, ignoredCompleted, totalItems: items.length, jobs };\n}\n\n/** Record a refresh snapshot into monday_snapshots. */\nexport async function recordSnapshot(summary: Omit, tokenConfigured: boolean): Promise {\n await sqlite.execute(\n `INSERT INTO monday_snapshots (jobs_json) VALUES (?)`,\n [JSON.stringify({ ...summary, tokenConfigured, source: \"monday\" })],\n );\n}\n\n/** Most recent refresh info for display. */\nexport async function lastRefresh(): Promise<{ fetchedAt: string | null; summary: Record | null }> {\n const rows = await sqlite.execute(`SELECT fetched_at, jobs_json FROM monday_snapshots ORDER BY id DESC LIMIT 1`);\n if (rows.rows.length === 0) return { fetchedAt: null, summary: null };\n const row = rows.rows[0] as { fetched_at: string; jobs_json: string };\n let summary: Record | null = null;\n try { summary = JSON.parse(row.jobs_json); } catch { summary = null; }\n return { fetchedAt: row.fetched_at, summary };\n}\n/** Expose which board column title maps to each job field (for metadata display). */\nexport function resolveColumnMapping(columns: MondayColumn[]): Record {\n const map = buildFieldMap(columns);\n const out: Record = {};\n for (const key of Object.keys(map) as FieldKey[]) {\n const id = map[key];\n const col = columns.find((c) => c.id === id);\n out[key] = col ? col.title : \"\";\n }\n return out;\n}\n","deleted",false,"label",[14],"9c7d0c21-6fce-451a-b6a0-ca5de197aeab",["D",1788450878892],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","NDX internal job production, labor, equipment, and cost dash","imageUrl","userId","fe3e8c07-bae6-44d7-85dc-b222854b68d6","pinnedFileId","179f165a-a7d4-11f1-92c0-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a06443-646e-71a4-ad2c-20559176a0b0","tursoName","9c7d0c216fce451ab6a0ca5de197aeab","tursoHostname","9c7d0c216fce451ab6a0ca5de197aeab-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789514495229],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_105":100},"org",{"_9":10,"_99":100,"_101":100,"_55":56,"_102":103,"_104":42},"branch",{"_35":89,"_11":90,"_22":28,"_91":45,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":12,"_98":10},"isOwned",63,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","pro","canRestrictVals","profileImageUrl","ctx",{"_82":-5,"_139":140,"_141":142,"_143":144,"_145":42,"_146":42,"_147":42,"_148":32,"_149":-5,"_150":-7,"_151":-7,"_152":63,"_153":42,"_154":42,"_155":-5,"_156":42,"_157":42,"_158":42,"_159":-5},"ENV",{"_110":111,"_112":113,"_114":90,"_115":116,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138},"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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]