web/packages/trpc/lib/routers/user/query/userTrackingInfo.ts

import { createCounter } from "@scandic-hotels/common/telemetry"

import { safeProtectedProcedure } from "../../../procedures"
import { isValidSession } from "../../../utils/session"
import { getEuroBonusProfileData } from "../../partners/sas/getEuroBonusProfile"
import { getFriendsMembership } from "../helpers"
import { getVerifiedUser } from "../utils/getVerifiedUser"

import type { LoginType } from "@scandic-hotels/common/constants/loginType"
import type { Session } from "next-auth"

import type { TrackingUserData } from "../../types"

export const userTrackingInfo = safeProtectedProcedure.query(async function ({
  ctx,
}) {
  if (ctx.app === "partner-sas") {
    return getSasEurobonusUserTrackingData(ctx.session)
  }

  if (ctx.app === "scandic-web") {
    return getScandicFriendsUserTrackingData(ctx.session)
  }

  return { loginStatus: "Error" } as const
})

async function getScandicFriendsUserTrackingData(session: Session | null) {
  const userTrackingInfoCounter = createCounter("user", "userTrackingInfo")
  const metricsUserTrackingInfo = userTrackingInfoCounter.init()

  metricsUserTrackingInfo.start()

  const memberType = "scandic-friends" as const

  const notLoggedInUserTrackingData: TrackingUserData = {
    loginStatus: "Non-logged in",
    memberType,
  }

  if (!isValidSession(session)) {
    metricsUserTrackingInfo.success({
      reason: "invalid session",
      data: notLoggedInUserTrackingData,
    })
    return notLoggedInUserTrackingData
  }

  try {
    const verifiedUserData = await getVerifiedUser({ token: session.token })

    if (!verifiedUserData || !verifiedUserData.loyalty) {
      metricsUserTrackingInfo.success({
        reason: "invalid user data",
        data: notLoggedInUserTrackingData,
      })
      return notLoggedInUserTrackingData
    }

    const membership = getFriendsMembership(verifiedUserData.loyalty)

    const loggedInUserTrackingData: TrackingUserData = {
      loginStatus: "logged in",
      loginType: session.token.loginType as LoginType,
      memberId: verifiedUserData.profileId,
      membershipNumber: membership?.membershipNumber,
      memberLevel: membership?.membershipLevel,
      loginAction: "login success",
      memberType,
    }

    metricsUserTrackingInfo.success({
      reason: "valid logged in",
      data: loggedInUserTrackingData,
    })

    return loggedInUserTrackingData
  } catch (error) {
    metricsUserTrackingInfo.fail(error)
    return notLoggedInUserTrackingData
  }
}

async function getSasEurobonusUserTrackingData(session: Session | null) {
  const notLoggedInUserTrackingData: TrackingUserData = {
    loginStatus: "Non-logged in",
    memberType: "sas-eurobonus",
  }

  if (!isValidSession(session)) {
    return notLoggedInUserTrackingData
  }

  try {
    const eurobonusProfile = await getEuroBonusProfileData({
      accessToken: session.token.access_token,
      loginType: "eurobonus",
    })

    const loggedInUserTrackingData: TrackingUserData = {
      loginStatus: "logged in",
      loginType: session.token.loginType,
      loginAction: "login success",
      memberType: "sas-eurobonus",
      eurobonusNumber: eurobonusProfile.eurobonusNumber,
      tier: eurobonusProfile.tier,
      linkStatus: eurobonusProfile.linkStatus,
    }

    return loggedInUserTrackingData
  } catch (_error) {
    return notLoggedInUserTrackingData
  }
}