VFS.cpp

Go to the documentation of this file.

 
#include <iostream>
#include <math.h>
 
#include <QMutexLocker>
#include <QFileInfo>
#include <QCoreApplication>
 
#include "defines.h"
#include "VFS.h"
#include "VFS_creator.h"
#include "VFS_base/VFS_thread.h"
#include "VFS_base/VFS_icons.h"
 
#include "VFS_filetypes/VFS_stream.h"
#include "VFS/VFS_base/VFS_thread.h"
 
VFS *VFS::_vfs(nullptr);
QJsonObject VFS::_parameters;
QMap<QString,QDateTime> VFS::_monitoredFiles;
 
VFS::VFS(QString configFile, QStringList plugins, bool describe, bool printConfig)
: VFS_node()
, _start(QDateTime::currentMSecsSinceEpoch())
, cp_init(CYAN, BOLD)
, cp_bold(UNDEF, BOLD)
, cp_warn(YELLOW, BOLD)
, cp_error(RED, BOLD)
, _logLevel(9)
, _logTime(0)
, _logger(nullptr)
{
        if (_vfs)
                throw "Only one instance of the VFS is allowed.";
 
        //set the static global instance object
        _vfs = this;
 
        if (configFile.isEmpty())
        {       VFS::ERROR("No config file specified.");
                return;
        }
 
        VFS::LOG("Initializing VFS on thread #0 'VFS'", 0);
 
        //name the main thread
        thread()->setObjectName("VFS");
 
        //load all plugins
        VFS_creator::init(plugins,describe);
 
        if (describe)
                return;
 
        VFS::LOG( QString("Plugins loaded."), 0);
        //VFS::LOG(         "----------------------------------" );
 
 
        //create the logger and wait for the thread to fully start
        VFS_creator::_outstanding.acquire();
        _logger = VFS_thread::fromConfig( QString("<logger name='logs' logLevel='%1' logTime='%2' adminAddress='%3' />").arg(_logLevel).arg(_logTime).arg("") );
        append("logs", _logger);
        VFS_creator::_outstanding.acquire(VFS_CREATOR_MAX_OUTSTANDING-1);
        qApp->processEvents();
        VFS_creator::_outstanding.release(VFS_CREATOR_MAX_OUTSTANDING);
 
        //now we're synchronized
        VFS::LOG(         "----------------------------------" );
        VFS::LOG( QString("VFS %1").arg(VFS_GIT_VERSION),0);
        VFS::LOG( QString("Logger started: %1 %2").arg(QDateTime::currentDateTime().toString()).arg(QDateTime::currentDateTime().toString("t")), 0);
        VFS::LOG(         "----------------------------------" );
 
        VFS_creator::build(configFile,this,printConfig);
 
 
        if (_monitoredFiles.size())
        {
                LOG(         "----------------------------------" );
                LOG( QString("VFS monitoring %1 config file%2 for changes:").arg(_monitoredFiles.size()).arg(_monitoredFiles.size() > 1 ? "s" : ""), 0);
                QMap<QString, QDateTime>::iterator i;
                for (i = _monitoredFiles.begin(); i != _monitoredFiles.end(); ++i)
                        LOG(" - "+i.key());
                LOG(         "----------------------------------" );
 
                _monitorTimerID = startTimer(1*1000*30);        //start the monitor timer, every 30 seconds.
        }
 
        LOG( QString("VFS initialized with %1 thread%2.").arg(VFS_thread::threadcount()).arg(VFS_thread::threadcount() > 1 ? "s" : ""), 0);
        LOG(         "----------------------------------" );
 
 
        emit initialized();
}
 
VFS::~VFS()
{
        //remove this referene so messages fall back to [ INIT ] state while the VFS is being destroyed
        this->_logger = nullptr;
 
        WARN("Exiting VFS...");
 
        //remove static instance
        //_vfs = nullptr;               //leave for now so we get messages.  The global _vfs will now be invalid.
}
 
void VFS::setAdminEmail(QString emails)
{
        QJsonObject o;
        o["adminemail"] = emails;
 
        VFS_request *r = createRequest(VFS_request::submit,"logs/settings","server",QJsonDocument(o));
        issueRequest(r);
}
 
void VFS::setLogSettings(int loglevel, int logtime)
{
        _logLevel = loglevel;
        _logTime = logtime;
 
        QJsonObject o;
        o["loglevel"] = loglevel;
        o["logtime"] = logtime;
 
        VFS_request *r = createRequest(VFS_request::submit,"logs/settings","server",QJsonDocument(o));
        issueRequest(r);
}
 
