Function sendLifecycleEmail

apps/sim/background/lifecycle-email.ts:20–57

({ userId, type }: LifecycleEmailParams)

}

async function sendLifecycleEmail({ userId, type }: LifecycleEmailParams): Promise<void> {
  const [userData] = await db.select().from(user).where(eq(user.id, userId)).limit(1)

  if (!userData?.email) {
    logger.warn('[lifecycle-email] User not found or has no email', { userId, type })
    return
  }

  const subscription = await getHighestPrioritySubscription(userId)
  if (checkEnterprisePlan(subscription)) {
    logger.info('[lifecycle-email] Skipping lifecycle email for enterprise user', { userId, type })
    return
  }

  const { from, replyTo } = getPersonalEmailFrom()

  let html: string

  switch (type) {
    case 'onboarding-followup':
      html = await renderOnboardingFollowupEmail(userData.name || undefined)
      break
    default:
      logger.warn('[lifecycle-email] Unknown lifecycle email type', { type })
      return
  }

  await sendEmail({
    to: userData.email,
    subject: getEmailSubject(type),
    html,
    from,
    replyTo,
    emailType: 'notifications',
  })

  logger.info('[lifecycle-email] Sent lifecycle email', { userId, type })
}

export const lifecycleEmailTask = task({
  id: LIFECYCLE_EMAIL_TASK_ID,