Function updateEmailPreferences

apps/sim/lib/messaging/email/unsubscribe.ts:92–147

(
  email: string,
  preferences: EmailPreferences
)

 * Update user's email preferences
 */
export async function updateEmailPreferences(
  email: string,
  preferences: EmailPreferences
): Promise<boolean> {
  try {
    const userResult = await db
      .select({ id: user.id })
      .from(user)
      .where(eq(user.email, email))
      .limit(1)

    if (!userResult[0]) {
      logger.warn(`User not found for email: ${email}`)
      return false
    }

    const userId = userResult[0].id

    const existingSettings = await db
      .select({ emailPreferences: settings.emailPreferences })
      .from(settings)
      .where(eq(settings.userId, userId))
      .limit(1)

    let currentEmailPreferences = {}
    if (existingSettings[0]) {
      currentEmailPreferences = (existingSettings[0].emailPreferences as EmailPreferences) || {}
    }

    const updatedEmailPreferences = {
      ...currentEmailPreferences,
      ...preferences,
    }

    await db
      .insert(settings)
      .values({
        id: userId,
        userId,
        emailPreferences: updatedEmailPreferences,
      })
      .onConflictDoUpdate({
        target: settings.userId,
        set: {
          emailPreferences: updatedEmailPreferences,
          updatedAt: new Date(),
        },
      })

    logger.info(`Updated email preferences for user: ${email}`)
    return true
  } catch (error) {
    logger.error('Error updating email preferences:', error)
    return false
  }
}

/**