#include "PluginClientThread.h"

#include <QLoggingCategory>

static Q_LOGGING_CATEGORY(log, "Client.Plugin.Thread")

CPluginClientThread::CPluginClientThread(QObject *parent)
    : CPluginClient(parent),
    m_pThread(nullptr)
{
    m_pThread = new CPluginThread(); // Note that the parent object pointer cannot be set here.
    if(m_pThread)
    {
        // The object is also deleted when the thread finishes executing.
        bool check = connect(m_pThread, SIGNAL(finished()),
                           m_pThread, SLOT(deleteLater()));
        Q_ASSERT(check);
        m_pThread->start();
    }
}

CPluginClientThread::~CPluginClientThread()
{
    qDebug(log) << "CPluginClientThread::~CPluginClientThread";
    if(m_pThread)
        m_pThread->quit(); // The don't deleteLater().
                           // because of it is connected finished signal
}

CConnecter *CPluginClientThread::CreateConnecter(
    const QString &szProtocol, CParameterClient *para)
{
    qDebug(log) << "CPluginClientThread::CreateConnecter()" << szProtocol;
    CConnecter* p = CPluginClient::CreateConnecter(szProtocol, para);
    if(!p) return nullptr;
    CConnecterConnect* pConnecter = qobject_cast<CConnecterConnect*>(p);
    if(!pConnecter) {
        QString szMsg = "Must be derived from CConnecterConnect*, Current is ";
        szMsg += p->metaObject()->className();
        szMsg += ";\nThe super class:\n";
        auto super = p->metaObject()->superClass();
        int n = 1;
        while(super){
            szMsg += QString(2 * n++, ' ') + "- ";
            szMsg += super->className();
            super = super->superClass();
        }
        qCritical(log) << szMsg;
        Q_ASSERT(false);
        return nullptr;
    }
    
    if(nullptr == m_pThread)
    {
        qDebug(log) << "The thread is nullptr";
        return nullptr;
    }

    bool check = connect(pConnecter, SIGNAL(sigOpenConnect(CConnecterConnect*)),
                         m_pThread, SIGNAL(sigConnect(CConnecterConnect*)));
    Q_ASSERT(check);
    check = connect(pConnecter, SIGNAL(sigCloseconnect(CConnecterConnect*)),
                    m_pThread, SIGNAL(sigDisconnect(CConnecterConnect*)));
    Q_ASSERT(check);
    
    return pConnecter;
}