워크플로우로 업무 자동화

[트리거: users.created]
       |
       v
[함수: send-welcome-email]
       |
       v
[지연: 1일]
       |
       v
[함수: check-profile-completed]
       |
       v
[조건: isCompleted == true?]
   |               |
   v               v
  Yes             No
   |               |
   v               v
[send-coupon]  [send-reminder]
   |               |
   v               v
[종료]         [지연: 3일]
                   |
                   v
               [check-profile]
                   |
                   v
               [조건 분기]
                   |
          Yes ----+---- No
           |            |
           v            v
       [coupon]      [종료]

// 환경 변수: RESEND_API_KEY (이메일 서비스 API 키)

export default async function handler(payload, context) {
  const { to, subject, template, data } = payload

  // 템플릿 렌더링
  const templates = {
    welcome: (d) => `
      <h1>환영합니다, ${d.name}님!</h1>
      <p>Connect Base에 가입해주셔서 감사합니다.</p>
      <a href="https://myapp.com/profile">프로필 완성하기</a>
    `,
    reminder: (d) => `
      <h1>${d.name}님, 프로필을 완성해주세요!</h1>
      <p>프로필을 완성하면 10% 할인 쿠폰을 드립니다.</p>
    `,
    coupon: (d) => `
      <h1>축하합니다, ${d.name}님!</h1>
      <p>첫 구매 10% 할인 쿠폰: <strong>WELCOME10</strong></p>
    `
  }

  const html = templates[template](data)

  // Resend API로 이메일 발송
  const response = await fetch('https://api.resend.com/emails', {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${context.env.RESEND_API_KEY}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({ from: '[email protected]', to, subject, html })
  })

  return { success: response.ok }
}

export default async function handler(payload, context) {
  const { userId } = payload
  const db = context.database

  const user = await db.table('users').doc(userId).get()
  const requiredFields = ['name', 'phone', 'address']
  const isCompleted = requiredFields.every(field => user[field])

  return {
    isCompleted,
    userId,
    name: user.name,
    email: user.email
  }
}

[트리거: orders.created]
       |
       v
[함수: check-inventory]
       |
       v
[조건: 재고 있음?]
   |           |
  No          Yes
   |           |
   v           v
[알림]    [process-payment]
   |           |
   v           v
[종료]    [조건: 결제 성공?]
              |           |
             No          Yes
              |           |
              v           v
          [알림]     [병렬 실행]
                        |
            +-----------+-----------+
            |           |           |
            v           v           v
      [재고 차감]  [확인 메일]  [배송 생성]

export default async function handler(payload, context) {
  const db = context.database

  const yesterday = new Date()
  yesterday.setDate(yesterday.getDate() - 1)
  const startOfDay = new Date(yesterday.setHours(0, 0, 0, 0))
  const endOfDay = new Date(yesterday.setHours(23, 59, 59, 999))

  // 주문 통계
  const orders = await db.table('orders').find({
    where: { createdAt: { $gte: startOfDay, $lte: endOfDay } }
  })

  const totalRevenue = orders.reduce((sum, o) => sum + o.amount, 0)

  // 신규 가입자
  const newUsers = await db.table('users').find({
    where: { createdAt: { $gte: startOfDay, $lte: endOfDay } }
  })

  return {
    date: startOfDay.toISOString().split('T')[0],
    metrics: {
      totalRevenue,
      orderCount: orders.length,
      newUserCount: newUsers.length
    }
  }
}

previous.userId        // 직전 스텝 출력의 userId
previous.email         // 직전 스텝 출력의 email
initial.orderId        // 워크플로우 시작 시 받은 초기 입력의 orderId

previous.success == true
previous.amount > 10000
previous.status == "success"
results.check-profile.isCompleted == true

// 데이터 이벤트로 워크플로우 트리거 (가장 흔한 패턴)
// 예: tbl_orders 에 row 가 생성되면 자동으로 워크플로우 실행
await cb.database.createData('tbl_orders', {
  data: { user_id: 'member_xxx', amount: 50000 }
})
// → 콘솔에서 "tbl_orders.created" 이벤트로 등록된 워크플로우들이 자동 실행됨