[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_156":157,"_158":159},"routes/_app.x.$handle.$name",{"_96":95,"_32":44,"_103":86,"_27":53,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":48,"_117":118,"_119":48,"_120":-5,"_121":-5,"_122":123},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_32":44,"_37":45,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":48},"version",18,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",true,"deletedHere","path","new-file-2362.ts","latestPath","fileId","5c8c6448-a964-11f1-8dff-1607ee4eb77e","name","fileType","http","content","/**\n * Good Maid Cleaning — Jobber booking relay\n * --------------------------------------------------\n * This one file does three jobs:\n * 1. Lets you connect this to Jobber (visit the address once, click \"Connect\")\n * 2. Receives real bookings from your website and creates them in Jobber\n * 3. Has a couple of \"peek at Jobber's rules\" links Henry can visit and send\n * back to Claude, so the exact field names can be locked in with zero guessing.\n *\n * You should not need to understand this file. Paste it in, then follow\n * the checklist page step by step.\n */\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n// ───────────────────────── Your Jobber app credentials ─────────────────────────\nconst CLIENT_ID = \"7021f6fd-bacd-427f-b06f-a03ffddca337\";\nconst CLIENT_SECRET =\n \"98a4b35e67bb87363dbd30ec9570b06357ca0043d40d8b185cc45849f6ff9a8e\";\n\nconst JOBBER_AUTH_URL = \"https://api.getjobber.com/api/oauth/authorize\";\nconst JOBBER_TOKEN_URL = \"https://api.getjobber.com/api/oauth/token\";\nconst JOBBER_GRAPHQL_URL = \"https://api.getjobber.com/api/graphql\";\nconst JOBBER_API_VERSION = \"2025-04-16\"; // newest published version as of this writing\n\nconst TOKENS_KEY = \"jobber_tokens\";\n\n// ───────────────────────── small helpers ─────────────────────────\n\nfunction baseUrl(req: Request) {\n const u = new URL(req.url);\n // Must exactly match the redirect URL you pasted into Jobber's Developer Center.\n return `${u.protocol}//${u.host}${u.pathname}`;\n}\n\nasync function saveTokens(tokens: Record) {\n await blob.setJSON(TOKENS_KEY, { ...tokens, saved_at: Date.now() });\n}\n\nasync function getTokens() {\n return await blob.getJSON(TOKENS_KEY);\n}\n\nasync function exchangeCodeForTokens(code: string, redirectUri: string) {\n const res = await fetch(JOBBER_TOKEN_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n grant_type: \"authorization_code\",\n code,\n redirect_uri: redirectUri,\n }),\n });\n const data = await res.json();\n if (!res.ok || data.error) {\n console.log(\"Token exchange failed:\", JSON.stringify(data));\n throw new Error(\n data.error_description || data.error || \"Token exchange failed\",\n );\n }\n return data;\n}\n\nasync function refreshTokens(refreshToken: string) {\n const res = await fetch(JOBBER_TOKEN_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n grant_type: \"refresh_token\",\n refresh_token: refreshToken,\n }),\n });\n const data = await res.json();\n if (!res.ok || data.error) {\n console.log(\"Token refresh failed:\", JSON.stringify(data));\n throw new Error(\n data.error_description || data.error || \"Token refresh failed\",\n );\n }\n return data;\n}\n\n// Returns a good-to-use access token, refreshing it first if it's stale.\n// (Refresh tokens rotate — a new refresh token comes back every time, and we\n// save it, since the old one stops working after one use.)\nasync function getValidAccessToken() {\n const tokens = await getTokens();\n if (!tokens) return null;\n const ageMs = Date.now() - tokens.saved_at;\n const expiresInMs = (tokens.expires_in || 3600) * 1000;\n if (ageMs > expiresInMs - 60_000) {\n const fresh = await refreshTokens(tokens.refresh_token);\n await saveTokens(fresh);\n return fresh.access_token;\n }\n return tokens.access_token;\n}\n\nasync function jobberGraphQL(\n accessToken: string,\n query: string,\n variables: Record,\n) {\n const res = await fetch(JOBBER_GRAPHQL_URL, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n \"X-JOBBER-GRAPHQL-VERSION\": JOBBER_API_VERSION,\n },\n body: JSON.stringify({ query, variables }),\n });\n const data = await res.json();\n console.log(\"Jobber response:\", JSON.stringify(data));\n return data;\n}\n\nfunction page(message: string, connectUrl?: string) {\n return new Response(\n `\n

Good Maid Cleaning — Jobber Connector

${message}