void VFS::getLogSettings(int &loglevel, int &logtime)
{
        loglevel = _logLevel;
        logtime = _logTime;
}
 
QByteArray VFS::icon()
{
        return VFS_icons::get("application");
}
 
void VFS::LOG(QString message, int level, QString user)
{
        level = qBound(0,level,9);
 
        //if (level > _vfs->_logLevel)
        //      return;
 
        QDateTime now = QDateTime::currentDateTime();
 
        //QString s = QString("%1,LOG,%2,%3,%4%5").arg(now.toMSecsSinceEpoch()).arg(user).arg(level).arg(message).arg(message.right(1)=="\n" ? "" : "\n");
 
        //use https://stackoverflow.com/questions/57452407/qstring-arg-issue-when-arg-contains-a-character-how-to-prevent-recursive/57452837#57452837
        QString s = QString("%1,LOG,%2,%3,%4%5").arg(QString::number(now.toMSecsSinceEpoch()),user,QString::number(level),message,message.right(1)=="\n" ? "" : "\n");
 
        if (!_vfs)
        {       printf("%s",qUtf8Printable(s));
                return;
        }
 
        if (_vfs->_logger && _vfs->_logger->hasNode())
        {
                QJsonObject o;
                o["data"] = s;
                QJsonDocument d(o);
 
                _vfs->issueRequest( _vfs->createRequest(VFS_request::submit,"logs/messages",user,d) );
        }
        else
        {
                if (level > _vfs->_logLevel)
                        return;
 
                QMutexLocker l(&_vfs->_printLock);      //prevent interleaved messages
                _vfs->cp_init.cprintf("[ INIT %d ] %s ",level,qUtf8Printable(user));
                printf("%s%s",qUtf8Printable(message), (message.right(1)=="\n" ? "" : "\n"));
        }
}
 
void VFS::WARN(QString message, int level, QString user)
{
        level = qBound(0,level,9);
 
        //if (level > _vfs->_logLevel)
        //      return;
 
        QDateTime now = QDateTime::currentDateTime();
 
        //QString s = QString("%1,WARN,%2,%3,%4%5").arg(now.toMSecsSinceEpoch()).arg(user).arg(level).arg(message).arg(message.right(1)=="\n" ? "" : "\n");
 
        //use https://stackoverflow.com/questions/57452407/qstring-arg-issue-when-arg-contains-a-character-how-to-prevent-recursive/57452837#57452837
        QString s = QString("%1,WARN,%2,%3,%4%5").arg(QString::number(now.toMSecsSinceEpoch()),user,QString::number(level),message,message.right(1)=="\n" ? "" : "\n");
 
        if (!_vfs)
        {       printf("%s",qUtf8Printable(s));
                return;
        }
 
        if (_vfs->_logger && _vfs->_logger->hasNode())
        {
                QJsonObject o;
                o["data"] = s;
                QJsonDocument d(o);
 
                _vfs->issueRequest( _vfs->createRequest(VFS_request::submit,"logs/warnings",user,d) );
        }
        else
        {
                if (level > _vfs->_logLevel)
                        return;
 
                QMutexLocker l(&_vfs->_printLock);      //prevent interleaved messages
                _vfs->cp_warn.cprintf("[ WARN %d ] %s %s",level,qUtf8Printable(user),qUtf8Printable(message));
                printf("%s",(message.right(1)=="\n" ? "" : "\n"));
        }
}
 
void VFS::ERROR(QString message, int level, QString user)
{
        level = qBound(0,level,9);
 
        //if (level > _vfs->_logLevel)
        //      return;
 
        QDateTime now = QDateTime::currentDateTime();
 
        //QString s = QString("%1,ERROR,%2,%3,%4%5").arg(now.toMSecsSinceEpoch()).arg(user).arg(level).arg(message).arg(message.right(1)=="\n" ? "" : "\n");
 
        //use https://stackoverflow.com/questions/57452407/qstring-arg-issue-when-arg-contains-a-character-how-to-prevent-recursive/57452837#57452837
        QString s = QString("%1,ERROR,%2,%3,%4%5").arg(QString::number(now.toMSecsSinceEpoch()),user,QString::number(level),message,message.right(1)=="\n" ? "" : "\n");
 
        if (!_vfs)
        {       printf("%s",qUtf8Printable(s));
                return;
        }
 
        if (_vfs->_logger && _vfs->_logger->hasNode())
        {
                QJsonObject o;
                o["data"] = s;
                QJsonDocument d(o);
 
                _vfs->issueRequest( _vfs->createRequest(VFS_request::submit,"logs/errors",user,d) );
        }
        else
        {
                if (level > _vfs->_logLevel)
                        return;
 
                QMutexLocker l(&_vfs->_printLock);      //prevent interleaved messages
                _vfs->cp_error.cprintferr("[ ERROR %d ] %s %s",level,qUtf8Printable(user),qUtf8Printable(message));
                printf("%s",(message.right(1)=="\n" ? "" : "\n"));
        }
}
 
