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)
      }),
  }),
})