100 lines
2.6 KiB
TypeScript
100 lines
2.6 KiB
TypeScript
import dayjs from "dayjs"
|
|
import { z } from "zod"
|
|
|
|
import { unauthorizedError } from "../../../errors"
|
|
import { safeProtectedServiceProcedure } from "../../../procedures"
|
|
import { toApiLang } from "../../../utils"
|
|
import { getRedemptionTokenSafely } from "../../../utils/getRedemptionTokenSafely"
|
|
import { getUserPointsBalance } from "../../../utils/getUserPointsBalance"
|
|
import { getHotelsAvailabilityByHotelIds } from "../services/getHotelsAvailabilityByHotelIds"
|
|
|
|
export type HotelsByHotelIdsAvailabilityInputSchema = z.output<
|
|
typeof getHotelsByHotelIdsAvailabilityInputSchema
|
|
>
|
|
export const getHotelsByHotelIdsAvailabilityInputSchema = z
|
|
.object({
|
|
hotelIds: z.array(z.number()),
|
|
roomStayStartDate: z.string().refine(
|
|
(val) => {
|
|
const fromDate = dayjs(val)
|
|
return fromDate.isValid()
|
|
},
|
|
{
|
|
message: "FROMDATE_INVALID",
|
|
}
|
|
),
|
|
roomStayEndDate: z.string().refine(
|
|
(val) => {
|
|
const toDate = dayjs(val)
|
|
|
|
return toDate.isValid()
|
|
},
|
|
{
|
|
message: "TODATE_INVALID",
|
|
}
|
|
),
|
|
adults: z.number(),
|
|
children: z.string().optional(),
|
|
bookingCode: z.string().optional().default(""),
|
|
redemption: z.boolean().optional().default(false),
|
|
})
|
|
.refine(
|
|
(data) => {
|
|
const fromDate = dayjs(data.roomStayStartDate).startOf("day")
|
|
const toDate = dayjs(data.roomStayEndDate).startOf("day")
|
|
|
|
return fromDate.isBefore(toDate)
|
|
},
|
|
{
|
|
message: "FROMDATE_BEFORE_TODATE",
|
|
}
|
|
)
|
|
.refine(
|
|
(data) => {
|
|
const fromDate = dayjs(data.roomStayStartDate)
|
|
const today = dayjs().startOf("day")
|
|
|
|
return fromDate.isSameOrAfter(today)
|
|
},
|
|
{
|
|
message: "FROMDATE_CANNOT_BE_IN_THE_PAST",
|
|
}
|
|
)
|
|
|
|
export const hotelsByHotelIds = safeProtectedServiceProcedure
|
|
.input(getHotelsByHotelIdsAvailabilityInputSchema)
|
|
.use(async ({ ctx, input, next }) => {
|
|
if (input.redemption) {
|
|
if (ctx.session?.token.access_token) {
|
|
const pointsValue = await getUserPointsBalance(ctx.session)
|
|
const token = getRedemptionTokenSafely(ctx.session, ctx.serviceToken)
|
|
if (pointsValue !== undefined && token) {
|
|
return next({
|
|
ctx: {
|
|
token: token,
|
|
userPoints: pointsValue,
|
|
},
|
|
input,
|
|
})
|
|
}
|
|
}
|
|
throw unauthorizedError()
|
|
}
|
|
return next({
|
|
ctx: {
|
|
token: ctx.serviceToken,
|
|
},
|
|
input,
|
|
})
|
|
})
|
|
.query(async ({ input, ctx }) => {
|
|
const { lang } = ctx
|
|
const apiLang = toApiLang(lang)
|
|
return getHotelsAvailabilityByHotelIds(
|
|
input,
|
|
apiLang,
|
|
ctx.token,
|
|
ctx.userPoints
|
|
)
|
|
})
|