/*
 * synergy -- mouse and keyboard sharing utility
 * Copyright (C) 2024 Symless Ltd.
 *
 * This package is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License
 * found in the file LICENSE that should have accompanied this file.
 *
 * This package is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program.  If not, see <http://www.gnu.org/licenses/>.
 */

#include "gui/config/IAppConfig.h"
#include "gui/core/CoreProcess.h"
#include "gui/ipc/IQIpcClient.h"
#include "gui/proxy/QProcessProxy.h"
#include "license/ILicense.h"
#include "shared/gui/mocks/AppConfigMock.h"
#include "shared/gui/mocks/ServerConfigMock.h"

#include "gmock/gmock.h"
#include <gmock/gmock.h>
#include <gtest/gtest.h>

using namespace synergy::gui;
using namespace synergy::license;
using namespace testing;

namespace {

class QProcessProxyMock : public proxy::QProcessProxy {
public:
  operator bool() const override { return toBool(); }

  QProcessProxyMock() {
    ON_CALL(*this, toBool()).WillByDefault(Return(true));
    ON_CALL(*this, state())
        .WillByDefault(Return(QProcess::ProcessState::Running));
    ON_CALL(*this, waitForStarted()).WillByDefault(Return(true));
  }

  MOCK_METHOD(bool, toBool, (), (const));
  MOCK_METHOD(void, create, (), (override));
  MOCK_METHOD(
      void, start, (const QString &program, const QStringList &arguments),
      (override));
  MOCK_METHOD(bool, waitForStarted, (), (override));
  MOCK_METHOD(QProcess::ProcessState, state, (), (const, override));
  MOCK_METHOD(void, close, (), (override));
  MOCK_METHOD(QString, readAllStandardOutput, (), (override));
  MOCK_METHOD(QString, readAllStandardError, (), (override));
};

class QIpcClientMock : public ipc::IQIpcClient {
public:
  QIpcClientMock() {
    ON_CALL(*this, isConnected()).WillByDefault(Return(true));
  }

  MOCK_METHOD(void, sendHello, (), (const, override));
  MOCK_METHOD(
      void, sendCommand, (const QString &command, ElevateMode elevate),
      (const, override));
  MOCK_METHOD(void, connectToHost, (), (override));
  MOCK_METHOD(void, disconnectFromHost, (), (override));
  MOCK_METHOD(bool, isConnected, (), (const, override));
};

class DepsMock : public CoreProcess::Deps {
public:
  DepsMock() {
    ON_CALL(*this, process()).WillByDefault(ReturnRef(m_process));
    ON_CALL(*this, ipcClient()).WillByDefault(ReturnRef(m_ipcClient));
    ON_CALL(*this, appPath(_)).WillByDefault(Return("stub app path"));
    ON_CALL(*this, fileExists(_)).WillByDefault(Return(true));
    ON_CALL(*this, getProfileRoot()).WillByDefault(Return("stub profile"));
  }

  MOCK_METHOD(proxy::QProcessProxy &, process, (), (override));
  MOCK_METHOD(ipc::IQIpcClient &, ipcClient, (), (override));
  MOCK_METHOD(QString, appPath, (const QString &name), (const, override));
  MOCK_METHOD(bool, fileExists, (const QString &path), (const, override));
  MOCK_METHOD(QString, getProfileRoot, (), (const, override));

  NiceMock<QProcessProxyMock> m_process;
  NiceMock<QIpcClientMock> m_ipcClient;
};

class LicenseMock : public ILicense {
public:
  LicenseMock() {
    ON_CALL(*this, isTlsAvailable()).WillByDefault(Return(true));
  }

  MOCK_METHOD(bool, isTlsAvailable, (), (const, override));
};

class CoreProcessTests : public Test {
public:
  CoreProcessTests()
      : m_coreProcess(m_appConfig, m_serverConfig, m_license, m_pDeps) {}

  NiceMock<AppConfigMock> m_appConfig;
  NiceMock<ServerConfigMock> m_serverConfig;
  NiceMock<LicenseMock> m_license;
  std::shared_ptr<NiceMock<DepsMock>> m_pDeps =
      std::make_shared<NiceMock<DepsMock>>();
  CoreProcess m_coreProcess;
};

} // namespace

TEST_F(CoreProcessTests, start_serverDesktop_callsProcessStart) {
  m_coreProcess.setMode(CoreProcess::Mode::Server);

  EXPECT_CALL(m_pDeps->m_process, start(_, _)).Times(1);

  m_coreProcess.start(ProcessMode::kDesktop);
}

TEST_F(CoreProcessTests, start_serverService_callsSendCommand) {
  m_coreProcess.setMode(CoreProcess::Mode::Server);

  EXPECT_CALL(m_pDeps->m_ipcClient, sendCommand(_, _)).Times(1);

  m_coreProcess.start(ProcessMode::kService);
}

TEST_F(CoreProcessTests, start_clientDesktop_callsProcessStart) {
  m_coreProcess.setMode(CoreProcess::Mode::Client);
  m_coreProcess.setAddress("stub address");

  EXPECT_CALL(m_pDeps->m_process, start(_, _)).Times(1);

  m_coreProcess.start(ProcessMode::kDesktop);
}

TEST_F(CoreProcessTests, start_clientService_callsSendCommand) {
  m_coreProcess.setMode(CoreProcess::Mode::Client);
  m_coreProcess.setAddress("stub address");

  EXPECT_CALL(m_pDeps->m_ipcClient, sendCommand(_, _)).Times(1);

  m_coreProcess.start(ProcessMode::kService);
}

TEST_F(CoreProcessTests, stop_serverDesktop_callsProcessClose) {
  m_coreProcess.setMode(CoreProcess::Mode::Server);
  m_coreProcess.start();

  EXPECT_CALL(m_pDeps->m_process, close()).Times(1);

  m_coreProcess.stop(ProcessMode::kDesktop);
}

TEST_F(CoreProcessTests, stop_serverService_callsSendCommand) {
  m_coreProcess.setMode(CoreProcess::Mode::Server);
  m_coreProcess.start();

  EXPECT_CALL(m_pDeps->m_ipcClient, sendCommand(_, _)).Times(1);

  m_coreProcess.stop(ProcessMode::kService);
}

TEST_F(CoreProcessTests, stop_clientDesktop_callsProcessClose) {
  m_coreProcess.setMode(CoreProcess::Mode::Client);
  m_coreProcess.setAddress("stub address");
  m_coreProcess.start();

  EXPECT_CALL(m_pDeps->m_process, close()).Times(1);

  m_coreProcess.stop(ProcessMode::kDesktop);
}

TEST_F(CoreProcessTests, stop_clientService_callsSendCommand) {
  m_coreProcess.setMode(CoreProcess::Mode::Client);
  m_coreProcess.setAddress("stub address");
  m_coreProcess.start();

  EXPECT_CALL(m_pDeps->m_ipcClient, sendCommand(_, _)).Times(1);

  m_coreProcess.stop(ProcessMode::kService);
}

TEST_F(CoreProcessTests, restart_serverDesktop_callsProcessStart) {
  ON_CALL(m_appConfig, processMode())
      .WillByDefault(Return(ProcessMode::kDesktop));
  m_coreProcess.setMode(CoreProcess::Mode::Server);
  m_coreProcess.start();

  EXPECT_CALL(m_pDeps->m_process, close()).Times(1);
  EXPECT_CALL(m_pDeps->m_process, start(_, _)).Times(1);

  m_coreProcess.restart();
}