void VFS::CRITICAL(QString message)
{
        int level = 0;
 
        QDateTime now = QDateTime::currentDateTime();
 
        //QString s = QString("%1,CRITICAL,%2,%3,%4%5").arg(now.toMSecsSinceEpoch()).arg("CRITICAL").arg(level).arg(message).arg(message.right(1)=="\n" ? "" : "\n");
 
        //use https://stackoverflow.com/questions/57452407/qstring-arg-issue-when-arg-contains-a-character-how-to-prevent-recursive/57452837#57452837
        QString s = QString("%1,CRITICAL,%2,%3,%4%5").arg(QString::number(now.toMSecsSinceEpoch()),"CRITICAL",QString::number(level),message,message.right(1)=="\n" ? "" : "\n");
 
        if (!_vfs)
        {       printf("%s\n",qUtf8Printable(s));
                return;
        }
 
        if (_vfs->_logger && _vfs->_logger->hasNode())
        {
                QJsonObject o;
                o["data"] = s;
                QJsonDocument d(o);
 
                _vfs->issueRequest( _vfs->createRequest(VFS_request::submit,"logs/critical","CRITICAL",d) );
        }
        else
        {
                QMutexLocker l(&_vfs->_printLock);      //prevent interleaved messages
                _vfs->cp_error.cprintferr("[ CRITICAL ] %s",qUtf8Printable(message));
                printf("%s",(message.right(1)=="\n" ? "" : "\n"));
 
                //email(_adminAddress,APPLICATION_NAME" CRITICAL",message);
                //std::cerr << cp_error.cp_s_init() << "             notification email sent to: " << qUtf8Printable(_adminAddress) << std::endl << cp_error.cp_s_rst();
        }
}
 
VFS * VFS::root()
{
        return _vfs;
}
 
 
QJsonDocument VFS::parameters()
{
        return QJsonDocument( _parameters );
}
 
qint64 VFS::starttime()
{
        return _vfs->_start;
}
 
qint64 VFS::uptime()
{
        return (QDateTime::currentMSecsSinceEpoch() - _vfs->_start);
}
 
QString VFS::uptimeString(bool ms)
{
        qint64 u = VFS::uptime();
        if (ms)
                return QString("%1:%2:%3:%4.%5")
                        .arg(u / (1000*60*60*24))
                        .arg((int)floor((u % (1000*60*60*24))/(1000*60*60)),2,(int)10,QChar('0'))
                        .arg((int)floor((u % (1000*60*60))/(1000*60)),2,(int)10,QChar('0'))
                        .arg((int)floor((u % (1000*60))/(1000)),2,(int)10,QChar('0'))
                        .arg((int)(u % 1000),3,(int)10,QChar('0'));
        else
                return QString("%1:%2:%3:%4")
                        .arg(u / (1000*60*60*24))
                        .arg((int)floor((u % (1000*60*60*24))/(1000*60*60)),2,(int)10,QChar('0'))
                        .arg((int)floor((u % (1000*60*60))/(1000*60)),2,(int)10,QChar('0'))
                        .arg((int)floor((u % (1000*60))/(1000)),2,(int)10,QChar('0'));
}
 
void VFS::timerEvent(QTimerEvent *event)
{
        if (event->timerId() == _monitorTimerID)
                monitoredFilesCheck();
}
 
 
void VFS::monitoredFilesCheck()
{
        QDateTime t;
        QFileInfo f;
        QMap<QString, QDateTime>::iterator i;
        for (i = _monitoredFiles.begin(); i != _monitoredFiles.end(); ++i)
        {
                LOG( QString("Checking modification time on '%1'...").arg(i.key()), 9 );
 
                t = i.value();
                f.setFile( i.key() );
 
                if ( !f.exists() )
                        WARN( QString("Monitored file '%1' doesn't exist.").arg(i.key()), 8 );
                else
                {       if ( f.lastModified() > t )
                        {
                                QMutexLocker l(&_printLock);    //prevent interleaved messages
 
                                QString message = QString("Monitored file '%1' has changed!").arg(i.key());
                                //WARN( message );
                                cp_warn.cprintf("[ WARN %d ] %s %s\n",0,"server",qUtf8Printable(message));      //do it manually so that it is the first message
 
                                QCoreApplication::exit(0);
                        }
                }
        }
}