\n ${\n connectUrl\n ? `

Connect to Jobber

`\n : \"\"\n }\n `,\n { headers: { \"Content-Type\": \"text/html\" } },\n );\n}\n\n// A tiny \"look up Jobber's exact rules\" helper. Visit, e.g.:\n// ?schema=JobCreateInput\n// ?schema=ClientCreateInput\n// while connected, and it shows Jobber's own field list as JSON.\nasync function schemaLookup(accessToken: string, typeName: string) {\n const query = `\n query($name: String!) {\n __type(name: $name) {\n name\n kind\n description\n inputFields {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n fields {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n enumValues {\n name\n }\n }\n }\n `;\n return await jobberGraphQL(accessToken, query, { name: typeName });\n}\n\n// Looks up the exact arguments a specific mutation expects, e.g.:\n// ?mutation=jobCreate\nasync function mutationLookup(accessToken: string, fieldName: string) {\n const query = `\n query {\n __type(name: \"Mutation\") {\n fields {\n name\n args {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n }\n }\n }\n `;\n const result = await jobberGraphQL(accessToken, query, {});\n const fields: any[] = result?.data?.__type?.fields || [];\n const match = fields.find((f) =>\n f.name.toLowerCase() === fieldName.toLowerCase()\n );\n return match ||\n {\n error: `No mutation named \"${fieldName}\" found`,\n allMutationNames: fields.map((f) => f.name),\n };\n}\n\n// ───────────────────────── the actual handler ─────────────────────────\n\n// Lets your website (or a quick test page) call this address from a browser.\nconst CORS_HEADERS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const redirectUri = baseUrl(req);\n\n // Browsers send this automatically before a real POST — just say \"go ahead\"\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: CORS_HEADERS });\n }\n\n // Jobber sending you back after you click \"Allow Access\"\n const code = url.searchParams.get(\"code\");\n if (req.method === \"GET\" && code) {\n try {\n const tokens = await exchangeCodeForTokens(code, redirectUri);\n await saveTokens(tokens);\n return page(\n \"✅ Connected to Jobber! You can close this tab — bookings from your website will now be sent here automatically.\",\n );\n } catch (err: any) {\n return page(\n \"❌ Something went wrong connecting to Jobber: \" + err.message +\n \"

Screenshot this and send it to Claude.\",\n );\n }\n }\n\n // Peek at Jobber's exact field names for a given input type\n const schemaType = url.searchParams.get(\"schema\");\n if (req.method === \"GET\" && schemaType) {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return page(\n \"Not connected to Jobber yet — connect first.\",\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`,\n );\n }\n const result = await schemaLookup(accessToken, schemaType);\n return Response.json(result);\n }\n\n // Peek at the exact arguments a mutation expects\n const mutationName = url.searchParams.get(\"mutation\");\n if (req.method === \"GET\" && mutationName) {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return page(\n \"Not connected to Jobber yet — connect first.\",\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`,\n );\n }\n const result = await mutationLookup(accessToken, mutationName);\n return Response.json(result);\n }\n\n // Plain visit with no code — show connect button or \"already connected\"\n if (req.method === \"GET\") {\n const authUrl =\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`;\n const tokens = await getTokens();\n if (tokens && !url.searchParams.has(\"reconnect\")) {\n return page(\n \"✅ Already connected to Jobber. Bookings from your website are sent here automatically.

Just changed your app's scopes/permissions in Jobber's Developer Center? Click here to reconnect and pick those changes up.',\n );\n }\n return page(\n 'Click the button, then click \"Allow Access\" on Jobber\\'s page.',\n authUrl,\n );\n }\n\n // A real booking coming in from the website\n if (req.method === \"POST\") {\n const json = (data: any, status = 200) =>\n Response.json(data, { status, headers: CORS_HEADERS });\n try {\n const booking = await req.json();\n console.log(\"Incoming booking:\", JSON.stringify(booking));\n\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return json(\n {\n ok: false,\n error:\n \"Not connected to Jobber yet. Visit this address in a browser once and click Connect.\",\n },\n 400,\n );\n }\n\n if (!booking.address) {\n return json({\n ok: false,\n error:\n \"Booking is missing a service address — Jobber needs one to create a job.\",\n }, 400);\n }\n\n // 1) Create the client record, along with a \"property\" (Jobber's name\n // for a service address) at the same time.\n const clientMutation = `\n mutation($input: ClientCreateInput!) {\n clientCreate(input: $input) {\n client {\n id\n firstName\n lastName\n properties { id }\n jobberWebUri\n }\n userErrors { message path }\n }\n }\n `;\n const clientInput: Record = {\n firstName: booking.firstName || \"\",\n lastName: booking.lastName || \"\",\n properties: [\n {\n address: {\n street1: booking.address.street || \"\",\n city: booking.address.city || \"\",\n province: booking.address.province || \"\",\n postalCode: booking.address.postalCode || \"\",\n country: booking.address.country || \"Canada\",\n },\n },\n ],\n };\n if (booking.email) {\n clientInput.emails = [{\n description: \"MAIN\",\n primary: true,\n address: booking.email,\n }];\n }\n if (booking.phone) {\n clientInput.phones = [{\n description: \"MAIN\",\n primary: true,\n number: booking.phone,\n }];\n }\n\n const clientResult = await jobberGraphQL(accessToken, clientMutation, {\n input: clientInput,\n });\n const clientTopErrors = clientResult.errors;\n const clientUserErrors = clientResult?.data?.clientCreate?.userErrors;\n if (clientTopErrors?.length || clientUserErrors?.length) {\n return json(\n {\n ok: false,\n step: \"clientCreate\",\n error: clientTopErrors || clientUserErrors,\n },\n 400,\n );\n }\n const client = clientResult.data.clientCreate.client;\n const clientId = client.id;\n const propertyId = client.properties?.[0]?.id;\n if (!propertyId) {\n return json({\n ok: false,\n step: \"clientCreate\",\n error:\n \"Client was created but no property/address came back with it.\",\n clientId,\n }, 400);\n }\n\n // 2) Create the job at that property — now with a real scheduled visit\n // and a real priced line item, instead of stuffing the date/time/price\n // into a plain-text note. This is what makes the job show up already\n // scheduled on your calendar, instead of sitting in \"Action Required\".\n const instructionsParts = [\n booking.notes,\n booking.scheduledDate && `Requested date: ${booking.scheduledDate}`,\n booking.scheduledTime && `Requested time: ${booking.scheduledTime}`,\n ].filter(Boolean);\n\n // Roughly how long the crew will be on site, estimated from the quoted\n // price rather than a flat guess — bigger/pricier jobs get more time on\n // the calendar. $45/hour is a placeholder assumed crew rate; change\n // just this one number if the real rate is different.\n const ASSUMED_HOURLY_RATE = 45;\n const MIN_JOB_HOURS = 1;\n const MAX_JOB_HOURS = 6;\n function estimateJobHours(price?: number) {\n if (!price) return 2; // no price given — fall back to a plain 2-hour guess\n const raw = price / ASSUMED_HOURLY_RATE;\n const clamped = Math.min(MAX_JOB_HOURS, Math.max(MIN_JOB_HOURS, raw));\n return Math.round(clamped * 4) / 4; // nearest 15 minutes\n }\n\n // Converts a time like \"10:00 AM\" into 24-hour \"10:00:00\", and returns\n // an end time `durationHours` later.\n function parseTimeRange(\n timeStr: string | undefined,\n durationHours: number,\n ) {\n if (!timeStr) return null;\n const m = /^(\\d{1,2}):(\\d{2})\\s*(AM|PM)?$/i.exec(timeStr.trim());\n if (!m) return null;\n let hour = parseInt(m[1], 10);\n let minute = parseInt(m[2], 10);\n const ampm = (m[3] || \"\").toUpperCase();\n if (ampm === \"PM\" && hour !== 12) hour += 12;\n if (ampm === \"AM\" && hour === 12) hour = 0;\n const pad = (n: number) => String(n).padStart(2, \"0\");\n const start = `${pad(hour)}:${pad(minute)}:00`;\n const totalStartMin = hour * 60 + minute;\n const totalEndMin = totalStartMin + Math.round(durationHours * 60);\n const endHour = Math.floor(totalEndMin / 60) % 24;\n const endMinute = totalEndMin % 60;\n const end = `${pad(endHour)}:${pad(endMinute)}:00`;\n return { start, end };\n }\n const jobHours = estimateJobHours(booking.quotedPrice);\n const timeRange = parseTimeRange(booking.scheduledTime, jobHours);\n\n const jobMutation = `\n mutation($input: JobCreateAttributes!) {\n jobCreate(input: $input) {\n job { id jobNumber }\n userErrors { message path }\n }\n }\n `;\n // Repeat customers (weekly/biweekly/monthly) get a real recurring\n // schedule instead of a single one-off visit — Jobber takes a standard\n // calendar \"RRULE\" string for this.\n // Jobber requires the \"RRULE:\" prefix on these — leaving it off is\n // what caused the first attempt to fail with a scheduling.recurrence error.\n const RECURRENCE_RULES: Record = {\n weekly: \"RRULE:FREQ=WEEKLY;INTERVAL=1\",\n biweekly: \"RRULE:FREQ=WEEKLY;INTERVAL=2\",\n monthly: \"RRULE:FREQ=MONTHLY;INTERVAL=1\",\n };\n const isRecurring = !!booking.recurring &&\n RECURRENCE_RULES[booking.frequency];\n\n const jobInput: Record = {\n propertyId,\n title: booking.serviceType || \"Cleaning\",\n instructions: instructionsParts.join(\"\\n\"),\n // One-off cleanings are invoiced once the job's marked done. Recurring\n // cleanings bill per visit instead, since the job itself never \"ends\" —\n // Jobber requires invoicingType: VISIT_BASED to go with PER_VISIT.\n invoicing: isRecurring\n ? { invoicingType: \"VISIT_BASED\", invoicingSchedule: \"PER_VISIT\" }\n : {\n invoicingType: \"FIXED_PRICE\",\n invoicingSchedule: \"ON_COMPLETION\",\n },\n };\n if (isRecurring) {\n // Jobber requires an explicit duration whenever recurrence is set,\n // since each repeat instance needs to know how long the visit runs.\n jobInput.arrivalWindow = {\n durationInMinutes: Math.round(jobHours * 60),\n };\n }\n if (booking.quotedPrice) {\n jobInput.lineItems = [\n {\n name: booking.serviceType || \"Cleaning\",\n unitPrice: booking.quotedPrice,\n quantity: 1,\n saveToProductsAndServices: false,\n },\n ];\n }\n if (booking.scheduledDate) {\n jobInput.timeframe = { startAt: booking.scheduledDate };\n // A recurring job needs an overall duration too, separate from each\n // visit's length — this is the length of the ongoing plan itself.\n // Using 1 year as a placeholder \"runs indefinitely until cancelled\"\n // window; customers can cancel/pause anytime per the site's copy.\n if (isRecurring) {\n jobInput.timeframe.durationValue = 1;\n jobInput.timeframe.durationUnits = \"YEARS\";\n }\n }\n if (timeRange) {\n jobInput.scheduling = {\n createVisits: true,\n notifyTeam: false,\n startTime: timeRange.start,\n endTime: timeRange.end,\n ...(isRecurring\n ? { recurrence: RECURRENCE_RULES[booking.frequency] }\n : {}),\n };\n }\n\n const jobResult = await jobberGraphQL(accessToken, jobMutation, {\n input: jobInput,\n });\n const jobTopErrors = jobResult.errors;\n const jobUserErrors = jobResult?.data?.jobCreate?.userErrors;\n if (jobTopErrors?.length || jobUserErrors?.length) {\n return json(\n {\n ok: false,\n step: \"jobCreate\",\n error: jobTopErrors || jobUserErrors,\n clientId,\n propertyId,\n },\n 400,\n );\n }\n\n return json({\n ok: true,\n clientId,\n propertyId,\n job: jobResult.data.jobCreate.job,\n // Link to the customer's own Jobber account page — once Jobber\n // Payments + Wallet is turned on, this is where they add their card.\n clientPortalUrl: client.jobberWebUri || null,\n });\n } catch (err: any) {\n console.log(\"Booking handler error:\", err.message || String(err));\n return json({ ok: false, error: err.message || String(err) }, 500);\n }\n }\n\n return page(\"Nothing to see here.\");\n}","createdAt",["D",1788920825796],"branchVersion","branchId","83d2718d-a70c-4c30-87d3-49b00a03d15a","id","98d33484-67a1-4e15-b5e2-908bdd4db21c","booking",["D",1788638314493],"deletedAt","legacyEnvVars",false,"privacy","public","httpPrivacy","description","","imageUrl","2cd2bd26-9686-4dcd-a759-914e239335a0","pinnedFileId","ff4c00a8-abf8-11f1-941b-1607ee4eb77e","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a07323-8ac8-72a9-899a-bc2445c41a3d","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_102":53},"org",{"_96":95,"_97":53,"_98":53,"_18":55,"_99":100,"_101":48},"branch",{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"isOwned",27,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","goodmaidcleaning","handle","displayName","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_32":44,"_37":152,"_46":-5,"_47":48,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":153,"_80":154,"_82":155,"_84":48},"tree",[147],"files",[147],"counts",{"_137":62,"_138":132,"_139":62,"_140":141,"_142":143},"contents",[124],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":125,"_32":126,"_30":127,"_128":-5,"_40":41,"_39":129,"_130":48,"_37":131,"_13":132,"_33":133,"_35":134,"_24":48,"_135":-5,"_27":136},"8c3a6024-7c01-44e1-9d48-429fa907de84","main.ts","2d32d308-a964-11f1-905d-1607ee4eb77e","parentId",17,"latest",["D",1788920814185],1,"script","/**\n * Good Maid Cleaning — Jobber booking relay\n * --------------------------------------------------\n * This one file does three jobs:\n * 1. Lets you connect this to Jobber (visit the address once, click \"Connect\")\n * 2. Receives real bookings from your website and creates them in Jobber\n * 3. Has a couple of \"peek at Jobber's rules\" links Henry can visit and send\n * back to Claude, so the exact field names can be locked in with zero guessing.\n *\n * You should not need to understand this file. Paste it in, then follow\n * the checklist page step by step.\n */\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n// ───────────────────────── Your Jobber app credentials ─────────────────────────\nconst CLIENT_ID = \"7021f6fd-bacd-427f-b06f-a03ffddca337\";\nconst CLIENT_SECRET =\n \"98a4b35e67bb87363dbd30ec9570b06357ca0043d40d8b185cc45849f6ff9a8e\";\n\nconst JOBBER_AUTH_URL = \"https://api.getjobber.com/api/oauth/authorize\";\nconst JOBBER_TOKEN_URL = \"https://api.getjobber.com/api/oauth/token\";\nconst JOBBER_GRAPHQL_URL = \"https://api.getjobber.com/api/graphql\";\nconst JOBBER_API_VERSION = \"2025-04-16\"; // newest published version as of this writing\n\nconst TOKENS_KEY = \"jobber_tokens\";\n\n// ───────────────────────── small helpers ─────────────────────────\n\nfunction baseUrl(req: Request) {\n const u = new URL(req.url);\n // Must exactly match the redirect URL you pasted into Jobber's Developer Center.\n return `${u.protocol}//${u.host}${u.pathname}`;\n}\n\nasync function saveTokens(tokens: Record) {\n await blob.setJSON(TOKENS_KEY, { ...tokens, saved_at: Date.now() });\n}\n\nasync function getTokens() {\n return await blob.getJSON(TOKENS_KEY);\n}\n\nasync function exchangeCodeForTokens(code: string, redirectUri: string) {\n const res = await fetch(JOBBER_TOKEN_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n grant_type: \"authorization_code\",\n code,\n redirect_uri: redirectUri,\n }),\n });\n const data = await res.json();\n if (!res.ok || data.error) {\n console.log(\"Token exchange failed:\", JSON.stringify(data));\n throw new Error(\n data.error_description || data.error || \"Token exchange failed\",\n );\n }\n return data;\n}\n\nasync function refreshTokens(refreshToken: string) {\n const res = await fetch(JOBBER_TOKEN_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/x-www-form-urlencoded\" },\n body: new URLSearchParams({\n client_id: CLIENT_ID,\n client_secret: CLIENT_SECRET,\n grant_type: \"refresh_token\",\n refresh_token: refreshToken,\n }),\n });\n const data = await res.json();\n if (!res.ok || data.error) {\n console.log(\"Token refresh failed:\", JSON.stringify(data));\n throw new Error(\n data.error_description || data.error || \"Token refresh failed\",\n );\n }\n return data;\n}\n\n// Returns a good-to-use access token, refreshing it first if it's stale.\n// (Refresh tokens rotate — a new refresh token comes back every time, and we\n// save it, since the old one stops working after one use.)\nasync function getValidAccessToken() {\n const tokens = await getTokens();\n if (!tokens) return null;\n const ageMs = Date.now() - tokens.saved_at;\n const expiresInMs = (tokens.expires_in || 3600) * 1000;\n if (ageMs > expiresInMs - 60_000) {\n const fresh = await refreshTokens(tokens.refresh_token);\n await saveTokens(fresh);\n return fresh.access_token;\n }\n return tokens.access_token;\n}\n\nasync function jobberGraphQL(\n accessToken: string,\n query: string,\n variables: Record,\n) {\n const res = await fetch(JOBBER_GRAPHQL_URL, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${accessToken}`,\n \"Content-Type\": \"application/json\",\n \"X-JOBBER-GRAPHQL-VERSION\": JOBBER_API_VERSION,\n },\n body: JSON.stringify({ query, variables }),\n });\n const data = await res.json();\n console.log(\"Jobber response:\", JSON.stringify(data));\n return data;\n}\n\nfunction page(message: string, connectUrl?: string) {\n return new Response(\n `\n

