Join Empower Lifestyle Group

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_154":155,"_156":157},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_102":84,"_27":103,"_13":14,"_104":-5,"_11":105,"_106":107,"_108":109,"_110":111,"_112":113,"_20":-5,"_114":-5,"_115":-5,"_116":25,"_117":118,"_119":120,"_121":-5,"_122":-5,"_123":124},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",11,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","04bd724a-27a3-11f1-b63f-42dde27851f2","name","fileType","http","content","/**\n * Agent Self-Registration — Val Town HTTP Handler (v3)\n *\n * Flow:\n * - GET: Serves branded registration landing page\n * - POST: Processes registration (creates sub-account, upserts contact, etc.)\n *\n * Environment Variables Required:\n * GHL_AGENCY_TOKEN — Agency-level API key\n * GHL_API_TOKEN — Sub-account PIT\n * GHL_COMPANY_ID — Agency company ID: iMDWpSbQp548698UddLD\n * GHL_LOCATION_ID — Main Empower Group location: 1JJ5vZco8B7G6UhgE4C7\n * GHL_SNAPSHOT_ID — Empower Agent Template snapshot ID\n */\n\nconst GHL_BASE = \"https://services.leadconnectorhq.com\";\n\n// Pipeline & stage IDs (from live audit)\nconst AGENT_PIPELINE_ID = \"rtO3iMAiRNfERGOLQqQj\";\nconst ONBOARDED_STAGE_ID = \"d9ce515a-91dc-43f0-9167-02d2ea2a46d4\";\n\n// Custom field IDs and keys (from live audit)\nconst FIELD_AGENT_CODE_ID = \"K8u86oA0GlpDlOJotv8x\";\nconst FIELD_RECRUITING_AGENT_CODE_ID = \"f4acnJJa3dGyqkiPppVQ\";\nconst FIELD_AGENT_CODE = \"agent_code\";\nconst FIELD_RECRUITING_AGENT_CODE = \"recruiting_agent_code\";\nconst FIELD_SUB_ACCOUNT_ID = \"subaccount_id\";\n\nconst CORS_HEADERS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n};\n\n// Helper: make GHL API call\nasync function ghlFetch(\n endpoint: string,\n token: string,\n options: RequestInit = {},\n): Promise<{ ok: boolean; status: number; data: any }> {\n const res = await fetch(`${GHL_BASE}${endpoint}`, {\n ...options,\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n \"Version\": \"2021-07-28\",\n \"Accept\": \"application/json\",\n ...(options.headers || {}),\n },\n });\n const data = await res.json();\n return { ok: res.ok, status: res.status, data };\n}\n\n// Helper: search contacts by custom field value\nasync function findContactByAgentCode(\n agentCode: string,\n locationId: string,\n token: string,\n): Promise {\n let startAfterId = \"\";\n const limit = 100;\n\n while (true) {\n const query = startAfterId\n ? `?locationId=${locationId}&limit=${limit}&startAfterId=${startAfterId}`\n : `?locationId=${locationId}&limit=${limit}`;\n\n const { ok, data } = await ghlFetch(`/contacts/${query}`, token);\n if (!ok || !data.contacts || data.contacts.length === 0) break;\n\n for (const contact of data.contacts) {\n if (contact.customFields) {\n for (const cf of contact.customFields) {\n if (\n (cf.id === \"K8u86oA0GlpDlOJotv8x\" || cf.key === FIELD_AGENT_CODE) &&\n cf.value === agentCode\n ) {\n return contact;\n }\n }\n }\n }\n\n if (data.contacts.length < limit) break;\n startAfterId = data.contacts[data.contacts.length - 1].id;\n }\n\n return null;\n}\n\n// Helper: add a user to a sub-account location (handles existing users)\nasync function addUserToLocation(\n email: string,\n firstName: string,\n lastName: string,\n locationId: string,\n agencyToken: string,\n companyId: string,\n): Promise {\n // Step 1: Search for existing user by email\n const searchRes = await ghlFetch(\n `/users/search?companyId=${companyId}&query=${encodeURIComponent(email)}&limit=1`,\n agencyToken,\n );\n\n if (searchRes.ok && searchRes.data?.users?.length > 0) {\n // User already exists — update their locationIds to include the new location\n const existingUser = searchRes.data.users[0];\n const userId = existingUser.id;\n const currentLocationIds: string[] = existingUser.locationIds || [];\n\n if (currentLocationIds.includes(locationId)) {\n console.log(`${email} already has access to location ${locationId}`);\n return true;\n }\n\n const updatedLocationIds = [...currentLocationIds, locationId];\n console.log(`Updating existing user ${email} (${userId}) to add location ${locationId}`);\n\n const updateRes = await ghlFetch(`/users/${userId}`, agencyToken, {\n method: \"PUT\",\n body: JSON.stringify({\n companyId: companyId,\n locationIds: updatedLocationIds,\n }),\n });\n\n if (updateRes.ok) {\n console.log(`Updated ${email} — now has access to ${updatedLocationIds.length} locations`);\n return true;\n } else {\n console.log(`Failed to update ${email}:`, JSON.stringify(updateRes.data));\n return false;\n }\n }\n\n // Step 2: User doesn't exist — create a new one with viewer-level permissions\n console.log(`Creating new user ${email} for location ${locationId}`);\n const { ok, data } = await ghlFetch(\"/users/\", agencyToken, {\n method: \"POST\",\n body: JSON.stringify({\n companyId: companyId,\n firstName: firstName,\n lastName: lastName,\n email: email,\n type: \"account\",\n role: \"user\",\n locationIds: [locationId],\n permissions: {\n dashboardStatsEnabled: true,\n appointmentsEnabled: true,\n contactsEnabled: true,\n opportunitiesEnabled: true,\n conversationsEnabled: true,\n membershipEnabled: true,\n assignedDataOnly: false,\n settingsEnabled: false,\n campaignsEnabled: false,\n campaignsReadOnly: true,\n triggersEnabled: false,\n workflowsEnabled: false,\n workflowsReadOnly: true,\n },\n }),\n });\n\n if (ok) {\n console.log(`Created user ${email} with access to location ${locationId}`);\n return true;\n } else {\n console.log(`Failed to create user ${email}:`, JSON.stringify(data));\n return false;\n }\n}\n\n// Serve the registration landing page\nfunction serveRegistrationPage(): Response {\n const html = `\n\n\n \n \n Join Empower Lifestyle Group\n \n\n\n

