import { IncomingMessage, ServerResponse } from 'http'
import { schedule } from '../../../common/scheduler'
import { asyncLocalStorage as l } from '../../../common/logger'
import { Router } from './index'
import { Reservation } from '../../../common/reservation'
import { parse } from 'querystring'
import dayjs from '../../../common/dayjs'
import { Dayjs } from 'dayjs'

export class ReservationsRouter extends Router {
  public async handleRequest(
    req: IncomingMessage,
    res: ServerResponse<IncomingMessage>
  ) {
    const { url = '', method } = req
    const [route] = url.split('?')
    switch (true) {
      case /^\/reservations$/.test(route) && method === 'GET': {
        await this.GET_reservations(req, res)
        break
      }
      case /^\/reservations$/.test(route) && method === 'POST': {
        await this.POST_reservations(req, res)
        break
      }
      case /^\/reservations\/\S+$/.test(route) && method === 'DELETE': {
        await this.DELETE_reservation(req, res)
        break
      }
      default: {
        this.handle404(req, res)
      }
    }
  }

  private async GET_reservations(
    req: IncomingMessage,
    res: ServerResponse<IncomingMessage>
  ) {
    const { url = '' } = req
    const [, queryParams] = url.split('?')
    let pageNumber = 0
    let pageSize = 0
    let date: Dayjs | undefined = undefined
    const {
      pageNumber: rawPageNumber = '0',
      pageSize: rawPageSize = '50',
      date: rawDate,
    } = parse(queryParams)
    if (typeof rawPageNumber === 'string') {
      pageNumber = Number.parseInt(rawPageNumber)
    } else {
      pageNumber = 0
    }

    if (typeof rawPageSize === 'string') {
      pageSize = Math.min(Number.parseInt(rawPageSize), 50)
    } else {
      pageSize = 50
    }

    if (typeof rawDate === 'string') {
      date = dayjs(rawDate)
    }

    l.getStore()?.debug('Fetching reservations', { pageNumber, pageSize, date: date?.format() })

    try {
      let reservations: Reservation[]
      if (date) {
        reservations = await Reservation.fetchByDate(date, 50)
      } else {
        reservations = await Reservation.fetchByPage(pageNumber, pageSize)
      }
      res.setHeader('content-type', 'application/json')
      l.getStore()?.debug('Found reservations', {
        reservations: reservations.map((r) => r.toString(true)),
      })
      return new Promise<void>((resolve, reject) => {
        res.write(
          `[${reservations.map((r) => r.toString(true)).join(',')}]`,
          (err) => {
            if (err) {
              reject(err)
            }
            resolve()
          }
        )
      })
    } catch (error) {
      l.getStore()?.error('Failed to get reservations', {
        message: (error as Error).message,
        stack: (error as Error).stack,
      })
      res.writeHead(500)
    }
  }

  private async POST_reservations(
    req: IncomingMessage,
    res: ServerResponse<IncomingMessage>
  ) {
    const jsonBody = await this.parseJsonContent(req)
    try {
      await schedule(jsonBody)
    } catch (error: unknown) {
      l.getStore()?.error('Failed to create reservation', {
        message: (error as Error).message,
        stack: (error as Error).stack,
      })
      res.writeHead(400)
    }
  }

  private async DELETE_reservation(
    req: IncomingMessage,
    res: ServerResponse<IncomingMessage>
  ) {
    const { url = '' } = req
    const [, , id] = url.split('/')
    l.getStore()?.debug('Deleting reservation', { id })
    try {
      await Reservation.deleteById(id)
      res.writeHead(200)
    } catch (error) {
      l.getStore()?.error('Failed to get reservations', {
        message: (error as Error).message,
        stack: (error as Error).stack,
      })
      res.writeHead(500)
    }
  }
}