115 lines
3.0 KiB
TypeScript
115 lines
3.0 KiB
TypeScript
import * as api from "@/lib/api"
|
|
import {
|
|
benefits,
|
|
extendedUser,
|
|
nextLevelPerks,
|
|
previousStays,
|
|
upcomingStays,
|
|
} from "./temp"
|
|
import {
|
|
badRequestError,
|
|
forbiddenError,
|
|
internalServerError,
|
|
unauthorizedError,
|
|
} from "@/server/errors/trpc"
|
|
import { protectedProcedure, router } from "@/server/trpc"
|
|
import { z } from "zod"
|
|
|
|
import { getUserSchema } from "./output"
|
|
|
|
function fakingRequest<T>(payload: T): Promise<T> {
|
|
return new Promise((resolve) => {
|
|
setTimeout(() => {
|
|
resolve(payload)
|
|
}, 1500)
|
|
})
|
|
}
|
|
|
|
export const userQueryRouter = router({
|
|
get: protectedProcedure.query(async function ({ ctx }) {
|
|
try {
|
|
const apiResponse = await api.get(api.endpoints.v0.profile, {
|
|
cache: "no-store",
|
|
headers: {
|
|
Authorization: `Bearer ${ctx.session.token.access_token}`,
|
|
},
|
|
})
|
|
|
|
if (!apiResponse.ok) {
|
|
switch (apiResponse.status) {
|
|
case 400:
|
|
throw badRequestError()
|
|
case 401:
|
|
throw unauthorizedError()
|
|
case 403:
|
|
throw forbiddenError()
|
|
default:
|
|
throw internalServerError()
|
|
}
|
|
}
|
|
|
|
const apiJson = await apiResponse.json()
|
|
if (!apiJson.data?.length) {
|
|
throw internalServerError()
|
|
}
|
|
|
|
const verifiedData = getUserSchema.safeParse(apiJson.data[0].attributes)
|
|
if (!verifiedData.success) {
|
|
console.info(`Get User - Verified Data Error`)
|
|
console.error(verifiedData.error)
|
|
throw badRequestError()
|
|
}
|
|
|
|
return {
|
|
...extendedUser,
|
|
...verifiedData.data,
|
|
firstName: verifiedData.data.name,
|
|
name: `${verifiedData.data.name} ${verifiedData.data.lastName}`,
|
|
}
|
|
} catch (error) {
|
|
console.info(`GEt User Error`)
|
|
console.error(error)
|
|
throw internalServerError()
|
|
}
|
|
}),
|
|
benefits: router({
|
|
current: protectedProcedure.query(async function (opts) {
|
|
// TODO: Make request to get user data from Scandic API
|
|
return await fakingRequest<typeof benefits>(benefits)
|
|
}),
|
|
nextLevel: protectedProcedure.query(async function (opts) {
|
|
// TODO: Make request to get user data from Scandic API
|
|
return await fakingRequest<typeof nextLevelPerks>(nextLevelPerks)
|
|
}),
|
|
}),
|
|
|
|
stays: router({
|
|
previous: protectedProcedure
|
|
.input(
|
|
z
|
|
.object({
|
|
perPage: z.number().min(0).default(6),
|
|
page: z.number().min(0).default(0),
|
|
})
|
|
.default({})
|
|
)
|
|
.query(async (opts) => {
|
|
const { perPage, page } = opts.input
|
|
return previousStays.slice(page * perPage, page * perPage + perPage)
|
|
}),
|
|
upcoming: protectedProcedure
|
|
.input(
|
|
z
|
|
.object({
|
|
perPage: z.number().min(0).default(6),
|
|
page: z.number().min(0).default(0),
|
|
})
|
|
.default({})
|
|
)
|
|
.query(async (opts) => {
|
|
const { perPage, page } = opts.input
|
|
return upcomingStays.slice(page * perPage, page * perPage + perPage)
|
|
}),
|
|
}),
|
|
})
|