[{"_1":2,"_221":-5,"_222":-5},"loaderData",{"_3":4,"_91":92,"_206":207},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":22,"_29":22,"_30":22,"_31":32,"_33":22},"auth",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"tokenType","session_token","sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","adfebe93a62ec16c60f2bbbbae23e7a8e771d6e9","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":22,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":22,"_90":22},"__clerk_ssr_state",{"_9":10,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":-5,"_20":-5,"_21":22},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":22,"_21":22,"_82":72,"_83":84,"_85":72,"_86":45,"_87":22,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/_app.x.$handle.$name",{"_93":94,"_95":96,"_97":-7,"_98":72,"_99":-7,"_100":101,"_146":147,"_179":180,"_181":182,"_191":192,"_199":-5,"_200":-5,"_201":-5,"_202":22,"_203":22,"_204":205},"handle","mitchell","name","chameleon-to-segment","branchName","path","version","project",{"_102":103,"_95":96,"_104":105,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":127,"_130":131,"_133":134,"_145":22},"id","a8744e14-8527-11f0-9c3e-0224a6c84d84","createdAt",["D",1756506582486],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","01989f92-30b8-72be-ad06-8e4fbcf00ca1","pinnedFileId","pinPreview","screenshotVersion","likeCount","01989f92-30b8-72be-ad06-90c3a9da2aae","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_128":129},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zMUNNc0puODRkdG1EOWYwNzVLRVk0cEUyRUEifQ","org",{"_93":94,"_132":129},"avatar","branch",{"_99":135,"_95":43,"_102":136,"_137":103,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},14,"a8749d92-8527-11f0-9c3e-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","tree",[148,169],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":135,"_156":157,"_104":158,"_99":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_166":167,"_98":168},"3dc80dd4-852d-11f0-b4c6-0224a6c84d84","main.tsx","fileId","a8767ba8-8527-11f0-9c3e-0224a6c84d84","parentId","branchId","branchVersion","latest",true,["D",1756508980488],8,"fileType","http","content","/**\n * Chameleon to Segment Webhook\n * Processes Chameleon webhook data and sends formatted events to Segment\n */\n\ninterface ChameleonWebhookPayload {\n headers: Record;\n params: Record;\n query: Record;\n body: {\n id: string;\n kind: string;\n data: {\n profile?: {\n uid?: string;\n email?: string;\n [key: string]: any;\n };\n survey?: {\n id: string;\n [key: string]: any;\n };\n response?: {\n id: string;\n [key: string]: any;\n };\n tour?: {\n id: string;\n name?: string;\n [key: string]: any;\n };\n step?: {\n id: string;\n [key: string]: any;\n };\n action?: {\n id: string;\n [key: string]: any;\n };\n };\n sent_at: string;\n };\n webhookUrl: string;\n executionMode: string;\n}\n\ninterface ProcessedEvent {\n event_id: string | null;\n event_name: string | null;\n event_timestamp: string | null;\n event_source: string;\n event_status: string;\n actor_id: string | null;\n actor_type: string;\n object_id: string | null;\n object_type: string | null;\n meta: string;\n}\n\nexport default async function (req: Request): Promise {\n try {\n // Only accept POST requests\n if (req.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n // Get Segment Write Key from environment\n const segmentWriteKey = Deno.env.get(\"SEGMENT_WRITE_KEY\");\n if (!segmentWriteKey) {\n console.error(\"SEGMENT_WRITE_KEY environment variable is required\");\n return new Response(\"Server configuration error\", { status: 500 });\n }\n\n // Parse the webhook payload\n const payload = await req.json();\n console.log(\"Received webhook payload:\", JSON.stringify(payload, null, 2));\n\n // Handle array of webhook data (as shown in your example)\n const webhookDataArray: ChameleonWebhookPayload[] = Array.isArray(payload)\n ? payload\n : [payload];\n\n const results = [];\n\n for (const webhookItem of webhookDataArray) {\n // Process the webhook data according to your n8n logic\n const processedEvent = processWebhookData(webhookItem);\n\n if (!processedEvent.actor_id) {\n console.warn(\"No actor_id found, skipping event:\", processedEvent);\n continue;\n }\n\n // Send to Segment\n // const segmentResult = await sendToSegment(\n // processedEvent,\n // segmentWriteKey,\n // );\n // results.push({\n // processed_event: processedEvent,\n // segment_result: segmentResult,\n // });\n }\n\n return new Response(\n JSON.stringify({\n success: true,\n processed: results.length,\n results,\n }),\n {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n } catch (error) {\n console.error(\"Webhook processing error:\", error);\n return new Response(\n JSON.stringify({\n error: \"Internal server error\",\n message: error.message,\n }),\n {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n },\n );\n }\n}\n\nfunction processWebhookData(input: ChameleonWebhookPayload): ProcessedEvent {\n const body = input || {};\n\n // Extract fields following your n8n logic\n console.log(body);\n const event_id = body.id || null;\n const event_name = body.kind || null;\n const event_timestamp = body.sent_at || null;\n const event_source = \"chameleon\";\n const event_status = \"success\";\n const actor_id = body.data?.profile?.uid?.toString() || null;\n const actor_type = \"user\";\n const object_id = body.data?.survey?.id || body.data?.response?.id || null;\n\n let object_type: string | null = null;\n if (event_name?.startsWith(\"survey.\")) {\n object_type = \"survey\";\n } else if (event_name?.startsWith(\"response.\")) {\n object_type = \"response\";\n } else {\n object_type = \"event\";\n }\n\n // Create meta object with profile, survey, and response data\n const meta = JSON.stringify({\n profile: body.data?.profile || null,\n survey: body.data?.survey || null,\n response: body.data?.response || null,\n tour: body.data?.tour || null,\n step: body.data?.step || null,\n action: body.data?.action || null,\n });\n\n return {\n event_id,\n event_name,\n event_timestamp,\n event_source,\n event_status,\n actor_id,\n actor_type,\n object_id,\n object_type,\n meta,\n };\n}\n\nasync function sendToSegment(\n processedEvent: ProcessedEvent,\n writeKey: string,\n): Promise {\n try {\n // Create Segment track event\n const segmentEvent = {\n userId: processedEvent.actor_id,\n event: formatEventName(processedEvent.event_name),\n properties: {\n event_id: processedEvent.event_id,\n event_name: processedEvent.event_name,\n event_source: processedEvent.event_source,\n event_status: processedEvent.event_status,\n actor_type: processedEvent.actor_type,\n object_id: processedEvent.object_id,\n object_type: processedEvent.object_type,\n // Parse meta back to object for better Segment properties\n ...parseMetaForSegment(processedEvent.meta),\n },\n timestamp: processedEvent.event_timestamp,\n context: {\n source: \"chameleon_webhook\",\n library: {\n name: \"val-town-webhook\",\n version: \"1.0.0\",\n },\n },\n };\n\n const response = await fetch(\"https://api.segment.io/v1/track\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"Authorization\": `Basic ${btoa(writeKey + \":\")}`,\n },\n body: JSON.stringify(segmentEvent),\n });\n\n if (!response.ok) {\n const errorText = await response.text();\n throw new Error(`Segment API error: ${response.status} ${errorText}`);\n }\n\n console.log(\n `Successfully sent event to Segment for user ${processedEvent.actor_id}`,\n );\n return {\n success: true,\n user_id: processedEvent.actor_id,\n event_name: segmentEvent.event,\n };\n } catch (error) {\n console.error(\"Failed to send event to Segment:\", error);\n return {\n success: false,\n error: error.message,\n user_id: processedEvent.actor_id,\n };\n }\n}\n\nfunction formatEventName(eventName: string | null): string {\n if (!eventName) return \"Chameleon Event\";\n\n // Convert dot notation to title case\n // e.g., \"tour.started\" -> \"Tour Started\"\n return eventName\n .split(\".\")\n .map((word) => word.charAt(0).toUpperCase() + word.slice(1))\n .join(\" \");\n}\n\nfunction parseMetaForSegment(metaString: string): Record {\n try {\n const meta = JSON.parse(metaString);\n const segmentProps: Record = {};\n\n // Add profile data as user traits-like properties\n if (meta.profile) {\n if (meta.profile.email) segmentProps.email = meta.profile.email;\n if (meta.profile.username) segmentProps.username = meta.profile.username;\n if (meta.profile.company_id) {\n segmentProps.company_id = meta.profile.company_id;\n }\n if (meta.profile.membership_tier) {\n segmentProps.membership_tier = meta.profile.membership_tier;\n }\n if (meta.profile.clearbit_company_name) {\n segmentProps.company_name = meta.profile.clearbit_company_name;\n }\n if (meta.profile.clearbit_company_domain) {\n segmentProps.company_domain = meta.profile.clearbit_company_domain;\n }\n }\n\n // Add survey/tour data\n if (meta.survey) {\n segmentProps.survey_id = meta.survey.id;\n if (meta.survey.name) segmentProps.survey_name = meta.survey.name;\n }\n\n if (meta.tour) {\n segmentProps.tour_id = meta.tour.id;\n if (meta.tour.name) segmentProps.tour_name = meta.tour.name;\n if (meta.tour.position) segmentProps.tour_position = meta.tour.position;\n }\n\n if (meta.step) {\n segmentProps.step_id = meta.step.id;\n if (meta.step.body) segmentProps.step_body = meta.step.body;\n }\n\n if (meta.response) {\n segmentProps.response_id = meta.response.id;\n }\n\n if (meta.action) {\n segmentProps.action_id = meta.action.id;\n }\n\n return segmentProps;\n } catch (error) {\n console.warn(\"Failed to parse meta for Segment properties:\", error);\n return { meta_raw: metaString };\n }\n}","deleted","label","children",[],[150],{"_102":170,"_95":171,"_151":172,"_153":-5,"_154":136,"_155":173,"_156":157,"_104":174,"_99":32,"_160":175,"_162":176,"_164":22,"_165":-5,"_166":177,"_98":178},"7df50ff6-8528-11f0-914d-0224a6c84d84","webhook.ts","7df510c8-8528-11f0-914d-0224a6c84d84",2,["D",1756506940682],"script","/**\n * Webhook that receives data, processes it, and sends it to Segment\n * \n * Environment Variables Required:\n * - SEGMENT_WRITE_KEY: Your Segment write key\n * \n * Usage:\n * POST to this endpoint with JSON data\n * The webhook will process the data and send appropriate events to Segment\n */\n\ninterface SegmentEvent {\n userId?: string;\n anonymousId?: string;\n event?: string;\n properties?: Record;\n traits?: Record;\n context?: Record;\n timestamp?: string;\n}\n\ninterface WebhookPayload {\n type: 'track' | 'identify' | 'page' | 'group';\n userId?: string;\n anonymousId?: string;\n event?: string;\n properties?: Record;\n traits?: Record;\n groupId?: string;\n name?: string;\n context?: Record;\n}\n\nexport default async function(req: Request): Promise {\n // Only allow POST requests\n if (req.method !== 'POST') {\n return new Response(JSON.stringify({ error: 'Method not allowed' }), {\n status: 405,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n\n try {\n // Get Segment write key from environment\n const segmentWriteKey = Deno.env.get('SEGMENT_WRITE_KEY');\n if (!segmentWriteKey) {\n console.error('SEGMENT_WRITE_KEY environment variable is not set');\n return new Response(JSON.stringify({ error: 'Server configuration error' }), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n\n // Parse incoming webhook data\n const payload: WebhookPayload = await req.json();\n console.log('Received webhook payload:', payload);\n\n // Process and validate the data\n const processedEvent = processWebhookData(payload);\n if (!processedEvent) {\n return new Response(JSON.stringify({ error: 'Invalid payload format' }), {\n status: 400,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n\n // Send to Segment\n const segmentResponse = await sendToSegment(segmentWriteKey, processedEvent, payload.type);\n \n if (!segmentResponse.ok) {\n const errorText = await segmentResponse.text();\n console.error('Segment API error:', errorText);\n return new Response(JSON.stringify({ \n error: 'Failed to send to Segment',\n details: errorText \n }), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n\n console.log('Successfully sent event to Segment');\n return new Response(JSON.stringify({ \n success: true, \n message: 'Event processed and sent to Segment',\n eventType: payload.type\n }), {\n status: 200,\n headers: { 'Content-Type': 'application/json' }\n });\n\n } catch (error) {\n console.error('Webhook processing error:', error);\n return new Response(JSON.stringify({ \n error: 'Internal server error',\n message: error.message \n }), {\n status: 500,\n headers: { 'Content-Type': 'application/json' }\n });\n }\n}\n\n/**\n * Process and validate webhook data\n * Add your custom processing logic here\n */\nfunction processWebhookData(payload: WebhookPayload): SegmentEvent | null {\n // Basic validation\n if (!payload.type) {\n console.error('Missing event type in payload');\n return null;\n }\n\n // Ensure we have either userId or anonymousId\n if (!payload.userId && !payload.anonymousId) {\n console.error('Missing userId or anonymousId in payload');\n return null;\n }\n\n // Build the Segment event based on type\n const baseEvent: SegmentEvent = {\n userId: payload.userId,\n anonymousId: payload.anonymousId,\n timestamp: new Date().toISOString(),\n context: {\n source: 'webhook',\n ...payload.context\n }\n };\n\n // Add type-specific fields\n switch (payload.type) {\n case 'track':\n if (!payload.event) {\n console.error('Missing event name for track event');\n return null;\n }\n return {\n ...baseEvent,\n event: payload.event,\n properties: payload.properties || {}\n };\n\n case 'identify':\n return {\n ...baseEvent,\n traits: payload.traits || {}\n };\n\n case 'page':\n return {\n ...baseEvent,\n name: payload.name,\n properties: payload.properties || {}\n };\n\n case 'group':\n if (!payload.groupId) {\n console.error('Missing groupId for group event');\n return null;\n }\n return {\n ...baseEvent,\n groupId: payload.groupId,\n traits: payload.traits || {}\n };\n\n default:\n console.error('Unsupported event type:', payload.type);\n return null;\n }\n}\n\n/**\n * Send event to Segment\n */\nasync function sendToSegment(\n writeKey: string, \n event: SegmentEvent, \n eventType: string\n): Promise {\n const segmentUrl = `https://api.segment.io/v1/${eventType}`;\n \n const headers = {\n 'Content-Type': 'application/json',\n 'Authorization': `Basic ${btoa(writeKey + ':')}`\n };\n\n console.log(`Sending ${eventType} event to Segment:`, event);\n\n return fetch(segmentUrl, {\n method: 'POST',\n headers,\n body: JSON.stringify(event)\n });\n}",[],[171],"files",[148,169],"counts",{"_183":32,"_184":185,"_186":32,"_187":188},"pulls","branches",1,"forks","envVars",{"_189":185,"_190":32},"count","emptyCount","contents",[193,196],{"_102":149,"_95":150,"_151":152,"_153":-5,"_154":136,"_155":135,"_156":157,"_104":194,"_99":159,"_160":161,"_162":163,"_164":22,"_165":-5,"_98":195},["D",1756508980488],[150],{"_102":170,"_95":171,"_151":172,"_153":-5,"_154":136,"_155":173,"_156":157,"_104":197,"_99":32,"_160":175,"_162":176,"_164":22,"_165":-5,"_98":198},["D",1756506940682],[171],"file","upstreamProject","upstreamBranch","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.environment-variables",{"_93":94,"_95":96,"_100":208,"_187":213},{"_102":103,"_95":96,"_104":209,"_106":-5,"_107":22,"_108":109,"_110":-5,"_111":-5,"_14":112,"_113":-5,"_114":22,"_115":-5,"_116":32,"_16":117,"_118":119,"_120":119,"_121":122,"_123":122,"_124":122,"_125":119,"_126":119,"_23":210,"_130":211,"_133":212,"_145":22},["D",1756506582486],{"_93":94,"_128":129},{"_93":94,"_132":129},{"_99":135,"_95":43,"_102":136,"_137":103,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},[214],{"_215":216,"_104":217,"_218":-5,"_110":219,"_220":22},"key","SEGMENT_WRITE_KEY",["D",1756508383289],"updatedAt","API key to write to segment","isEmpty","actionData","errors"]

mitchell

chameleon-to-segment

Environment variables