commandpipe.h

/*
    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
*/
 
#ifndef COMMANDPIPE_H
#define COMMANDPIPE_H
 
#include <QDataStream>
#include <QObject>
 
class QIODevice;
 
namespace Baloo {
namespace Private {
 
/**
 * Bidirectional communication pipe
 *
 */
class ControllerPipe : public QObject
{
    Q_OBJECT
 
public:
    ControllerPipe(QIODevice* commandPipe, QIODevice* statusPipe);
 
    void processIds(const QVector<quint64>& ids);
 
Q_SIGNALS:
    void urlStarted(const QString& url);
    void urlFinished(const QString& url);
    void urlFailed(const QString& url);
    void batchFinished();
 
public Q_SLOTS:
    void processStatusData();
 
private:
    QDataStream m_commandStream;
    QDataStream m_statusStream;
};
 
class WorkerPipe : public QObject
{
    Q_OBJECT
 
public:
    WorkerPipe(QIODevice* commandPipe, QIODevice* statusPipe);
 
    void urlStarted(const QString& url);
    void urlFinished(const QString& url);
    void urlFailed(const QString& url);
    void batchFinished();
 
public Q_SLOTS:
    void processIdData();
 
Q_SIGNALS:
    void newDocumentIds(const QVector<quint64>& ids);
    void inputEnd();
 
private:
    QDataStream m_commandStream;
    QDataStream m_statusStream;
};
 
} // namespace Private
} // namespace Baloo
#endif