import app from "$app";
import db from "$db";
import { auth } from "$lib/passport";
import { emit } from "$lib/sockets";
import { Op } from "@sequelize/core";

app.get("/request/:id", auth, async (req, res) => {
  try {
    let request = await db.Request.findOne({
      where: { id: req.params.id },
      include: [
        {
          attributes: ["username", "profile"],
          model: db.User,
          as: "recipient"
        },
        {
          attributes: ["username", "profile"],
          model: db.User,
          as: "requester"
        },
        {
          model: db.Invoice,
          as: "invoice"
        }
      ]
    });

    res.send({ request });
  } catch (e) {
    console.log(e);
    res.code(500).send(e.message);
  }
});

app.get("/requests", auth, async (req, res) => {
  try {
    const day = new Date(new Date().setDate(new Date().getDate() - 1));

    let invoices = (
      await db.Request.findAll({
        where: {
          requester_id: req.user.id,
          createdAt: { [Op.gt]: day }
          //"$invoice.received$": { [Op.lt]: "$invoice.amount$" }
        },
        order: [["createdAt", "DESC"]],
        include: {
          model: db.Invoice,
          as: "invoice",
          include: {
            model: db.User,
            as: "user"
          }
        }
      })
    )
      .map(r => r.invoice && r.invoice.get({ plain: true }))
      .filter(Boolean);

    let requests = await db.Request.findAll({
      where: { recipient_id: req.user.id, createdAt: { [Op.gt]: day }, invoice_id: { [Op.eq]: null } },
      order: [["createdAt", "DESC"]],
      include: {
        attributes: ["username", "profile"],
        model: db.User,
        as: "requester"
      }
    });

    res.send({ invoices, requests });
  } catch (e) {
    console.log(e);
    res.code(500).send(e.message);
  }
});

app.post("/requests", auth, async (req, res) => {
  try {
    let { recipient: username, ...params } = req.body;
    let { id: recipient_id } = await db.User.findOne({ where: { username } });

    let request = await db.Request.create({ recipient_id, ...params });
    request = request.get({ plain: true });
    request.requester = {
      username: req.user.username,
      profile: req.user.profile
    };
    emit(username, "request", request);

    res.send(request);
  } catch (e) {
    console.log(e);
    res.code(500).send(e.message);
  }
});