[{"_1":2,"_171":-5,"_172":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","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","e3ca0a77ab07ff2ce3097208ffd6aa0e378d3c47","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":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_146":147,"_168":169,"_170":-5},"handle","lantholin","name","YapTrap","path","backend/platforms/messenger.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":-5,"_113":20,"_114":-5,"_115":32,"_14":116,"_117":118,"_119":118,"_120":121,"_122":121,"_123":121,"_124":118,"_125":118,"_23":126,"_129":130,"_132":133,"_145":20},"id","e0b6bffa-8eaa-11f0-b609-0224a6c84d84","createdAt",["D",1757552501410],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","01991120-79d9-71bf-ab3a-268b208877c6","pinnedFileId","pinPreview","screenshotVersion","likeCount","01991120-79d9-71bf-ab3a-2b0a78a4a875","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_127":128},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zMkNlUHBrVWxlV3k1VG50eDloQVRhOU5WQWUifQ","org",{"_93":94,"_131":128},"avatar","branch",{"_134":135,"_95":43,"_101":136,"_137":102,"_138":-5,"_139":-5,"_140":-5,"_141":-5,"_142":-5,"_143":96,"_144":94},"version",69,"e0b72094-8eaa-11f0-b609-0224a6c84d84","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":148,"_95":149,"_150":151,"_152":153,"_154":136,"_155":135,"_156":157,"_103":158,"_134":32,"_159":160,"_161":162,"_163":20,"_164":-5,"_97":165},"37dee474-8f1e-11f0-9eb6-0224a6c84d84","messenger.ts","fileId","37dee53c-8f1e-11f0-9eb6-0224a6c84d84","parentId","c462bbf0-4c3d-4228-be72-2fc56d823e4e","branchId","branchVersion","latest",true,["D",1757602039740],"fileType","script","content","/**\n * Facebook Messenger platform handler for YapTrap via Puppeteer\n * Handles Messenger messaging through browser automation\n * \n * WARNING: This approach may violate Facebook's Terms of Service\n * Use at your own risk and consider official Messenger Platform API instead\n */\n\nimport { BasePlatformHandler } from './base.ts';\nimport type { NormalizedMessage } from '../../shared/types.ts';\nimport { generateConversationId, generateUserId } from '../../shared/utils.ts';\n\nexport class MessengerHandler extends BasePlatformHandler {\n private puppeteerEndpoint: string;\n private sessionData: any;\n private isLoggedIn: boolean = false;\n \n constructor() {\n super('messenger');\n this.puppeteerEndpoint = Deno.env.get('PUPPETEER_ENDPOINT') || 'http://localhost:3002';\n this.sessionData = null;\n }\n \n protected getRequiredEnvVars(): string[] {\n return ['MESSENGER_EMAIL', 'MESSENGER_PASSWORD', 'PUPPETEER_ENDPOINT'];\n }\n \n /**\n * Normalize Messenger message to internal format\n */\n async normalizeMessage(payload: any): Promise {\n try {\n // Handle Puppeteer-scraped message format\n if (!payload.messages || !Array.isArray(payload.messages)) {\n await this.logActivity('debug', 'Ignoring payload without messages array');\n return null;\n }\n \n for (const message of payload.messages) {\n if (!message.text || !message.sender || !message.conversationId) {\n continue;\n }\n \n // Skip messages from self\n if (message.sender.isMe) {\n continue;\n }\n \n const conversationId = generateConversationId('messenger', message.conversationId);\n const userId = generateUserId('messenger', message.sender.id || message.sender.name);\n \n // TODO: Implement user and conversation management for Messenger\n \n const normalizedMessage = this.createNormalizedMessage(\n message.text,\n conversationId,\n userId,\n {\n senderId: message.sender.id,\n senderName: message.sender.name,\n messengerConversationId: message.conversationId,\n timestamp: message.timestamp,\n originalPayload: message\n }\n );\n \n await this.logActivity(\n 'info',\n 'Messenger message normalized successfully',\n { \n messageId: normalizedMessage.id,\n conversationId,\n userId,\n senderName: message.sender.name\n },\n conversationId,\n userId\n );\n \n return normalizedMessage;\n }\n \n await this.logActivity('debug', 'No processable messages found in Messenger payload');\n return null;\n \n } catch (error) {\n await this.logActivity('error', `Failed to normalize Messenger message: ${error.message}`, {\n error: error.message,\n payload\n });\n return null;\n }\n }\n \n /**\n * Send Messenger message via Puppeteer automation\n */\n async sendMessage(conversationId: string, content: string, metadata: any = {}): Promise {\n const startTime = Date.now();\n \n try {\n if (!await this.authenticate()) {\n throw new Error('Messenger Puppeteer session not available');\n }\n \n // Extract Messenger conversation ID from our internal ID\n const messengerConversationId = this.extractMessengerConversationId(conversationId);\n if (!messengerConversationId) {\n throw new Error(`Invalid Messenger conversation ID: ${conversationId}`);\n }\n \n // Send message via Puppeteer API\n const messagePayload = {\n action: 'sendMessage',\n conversationId: messengerConversationId,\n message: content,\n sessionId: this.sessionData?.sessionId\n };\n \n const response = await this.callPuppeteerAPI(messagePayload);\n \n if (!response.success) {\n throw new Error(`Puppeteer API error: ${response.error}`);\n }\n \n const duration = Date.now() - startTime;\n \n await this.logActivity(\n 'info',\n 'Messenger message sent successfully via Puppeteer',\n {\n conversationId,\n messengerConversationId,\n messageId: response.messageId,\n duration\n },\n conversationId\n );\n \n // Record metrics\n await import('../monitoring/metrics.ts').then(({ MetricsCollector }) => \n MetricsCollector.recordPlatformAPI('messenger', 'send_message', duration, true)\n );\n \n } catch (error) {\n const duration = Date.now() - startTime;\n \n await this.logActivity(\n 'error',\n `Failed to send Messenger message via Puppeteer: ${error.message}`,\n {\n conversationId,\n content: content.substring(0, 100),\n error: error.message,\n duration\n },\n conversationId\n );\n \n // Record failed metrics\n await import('../monitoring/metrics.ts').then(({ MetricsCollector }) => \n MetricsCollector.recordPlatformAPI('messenger', 'send_message', duration, false)\n );\n \n throw error;\n }\n }\n \n /**\n * Validate Puppeteer webhook payload\n */\n validateWebhook(payload: any, signature: string): boolean {\n try {\n // Puppeteer doesn't use traditional webhook signatures\n // Instead, validate the payload structure and session\n if (!payload || typeof payload !== 'object') {\n return false;\n }\n \n // Check for required Puppeteer payload structure\n if (payload.sessionId && payload.messages) {\n return true;\n }\n \n // Check for authentication payload\n if (payload.action && payload.sessionId) {\n return true;\n }\n \n return false;\n \n } catch (error) {\n this.logActivity('error', `Messenger Puppeteer webhook validation failed: ${error.message}`, {\n error: error.message\n });\n return false;\n }\n }\n \n /**\n * Call Puppeteer API\n */\n private async callPuppeteerAPI(payload: any): Promise {\n try {\n const response = await fetch(`${this.puppeteerEndpoint}/api/messenger`, {\n method: 'POST',\n headers: {\n 'Content-Type': 'application/json',\n 'Authorization': `Bearer ${Deno.env.get('PUPPETEER_API_KEY') || 'default'}`\n },\n body: JSON.stringify(payload)\n });\n \n if (!response.ok) {\n throw new Error(`HTTP ${response.status}: ${response.statusText}`);\n }\n \n return await response.json();\n \n } catch (error) {\n throw new Error(`Puppeteer API call failed: ${error.message}`);\n }\n }\n \n /**\n * Initialize Puppeteer Messenger session\n */\n async initializePuppeteerSession(): Promise {\n try {\n await this.logActivity('info', 'Initializing Puppeteer Messenger session');\n \n const loginPayload = {\n action: 'login',\n email: Deno.env.get('MESSENGER_EMAIL'),\n password: Deno.env.get('MESSENGER_PASSWORD'),\n headless: Deno.env.get('PUPPETEER_HEADLESS') !== 'false'\n };\n \n const response = await this.callPuppeteerAPI(loginPayload);\n \n if (response.success) {\n this.sessionData = response.session;\n this.isLoggedIn = true;\n \n await this.logActivity('info', 'Puppeteer Messenger session initialized successfully', {\n sessionId: this.sessionData.sessionId\n });\n \n // Start message monitoring\n await this.startMessageMonitoring();\n \n return true;\n } else {\n throw new Error(response.error || 'Login failed');\n }\n \n } catch (error) {\n await this.logActivity('error', `Failed to initialize Puppeteer session: ${error.message}`);\n return false;\n }\n }\n \n /**\n * Start monitoring for new messages\n */\n private async startMessageMonitoring(): Promise {\n try {\n const monitorPayload = {\n action: 'startMonitoring',\n sessionId: this.sessionData.sessionId,\n webhookUrl: `${Deno.env.get('YAPTRAP_BASE_URL')}/webhooks/messenger`\n };\n \n await this.callPuppeteerAPI(monitorPayload);\n \n await this.logActivity('info', 'Started Messenger message monitoring');\n \n } catch (error) {\n await this.logActivity('error', `Failed to start message monitoring: ${error.message}`);\n }\n }\n \n /**\n * Get active conversations\n */\n async getActiveConversations(): Promise {\n try {\n const payload = {\n action: 'getConversations',\n sessionId: this.sessionData?.sessionId\n };\n \n const response = await this.callPuppeteerAPI(payload);\n \n if (response.success) {\n return response.conversations || [];\n }\n \n return [];\n \n } catch (error) {\n await this.logActivity('error', `Failed to get conversations: ${error.message}`);\n return [];\n }\n }\n \n /**\n * Extract Messenger conversation ID from our internal ID\n */\n private extractMessengerConversationId(conversationId: string): string | null {\n // Conversation ID format: conv_messenger_MESSENGERCONVID\n const parts = conversationId.split('_');\n if (parts.length >= 3 && parts[0] === 'conv' && parts[1] === 'messenger') {\n return parts.slice(2).join('_');\n }\n return null;\n }\n \n /**\n * Check if session is active\n */\n isSessionActive(): boolean {\n return this.isLoggedIn && this.sessionData !== null;\n }\n \n /**\n * Handle session events\n */\n async handleSessionEvent(event: string, data: any): Promise {\n switch (event) {\n case 'session.expired':\n await this.handleSessionExpired(data);\n break;\n case 'messages.received':\n await this.handleNewMessages(data);\n break;\n case 'login.required':\n await this.handleLoginRequired(data);\n break;\n default:\n await this.logActivity('debug', `Unhandled Puppeteer event: ${event}`, { data });\n }\n }\n \n private async handleSessionExpired(data: any): Promise {\n this.isLoggedIn = false;\n this.sessionData = null;\n \n await this.logActivity('warn', 'Puppeteer Messenger session expired', { data });\n \n // Attempt to re-login\n setTimeout(() => {\n this.initializePuppeteerSession();\n }, 5000);\n }\n \n private async handleNewMessages(data: any): Promise {\n try {\n const normalized = await this.normalizeMessage(data);\n if (normalized) {\n // Forward to message processor\n const { MessageProcessor } = await import('../ai/processor.ts');\n const processor = new MessageProcessor();\n await processor.processMessage(normalized);\n }\n } catch (error) {\n await this.logActivity('error', `Failed to process Puppeteer message: ${error.message}`);\n }\n }\n \n private async handleLoginRequired(data: any): Promise {\n await this.logActivity('warn', 'Messenger login required', { data });\n \n // Attempt to re-login\n await this.initializePuppeteerSession();\n }\n \n /**\n * Cleanup session\n */\n async cleanup(): Promise {\n try {\n if (this.sessionData) {\n const payload = {\n action: 'cleanup',\n sessionId: this.sessionData.sessionId\n };\n \n await this.callPuppeteerAPI(payload);\n }\n \n this.isLoggedIn = false;\n this.sessionData = null;\n \n await this.logActivity('info', 'Puppeteer Messenger session cleaned up');\n \n } catch (error) {\n await this.logActivity('error', `Failed to cleanup session: ${error.message}`);\n }\n }\n}","deleted","label",[166,167,149],"backend","platforms","permalink","https://www.val.town/x/lantholin/YapTrap/code/backend/platforms/messenger.ts","extension","actionData","errors"]