powerup.js

require('dotenv').config();

const fs = require('fs');
const path = require('path');
const { Client, PrivateKey } = require('@hiveio/dhive');

const username = process.env.HIVE_USERNAME;
const activeKey = process.env.HIVE_ACTIVE_KEY;
const amount = process.env.HIVE_AMOUNT || '1.000';

// Conexão com a Hive
const client = new Client([
  'https://api.hive.blog',
  'https://api.deathwing.me',
  'https://hive-api.arcange.eu',
]);

const now = new Date();
const utcDateStr = now.toISOString().split('T')[0]; // YYYY-MM-DD

// Logger
function log(msg) {
  const now = new Date();
  const timestamp = now.toISOString();
  const dia = String(now.getUTCDate()).padStart(2, '0');
  const mes = String(now.getUTCMonth() + 1).padStart(2, '0');
  const ano = String(now.getUTCFullYear());

  const logDir = path.join(__dirname, 'log');
  if (!fs.existsSync(logDir)) fs.mkdirSync(logDir);

  const logFile = path.join(logDir, `powerup_log_${dia}${mes}${ano}.txt`);
  const fullMsg = `[${timestamp}] ${msg}\n`;
  fs.appendFileSync(logFile, fullMsg);
  console.log(fullMsg.trim());
}

// Validação
log(`Validating configuration parameters...`);

if (!username || username.trim() === '' || username === 'your_hive_user') {
  log('HIVE_USERNAME field is empty or not set in .env file! Cannot continue!');
  process.exit(1);
}

if (!activeKey || activeKey.trim() === '' || activeKey === 'your_private_key') {
  log('HIVE_ACTIVE_KEY field is empty or not set in .env file! Cannot continue!');
  process.exit(1);
}

if (!amount || isNaN(parseFloat(amount)) || parseFloat(amount) <= 0) {
  log('Invalid HIVE_AMOUNT field in .env file! Cannot continue!');
  process.exit(1);
}

log(`Checking Account Power Up Operations for ${username}...`);

// Buscar até 10.000 entradas de histórico, em blocos de 1000
async function buscarPowerUpsDoDia(usuario, dataUTC) {
  let start = -1;
  const limiteMax = 10000;
  let totalOps = [];
  let done = false;

  while (!done && totalOps.length < limiteMax) {
    const batchSize = 1000;
    const history = await client.database.call('get_account_history', [usuario, start, batchSize]);

    if (!history || history.length === 0) break;

    let foundPowerUpToday = false;
    let stopBecauseOlder = false;
    
    for (const [index, entry] of [...history].reverse()) {
      const [opType, opData] = entry.op;
      const timestamp = entry.timestamp.split('T')[0]; // YYYY-MM-DD

      start = index - 1;

      if (opType === 'transfer_to_vesting' && timestamp === dataUTC && opData.from === usuario) {
        totalOps.push(entry);
        foundPowerUpToday = true;
        break;
      }

      if (timestamp < dataUTC) {
        stopBecauseOlder = true;
        break;
      }
    }

    if (foundPowerUpToday) {
      done = true;
    } else if (stopBecauseOlder) {
      done = true;
    }

    if (history.length < batchSize) break;
  }

  return totalOps;

}

// Main Function
(async () => {
  try {
    const powerUpsHoje = await buscarPowerUpsDoDia(username, utcDateStr);

    if (powerUpsHoje.length > 0) {
      log(`There is already Power Up today (${utcDateStr} UTC). No action will be taken.`);
      process.exit(0);
    }

    log(`No Power Up found today. Performing ${amount} HIVE Power Up.`);

    const key = PrivateKey.fromString(activeKey);

    const op = [
      'transfer_to_vesting',
      {
        from: username,
        to: username,
        amount: `${parseFloat(amount).toFixed(3)} HIVE`,
      },
    ];

    await client.broadcast.sendOperations([op], key);
    log('Power Up successfully completed!');
  } catch (err) {
    log('Error fetching history or executing operation: ' + (err.message || String(err)));
    process.exit(1);
  }
})();