Mail Management

import { Inbound } from '@inboundemail/sdk'

const inbound = new Inbound({ apiKey: process.env.INBOUND_API_KEY! })

// List all emails
const emails = await inbound.mail.list()

// With filters
const filteredEmails = await inbound.mail.list({
  limit: 20,
  offset: 0,
  search: 'invoice',
  domain: 'example.com',
  timeRange: '7d',
  includeArchived: false
})

console.log(`Found ${emails.emails.length} emails`)
console.log(`Total: ${emails.pagination.total}`)

interface GetMailResponse {
  emails: EmailItem[]
  pagination: {
    limit: number
    offset: number
    total: number
    hasMore?: boolean
  }
}

interface EmailItem {
  id: string
  emailId: string
  messageId: string | null
  subject: string
  from: string
  fromName: string | null
  recipient: string
  preview: string
  receivedAt: Date
  isRead: boolean
  readAt: Date | null
  isArchived: boolean
  archivedAt: Date | null
  hasAttachments: boolean
  attachmentCount: number
  parseSuccess: boolean | null
  parseError: string | null
  createdAt: Date
}

const emailDetails = await inbound.mail.get('email_abc123')

console.log('Subject:', emailDetails.subject)
console.log('From:', emailDetails.from)
console.log('Text:', emailDetails.textBody)
console.log('HTML:', emailDetails.htmlBody)
console.log('Attachments:', emailDetails.attachments.length)

interface GetMailByIdResponse {
  id: string
  emailId: string
  subject: string
  from: string
  to: string
  textBody: string
  htmlBody: string
  receivedAt: Date
  attachments: Array<{
    filename: string
    contentType: string
    size: number
    contentId?: string
  }>
}

// Reply to an email
await inbound.mail.reply({
  emailId: 'email_abc123',
  to: 'customer@example.com',
  subject: 'Re: Your inquiry',
  textBody: 'Thank you for your message. We will get back to you soon.',
  htmlBody: '<p>Thank you for your message. We will get back to you soon.</p>'
})

// Search for unprocessed orders
const orderEmails = await inbound.mail.list({
  search: 'order',
  timeRange: '24h',
  status: 'processed'
})

for (const email of orderEmails.emails) {
  // Get full email details
  const details = await inbound.mail.get(email.id)
  
  // Process order
  const orderNumber = extractOrderNumber(details.textBody)
  await processOrder(orderNumber)
  
  // Reply to confirm
  await inbound.mail.reply({
    emailId: email.id,
    to: email.from,
    subject: `Order ${orderNumber} Confirmed`,
    textBody: `Your order ${orderNumber} has been received and is being processed.`
  })
}

async function getAllEmails() {
  const allEmails: EmailItem[] = []
  let offset = 0
  const limit = 100
  
  while (true) {
    const response = await inbound.mail.list({
      limit,
      offset,
      timeRange: '30d'
    })
    
    allEmails.push(...response.emails)
    
    if (!response.pagination.hasMore) break
    offset += limit
  }
  
  return allEmails
}

// Get emails older than 30 days
const oldEmails = await inbound.mail.list({
  timeRange: '90d',
  includeArchived: false
})

// Filter emails older than 30 days
const thirtyDaysAgo = new Date()
thirtyDaysAgo.setDate(thirtyDaysAgo.getDate() - 30)

const toArchive = oldEmails.emails.filter(
  email => new Date(email.receivedAt) < thirtyDaysAgo
)

// Archive them (using your own archive logic)
for (const email of toArchive) {
  await archiveEmail(email.id)
}

// Get email statistics
const emails = await inbound.mail.list({
  timeRange: '7d',
  limit: 100
})

const stats = {
  total: emails.pagination.total,
  withAttachments: emails.emails.filter(e => e.hasAttachments).length,
  failed: emails.emails.filter(e => !e.parseSuccess).length,
  domains: [...new Set(emails.emails.map(e => 
    e.recipient.split('@')[1]
  ))],
  avgResponseTime: calculateAvgResponseTime(emails.emails)
}

console.log('Weekly email stats:', stats)

try {
  const emails = await inbound.mail.list()
} catch (error) {
  if (error.message.includes('401')) {
    console.error('Invalid API key')
  } else if (error.message.includes('429')) {
    console.error('Rate limit exceeded')
  } else {
    console.error('API error:', error.message)
  }
}