#include "runqueue.h"

#include "flib.h"

extern "C" {

extern RunEngine_t* flibRunEngine;

extern ipcToEngineRaw_t* flibIpcToEngineRaw;

extern ipcSetEngineBarrier_t* flibIpcSetEngineBarrier;

extern ipcRemoveBarrierFromEngineQueue_t* flibIpcRemoveBarrierFromEngineQueue;

}

RunQueue::RunQueue(QObject* parent)

    : QObject(parent)

{

}

void RunQueue::queue(const GameConfig& config)

{

    m_runQueue.prepend(config);

    flibIpcSetEngineBarrier();

    for (const QByteArray& b : m_runQueue.last().config()) {

        flibIpcToEngineRaw(b.data(), b.size());

    }

    if (m_runQueue.size() == 1)

        nextRun();

}

void RunQueue::onGameFinished()

{

    m_runQueue.pop_front();

    nextRun();

}

void RunQueue::nextRun()

{

    if (!m_runQueue.isEmpty()) {

        if (m_runQueue[0].isPreview())

            emit previewIsRendering();

        flibIpcRemoveBarrierFromEngineQueue();

        flibRunEngine(m_runQueue[0].argc(), m_runQueue[0].argv());

    }

}