waylandcopyclient.h

// SPDX-FileCopyrightText: 2011 - 2022 UnionTech Software Technology Co., Ltd.
//
// SPDX-License-Identifier: GPL-3.0-or-later

#ifndef COPYCLIENT_H
#define COPYCLIENT_H

#include <QMutex>
#include <QMimeData>
#include <QPointer>
#include <QMimeType>

namespace KWayland
{
namespace Client
{
class ConnectionThread;
class EventQueue;
class Registry;
class Seat;
class DataControlDeviceV1;
class DataControlDeviceManager;
class DataControlSourceV1;
class DataControlOfferV1;
} //Client
} //KWayland

class ReadPipeDataTask;

using namespace KWayland::Client;

class DMimeData : public QMimeData
{
    Q_OBJECT
public:
    DMimeData();
    ~DMimeData();
    virtual QVariant retrieveData(const QString &mimeType,
                                      QVariant::Type preferredType) const;
};

class WaylandCopyClient : public QObject
{
    Q_OBJECT

public:
    explicit WaylandCopyClient(QObject *parent = nullptr);
    virtual ~WaylandCopyClient();

    void init();
    const QMimeData *mimeData();
    void setMimeData(QMimeData *mimeData);

private:
    void setupRegistry(Registry *registry);
    QStringList filterMimeType(const QStringList &mimeTypeList);
    void sendOffer();

Q_SIGNALS:
    // when new source in , send dataChanged
    void dataChanged();
    // when data is copied, send dataCopied,
    void dataCopied();
    // when a new dataOffer request in ,then send it
    void dataOfferedNew();
    void dataReady(qint64, const QString &, const QByteArray &);

protected slots:
    void onSendDataRequest(const QString &mimeType, qint32 fd) const;
    void onDataOffered(DataControlOfferV1 *offer);
    void onDataCopied();

private:
    void execTask(const QStringList &mimeTypes, DataControlOfferV1 *offer);
    void taskDataReady(qint64, const QString &mimeType, const QByteArray &data);

    void onDataOfferedTask(DataControlOfferV1 *offer, const QString &mimeType);
    bool readData(int fd, QByteArray &data);

private:
    QThread *m_connectionThread;
    ConnectionThread *m_connectionThreadObject;
    EventQueue *m_eventQueue;
    DataControlDeviceManager *m_dataControlDeviceManager;
    DataControlDeviceV1 *m_dataControlDevice;
    DataControlSourceV1 *m_copyControlSource;
    QPointer<QMimeData> m_mimeData;
    Seat *m_seat;

    qint64 m_curOffer;
    QStringList m_curMimeTypes;
    bool m_pipeIsForcedClosed;
};

#endif // COPYCLIENT_H