/**
 * @file
 * @brief This file is expected to contain tests involving sync root paths (local
 * and remote), e.g., what happens when the remote root of a sync gets deleted.
 */

#include <string_view>
#ifdef ENABLE_SYNC

#include "mock_listeners.h"
#include "SdkTestSyncNodesOperations.h"

#include <gmock/gmock.h>

using namespace sdk_test;
using namespace testing;

namespace
{
bool thereIsRenamedNode(const MegaNodeList* const nodes, const std::string_view targetName)
{
    if (!nodes)
        return false;

    const auto nodeIsRenamed = [targetName](auto* const node)
    {
        return node && node->getName() == targetName &&
               node->hasChanged(MegaNode::CHANGE_TYPE_NAME);
    };

    for (auto i = nodes->size(); i--;)
    {
        if (nodeIsRenamed(nodes->get(i)))
        {
            return true;
        }
    }
    return false;
}
} // namespace

/**
 * @class SdkTestSyncRootOperations
 * @brief Test fixture designed to test operations involving sync root local and remote paths.
 */
class SdkTestSyncLocalOperations: public SdkTestSyncNodesOperations
{
public:
    static constexpr std::string_view source{"test.cvj"};
    static constexpr std::string_view target{"test.bak"};

    const std::vector<NodeInfo>& getElements() const override
    {
        // To ensure "testCommonFile" is identical in both dirs
        static const std::vector<NodeInfo> ELEMENTS{
            DirNodeInfo(DEFAULT_SYNC_REMOTE_PATH)
                .addChild(FileNodeInfo(std::string{target}).setSize(1000))
                .addChild(FileNodeInfo(std::string{source}).setSize(900))};
        return ELEMENTS;
    }

    void renameAndCreate() const
    {
        using clock = std::chrono::steady_clock;
        const auto nodeRenamed = [](const MegaNodeList* nodes) -> bool
        {
            return thereIsRenamedNode(nodes, target);
        };
        // Track putnodes complete (move)
        std::promise<clock::time_point> finishedRename;
        NiceMock<MockNodesUpdateListener> mockNodesListener{megaApi[0].get()};
        EXPECT_CALL(mockNodesListener, onNodesUpdate).Times(AnyNumber());
        EXPECT_CALL(mockNodesListener, onNodesUpdate(_, Truly(nodeRenamed)))
            .WillOnce(
                [&finishedRename]
                {
                    finishedRename.set_value(clock::now());
                });

        // Track new test.cvj upload. On first update, wait until move ends
        const auto ExpectedTransfer = Pointer(Property(&MegaTransfer::getFileName, source));
        const auto OkError = Pointer(Property(&MegaError::getErrorCode, API_OK));
        std::promise<clock::time_point> finishedTransfer;
        MockTransferListener mockTransferListener{megaApi[0].get()};
        EXPECT_CALL(mockTransferListener, onTransferStart(_, ExpectedTransfer)).Times(1);
        EXPECT_CALL(mockTransferListener, onTransferUpdate(_, ExpectedTransfer)).Times(AnyNumber());
        EXPECT_CALL(mockTransferListener, onTransferFinish(_, ExpectedTransfer, OkError))
            .WillOnce(
                [&finishedTransfer]
                {
                    finishedTransfer.set_value(clock::now());
                });

        megaApi[0]->addListener(&mockNodesListener);
        megaApi[0]->addListener(&mockTransferListener);

        std::filesystem::rename(localTmpPath() / source, localTmpPath() / target);
        auto rnFut = finishedRename.get_future();
        auto futureRenameStatus = rnFut.wait_for(COMMON_TIMEOUT);
        ASSERT_EQ(futureRenameStatus, std::future_status::ready) << "Timeout rename";

        sdk_test::createRandomFile(localTmpPath() / source, 950);
        auto trFut = finishedTransfer.get_future();
        auto futureStatus = trFut.wait_for(COMMON_TIMEOUT);
        ASSERT_EQ(futureStatus, std::future_status::ready) << "Timeout transfer";

        megaApi[0]->removeListener(&mockNodesListener);
        megaApi[0]->removeListener(&mockTransferListener);

        // Verify expectations on the mocks. If any expectation failed, this returns false.
        bool nodesOk = ::testing::Mock::VerifyAndClearExpectations(&mockNodesListener);
        bool transferOk = ::testing::Mock::VerifyAndClearExpectations(&mockTransferListener);

        ASSERT_TRUE(nodesOk) << "Expectations on nodes listener failed.";
        ASSERT_TRUE(transferOk) << "Expectations on transfer listener failed.";

        const auto transferFinishTime = trFut.get();
        const auto renameFinishTime = rnFut.get();
        ASSERT_GT(transferFinishTime, renameFinishTime)
            << "Test is invalid, putnodes ended after the transfer finished";

        std::this_thread::sleep_for(5s);
    }

