Xây AI Email Assistant Hoạt Động Thực Sự

mkdir ai-email-assistant && cd ai-email-assistant
npm init -y
npm install openai resend dotenv zod

OPENAI_API_KEY=your-openai-key
RESEND_API_KEY=your-resend-key
FROM_EMAIL=ban@domain.com

import OpenAI from 'openai'
 
const client = new OpenAI()
 
export async function summarizeEmail(emailContent: string): Promise<string> {
  const response = await client.chat.completions.create({
    model: 'gpt-4o',
    messages: [
      {
        role: 'system',
        content: `Bạn là chuyên gia tóm tắt email. Trích xuất:
        1. Chủ đề chính trong một câu
        2. Quyết định hoặc yêu cầu quan trọng (bullet points)
        3. Hành động cần thực hiện và deadline
        4. Những người quan trọng được đề cập
        Ngắn gọn, tập trung vào thông tin có thể hành động.`
      },
      {
        role: 'user',
        content: `Tóm tắt email thread này:\n\n${emailContent}`
      }
    ],
    max_tokens: 500
  })
 
  return response.choices[0].message.content ?? ''
}

interface DraftReplyOptions {
  emailThread: string
  tone: 'professional' | 'friendly' | 'concise'
  keyPoints: string[]
  senderName: string
}
 
export async function draftReply(options: DraftReplyOptions): Promise<string> {
  const { emailThread, tone, keyPoints, senderName } = options
 
  const toneGuide = {
    professional: 'trang trọng, lịch sự, phù hợp môi trường công sở',
    friendly: 'thân thiện, gần gũi, vẫn chuyên nghiệp',
    concise: 'ngắn gọn, trực tiếp, không dài dòng — đi thẳng vào vấn đề'
  }
 
  const response = await client.chat.completions.create({
    model: 'gpt-4o',
    messages: [
      {
        role: 'system',
        content: `Bạn soạn thảo email reply. Tone: ${toneGuide[tone]}.
        Luôn gọi tên người nhận.
        Cấu trúc: lời chào → nội dung chính → bước tiếp theo rõ ràng → kết thúc.
        Không dùng placeholder text.`
      },
      {
        role: 'user',
        content: `Soạn reply cho email thread từ ${senderName}.
        
Các điểm cần đề cập:
${keyPoints.map(p => `- ${p}`).join('\n')}
 
Thread gốc:
${emailThread}`
      }
    ],
    max_tokens: 800
  })
 
  return response.choices[0].message.content ?? ''
}

import { z } from 'zod'
 
const ClassificationSchema = z.object({
  priority: z.enum(['urgent', 'normal', 'low']),
  category: z.enum(['action-required', 'fyi', 'newsletter', 'spam', 'meeting']),
  reasoning: z.string()
})
 
export async function classifyEmail(emailContent: string) {
  const response = await client.chat.completions.create({
    model: 'gpt-4o',
    messages: [
      {
        role: 'system',
        content: 'Phân loại email theo priority và category. Chỉ trả về JSON.'
      },
      {
        role: 'user',
        content: `Phân loại email này và trả JSON theo schema:
        { priority: "urgent"|"normal"|"low", category: "action-required"|"fyi"|"newsletter"|"spam"|"meeting", reasoning: string }
        
        Email: ${emailContent}`
      }
    ],
    response_format: { type: 'json_object' }
  })
 
  const parsed = JSON.parse(response.choices[0].message.content ?? '{}')
  return ClassificationSchema.parse(parsed)
}

import { Resend } from 'resend'
 
const resend = new Resend(process.env.RESEND_API_KEY)
 
export async function sendEmail(options: {
  to: string
  subject: string
  body: string
  replyTo?: string
}) {
  const { to, subject, body, replyTo } = options
 
  const { data, error } = await resend.emails.send({
    from: process.env.FROM_EMAIL!,
    to,
    subject,
    text: body,
    replyTo
  })
 
  if (error) throw new Error(`Gửi email thất bại: ${error.message}`)
  return data
}

import * as readline from 'readline'
 
const rl = readline.createInterface({ input: process.stdin, output: process.stdout })
const question = (prompt: string): Promise<string> =>
  new Promise(resolve => rl.question(prompt, resolve))
 
async function main() {
  console.log('AI Email Assistant\n')
  const action = await question('Chọn hành động (summarize/draft/classify): ')
  const emailContent = await question('Dán nội dung email:\n')
 
  if (action === 'summarize') {
    const summary = await summarizeEmail(emailContent)
    console.log('\nTóm tắt:\n', summary)
  } else if (action === 'draft') {
    const tone = await question('Tone (professional/friendly/concise): ') as any
    const points = await question('Các điểm cần đề cập (cách nhau bằng dấu phẩy): ')
    const sender = await question('Tên người gửi: ')
    const draft = await draftReply({
      emailThread: emailContent,
      tone,
      keyPoints: points.split(',').map(p => p.trim()),
      senderName: sender
    })
    console.log('\nBản nháp:\n', draft)
  } else if (action === 'classify') {
    const result = await classifyEmail(emailContent)
    console.log('\nPhân loại:', JSON.stringify(result, null, 2))
  }
 
  rl.close()
}
 
main().catch(console.error)