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}",[29],"pulls","branches",1,"forks","envVars",{"_147":61,"_149":61},"connections",{"_147":61,"_148":61},"count","unfilledCount","emptyCount",{"_42":131,"_32":29,"_30":132,"_126":-5,"_40":41,"_39":133,"_127":24,"_37":156,"_13":135,"_33":136,"_35":137,"_23":24,"_129":-5,"_153":157,"_26":158},{"_42":125,"_32":27,"_30":31,"_126":-5,"_40":41,"_39":14,"_127":24,"_37":152,"_13":61,"_33":34,"_35":36,"_23":24,"_129":-5,"_153":154,"_26":155},["D",1788922134845],"children",[],[27],["D",1788922034422],[],[29],["D",1788638314493],{"_95":94,"_101":52},{"_95":94,"_96":52,"_97":52,"_18":54,"_98":99,"_100":24},{"_13":84,"_32":85,"_42":41,"_86":43,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":44,"_93":94},"ctx",{"_77":-5,"_120":196,"_197":198,"_199":200,"_201":24,"_202":24,"_203":24,"_204":57,"_205":-5,"_206":-7,"_207":-7,"_208":61,"_209":24,"_210":24,"_211":-5,"_212":24,"_213":24,"_214":24,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":85,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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 · v21