2517

Committed 24 Jul 2024 01:12PM UTC coverage: 91.077% (+0.007%) from 91.07%

Build # 2517

Build Type

push

Evergreen

Committed by

web-flow

Commit Message

Fix intermittent failure of the role change client reset tests (#7919)

Run Details

102674 of 181450 branches covered (56.59%)

1 of 3 new or added lines in 1 file covered. (33.33%)

45 existing lines in 16 files now uncovered.

216300 of 237491 relevant lines covered (91.08%)

5560480.31 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

95.55

/test/object-store/sync/flx_role_change.cpp

////////////////////////////////////////////////////////////////////////////
//
// Copyright 2024 MongoDB Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
// http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
//
////////////////////////////////////////////////////////////////////////////

#ifdef REALM_ENABLE_AUTH_TESTS

#include <catch2/catch_all.hpp>

#include <util/test_file.hpp>
#include <util/sync/flx_sync_harness.hpp>
#include <util/sync/sync_test_utils.hpp>

#include <realm/object_id.hpp>
#include <realm/query_expression.hpp>

#include <realm/object-store/impl/realm_coordinator.hpp>
#include <realm/object-store/object.hpp>
#include <realm/object-store/schema.hpp>
#include <realm/object-store/impl/object_accessor_impl.hpp>
#include <realm/object-store/sync/async_open_task.hpp>
#include <realm/object-store/sync/sync_session.hpp>

#include <realm/sync/client_base.hpp>
#include <realm/sync/config.hpp>
#include <realm/sync/protocol.hpp>
#include <realm/sync/subscriptions.hpp>
#include <realm/sync/noinst/client_reset_operation.hpp>

#include <realm/util/future.hpp>
#include <realm/util/logger.hpp>

#include <filesystem>
#include <iostream>
#include <stdexcept>

using namespace realm;
using namespace realm::app;

namespace {

const Schema g_person_schema{{"Person",
                              {{"_id", PropertyType::ObjectId, Property::IsPrimary{true}},
                               {"role", PropertyType::String},
                               {"name", PropertyType::String},
                               {"emp_id", PropertyType::Int}}}};

auto fill_person_schema = [](SharedRealm realm, std::string role, size_t count) {
    CppContext c(realm);
    for (size_t i = 0; i < count; ++i) {
        auto obj = Object::create(c, realm, "Person",
                                  std::any(AnyDict{
                                      {"_id", ObjectId::gen()},
                                      {"role", role},
                                      {"name", util::format("%1-%2", role, i)},
                                      {"emp_id", static_cast<int64_t>(i)},
                                  }));
    }
};

struct HarnessParams {
    size_t num_emps = 150;
    size_t num_mgrs = 25;
    size_t num_dirs = 10;
    std::optional<size_t> num_objects = 10;
    std::optional<size_t> max_download_bytes = 4096;
    std::optional<size_t> sleep_millis;
};

std::unique_ptr<FLXSyncTestHarness> setup_harness(std::string app_name, HarnessParams params)
{
    auto harness = std::make_unique<FLXSyncTestHarness>(
        app_name, FLXSyncTestHarness::ServerSchema{g_person_schema, {"role", "name"}});

    auto& app_session = harness->session().app_session();

    if (params.num_objects) {
        REQUIRE(app_session.admin_api.patch_app_settings(
            app_session.server_app_id, {{"sync", {{"num_objects_before_bootstrap_flush", *params.num_objects}}}}));
    }

    if (params.max_download_bytes) {
        REQUIRE(app_session.admin_api.patch_app_settings(
            app_session.server_app_id,
            {{"sync", {{"qbs_download_changeset_soft_max_byte_size", *params.max_download_bytes}}}}));
    }

    if (params.sleep_millis) {
        REQUIRE(app_session.admin_api.patch_app_settings(
            app_session.server_app_id, {{"sync", {{"download_loop_sleep_millis", *params.sleep_millis}}}}));
    }

    // Initialize the realm with some data
    harness->load_initial_data([&](SharedRealm realm) {
        fill_person_schema(realm, "employee", params.num_emps);
        fill_person_schema(realm, "manager", params.num_mgrs);
        fill_person_schema(realm, "director", params.num_dirs);
    });
    // Return the unique_ptr for the newly created harness
    return harness;
}

void update_role(nlohmann::json& rule, nlohmann::json doc_filter)
{
    rule["roles"][0]["document_filters"]["read"] = doc_filter;
    rule["roles"][0]["document_filters"]["write"] = doc_filter;
}

void set_up_realm(SharedRealm& setup_realm, size_t expected_cnt)
{
    // Set up the initial subscription
    auto table = setup_realm->read_group().get_table("class_Person");
    auto new_subs = setup_realm->get_latest_subscription_set().make_mutable_copy();
    new_subs.insert_or_assign(Query(table));
    auto subs = new_subs.commit();

    // Wait for subscription update and sync to complete
    subs.get_state_change_notification(sync::SubscriptionSet::State::Complete).get();
    REQUIRE(!wait_for_download(*setup_realm));
    REQUIRE(!wait_for_upload(*setup_realm));
    wait_for_advance(*setup_realm);

    // Verify the data was downloaded
    table = setup_realm->read_group().get_table("class_Person");
    Results results(setup_realm, Query(table));
    REQUIRE(results.size() == expected_cnt);
}

void verify_records(SharedRealm& check_realm, size_t emps, size_t mgrs, size_t dirs)
{
    // Validate the expected number of entries for each role type after the role change
    auto table = check_realm->read_group().get_table("class_Person");
    REQUIRE(table->size() == (emps + mgrs + dirs));
    auto role_col = table->get_column_key("role");
    auto table_query = Query(table).equal(role_col, "employee");
    auto results = Results(check_realm, table_query);
    REQUIRE(results.size() == emps);
    table_query = Query(table).equal(role_col, "manager");
    results = Results(check_realm, table_query);
    REQUIRE(results.size() == mgrs);
    table_query = Query(table).equal(role_col, "director");
    results = Results(check_realm, table_query);
    REQUIRE(results.size() == dirs);
}

// Wait for realm download/upload/advance and then validate the record counts in the
// local realm.
bool wait_and_verify(SharedRealm realm, size_t emps, size_t mgrs, size_t dirs)
{
    // Using a bool to return the wait results, since using REQUIRE around
    // wait_for_download() and wait_for_upload() was causing TSAN errors
    // with the REQUIRE calls in the event hook
    if (wait_for_download(*realm) || wait_for_upload(*realm)) // these return true on failure
        return false;
    wait_for_advance(*realm);
    verify_records(realm, emps, mgrs, dirs);
    return true;
}

} // namespace

TEST_CASE("flx: role change bootstraps", "[sync][flx][baas][role change][bootstrap]") {
    auto logger = util::Logger::get_default_logger();

    // Pausing the download builder will ensure a single download message (for the bootstrap
    // in this test), will contain all the changesets for the bootstrap.
    auto pause_download_builder = [](std::weak_ptr<SyncSession> weak_session, bool pause) {
        if (auto session = weak_session.lock()) {
            nlohmann::json test_command = {{"command", pause ? "PAUSE_DOWNLOAD_BUILDER" : "RESUME_DOWNLOAD_BUILDER"}};
            SyncSession::OnlyForTesting::send_test_command(*session, test_command.dump())
                .get_async([](StatusWith<std::string> result) {
                    REQUIRE(result.is_ok());             // Future completed successfully
                    REQUIRE(result.get_value() == "{}"); // Command completed successfully
                });
        }
    };

    enum BootstrapMode {
        NoErrorNoBootstrap,
        GotErrorNoBootstrap,
        SingleMessage,
        SingleMessageMulti,
        MultiMessage,
        AnyBootstrap
    };
    struct ExpectedResults {
        BootstrapMode bootstrap;
        size_t emps;
        size_t mgrs;
        size_t dirs;
    };

    enum TestState {
        not_ready,
        start,
        reconnect_received,
        session_resumed,
        ident_message,
        downloading,
        downloaded,
        complete
    };

    TestingStateMachine<TestState> state_machina(TestState::not_ready);
    int64_t query_version = 0;
    BootstrapMode bootstrap_mode = BootstrapMode::GotErrorNoBootstrap;
    size_t download_msg_count = 0;
    size_t bootstrap_msg_count = 0;
    bool role_change_bootstrap = false;
    bool send_test_command = false;

    auto setup_config_callbacks = [&](SyncTestFile& config) {
        // Use the sync client event hook to check for the error received and for tracking
        // download messages and bootstraps
        config.sync_config->on_sync_client_event_hook = [&](std::weak_ptr<SyncSession> weak_session,
                                                            const SyncClientHookData& data) {
            state_machina.transition_with([&](TestState cur_state) -> std::optional<TestState> {
                if (cur_state == TestState::not_ready || cur_state == TestState::complete)
                    return std::nullopt;

                using BatchState = sync::DownloadBatchState;
                using Event = SyncClientHookEvent;
                switch (data.event) {
                    case Event::ErrorMessageReceived:
                        REQUIRE(cur_state == TestState::start);
                        REQUIRE(data.error_info->raw_error_code ==
                                static_cast<int>(sync::ProtocolError::session_closed));
                        REQUIRE(data.error_info->server_requests_action ==
                                sync::ProtocolErrorInfo::Action::Transient);
                        REQUIRE_FALSE(data.error_info->is_fatal);
                        return TestState::reconnect_received;

                    case Event::SessionConnected:
                        // Handle the reconnect if session multiplexing is disabled
                        [[fallthrough]];
                    case Event::SessionResumed:
                        if (send_test_command) {
                            REQUIRE(cur_state == TestState::reconnect_received);
                            logger->trace("ROLE CHANGE: sending PAUSE test command after resumed");
                            pause_download_builder(weak_session, true);
                        }
                        return TestState::session_resumed;

                    case Event::IdentMessageSent:
                        if (send_test_command) {
                            REQUIRE(cur_state == TestState::session_resumed);
                            logger->trace("ROLE CHANGE: sending RESUME test command after ident message sent");
                            pause_download_builder(weak_session, false);
                        }
                        return TestState::ident_message;

                    case Event::DownloadMessageReceived: {
                        // Skip unexpected download messages
                        if (cur_state != TestState::ident_message && cur_state != TestState::downloading) {
                            return std::nullopt;
                        }
                        ++download_msg_count;
                        // A multi-message bootstrap is in progress..
                        if (data.batch_state == BatchState::MoreToCome) {
                            // More than 1 bootstrap message, always a multi-message
                            bootstrap_mode = BootstrapMode::MultiMessage;
                            logger->trace("ROLE CHANGE: detected multi-message bootstrap");
                            return TestState::downloading;
                        }
                        // single bootstrap message or last message in the multi-message bootstrap
                        else if (data.batch_state == BatchState::LastInBatch) {
                            if (download_msg_count == 1) {
                                if (data.num_changesets == 1) {
                                    logger->trace("ROLE CHANGE: detected single-message/single-changeset bootstrap");
                                    bootstrap_mode = BootstrapMode::SingleMessage;
                                }
                                else {
                                    logger->trace("ROLE CHANGE: detected single-message/multi-changeset bootstrap");
                                    bootstrap_mode = BootstrapMode::SingleMessageMulti;
                                }
                            }
                            return TestState::downloaded;
                        }
                        return std::nullopt;
                    }

                    // A bootstrap message was processed
                    case Event::BootstrapMessageProcessed: {
                        REQUIRE(data.batch_state != BatchState::SteadyState);
                        REQUIRE((cur_state == TestState::downloading || cur_state == TestState::downloaded));
                        ++bootstrap_msg_count;
                        if (data.query_version == query_version) {
                            role_change_bootstrap = true;
                        }
                        return std::nullopt;
                    }
                    // The bootstrap has been received and processed
                    case Event::BootstrapProcessed:
                        REQUIRE(cur_state == TestState::downloaded);
                        return TestState::complete;

                    default:
                        return std::nullopt;
                }
            });
            return SyncClientHookAction::NoAction;
        };

        // Add client reset callback to verify a client reset doesn't happen
        config.sync_config->notify_before_client_reset = [&](std::shared_ptr<Realm>) {
            // Make sure a client reset did not occur while waiting for the role change to
            // be applied
            FAIL("Client reset is not expected when the role/rules/permissions are changed");
        };
    };

    auto update_perms_and_verify = [&](FLXSyncTestHarness& harness, SharedRealm check_realm, nlohmann::json new_rules,
                                       ExpectedResults expected) {
        // Reset the state machine
        state_machina.transition_with([&](TestState cur_state) {
            REQUIRE(cur_state == TestState::not_ready);
            bootstrap_msg_count = 0;
            download_msg_count = 0;
            role_change_bootstrap = false;
            query_version = check_realm->get_active_subscription_set().version();
            if (expected.bootstrap == BootstrapMode::SingleMessageMulti) {
                send_test_command = true;
            }
            return TestState::start;
        });

        // Update the permissions on the server - should send an error to the client to force
        // it to reconnect
        auto& app_session = harness.session().app_session();
        logger->debug("ROLE CHANGE: Updating rule definitions: %1", new_rules);
        app_session.admin_api.update_default_rule(app_session.server_app_id, new_rules);

        if (expected.bootstrap != BootstrapMode::NoErrorNoBootstrap) {
            // After updating the permissions (if they are different), the server should send an
            // error that will disconnect/reconnect the session - verify the reconnect occurs.
            // Make sure at least the reconnect state (or later) has been reached
            auto state_reached = state_machina.wait_until([](TestState cur_state) {
                return static_cast<int>(cur_state) >= static_cast<int>(TestState::reconnect_received);
            });
            REQUIRE(state_reached);
        }

        // Assuming the session disconnects and reconnects, the server initiated role change
        // bootstrap download will take place when the session is re-established and will
        // complete before the server sends the initial MARK response.
        // Validate the expected number of entries for each role type after the role change
        bool update_successful = wait_and_verify(check_realm, expected.emps, expected.mgrs, expected.dirs);

        // Now that the server initiated bootstrap should be complete, verify the operation
        // performed matched what was expected.
        state_machina.transition_with([&](TestState cur_state) {
            if (!update_successful) {
                FAIL("Failed to wait for realm update during role change bootstrap");
            }

            switch (expected.bootstrap) {
                case BootstrapMode::NoErrorNoBootstrap:
                    // Confirm that neither an error nor bootstrap occurred
                    REQUIRE(cur_state == TestState::start);
                    REQUIRE_FALSE(role_change_bootstrap);
                    break;
                case BootstrapMode::GotErrorNoBootstrap:
                    // Confirm that the session restarted, but a bootstrap did not occur
                    REQUIRE(cur_state == TestState::reconnect_received);
                    REQUIRE_FALSE(role_change_bootstrap);
                    break;
                case BootstrapMode::AnyBootstrap:
                    // Confirm that a bootstrap occurred, but it doesn't matter which type
                    REQUIRE(cur_state == TestState::complete);
                    REQUIRE(role_change_bootstrap);
                    break;
                default:
                    // By the time the MARK response is received and wait_for_download()
                    // returns, the bootstrap should have already been applied.
                    REQUIRE(expected.bootstrap == bootstrap_mode);
                    REQUIRE(role_change_bootstrap);
                    REQUIRE(cur_state == TestState::complete);
                    if (expected.bootstrap == BootstrapMode::SingleMessageMulti ||
                        expected.bootstrap == BootstrapMode::SingleMessage) {
                        REQUIRE(bootstrap_msg_count == 1);
                    }
                    else if (expected.bootstrap == BootstrapMode::MultiMessage) {
                        REQUIRE(bootstrap_msg_count > 1);
                    }
                    break;
            }
            return std::nullopt; // Don't transition
        });

        // Reset the state machine to "not ready" before leaving
        state_machina.transition_to(TestState::not_ready);
    };

    auto setup_test = [&](FLXSyncTestHarness& harness, nlohmann::json initial_rules, size_t initial_count) {
        // If an intial set of rules are provided, then set them now
        auto& app_session = harness.session().app_session();
        // If the rules are empty, then reset to the initial default state
        if (initial_rules.empty()) {
            initial_rules = app_session.admin_api.get_default_rule(app_session.server_app_id);
            AppCreateConfig::ServiceRole general_role{"default"};
            initial_rules["roles"] = {};
            initial_rules["roles"][0] = transform_service_role(general_role);
        }
        logger->debug("ROLE CHANGE: Initial rule definitions: %1", initial_rules);
        app_session.admin_api.update_default_rule(app_session.server_app_id, initial_rules);

        // Create and set up a new realm to be returned; wait for data sync
        auto config = harness.make_test_file();
        setup_config_callbacks(config);
        auto setup_realm = Realm::get_shared_realm(config);
        set_up_realm(setup_realm, initial_count);
        return setup_realm;
    };

    // 150 emps, 25 mgrs, 10 dirs
    // 10 objects before flush
    // 4096 download soft max bytes
    HarnessParams params{};

    // Only create the harness one time for all the sections under this test case
    static std::unique_ptr<FLXSyncTestHarness> harness;
    if (!harness) {
        harness = setup_harness("flx_role_change_bootstraps", params);
    }

    size_t num_total = params.num_emps + params.num_mgrs + params.num_dirs;
    auto realm_1 = setup_test(*harness, {}, num_total);
    // Get the current rules so it can be updated during the test
    auto& app_session = harness->session().app_session();
    auto test_rules = app_session.admin_api.get_default_rule(app_session.server_app_id);

    SECTION("Role changes lead to objects in/out of view without client reset") {
        // Single message bootstrap - remove employees, keep mgrs/dirs
        logger->trace("ROLE CHANGE: Updating rules to remove employees");
        update_role(test_rules, {{"role", {{"$in", {"manager", "director"}}}}});
        update_perms_and_verify(*harness, realm_1, test_rules,
                                {BootstrapMode::SingleMessage, 0, params.num_mgrs, params.num_dirs});
        // Write the same rules again - the client should not receive the reconnect (200) error
        logger->trace("ROLE CHANGE: Updating same rules again and verify reconnect doesn't happen");
        update_perms_and_verify(*harness, realm_1, test_rules,
                                {BootstrapMode::NoErrorNoBootstrap, 0, params.num_mgrs, params.num_dirs});
        // Multi-message bootstrap - add employeees, remove managers and directors
        logger->trace("ROLE CHANGE: Updating rules to add back the employees and remove mgrs/dirs");
        update_role(test_rules, {{"role", "employee"}});
        update_perms_and_verify(*harness, realm_1, test_rules, {BootstrapMode::MultiMessage, params.num_emps, 0, 0});
        // Single message/multi-changeset bootstrap - add back the managers and directors
        logger->trace("ROLE CHANGE: Updating rules to allow all records");
        update_role(test_rules, true);
        update_perms_and_verify(
            *harness, realm_1, test_rules,
            {BootstrapMode::SingleMessageMulti, params.num_emps, params.num_mgrs, params.num_dirs});
    }
    SECTION("Role changes for one user do not change unaffected user") {
        // Get the config for the first user
        auto config_1 = harness->make_test_file();

        // Start with a default rule that only allows access to the employee records
        AppCreateConfig::ServiceRole general_role{"default"};
        general_role.document_filters.read = {{"role", "employee"}};
        general_role.document_filters.write = {{"role", "employee"}};

        test_rules["roles"][0] = transform_service_role(general_role);
        harness->do_with_new_realm([&](SharedRealm new_realm) {
            set_up_realm(new_realm, num_total);

            // Add the initial rule and verify the data in realm 1 and 2 (both should just have the employees)
            update_perms_and_verify(*harness, realm_1, test_rules,
                                    {BootstrapMode::AnyBootstrap, params.num_emps, 0, 0});
            bool update_successful = wait_and_verify(new_realm, params.num_emps, 0, 0);
            REQUIRE(update_successful);
        });
        {
            // Create another user and a new realm config for that user
            create_user_and_log_in(harness->app());
            auto config_2 = harness->make_test_file();
            REQUIRE(config_1.sync_config->user->user_id() != config_2.sync_config->user->user_id());
            std::atomic<bool> test_started = false;

            // Reopen realm 2 and add a hook callback to check for bootstraps, which should not happen
            // on this realm
            config_2.sync_config->on_sync_client_event_hook = [&](std::weak_ptr<SyncSession>,
                                                                  const SyncClientHookData& data) {
                using Event = SyncClientHookEvent;
                if (!test_started.load()) {
                    return SyncClientHookAction::NoAction; // Not checking yet
                }
                // If a download message was received or bootstrap was processed, then fail the test
                if ((data.event == Event::DownloadMessageReceived &&
                     data.batch_state != sync::DownloadBatchState::SteadyState) ||
                    data.event == Event::BootstrapMessageProcessed || data.event == Event::BootstrapProcessed) {
                    FAIL("Bootstrap occurred on the second realm, which was not expected");
                }
                return SyncClientHookAction::NoAction;
            };
            auto realm_2 = Realm::get_shared_realm(config_2);
            set_up_realm(realm_2, params.num_emps);

            test_started = true;
            // The first rule allows access to all records for user 1
            AppCreateConfig::ServiceRole user1_role{"user 1 role"};
            user1_role.apply_when = {{"%%user.id", config_1.sync_config->user->user_id()}};
            // Add two rules, the first applies to user 1 and the second applies to other users
            test_rules["roles"] = {transform_service_role(user1_role), transform_service_role(general_role)};
            // Realm 1 should receive a role change bootstrap which updates the data to all records
            // It doesn't matter what type of bootstrap occurs
            update_perms_and_verify(*harness, realm_1, test_rules,
                                    {BootstrapMode::AnyBootstrap, params.num_emps, params.num_mgrs, params.num_dirs});

            // Realm 2 data should not change (and there shouldn't be any bootstrap messages)
            verify_records(realm_2, params.num_emps, 0, 0);

            // The first rule will be updated to only have access to employee and managers
            AppCreateConfig::ServiceRole user1_role_2 = user1_role;
            user1_role_2.document_filters.read = {{"role", {{"$in", {"employee", "manager"}}}}};
            user1_role_2.document_filters.write = {{"role", {{"$in", {"employee", "manager"}}}}};
            // Update the first rule for user 1 and verify the data after the rule is applied
            test_rules["roles"][0] = transform_service_role(user1_role_2);
            // Realm 1 should receive a role change bootstrap which updates the data to employee
            // and manager records. It doesn't matter what type of bootstrap occurs
            update_perms_and_verify(*harness, realm_1, test_rules,
                                    {BootstrapMode::AnyBootstrap, params.num_emps, params.num_mgrs, 0});

            // Realm 2 data should not change (and there shouldn't be any bootstrap messages)
            verify_records(realm_2, params.num_emps, 0, 0);
        }
    }

    // ----------------------------------------------------------------
    // Add new sections before this one
    // ----------------------------------------------------------------
    SECTION("Pending changes are lost if not allowed after role change") {
        std::vector<ObjectId> emp_ids;
        std::vector<ObjectId> mgr_ids;
        auto config = harness->make_test_file();
        config.sync_config->error_handler = [&](std::shared_ptr<SyncSession>, SyncError error) {
            REQUIRE(!error.is_fatal); // No fatal errors please
            // Expecting a compensating write error
            REQUIRE(error.status == ErrorCodes::SyncCompensatingWrite);
        };
        auto test_realm = Realm::get_shared_realm(config);
        set_up_realm(test_realm, num_total);
        // Perform the local updates offline
        test_realm->sync_session()->shutdown_and_wait();
        // Modify a set of records with new roles and create some new records as well
        // This should be called offline so the changes aren't sync'ed prematurely
        auto update_records = [](SharedRealm update_realm, std::string_view role_to_change,
                                 std::vector<ObjectId>& saved_ids, size_t num_to_modify, size_t num_to_create) {
            update_realm->begin_transaction();
            auto table = update_realm->read_group().get_table("class_Person");
            auto id_col = table->get_column_key("_id");
            auto role_col = table->get_column_key("role");
            auto name_col = table->get_column_key("name");
            auto empid_col = table->get_column_key("emp_id");
            auto table_query = Query(table).equal(role_col, role_to_change.data());
            auto results = Results(update_realm, table_query);
            REQUIRE(results.size() > 0);
            // Modify the role of some existing objects
            for (size_t i = 0; i < num_to_modify; i++) {
                auto obj = results.get(i);
                saved_ids.push_back(obj.get<ObjectId>(id_col));
                obj.set(role_col, "worker-bee");
            }
            // And create some new objects
            for (size_t i = 0; i < num_to_create; i++) {
                auto obj = table->create_object_with_primary_key(ObjectId::gen());
                obj.set(role_col, role_to_change.data());
                obj.set(name_col, util::format("%1-%2(new)", role_to_change.data(), i));
                obj.set(empid_col, static_cast<int64_t>(i + 2500)); // actual # doesnt matter
            }
            update_realm->commit_transaction();
        };
        auto do_update_rules = [&](nlohmann::json new_rules) {
            update_role(test_rules, new_rules);
            logger->debug("ROLE CHANGE: Updating rule definitions: %1", test_rules);
            app_session.admin_api.update_default_rule(app_session.server_app_id, test_rules);
        };
        auto do_verify = [](SharedRealm realm, size_t cnt, std::vector<ObjectId>& saved_ids,
                            std::optional<std::string_view> expected = std::nullopt) {
            REQUIRE(!wait_for_download(*realm));
            REQUIRE(!wait_for_upload(*realm));
            wait_for_advance(*realm);
            // Verify none of the records modified above exist in the realm
            auto table = realm->read_group().get_table("class_Person");
            REQUIRE(table->size() == cnt);
            auto id_col = table->get_column_key("_id");
            auto role_col = table->get_column_key("role");
            for (auto& id : saved_ids) {
                auto objkey = table->find_first(id_col, id);
                if (expected) {
                    REQUIRE(objkey);
                    auto obj = table->get_object(objkey);
                    REQUIRE(obj.get<String>(role_col) == *expected);
                }
                else {
                    REQUIRE(!objkey);
                }
            }
        };
        // Update the rules so employees are not allowed and removed from view
        // This will also remove the existing changes to the 10 employee records
        // and the 5 new employee records.
        size_t num_to_create = 5;
        // Update 10 employees to worker-bee and create 5 new employees
        update_records(test_realm, "employee", emp_ids, 10, num_to_create);
        // Update 5 managers to worker-bee and create 5 new managers
        update_records(test_realm, "manager", mgr_ids, 5, num_to_create);
        // Update the allowed roles to "manager" and "worker-bee"
        do_update_rules({{"role", {{"$in", {"manager", "worker-bee"}}}}});
        // Resume the session and verify none of the new/modified employee
        // records are present
        test_realm->sync_session()->resume();
        // Verify none of the employee object IDs are present in the local data
        do_verify(test_realm, params.num_mgrs + num_to_create, emp_ids, std::nullopt);
        // Verify all of the manager object IDs are present in the local data
        do_verify(test_realm, params.num_mgrs + num_to_create, mgr_ids, "worker-bee");

        // Update the allowed roles to "employee"
        do_update_rules({{"role", "employee"}});
        // Verify the items with the object IDs are still listed as employees
        do_verify(test_realm, params.num_emps, emp_ids, "employee");

        // Tear down the app since some of the records were added and modified
        harness.reset();
    }
}

TEST_CASE("flx: role changes during bootstrap complete successfully", "[sync][flx][baas][role change][bootstrap]") {
    auto logger = util::Logger::get_default_logger();

    // 150 emps, 25 mgrs, 10 dirs
    // 10 objects before flush
    // 1536 download soft max bytes
    HarnessParams params{};
    params.max_download_bytes = 1536; // 1.5 KB

    // Only create the harness one time for all the sections under this test case
    static std::unique_ptr<FLXSyncTestHarness> harness;
    if (!harness) {
        harness = setup_harness("flx_role_change_during_bs", params);
    }

    // Get the current rules so it can be updated during the test
    auto& app_session = harness->session().app_session();
    auto default_rule = app_session.admin_api.get_default_rule(app_session.server_app_id);

    // Make sure the rules are reset back to the original value (all records allowed)
    update_role(default_rule, true);
    logger->debug("ROLE CHANGE: Initial rule definitions: %1", default_rule);
    REQUIRE(app_session.admin_api.update_default_rule(app_session.server_app_id, default_rule));

    enum BootstrapTestState {
        not_ready,
        start,
        ident_sent,
        reconnect_received,
        downloading,
        downloaded,
        integrating,
        integration_complete,
        complete
    };

    BootstrapTestState update_role_state = BootstrapTestState::not_ready;
    int update_msg_count = -1;
    int bootstrap_count = 0;
    int bootstrap_msg_count = 0;
    bool session_restarted = false;
    TestingStateMachine<BootstrapTestState> bootstrap_state(BootstrapTestState::not_ready);

    auto setup_config_callbacks = [&](SyncTestFile& config) {
        // Use the sync client event hook to check for the error received and for tracking
        // download messages and bootstraps
        config.sync_config->on_sync_client_event_hook = [&](std::weak_ptr<SyncSession>,
                                                            const SyncClientHookData& data) {
            bootstrap_state.transition_with([&](BootstrapTestState cur_state) -> std::optional<BootstrapTestState> {
                using BatchState = sync::DownloadBatchState;
                using Event = SyncClientHookEvent;
                // Keep track of the number of bootstraps that have occurred, regardless of cur state
                if (data.event == Event::BootstrapProcessed) {
                    bootstrap_count++;
                }

                // Has the test started?
                if (cur_state == BootstrapTestState::not_ready)
                    return std::nullopt;

                std::optional<BootstrapTestState> new_state;

                switch (data.event) {
                    case Event::IdentMessageSent:
                        new_state = BootstrapTestState::ident_sent;
                        break;

                    case Event::ErrorMessageReceived:
                        REQUIRE(data.error_info->raw_error_code ==
                                static_cast<int>(sync::ProtocolError::session_closed));
                        REQUIRE(data.error_info->server_requests_action ==
                                sync::ProtocolErrorInfo::Action::Transient);
                        REQUIRE_FALSE(data.error_info->is_fatal);
                        session_restarted = true;
                        break;

                    // A bootstrap message was processed
                    case Event::BootstrapMessageProcessed:
                        bootstrap_msg_count++;
                        if (data.batch_state == BatchState::LastInBatch) {
                            new_state = BootstrapTestState::downloaded;
                        }
                        else if (data.batch_state == BatchState::MoreToCome) {
                            new_state = BootstrapTestState::downloading;
                        }
                        break;

                    case SyncClientHookEvent::DownloadMessageIntegrated:
                        if (data.batch_state == BatchState::SteadyState) {
                            break;
                        }
                        REQUIRE((cur_state == BootstrapTestState::downloaded ||
                                 cur_state == BootstrapTestState::integrating));
                        new_state = BootstrapTestState::integrating;
                        break;

                    // The bootstrap has been received and processed
                    case Event::BootstrapProcessed:
                        REQUIRE(cur_state == BootstrapTestState::integrating);
                        new_state = BootstrapTestState::integration_complete;
                        break;

                    default:
                        break;
                }
                // If the state is changing and a role change is requested for that state, then
                // update the role now.
                if (new_state && new_state == update_role_state &&
                    update_role_state != BootstrapTestState::not_ready && bootstrap_msg_count >= update_msg_count) {
                    logger->debug("ROLE CHANGE: Updating rule definitions: %1", default_rule);
                    REQUIRE(app_session.admin_api.update_default_rule(app_session.server_app_id, default_rule));
                    update_role_state = BootstrapTestState::not_ready; // Bootstrap tracking is complete
                }
                return new_state;
            });
            return SyncClientHookAction::NoAction;
        };

        // Add client reset callback to verify a client reset doesn't happen
        config.sync_config->notify_before_client_reset = [&](std::shared_ptr<Realm>) {
            // Make sure a client reset did not occur while waiting for the role change to
            // be applied
            FAIL("Client reset is not expected when the role/rules/permissions are changed");
        };
    };

    auto setup_test_params = [&](BootstrapTestState change_state, int msg_count = -1) {
        // Use the state machine mutex to protect the variables shared with the event hook
        bootstrap_state.transition_with([&](BootstrapTestState) {
            bootstrap_count = 0;              // Reset the bootstrap count
            bootstrap_msg_count = 0;          // Reset the bootstrap msg count
            update_role_state = change_state; // State where the role change should be sent
            update_msg_count = msg_count;     // Wait for this many download messages
            return BootstrapTestState::start; // Update to start to begin tracking state
        });
    };

    // Create the shared realm and configure a subscription for the manager and director records
    auto config = harness->make_test_file();
    setup_config_callbacks(config);

    SECTION("Role change during initial schema bootstrap") {
        // Trigger the role change after the IDENT message is sent so the role change
        // bootstrap will occur while the new realm is receiving the schema bootstrap
        setup_test_params(BootstrapTestState::ident_sent);
        auto realm_1 = Realm::get_shared_realm(config);
        REQUIRE(!wait_for_download(*realm_1));
        REQUIRE(!wait_for_upload(*realm_1));
        // Use the state machine mutex to protect the variables shared with the event hook
        bootstrap_state.transition_with([&](BootstrapTestState) {
            // Only the initial schema bootstrap with 1 download message should take place
            // without restarting the session
            REQUIRE(bootstrap_count == 1);
            REQUIRE(bootstrap_msg_count == 1);
            // Bootstrap was not triggered, since it's a new file ident
            REQUIRE_FALSE(session_restarted);
            return std::nullopt;
        });
    }
    SECTION("Role change during subscription bootstrap") {
        auto realm_1 = Realm::get_shared_realm(config);
        bool initial_subscription = GENERATE(false, true);

        if (initial_subscription) {
            auto table = realm_1->read_group().get_table("class_Person");
            auto role_col = table->get_column_key("role");
            auto sub_query = Query(table).equal(role_col, "manager").Or().equal(role_col, "director");
            auto new_subs = realm_1->get_latest_subscription_set().make_mutable_copy();
            new_subs.insert_or_assign(sub_query);
            auto subs = new_subs.commit();

            // Wait for subscription bootstrap to and sync to complete
            subs.get_state_change_notification(sync::SubscriptionSet::State::Complete).get();

            // Verify the data was downloaded and only includes managers and directors
            bool update_successful = wait_and_verify(realm_1, 0, params.num_mgrs, params.num_dirs);
            REQUIRE(update_successful);
        }

        // The test will update the rule to change access from all records to only the employee
        // records while a new subscription for all Person entries is being bootstrapped.
        update_role(default_rule, {{"role", "employee"}});

        // Set up a new bootstrap while offline
        realm_1->sync_session()->shutdown_and_wait();
        {
            // Set up a subscription for the Person table
            auto table = realm_1->read_group().get_table("class_Person");
            auto new_subs = realm_1->get_latest_subscription_set().make_mutable_copy();
            new_subs.clear();
            new_subs.insert_or_assign(Query(table));
            auto subs = new_subs.commit();
            // Each one of these sections runs the role change bootstrap test with different
            // settings for the `update_role_state` which indicates at which stage during
            // the bootstrap where the role change will occur.
            SECTION("Role change occurs during bootstrap download") {
                logger->debug("ROLE CHANGE: Role change during %1 query bootstrap download",
                              initial_subscription ? "second" : "first");
                // Wait for the downloading state and 3 messages have been downloaded
                setup_test_params(BootstrapTestState::downloading, 3);
            }
            SECTION("Role change occurs after bootstrap downloaded") {
                logger->debug("ROLE CHANGE: Role change after %1 query bootstrap download",
                              initial_subscription ? "second" : "first");
                // Wait for the downloaded state
                setup_test_params(BootstrapTestState::downloaded);
            }
            SECTION("Role change occurs during bootstrap integration") {
                logger->debug("ROLE CHANGE: Role change during %1 query bootstrap integration",
                              initial_subscription ? "second" : "first");
                // Wait for bootstrap messages to be integrated
                setup_test_params(BootstrapTestState::integrating);
            }
            SECTION("Role change occurs after bootstrap integration") {
                logger->debug("ROLE CHANGE: Role change after %1 query bootstrap integration",
                              initial_subscription ? "second" : "first");
                // Wait for the end of the bootstrap integration
                setup_test_params(BootstrapTestState::integration_complete);
            }

            // Resume the session an wait for subscription bootstrap to and sync to complete
            realm_1->sync_session()->resume();
            subs.get_state_change_notification(sync::SubscriptionSet::State::Complete).get();

            // Verify the data was downloaded/updated (only the employee records)
            bool update_successful = wait_and_verify(realm_1, params.num_emps, 0, 0);

            // Use the state machine mutex to protect the variables shared with the event hook
            bootstrap_state.transition_with([&](BootstrapTestState) {
                if (!update_successful) {
                    FAIL("Failed to wait for realm update during role change bootstrap");
                }
                // Expecting two bootstraps have occurred (role change and subscription)
                // and the session was restarted with 200 error.
                REQUIRE(session_restarted);
                REQUIRE(bootstrap_count == 2);
                REQUIRE(bootstrap_msg_count > 1);
                return std::nullopt;
            });
        }
    }
    // ----------------------------------------------------------------
    // Add new sections before this one
    // ----------------------------------------------------------------
    SECTION("teardown") {
        // Since the harness is reused for each of the role change during bootstrap tests,
        // this section will run last to destroy the harness after the tests are complete.
        harness.reset();
    }
}

TEST_CASE("flx: role changes during client resets complete successfully",
          "[sync][flx][baas][role change][client reset]") {
    auto logger = util::Logger::get_default_logger();

    // 150 emps, 25 mgrs, 25 dirs
    // 10 objects before flush
    // 512 download soft max bytes
    HarnessParams params{};
    params.num_dirs = 25;
    params.max_download_bytes = 512;

    // Only create the harness one time for all the sections under this test case
    static std::unique_ptr<FLXSyncTestHarness> harness;
    if (!harness) {
        harness = setup_harness("flx_role_change_during_cr", params);
    }

    SECTION("Role change during client reset") {
        // Get the current rules so it can be updated during the test
        auto& app_session = harness->session().app_session();
        auto default_rule = app_session.admin_api.get_default_rule(app_session.server_app_id);

        enum ClientResetTestState {
            not_ready,
            start,
            // Primary sync session states before client reset
            bind_before_cr_session,
            // Fresh realm download sync session states
            cr_session_ident,
            cr_session_downloading,
            cr_session_downloaded,
            cr_session_integrating,
            cr_session_integrated,
            // Primary sync session states after fresh realm download
            bind_after_cr_session,
            merged_after_cr_session,
            ident_after_cr_session,
        };

        bool client_reset_error = false;
        bool role_change_error = false;
        ClientResetTestState update_role_state = ClientResetTestState::not_ready;
        int client_reset_count = 0;
        bool skip_role_change_check = false;
        TestingStateMachine<ClientResetTestState> client_reset_state(ClientResetTestState::not_ready);

        // Set the state where the role change will be triggered
        constexpr bool skip_role_change_error_check = true;
        auto setup_test_params = [&](ClientResetTestState change_state, bool skip_role_error = false) {
            client_reset_state.transition_with([&](ClientResetTestState) {
                client_reset_error = false;       // Reset the client reset error tracking
                role_change_error = false;        // Reset the role change error tracking
                client_reset_count = 0;           // Reset the client reset error count
                update_role_state = change_state; // State where the role change should be sent
                // If the role change check is skipped, the test will not look for the role change error
                // Depending on when the role change error is received (e.g. session deactivating), it
                // may not be successfully or reliably captured with the event hook.
                skip_role_change_check = skip_role_error;
                return ClientResetTestState::start; // Update to start to begin tracking state
            });
        };

        auto setup_config_callbacks = [&](SyncTestFile& config) {
            // Use the sync client event hook to check for the error received and for tracking
            // download messages and bootstraps
            config.sync_config->on_sync_client_event_hook = [&](std::weak_ptr<SyncSession> weak_session,
                                                                const SyncClientHookData& data) {
                bool is_fresh_path;
                auto session = weak_session.lock();
                if (!session) {
                    // Session is being closed while this function was called
                    return SyncClientHookAction::NoAction;
                }
                is_fresh_path = _impl::client_reset::is_fresh_path(session->path());

                client_reset_state.transition_with(
                    [&](ClientResetTestState cur_state) -> std::optional<ClientResetTestState> {
                        using BatchState = sync::DownloadBatchState;
                        using Event = SyncClientHookEvent;

                        // Exit early if the test/state tracking hasn't started
                        if (cur_state == ClientResetTestState::not_ready)
                            return std::nullopt;

                        // If an error occurred, check to see if it is a client reset error or the
                        // session restart (due to the role change).
                        if (data.event == Event::ErrorMessageReceived) {
                            REQUIRE(data.error_info);
                            // Client reset error occurred
                            if (data.error_info->raw_error_code ==
                                static_cast<int>(sync::ProtocolError::bad_client_file_ident)) {
                                REQUIRE(data.error_info->should_client_reset);
                                REQUIRE(data.error_info->server_requests_action ==
                                        sync::ProtocolErrorInfo::Action::ClientReset);
                                REQUIRE(data.error_info->is_fatal);
                                logger->debug("ROLE CHANGE: client reset error received");
                                client_reset_error = true;
                            }
                            // 200 error is received to start role change bootstrap
                            else if (data.error_info->raw_error_code ==
                                     static_cast<int>(sync::ProtocolError::session_closed)) {
                                REQUIRE(data.error_info->server_requests_action ==
                                        sync::ProtocolErrorInfo::Action::Transient);
                                REQUIRE_FALSE(data.error_info->is_fatal);
                                logger->debug("ROLE CHANGE: role change error received");
                                role_change_error = true;
                            }
                            // Other errors are not expected
                            else {
                                FAIL(util::format("Unexpected %1 error occurred during role change test: [%2] %3",
                                                  data.error_info->is_fatal ? "fatal" : "non-fatal",
                                                  data.error_info->raw_error_code, data.error_info->message));
                            }
                            return std::nullopt;
                        }
                        std::optional<ClientResetTestState> new_state = std::nullopt;
                        // Once the client reset progresses to the state that matches the `update_role_state`
                        // value, the role change will occur and `update_role_state` will be cleared.
                        if (update_role_state == ClientResetTestState::not_ready) {
                            // Once update_role_state is cleared, tracking the state is no longer necessary
                            return std::nullopt;
                        }
                        // Track the state of the client reset progress, from receiving the client reset error,
                        // to downloading the fresh realm, to the client reset diff when the primary session
                        // restarts. The state is used to kick off the role change when the client reset state
                        // reaches the state specified by `update_role_state`. Once the role change has been
                        // initiated, `update_role_state` will be cleared and the state will no longer be
                        // tracked for the rest of the test (other than looking for the errors above).
                        switch (data.event) {
                            case Event::BindMessageSent:
                                // "bind_before_cr_session" - BIND msg sent prior to receiving client reset error
                                if (cur_state == ClientResetTestState::start) {
                                    REQUIRE_FALSE(client_reset_error);
                                    new_state = ClientResetTestState::bind_before_cr_session;
                                }
                                // "bind_after_cr_session" - BIND msg sent after fresh realm download session is
                                // complete
                                else if (cur_state == ClientResetTestState::cr_session_integrated) {
                                    REQUIRE(client_reset_error);
                                    new_state = ClientResetTestState::bind_after_cr_session;
                                }
                                break;
                            case Event::ClientResetMergeComplete:
                                // "merged_after_cr_session" - client reset diff is complete
                                REQUIRE(cur_state == ClientResetTestState::bind_after_cr_session);
                                REQUIRE_FALSE(is_fresh_path);
                                REQUIRE(client_reset_error);
                                new_state = ClientResetTestState::merged_after_cr_session;
                                break;
                            case Event::IdentMessageSent:
                                // Skip the IDENT message if the client reset error hasn't occurred
                                if (!client_reset_error)
                                    break;
                                // "cr_session_ident" - IDENT msg sent for the fresh realm download session
                                if (cur_state == ClientResetTestState::bind_before_cr_session) {
                                    REQUIRE(is_fresh_path);
                                    new_state = ClientResetTestState::cr_session_ident;
                                }
                                // "ident_after_cr_session" - IDENT msg sent after client reset diff is complete
                                else if (cur_state == ClientResetTestState::merged_after_cr_session) {
                                    REQUIRE_FALSE(is_fresh_path);
                                    new_state = ClientResetTestState::ident_after_cr_session;
                                }
                                break;
                            // A bootstrap message was processed by the client reset session
                            case Event::BootstrapMessageProcessed:
                                // "cr_session_downloaded" - last DOWNLOAD message received of fresh realm bootstrap
                                if (!client_reset_error || data.batch_state == BatchState::SteadyState)
                                    break;
                                if (data.batch_state == BatchState::LastInBatch) {
                                    new_state = ClientResetTestState::cr_session_downloaded;
                                }
                                // "cr_session_downloading" - first DOWNLOAD message received of fresh realm bootstrap
                                else if (data.batch_state == BatchState::MoreToCome) {
                                    new_state = ClientResetTestState::cr_session_downloading;
                                }
                                break;
                            case Event::DownloadMessageIntegrated:
                                if (!client_reset_error)
                                    break;
                                // "cr_session_integrating" - fresh realm bootstrap is being integrated
                                new_state = ClientResetTestState::cr_session_integrating;
                                break;
                            // The client reset session has processed the bootstrap
                            case Event::BootstrapProcessed:
                                if (!client_reset_error)
                                    break;
                                // "cr_session_integrating" - fresh realm bootstrap integration is complete
                                new_state = ClientResetTestState::cr_session_integrated;
                                break;
                            default:
                                break;
                        }

                        // If a new state is specified, check to see if it matches the value of `update_role_state`
                        // and perform the role change if the two match. Once the role change has been sent, clear
                        // `update_role_state` since the state doesn't need to be tracked anymore.
                        if (new_state && update_role_state && *new_state == update_role_state) {
                            logger->debug("ROLE CHANGE: Updating rule definitions: %1", default_rule);
                            REQUIRE(
                                app_session.admin_api.update_default_rule(app_session.server_app_id, default_rule));
                            update_role_state = ClientResetTestState::not_ready; // Bootstrap tracking is complete
                        }
                        return new_state;
                    });
                return SyncClientHookAction::NoAction;
            };

            // Add client reset callback to count the number of times a client reset occurred (should be 1)
            config.sync_config->notify_before_client_reset = [&](std::shared_ptr<Realm>) {
                client_reset_state.transition_with([&](ClientResetTestState) {
                    // Save that a client reset took place
                    client_reset_count++;
                    return std::nullopt;
                });
            };

            config.sync_config->error_handler = [](std::shared_ptr<SyncSession>, SyncError error) {
                // Only expecting a client reset error to be reported
                if (error.status != ErrorCodes::SyncClientResetRequired)
                    FAIL(util::format("Unexpected error received by error handler: %1", error.status));
            };
        };

        // Start with the role/rules set to only allow manager and director records
        update_role(default_rule, {{"role", {{"$in", {"manager", "director"}}}}});
        logger->debug("ROLE CHANGE: Initial rule definitions: %1", default_rule);
        REQUIRE(app_session.admin_api.update_default_rule(app_session.server_app_id, default_rule));

        auto config_1 = harness->make_test_file();
        auto&& [reset_future, reset_handler] = reset_utils::make_client_reset_handler();
        config_1.sync_config->notify_after_client_reset = std::move(reset_handler);
        config_1.sync_config->client_resync_mode = ClientResyncMode::Recover;
        setup_config_callbacks(config_1);

        auto realm_1 = Realm::get_shared_realm(config_1);
        {
            // Set up a default subscription for all records of the Person class
            auto table = realm_1->read_group().get_table("class_Person");
            auto new_subs = realm_1->get_latest_subscription_set().make_mutable_copy();
            new_subs.clear();
            new_subs.insert_or_assign(Query(table));
            auto subs = new_subs.commit();
            subs.get_state_change_notification(sync::SubscriptionSet::State::Complete).get();
            bool update_successful = wait_and_verify(realm_1, 0, params.num_mgrs, params.num_dirs);
            REQUIRE(update_successful);
        }
        // During the test, the role change will be updated from only allowing manager and director
        // records to only allowing employee records while a client reset is in progress.
        update_role(default_rule, {{"role", "employee"}});
        // Force a client reset to occur the next time the session connects
        reset_utils::trigger_client_reset(app_session, realm_1);

        // Each one of these sections runs the role change client reset test with the different
        // setting for the `update_role_state` which indicates which stage during the client reset
        // where the role change will occur. The verification of the session restart error (200)
        // is difficult to catch at some stages, and the test will skip the 200 error verification.
        SECTION("Role change occurs as soon as the BIND message is sent just before the client reset is started") {
            logger->debug("ROLE CHANGE: Role change occurs as soon as the BIND message is sent just before the "
                          "client reset is started");
            setup_test_params(ClientResetTestState::bind_before_cr_session, skip_role_change_error_check);
        }
        SECTION("Role change occurs after the IDENT message is sent for the fresh realm download session") {
            logger->debug("ROLE CHANGE: Role change occurs after the IDENT message is sent for the fresh realm "
                          "download session");
            setup_test_params(ClientResetTestState::cr_session_ident);
        }
        SECTION("Role change occurs while the fresh realm bootstrap is being downloaded") {
            logger->debug("ROLE CHANGE: Role change occurs while the fresh realm bootstrap is being downloaded");
            setup_test_params(ClientResetTestState::cr_session_downloading);
        }
        SECTION("Role change occurs as soon as the fresh realm bootstrap download is complete") {
            logger->debug(
                "ROLE CHANGE: Role change occurs as soon as the fresh realm bootstrap download is complete");
            setup_test_params(ClientResetTestState::cr_session_downloaded);
        }
        SECTION("Role change occurs while the fresh realm bootstrap is being integrated") {
            logger->debug("ROLE CHANGE: Role change occurs while the fresh realm bootstrap is being integrated");
            // Trigger the role change while the subscription bootstrap changeset
            // integration for the fresh realm sync session is in progress
            setup_test_params(ClientResetTestState::cr_session_integrating);
        }
        SECTION("Role change occurs after fresh realm bootstrap is integrated") {
            logger->debug("ROLE CHANGE: Role change occurs after fresh realm bootstrap is integrated");
            setup_test_params(ClientResetTestState::cr_session_integrated);
        }
        SECTION("Role change occurs after BIND message is sent for the primary sync session") {
            logger->debug("ROLE CHANGE: Role change occurs after BIND message is sent for the primary sync session");
            setup_test_params(ClientResetTestState::bind_after_cr_session, skip_role_change_error_check);
        }
        SECTION("Role change occurs as soon as the client reset diff is complete") {
            logger->debug("ROLE CHANGE: Role change occurs as soon as the client reset diff is complete");
            setup_test_params(ClientResetTestState::merged_after_cr_session, skip_role_change_error_check);
        }
        SECTION("Role change occurs after IDENT message is sent after client reset merge is complete") {
            logger->debug(
                "ROLE CHANGE: Role change occurs after IDENT message is sent after client reset merge is complete");
            // Trigger role change
            // Trigger the role change after the IDENT message is sent after the client reset
            // and before the MARK response is received from the server to close out the
            // client reset.
            setup_test_params(ClientResetTestState::ident_after_cr_session);
        }

        // Client reset will happen when session tries to reconnect
        realm_1->sync_session()->restart_session();
        auto resync_mode = wait_for_future(std::move(reset_future)).get();

        // Verify the data was downloaded/updated (only the employee records)
        bool update_successful = wait_and_verify(realm_1, params.num_emps, 0, 0);

        client_reset_state.transition_with([&](ClientResetTestState) {
            if (!update_successful) {
                FAIL("Failed to wait for realm update during role change bootstrap");
            }
            // Using the state machine mutex to protect the event hook shared variables
            // Verify that the client reset occurred
            REQUIRE(resync_mode == ClientResyncMode::Recover);
            REQUIRE(client_reset_error);
            REQUIRE(client_reset_count == 1);
            // Unless skip_role_change_check is set, verify role change error occurred as well
            REQUIRE((role_change_error || skip_role_change_check));
            return std::nullopt;
        });
    }
    // ----------------------------------------------------------------
    // Add new sections before this one
    // ----------------------------------------------------------------
    SECTION("teardown") {
        // Since the harness is reused for each of the role change client reset tests, this
        // section will run last to destroy the harness after the tests are complete.
        harness.reset();
    }
}

#endif // REALM_ENABLE_AUTH_TESTS

realm / realm-core / 2517

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous