import { Record } from './../models/records'

export const get = async (request, reply) => {
  try {
    const { size = 0, page = 1 } = request.query
    const limit: number = parseInt(size as string, 10)
    const offset: number = (parseInt(page as string, 10) - 1) * limit

    let queryOptions = {
      order: [['created', 'DESC']] as [string, string][],
    }

    if (limit > 0) {
      queryOptions = {
        ...queryOptions,
        limit: limit,
        offset: offset,
      } as { order: [string, string][]; limit: number; offset: number }
    }
    const { count, rows: data } = await Record.findAndCountAll(queryOptions)

    return reply.send({
      total: count,
      page: parseInt(page as string, 10),
      size: limit,
      data,
    })
  } catch (error: any) {
    return reply.code(400).send({
      statusCode: 400,
      message: error.message,
    })
  }
}

export const update = async (request, reply) => {
  try {
    const params = request?.body
    const options = {
      id: params.id,
      type: params.type,
      alias: params.alias,
      amount: params.amount,
      currency: params.currency,
      note: params.note,
      datetime: params.datetime,
      created: new Date(),
      risk: params.risk,
      liquidity: params.liquidity,
      tags: params.tags,
    }
    const data = await Record.update(options, {
      where: { id: params.id },
    })
    return reply.send(data)
  } catch (error: any) {
    return reply.code(400).send({
      statusCode: 400,
      message: error.message,
    })
  }
}

export const destroy = async (request, reply) => {
  try {
    const { id = '' } = request?.body
    const data = await Record.destroy({
      where: { id },
    })
    return reply.send(data)
  } catch (error: any) {
    return reply.code(400).send({
      statusCode: 400,
      message: error.message,
    })
  }
}