    void disableSyncDeleteLocalFilesAndWaitForRedownloading()
    {
        static constexpr std::string_view logPre{
            "disableSyncDeleteLocalFilesAndWaitForRedownloading : "};
        LOG_verbose << logPre << "Disabling the sync";
        ASSERT_NO_FATAL_FAILURE(disableSync());

        LOG_verbose << logPre << "Deleting local files (source and target)";
        std::filesystem::remove(localTmpPath() / source);
        std::filesystem::remove(localTmpPath() / target);
        std::this_thread::sleep_for(2s);

        LOG_verbose << logPre << "Setting transfer expectations";
        using clock = std::chrono::steady_clock;

        const auto ExpectedTransfer1 = Pointer(Property(&MegaTransfer::getFileName, source));
        const auto ExpectedTransfer2 = Pointer(Property(&MegaTransfer::getFileName, target));
        const auto OkError1 = Pointer(Property(&MegaError::getErrorCode, API_OK));
        const auto OkError2 = Pointer(Property(&MegaError::getErrorCode, API_OK));

        std::promise<clock::time_point> finishedTransfer1;
        std::promise<clock::time_point> finishedTransfer2;

        MockTransferListener mockTransferListener{megaApi[0].get()};
        EXPECT_CALL(mockTransferListener, onTransferStart(_, ExpectedTransfer1)).Times(1);
        EXPECT_CALL(mockTransferListener, onTransferUpdate(_, ExpectedTransfer1))
            .Times(AnyNumber());
        EXPECT_CALL(mockTransferListener, onTransferFinish(_, ExpectedTransfer1, OkError1))
            .WillOnce(
                [&finishedTransfer1]
                {
                    finishedTransfer1.set_value(clock::now());
                });

        EXPECT_CALL(mockTransferListener, onTransferStart(_, ExpectedTransfer2)).Times(1);
        EXPECT_CALL(mockTransferListener, onTransferUpdate(_, ExpectedTransfer2))
            .Times(AnyNumber());
        EXPECT_CALL(mockTransferListener, onTransferFinish(_, ExpectedTransfer2, OkError2))
            .WillOnce(
                [&finishedTransfer2]
                {
                    finishedTransfer2.set_value(clock::now());
                });

        megaApi[0]->addListener(&mockTransferListener);

        LOG_verbose << logPre << "Resuming the sync";
        ASSERT_NO_FATAL_FAILURE(resumeSync());

        LOG_verbose << logPre << "Ensuring sync is running on " << DEFAULT_SYNC_REMOTE_PATH;
        ASSERT_NO_FATAL_FAILURE(ensureSyncNodeIsRunning(DEFAULT_SYNC_REMOTE_PATH));

        LOG_verbose << logPre << "Waiting for downloads";

        ASSERT_EQ(finishedTransfer1.get_future().wait_for(COMMON_TIMEOUT),
                  std::future_status::ready);

        ASSERT_EQ(finishedTransfer2.get_future().wait_for(COMMON_TIMEOUT),
                  std::future_status::ready);

        LOG_verbose << logPre << "Sync-downloads completed!";

        LOG_verbose << logPre << "Waiting for sync remote and local roots to have the same content";
        ASSERT_NO_FATAL_FAILURE(waitForSyncToMatchCloudAndLocal());

        LOG_verbose << logPre << "Waiting for sync completed!";
    }

