/*
    This file is part of the KDE Baloo Project
    SPDX-FileCopyrightText: 2021 Stefan Brüns <stefan.bruens@rwth-aachen.de>

    SPDX-License-Identifier: LGPL-2.1-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
*/

#include "commandpipe.h"
#include <QVector>
#include "baloodebug.h"
#include <QIODevice>
namespace Baloo {
namespace Private {

enum BatchStatus : quint8 {
    Invalid = 'X',
    UrlStarted = 'S',
    UrlFinished = 'F',
    UrlFailed = 'f',
    BatchFinished = 'B',
};

ControllerPipe::ControllerPipe(QIODevice* commandPipe, QIODevice* statusPipe)
    : m_commandStream(commandPipe)
    , m_statusStream(statusPipe)
{
}

void ControllerPipe::processIds(const QVector<quint64>& ids)
{
    m_commandStream << ids;
}

void ControllerPipe::processStatusData()
{
    QString url;
    BatchStatus event{Invalid};

    while (true) {
        m_statusStream.startTransaction();
        m_statusStream >> event;

        if ((m_statusStream.status() != QDataStream::Ok) && m_statusStream.device()->atEnd()) {
	    m_statusStream.rollbackTransaction();
            break;
        }

        if (event == BatchFinished) {
            if (m_statusStream.commitTransaction()) {
                Q_EMIT batchFinished();
                continue;
            } else {
                break;
            }
        }

        m_statusStream >> url;
        if (!m_statusStream.commitTransaction()) {
            break;
        }

        switch (event) {
        case UrlStarted:
            Q_EMIT urlStarted(url);
            break;

        case UrlFinished:
            Q_EMIT urlFinished(url);
            break;

        case UrlFailed:
            Q_EMIT urlFailed(url);
            break;

        default:
            qCCritical(BALOO) << "Got unknown result from extractor" << event << url;
        }
    }
}

WorkerPipe::WorkerPipe(QIODevice* commandPipe, QIODevice* statusPipe)
    : m_commandStream(commandPipe)
    , m_statusStream(statusPipe)
{
}

void WorkerPipe::processIdData()
{
    QVector<quint64> ids;

    while (true) {
        m_commandStream.startTransaction();
        m_commandStream >> ids;

        /* QIODevice::atEnd() has to be checked *after* reading from
         * the QDataStream, but *before* commitTransaction to get
         * the correct pipe status.
         * QDataStream::status() will be `ReadPastEnd` for both partial
         * reads as well as closed pipes
         */
        if ((m_commandStream.status() != QDataStream::Ok) && m_commandStream.device()->atEnd()) {
            m_commandStream.rollbackTransaction();
            Q_EMIT inputEnd();
            return;
        }

        if (!m_commandStream.commitTransaction()) {
            return;
        }

        Q_EMIT newDocumentIds(ids);
        if (m_commandStream.device()->atEnd()) {
            return;
        }
    }
}

void WorkerPipe::urlStarted(const QString& url)
{
    m_statusStream << UrlStarted << url;
}

void WorkerPipe::urlFinished(const QString& url)
{
    m_statusStream << UrlFinished << url;
}

void WorkerPipe::urlFailed(const QString& url)
{
    m_statusStream << UrlFailed << url;
}

void WorkerPipe::batchFinished()
{
    m_statusStream << BatchFinished;
}

} // namespace Private
} // namespace Baloo

#include "moc_commandpipe.cpp"