logos-blockchain-ui/src/BlockchainBackend.cpp

#include "BlockchainBackend.h"
#include <QByteArray>
#include <QDebug>
#include <QDateTime>
#include <QSettings>
#include <QTimer>
#include <QUrl>

namespace {
    const char kSettingsOrg[] = "Logos";
    const char kSettingsApp[] = "BlockchainUI";
    const char kConfigPathKey[] = "configPath";
}

BlockchainBackend::BlockchainBackend(LogosAPI* logosAPI, QObject* parent)
    : QObject(parent),
      m_status(NotStarted),
      m_configPath(""),
      m_logModel(new LogModel(this)),
      m_logos(nullptr),
      m_blockchainModule(nullptr)
{
    QSettings s(kSettingsOrg, kSettingsApp);
    QString saved = s.value(kConfigPathKey).toString();
    if (!saved.isEmpty()) {
        m_configPath = saved;
    } else {
        m_configPath = QString::fromUtf8(qgetenv("LB_CONFIG_PATH"));
    }

    if (!logosAPI) {
        logosAPI = new LogosAPI("core", this);
    }

    m_logos = new LogosModules(logosAPI);

    if (!m_logos) {
        setStatus(ErrorNotInitialized);
        return;
    }

    m_blockchainModule = &m_logos->liblogos_blockchain_module;

    if (m_blockchainModule && !m_blockchainModule->on("newBlock", [this](const QVariantList& data) {
        onNewBlock(data);
    })) {
        setStatus(ErrorSubscribeFailed);
    }
}

BlockchainBackend::~BlockchainBackend()
{
    stopBlockchain();
}

void BlockchainBackend::setStatus(BlockchainStatus newStatus)
{
    if (m_status != newStatus) {
        m_status = newStatus;
        emit statusChanged();
    }
}

void BlockchainBackend::setConfigPath(const QString& path)
{
    const QString localPath = QUrl::fromUserInput(path).toLocalFile();
    if (m_configPath != localPath) {
        m_configPath = localPath;
        QSettings s(kSettingsOrg, kSettingsApp);
        s.setValue(kConfigPathKey, m_configPath);
        emit configPathChanged();
    }
}

void BlockchainBackend::clearLogs()
{
    m_logModel->clear();
}

QString BlockchainBackend::getBalance(const QString& addressHex)
{
    if (!m_blockchainModule) {
        return QStringLiteral("Error: Module not initialized.");
    }
    return m_blockchainModule->wallet_get_balance(addressHex);
}

QString BlockchainBackend::transferFunds(const QString& fromKeyHex, const QString& toKeyHex, const QString& amountStr)
{
    if (!m_blockchainModule) {
        return QStringLiteral("Error: Module not initialized.");
    }
    QStringList senderAddresses;
    senderAddresses << fromKeyHex;
    return m_blockchainModule->wallet_transfer_funds(fromKeyHex, senderAddresses, toKeyHex, amountStr, "");
}

void BlockchainBackend::startBlockchain()
{
    if (!m_blockchainModule) {
        setStatus(ErrorNotInitialized);
        return;
    }

    setStatus(Starting);

    int result = m_blockchainModule->start(m_configPath, QString());

    if (result == 0 || result == 1) {
        setStatus(Running);
        QTimer::singleShot(500, this, [this]() { refreshKnownAddresses(); });
    } else if (result == 2) {
        setStatus(ErrorConfigMissing);
    } else if (result == 3) {
        setStatus(ErrorStartFailed);
    } else {
        setStatus(ErrorStartFailed);
    }
}

void BlockchainBackend::refreshKnownAddresses()
{
    if (!m_blockchainModule) return;
    QStringList list = m_blockchainModule->wallet_get_known_addresses();
    qDebug() << "BlockchainBackend: received from blockchain lib: type=QStringList, count=" << list.size();
    if (m_knownAddresses != list) {
        m_knownAddresses = std::move(list);
        emit knownAddressesChanged();
    }
}

void BlockchainBackend::stopBlockchain()
{
    if (m_status != Running && m_status != Starting) {
        return;
    }

    if (!m_blockchainModule) {
        setStatus(ErrorNotInitialized);
        return;
    }

    setStatus(Stopping);

    int result = m_blockchainModule->stop();

    if (result == 0 || result == 1) {
        setStatus(Stopped);
    } else {
        setStatus(ErrorStopFailed);
    }
}

void BlockchainBackend::onNewBlock(const QVariantList& data)
{
    QString timestamp = QDateTime::currentDateTime().toString("HH:mm:ss");
    QString line;
    if (!data.isEmpty()) {
        QString blockInfo = data.first().toString();
        QString shortInfo = blockInfo.left(80);
        if (blockInfo.length() > 80) {
            shortInfo += "...";
        }
        line = QString("[%1] 📦 New block: %2").arg(timestamp, shortInfo);
    } else {
        line = QString("[%1] 📦 New block (no data)").arg(timestamp);
    }
    m_logModel->append(line);
}