    void renameAndCreateExtended(bool disableSyncAndCheckHashesAfterRedownload)
    {
        using clock = std::chrono::steady_clock;
        const auto nodeRenamed = [](const MegaNodeList* nodes) -> bool
        {
            return thereIsRenamedNode(nodes, target);
        };
        // Track putnodes complete (move)
        std::promise<clock::time_point> finishedRename;
        NiceMock<MockNodesUpdateListener> mockNodesListener{megaApi[0].get()};
        EXPECT_CALL(mockNodesListener, onNodesUpdate).Times(AnyNumber());
        EXPECT_CALL(mockNodesListener, onNodesUpdate(_, Truly(nodeRenamed)))
            .WillOnce(
                [&finishedRename]
                {
                    finishedRename.set_value(clock::now());
                });

        // Track new test.cvj upload. On first update, wait until move ends
        const auto ExpectedTransfer = Pointer(Property(&MegaTransfer::getFileName, source));
        const auto OkError = Pointer(Property(&MegaError::getErrorCode, API_OK));
        std::promise<clock::time_point> finishedTransfer;
        std::promise<std::string> gotFileName;
        std::promise<error> errorTransfer;
        MockTransferListener mockTransferListener{megaApi[0].get()};
        EXPECT_CALL(mockTransferListener, onTransferStart(_, ExpectedTransfer)).Times(1);
        EXPECT_CALL(mockTransferListener, onTransferUpdate(_, ExpectedTransfer)).Times(AnyNumber());
        EXPECT_CALL(mockTransferListener, onTransferFinish(_, ExpectedTransfer, _))
            .WillOnce(
                [&finishedTransfer, &gotFileName, &errorTransfer](::mega::MegaApi*,
                                                                  ::mega::MegaTransfer* t,
                                                                  ::mega::MegaError* e)
                {
                    finishedTransfer.set_value(clock::now());
                    LOG_debug << "[mockTransferFinish::onTransferFinish] t->getFileName = '"
                              << t->getFileName() << "', t->getPath = '" << t->getPath() << "'";
                    gotFileName.set_value(t->getFileName());
                    errorTransfer.set_value((error)e->getErrorCode());
                });

        megaApi[0]->addListener(&mockNodesListener);
        megaApi[0]->addListener(&mockTransferListener);

        const auto sourceOriginalHash = hashFileHex(localTmpPath() / source);
        const auto targetOriginalHash = hashFileHex(localTmpPath() / target);

        std::filesystem::rename(localTmpPath() / source, localTmpPath() / target);
        auto rnFut = finishedRename.get_future();
        auto futureRnStatus = rnFut.wait_for(COMMON_TIMEOUT);
        ASSERT_EQ(futureRnStatus, std::future_status::ready) << "Timeout rename";

        const std::filesystem::path sourcePath = localTmpPath() / source;
        sdk_test::createRandomFile(sourcePath, 950);

        const auto sourceNewHash = hashFileHex(localTmpPath() / source);

        auto trFut = finishedTransfer.get_future();
        auto trFilenameFut = gotFileName.get_future();
        auto errorTransferFut = errorTransfer.get_future();
        auto futureStatus = trFut.wait_for(COMMON_TIMEOUT);

        ASSERT_EQ(futureStatus, std::future_status::ready) << "Timeout transfer";
        futureStatus = trFilenameFut.wait_for(COMMON_TIMEOUT);
        ASSERT_EQ(futureStatus, std::future_status::ready) << "Timeout transfer get name";
        futureStatus = errorTransferFut.wait_for(COMMON_TIMEOUT);
        ASSERT_EQ(futureStatus, std::future_status::ready) << "Timeout transfer get error";

        megaApi[0]->removeListener(&mockNodesListener);
        megaApi[0]->removeListener(&mockTransferListener);

        // Verify expectations on the mocks. If any expectation failed, this returns false.
        bool nodesOk = ::testing::Mock::VerifyAndClearExpectations(&mockNodesListener);
        bool transferOk = ::testing::Mock::VerifyAndClearExpectations(&mockTransferListener);

        ASSERT_TRUE(nodesOk) << "Expectations on nodes listener failed.";
        ASSERT_TRUE(transferOk) << "Expectations on transfer listener failed.";

        const auto transferFinishTime = trFut.get();
        const auto remoteName = trFilenameFut.get();
        const auto transferError = errorTransferFut.get();
        const auto renameFinishTime = rnFut.get();
        ASSERT_GT(transferFinishTime, renameFinishTime)
            << "Test is invalid, putnodes ended after the transfer finished";

        fs::path uploadedPath = localTmpPath() / remoteName;
        EXPECT_EQ(uploadedPath, sourcePath);

        const auto sourceCurrentHash = hashFileHex(localTmpPath() / source);
        const auto targetCurrentHash = hashFileHex(localTmpPath() / target);

        LOG_debug << "SourceOriginalHash: " << sourceOriginalHash
                  << " [SourceCurrentHash: " << sourceCurrentHash << "]";
        LOG_debug << "TargetOriginalHash: " << targetOriginalHash
                  << " [TargetCurrentHash: " << targetCurrentHash << "]";
        LOG_debug << "SourceNewHash: " << sourceNewHash
                  << " [SourceCurrentHash: " << sourceCurrentHash << "]";

        EXPECT_EQ(sourceOriginalHash, targetCurrentHash);
        EXPECT_NE(sourceOriginalHash, targetOriginalHash);
        EXPECT_EQ(sourceNewHash, sourceCurrentHash);
        EXPECT_NE(sourceNewHash, sourceOriginalHash);
        EXPECT_NE(sourceNewHash, targetOriginalHash);

        ASSERT_EQ(transferError, API_OK);

        std::this_thread::sleep_for(5s);

        if (disableSyncAndCheckHashesAfterRedownload)
        {
            ASSERT_NO_FATAL_FAILURE(disableSyncDeleteLocalFilesAndWaitForRedownloading());

            const auto sourceCurrentHashAfterFreshDownload = hashFileHex(localTmpPath() / source);
            const auto targetCurrentHashAfterFreshDownload = hashFileHex(localTmpPath() / target);

            LOG_debug << "Checking hashes of source (" << source << ") and target (" << target
                      << ") after disabling the sync + deleting local files + resuming the sync + "
                         "sync-downloading source and target + calculate fresh hash for each";

            LOG_debug << "SourceOriginalHash: " << sourceOriginalHash
                      << " [SourceCurrentHash: " << sourceCurrentHash << "]";
            LOG_debug << "TargetOriginalHash: " << targetOriginalHash
                      << " [TargetCurrentHash: " << targetCurrentHash << "]";
            LOG_debug << "SourceNewHash: " << sourceNewHash
                      << " [SourceCurrentHash: " << sourceCurrentHash << "]";

            EXPECT_EQ(sourceOriginalHash, targetCurrentHashAfterFreshDownload);
            EXPECT_NE(sourceOriginalHash, targetOriginalHash);
            EXPECT_EQ(sourceNewHash, sourceCurrentHashAfterFreshDownload);
            EXPECT_NE(sourceNewHash, sourceOriginalHash);
            EXPECT_NE(sourceNewHash, targetOriginalHash);
        }
    }
};

