${escapeHtml(messageText)}

\n\n

\n Google Chat metadata
\n Sender: ${escapeHtml(senderName)}
\n Space: ${escapeHtml(spaceName)}
\n Message ID: ${escapeHtml(externalMessageId)}
\n Thread ID: ${escapeHtml(threadId)}
\n Created: ${escapeHtml(createdAt || \"Unknown\")}\n

\n `;\n\n const payload: Record = {\n title: `[Google Chat] ${spaceName}: ${messageText.slice(0, 100)}`,\n body_html: bodyHtml,\n requester_email: senderEmail,\n requester_name: senderName,\n requester_avatar_url: message.sender?.avatarUrl,\n author_unverified: true,\n created_at: createdAt,\n tags: [\"google-chat\"],\n };\n\n if (teamId) {\n payload.team_id = teamId;\n }\n\n const response = await fetch(`${PYLON_API_URL}/issues`, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${pylonToken}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n },\n body: JSON.stringify(payload),\n });\n\n const responseText = await response.text();\n\n if (!response.ok) {\n throw new Error(\n `Pylon returned ${response.status}: ${responseText}`,\n );\n }\n\n return responseText ? JSON.parse(responseText) : {};\n}\n\nexport default async function handler(\n request: Request,\n): Promise {\n if (request.method === \"GET\") {\n return Response.json({\n ok: true,\n service: \"google-chat-to-pylon\",\n });\n }\n\n if (request.method !== \"POST\") {\n return new Response(\"Method not allowed\", { status: 405 });\n }\n\n /*\n * Initial shared-secret protection.\n * Pub/Sub will call a URL such as:\n * https://YOUR-VAL.web.val.run/?secret=YOUR_SECRET\n *\n * For production, authenticated Pub/Sub push with Google-signed\n * OIDC tokens is preferable.\n */\n const expectedSecret = Deno.env.get(\"GOOGLE_WEBHOOK_SECRET\");\n const requestUrl = new URL(request.url);\n const suppliedSecret = requestUrl.searchParams.get(\"secret\");\n\n if (!expectedSecret || suppliedSecret !== expectedSecret) {\n return new Response(\"Unauthorized\", { status: 401 });\n }\n\n let envelope: PubSubEnvelope;\n\n try {\n envelope = await request.json();\n } catch {\n return new Response(\"Invalid JSON\", { status: 400 });\n }\n\n const encodedData = envelope.message?.data;\n\n if (!encodedData) {\n return new Response(\"Missing Pub/Sub message data\", {\n status: 400,\n });\n }\n\n try {\n const event = decodeBase64Json(encodedData) as GoogleChatEvent;\n\n const eventType = event.type || event.eventType || \"\";\n const chatMessage = extractChatMessage(event);\n\n console.log(\"Google event\", {\n eventType,\n subject: event.subject,\n pubSubMessageId: envelope.message?.messageId,\n event,\n });\n\n // Ignore non-message events.\n if (\n eventType &&\n !eventType.includes(\"message\") &&\n !eventType.includes(\"Message\")\n ) {\n return Response.json({\n ok: true,\n ignored: true,\n reason: `Unsupported event type: ${eventType}`,\n });\n }\n\n if (!chatMessage) {\n return Response.json({\n ok: true,\n ignored: true,\n reason: \"No Google Chat message found in event\",\n });\n }\n\n /*\n * Optional filter: ignore messages created by Chat apps.\n * This helps prevent loops when replies are later synchronized\n * from Pylon back into Google Chat.\n */\n if (chatMessage.sender?.type === \"BOT\") {\n return Response.json({\n ok: true,\n ignored: true,\n reason: \"Bot message\",\n });\n }\n\n const pylonResult = await createPylonIssue(\n chatMessage,\n event,\n envelope.message?.messageId,\n );\n\n return Response.json({\n ok: true,\n pylon: pylonResult,\n });\n } catch (error) {\n console.error(error);\n\n /*\n * Returning a non-2xx status makes Pub/Sub retry the event.\n */\n return Response.json(\n {\n ok: false,\n error: error instanceof Error ? error.message : String(error),\n },\n { status: 500 },\n );\n }\n}","label",[60],"pulls","branches","forks","envVars",{"_169":36,"_171":20},"connections",{"_169":20,"_170":20},"count","unfilledCount","emptyCount",{"_29":154,"_13":60,"_58":59,"_39":-5,"_31":32,"_155":77,"_156":129,"_33":173,"_35":70,"_61":62,"_158":159,"_63":24,"_160":-5,"_174":175,"_131":176},["D",1782123311710],"children",[],[60],["D",1782123068340],{"_11":12,"_130":125},{"_11":12,"_124":-5,"_66":125,"_25":-5,"_126":127,"_128":129},{"_35":77,"_13":16,"_29":32,"_116":82,"_117":-5,"_118":-5,"_119":-5,"_120":-5,"_121":-5,"_122":14,"_123":12},"ctx",{"_47":-5,"_150":214,"_215":216,"_217":218,"_219":24,"_220":24,"_221":24,"_222":129,"_223":-5,"_224":-7,"_225":-7,"_226":20,"_227":24,"_228":24,"_229":-5,"_230":24,"_231":24,"_232":24,"_233":-5},"ENV",{"_185":186,"_187":188,"_189":16,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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"]

History