Gmail

integrations:
  gmail:
    enabled: true
    credentials:
      client_id: ${GMAIL_CLIENT_ID}
      client_secret: ${GMAIL_CLIENT_SECRET}
    settings:
      oauth_callback_path: "/auth/google/callback"
      token_storage: "encrypted-file"
      scopes:
        - gmail.send
        - gmail.readonly
        - gmail.modify
        - gmail.labels
      watch:
        enabled: true
        topic: "projects/my-project/topics/cognest-gmail"
        label_filter: "INBOX"
      max_results: 50
      signature: "Sent via Cognest"

# .env
GMAIL_CLIENT_ID=829471035284-abc123def456.apps.googleusercontent.com
GMAIL_CLIENT_SECRET=GOCSPX-aBcDeFgHiJkLmNoPqRs

import { Cognest } from '@cognest/sdk'
import { Gmail } from '@cognest/integrations/gmail'

const cognest = new Cognest({ configPath: false })

cognest.use(Gmail, {
  clientId: process.env.GMAIL_CLIENT_ID!,
  clientSecret: process.env.GMAIL_CLIENT_SECRET!,
  settings: {
    oauthCallbackPath: '/auth/google/callback',
    tokenStorage: 'encrypted-file',
    scopes: [
      'gmail.send',
      'gmail.readonly',
      'gmail.modify',
      'gmail.labels',
    ],
    watch: {
      enabled: true,
      topic: 'projects/my-project/topics/cognest-gmail',
      labelFilter: 'INBOX',
    },
    maxResults: 50,
    signature: 'Sent via Cognest',
  },
})

await cognest.start()

const gmail = cognest.integration<Gmail>('gmail')

// Generate the authorization URL
const authUrl = gmail.getAuthUrl({
  redirectUri: 'https://your-app.com/auth/google/callback',
  accessType: 'offline',   // Required for refresh tokens
  prompt: 'consent',       // Force consent to get refresh token
})

// After user authorizes, exchange the code
await gmail.handleCallback(authorizationCode)

// Tokens are now stored and auto-refreshed

import { Cognest } from '@cognest/sdk'
import { Gmail } from '@cognest/integrations/gmail'

const cognest = new Cognest()
const gmail = cognest.integration<Gmail>('gmail')

// Auto-respond to new support emails
cognest.on('gmail:email:received', async (ctx) => {
  const { messageId, threadId, from, subject, snippet, labels } = ctx.payload

  // Only process emails in the support label
  if (!labels.includes('Label_support')) return

  // Skip if the sender is our own address (avoid loops)
  const profile = await gmail.getProfile()
  if (from.includes(profile.emailAddress)) return

  // Fetch the full thread for context
  const thread = await gmail.getThread(threadId, {
    format: 'full',
  })

  // Build conversation history from thread messages
  const history = thread.messages.map((msg) => ({
    role: msg.from.includes(profile.emailAddress) ? 'assistant' as const : 'user' as const,
    content: msg.textBody,
  }))

  // Generate a response with the AI engine
  const response = await cognest.engine.chat({
    conversationId: `email:${threadId}`,
    messages: history,
    systemPrompt: `You are a helpful customer support agent for Acme Corp.
      Be concise and professional. If you cannot resolve the issue,
      say you will escalate to a human team member.`,
  })

  // Reply to the thread
  await gmail.reply(threadId, {
    body: response.text,
    html: `<div style="font-family: sans-serif;">${response.html}</div>`,
  })

  // Label the message as processed
  await gmail.addLabel(messageId, 'Label_auto_replied')
})

// Periodic check for unread messages (backup for missed webhooks)
cognest.schedule('*/15 * * * *', async () => {
  const unread = await gmail.getUnread({
    maxResults: 10,
    labelIds: ['Label_support'],
  })

  for (const msg of unread.messages) {
    // Emit as if received via webhook
    cognest.emit('gmail:email:received', {
      messageId: msg.id,
      threadId: msg.threadId,
      from: msg.from,
      to: msg.to,
      subject: msg.subject,
      snippet: msg.snippet,
      labels: msg.labelIds,
      date: msg.date,
    })
  }
})

// Search for specific emails
async function findInvoices(after: string) {
  const results = await gmail.search(
    `subject:invoice has:attachment after:${after}`,
    { maxResults: 25 }
  )

  return results.messages.map((msg) => ({
    id: msg.id,
    from: msg.from,
    subject: msg.subject,
    date: msg.date,
  }))
}

await cognest.start()
console.log('Gmail integration is running')