Join Empower Lifestyle Group

\n \n \n \n

\n \n\n`;\n\n return new Response(html, {\n headers: {\n \"Content-Type\": \"text/html; charset=utf-8\",\n ...CORS_HEADERS,\n },\n });\n}\n\n// Main handler\nexport default async function (req: Request): Promise {\n // Handle CORS preflight\n if (req.method === \"OPTIONS\") {\n return new Response(null, { headers: CORS_HEADERS });\n }\n\n // Serve the registration page on GET\n if (req.method === \"GET\") {\n const url = new URL(req.url);\n const adminAction = url.searchParams.get(\"admin\");\n \n if (adminAction) {\n const GHL_AGENCY_TOKEN = Deno.env.get(\"GHL_AGENCY_TOKEN\");\n const GHL_COMPANY_ID = Deno.env.get(\"GHL_COMPANY_ID\");\n if (!GHL_AGENCY_TOKEN || !GHL_COMPANY_ID) {\n return Response.json({ error: \"Missing env vars\" }, { status: 500, headers: CORS_HEADERS });\n }\n \n if (adminAction === \"search_user\") {\n const email = url.searchParams.get(\"email\") || \"\";\n const res = await fetch(`${GHL_BASE}/users/search?companyId=${GHL_COMPANY_ID}&query=${encodeURIComponent(email)}&limit=10`, {\n headers: { \"Authorization\": `Bearer ${GHL_AGENCY_TOKEN}`, \"Version\": \"2021-07-28\", \"Accept\": \"application/json\" },\n });\n return Response.json(await res.json(), { headers: CORS_HEADERS });\n }\n \n if (adminAction === \"update_user\") {\n const userId = url.searchParams.get(\"userId\") || \"\";\n const email = url.searchParams.get(\"email\") || \"\";\n const locationId = url.searchParams.get(\"locationId\") || \"\";\n const res = await fetch(`${GHL_BASE}/users/${userId}`, {\n method: \"PUT\",\n headers: { \"Authorization\": `Bearer ${GHL_AGENCY_TOKEN}`, \"Content-Type\": \"application/json\", \"Version\": \"2021-07-28\", \"Accept\": \"application/json\" },\n body: JSON.stringify({\n companyId: GHL_COMPANY_ID,\n ...(email ? { email } : {}),\n ...(locationId ? { locationIds: [locationId] } : {}),\n }),\n });\n return Response.json(await res.json(), { headers: CORS_HEADERS });\n }\n \n return Response.json({ error: \"Unknown admin action\" }, { status: 400, headers: CORS_HEADERS });\n }\n \n return serveRegistrationPage();\n }\n\n if (req.method !== \"POST\") {\n return Response.json({ error: \"Method not allowed\" }, { status: 405 });\n }\n\n try {\n const body = await req.json();\n console.log(\"Registration request received:\", JSON.stringify(body));\n\n // ------- 1. Validate required fields -------\n const required = [\n \"first_name\",\n \"last_name\",\n \"email\",\n \"agent_code\",\n \"recruiting_agent_code\",\n ];\n const missing = required.filter((f) => !body[f]);\n if (missing.length > 0) {\n return Response.json(\n { error: `Missing required fields: ${missing.join(\", \")}` },\n { status: 400, headers: CORS_HEADERS },\n );\n }\n\n // ------- 2. Read environment variables -------\n const GHL_AGENCY_TOKEN = Deno.env.get(\"GHL_AGENCY_TOKEN\");\n const GHL_API_TOKEN = Deno.env.get(\"GHL_API_TOKEN\");\n const GHL_COMPANY_ID = Deno.env.get(\"GHL_COMPANY_ID\");\n const GHL_SNAPSHOT_ID = Deno.env.get(\"GHL_SNAPSHOT_ID\");\n const GHL_LOCATION_ID = Deno.env.get(\"GHL_LOCATION_ID\");\n\n if (\n !GHL_AGENCY_TOKEN || !GHL_API_TOKEN || !GHL_COMPANY_ID || !GHL_LOCATION_ID\n ) {\n console.error(\"Missing required env vars.\");\n return Response.json({ error: \"Server configuration error\" }, {\n status: 500,\n headers: CORS_HEADERS,\n });\n }\n\n const agentCode = body.agent_code.trim();\n const recruitingAgentCode = body.recruiting_agent_code.trim();\n\n // ------- 3. Create GHL Sub-Account (Agency Token) -------\n const locationPayload: Record = {\n name: `${body.first_name} ${body.last_name}`,\n companyId: GHL_COMPANY_ID,\n email: body.email,\n phone: body.phone || \"\",\n city: body.city || \"\",\n state: body.state || \"\",\n country: \"CA\",\n timezone: \"America/Vancouver\",\n prospectInfo: {\n firstName: body.first_name,\n lastName: body.last_name,\n email: body.email,\n },\n };\n\n if (GHL_SNAPSHOT_ID) {\n locationPayload.snapshotId = GHL_SNAPSHOT_ID;\n }\n\n console.log(\"Creating sub-account with agency token...\");\n const createRes = await ghlFetch(\"/locations/\", GHL_AGENCY_TOKEN, {\n method: \"POST\",\n body: JSON.stringify(locationPayload),\n });\n\n if (!createRes.ok) {\n console.error(\n \"Sub-account creation failed:\",\n JSON.stringify(createRes.data),\n );\n return Response.json(\n { error: \"Failed to create sub-account\", details: createRes.data },\n { status: createRes.status, headers: CORS_HEADERS },\n );\n }\n\n const newLocationId = createRes.data.id || createRes.data.locationId ||\n createRes.data?.location?.id;\n console.log(\"Sub-account created:\", newLocationId);\n\n // ------- 4. Upsert Contact in Main Location (PIT Token) -------\n console.log(\"Upserting contact in main location...\");\n const upsertPayload = {\n firstName: body.first_name,\n lastName: body.last_name,\n email: body.email,\n phone: body.phone || \"\",\n locationId: GHL_LOCATION_ID,\n customFields: [\n { id: FIELD_AGENT_CODE_ID, field_value: agentCode },\n {\n id: FIELD_RECRUITING_AGENT_CODE_ID,\n field_value: recruitingAgentCode,\n },\n { key: FIELD_SUB_ACCOUNT_ID, field_value: newLocationId },\n ],\n tags: [\"registered-agent\"],\n };\n\n const contactRes = await ghlFetch(\"/contacts/upsert\", GHL_API_TOKEN, {\n method: \"POST\",\n body: JSON.stringify(upsertPayload),\n });\n\n if (!contactRes.ok) {\n console.error(\n \"Contact upsert failed:\",\n contactRes.status,\n JSON.stringify(contactRes.data),\n );\n }\n\n const contactId = contactRes.data?.contact?.id;\n console.log(\"Contact upserted:\", contactId);\n\n // ------- 5. Add to Agent Pipeline at \"Onboarded & Registered\" -------\n let opportunityId = null;\n if (contactId) {\n const oppRes = await ghlFetch(\"/opportunities/\", GHL_API_TOKEN, {\n method: \"POST\",\n body: JSON.stringify({\n pipelineId: AGENT_PIPELINE_ID,\n pipelineStageId: ONBOARDED_STAGE_ID,\n locationId: GHL_LOCATION_ID,\n contactId: contactId,\n name: `${body.first_name} ${body.last_name} - Agent Onboarding`,\n status: \"open\",\n }),\n });\n\n if (oppRes.ok) {\n opportunityId = oppRes.data?.opportunity?.id;\n console.log(\"Added to Agent Pipeline:\", opportunityId);\n } else {\n console.error(\n \"Pipeline placement failed:\",\n oppRes.status,\n JSON.stringify(oppRes.data),\n );\n }\n }\n\n // ------- 6. Wire Upline Permission Chain -------\n console.log(\"Setting up upline permissions...\");\n let currentRecruitingCode = recruitingAgentCode;\n const processedCodes = new Set();\n\n while (\n currentRecruitingCode && !processedCodes.has(currentRecruitingCode)\n ) {\n processedCodes.add(currentRecruitingCode);\n\n const upline = await findContactByAgentCode(\n currentRecruitingCode,\n GHL_LOCATION_ID,\n GHL_API_TOKEN,\n );\n\n if (!upline) {\n console.log(\n `Upline with code ${currentRecruitingCode} not found — stopping chain`,\n );\n break;\n }\n\n console.log(\n `Found upline: ${upline.firstName} ${upline.lastName} (${currentRecruitingCode})`,\n );\n\n await addUserToLocation(\n upline.email,\n upline.firstName || \"\",\n upline.lastName || \"\",\n newLocationId,\n GHL_AGENCY_TOKEN,\n GHL_COMPANY_ID,\n );\n\n let nextRecruitingCode = \"\";\n if (upline.customFields) {\n for (const cf of upline.customFields) {\n if (\n cf.id === \"f4acnJJa3dGyqkiPppVQ\" ||\n cf.key === FIELD_RECRUITING_AGENT_CODE\n ) {\n nextRecruitingCode = cf.value || \"\";\n break;\n }\n }\n }\n\n currentRecruitingCode = nextRecruitingCode.trim();\n }\n\n console.log(\n \"Upline chain complete. Processed codes:\",\n Array.from(processedCodes),\n );\n\n // ------- 7. AUTO-ASSIGN STAFF TO CLIENT MEETING CALENDAR (NEW in v4) -------\n // This makes registration truly \"grab and go\" — the new agent is automatically\n // assigned as staff to their Client Meeting calendar with correct hours.\n // Note: Snapshot deployment may take a few seconds, so we retry if needed.\n let calendarSetupResult = { ok: false, message: \"not attempted\" };\n const maxRetries = 3;\n const retryDelayMs = 5000; // 5 seconds between retries\n\n for (let attempt = 1; attempt <= maxRetries; attempt++) {\n console.log(`[Calendar Setup] Attempt ${attempt}/${maxRetries}...`);\n calendarSetupResult = await setupCalendarStaff(\n GHL_AGENCY_TOKEN,\n GHL_COMPANY_ID,\n newLocationId,\n );\n\n if (calendarSetupResult.ok) break;\n\n if (attempt < maxRetries) {\n console.log(`[Calendar Setup] Waiting ${retryDelayMs}ms before retry...`);\n await new Promise((resolve) => setTimeout(resolve, retryDelayMs));\n }\n }\n\n if (!calendarSetupResult.ok) {\n console.error(\"[Calendar Setup] All attempts failed:\", calendarSetupResult.message);\n // Don't fail the whole registration — calendar can be fixed manually\n }\n\n // ------- 8. Return Success -------\n return Response.json(\n {\n success: true,\n message: `Sub-account created for ${body.first_name} ${body.last_name}`,\n agentCode: agentCode,\n recruitingAgentCode: recruitingAgentCode,\n newLocationId: newLocationId,\n contactId: contactId || null,\n opportunityId: opportunityId || null,\n contactUpsertOk: contactRes.ok,\n contactUpsertStatus: contactRes.status,\n uplineChain: Array.from(processedCodes),\n calendarSetup: calendarSetupResult,\n },\n { headers: CORS_HEADERS },\n );\n } catch (err) {\n console.error(\"Registration error:\", err);\n return Response.json(\n { error: \"Internal server error\", details: String(err) },\n { status: 500, headers: CORS_HEADERS },\n );\n }\n}\n","deleted","label",[107],"pulls","branches",1,"forks","envVars",{"_131":133,"_134":39},"connections",{"_131":39,"_132":39},"count","unfilledCount",5,"emptyCount",{"_18":106,"_20":107,"_108":109,"_110":-5,"_111":65,"_112":63,"_113":100,"_22":136,"_62":115,"_116":117,"_118":119,"_120":26,"_121":-5,"_137":138,"_82":139},["D",1776200174601],"children",[],[107],["D",1774371653765],{"_16":17,"_80":76},{"_16":17,"_74":-5,"_75":76,"_32":33,"_77":78,"_79":26},{"_62":63,"_20":64,"_18":65,"_66":19,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":-5,"_72":21,"_73":17},"ctx",{"_55":-5,"_102":177,"_178":179,"_180":181,"_182":26,"_183":26,"_184":26,"_185":100,"_186":-5,"_187":-7,"_188":-7,"_189":39,"_190":26,"_191":26,"_192":-5,"_193":26,"_194":26,"_195":26,"_196":-5},"ENV",{"_148":149,"_150":151,"_152":64,"_153":154,"_155":156,"_157":158,"_159":160,"_161":162,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]

Search