/**
 * @brief Renames A to B (B already exists, so it's replaced) and creates a new A. After the move
 * and the transfer finish, repeat the operation.
 *
 * The first time that a move operation takes place, the sync debris folder is not created yet,
 * affecting the sequence of requests sent to the API:
 *    1. The request to move (rename) the node to-be-displaced along with the request will be sent
 * to create the daily SyncDebris.
 *    2. Action packets are received, node to-be-displaced is not yet fully updated as there are now
 * 2 duplicated nodes in the cloud, the renamed one and the old one that still needs to be sent to
 * debris.
 *    3. After receiving the action packets, the request to move to debris the node-to-be-displaced
 * will be sent.
 *    4. Immediately after, the move operation completion will be checked: the row.cloudNode still
 * has the old handle (as it not has yet been moved to debris, that cloudNode is outdated). So the
 * move operation is reset for evaluation.
 *    5. The operation to move the node-to-be-displaced to debris will be finished, but the
 * checkMoves will wait a bit (it considers the file is still changing, as it has stats that it
 * didn't have before).
 *    6. When the checkMoves takes place again, all the move operation in the cloud has been
 * completed, so it doesn't need to start a move operation again.
 *
 * The second time a move operation takes place, the sync debris is created already:
 *    1. The request to move (rename) the node-to-be-displaced will the request to move the
 * node-to-be-displaced to the daily SyncDebris.
 *    2. Action packets are received, updating the current cloud nodes accordingly, and the
 * displaced node with the previous handle does not exist anymore.
 *    3. Immediately after, the move operation completion will be checked: the row.cloudNode has the
 * updated handle.
 *    4. The move operation is completed from the sync engine: it takes all the data from the
 * sourceSyncNode, including the transfer in flight, and marks the row as synced.
 *
 * Expectations are that only one upload transfer (the one to create the new A) is started in each
 * iteration:
 *    1. First iteration, there is a move operation which is cancelled. The upload transfer is never
 * moved to another sync node.
 *    2. Second iteration, the move operation is completed from the sync engine, and the upload
 * transfer is moved to the target sync node (B). The fix must prevent this from happening for this
 * scenario, avoiding a new upload to be started again from the new file A.
 */
TEST_F(SdkTestSyncLocalOperations, RenameAndCreateNew)
{
    static const auto logPre{getLogPrefix()};
    LOG_debug << logPre << "Starting";
    for (const auto i: range(2))
    {
        LOG_debug << logPre << "rename n" << (i + 1);
        ASSERT_NO_FATAL_FAILURE(renameAndCreate())
            << "Unexpected behaviour on the rename & create operation n" << i;
    }
    LOG_debug << logPre << "Finishing";
}

/**
 * @brief RenameAndCreateNew test in "hard mode".
 *
 * 1. Uses random data.
 * 2. Extended expectations for onTransferFinish, getting file names and delaying the error
 * checking.
 * 3. Calculates SHA256 of each file before, after and current (current = in the very moment of
 * calling it, generally after some transfers or intermediate operations).
 * 4. Final check at the end: disables the sync, deletes the local source and target files, resumes
 * the sync so the files are sync-downloaded from the cloud, calculates the SHA-256 of each and
 * checks that it is the expected one.
 */
TEST_F(SdkTestSyncLocalOperations, RenameAndCreateNewWithExtendedExpectations)
{
    static const auto logPre{getLogPrefix()};
    LOG_debug << logPre << "Starting";
    for (const auto i: range(2))
    {
        LOG_debug << logPre << "rename n" << (i + 1);
        ASSERT_NO_FATAL_FAILURE(renameAndCreateExtended(static_cast<bool>(i)))
            << "Unexpected behaviour on the rename & create operation n" << i;
    }
    LOG_debug << logPre << "Finishing";
}
#endif