033-diffs-trivial.cpp 3.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. #include "catch.hpp"
  2. #include "test-utils.h"
  3. #include "access.h"
  4. #include "model/cluster.h"
  5. #include "model/diff/modify/create_folder.h"
  6. #include "model/diff/modify/lock_file.h"
  7. #include "model/diff/modify/file_availability.h"
  8. #include "model/diff/modify/new_file.h"
  9. #include "model/diff/peer/peer_state.h"
  10. #include "model/diff/cluster_visitor.h"
  11. using namespace syncspirit;
  12. using namespace syncspirit::model;
  13. using namespace syncspirit::proto;
  14. using namespace syncspirit::test;
  15. TEST_CASE("peer state update", "[model]") {
  16. auto my_id = device_id_t::from_string("KHQNO2S-5QSILRK-YX4JZZ4-7L77APM-QNVGZJT-EKU7IFI-PNEPBMY-4MXFMQD").value();
  17. auto my_device = device_t::create(my_id, "my-device").value();
  18. auto peer_id = device_id_t::from_string("VUV42CZ-IQD5A37-RPEBPM4-VVQK6E4-6WSKC7B-PVJQHHD-4PZD44V-ENC6WAZ").value();
  19. auto peer_device = device_t::create(peer_id, "peer-device").value();
  20. auto cluster = cluster_ptr_t(new cluster_t(my_device, 1));
  21. cluster->get_devices().put(my_device);
  22. cluster->get_devices().put(peer_device);
  23. rotor::address_ptr_t addr;
  24. auto diff = diff::cluster_diff_ptr_t(new diff::peer::peer_state_t(*cluster, peer_id.get_sha256(), addr, true));
  25. CHECK(peer_device->is_online() == false);
  26. REQUIRE(diff->apply(*cluster));
  27. CHECK(peer_device->is_online() == true);
  28. diff = new diff::peer::peer_state_t(*cluster, peer_id.get_sha256(), addr, false);
  29. REQUIRE(diff->apply(*cluster));
  30. CHECK(peer_device->is_online() == false);
  31. }
  32. TEST_CASE("with file", "[model]") {
  33. auto my_id = device_id_t::from_string("KHQNO2S-5QSILRK-YX4JZZ4-7L77APM-QNVGZJT-EKU7IFI-PNEPBMY-4MXFMQD").value();
  34. auto my_device = device_t::create(my_id, "my-device").value();
  35. auto cluster = cluster_ptr_t(new cluster_t(my_device, 1));
  36. cluster->get_devices().put(my_device);
  37. db::Folder db_folder;
  38. db_folder.set_id("1234-5678");
  39. db_folder.set_label("my-label");
  40. auto diff = diff::cluster_diff_ptr_t(new diff::modify::create_folder_t(db_folder));
  41. REQUIRE(diff->apply(*cluster));
  42. auto folder_info = cluster->get_folders().by_id(db_folder.id())->get_folder_infos().by_device(my_device);
  43. CHECK(folder_info->is_actual());
  44. proto::FileInfo pr_file_info;
  45. pr_file_info.set_name("a.txt");
  46. pr_file_info.set_type(proto::FileInfoType::SYMLINK);
  47. pr_file_info.set_symlink_target("/some/where");
  48. pr_file_info.set_block_size(5);
  49. pr_file_info.set_size(5);
  50. auto b1 = pr_file_info.add_blocks();
  51. b1->set_hash(utils::sha256_digest("12345").value());
  52. b1->set_offset(0);
  53. b1->set_size(5);
  54. diff = diff::cluster_diff_ptr_t(new diff::modify::new_file_t(*cluster, db_folder.id(), pr_file_info, {*b1}));
  55. REQUIRE(diff->apply(*cluster));
  56. auto file = folder_info->get_file_infos().by_name("a.txt");
  57. REQUIRE(file);
  58. SECTION("lock/unlock") {
  59. diff = diff::cluster_diff_ptr_t(new diff::modify::lock_file_t(db_folder.id(), pr_file_info.name(), true));
  60. REQUIRE(diff->apply(*cluster));
  61. auto file = folder_info->get_file_infos().by_name(pr_file_info.name());
  62. REQUIRE(file->is_locked());
  63. diff = diff::cluster_diff_ptr_t(new diff::modify::lock_file_t(db_folder.id(), pr_file_info.name(), false));
  64. REQUIRE(diff->apply(*cluster));
  65. REQUIRE(!file->is_locked());
  66. }
  67. SECTION("file_availability") {
  68. REQUIRE(!file->is_locally_available());
  69. diff = diff::cluster_diff_ptr_t(new diff::modify::file_availability_t(file));
  70. REQUIRE(diff->apply(*cluster));
  71. REQUIRE(file->is_locally_available());
  72. }
  73. }