const Transactions = require('../../models/transaction.js');
const config       = require('../../config');
const logger       = require('../logger');


const MAX_PAGE_TXS = config.api.max_page_txs;

function getEmptyInputs(cb) {
  return Transactions.getEmptyInputs(cb);
}

function getTopTransactions(cb) {
  return Transactions.last(cb);
}

function getTxById(txid, cb) {
  return Transactions.byId(txid, cb);
}

function getTxByBlock(blockHash, page, limit, cb) {
  return Transactions.byBlockHash(blockHash, cb)
    .skip(limit * page);
}

function getTxByAddress(address, page, limit, cb) {
  return Transactions.byAddress(address, cb)
    .limit(limit)
    .skip(limit * page);
}

function getTxCountByBlock(blockHash, cb) {
  return Transactions.countByBlock(blockHash, cb);
}

function getTxCountByAddress(address, cb) {
  return Transactions.countByAddress(address, cb);
}

function updateInput(txid, inputid, value, address) {
  return Transactions.updateInput(txid, inputid, value, address);
}

// Updates empty inputs with prevout addr & value
function auditInputs() {
  getEmptyInputs(
    (err, txs) => {
      if (err) {
        return logger.log('warn',
          `No Empty Inputs found: ${err.err}`);
      }
      // For each tx with unmarked inputs
      return txs.forEach((inputTx) => {
        inputTx.inputs.forEach((input) => {
          const txHash = input.prevout.hash;
          const outIdx = input.prevout.index;

          return getTxById(txHash, (error, tx) => {
            if (error || !tx) {
              // Mongo save is async. Bcoin is kinda sync... Does not mean the tx will not be found
              return logger.log('warn',
                `No Tx found: ${txHash} ${error}`);
            }
            return updateInput(inputTx._id, input._id, tx.outputs[outIdx].value, tx.outputs[outIdx].address);
          });
        });
      });
    });
}

module.exports = {
  auditInputs,
  getEmptyInputs,
  getTopTransactions,
  getTxById,
  getTxByBlock,
  getTxCountByBlock,
  getTxByAddress,
  getTxCountByAddress,
  updateInput,
};