/*!
 *
 * Copyright (c) 2019-2020 Diality Inc. - All Rights Reserved.
 * copyright
 *          THIS CODE MAY NOT BE COPIED OR REPRODUCED IN ANY FORM,
 *          IN PART OR IN WHOLE,
 *          WITHOUT THE EXPLICIT PERMISSION OF THE COPYRIGHT OWNER.
 *
 * file    messageacknowmodel.cpp
 * date    1/17/2020
 * author  Behrouz NematiPour
 *
 */
#include "messageacknowmodel.h"

// Qt
#include <QThread>
#include <QApplication>

// Project
#include "messagedispatcher.h"

// namespace
using namespace Can;

/*!
 * \brief   MessageAcknowModel::MessageAcknowModel
 * \details Constructor
 * \param   parent - QObject parent owner object.
 *          Qt handles the children destruction by their parent objects life-cycle.
 */
MessageAcknowModel::MessageAcknowModel(QObject *parent) : QObject(parent) { }


/*!
 * \brief   MessageAcknowModel::init
 * \details Initializes the class by setting the connections and starting the timer
 * \return  False if it has been called before.
 */
bool MessageAcknowModel::init()
{
    if ( _init ) return false;
    _init = true;

    // runs in MessageAcknowModel thread
    initConnections();

    return true;
}

/*!
 * \brief   MessageAcknowModel::init
 * \details Initialized the Class by calling the init() method first
 *          And initializes the thread vThread by calling initThread
 *          on success init().
 * \param   vThread - the thread
 * \return  returns the return value of the init() method
 */
bool MessageAcknowModel::init(QThread &vThread)
{
    if ( ! init() ) return false;
    initThread(vThread);
    return true;
}

/*!
 * \brief   MessageAcknowModel::quit
 * \details quits the class
 *          Calls quitThread
 */
void MessageAcknowModel::quit()
{
    quitThread();
}

/*!
 * \brief   MessageAcknowModel::initConnections
 * \details Initializes the required signal/slot connection between this class and other objects
 *          to be able to communicate.
 */
void MessageAcknowModel::initConnections()
{
    connect(&_MessageDispatcher, SIGNAL(didAcknowTransmit(Can_Id, Sequence, const FrameList &)),
            this               ,   SLOT( onAcknowTransmit(Can_Id, Sequence, const FrameList &)));
    connect(&_MessageDispatcher, SIGNAL(didAcknowReceive (        Sequence                   )),
            this               ,   SLOT( onAcknowReceive (        Sequence                   )));
}

/*!
 * \brief   ApplicationController::initThread
 * \details Moves this object into the thread vThread.
 *          And checks that this method is called from main thread.
 *          Also connects quitThread to application aboutToQuit.
 * \param   vThread - the thread
 */
void MessageAcknowModel::initThread(QThread &vThread)
{
    // runs in main thread
    Q_ASSERT_X(QThread::currentThread() == qApp->thread() , __func__, "The Class initialization must be done in Main Thread" );
    _thread = &vThread;
    _thread->setObjectName(QString("%1_Thread").arg(metaObject()->className()));
    connect(qApp, SIGNAL(aboutToQuit()), this, SLOT(quit()));
    _thread->start();
    moveToThread(_thread);
}

/*!
 * \brief   MessageAcknowModel::quitThread
 * \details Moves this object to main thread to be handled by QApplicaiton
 *          And to be destroyed there.
 */
void MessageAcknowModel::quitThread()
{
    if ( ! _thread ) return;

    // runs in thread
    moveToThread(qApp->thread());
}

void MessageAcknowModel::onAcknowTransmit(Can_Id vCan_Id, Sequence vSequence, const FrameList &vFrameList)
{
    _acknowList[vSequence] = new Private::AcknowModel(vCan_Id, vSequence, vFrameList);
    connect(_acknowList[vSequence]  , SIGNAL(didFramesTransmit(Can_Id, Sequence, const FrameList &)),
            this                    ,   SLOT( onFramesTransmit(Can_Id, Sequence, const FrameList &)));
    connect(_acknowList[vSequence]  , SIGNAL(didFailedTransmit(        Sequence                   )),
            this                    ,   SLOT( onFailedTransmit(        Sequence                   )));
    _acknowList[vSequence]->start();
}

void MessageAcknowModel::onAcknowReceive(Sequence vSequence)
{
    _acknowList[vSequence]->deleteLater();
    _acknowList.remove(vSequence);
}

void MessageAcknowModel::onFramesTransmit(Can_Id vCan_Id, Sequence vSequence, const FrameList &vFrameList)
{
    emit didFramesTransmit(vCan_Id, vSequence, vFrameList);
}

void MessageAcknowModel::onFailedTransmit(Sequence vSequence)
{
    _acknowList[vSequence]->deleteLater();
    _acknowList.remove(vSequence);
    emit didFailedTransmit(vSequence);
}