const reverse = require("buffer-reverse");

module.exports = async (req, res) => {
  let { user } = req;
  let {
    address,
    tx: { hex }
  } = req.body;

  const isChange = async address =>
    (await lq.getAddressInfo(address)).ismine &&
    (!Object.keys(addresses).includes(address) || address === user.liquid);

  const unblinded = await lq.unblindRawTransaction(hex);
  tx = await lq.decodeRawTransaction(unblinded.hex);

  let totals = {};
  let change = {};
  let fee = 0;

  for (let i = 0; i < tx.vout.length; i++) {
    let {
      asset,
      value,
      scriptPubKey: { type, addresses }
    } = tx.vout[i];

    if (type === "fee") fee = toSats(value);
    else {
      if (!totals[asset]) totals[asset] = change[asset] = 0;
      totals[asset] += toSats(value);

      if (addresses) {
        if (await isChange(addresses[0])) {
          change[asset] += toSats(value);
        }
      }
    }
  }

  const assets = Object.keys(totals);
  const payments = [];

  try {
    await db.transaction(async transaction => {
      for (let i = 0; i < assets.length; i++) {
        let asset = assets[i];
        let total = totals[asset];
        if (change[asset]) total -= change[asset];
        if (asset === config.liquid.btcasset) total += fee;

        l.info("creating liquid payment", user.username, asset, total, fee);

        let account = await db.Account.findOne({
          where: {
            user_id: user.id,
            asset
          },
          lock: transaction.LOCK.UPDATE,
          transaction
        });

        if (total > account.balance) {
          l.warn("amount exceeds balance", {
            total,
            fee,
            balance: account.balance
          });
          throw new Error("Insufficient funds");
        }

        account.balance -= total;
        await account.save({ transaction });

        let payment = {
          amount: -total,
          account_id: account.id,
          fee,
          user_id: user.id,
          rate: app.get("rates")[user.currency],
          currency: user.currency,
          address,
          confirmed: true,
          received: false,
          network: "LBTC"
        };

        payment.account = account;
        payments.push(payment);
      }
    });
  } catch (e) {
    l.error("problem creating liquid payment", user.username, e.message);
    return res.status(500).send(e.message);
  }

  try {
    if (config.liquid.walletpass)
      await lq.walletPassphrase(config.liquid.walletpass, 300);

    hex = await lq.blindRawTransaction(hex);
    rawtx = (await lq.signRawTransactionWithWallet(hex)).hex;
    let txid = await lq.sendRawTransaction(rawtx);

    let main;
    for (let i = 0; i < assets.length; i++) {
      p = payments[i];
      let { account } = p;
      p.hash = txid;
      p = await db.Payment.create(p);
      if (account.ticker !== "BTC" || !main) {
        main = p.get({ plain: true });
        main.account = account.get({ plain: true });
      }
    }

    user = await getUser(user.username);
    emit(user.username, "user", user);
    res.send(main);
  } catch (e) {
    l.error("problem sending liquid", user.username, e.message);
    return res.status(500).send(e.message);
  }
};