syncspirit/tests/032-diff-modify.cpp

#include "catch.hpp"
#include "test-utils.h"
#include "access.h"
#include "model/cluster.h"
#include "model/diff/modify/create_folder.h"
#include "model/diff/modify/share_folder.h"
#include "model/diff/modify/update_peer.h"
#include "model/diff/diff_visitor.h"

using namespace syncspirit;
using namespace syncspirit::model;
using namespace syncspirit::proto;
using namespace syncspirit::test;

template <typename F>
struct my_cluster_update_visitor_t: diff::diff_visitor_t {
    F fn;

    my_cluster_update_visitor_t(F&& fn_): fn{std::forward<F>(fn_)}{}
    outcome::result<void> operator()(const diff::peer::cluster_update_t &diff) noexcept override {
        return fn(diff);
    }
};

TEST_CASE("cluster modifications from ui", "[model]") {
    auto my_id = device_id_t::from_string("KHQNO2S-5QSILRK-YX4JZZ4-7L77APM-QNVGZJT-EKU7IFI-PNEPBMY-4MXFMQD").value();
    auto my_device =  device_t::create(my_id, "my-device").value();
    auto peer_id = device_id_t::from_string("VUV42CZ-IQD5A37-RPEBPM4-VVQK6E4-6WSKC7B-PVJQHHD-4PZD44V-ENC6WAZ").value();

    auto peer_device =  device_t::create(peer_id, "peer-device").value();
    auto cluster = cluster_ptr_t(new cluster_t(my_device, 1));
    cluster->get_devices().put(my_device);
    cluster->get_devices().put(peer_device);

    auto& folders = cluster->get_folders();
    db::Folder db_folder;
    db_folder.set_id("1234-5678");
    db_folder.set_label("my-label");
    db_folder.set_path("/my/path");

    SECTION("folder creation") {
        SECTION("simple") {
            auto diff = diff::cluster_diff_ptr_t(new diff::modify::create_folder_t(db_folder));
            REQUIRE(diff->apply(*cluster));
            auto folder = folders.by_id(db_folder.id());
            REQUIRE(folder);
            CHECK(folder->get_id() == db_folder.id());
            CHECK(folder->get_label() == db_folder.label());
            CHECK(folder->get_path() == db_folder.path());
            CHECK(folder->get_cluster() == cluster);

            auto fi = folder->get_folder_infos().by_device(my_device);
            REQUIRE(fi);
            CHECK(fi->get_max_sequence() == 0);
            CHECK(fi->get_index() != 0);
        }

        SECTION("with prototype") {
            auto diff = diff::cluster_diff_ptr_t(new diff::modify::create_folder_t(db_folder, peer_id.get_sha256(), 123, 4));
            REQUIRE(diff->apply(*cluster));
            auto folder = folders.by_id(db_folder.id());
            REQUIRE(folder);
            CHECK(folder->get_id() == db_folder.id());
            CHECK(folder->get_label() == db_folder.label());
            CHECK(folder->get_path() == db_folder.path());
            CHECK(folder->get_cluster() == cluster);

            auto fi_my = folder->get_folder_infos().by_device(my_device);
            REQUIRE(fi_my);
            CHECK(fi_my->get_device() == my_device);
            CHECK(fi_my->get_max_sequence() == 0);
            CHECK(fi_my->get_index() != 0);

            auto fi_peer = folder->get_folder_infos().by_device(peer_device);
            REQUIRE(fi_peer);
            CHECK(fi_peer->get_device() == peer_device);
            CHECK(fi_peer->get_max_sequence() == 4);
            CHECK(fi_peer->get_index() == 123);
        }
    }

    SECTION("share folder") {
        auto diff_create = diff::cluster_diff_ptr_t(new diff::modify::create_folder_t(db_folder));
        REQUIRE(diff_create->apply(*cluster));
        auto diff_share = diff::cluster_diff_ptr_t(new diff::modify::share_folder_t(peer_id.get_sha256(), db_folder.id()));
        REQUIRE(diff_share->apply(*cluster));

        auto folder = folders.by_id(db_folder.id());
        REQUIRE(folder);
        auto fi_peer = folder->get_folder_infos().by_device(peer_device);
        REQUIRE(fi_peer);
        CHECK(fi_peer->get_device() == peer_device);
        CHECK(fi_peer->get_max_sequence() == 0);
        CHECK(fi_peer->get_index() != 0);
    }

    SECTION("update peer") {
        db::Device db;
        db.set_name("myyy-devices");
        db.set_cert_name("cn2");
        auto diff = diff::cluster_diff_ptr_t(new diff::modify::update_peer_t(db, my_id.get_sha256()));
        REQUIRE(diff->apply(*cluster));
        CHECK(my_device->get_name() == "myyy-devices");
        CHECK(my_device->get_cert_name() == "cn2");
    }

    SECTION("update peer // wrong decice_id") {
        db::Device db;
        db.set_name("myyy-devices");
        db.set_cert_name("cn2");
        auto diff = diff::cluster_diff_ptr_t(new diff::modify::update_peer_t(db, "wrong-sha256"));
        auto r = diff->apply(*cluster);
        REQUIRE(!r);
        auto err = r.error();
        CHECK(err.message() == "device id is malformed (28)");
    }
}