File indexing completed on 2024-06-09 05:06:59

 /*
  * SPDX-FileCopyrightText: 2014 Daniel Vrátil <dvratil@redhat.com>
  *
  * SPDX-License-Identifier: LGPL-2.1-or-later
  *
  */
 
 #pragma once
 
 #include "datastream_p_p.h"
 #include <QRecursiveMutex>
 #include <QThread>
 
 #include "fakeakonadiserver.h"
 
 class QLocalSocket;
 
 namespace Akonadi
 {
 namespace Server
 {
 class FakeClient : public QThread
 {
     Q_OBJECT
 
 public:
     explicit FakeClient(QObject *parent = nullptr);
     ~FakeClient() override;
 
     void setScenarios(const TestScenario::List &scenarios);
 
     bool isScenarioDone() const;
 
     void start();
     void startScenario();
     void cleanup();
 
 private Q_SLOTS:
     void do_connectToServer();
     void do_startScenario();
 
     bool dataAvailable();
     void readServerPart();
     void writeClientPart();
     void connectionLost();
 
 private:
     mutable QRecursiveMutex mMutex;
 
     TestScenario::List mScenarios;
     QLocalSocket *mSocket = nullptr;
     Protocol::DataStream mStream;
 };
 }
 }