27aef3982e
Fix(LOY-222): Find my booking url handling * fix(LOY-222): adapt findMyBooking url based on HIDE_FOR_NEXT_RELEASE * feat(LOY-222): add current web paths for findMyBooking in multiple languages * refactor(LOY-222): better env and new url constructions * refactor(LOY-222): decouple env var handling from getCurrentWebUrl * fix(LOY-222): update findMyBooking URL construction to use baseUrl * fix(LOY-222): simplify findMyBooking URL handling for new web urls * fix(LOY-222): Update Finnish path for hotel reservation lookup * refactor(LOY-222): rename PUBLIC_URL to NEXT_PUBLIC_PUBLIC_URL for consistency Approved-by: Christian Andolf Approved-by: Linus Flood
109 lines
2.9 KiB
TypeScript
109 lines
2.9 KiB
TypeScript
import { metrics } from "@opentelemetry/api"
|
|
|
|
import { myBookingPath } from "@/constants/myBooking"
|
|
import { myStay } from "@/constants/routes/myStay"
|
|
import { env } from "@/env/server"
|
|
import * as api from "@/lib/api"
|
|
|
|
import { getCurrentWebUrl } from "@/utils/url"
|
|
|
|
import { encrypt } from "../utils/encryption"
|
|
|
|
import type { Lang } from "@/constants/languages"
|
|
import type { FriendTransaction, Stay } from "./output"
|
|
|
|
const meter = metrics.getMeter("trpc.user")
|
|
const getProfileCounter = meter.createCounter("trpc.user.profile")
|
|
const getProfileSuccessCounter = meter.createCounter(
|
|
"trpc.user.profile-success"
|
|
)
|
|
const getProfileFailCounter = meter.createCounter("trpc.user.profile-fail")
|
|
|
|
async function updateStaysBookingUrl(
|
|
data: Stay[],
|
|
token: string,
|
|
lang: Lang
|
|
): Promise<Stay[]>
|
|
|
|
async function updateStaysBookingUrl(
|
|
data: FriendTransaction[],
|
|
token: string,
|
|
lang: Lang
|
|
): Promise<FriendTransaction[]>
|
|
|
|
async function updateStaysBookingUrl(
|
|
data: Stay[] | FriendTransaction[],
|
|
token: string,
|
|
lang: Lang
|
|
) {
|
|
// Temporary API call needed till we have user name in ctx session data
|
|
getProfileCounter.add(1)
|
|
console.info("api.user.profile updatebookingurl start", JSON.stringify({}))
|
|
const apiResponse = await api.get(api.endpoints.v1.Profile.profile, {
|
|
cache: "no-store",
|
|
headers: {
|
|
Authorization: `Bearer ${token}`,
|
|
},
|
|
})
|
|
|
|
if (!apiResponse.ok) {
|
|
getProfileFailCounter.add(1, { error: JSON.stringify(apiResponse) })
|
|
console.info(
|
|
"api.user.profile updatebookingurl error",
|
|
JSON.stringify({ error: apiResponse })
|
|
)
|
|
return data
|
|
}
|
|
|
|
const apiJson = await apiResponse.json()
|
|
if (!apiJson.data?.attributes) {
|
|
return data
|
|
}
|
|
|
|
getProfileSuccessCounter.add(1)
|
|
console.info("api.user.profile updatebookingurl success", JSON.stringify({}))
|
|
|
|
return data.map((d) => {
|
|
const originalString =
|
|
d.attributes.confirmationNumber.toString() +
|
|
"," +
|
|
apiJson.data.attributes.lastName
|
|
const encryptedBookingValue = encrypt(originalString)
|
|
|
|
// Get base URL with fallback for ephemeral environments (like deploy previews).
|
|
const baseUrl = env.PUBLIC_URL || "https://www.scandichotels.com"
|
|
|
|
// Construct Booking URL.
|
|
const bookingUrl = env.HIDE_FOR_NEXT_RELEASE
|
|
? new URL(
|
|
getCurrentWebUrl({
|
|
path: myBookingPath[lang],
|
|
lang,
|
|
baseUrl,
|
|
})
|
|
)
|
|
: new URL(myStay[lang], baseUrl)
|
|
|
|
// Add search parameters.
|
|
if (encryptedBookingValue) {
|
|
bookingUrl.searchParams.set("RefId", encryptedBookingValue)
|
|
} else {
|
|
bookingUrl.searchParams.set("lastName", apiJson.data.attributes.lastName)
|
|
bookingUrl.searchParams.set(
|
|
"bookingId",
|
|
d.attributes.confirmationNumber.toString()
|
|
)
|
|
}
|
|
|
|
return {
|
|
...d,
|
|
attributes: {
|
|
...d.attributes,
|
|
bookingUrl: bookingUrl.toString(),
|
|
},
|
|
}
|
|
})
|
|
}
|
|
|
|
export { updateStaysBookingUrl }
|