overleaf/services/web/app/src/Features/User/UserPostRegistrationAnalyticsManager.mjs

import Queues from '../../infrastructure/Queues.js'
import UserGetter from './UserGetter.js'
import InstitutionsAPI from '../Institutions/InstitutionsAPI.js'
import AnalyticsManager from '../Analytics/AnalyticsManager.js'

const ONE_DAY_MS = 24 * 60 * 60 * 1000

async function schedulePostRegistrationAnalytics(user) {
  await Queues.createScheduledJob(
    'post-registration-analytics',
    { data: { userId: user._id } },
    ONE_DAY_MS
  )
}

async function postRegistrationAnalytics(userId) {
  const user = await UserGetter.promises.getUser({ _id: userId }, { email: 1 })
  if (!user) {
    return
  }
  await checkAffiliations(userId)
}

async function checkAffiliations(userId) {
  const affiliationsData =
    await InstitutionsAPI.promises.getUserAffiliations(userId)
  const hasCommonsAccountAffiliation = affiliationsData.some(
    affiliationData =>
      affiliationData.institution && affiliationData.institution.commonsAccount
  )

  if (hasCommonsAccountAffiliation) {
    await AnalyticsManager.setUserPropertyForUser(
      userId,
      'registered-from-commons-account',
      true
    )
  }
}

export default {
  schedulePostRegistrationAnalytics,
  postRegistrationAnalytics,
}