Good Maid Cleaning — Jobber Connector

${message}

\n ${\n connectUrl\n ? `

Connect to Jobber

`\n : \"\"\n }\n `,\n { headers: { \"Content-Type\": \"text/html\" } },\n );\n}\n\n// A tiny \"look up Jobber's exact rules\" helper. Visit, e.g.:\n// ?schema=JobCreateInput\n// ?schema=ClientCreateInput\n// while connected, and it shows Jobber's own field list as JSON.\nasync function schemaLookup(accessToken: string, typeName: string) {\n const query = `\n query($name: String!) {\n __type(name: $name) {\n name\n kind\n description\n inputFields {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n fields {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n enumValues {\n name\n }\n }\n }\n `;\n return await jobberGraphQL(accessToken, query, { name: typeName });\n}\n\n// Looks up the exact arguments a specific mutation expects, e.g.:\n// ?mutation=jobCreate\nasync function mutationLookup(accessToken: string, fieldName: string) {\n const query = `\n query {\n __type(name: \"Mutation\") {\n fields {\n name\n args {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n }\n }\n }\n `;\n const result = await jobberGraphQL(accessToken, query, {});\n const fields: any[] = result?.data?.__type?.fields || [];\n const match = fields.find((f) =>\n f.name.toLowerCase() === fieldName.toLowerCase()\n );\n return match ||\n {\n error: `No mutation named \"${fieldName}\" found`,\n allMutationNames: fields.map((f) => f.name),\n };\n}\n\n// Same idea as mutationLookup, but for top-level read queries, e.g.:\n// ?query=clients\nasync function queryLookup(accessToken: string, fieldName: string) {\n const query = `\n query {\n __type(name: \"Query\") {\n fields {\n name\n args {\n name\n type { name kind ofType { name kind ofType { name kind } } }\n }\n }\n }\n }\n `;\n const result = await jobberGraphQL(accessToken, query, {});\n const fields: any[] = result?.data?.__type?.fields || [];\n const match = fields.find((f) =>\n f.name.toLowerCase() === fieldName.toLowerCase()\n );\n return match ||\n {\n error: `No query named \"${fieldName}\" found`,\n allQueryNames: fields.map((f) => f.name),\n };\n}\n\n// ───────────────── first-clean discount + cancellation ─────────────────\n// These two are called by the payment relay (server-to-server, not by the\n// browser directly) so the Jobber OAuth token never has to leave this file.\n\n// Best-effort: is there already a Jobber client whose email, phone, or\n// street address matches what was just typed into checkout? If Jobber's\n// `clients` query needs a different search argument than `searchTerm`,\n// this will throw — the caller treats any error as \"assume returning\n// customer, no discount\" rather than letting it block checkout. Visit\n// ?query=clients once to confirm the real argument name if\n// this doesn't work on the first try.\nasync function findMatchingClient(\n accessToken: string,\n email?: string,\n phone?: string,\n address?: string,\n) {\n const terms = [email, phone, address].filter(Boolean) as string[];\n for (const term of terms) {\n const query = `\n query($term: String!) {\n clients(searchTerm: $term, first: 5) {\n nodes {\n id\n emails { address }\n phones { number }\n billingAddress { street1 }\n }\n }\n }\n `;\n const result = await jobberGraphQL(accessToken, query, { term });\n if (result.errors?.length) {\n throw new Error(result.errors.map((e: any) => e.message).join(\"; \"));\n }\n const nodes: any[] = result?.data?.clients?.nodes || [];\n for (const c of nodes) {\n const emailHit = email &&\n (c.emails || []).some((e: any) =>\n (e.address || \"\").toLowerCase() === email.toLowerCase()\n );\n const phoneHit = phone &&\n (c.phones || []).some((p: any) =>\n (p.number || \"\").replace(/\\D/g, \"\") === phone.replace(/\\D/g, \"\")\n );\n const addrHit = address &&\n (c.billingAddress?.street1 || \"\").toLowerCase().trim() ===\n address.toLowerCase().trim();\n if (emailHit || phoneHit || addrHit) return true;\n }\n }\n return false;\n}\n\n// Best-effort job cancellation. \"jobClose\" is a guess at the real mutation\n// name — visit ?mutation=jobClose (or jobArchive, jobDelete —\n// try each) to see whether Jobber accepts it and what arguments it wants,\n// exactly like jobCreate was confirmed originally. If this throws, the\n// caller still refunds the customer and emails you to remove the job from\n// your calendar by hand, so a cleaner never shows up to a cancelled job.\nasync function cancelJobberJob(accessToken: string, jobberJobId: string) {\n const mutation = `\n mutation($id: EncodedId!) {\n jobClose(jobId: $id) {\n job { id }\n userErrors { message }\n }\n }\n `;\n const result = await jobberGraphQL(accessToken, mutation, {\n id: jobberJobId,\n });\n if (result.errors?.length) {\n throw new Error(result.errors.map((e: any) => e.message).join(\"; \"));\n }\n const userErrors = result?.data?.jobClose?.userErrors;\n if (userErrors?.length) {\n throw new Error(userErrors.map((e: any) => e.message).join(\"; \"));\n }\n return true;\n}\n\n// ───────────────────────── the actual handler ─────────────────────────\n\n// Lets your website (or a quick test page) call this address from a browser.\nconst CORS_HEADERS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"POST, GET, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type\",\n};\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const redirectUri = baseUrl(req);\n\n // Browsers send this automatically before a real POST — just say \"go ahead\"\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: CORS_HEADERS });\n }\n\n // Jobber sending you back after you click \"Allow Access\"\n const code = url.searchParams.get(\"code\");\n if (req.method === \"GET\" && code) {\n try {\n const tokens = await exchangeCodeForTokens(code, redirectUri);\n await saveTokens(tokens);\n return page(\n \"✅ Connected to Jobber! You can close this tab — bookings from your website will now be sent here automatically.\",\n );\n } catch (err: any) {\n return page(\n \"❌ Something went wrong connecting to Jobber: \" + err.message +\n \"

Screenshot this and send it to Claude.\",\n );\n }\n }\n\n // Peek at Jobber's exact field names for a given input type\n const schemaType = url.searchParams.get(\"schema\");\n if (req.method === \"GET\" && schemaType) {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return page(\n \"Not connected to Jobber yet — connect first.\",\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`,\n );\n }\n const result = await schemaLookup(accessToken, schemaType);\n return Response.json(result);\n }\n\n // Peek at the exact arguments a mutation expects\n const mutationName = url.searchParams.get(\"mutation\");\n if (req.method === \"GET\" && mutationName) {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return page(\n \"Not connected to Jobber yet — connect first.\",\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`,\n );\n }\n const result = await mutationLookup(accessToken, mutationName);\n return Response.json(result);\n }\n\n // Peek at the exact arguments a read query expects (e.g. ?query=clients)\n const queryName = url.searchParams.get(\"query\");\n if (req.method === \"GET\" && queryName) {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return page(\n \"Not connected to Jobber yet — connect first.\",\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`,\n );\n }\n const result = await queryLookup(accessToken, queryName);\n return Response.json(result);\n }\n\n // Plain visit with no code — show connect button or \"already connected\"\n if (req.method === \"GET\") {\n const authUrl =\n `${JOBBER_AUTH_URL}?response_type=code&client_id=${CLIENT_ID}&redirect_uri=${\n encodeURIComponent(redirectUri)\n }&state=setup`;\n const tokens = await getTokens();\n if (tokens && !url.searchParams.has(\"reconnect\")) {\n return page(\n \"✅ Already connected to Jobber. Bookings from your website are sent here automatically.

Just changed your app's scopes/permissions in Jobber's Developer Center? Click here to reconnect and pick those changes up.',\n );\n }\n return page(\n 'Click the button, then click \"Allow Access\" on Jobber\\'s page.',\n authUrl,\n );\n }\n\n // A real booking coming in from the website\n if (req.method === \"POST\") {\n const json = (data: any, status = 200) =>\n Response.json(data, { status, headers: CORS_HEADERS });\n try {\n const booking = await req.json();\n\n // These two actions are called by the payment relay, server-to-server\n // — not by the customer's browser — so they're handled first, before\n // the default \"create a booking\" behavior below.\n if (booking.action === \"checkClient\") {\n try {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return json({\n isReturning: false,\n error: \"Not connected to Jobber\",\n });\n }\n const isReturning = await findMatchingClient(\n accessToken,\n booking.email,\n booking.phone,\n booking.address,\n );\n return json({ isReturning });\n } catch (err: any) {\n console.log(\n \"checkClient failed, defaulting to isReturning:true (no discount):\",\n err.message || String(err),\n );\n return json({ isReturning: true, error: err.message || String(err) });\n }\n }\n if (booking.action === \"cancelJob\") {\n try {\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return json({ ok: false, error: \"Not connected to Jobber\" }, 400);\n }\n await cancelJobberJob(accessToken, booking.jobberJobId);\n return json({ ok: true });\n } catch (err: any) {\n console.log(\"cancelJob failed:\", err.message || String(err));\n return json({ ok: false, error: err.message || String(err) }, 400);\n }\n }\n\n console.log(\"Incoming booking:\", JSON.stringify(booking));\n\n const accessToken = await getValidAccessToken();\n if (!accessToken) {\n return json(\n {\n ok: false,\n error:\n \"Not connected to Jobber yet. Visit this address in a browser once and click Connect.\",\n },\n 400,\n );\n }\n\n if (!booking.address) {\n return json({\n ok: false,\n error:\n \"Booking is missing a service address — Jobber needs one to create a job.\",\n }, 400);\n }\n\n // 1) Create the client record, along with a \"property\" (Jobber's name\n // for a service address) at the same time.\n const clientMutation = `\n mutation($input: ClientCreateInput!) {\n clientCreate(input: $input) {\n client {\n id\n firstName\n lastName\n properties { id }\n jobberWebUri\n }\n userErrors { message path }\n }\n }\n `;\n const clientInput: Record = {\n firstName: booking.firstName || \"\",\n lastName: booking.lastName || \"\",\n properties: [\n {\n address: {\n street1: booking.address.street || \"\",\n city: booking.address.city || \"\",\n province: booking.address.province || \"\",\n postalCode: booking.address.postalCode || \"\",\n country: booking.address.country || \"Canada\",\n },\n },\n ],\n };\n if (booking.email) {\n clientInput.emails = [{\n description: \"MAIN\",\n primary: true,\n address: booking.email,\n }];\n }\n if (booking.phone) {\n clientInput.phones = [{\n description: \"MAIN\",\n primary: true,\n number: booking.phone,\n }];\n }\n\n const clientResult = await jobberGraphQL(accessToken, clientMutation, {\n input: clientInput,\n });\n const clientTopErrors = clientResult.errors;\n const clientUserErrors = clientResult?.data?.clientCreate?.userErrors;\n if (clientTopErrors?.length || clientUserErrors?.length) {\n return json(\n {\n ok: false,\n step: \"clientCreate\",\n error: clientTopErrors || clientUserErrors,\n },\n 400,\n );\n }\n const client = clientResult.data.clientCreate.client;\n const clientId = client.id;\n const propertyId = client.properties?.[0]?.id;\n if (!propertyId) {\n return json({\n ok: false,\n step: \"clientCreate\",\n error:\n \"Client was created but no property/address came back with it.\",\n clientId,\n }, 400);\n }\n\n // 2) Create the job at that property — now with a real scheduled visit\n // and a real priced line item, instead of stuffing the date/time/price\n // into a plain-text note. This is what makes the job show up already\n // scheduled on your calendar, instead of sitting in \"Action Required\".\n const instructionsParts = [\n booking.notes,\n booking.scheduledDate && `Requested date: ${booking.scheduledDate}`,\n booking.scheduledTime && `Requested time: ${booking.scheduledTime}`,\n ].filter(Boolean);\n\n // Roughly how long the crew will be on site, estimated from the quoted\n // price rather than a flat guess — bigger/pricier jobs get more time on\n // the calendar. $45/hour is a placeholder assumed crew rate; change\n // just this one number if the real rate is different.\n const ASSUMED_HOURLY_RATE = 45;\n const MIN_JOB_HOURS = 1;\n const MAX_JOB_HOURS = 6;\n function estimateJobHours(price?: number) {\n if (!price) return 2; // no price given — fall back to a plain 2-hour guess\n const raw = price / ASSUMED_HOURLY_RATE;\n const clamped = Math.min(MAX_JOB_HOURS, Math.max(MIN_JOB_HOURS, raw));\n return Math.round(clamped * 4) / 4; // nearest 15 minutes\n }\n\n // Converts a time like \"10:00 AM\" into 24-hour \"10:00:00\", and returns\n // an end time `durationHours` later.\n function parseTimeRange(\n timeStr: string | undefined,\n durationHours: number,\n ) {\n if (!timeStr) return null;\n const m = /^(\\d{1,2}):(\\d{2})\\s*(AM|PM)?$/i.exec(timeStr.trim());\n if (!m) return null;\n let hour = parseInt(m[1], 10);\n let minute = parseInt(m[2], 10);\n const ampm = (m[3] || \"\").toUpperCase();\n if (ampm === \"PM\" && hour !== 12) hour += 12;\n if (ampm === \"AM\" && hour === 12) hour = 0;\n const pad = (n: number) => String(n).padStart(2, \"0\");\n const start = `${pad(hour)}:${pad(minute)}:00`;\n const totalStartMin = hour * 60 + minute;\n const totalEndMin = totalStartMin + Math.round(durationHours * 60);\n const endHour = Math.floor(totalEndMin / 60) % 24;\n const endMinute = totalEndMin % 60;\n const end = `${pad(endHour)}:${pad(endMinute)}:00`;\n return { start, end };\n }\n const jobHours = estimateJobHours(booking.quotedPrice);\n const timeRange = parseTimeRange(booking.scheduledTime, jobHours);\n\n const jobMutation = `\n mutation($input: JobCreateAttributes!) {\n jobCreate(input: $input) {\n job { id jobNumber }\n userErrors { message path }\n }\n }\n `;\n // Repeat customers (weekly/biweekly/monthly) get a real recurring\n // schedule instead of a single one-off visit — Jobber takes a standard\n // calendar \"RRULE\" string for this.\n // Jobber requires the \"RRULE:\" prefix on these — leaving it off is\n // what caused the first attempt to fail with a scheduling.recurrence error.\n const RECURRENCE_RULES: Record = {\n weekly: \"RRULE:FREQ=WEEKLY;INTERVAL=1\",\n biweekly: \"RRULE:FREQ=WEEKLY;INTERVAL=2\",\n monthly: \"RRULE:FREQ=MONTHLY;INTERVAL=1\",\n };\n const isRecurring = !!booking.recurring &&\n RECURRENCE_RULES[booking.frequency];\n\n const jobInput: Record = {\n propertyId,\n title: booking.serviceType || \"Cleaning\",\n instructions: instructionsParts.join(\"\\n\"),\n // One-off cleanings are invoiced once the job's marked done. Recurring\n // cleanings bill per visit instead, since the job itself never \"ends\" —\n // Jobber requires invoicingType: VISIT_BASED to go with PER_VISIT.\n invoicing: isRecurring\n ? { invoicingType: \"VISIT_BASED\", invoicingSchedule: \"PER_VISIT\" }\n : {\n invoicingType: \"FIXED_PRICE\",\n invoicingSchedule: \"ON_COMPLETION\",\n },\n };\n if (isRecurring) {\n // Jobber requires an explicit duration whenever recurrence is set,\n // since each repeat instance needs to know how long the visit runs.\n jobInput.arrivalWindow = {\n durationInMinutes: Math.round(jobHours * 60),\n };\n }\n if (booking.quotedPrice) {\n jobInput.lineItems = [\n {\n name: booking.serviceType || \"Cleaning\",\n unitPrice: booking.quotedPrice,\n quantity: 1,\n saveToProductsAndServices: false,\n },\n ];\n }\n if (booking.scheduledDate) {\n jobInput.timeframe = { startAt: booking.scheduledDate };\n // A recurring job needs an overall duration too, separate from each\n // visit's length — this is the length of the ongoing plan itself.\n // Using 1 year as a placeholder \"runs indefinitely until cancelled\"\n // window; customers can cancel/pause anytime per the site's copy.\n if (isRecurring) {\n jobInput.timeframe.durationValue = 1;\n jobInput.timeframe.durationUnits = \"YEARS\";\n }\n }\n if (timeRange) {\n jobInput.scheduling = {\n createVisits: true,\n notifyTeam: false,\n startTime: timeRange.start,\n endTime: timeRange.end,\n ...(isRecurring\n ? { recurrence: RECURRENCE_RULES[booking.frequency] }\n : {}),\n };\n }\n\n const jobResult = await jobberGraphQL(accessToken, jobMutation, {\n input: jobInput,\n });\n const jobTopErrors = jobResult.errors;\n const jobUserErrors = jobResult?.data?.jobCreate?.userErrors;\n if (jobTopErrors?.length || jobUserErrors?.length) {\n return json(\n {\n ok: false,\n step: \"jobCreate\",\n error: jobTopErrors || jobUserErrors,\n clientId,\n propertyId,\n },\n 400,\n );\n }\n\n return json({\n ok: true,\n clientId,\n propertyId,\n job: jobResult.data.jobCreate.job,\n // Link to the customer's own Jobber account page — once Jobber\n // Payments + Wallet is turned on, this is where they add their card.\n clientPortalUrl: client.jobberWebUri || null,\n });\n } catch (err: any) {\n console.log(\"Booking handler error:\", err.message || String(err));\n return json({ ok: false, error: err.message || String(err) }, 500);\n }\n }\n\n return page(\"Nothing to see here.\");\n}","label",[126],"pulls","branches","forks","envVars",{"_144":62,"_146":62},"connections",{"_144":62,"_145":62},"count","unfilledCount","emptyCount",{"_42":125,"_32":126,"_30":127,"_128":-5,"_40":41,"_39":129,"_130":48,"_37":148,"_13":132,"_33":133,"_35":134,"_24":48,"_135":-5,"_149":150,"_27":151},["D",1788920814185],"children",[],[126],["D",1788638314493],{"_96":95,"_102":53},{"_96":95,"_97":53,"_98":53,"_18":55,"_99":100,"_101":48},{"_13":85,"_32":86,"_42":41,"_87":43,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":44,"_94":95},"ctx",{"_78":-5,"_121":189,"_190":191,"_192":193,"_194":48,"_195":48,"_196":48,"_197":25,"_198":-5,"_199":-7,"_200":-7,"_201":62,"_202":48,"_203":48,"_204":-5,"_205":48,"_206":48,"_207":48,"_208":-5},"ENV",{"_160":161,"_162":163,"_164":86,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188},"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 · v18