\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 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 = [\"first_name\", \"last_name\", \"email\", \"agent_code\", \"recruiting_agent_code\"];\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 (!GHL_AGENCY_TOKEN || !GHL_API_TOKEN || !GHL_COMPANY_ID || !GHL_LOCATION_ID) {\n console.error(\"Missing required env vars.\");\n return Response.json({ error: \"Server configuration error\" }, { status: 500, headers: CORS_HEADERS });\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(\"Sub-account creation failed:\", JSON.stringify(createRes.data));\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 || 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 { id: FIELD_RECRUITING_AGENT_CODE_ID, field_value: recruitingAgentCode },\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(\"Contact upsert failed:\", contactRes.status, JSON.stringify(contactRes.data));\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(\"Pipeline placement failed:\", oppRes.status, JSON.stringify(oppRes.data));\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 (currentRecruitingCode && !processedCodes.has(currentRecruitingCode)) {\n processedCodes.add(currentRecruitingCode);\n\n const upline = await findContactByAgentCode(currentRecruitingCode, GHL_LOCATION_ID, GHL_API_TOKEN);\n\n if (!upline) {\n console.log(`Upline with code ${currentRecruitingCode} not found — stopping chain`);\n break;\n }\n\n console.log(`Found upline: ${upline.firstName} ${upline.lastName} (${currentRecruitingCode})`);\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 (cf.id === \"f4acnJJa3dGyqkiPppVQ\" || cf.key === FIELD_RECRUITING_AGENT_CODE) {\n nextRecruitingCode = cf.value || \"\";\n break;\n }\n }\n }\n\n currentRecruitingCode = nextRecruitingCode.trim();\n }\n\n console.log(\"Upline chain complete. Processed codes:\", Array.from(processedCodes));\n\n // ------- 7. 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 },\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 * Agent Self-Registration — Val Town HTTP Handler (v3)\n *\n * Flow:\n * - GET: Serves branded registration landing page\n * - POST: Processes registration (creates sub-account, upserts contact, etc.)\n *\n * Environment Variables Required:\n * GHL_AGENCY_TOKEN — Agency-level API key\n * GHL_API_TOKEN — Sub-account PIT\n * GHL_COMPANY_ID — Agency company ID: iMDWpSbQp548698UddLD\n * GHL_LOCATION_ID — Main Empower Group location: 1JJ5vZco8B7G6UhgE4C7\n * GHL_SNAPSHOT_ID — Empower Agent Template snapshot ID\n */\n\nconst GHL_BASE = \"https://services.leadconnectorhq.com\";\n\n// Pipeline & stage IDs (from live audit)\nconst AGENT_PIPELINE_ID = \"rtO3iMAiRNfERGOLQqQj\";\nconst ONBOARDED_STAGE_ID = \"d9ce515a-91dc-43f0-9167-02d2ea2a46d4\";\n\n// Custom field IDs and keys (from live audit)\nconst FIELD_AGENT_CODE_ID = \"K8u86oA0GlpDlOJotv8x\";\nconst FIELD_RECRUITING_AGENT_CODE_ID = \"f4acnJJa3dGyqkiPppVQ\";\nconst FIELD_AGENT_CODE = \"agent_code\";\nconst FIELD_RECRUITING_AGENT_CODE = \"recruiting_agent_code\";\nconst FIELD_SUB_ACCOUNT_ID = \"subaccount_id\";\n\nconst CORS_HEADERS = {\n \"Access-Control-Allow-Origin\": \"*\",\n \"Access-Control-Allow-Methods\": \"GET, POST, OPTIONS\",\n \"Access-Control-Allow-Headers\": \"Content-Type, Authorization\",\n};\n\n// Helper: make GHL API call\nasync function ghlFetch(\n endpoint: string,\n token: string,\n options: RequestInit = {},\n): Promise<{ ok: boolean; status: number; data: any }> {\n const res = await fetch(`${GHL_BASE}${endpoint}`, {\n ...options,\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n \"Version\": \"2021-07-28\",\n \"Accept\": \"application/json\",\n ...(options.headers || {}),\n },\n });\n const data = await res.json();\n return { ok: res.ok, status: res.status, data };\n}\n\n// Helper: search contacts by custom field value\nasync function findContactByAgentCode(\n agentCode: string,\n locationId: string,\n token: string,\n): Promise {\n let startAfterId = \"\";\n const limit = 100;\n\n while (true) {\n const query = startAfterId\n ? `?locationId=${locationId}&limit=${limit}&startAfterId=${startAfterId}`\n : `?locationId=${locationId}&limit=${limit}`;\n\n const { ok, data } = await ghlFetch(`/contacts/${query}`, token);\n if (!ok || !data.contacts || data.contacts.length === 0) break;\n\n for (const contact of data.contacts) {\n if (contact.customFields) {\n for (const cf of contact.customFields) {\n if (\n (cf.id === \"K8u86oA0GlpDlOJotv8x\" || cf.key === FIELD_AGENT_CODE) &&\n cf.value === agentCode\n ) {\n return contact;\n }\n }\n }\n }\n\n if (data.contacts.length < limit) break;\n startAfterId = data.contacts[data.contacts.length - 1].id;\n }\n\n return null;\n}\n\n// Helper: add a user to a sub-account location (handles existing users)\nasync function addUserToLocation(\n email: string,\n firstName: string,\n lastName: string,\n locationId: string,\n agencyToken: string,\n companyId: string,\n): Promise {\n // Step 1: Search for existing user by email\n const searchRes = await ghlFetch(\n `/users/search?companyId=${companyId}&query=${\n encodeURIComponent(email)\n }&limit=1`,\n agencyToken,\n );\n\n if (searchRes.ok && searchRes.data?.users?.length > 0) {\n // User already exists — update their locationIds to include the new location\n const existingUser = searchRes.data.users[0];\n const userId = existingUser.id;\n const currentLocationIds: string[] = existingUser.locationIds || [];\n\n if (currentLocationIds.includes(locationId)) {\n console.log(`${email} already has access to location ${locationId}`);\n return true;\n }\n\n const updatedLocationIds = [...currentLocationIds, locationId];\n console.log(\n `Updating existing user ${email} (${userId}) to add location ${locationId}`,\n );\n\n const updateRes = await ghlFetch(`/users/${userId}`, agencyToken, {\n method: \"PUT\",\n body: JSON.stringify({\n companyId: companyId,\n locationIds: updatedLocationIds,\n }),\n });\n\n if (updateRes.ok) {\n console.log(\n `Updated ${email} — now has access to ${updatedLocationIds.length} locations`,\n );\n return true;\n } else {\n console.log(`Failed to update ${email}:`, JSON.stringify(updateRes.data));\n return false;\n }\n }\n\n // Step 2: User doesn't exist — create a new one with viewer-level permissions\n console.log(`Creating new user ${email} for location ${locationId}`);\n const { ok, data } = await ghlFetch(\"/users/\", agencyToken, {\n method: \"POST\",\n body: JSON.stringify({\n companyId: companyId,\n firstName: firstName,\n lastName: lastName,\n email: email,\n type: \"account\",\n role: \"user\",\n locationIds: [locationId],\n permissions: {\n dashboardStatsEnabled: true,\n appointmentsEnabled: true,\n contactsEnabled: true,\n opportunitiesEnabled: true,\n conversationsEnabled: true,\n membershipEnabled: true,\n assignedDataOnly: false,\n settingsEnabled: false,\n campaignsEnabled: false,\n campaignsReadOnly: true,\n triggersEnabled: false,\n workflowsEnabled: false,\n workflowsReadOnly: true,\n },\n }),\n });\n\n if (ok) {\n console.log(`Created user ${email} with access to location ${locationId}`);\n return true;\n } else {\n console.log(`Failed to create user ${email}:`, JSON.stringify(data));\n return false;\n }\n}\n\n// Serve the registration landing page\nfunction serveRegistrationPage(): Response {\n const html = `\n\n\n \n \n Join Empower Lifestyle Group\n \n\n\n

\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 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. 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 },\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}","createdAt",["D",1775843240756],"branchVersion","branchId","04baebec-27a3-11f1-b63f-42dde27851f2","id","04ba394a-27a3-11f1-b63f-42dde27851f2","agentRegistration",["D",1774371653765],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019d20a4-a3f3-740f-a05e-7faa4351fd8b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019d20a4-a3f4-753a-a766-aebbf1992668","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_101":97},"org",{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",14,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mattcheema","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoiZGVmYXVsdCIsImlpZCI6Imluc18yTm10cGhQUklwU0tqZHNiOHNnNGd2ZjJURFUiLCJyaWQiOiJ1c2VyXzNCT25tMUJTbjNkSXdHcFp3a2o3TDZTZk5LcyJ9","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":150,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":151,"_78":152,"_80":153,"_82":25},"tree",[145],"files",[145],"counts",{"_133":60,"_134":135,"_136":60,"_137":138,"_139":140},"contents",[125],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":129,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_27":132},"52f07920-3505-11f1-bd61-42b51c65c3df","parentId","latest",["D",1775843240756],10,"label",[28],"pulls","branches",1,"forks","envVars",{"_141":143,"_144":60},"connections",{"_141":60,"_142":60},"count","unfilledCount",5,"emptyCount",{"_43":126,"_32":28,"_30":31,"_127":-5,"_41":42,"_40":14,"_128":25,"_38":146,"_13":130,"_33":34,"_35":37,"_24":25,"_131":-5,"_147":148,"_27":149},["D",1775843240756],"children",[],[28],["D",1774371653765],{"_94":93,"_101":97},{"_94":93,"_95":-5,"_96":97,"_18":54,"_98":99,"_100":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_122":187,"_188":189,"_190":191,"_192":25,"_193":25,"_194":25,"_195":120,"_196":-5,"_197":-7,"_198":-7,"_199":60,"_200":25,"_201":25,"_202":-5,"_203":25,"_204":25,"_205":25,"_206":-5},"ENV",{"_158":159,"_160":161,"_162":84,"_163":164,"_165":166,"_167":168,"_169":170,"_171":172,"_173":174,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186},"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 · v11