thomas.goyne_275

Committed 09 Apr 2024 03:33AM UTC coverage: 92.608% (+0.5%) from 92.088%

Build # thomas.goyne_275

Build Type

Pull #7300

Evergreen

Committed by

tgoyne

Commit Message

Extract some duplicated code in PushClient

Pull Request Pull Request #7300: Rework sync user handling and metadata storage

Run Details

102672 of 194970 branches covered (52.66%)

3165 of 3247 new or added lines in 46 files covered. (97.47%)

34 existing lines in 9 files now uncovered.

249420 of 269329 relevant lines covered (92.61%)

45087511.34 hits per line

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

99.79

/test/object-store/c_api/c_api.cpp

////////////////////////////////////////////////////////////////////////////
//
// Copyright 2019 Realm 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.
//
////////////////////////////////////////////////////////////////////////////

#include "../util/test_file.hpp"
#include "../util/event_loop.hpp"

#include <realm.h>

#include <realm/object-store/c_api/conversion.hpp>
#include <realm/object-store/c_api/realm.hpp>
#include <realm/object-store/c_api/types.hpp>
#include <realm/object-store/impl/object_accessor_impl.hpp>
#include <realm/object-store/object.hpp>
#include <realm/object-store/sync/generic_network_transport.hpp>
#include <realm/sync/binding_callback_thread_observer.hpp>
#include <realm/util/base64.hpp>
#include <realm/util/logger.hpp>

#include <catch2/catch_all.hpp>

#include <cstring>
#include <numeric>
#include <thread>
#include <fstream>

#if REALM_ENABLE_SYNC
#include <util/sync/flx_sync_harness.hpp>
#include <util/sync/sync_test_utils.hpp>
#include "../util/test_path.hpp"
#include "../util/unit_test_transport.hpp"

#include <realm/object-store/sync/app_utils.hpp>
#include <realm/object-store/sync/sync_user.hpp>
#include <realm/sync/client_base.hpp>
#include <realm/sync/network/websocket.hpp>
#include <realm/sync/protocol.hpp>
#include <realm/util/misc_errors.hpp>

#include <external/json/json.hpp>
#endif

#if REALM_ENABLE_AUTH_TESTS
#include "util/sync/baas_admin_api.hpp"
#endif

using namespace realm;

extern "C" int realm_c_api_tests(const char* file);

namespace {
template <class T>
T checked(T x)
{
    if (!x) {
        realm_error_t err_info;
        if (realm_get_last_error(&err_info)) {
            FAIL(err_info.message);
        }
    }
    return x;
}

realm_value_t rlm_str_val(const char* str)
{
    realm_value_t val;
    val.type = RLM_TYPE_STRING;
    val.string = realm_string_t{str, std::strlen(str)};
    return val;
}

realm_value_t rlm_int_val(int64_t n)
{
    realm_value_t val;
    val.type = RLM_TYPE_INT;
    val.integer = n;
    return val;
}

realm_value_t rlm_float_val(float fnum)
{
    realm_value_t val;
    val.type = RLM_TYPE_FLOAT;
    val.fnum = fnum;
    return val;
}

realm_value_t rlm_double_val(double dnum)
{
    realm_value_t val;
    val.type = RLM_TYPE_DOUBLE;
    val.dnum = dnum;
    return val;
}

realm_value_t rlm_object_id_val(const char* hex_digits)
{
    size_t len = strlen(hex_digits);
    REALM_ASSERT(len == 12);
    realm_value_t val;
    val.type = RLM_TYPE_OBJECT_ID;
    for (size_t i = 0; i < 12; ++i) {
        val.object_id.bytes[i] = uint8_t(hex_digits[i]);
    }
    return val;
}

realm_value_t rlm_timestamp_val(int64_t seconds, int32_t nanoseconds)
{
    realm_value_t val;
    val.type = RLM_TYPE_TIMESTAMP;
    val.timestamp.seconds = seconds;
    val.timestamp.nanoseconds = nanoseconds;
    return val;
}

realm_value_t rlm_bool_val(bool b)
{
    realm_value_t val;
    val.type = RLM_TYPE_BOOL;
    val.boolean = b;
    return val;
}

realm_value_t rlm_decimal_val(double d)
{
    realm_value_t val;
    val.type = RLM_TYPE_DECIMAL128;

    realm::Decimal128 dec{d};
    val.decimal128.w[0] = dec.raw()->w[0];
    val.decimal128.w[1] = dec.raw()->w[1];

    return val;
}

realm_value_t rlm_decimal_nan()
{
    realm_value_t val;
    val.type = RLM_TYPE_DECIMAL128;

    realm::Decimal128 dec = realm::Decimal128::nan("0");
    val.decimal128.w[0] = dec.raw()->w[0];
    val.decimal128.w[1] = dec.raw()->w[1];

    return val;
}

realm_value_t rlm_uuid_val(const char* str)
{
    realm_value_t val;
    val.type = RLM_TYPE_UUID;
    realm::UUID uuid{realm::StringData{str}};
    auto bytes = uuid.to_bytes();
    for (size_t i = 0; i < 16; ++i) {
        val.uuid.bytes[i] = bytes[i];
    }
    return val;
}

realm_value_t rlm_binary_val(const uint8_t* bytes, size_t len)
{
    realm_value_t val;
    val.type = RLM_TYPE_BINARY;
    val.binary.size = len;
    val.binary.data = bytes;
    return val;
}

realm_value_t rlm_link_val(realm_class_key_t cls, realm_object_key_t obj)
{
    realm_value_t val;
    val.type = RLM_TYPE_LINK;
    val.link.target_table = cls;
    val.link.target = obj;
    return val;
}

realm_value_t rlm_null()
{
    realm_value_t null;
    null.type = RLM_TYPE_NULL;
    return null;
}

std::string rlm_stdstr(realm_value_t val)
{
    CHECK(val.type == RLM_TYPE_STRING);
    return std::string(val.string.data, 0, val.string.size);
}

bool rlm_val_eq(realm_value_t lhs, realm_value_t rhs)
{
    if (lhs.type != rhs.type)
        return false;

    switch (lhs.type) {
        case RLM_TYPE_NULL:
        case RLM_TYPE_LIST:
        case RLM_TYPE_DICTIONARY:
            return true;
        case RLM_TYPE_INT:
            return lhs.integer == rhs.integer;
        case RLM_TYPE_BOOL:
            return lhs.boolean == rhs.boolean;
        case RLM_TYPE_STRING:
            return strncmp(lhs.string.data, rhs.string.data, lhs.string.size) == 0;
        case RLM_TYPE_BINARY:
            return memcmp(lhs.binary.data, rhs.binary.data, lhs.binary.size) == 0;
        case RLM_TYPE_TIMESTAMP:
            return lhs.timestamp.seconds == rhs.timestamp.seconds &&
                   lhs.timestamp.nanoseconds == rhs.timestamp.nanoseconds;
        case RLM_TYPE_FLOAT:
            return lhs.fnum == rhs.fnum;
        case RLM_TYPE_DOUBLE:
            return lhs.dnum == rhs.dnum;
        case RLM_TYPE_DECIMAL128:
            return lhs.decimal128.w[0] == rhs.decimal128.w[0] && lhs.decimal128.w[1] == rhs.decimal128.w[1];
        case RLM_TYPE_OBJECT_ID:
            return memcmp(lhs.object_id.bytes, rhs.object_id.bytes, 12) == 0;
        case RLM_TYPE_LINK:
            return lhs.link.target_table == rhs.link.target_table && lhs.link.target == rhs.link.target;
        case RLM_TYPE_UUID:
            return memcmp(lhs.uuid.bytes, rhs.uuid.bytes, 16) == 0;
    }
    REALM_TERMINATE("");
}

struct RealmReleaseDeleter {
    void operator()(void* ptr)
    {
        realm_release(ptr);
    }
};

template <class T>
using CPtr = std::unique_ptr<T, RealmReleaseDeleter>;

template <class T>
CPtr<T> cptr(T* ptr)
{
    return CPtr<T>{ptr};
}

template <class T>
CPtr<T> cptr_checked(T* ptr)
{
    return cptr(checked(ptr));
}

template <class T>
CPtr<T> clone_cptr(const CPtr<T>& ptr)
{
    void* clone = realm_clone(ptr.get());
    return CPtr<T>{static_cast<T*>(clone)};
}

template <class T>
CPtr<T> clone_cptr(const T* ptr)
{
    void* clone = realm_clone(ptr);
    return CPtr<T>{static_cast<T*>(clone)};
}
} // anonymous namespace

#define CHECK_ERR(err)                                                                                               \
    do {                                                                                                             \
        realm_error_t _err;                                                                                          \
        _err.message = "";                                                                                           \
        _err.error = RLM_ERR_NONE;                                                                                   \
        CHECK(realm_get_last_error(&_err));                                                                          \
        if (_err.error != err) {                                                                                     \
            CHECK(_err.error == err);                                                                                \
            CHECK(std::string{_err.message} == "");                                                                  \
        }                                                                                                            \
        else {                                                                                                       \
            realm_clear_last_error();                                                                                \
        }                                                                                                            \
    } while (false);

#define CHECK_ERR_CAT(err, category)                                                                                 \
    do {                                                                                                             \
        realm_error_t _err;                                                                                          \
        _err.message = "";                                                                                           \
        _err.categories = 0;                                                                                         \
        _err.error = RLM_ERR_NONE;                                                                                   \
        CHECK(realm_get_last_error(&_err));                                                                          \
        CHECK((_err.categories ^ category) == 0);                                                                    \
        if (_err.error != err) {                                                                                     \
            CHECK(_err.error == err);                                                                                \
            CHECK(std::string{_err.message} == "");                                                                  \
        }                                                                                                            \
        else {                                                                                                       \
            realm_clear_last_error();                                                                                \
        }                                                                                                            \
    } while (false);

TEST_CASE("C API (C)", "[c_api]") {
    TestFile file;
    CHECK(realm_c_api_tests(file.path.c_str()) == 0);
}

TEST_CASE("C API (non-database)", "[c_api]") {
    SECTION("realm_get_library_version_numbers()") {
        int major, minor, patch;
        const char* extra;
        realm_get_library_version_numbers(&major, &minor, &patch, &extra);

        CHECK(major == REALM_VERSION_MAJOR);
        CHECK(minor == REALM_VERSION_MINOR);
        CHECK(patch == REALM_VERSION_PATCH);
        CHECK(std::string{extra} == REALM_VERSION_EXTRA);
    }

    SECTION("realm_get_library_version()") {
        const char* version = realm_get_library_version();
        CHECK(std::string{version} == REALM_VERSION_STRING);
    }

    SECTION("realm_release(NULL)") {
        // Just check that it doesn't crash.
        realm_release(nullptr);
    }

    SECTION("realm_get_last_error()") {
        CHECK(!realm_get_last_error(nullptr));
        CHECK(!realm_clear_last_error());

        auto synthetic = []() {
            throw std::runtime_error("Synthetic error");
        };
        CHECK(!realm_wrap_exceptions(synthetic));

        realm_error_t err;
        CHECK(realm_get_last_error(&err));
        CHECK(err.error == RLM_ERR_RUNTIME);
        CHECK(std::string{err.message} == "Synthetic error");
        realm_clear_last_error();
    }

    SECTION("realm_get_last_error_as_async_error()") {
        CHECK(!realm_get_last_error_as_async_error());

        auto synthetic = []() {
            throw std::runtime_error("Synthetic error");
        };
        CHECK(!realm_wrap_exceptions(synthetic));

        realm_async_error_t* async_err = realm_get_last_error_as_async_error();
        CHECK(async_err);

        realm_error_t err;
        CHECK(realm_get_async_error(async_err, &err));
        CHECK_FALSE(realm_get_async_error(nullptr, &err));

        CHECK(err.error == RLM_ERR_RUNTIME);
        CHECK(std::string{err.message} == "Synthetic error");

        SECTION("realm_clone()") {
            auto cloned = clone_cptr(async_err);
            CHECK(realm_equals(async_err, cloned.get()));
            realm_error_t err2;
            CHECK(realm_get_async_error(cloned.get(), &err2));
            CHECK(err2.error == RLM_ERR_RUNTIME);
            CHECK(std::string{err2.message} == "Synthetic error");
        }

        SECTION("realm_equals()") {
            auto config = cptr(realm_config_new());
            CHECK(!realm_equals(config.get(), async_err));
            CHECK(!realm_equals(async_err, config.get()));
        }

        realm_release(async_err);
        realm_clear_last_error();
    }

    SECTION("realm_clear_last_error()") {
        auto synthetic = []() {
            throw std::runtime_error("Synthetic error");
        };
        CHECK(!realm_wrap_exceptions(synthetic));

        CHECK(realm_clear_last_error());
        CHECK(!realm_get_last_error(nullptr));
    }

    SECTION("realm_clone() error") {
        // realm_config_t is not clonable
        auto config = cptr(realm_config_new());
        CHECK(!realm_clone(config.get()));
        CHECK_ERR(RLM_ERR_NOT_CLONABLE);
    }

    SECTION("realm_create_thread_safe_reference() error") {
        // realm_config_t is not sendable between threads
        auto config = cptr(realm_config_new());
        CHECK(!realm_create_thread_safe_reference(config.get()));
        CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
    }

    SECTION("realm_is_frozen() false by default") {
        // realm_config_t cannot be frozen, so is never frozen
        auto config = cptr(realm_config_new());
        CHECK(!realm_is_frozen(config.get()));
    }

    SECTION("realm_equals() with different object types returns false") {
        auto config = cptr(realm_config_new());
        auto schema = cptr(realm_schema_new(nullptr, 0, nullptr));
        CHECK(!realm_equals(config.get(), schema.get()));
        CHECK(!realm_equals(schema.get(), config.get()));
    }

    SECTION("realm_config_t") {
        auto config = cptr(realm_config_new());

        SECTION("realm_config_set_path()") {
            realm_config_set_path(config.get(), "hello");
            CHECK(std::string{realm_config_get_path(config.get())} == "hello");
        }

        SECTION("realm_config_set_encryption_key()") {
            uint8_t key[64] = {0};
            std::iota(std::begin(key), std::end(key), 0);
            CHECK(realm_config_set_encryption_key(config.get(), key, 64));

            uint8_t buffer[64];
            size_t len = realm_config_get_encryption_key(config.get(), buffer);
            CHECK(len == 64);

            CHECK(!realm_config_set_encryption_key(config.get(), key, 63));
            CHECK_ERR(RLM_ERR_INVALID_ENCRYPTION_KEY);
        }

        SECTION("realm_config_set_schema()") {
            auto empty_schema = cptr(realm_schema_new(nullptr, 0, nullptr));
            realm_config_set_schema(config.get(), empty_schema.get());
            auto schema = cptr(realm_config_get_schema(config.get()));
            CHECK(schema);
            CHECK(realm_equals(empty_schema.get(), schema.get()));
            realm_config_set_schema(config.get(), nullptr);
            CHECK(realm_config_get_schema(config.get()) == nullptr);
        }

        SECTION("realm_config_set_schema_version()") {
            realm_config_set_schema_version(config.get(), 26);
            CHECK(realm_config_get_schema_version(config.get()) == 26);
        }

        SECTION("realm_config_set_schema_mode()") {
            auto check_mode = [&](realm_schema_mode_e mode) {
                realm_config_set_schema_mode(config.get(), mode);
                CHECK(realm_config_get_schema_mode(config.get()) == mode);
            };
            check_mode(RLM_SCHEMA_MODE_AUTOMATIC);
            check_mode(RLM_SCHEMA_MODE_IMMUTABLE);
            check_mode(RLM_SCHEMA_MODE_READ_ONLY);
            check_mode(RLM_SCHEMA_MODE_SOFT_RESET_FILE);
            check_mode(RLM_SCHEMA_MODE_HARD_RESET_FILE);
            check_mode(RLM_SCHEMA_MODE_ADDITIVE_EXPLICIT);
            check_mode(RLM_SCHEMA_MODE_ADDITIVE_DISCOVERED);
            check_mode(RLM_SCHEMA_MODE_MANUAL);
        }

        SECTION("realm_config_set_schema_subset_mode()") {
            auto check_subset_mode = [&](realm_schema_subset_mode_e mode) {
                realm_config_set_schema_subset_mode(config.get(), mode);
                CHECK(realm_config_get_schema_subset_mode(config.get()) == mode);
            };
            check_subset_mode(RLM_SCHEMA_SUBSET_MODE_ALL_CLASSES);
            check_subset_mode(RLM_SCHEMA_SUBSET_MODE_ALL_PROPERTIES);
            check_subset_mode(RLM_SCHEMA_SUBSET_MODE_COMPLETE);
            check_subset_mode(RLM_SCHEMA_SUBSET_MODE_STRICT);
        }

        SECTION("realm_config_set_disable_format_upgrade()") {
            realm_config_set_disable_format_upgrade(config.get(), true);
            CHECK(realm_config_get_disable_format_upgrade(config.get()) == true);
            realm_config_set_disable_format_upgrade(config.get(), false);
            CHECK(realm_config_get_disable_format_upgrade(config.get()) == false);
        }

        SECTION("realm_config_set_automatic_change_notifications()") {
            realm_config_set_automatic_change_notifications(config.get(), true);
            CHECK(realm_config_get_automatic_change_notifications(config.get()) == true);
            realm_config_set_automatic_change_notifications(config.get(), false);
            CHECK(realm_config_get_automatic_change_notifications(config.get()) == false);
        }

        SECTION("realm_config_set_force_sync_history()") {
            realm_config_set_force_sync_history(config.get(), true);
            CHECK(realm_config_get_force_sync_history(config.get()) == true);
            realm_config_set_force_sync_history(config.get(), false);
            CHECK(realm_config_get_force_sync_history(config.get()) == false);
        }

        SECTION("realm_config_set_max_number_of_active_versions()") {
            realm_config_set_max_number_of_active_versions(config.get(), 999);
            CHECK(realm_config_get_max_number_of_active_versions(config.get()) == 999);
        }

        SECTION("realm_config_set_in_memory()") {
            realm_config_set_in_memory(config.get(), true);
            CHECK(realm_config_get_in_memory(config.get()) == true);
        }

        SECTION("realm_config_set_fifo_path()") {
            realm_config_set_fifo_path(config.get(), "test_path.FIFO");
            CHECK(std::string{realm_config_get_fifo_path(config.get())} == "test_path.FIFO");
        }
    }

    SECTION("realm_error_t is properly initialized from Status") {
        Status status(ErrorCodes::RuntimeError, "I am a runtime error!");
        realm_error_t c_err = c_api::to_capi(status);
        REQUIRE(c_err.error == RLM_ERR_RUNTIME);
        REQUIRE(c_err.message == status.reason());
        REQUIRE(c_err.categories == RLM_ERR_CAT_RUNTIME);
        REQUIRE(c_err.path == nullptr);
        REQUIRE(c_err.user_code_error == nullptr);
    }

#if REALM_ENABLE_SYNC
    SECTION("sync_client_config_t") {
        auto test_sync_client_config = cptr(realm_sync_client_config_new());
        realm_sync_client_config_set_base_file_path(test_sync_client_config.get(), "some string");
        CHECK(test_sync_client_config->base_file_path == "some string");
        realm_sync_client_config_set_metadata_mode(test_sync_client_config.get(),
                                                   RLM_SYNC_CLIENT_METADATA_MODE_ENCRYPTED);
        CHECK(test_sync_client_config->metadata_mode ==
              static_cast<realm::SyncClientConfig::MetadataMode>(RLM_SYNC_CLIENT_METADATA_MODE_ENCRYPTED));
        auto enc_key = make_test_encryption_key(123);
        realm_sync_client_config_set_metadata_encryption_key(test_sync_client_config.get(),
                                                             reinterpret_cast<uint8_t*>(enc_key.data()));
        CHECK(test_sync_client_config->custom_encryption_key);
        CHECK(std::equal(enc_key.begin(), enc_key.end(), test_sync_client_config->custom_encryption_key->begin()));
        realm_sync_client_config_set_reconnect_mode(test_sync_client_config.get(),
                                                    RLM_SYNC_CLIENT_RECONNECT_MODE_TESTING);
        CHECK(test_sync_client_config->reconnect_mode ==
              static_cast<ReconnectMode>(RLM_SYNC_CLIENT_RECONNECT_MODE_TESTING));
        realm_sync_client_config_set_multiplex_sessions(test_sync_client_config.get(), true);
        CHECK(test_sync_client_config->multiplex_sessions);
        realm_sync_client_config_set_multiplex_sessions(test_sync_client_config.get(), false);
        CHECK_FALSE(test_sync_client_config->multiplex_sessions);
        realm_sync_client_config_set_user_agent_binding_info(test_sync_client_config.get(), "some user agent stg");
        CHECK(test_sync_client_config->user_agent_binding_info == "some user agent stg");
        realm_sync_client_config_set_user_agent_application_info(test_sync_client_config.get(), "some application");
        CHECK(test_sync_client_config->user_agent_application_info == "some application");
        realm_sync_client_config_set_connect_timeout(test_sync_client_config.get(), 666);
        CHECK(test_sync_client_config->timeouts.connect_timeout == 666);
        realm_sync_client_config_set_connection_linger_time(test_sync_client_config.get(), 999);
        CHECK(test_sync_client_config->timeouts.connection_linger_time == 999);
        realm_sync_client_config_set_ping_keepalive_period(test_sync_client_config.get(), 555);
        CHECK(test_sync_client_config->timeouts.ping_keepalive_period == 555);
        realm_sync_client_config_set_pong_keepalive_timeout(test_sync_client_config.get(), 100000);
        CHECK(test_sync_client_config->timeouts.pong_keepalive_timeout == 100000);
        realm_sync_client_config_set_fast_reconnect_limit(test_sync_client_config.get(), 1099);
        CHECK(test_sync_client_config->timeouts.fast_reconnect_limit == 1099);
        realm_sync_client_config_set_resumption_delay_interval(test_sync_client_config.get(), 1024);
        CHECK(test_sync_client_config->timeouts.reconnect_backoff_info.resumption_delay_interval.count() == 1024);
        realm_sync_client_config_set_max_resumption_delay_interval(test_sync_client_config.get(), 600024);
        CHECK(test_sync_client_config->timeouts.reconnect_backoff_info.max_resumption_delay_interval.count() ==
              600024);
        realm_sync_client_config_set_resumption_delay_backoff_multiplier(test_sync_client_config.get(), 1010);
        CHECK(test_sync_client_config->timeouts.reconnect_backoff_info.resumption_delay_backoff_multiplier == 1010);
    }

    SECTION("realm_app_config_t") {
        const uint64_t request_timeout = 2500;
        std::string base_url = "https://path/to/app";
        std::string base_url2 = "https://some/other/path";
        auto transport = std::make_shared<UnitTestTransport>(request_timeout);
        transport->set_expected_options({{"device",
                                          {{"appId", "app_id_123"},
                                           {"platform", util::get_library_platform()},
                                           {"platformVersion", "some_platform_version"},
                                           {"sdk", "some_sdk_name"},
                                           {"sdkVersion", "some_sdk_version"},
                                           {"cpuArch", util::get_library_cpu_arch()},
                                           {"deviceName", "some_device_name"},
                                           {"deviceVersion", "some_device_version"},
                                           {"frameworkName", "some_framework_name"},
                                           {"frameworkVersion", "some_framework_version"},
                                           {"coreVersion", REALM_VERSION_STRING},
                                           {"bundleId", "some_bundle_id"}}}});
        transport->set_base_url(base_url);
        auto http_transport = realm_http_transport(transport);
        auto app_config = cptr(realm_app_config_new("app_id_123", &http_transport));
        CHECK(app_config.get() != nullptr);
        CHECK(app_config->app_id == "app_id_123");
        CHECK(app_config->transport == transport);

        CHECK(realm_app_get_default_base_url() == app::App::default_base_url());

        CHECK(!app_config->base_url);
        realm_app_config_set_base_url(app_config.get(), base_url.c_str());
        CHECK(app_config->base_url == base_url);

        realm_app_config_set_default_request_timeout(app_config.get(), request_timeout);
        CHECK(app_config->default_request_timeout_ms == request_timeout);

        realm_app_config_set_platform_version(app_config.get(), "some_platform_version");
        CHECK(app_config->device_info.platform_version == "some_platform_version");

        realm_app_config_set_sdk_version(app_config.get(), "some_sdk_version");
        CHECK(app_config->device_info.sdk_version == "some_sdk_version");

        realm_app_config_set_sdk(app_config.get(), "some_sdk_name");
        CHECK(app_config->device_info.sdk == "some_sdk_name");

        realm_app_config_set_device_name(app_config.get(), "some_device_name");
        CHECK(app_config->device_info.device_name == "some_device_name");

        realm_app_config_set_device_version(app_config.get(), "some_device_version");
        CHECK(app_config->device_info.device_version == "some_device_version");

        realm_app_config_set_framework_name(app_config.get(), "some_framework_name");
        CHECK(app_config->device_info.framework_name == "some_framework_name");

        realm_app_config_set_framework_version(app_config.get(), "some_framework_version");
        CHECK(app_config->device_info.framework_version == "some_framework_version");

        realm_app_config_set_bundle_id(app_config.get(), "some_bundle_id");
        CHECK(app_config->device_info.bundle_id == "some_bundle_id");

        test_util::TestDirGuard temp_dir(util::make_temp_dir());
        auto sync_client_config = cptr(realm_sync_client_config_new());
        realm_sync_client_config_set_base_file_path(sync_client_config.get(), temp_dir.c_str());
        realm_sync_client_config_set_metadata_mode(sync_client_config.get(), RLM_SYNC_CLIENT_METADATA_MODE_DISABLED);

        auto test_app = cptr(realm_app_create(app_config.get(), sync_client_config.get()));
        realm_user_t* sync_user;
        auto user_data_free = [](realm_userdata_t) {};

        // Verify the values above are included in the login request
        auto credentials = cptr(realm_app_credentials_new_anonymous(true));
        realm_app_log_in_with_credentials(
            test_app.get(), credentials.get(),
            [](realm_userdata_t userdata, realm_user_t* user, const realm_app_error_t* error) {
                CHECK(!error);
                CHECK(user);
                auto clone_ptr = realm_clone(user);
                CHECK(realm_equals(user, clone_ptr));
                *(static_cast<realm_user_t**>(userdata)) = static_cast<realm_user_t*>(clone_ptr);
            },
            &sync_user, user_data_free);

        auto user_state = [](realm_userdata_t, realm_user_state_e state) {
            CHECK(state == RLM_USER_STATE_LOGGED_IN);
        };
        auto token =
            realm_sync_user_on_state_change_register_callback(sync_user, user_state, nullptr, user_data_free);

        auto check_base_url = [&](const std::string_view expected) {
            CHECK(transport->get_location_called());
            auto app_base_url = realm_app_get_base_url(test_app.get());
            CHECK(app_base_url == expected);
            realm_free(app_base_url);
        };

        auto update_and_check_base_url = [&](const char* new_base_url, const std::string_view expected) {
            transport->set_base_url(expected);
            realm_app_update_base_url(
                test_app.get(), new_base_url,
                [](realm_userdata_t, const realm_app_error_t* error) {
                    CHECK(!error);
                },
                nullptr, user_data_free);

            realm_app_refresh_custom_data(
                test_app.get(), sync_user,
                [](realm_userdata_t, const realm_app_error_t* error) {
                    CHECK(!error);
                },
                nullptr, user_data_free);

            check_base_url(expected);
        };

        check_base_url(base_url);

        // Reset to the default base url using nullptr
        update_and_check_base_url(nullptr, app::App::default_base_url());

        // Set to some other base url
        update_and_check_base_url(base_url2.c_str(), base_url2);

        // Reset to default base url using empty string
        update_and_check_base_url("", app::App::default_base_url());

        realm_release(sync_user);
        realm_release(token);
    }
#endif // REALM_ENABLE_SYNC
}

namespace {

/// Generate realm_property_info_t for all possible property types.
std::vector<realm_property_info_t> all_property_types(const char* link_target)
{
    std::vector<realm_property_info_t> properties;

    static const char* names[] = {
        "int", "bool", "string", "binary", "timestamp", "float", "double", "decimal", "object_id", "uuid",
    };
    static const char* nullable_names[] = {
        "nullable_int",   "nullable_bool",   "nullable_string",  "nullable_binary",    "nullable_timestamp",
        "nullable_float", "nullable_double", "nullable_decimal", "nullable_object_id", "nullable_uuid",
    };
    static const char* list_names[] = {
        "int_list",   "bool_list",   "string_list",  "binary_list",    "timestamp_list",
        "float_list", "double_list", "decimal_list", "object_id_list", "uuid_list",
    };
    static const char* nullable_list_names[] = {
        "nullable_int_list",       "nullable_bool_list",  "nullable_string_list", "nullable_binary_list",
        "nullable_timestamp_list", "nullable_float_list", "nullable_double_list", "nullable_decimal_list",
        "nullable_object_id_list", "nullable_uuid_list",
    };
    static const char* set_names[] = {
        "int_set",   "bool_set",   "string_set",  "binary_set",    "timestamp_set",
        "float_set", "double_set", "decimal_set", "object_id_set", "uuid_set",
    };
    static const char* nullable_set_names[] = {
        "nullable_int_set",       "nullable_bool_set",  "nullable_string_set", "nullable_binary_set",
        "nullable_timestamp_set", "nullable_float_set", "nullable_double_set", "nullable_decimal_set",
        "nullable_object_id_set", "nullable_uuid_set",
    };
    static const char* dict_names[] = {
        "int_dict",   "bool_dict",   "string_dict",  "binary_dict",    "timestamp_dict",
        "float_dict", "double_dict", "decimal_dict", "object_id_dict", "uuid_dict",
    };
    static const char* nullable_dict_names[] = {
        "nullable_int_dict",       "nullable_bool_dict",  "nullable_string_dict", "nullable_binary_dict",
        "nullable_timestamp_dict", "nullable_float_dict", "nullable_double_dict", "nullable_decimal_dict",
        "nullable_object_id_dict", "nullable_uuid_dict",
    };
    static const realm_property_type_e types[] = {
        RLM_PROPERTY_TYPE_INT,       RLM_PROPERTY_TYPE_BOOL,  RLM_PROPERTY_TYPE_STRING, RLM_PROPERTY_TYPE_BINARY,
        RLM_PROPERTY_TYPE_TIMESTAMP, RLM_PROPERTY_TYPE_FLOAT, RLM_PROPERTY_TYPE_DOUBLE, RLM_PROPERTY_TYPE_DECIMAL128,
        RLM_PROPERTY_TYPE_OBJECT_ID, RLM_PROPERTY_TYPE_UUID,
    };

    size_t num_names = std::distance(std::begin(names), std::end(names));
    size_t num_nullable_names = std::distance(std::begin(nullable_names), std::end(nullable_names));
    size_t num_list_names = std::distance(std::begin(list_names), std::end(list_names));
    size_t num_nullable_list_names = std::distance(std::begin(nullable_list_names), std::end(nullable_list_names));
    size_t num_set_names = std::distance(std::begin(set_names), std::end(set_names));
    size_t num_nullable_set_names = std::distance(std::begin(nullable_set_names), std::end(nullable_set_names));
    size_t num_dict_names = std::distance(std::begin(dict_names), std::end(dict_names));
    size_t num_nullable_dict_names = std::distance(std::begin(nullable_dict_names), std::end(nullable_dict_names));
    size_t num_types = std::distance(std::begin(types), std::end(types));

    REALM_ASSERT(num_names == num_types);
    REALM_ASSERT(num_nullable_names == num_types);
    REALM_ASSERT(num_list_names == num_types);
    REALM_ASSERT(num_nullable_list_names == num_types);
    REALM_ASSERT(num_set_names == num_types);
    REALM_ASSERT(num_nullable_set_names == num_types);
    REALM_ASSERT(num_dict_names == num_types);
    REALM_ASSERT(num_nullable_dict_names == num_types);

    for (size_t i = 0; i < num_names; ++i) {
        const char* public_name = i == 0 ? "public_int" : "";
        realm_property_info_t normal{
            names[i],
            public_name,
            types[i],
            RLM_COLLECTION_TYPE_NONE,
            "",
            "",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        };
        realm_property_info_t nullable{
            nullable_names[i],     "", types[i], RLM_COLLECTION_TYPE_NONE, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NULLABLE,
        };
        realm_property_info_t list{
            list_names[i],       "", types[i], RLM_COLLECTION_TYPE_LIST, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        };
        realm_property_info_t nullable_list{
            nullable_list_names[i], "", types[i], RLM_COLLECTION_TYPE_LIST, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NULLABLE,
        };
        realm_property_info_t set{
            set_names[i],        "", types[i], RLM_COLLECTION_TYPE_SET, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        };
        realm_property_info_t nullable_set{
            nullable_set_names[i], "", types[i], RLM_COLLECTION_TYPE_SET, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NULLABLE,
        };
        realm_property_info_t dict{
            dict_names[i],       "", types[i], RLM_COLLECTION_TYPE_DICTIONARY, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        };
        realm_property_info_t nullable_dict{
            nullable_dict_names[i], "", types[i], RLM_COLLECTION_TYPE_DICTIONARY, "", "", RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NULLABLE,
        };

        properties.push_back(normal);
        properties.push_back(nullable);
        properties.push_back(list);
        properties.push_back(nullable_list);
        properties.push_back(set);
        properties.push_back(nullable_set);
        properties.push_back(dict);
        properties.push_back(nullable_dict);
    }

    realm_property_info_t link{
        "link",      "", RLM_PROPERTY_TYPE_OBJECT, RLM_COLLECTION_TYPE_NONE,
        link_target, "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NULLABLE,
    };
    realm_property_info_t link_list{
        "link_list", "", RLM_PROPERTY_TYPE_OBJECT, RLM_COLLECTION_TYPE_LIST,
        link_target, "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NORMAL,
    };
    realm_property_info_t link_set{
        "link_set",  "", RLM_PROPERTY_TYPE_OBJECT, RLM_COLLECTION_TYPE_SET,
        link_target, "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NORMAL,
    };
    realm_property_info_t link_dict{
        "link_dict", "", RLM_PROPERTY_TYPE_OBJECT, RLM_COLLECTION_TYPE_DICTIONARY,
        link_target, "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NULLABLE,
    };

    properties.push_back(link);
    properties.push_back(link_list);
    properties.push_back(link_set);
    properties.push_back(link_dict);

    realm_property_info_t mixed{
        "mixed", "", RLM_PROPERTY_TYPE_MIXED,  RLM_COLLECTION_TYPE_NONE,
        "",      "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NULLABLE,
    };
    // realm_property_info_t mixed_list{
    //     "mixed_list", "", RLM_PROPERTY_TYPE_MIXED,  RLM_COLLECTION_TYPE_LIST,
    //     "",           "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NORMAL,
    // };

    properties.push_back(mixed);
    // properties.push_back(mixed_list);

    return properties;
}

CPtr<realm_schema_t> make_schema()
{
    auto foo_properties = all_property_types("Bar");

    const realm_class_info_t classes[3] = {
        {
            "Foo",
            "",                    // primary key
            foo_properties.size(), // properties
            0,                     // computed_properties
            RLM_INVALID_CLASS_KEY,
            RLM_CLASS_NORMAL,
        },
        {
            "Bar",
            "int", // primary key
            5,     // properties
            1,     // computed properties,
            RLM_INVALID_CLASS_KEY,
            RLM_CLASS_NORMAL,
        },
        {
            "Embedded",
            "", // primary key
            1,  // properties
            0,  // computed properties,
            RLM_INVALID_CLASS_KEY,
            RLM_CLASS_EMBEDDED,
        },
    };

    const realm_property_info_t bar_properties[6] = {
        {
            "int",
            "",
            RLM_PROPERTY_TYPE_INT,
            RLM_COLLECTION_TYPE_NONE,
            "",
            "",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_INDEXED | RLM_PROPERTY_PRIMARY_KEY,
        },
        {
            "strings",
            "",
            RLM_PROPERTY_TYPE_STRING,
            RLM_COLLECTION_TYPE_LIST,
            "",
            "",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL | RLM_PROPERTY_NULLABLE,
        },
        {
            "doubles",
            "",
            RLM_PROPERTY_TYPE_DOUBLE,
            RLM_COLLECTION_TYPE_NONE,
            "",
            "",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        },
        {
            "sub",
            "",
            RLM_PROPERTY_TYPE_OBJECT,
            RLM_COLLECTION_TYPE_NONE,
            "Embedded",
            "",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NULLABLE,
        },
        {
            "sub_list",
            "",
            RLM_PROPERTY_TYPE_OBJECT,
            RLM_COLLECTION_TYPE_LIST,
            "Embedded",
            "",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        },
        {
            "linking_objects",
            "",
            RLM_PROPERTY_TYPE_LINKING_OBJECTS,
            RLM_COLLECTION_TYPE_LIST,
            "Foo",
            "link_list",
            RLM_INVALID_PROPERTY_KEY,
            RLM_PROPERTY_NORMAL,
        },
    };

    const realm_property_info_t embedded_properties[1] = {{
        "int",
        "",
        RLM_PROPERTY_TYPE_INT,
        RLM_COLLECTION_TYPE_NONE,
        "",
        "",
        RLM_INVALID_PROPERTY_KEY,
        RLM_PROPERTY_NORMAL,
    }};
    const realm_property_info_t* class_properties[3] = {foo_properties.data(), bar_properties, embedded_properties};

    return cptr(realm_schema_new(classes, 3, class_properties));
}

CPtr<realm_config_t> make_config(const char* filename, bool set_schema = true)
{
    auto config = cptr(realm_config_new());
    realm_config_set_path(config.get(), filename);
    realm_config_set_schema_mode(config.get(), RLM_SCHEMA_MODE_AUTOMATIC);

    if (set_schema) {
        auto schema = make_schema();
        CHECK(checked(schema.get()));
        REQUIRE(checked(realm_schema_validate(schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));
        realm_config_set_schema(config.get(), schema.get());
        realm_config_set_schema_version(config.get(), 0);
    }

    realm_config_set_automatic_change_notifications(config.get(), true);
    realm_config_set_max_number_of_active_versions(config.get(), 1000);

    return config;
}

struct ConfigUserdata {
    size_t num_initializations = 0;
    size_t num_migrations = 0;
    size_t num_compact_on_launch = 0;
};

bool initialize_data(void* userdata_p, realm_t*)
{
    auto userdata = static_cast<ConfigUserdata*>(userdata_p);
    ++userdata->num_initializations;
    return true;
}

void free_data(void* userdata_p)
{
    free(userdata_p);
}

void delete_data(void* userdata_p)
{
    delete static_cast<ConfigUserdata*>(userdata_p);
}

bool migrate_schema(void* userdata_p, realm_t* old, realm_t* new_, const realm_schema_t*)
{
    auto userdata = static_cast<ConfigUserdata*>(userdata_p);
    static_cast<void>(old);
    static_cast<void>(new_);
    ++userdata->num_migrations;
    REQUIRE_FALSE((*old)->auto_refresh());
    return true;
}

bool migrate_schema_delete_old_table(void* userdata_p, realm_t* old, realm_t* new_, const realm_schema_t*)
{
    auto userdata = static_cast<ConfigUserdata*>(userdata_p);
    static_cast<void>(old);
    static_cast<void>(new_);
    ++userdata->num_migrations;
    bool table_deleted = false;
    CHECK(checked(realm_remove_table(new_, "Foo", &table_deleted)));
    CHECK(table_deleted);
    return table_deleted;
}

bool migrate_schema_rename_prop(void* userdata_p, realm_t* old, realm_t* new_, const realm_schema_t* schema)
{
    auto userdata = static_cast<ConfigUserdata*>(userdata_p);
    static_cast<void>(old);
    static_cast<void>(new_);
    ++userdata->num_migrations;
    CHECK(realm_schema_rename_property(new_, (realm_schema_t*)schema, "Foo", "int", "int_new"));
    return true;
}

bool should_compact_on_launch(void* userdata_p, uint64_t, uint64_t)
{
    auto userdata = static_cast<ConfigUserdata*>(userdata_p);
    ++userdata->num_compact_on_launch;
    return false;
}

struct LogUserData {
    std::vector<std::pair<std::string, std::string>> log;
};

void realm_log_func(realm_userdata_t u, const char* category, realm_log_level_e, const char* message)
{
    LogUserData* userdata = static_cast<LogUserData*>(u);
    userdata->log.emplace_back(std::make_pair(category, message));
}

realm_t* open_realm(TestFile& test_file)
{
    auto schema = make_schema();
    CHECK(checked(schema.get()));
    REQUIRE(checked(realm_schema_validate(schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));

    auto config = make_config(test_file.path.c_str(), false);

    auto realm = realm_open(config.get());
    REQUIRE(checked(realm));
    REQUIRE(checked(realm_update_schema(realm, schema.get())));

    CHECK(!realm_equals(realm, nullptr));

    auto realm2 = cptr(realm_open(config.get()));
    CHECK(checked(realm2.get()));
    CHECK(!realm_equals(realm, realm2.get()));
    CHECK(realm_equals(realm, realm));

    return realm;
}

} // anonymous namespace

TEST_CASE("C API - schema", "[c_api]") {
    TestFile test_file;

    SECTION("schema in config") {
        TestFile test_file_2;

        auto schema = make_schema();
        CHECK(checked(schema.get()));
        REQUIRE(checked(realm_schema_validate(schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));
        auto config = cptr(realm_config_new());
        realm_config_set_path(config.get(), test_file_2.path.c_str());
        realm_config_set_schema_mode(config.get(), RLM_SCHEMA_MODE_AUTOMATIC);
        realm_config_set_schema_version(config.get(), 0);
        realm_config_set_schema(config.get(), schema.get());

        SECTION("error on open") {
            {
                std::ofstream o(test_file_2.path.c_str());
                o << "Mary had a little lamb" << std::endl;
            }
            CHECK(!realm_open(config.get()));
            realm_error_t err;
            CHECK(realm_get_last_error(&err));
            REQUIRE(test_file_2.path == err.path);
            CHECK(realm_clear_last_error());
        }

        SECTION("data initialization callback") {
            ConfigUserdata userdata;
            realm_config_set_data_initialization_function(config.get(), initialize_data, &userdata, nullptr);
            auto realm = cptr_checked(realm_open(config.get()));
            CHECK(userdata.num_initializations == 1);
        }

        SECTION("data initialization callback error") {
            ConfigUserdata* userdata = new ConfigUserdata();
            realm_config_set_data_initialization_function(
                config.get(),
                [](void*, realm_t*) {
                    return false;
                },
                userdata, delete_data);
            CHECK(!realm_open(config.get()));
            CHECK_ERR(RLM_ERR_CALLBACK);
        }

        SECTION("migration callback") {
            ConfigUserdata userdata;
            realm_config_set_migration_function(config.get(), migrate_schema, &userdata, nullptr);
            auto realm = cptr_checked(realm_open(config.get()));
            CHECK(userdata.num_migrations == 0);
            realm.reset();

            auto config2 = cptr(realm_config_new());
            auto empty_schema = cptr(realm_schema_new(nullptr, 0, nullptr));
            realm_config_set_path(config2.get(), test_file_2.path.c_str());
            realm_config_set_schema_mode(config2.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config2.get(), 999);
            realm_config_set_schema(config2.get(), empty_schema.get());
            realm_config_set_migration_function(config2.get(), migrate_schema, &userdata, nullptr);
            auto realm2 = cptr_checked(realm_open(config2.get()));
            CHECK(userdata.num_migrations == 1);
        }

        SECTION("migrate schema and delete old table") {
            TestFile test_file_3;
            ConfigUserdata userdata;

            realm_config_set_migration_function(config.get(), migrate_schema_delete_old_table, &userdata, nullptr);
            const realm_class_info_t foo_class[1] = {{
                "Foo",
                "int",
                1,
                0,
                RLM_INVALID_CLASS_KEY,
                RLM_CLASS_NORMAL,
            }};
            const realm_class_info_t bar_class[1] = {{
                "Bar",
                "int",
                1,
                0,
                RLM_INVALID_CLASS_KEY,
                RLM_CLASS_NORMAL,
            }};
            const realm_property_info_t properties[1] = {
                {
                    "int",
                    "",
                    RLM_PROPERTY_TYPE_INT,
                    RLM_COLLECTION_TYPE_NONE,
                    "",
                    "",
                    RLM_INVALID_PROPERTY_KEY,
                    RLM_PROPERTY_INDEXED | RLM_PROPERTY_PRIMARY_KEY,
                },
            };
            const realm_property_info_t* props[1] = {properties};
            auto schema = cptr(realm_schema_new(foo_class, 1, props));
            auto new_schema = cptr(realm_schema_new(bar_class, 1, props));
            CHECK(checked(schema.get()));
            CHECK(checked(new_schema.get()));
            REQUIRE(checked(realm_schema_validate(schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));
            REQUIRE(checked(realm_schema_validate(new_schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));
            // realm with schema containing Foo
            auto config = cptr(realm_config_new());
            realm_config_set_path(config.get(), test_file_3.path.c_str());
            realm_config_set_schema_mode(config.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config.get(), 0);
            realm_config_set_schema(config.get(), schema.get());
            auto realm = cptr_checked(realm_open(config.get()));
            CHECK(userdata.num_migrations == 0);
            realm.reset();
            // migrate schema basically changing Foo into Bar
            auto config2 = cptr(realm_config_new());
            realm_config_set_path(config2.get(), test_file_3.path.c_str());
            realm_config_set_schema_mode(config2.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config2.get(), 999);
            realm_config_set_schema(config2.get(), new_schema.get());
            realm_config_set_migration_function(config2.get(), migrate_schema_delete_old_table, &userdata, nullptr);
            auto realm2 = cptr_checked(realm_open(config2.get()));
            CHECK(userdata.num_migrations == 1);
            auto new_db_schema = realm_get_schema(realm2.get());
            CHECK(realm_equals(new_db_schema, new_schema.get()));
            realm2.reset();
            realm_release(new_db_schema);
        }

        SECTION("migration callback rename property") {
            TestFile test_file_3;
            ConfigUserdata userdata;

            realm_config_set_migration_function(config.get(), migrate_schema_rename_prop, &userdata, nullptr);

            const realm_class_info_t foo_class[1] = {{
                "Foo",
                "int",
                1,
                0,
                RLM_INVALID_CLASS_KEY,
                RLM_CLASS_NORMAL,
            }};
            const realm_property_info_t foo_properties[1] = {
                {
                    "int",
                    "",
                    RLM_PROPERTY_TYPE_INT,
                    RLM_COLLECTION_TYPE_NONE,
                    "",
                    "",
                    RLM_INVALID_PROPERTY_KEY,
                    RLM_PROPERTY_INDEXED | RLM_PROPERTY_PRIMARY_KEY,
                },
            };
            const realm_property_info_t foo_properties_new[1] = {
                {
                    "int_new",
                    "",
                    RLM_PROPERTY_TYPE_INT,
                    RLM_COLLECTION_TYPE_NONE,
                    "",
                    "",
                    RLM_INVALID_PROPERTY_KEY,
                    RLM_PROPERTY_INDEXED | RLM_PROPERTY_PRIMARY_KEY,
                },
            };
            const realm_property_info_t* props[1] = {foo_properties};
            const realm_property_info_t* props_new[1] = {foo_properties_new};

            auto schema = cptr(realm_schema_new(foo_class, 1, props));
            auto new_schema = cptr(realm_schema_new(foo_class, 1, props_new));
            CHECK(checked(schema.get()));
            CHECK(checked(new_schema.get()));
            REQUIRE(checked(realm_schema_validate(schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));
            REQUIRE(checked(realm_schema_validate(new_schema.get(), RLM_SCHEMA_VALIDATION_BASIC)));
            // realm with schema
            auto config = cptr(realm_config_new());
            realm_config_set_path(config.get(), test_file_3.path.c_str());
            realm_config_set_schema_mode(config.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config.get(), 0);
            realm_config_set_schema(config.get(), schema.get());
            auto realm = cptr_checked(realm_open(config.get()));
            CHECK(userdata.num_migrations == 0);
            realm.reset();
            // realm with new schema
            auto config2 = cptr(realm_config_new());
            realm_config_set_path(config2.get(), test_file_3.path.c_str());
            realm_config_set_schema_mode(config2.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config2.get(), 999);
            realm_config_set_schema(config2.get(), new_schema.get());
            realm_config_set_migration_function(config2.get(), migrate_schema_rename_prop, &userdata, nullptr);
            auto realm2 = cptr_checked(realm_open(config2.get()));
            CHECK(userdata.num_migrations == 1);
            auto new_db_schema = realm_get_schema(realm2.get());
            CHECK(realm_equals(new_db_schema, new_schema.get()));
            realm2.reset();
            realm_release(new_db_schema);
        }

        SECTION("migration callback error") {
            ConfigUserdata userdata;
            auto realm = cptr_checked(realm_open(config.get()));
            realm.reset();

            auto config2 = cptr(realm_config_new());
            auto empty_schema = cptr(realm_schema_new(nullptr, 0, nullptr));
            realm_config_set_path(config2.get(), test_file_2.path.c_str());
            realm_config_set_schema_mode(config2.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config2.get(), 999);
            realm_config_set_schema(config2.get(), empty_schema.get());

            realm_config_set_migration_function(
                config2.get(),
                [](void*, realm_t*, realm_t*, const realm_schema_t*) {
                    return false;
                },
                &userdata, nullptr);
            CHECK(!realm_open(config2.get()));
            CHECK_ERR(RLM_ERR_CALLBACK);
        }

        SECTION("should compact on launch callback") {
            void* userdata_p = malloc(sizeof(ConfigUserdata));
            memset(userdata_p, 0, sizeof(ConfigUserdata));
            realm_config_set_should_compact_on_launch_function(config.get(), should_compact_on_launch, userdata_p,
                                                               free_data);
            auto realm = cptr_checked(realm_open(config.get()));
            CHECK(static_cast<ConfigUserdata*>(userdata_p)->num_compact_on_launch == 1);
        }

        SECTION("should compact on launch and initialization callback") {
            ConfigUserdata* userdata = new ConfigUserdata();
            realm_config_set_should_compact_on_launch_function(config.get(), should_compact_on_launch, userdata,
                                                               delete_data);
            realm_config_set_data_initialization_function(config.get(), initialize_data, userdata,
                                                          free_data); // should not update free function
            auto realm = cptr_checked(realm_open(config.get()));
            CHECK(userdata->num_initializations == 1);
            CHECK(userdata->num_compact_on_launch == 1);
        }

        SECTION("migration callback register exception error") {
            ConfigUserdata userdata;
            auto realm = cptr_checked(realm_open(config.get()));
            realm.reset();

            auto config2 = cptr(realm_config_new());
            auto empty_schema = cptr(realm_schema_new(nullptr, 0, nullptr));
            realm_config_set_path(config2.get(), test_file_2.path.c_str());
            realm_config_set_schema_mode(config2.get(), RLM_SCHEMA_MODE_AUTOMATIC);
            realm_config_set_schema_version(config2.get(), 999);
            realm_config_set_schema(config2.get(), empty_schema.get());

            struct MyExceptionWrapper {
                std::exception_ptr m_ptr{nullptr};
            };

            realm_config_set_migration_function(
                config2.get(),
                [](void*, realm_t*, realm_t*, const realm_schema_t*) {
                    try {
                        throw std::runtime_error("Test error in callback");
                    }
                    catch (...) {
                        auto wrapper = new MyExceptionWrapper();
                        wrapper->m_ptr = std::current_exception();
                        realm_register_user_code_callback_error((void*)(wrapper));
                    }
                    return false;
                },
                &userdata, nullptr);

            CHECK(!realm_open(config2.get()));
            realm_error_t _err;
            _err.message = "";
            _err.error = RLM_ERR_NONE;
            CHECK(realm_get_last_error(&_err));
            CHECK(_err.error == RLM_ERR_CALLBACK);
            CHECK(std::string{_err.message} == "User-provided callback failed");
            REQUIRE(_err.user_code_error); // this is the error registered inside the callback
            auto ex = (MyExceptionWrapper*)_err.user_code_error;
            try {
                std::rethrow_exception(ex->m_ptr);
            }
            catch (const std::exception& ex) {
                CHECK(std::string{ex.what()} == std::string{"Test error in callback"});
            }
            CHECK(realm_clear_last_error());
            delete ex;
        }
    }

    auto realm = open_realm(test_file);

    SECTION("schema is set after opening") {
        const realm_class_info_t baz = {
            "baz",
            "", // primary key
            1,  // properties
            0,  // computed_properties
            RLM_INVALID_CLASS_KEY,
            RLM_CLASS_NORMAL,
        };

        auto int_property = realm_property_info_t{
            "int", "", RLM_PROPERTY_TYPE_INT,    RLM_COLLECTION_TYPE_NONE,
            "",    "", RLM_INVALID_PROPERTY_KEY, RLM_PROPERTY_NORMAL,
        };
        realm_property_info_t* baz_properties = &int_property;

        // get class count
        size_t num_classes = realm_get_num_classes(realm);
        realm_class_key_t* out_keys = (realm_class_key_t*)malloc(sizeof(realm_class_key_t) * num_classes);
        // get class keys
        realm_get_class_keys(realm, out_keys, num_classes, nullptr);
        realm_class_info_t* classes = (realm_class_info_t*)malloc(sizeof(realm_class_info_t) * (num_classes + 1));
        const realm_property_info_t** properties =
            (const realm_property_info_t**)malloc(sizeof(realm_property_info_t*) * (num_classes + 1));
        // iterating through each class, "recreate" the old schema
        for (size_t i = 0; i < num_classes; i++) {
            realm_get_class(realm, out_keys[i], &classes[i]);
            size_t out_n;
            realm_get_class_properties(realm, out_keys[i], nullptr, 0, &out_n);
            realm_property_info_t* out_props = (realm_property_info_t*)malloc(sizeof(realm_property_info_t) * out_n);
            realm_get_class_properties(realm, out_keys[i], out_props, out_n, nullptr);
            properties[i] = out_props;
        }
        // add the new class and its properties to the arrays
        classes[num_classes] = baz;

        properties[num_classes] = baz_properties;

        // create a new schema and update the realm
        auto new_schema = realm_schema_new(classes, num_classes + 1, properties);

        // check that the schema changed callback fires with the new schema
        struct Context {
            realm_schema_t* expected_schema;
            bool result;
        } context = {new_schema, false};
        auto token = realm_add_schema_changed_callback(
            realm,
            [](void* userdata, auto* new_schema) {
                auto& ctx = *reinterpret_cast<Context*>(userdata);
                ctx.result = realm_equals(new_schema, ctx.expected_schema);
            },
            &context, [](void*) {});

        CHECK(checked(realm_update_schema(realm, new_schema)));
        CHECK(context.result);
        auto new_num_classes = realm_get_num_classes(realm);
        CHECK(new_num_classes == (num_classes + 1));

        bool found;
        realm_class_info_t baz_info;
        CHECK(checked(realm_find_class(realm, "baz", &found, &baz_info)));
        CHECK(found);
        realm_property_info_t baz_int_property;
        CHECK(checked(realm_find_property(realm, baz_info.key, "int", &found, &baz_int_property)));
        CHECK(found);

        free(out_keys);
        free(classes);
        for (size_t i = 0; i < num_classes; i++) {
            free((realm_property_info_t*)properties[i]);
        }
        free(properties);
        realm_release(new_schema);
        realm_release(token);
    }

    SECTION("schema validates") {
        auto schema = realm_get_schema(realm);
        CHECK(checked(schema));
        CHECK(checked(realm_schema_validate(schema, realm_schema_validation_mode::RLM_SCHEMA_VALIDATION_BASIC)));

        auto schema2 = realm_get_schema(realm);
        CHECK(checked(schema2));
        CHECK(realm_equals(schema, schema2));
        realm_release(schema2);
        realm_release(schema);
    }

    SECTION("clone schema") {
        auto schema = cptr(realm_get_schema(realm));
        auto schema2 = clone_cptr(schema);
        CHECK(schema.get() != schema2.get());
        CHECK(realm_equals(schema.get(), schema2.get()));
    }

    realm_close(realm);
    REQUIRE(realm_is_closed(realm));
    realm_release(realm);
}

TEST_CASE("C API - realm", "[c_api]") {
    TestFile test_file;
    realm_t* realm = open_realm(test_file);

    CHECK(realm_get_num_classes(realm) == 3);

    SECTION("cached realm") {
        auto config2 = make_config(test_file.path.c_str(), false);
        realm_config_set_cached(config2.get(), true);
        REQUIRE(realm_config_get_cached(config2.get()));
        auto realm2 = cptr(realm_open(config2.get()));
        CHECK(!realm_equals(realm, realm2.get()));
        auto realm3 = cptr(realm_open(config2.get()));
        REQUIRE(realm_equals(realm3.get(), realm2.get()));
    }

    SECTION("native ptr conversion") {
        realm::SharedRealm native;
        _realm_get_native_ptr(realm, &native, sizeof(native));
        auto path = native->config().path;
        CHECK(path == test_file.path);

        auto realm2 = cptr_checked(_realm_from_native_ptr(&native, sizeof(native)));
        CHECK(realm_equals(realm2.get(), realm));
    }

    SECTION("realm changed notification") {
        bool realm_changed_callback_called = false;
        auto token = cptr(realm_add_realm_changed_callback(
            realm,
            [](void* userdata) {
                *reinterpret_cast<bool*>(userdata) = true;
            },
            &realm_changed_callback_called, [](void*) {}));

        realm_begin_write(realm);
        realm_commit(realm);
        CHECK(realm_changed_callback_called);
    }

    SECTION("realm refresh registering while not in transaction") {
        bool realm_refresh_callback_called = false;
        auto token = cptr(realm_add_realm_refresh_callback(
            realm,
            [](void* userdata) {
                *reinterpret_cast<bool*>(userdata) = true;
            },
            &realm_refresh_callback_called, [](void*) {}));
        realm_begin_write(realm);
        realm_commit(realm);
        CHECK_FALSE(realm_refresh_callback_called);
    }

    SECTION("realm refresh registering callback in transaction but on the same version") {
        bool realm_refresh_callback_called = false;
        realm_begin_write(realm);
        auto token = cptr(realm_add_realm_refresh_callback(
            realm,
            [](void* userdata) {
                *reinterpret_cast<bool*>(userdata) = true;
            },
            &realm_refresh_callback_called, [](void*) {}));
        realm_commit(realm);
        CHECK_FALSE(realm_refresh_callback_called);
    }

    SECTION("realm async refresh - main use case") {
        bool realm_refresh_callback_called = false;
        auto config = make_config(test_file.path.c_str(), false);
        auto realm2 = cptr(realm_open(config.get()));

        realm_begin_write(realm);
        realm_begin_read(realm2.get());
        realm_commit(realm);

        auto token = cptr(realm_add_realm_refresh_callback(
            realm2.get(),
            [](void* userdata) {
                *reinterpret_cast<bool*>(userdata) = true;
            },
            &realm_refresh_callback_called, [](void*) {}));

        realm_refresh(realm2.get(), nullptr);
        REQUIRE(token);
        CHECK(realm_refresh_callback_called);
    }

    SECTION("realm async refresh - main use case, multiple callbacks") {
        std::atomic_int counter = 0;
        auto config = make_config(test_file.path.c_str(), false);
        auto realm2 = cptr(realm_open(config.get()));

        realm_begin_write(realm);
        realm_begin_read(realm2.get());
        realm_commit(realm);

        auto f = [](void* userdata) {
            auto ptr = reinterpret_cast<std::atomic_int*>(userdata);
            ptr->fetch_add(1);
        };
        auto token1 = cptr(realm_add_realm_refresh_callback(realm2.get(), f, &counter, [](void*) {}));
        auto token2 = cptr(realm_add_realm_refresh_callback(realm2.get(), f, &counter, [](void*) {}));
        realm_refresh(realm2.get(), nullptr);
        REQUIRE(token1);
        REQUIRE(token2);
        CHECK(counter.load() == 2);
    }

    SECTION("realm refresh read transaction frozen - register on unfrozen realm") {
        bool realm_refresh_callback_called = false;
        realm_begin_read(realm);

        auto realm2 = cptr_checked(realm_freeze(realm));
        CHECK(!realm_is_frozen(realm));
        CHECK(realm_is_frozen(realm2.get()));
        CHECK(realm != realm2.get());

        auto token = cptr(realm_add_realm_refresh_callback(
            realm,
            [](void* userdata) {
                *reinterpret_cast<bool*>(userdata) = true;
            },
            &realm_refresh_callback_called, [](void*) {}));

        realm_refresh(realm, nullptr);
        CHECK_FALSE(realm_refresh_callback_called);
    }

    SECTION("realm refresh read transaction frozen - register on frozen realm") {
        bool realm_refresh_callback_called = false;
        realm_begin_read(realm);

        auto realm2 = cptr_checked(realm_freeze(realm));
        CHECK(!realm_is_frozen(realm));
        CHECK(realm_is_frozen(realm2.get()));
        CHECK(realm != realm2.get());

        auto token = cptr(realm_add_realm_refresh_callback(
            realm2.get(),
            [](void* userdata) {
                *reinterpret_cast<bool*>(userdata) = true;
            },
            &realm_refresh_callback_called, [](void*) {}));

        realm_refresh(realm, nullptr);
        CHECK(token == nullptr);
        CHECK_FALSE(realm_refresh_callback_called);
    }

    SECTION("realm_freeze()") {
        auto realm2 = cptr_checked(realm_freeze(realm));
        CHECK(!realm_is_frozen(realm));
        CHECK(realm_is_frozen(realm2.get()));
    }

    SECTION("realm_compact()") {
        bool did_compact = false;
        CHECK(checked(realm_compact(realm, &did_compact)));
        CHECK(did_compact);
    }

    realm_close(realm);
    REQUIRE(realm_is_closed(realm));
    realm_release(realm);
}

TEST_CASE("C API logging", "[c_api]") {
    TestFile test_file;

    LogUserData userdata;
    const char* category_names[20];
    auto num_categories = realm_get_category_names(20, category_names);
    auto log_level_old = realm_get_log_level_category("Realm");

    realm_set_log_callback(realm_log_func, &userdata, nullptr);
    realm_set_log_level(RLM_LOG_LEVEL_DEBUG);
    for (size_t n = 0; n < num_categories; n++) {
        CHECK(realm_get_log_level_category(category_names[n]) == RLM_LOG_LEVEL_DEBUG);
    }

    auto prev_level = realm_set_log_level_category("Realm.Storage.Object", RLM_LOG_LEVEL_OFF);
    CHECK(prev_level == RLM_LOG_LEVEL_DEBUG);
    CHECK(realm_get_log_level_category("Realm.Storage.Object") == RLM_LOG_LEVEL_OFF);
    auto config = make_config(test_file.path.c_str(), true);
    realm_t* realm = realm_open(config.get());
    realm_begin_write(realm);
    realm_class_info_t class_foo;
    realm_find_class(realm, "Foo", nullptr, &class_foo);
    realm_property_info_t info;
    realm_find_property(realm, class_foo.key, "int", nullptr, &info);
    auto obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
    realm_set_value(obj1.get(), info.key, rlm_int_val(123), false);
    realm_commit(realm);
    CHECK(userdata.log.size() == 11);
    realm_set_log_level(RLM_LOG_LEVEL_INFO);
    // Commit begin/end should not be logged at INFO level
    realm_begin_write(realm);
    realm_commit(realm);
    CHECK(userdata.log.size() == 11);
    // We only expect Realm.Storage category logs
    for (size_t n = 0; n < userdata.log.size(); n++) {
        CHECK(userdata.log.at(n).first.rfind("Realm.Storage", 0) == 0);
    }
    realm_release(realm);
    userdata.log.clear();
    realm_set_log_level(RLM_LOG_LEVEL_ERROR);
    realm = realm_open(config.get());
    realm_release(realm);
    CHECK(userdata.log.empty());

    // Remove this logger again
    realm_set_log_callback(nullptr, nullptr, nullptr);
    // Restore old log level
    realm_set_log_level(log_level_old);
}

TEST_CASE("C API - scheduler", "[c_api]") {
    TestFile test_file;
    realm_t* realm;

    struct SchedulerData {
        bool free_called = false;
        realm_work_queue_t* work_queue;
        std::mutex mutex;
        std::condition_variable cond;
        void wait()
        {
            std::unique_lock<std::mutex> lk(mutex);
            cond.wait(lk);
        }
        void notify(realm_work_queue_t* wq)
        {
            std::unique_lock<std::mutex> lk(mutex);
            work_queue = wq;
            cond.notify_one();
        }
        void execute()
        {
            realm_scheduler_perform_work(work_queue);
        }
    } scheduler_data;

    struct NotifierData {
        bool notify_called = false;
    } notifier_data;

    {
        auto config = make_config(test_file.path.c_str());
        auto scheduler = realm_scheduler_new(
            &scheduler_data,
            [](void* data) {
                static_cast<SchedulerData*>(data)->free_called = true;
            },
            [](void* data, realm_work_queue_t* work_queue) {
                static_cast<SchedulerData*>(data)->notify(work_queue);
            },
            [](void*) {
                return true;
            },
            nullptr, nullptr);
        realm_config_set_scheduler(config.get(), scheduler);
        realm = realm_open(config.get());
        realm_release(scheduler);
    }

    bool found = false;
    realm_class_info_t class_foo;
    realm_find_class(realm, "Foo", &found, &class_foo);
    auto res = realm_object_find_all(realm, class_foo.key);
    auto token = realm_results_add_notification_callback(res, &notifier_data, nullptr, nullptr,
                                                         [](void* data, const realm_collection_changes_t*) {
                                                             static_cast<NotifierData*>(data)->notify_called = true;
                                                         });

    realm_begin_write(realm);
    auto obj = realm_object_create(realm, class_foo.key);
    realm_release(obj);
    realm_commit(realm);

    scheduler_data.wait();

    notifier_data.notify_called = false;
    scheduler_data.execute();
    CHECK(notifier_data.notify_called);

    CHECK(!scheduler_data.free_called);
    realm_release(token);
    realm_release(res);
    realm_release(realm);
    CHECK(scheduler_data.free_called);
}

TEST_CASE("C API - properties", "[c_api]") {
    TestFile test_file;
    realm_t* realm = open_realm(test_file);

    auto write = [&](auto&& f) {
        checked(realm_begin_write(realm));
        f();
        checked(realm_commit(realm));
        checked(realm_refresh(realm, nullptr));
    };

    bool found = false;

    realm_class_info_t class_foo, class_bar, class_embedded;
    CHECK(checked(realm_find_class(realm, "Foo", &found, &class_foo)));
    REQUIRE(found);
    CHECK(checked(realm_find_class(realm, "Bar", &found, &class_bar)));
    REQUIRE(found);
    CHECK(checked(realm_find_class(realm, "Embedded", &found, &class_embedded)));
    REQUIRE(found);

    std::map<std::string, realm_property_key_t> foo_properties;
    for (const auto& p : all_property_types("Bar")) {
        realm_property_info_t info;
        bool found = false;
        REQUIRE(realm_find_property(realm, class_foo.key, p.name, &found, &info));
        REQUIRE(found);
        CHECK(p.key == RLM_INVALID_PROPERTY_KEY);
        CHECK(info.key != RLM_INVALID_PROPERTY_KEY);
        CHECK(info.type == p.type);
        CHECK(std::string{info.public_name} == p.public_name);
        CHECK(info.collection_type == p.collection_type);
        CHECK(std::string{info.link_target} == p.link_target);
        CHECK(std::string{info.link_origin_property_name} == p.link_origin_property_name);
        foo_properties[info.name] = info.key;
    }

    std::map<std::string, realm_property_key_t> bar_properties;
    {
        realm_property_info_t info;
        bool found = false;
        REQUIRE(checked(realm_find_property(realm, class_bar.key, "int", &found, &info)));
        REQUIRE(found);
        bar_properties["int"] = info.key;

        REQUIRE(checked(realm_find_property(realm, class_bar.key, "strings", &found, &info)));
        REQUIRE(found);
        bar_properties["strings"] = info.key;

        REQUIRE(checked(realm_find_property(realm, class_bar.key, "doubles", &found, &info)));
        REQUIRE(found);
        bar_properties["doubles"] = info.key;

        REQUIRE(checked(realm_find_property(realm, class_bar.key, "linking_objects", &found, &info)));
        REQUIRE(found);
        bar_properties["linking_objects"] = info.key;
    }

    realm_property_key_t foo_int_key = foo_properties["int"];
    realm_property_key_t foo_str_key = foo_properties["string"];
    realm_property_key_t foo_links_key = foo_properties["link_list"];
    realm_property_key_t bar_int_key = bar_properties["int"];
    realm_property_key_t bar_strings_key = bar_properties["strings"];
    realm_property_key_t bar_doubles_key = bar_properties["doubles"];

    SECTION("realm_find_class() errors") {
        bool found = true;
        CHECK(realm_find_class(realm, "does not exist", &found, nullptr));
        CHECK(!found);
    }

    SECTION("realm_remove_table()") {
        bool table_deleted = true;
        CHECK(!realm_remove_table(realm, "Foo", &table_deleted));
        CHECK_ERR(RLM_ERR_INVALID_SCHEMA_CHANGE);
        CHECK(!table_deleted);
    }

    SECTION("realm_get_class_keys()") {
        realm_class_key_t keys[2];
        // return total number of keys present, copy only if there is enough space in the vector passed in
        size_t found = 0;
        CHECK(checked(realm_get_class_keys(realm, keys, 2, &found)));
        CHECK(found == 3);
        CHECK(checked(realm_get_class_keys(realm, keys, 1, &found)));
        CHECK(found == 3);
    }

    SECTION("realm_find_property() errors") {
        realm_property_info_t dummy;
        CHECK(!realm_find_property(realm, 123123123, "Foo", &found, &dummy));
        CHECK_ERR(RLM_ERR_NO_SUCH_TABLE);
        CHECK(!realm_find_property(realm, 123123123, "Foo", &found, nullptr));
        CHECK_ERR(RLM_ERR_NO_SUCH_TABLE);

        bool found;
        CHECK(checked(realm_find_property(realm, class_foo.key, "int", nullptr, nullptr)));
        CHECK(checked(realm_find_property(realm, class_foo.key, "int", &found, nullptr)));
        CHECK(found);

        found = true;
        CHECK(checked(realm_find_property(realm, class_foo.key, "i don't exist", &found, nullptr)));
        CHECK(!found);
    }

    SECTION("realm_find_property_by_public_name()") {
        realm_property_info_t property;
        bool found = false;
        CHECK(checked(realm_find_property_by_public_name(realm, class_foo.key, "public_int", &found, &property)));
        CHECK(found);
        CHECK(property.key == foo_int_key);

        found = false;
        CHECK(checked(realm_find_property_by_public_name(realm, class_foo.key, "string", &found, &property)));
        CHECK(found);
        CHECK(property.key == foo_properties["string"]);

        CHECK(checked(realm_find_property_by_public_name(realm, class_foo.key, "I don't exist", &found, &property)));
        CHECK(!found);
    }

    SECTION("realm_get_property_keys()") {
        size_t num_found = 0;
        size_t properties_found = 0;

        // discover how many properties there are.
        CHECK(checked(realm_get_property_keys(realm, class_foo.key, nullptr, 0, &properties_found)));
        realm_property_key_t* properties_foo =
            (realm_property_key_t*)malloc(sizeof(realm_property_key_t) * properties_found);
        CHECK(checked(realm_get_property_keys(realm, class_foo.key, properties_foo, properties_found, &num_found)));
        CHECK(num_found == properties_found);
        CHECK(properties_foo[0] == foo_properties["int"]);
        realm_free(properties_foo);

        num_found = 0;
        properties_found = 0;
        // discover how many properties there are.
        CHECK(checked(realm_get_property_keys(realm, class_bar.key, nullptr, 0, &properties_found)));
        realm_property_key_t* properties_bar =
            (realm_property_key_t*)malloc(sizeof(realm_property_key_t) * properties_found);
        CHECK(checked(realm_get_property_keys(realm, class_bar.key, properties_bar, properties_found, &num_found)));
        CHECK(num_found == properties_found);
        CHECK(properties_bar[2] == bar_properties["doubles"]);
        CHECK(properties_bar[0] == bar_properties["int"]);
        realm_free(properties_bar);

        num_found = 0;
        CHECK(checked(realm_get_property_keys(realm, class_foo.key, nullptr, 0, &num_found)));
        CHECK(num_found == class_foo.num_properties + class_foo.num_computed_properties);

        std::vector<realm_property_key_t> ps;
        ps.resize(1000);
        CHECK(checked(realm_get_property_keys(realm, class_foo.key, ps.data(), ps.size(), &num_found)));
        CHECK(num_found == class_foo.num_properties + class_foo.num_computed_properties);

        CHECK(checked(realm_get_property_keys(realm, class_bar.key, ps.data(), ps.size(), &num_found)));
        CHECK(num_found == 6);
    }

    SECTION("realm_get_property()") {
        realm_property_info_t prop;
        CHECK(checked(realm_get_property(realm, class_bar.key, bar_properties["linking_objects"], &prop)));
        CHECK(prop.key == bar_properties["linking_objects"]);
        CHECK(std::string{prop.name} == "linking_objects");

        CHECK(!realm_get_property(realm, class_bar.key, 123123123, &prop));
        CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
    }

    SECTION("realm_object_create() errors") {
        SECTION("invalid table") {
            write([&]() {
                auto p = realm_object_create(realm, 123123123);
                CHECK(!p);
                CHECK_ERR(RLM_ERR_NO_SUCH_TABLE);
            });
        }

        SECTION("missing primary key") {
            write([&]() {
                auto p = realm_object_create(realm, class_bar.key);
                CHECK(!p);
                CHECK_ERR(RLM_ERR_MISSING_PRIMARY_KEY);
            });
        }

        SECTION("embedded object") {
            write([&]() {
                auto p = realm_object_create(realm, class_embedded.key);
                CHECK(!p);
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
            });
        }

        SECTION("wrong primary key type") {
            write([&]() {
                auto p = realm_object_create_with_primary_key(realm, class_bar.key, rlm_str_val("Hello"));
                CHECK(!p);
                CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);
            });

            write([&]() {
                auto p = realm_object_create_with_primary_key(realm, class_bar.key, rlm_null());
                CHECK(!p);
                CHECK_ERR(RLM_ERR_PROPERTY_NOT_NULLABLE);
            });
        }

        SECTION("class does not have a primary key") {
            write([&]() {
                CHECK(!realm_object_create_with_primary_key(realm, class_foo.key, rlm_int_val(123)));
                CHECK_ERR(RLM_ERR_UNEXPECTED_PRIMARY_KEY);
            });
        }

        SECTION("duplicate primary key") {
            write([&]() {
                cptr_checked(realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(123)));
                auto p = realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(123));
                CHECK(!p);
                CHECK_ERR(RLM_ERR_OBJECT_ALREADY_EXISTS);
            });
        }

        SECTION("not in a transaction") {
            CHECK(!realm_object_create(realm, class_foo.key));
            CHECK_ERR(RLM_ERR_WRONG_TRANSACTION_STATE);
        }
    }


    SECTION("objects") {
        CPtr<realm_object_t> obj1;
        CPtr<realm_object_t> obj2;
        auto int_val1 = rlm_int_val(123);
        auto int_val2 = rlm_int_val(456);
        write([&]() {
            obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
            CHECK(obj1);
            CHECK(checked(realm_set_value(obj1.get(), foo_int_key, int_val1, false)));
            CHECK(checked(realm_set_value(obj1.get(), foo_str_key, rlm_str_val("Hello, World!"), false)));
            obj2 = cptr_checked(realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(1)));
            CHECK(obj2);
            CPtr<realm_object_t> obj3 = cptr_checked(realm_object_create(realm, class_foo.key));
            CHECK(obj3);
            CHECK(checked(realm_set_value(obj3.get(), foo_int_key, int_val2, false)));
            CPtr<realm_object_t> obj4 = cptr_checked(realm_object_create(realm, class_foo.key));
            CHECK(obj3);
            CHECK(checked(realm_set_value(obj4.get(), foo_int_key, int_val1, false)));
        });

        size_t foo_count, bar_count;
        CHECK(checked(realm_get_num_objects(realm, class_foo.key, &foo_count)));
        CHECK(checked(realm_get_num_objects(realm, class_bar.key, &bar_count)));
        REQUIRE(foo_count == 3);
        REQUIRE(bar_count == 1);

        SECTION("realm_get_value_by_property_index") {
            realm_value value;
            CHECK(checked(realm_get_value_by_property_index(obj1.get(), 0, &value)));
            CHECK(value.integer == int_val1.integer);
            CHECK(checked(realm_get_value_by_property_index(obj1.get(), 16, &value)));
            CHECK(value.string.data == std::string{"Hello, World!"});
        }

        SECTION("realm_clone()") {
            auto obj1a = clone_cptr(obj1);
            CHECK(realm_equals(obj1a.get(), obj1.get()));
        }

        SECTION("native pointer mapping") {
            auto object = *static_cast<const realm::Object*>(_realm_object_get_native_ptr(obj1.get()));
            auto obj = object.get_obj();
            CHECK(obj.get<int64_t>(realm::ColKey(foo_int_key)) == int_val1.integer);

            auto obj1a = cptr_checked(_realm_object_from_native_copy(&object, sizeof(object)));
            CHECK(realm_equals(obj1.get(), obj1a.get()));
            auto obj1b = cptr_checked(_realm_object_from_native_move(&object, sizeof(object)));
            CHECK(realm_equals(obj1.get(), obj1b.get()));
        }

        SECTION("realm_get_num_objects()") {
            size_t num_foos, num_bars;
            CHECK(checked(realm_get_num_objects(realm, class_foo.key, &num_foos)));
            CHECK(checked(realm_get_num_objects(realm, class_bar.key, &num_bars)));
            CHECK(num_foos == 3);
            CHECK(num_bars == 1);

            CHECK(checked(realm_get_num_objects(realm, class_bar.key, nullptr)));
            CHECK(!realm_get_num_objects(realm, 123123123, nullptr));
            CHECK_ERR(RLM_ERR_NO_SUCH_TABLE);
        }

        SECTION("realm_get_object()") {
            realm_object_key_t obj1_key = realm_object_get_key(obj1.get());
            auto obj1a = cptr_checked(realm_get_object(realm, class_foo.key, obj1_key));
            CHECK(obj1a);
            CHECK(realm_equals(obj1a.get(), obj1.get()));

            realm_object_key_t invalid_key = 123123123;
            CHECK(!realm_get_object(realm, class_foo.key, invalid_key));
            CHECK_ERR(RLM_ERR_NO_SUCH_OBJECT);

            realm_class_key_t invalid_class_key = 123123123;
            CHECK(!realm_get_object(realm, invalid_class_key, obj1_key));
            CHECK_ERR(RLM_ERR_NO_SUCH_TABLE);
        }

        SECTION("create object with primary key that already exists") {
            bool did_create;
            auto obj2a = cptr_checked(
                realm_object_get_or_create_with_primary_key(realm, class_bar.key, rlm_int_val(1), &did_create));
            CHECK(!did_create);
            CHECK(realm_equals(obj2a.get(), obj2.get()));
        }

        SECTION("realm_get_value()") {
            realm_value_t value;
            CHECK(checked(realm_get_value(obj1.get(), foo_int_key, &value)));
            CHECK(value.type == RLM_TYPE_INT);
            CHECK(value.integer == 123);

            CHECK(checked(realm_get_value(obj1.get(), foo_str_key, &value)));
            CHECK(value.type == RLM_TYPE_STRING);
            CHECK(strncmp(value.string.data, "Hello, World!", value.string.size) == 0);

            CHECK(checked(realm_get_value(obj1.get(), foo_int_key, nullptr)));

            CHECK(!realm_get_value(obj1.get(), 123123123, &value));
            CHECK_ERR(RLM_ERR_INVALID_PROPERTY);

            CHECK(!realm_get_value(obj1.get(), 123123123, nullptr));
            CHECK_ERR(RLM_ERR_INVALID_PROPERTY);

            // Cannot use realm_get_value() to get a list.
            CHECK(!realm_get_value(obj1.get(), foo_links_key, &value));
            CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);

            write([&]() {
                CHECK(checked(realm_object_delete(obj1.get())));
            });
            CHECK(!realm_get_value(obj1.get(), foo_int_key, &value));
            CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);
        }

        SECTION("realm_get_values()") {
            realm_value_t values[3];

            realm_property_key_t keys1[3] = {foo_int_key, foo_str_key, foo_int_key};
            CHECK(checked(realm_get_values(obj1.get(), 3, keys1, values)));

            CHECK(values[0].type == RLM_TYPE_INT);
            CHECK(values[1].type == RLM_TYPE_STRING);
            CHECK(values[2].type == RLM_TYPE_INT);

            CHECK(values[0].integer == 123);
            CHECK(strncmp(values[1].string.data, "Hello, World!", values[1].string.size) == 0);
            CHECK(values[2].integer == 123);

            realm_property_key_t keys2[3] = {foo_int_key, 123123123, foo_str_key};
            CHECK(!realm_get_values(obj1.get(), 3, keys2, values));
            CHECK_ERR(RLM_ERR_INVALID_PROPERTY);

            write([&]() {
                CHECK(checked(realm_object_delete(obj1.get())));
            });
            CHECK(!realm_get_values(obj1.get(), 3, keys1, values));
            CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);
        }

        SECTION("realm_set_value() errors") {
            CHECK(!realm_set_value(obj1.get(), foo_int_key, rlm_int_val(456), false));
            CHECK_ERR(RLM_ERR_WRONG_TRANSACTION_STATE);

            write([&]() {
                CHECK(!realm_set_value(obj1.get(), foo_int_key, rlm_null(), false));
                CHECK_ERR(RLM_ERR_PROPERTY_NOT_NULLABLE);

                CHECK(!realm_set_value(obj1.get(), foo_int_key, rlm_str_val("a"), false));
                CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);

                CHECK(!realm_set_value(obj1.get(), 123123123, rlm_int_val(123), false));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            });
        }

        SECTION("realm_set_values() errors") {
            realm_value_t int456 = rlm_int_val(456);
            CHECK(!realm_set_values(obj1.get(), 1, &foo_int_key, &int456, false));
            CHECK_ERR(RLM_ERR_WRONG_TRANSACTION_STATE);

            write([&]() {
                realm_value_t value;
                realm_property_key_t keys1[3] = {foo_int_key, foo_str_key, foo_int_key};
                realm_property_key_t keys2[3] = {foo_int_key, 123123123, foo_str_key};

                // No error; check that the last value wins when there are
                // duplicate keys.
                realm_value_t values1[3] = {rlm_int_val(234), rlm_str_val("aaa"), rlm_int_val(345)};
                CHECK(checked(realm_set_values(obj1.get(), 3, keys1, values1, false)));

                realm_get_value(obj1.get(), foo_int_key, &value);
                CHECK(value.type == RLM_TYPE_INT);
                CHECK(value.integer == 345);
                realm_get_value(obj1.get(), foo_str_key, &value);
                CHECK(value.type == RLM_TYPE_STRING);
                CHECK(strncmp("aaa", value.string.data, value.string.size) == 0);

                // Type mismatch error.
                realm_value_t values2[3] = {rlm_int_val(111), rlm_str_val("bbb"), rlm_str_val("ccc")};
                CHECK(!realm_set_values(obj1.get(), 3, keys1, values2, false));
                CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);
                // Properties should remain unchanged.
                realm_get_value(obj1.get(), foo_int_key, &value);
                CHECK(value.type == RLM_TYPE_INT);
                CHECK(value.integer == 345);
                realm_get_value(obj1.get(), foo_str_key, &value);
                CHECK(value.type == RLM_TYPE_STRING);

                // Invalid property key error.
                CHECK(!realm_set_values(obj1.get(), 3, keys2, values2, false));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
                // Properties should remain unchanged.
                realm_get_value(obj1.get(), foo_int_key, &value);
                CHECK(value.type == RLM_TYPE_INT);
                CHECK(value.integer == 345);
                realm_get_value(obj1.get(), foo_str_key, &value);
                CHECK(value.type == RLM_TYPE_STRING);
            });
        }

        SECTION("realm_object_add_int errors") {
            SECTION("SUCCESS") {
                realm_begin_write(realm);
                CHECK(realm_object_add_int(obj1.get(), foo_int_key, 10));
                realm_commit(realm);
            }
            SECTION("ERROR") {
                CHECK(!realm_object_add_int(obj1.get(), foo_int_key, 10));
                CHECK_ERR(RLM_ERR_WRONG_TRANSACTION_STATE);
            }
        }

        SECTION("get/set all property types") {
            realm_value_t null = rlm_null();
            realm_value_t integer = rlm_int_val(987);
            realm_value_t boolean = rlm_bool_val(true);
            realm_value_t string = rlm_str_val("My string");
            const uint8_t binary_data[] = {0, 1, 2, 3, 4, 5, 6, 7};
            realm_value_t binary = rlm_binary_val(binary_data, sizeof(binary_data));
            realm_value_t timestamp = rlm_timestamp_val(1000000, 123123123);
            realm_value_t fnum = rlm_float_val(123.f);
            realm_value_t dnum = rlm_double_val(456.0);
            realm_value_t decimal = rlm_decimal_val(999.0);
            realm_value_t object_id = rlm_object_id_val("abc123abc123");
            realm_value_t uuid = rlm_uuid_val("01234567-9abc-4def-9012-3456789abcde");
            realm_value_t link = rlm_link_val(class_bar.key, realm_object_get_key(obj2.get()));

            write([&]() {
                CHECK(realm_set_value(obj1.get(), foo_properties["int"], integer, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["bool"], boolean, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["string"], string, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["binary"], binary, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["timestamp"], timestamp, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["float"], fnum, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["double"], dnum, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["decimal"], decimal, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["object_id"], object_id, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["uuid"], uuid, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["mixed"], integer, false));

                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_int"], integer, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_bool"], boolean, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_string"], string, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_binary"], binary, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_timestamp"], timestamp, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_float"], fnum, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_double"], dnum, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_decimal"], decimal, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_object_id"], object_id, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_uuid"], uuid, false));

                CHECK(realm_set_value(obj1.get(), foo_properties["link"], link, false));
            });

            realm_value_t value;

            CHECK(realm_get_value(obj1.get(), foo_properties["int"], &value));
            CHECK(rlm_val_eq(value, integer));
            CHECK(realm_get_value(obj1.get(), foo_properties["bool"], &value));
            CHECK(rlm_val_eq(value, boolean));
            CHECK(realm_get_value(obj1.get(), foo_properties["string"], &value));
            CHECK(rlm_val_eq(value, string));
            CHECK(realm_get_value(obj1.get(), foo_properties["binary"], &value));
            CHECK(rlm_val_eq(value, binary));
            CHECK(realm_get_value(obj1.get(), foo_properties["timestamp"], &value));
            CHECK(rlm_val_eq(value, timestamp));
            CHECK(realm_get_value(obj1.get(), foo_properties["float"], &value));
            CHECK(rlm_val_eq(value, fnum));
            CHECK(realm_get_value(obj1.get(), foo_properties["double"], &value));
            CHECK(rlm_val_eq(value, dnum));
            CHECK(realm_get_value(obj1.get(), foo_properties["decimal"], &value));
            CHECK(rlm_val_eq(value, decimal));
            CHECK(realm_get_value(obj1.get(), foo_properties["object_id"], &value));
            CHECK(rlm_val_eq(value, object_id));
            CHECK(realm_get_value(obj1.get(), foo_properties["uuid"], &value));
            CHECK(rlm_val_eq(value, uuid));
            CHECK(realm_get_value(obj1.get(), foo_properties["mixed"], &value));
            CHECK(rlm_val_eq(value, integer));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_int"], &value));
            CHECK(rlm_val_eq(value, integer));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_bool"], &value));
            CHECK(rlm_val_eq(value, boolean));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_string"], &value));
            CHECK(rlm_val_eq(value, string));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_binary"], &value));
            CHECK(rlm_val_eq(value, binary));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_timestamp"], &value));
            CHECK(rlm_val_eq(value, timestamp));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_float"], &value));
            CHECK(rlm_val_eq(value, fnum));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_double"], &value));
            CHECK(rlm_val_eq(value, dnum));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_decimal"], &value));
            CHECK(rlm_val_eq(value, decimal));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_object_id"], &value));
            CHECK(rlm_val_eq(value, object_id));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_uuid"], &value));
            CHECK(rlm_val_eq(value, uuid));
            CHECK(realm_get_value(obj1.get(), foo_properties["link"], &value));
            CHECK(rlm_val_eq(value, link));

            write([&]() {
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_int"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_bool"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_string"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_binary"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_timestamp"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_float"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_double"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_decimal"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_object_id"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["nullable_uuid"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["mixed"], null, false));
                CHECK(realm_set_value(obj1.get(), foo_properties["link"], null, false));
            });

            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_int"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_bool"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_string"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_binary"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_timestamp"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_float"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_double"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_decimal"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_object_id"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["nullable_uuid"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["mixed"], &value));
            CHECK(rlm_val_eq(value, null));
            CHECK(realm_get_value(obj1.get(), foo_properties["link"], &value));
            CHECK(rlm_val_eq(value, null));
        }

        SECTION("embedded") {
            realm_property_info_t info;
            bool found = false;
            REQUIRE(checked(realm_find_property(realm, class_bar.key, "sub", &found, &info)));
            REQUIRE(found);

            auto embedded = cptr_checked(realm_get_linked_object(obj2.get(), info.key));
            CHECK(!embedded);
            write([&]() {
                auto embedded = cptr_checked(realm_set_embedded(obj2.get(), info.key));
                CHECK(embedded);
            });
            embedded = cptr_checked(realm_get_linked_object(obj2.get(), info.key));
            CHECK(embedded);
        }

        SECTION("delete causes invalidation errors") {
            write([&]() {
                // Get a list instance for later
                auto list = cptr_checked(realm_get_list(obj1.get(), foo_links_key));

                CHECK(checked(realm_object_delete(obj1.get())));
                CHECK(!realm_object_is_valid(obj1.get()));

                realm_clear_last_error();
                CHECK(!realm_object_delete(obj1.get()));
                CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);

                realm_clear_last_error();
                CHECK(!realm_set_value(obj1.get(), foo_int_key, rlm_int_val(123), false));
                CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);

                realm_clear_last_error();
                auto list2 = realm_get_list(obj1.get(), foo_links_key);
                CHECK(!list2);
                CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);

                size_t size;
                CHECK(!realm_list_size(list.get(), &size));
                CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);
            });
        }

        SECTION("lists") {
            SECTION("realm_get_list() errors") {
                CHECK(!realm_get_list(obj2.get(), bar_int_key));
                CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);

                CHECK(!realm_get_list(obj2.get(), 123123123));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("nullable strings") {
                auto strings = cptr_checked(realm_get_list(obj2.get(), bar_strings_key));
                CHECK(strings);
                CHECK(!realm_is_frozen(strings.get()));

                realm_value_t a = rlm_str_val("a");
                realm_value_t b = rlm_str_val("b");
                realm_value_t c = rlm_null();

                SECTION("realm_equals() type check") {
                    CHECK(!realm_equals(strings.get(), obj1.get()));
                }

                SECTION("realm_clone()") {
                    auto list2 = clone_cptr(strings.get());
                    CHECK(realm_equals(strings.get(), list2.get()));
                    CHECK(strings.get() != list2.get());
                }

                SECTION("insert, then get") {
                    write([&]() {
                        CHECK(checked(realm_list_insert(strings.get(), 0, a)));
                        CHECK(checked(realm_list_insert(strings.get(), 1, b)));
                        CHECK(checked(realm_list_insert(strings.get(), 2, c)));

                        realm_value_t a2, b2, c2;
                        CHECK(checked(realm_list_get(strings.get(), 0, &a2)));
                        CHECK(checked(realm_list_get(strings.get(), 1, &b2)));
                        CHECK(checked(realm_list_get(strings.get(), 2, &c2)));

                        CHECK(rlm_stdstr(a2) == "a");
                        CHECK(rlm_stdstr(b2) == "b");
                        CHECK(c2.type == RLM_TYPE_NULL);

                        size_t out_index = -1;
                        bool found;
                        CHECK(checked(realm_list_find(strings.get(), &a2, &out_index, &found)));
                        CHECK(out_index == 0);
                        CHECK(found);
                        CHECK(checked(realm_list_find(strings.get(), &b2, &out_index, &found)));
                        CHECK(out_index == 1);
                        CHECK(found);
                        CHECK(checked(realm_list_find(strings.get(), &c2, &out_index, &found)));
                        CHECK(out_index == 2);
                        CHECK(found);

                        realm_value_t dummy = rlm_str_val("c");
                        CHECK(checked(realm_list_find(strings.get(), &dummy, &out_index, &found)));
                        CHECK(!found);
                        CHECK(out_index == realm::not_found);

                        // verify that conversion to results works
                        auto results = cptr_checked(realm_list_to_results(strings.get()));
                        CHECK(checked(realm_results_find(results.get(), &a2, &out_index, &found)));
                        CHECK(found);
                        CHECK(out_index == 0);
                        CHECK(checked(realm_results_find(results.get(), &b2, &out_index, &found)));
                        CHECK(found);
                        CHECK(out_index == 1);
                        CHECK(checked(realm_results_find(results.get(), &c2, &out_index, &found)));
                        CHECK(found);
                        CHECK(out_index == 2);
                    });
                }

                SECTION("equality") {
                    auto strings2 = cptr_checked(realm_get_list(obj2.get(), bar_strings_key));
                    CHECK(strings2);
                    CHECK(realm_equals(strings.get(), strings2.get()));

                    write([&]() {
                        auto obj3 =
                            cptr_checked(realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(2)));
                        CHECK(obj3);
                        auto strings3 = cptr_checked(realm_get_list(obj3.get(), bar_strings_key));
                        CHECK(!realm_equals(strings.get(), strings3.get()));
                    });
                }
            }

            SECTION("get/insert all property types") {
                realm_value_t null = rlm_null();
                realm_value_t integer = rlm_int_val(987);
                realm_value_t boolean = rlm_bool_val(true);
                realm_value_t string = rlm_str_val("My string");
                const uint8_t binary_data[] = {0, 1, 2, 3, 4, 5, 6, 7};
                realm_value_t binary = rlm_binary_val(binary_data, sizeof(binary_data));
                realm_value_t timestamp = rlm_timestamp_val(1000000, 123123123);
                realm_value_t fnum = rlm_float_val(123.f);
                realm_value_t dnum = rlm_double_val(456.0);
                realm_value_t decimal = rlm_decimal_val(999.0);
                realm_value_t object_id = rlm_object_id_val("abc123abc123");
                realm_value_t uuid = rlm_uuid_val("01234567-9abc-4def-9012-3456789abcde");

                auto int_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["int_list"]));
                auto bool_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["bool_list"]));
                auto string_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["string_list"]));
                auto binary_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["binary_list"]));
                auto timestamp_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["timestamp_list"]));
                auto float_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["float_list"]));
                auto double_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["double_list"]));
                auto decimal_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["decimal_list"]));
                auto object_id_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["object_id_list"]));
                auto uuid_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["uuid_list"]));
                auto nullable_int_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_int_list"]));
                auto nullable_bool_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_bool_list"]));
                auto nullable_string_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_string_list"]));
                auto nullable_binary_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_binary_list"]));
                auto nullable_timestamp_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_timestamp_list"]));
                auto nullable_float_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_float_list"]));
                auto nullable_double_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_double_list"]));
                auto nullable_decimal_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_decimal_list"]));
                auto nullable_object_id_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_object_id_list"]));
                auto nullable_uuid_list =
                    cptr_checked(realm_get_list(obj1.get(), foo_properties["nullable_uuid_list"]));

                write([&]() {
                    CHECK(realm_list_insert(int_list.get(), 0, integer));
                    CHECK(realm_list_insert(bool_list.get(), 0, boolean));
                    CHECK(realm_list_insert(string_list.get(), 0, string));
                    CHECK(realm_list_insert(binary_list.get(), 0, binary));
                    CHECK(realm_list_insert(timestamp_list.get(), 0, timestamp));
                    CHECK(realm_list_insert(float_list.get(), 0, fnum));
                    CHECK(realm_list_insert(double_list.get(), 0, dnum));
                    CHECK(realm_list_insert(decimal_list.get(), 0, decimal));
                    CHECK(realm_list_insert(object_id_list.get(), 0, object_id));
                    CHECK(realm_list_insert(uuid_list.get(), 0, uuid));

                    CHECK(realm_list_insert(nullable_int_list.get(), 0, integer));
                    CHECK(realm_list_insert(nullable_bool_list.get(), 0, boolean));
                    CHECK(realm_list_insert(nullable_string_list.get(), 0, string));
                    CHECK(realm_list_insert(nullable_binary_list.get(), 0, binary));
                    CHECK(realm_list_insert(nullable_timestamp_list.get(), 0, timestamp));
                    CHECK(realm_list_insert(nullable_float_list.get(), 0, fnum));
                    CHECK(realm_list_insert(nullable_double_list.get(), 0, dnum));
                    CHECK(realm_list_insert(nullable_decimal_list.get(), 0, decimal));
                    CHECK(realm_list_insert(nullable_object_id_list.get(), 0, object_id));
                    CHECK(realm_list_insert(nullable_uuid_list.get(), 0, uuid));

                    CHECK(realm_list_insert(nullable_int_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_bool_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_string_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_binary_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_timestamp_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_float_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_double_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_decimal_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_object_id_list.get(), 1, null));
                    CHECK(realm_list_insert(nullable_uuid_list.get(), 1, null));
                });

                auto find = ([&](auto* list, auto* value) {
                    std::size_t index = -1;
                    bool found = false;
                    CHECK(checked(realm_list_find(list, value, &index, &found)));
                    CHECK(index == 0);
                    CHECK(found);
                    return (index < list->size()) && found == true;
                });

                realm_value_t value;
                CHECK(realm_list_get(int_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, integer));
                CHECK(!realm_list_get_linked_object(int_list.get(), 0));
                CHECK(find(int_list.get(), &value));
                CHECK(realm_list_get(bool_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, boolean));
                CHECK(find(bool_list.get(), &value));
                CHECK(realm_list_get(string_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, string));
                CHECK(find(string_list.get(), &value));
                CHECK(realm_list_get(binary_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, binary));
                CHECK(find(binary_list.get(), &value));
                CHECK(realm_list_get(timestamp_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(find(timestamp_list.get(), &value));
                CHECK(realm_list_get(float_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, fnum));
                CHECK(find(float_list.get(), &value));
                CHECK(realm_list_get(double_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, dnum));
                CHECK(find(double_list.get(), &value));
                CHECK(realm_list_get(decimal_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, decimal));
                CHECK(find(decimal_list.get(), &value));
                CHECK(realm_list_get(object_id_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, object_id));
                CHECK(find(object_id_list.get(), &value));
                CHECK(realm_list_get(uuid_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, uuid));
                CHECK(find(uuid_list.get(), &value));
                CHECK(realm_list_get(nullable_int_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, integer));
                CHECK(find(nullable_int_list.get(), &value));
                CHECK(realm_list_get(nullable_bool_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, boolean));
                CHECK(find(nullable_bool_list.get(), &value));
                CHECK(realm_list_get(nullable_string_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, string));
                CHECK(find(nullable_string_list.get(), &value));
                CHECK(realm_list_get(nullable_binary_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, binary));
                CHECK(find(nullable_binary_list.get(), &value));
                CHECK(realm_list_get(nullable_timestamp_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(find(nullable_timestamp_list.get(), &value));
                CHECK(realm_list_get(nullable_float_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, fnum));
                CHECK(find(nullable_float_list.get(), &value));
                CHECK(realm_list_get(nullable_double_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, dnum));
                CHECK(find(nullable_double_list.get(), &value));
                CHECK(realm_list_get(nullable_decimal_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, decimal));
                CHECK(find(nullable_decimal_list.get(), &value));
                CHECK(realm_list_get(nullable_object_id_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, object_id));
                CHECK(find(nullable_object_id_list.get(), &value));
                CHECK(realm_list_get(nullable_uuid_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, uuid));
                CHECK(find(nullable_uuid_list.get(), &value));

                write([&]() {
                    CHECK(realm_list_insert(nullable_int_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_bool_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_string_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_binary_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_timestamp_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_float_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_double_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_decimal_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_object_id_list.get(), 0, null));
                    CHECK(realm_list_insert(nullable_uuid_list.get(), 0, null));
                });

                CHECK(realm_list_get(nullable_int_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_bool_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_string_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_binary_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_timestamp_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_float_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_double_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_decimal_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_object_id_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_list_get(nullable_uuid_list.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
            }

            SECTION("move") {
                auto int_list = cptr_checked(realm_get_list(obj1.get(), foo_properties["int_list"]));
                write([&]() {
                    for (int i = 0; i < 10; ++i) {
                        CHECK(realm_list_insert(int_list.get(), i, rlm_int_val(i)));
                    }
                });

                realm_value_t value;
                auto expected = std::vector<int64_t>{0, 1, 2, 3, 4, 5, 6, 7, 8, 9};
                for (int i = 0; i < 10; ++i) {
                    CHECK(realm_list_get(int_list.get(), i, &value));
                    CHECK(rlm_val_eq(value, rlm_int_val(expected[i])));
                }

                write([&]() {
                    CHECK(realm_list_move(int_list.get(), 0, 1));
                });

                expected = std::vector<int64_t>{1, 0, 2, 3, 4, 5, 6, 7, 8, 9};
                for (int i = 0; i < 10; ++i) {
                    CHECK(realm_list_get(int_list.get(), i, &value));
                    CHECK(rlm_val_eq(value, rlm_int_val(expected[i])));
                }

                write([&]() {
                    CHECK(realm_list_move(int_list.get(), 3, 2));
                });

                expected = std::vector<int64_t>{1, 0, 3, 2, 4, 5, 6, 7, 8, 9};
                for (int i = 0; i < 10; ++i) {
                    CHECK(realm_list_get(int_list.get(), i, &value));
                    CHECK(rlm_val_eq(value, rlm_int_val(expected[i])));
                }
            }

            SECTION("links") {
                CPtr<realm_list_t> bars;

                write([&]() {
                    bars = cptr_checked(realm_get_list(obj1.get(), foo_links_key));
                    auto bar_link = realm_object_as_link(obj2.get());
                    realm_value_t bar_link_val;
                    bar_link_val.type = RLM_TYPE_LINK;
                    bar_link_val.link = bar_link;
                    CHECK(checked(realm_list_insert(bars.get(), 0, bar_link_val)));
                    CHECK(checked(realm_list_insert(bars.get(), 1, bar_link_val)));
                    size_t size;
                    CHECK(checked(realm_list_size(bars.get(), &size)));
                    CHECK(size == 2);

                    bool found = true;
                    size_t index = -1;
                    CHECK(checked(realm_list_find(bars.get(), &bar_link_val, &index, &found)));
                    CHECK(index == 0);
                    CHECK(found);

                    realm_list_clear(bars.get());
                    CHECK(checked(realm_list_find(bars.get(), &bar_link_val, &index, &found)));
                    CHECK(index == realm::not_found);
                    CHECK(!found);

                    CHECK(checked(realm_list_insert(bars.get(), 0, bar_link_val)));
                    CHECK(checked(realm_list_insert(bars.get(), 1, bar_link_val)));
                });

                SECTION("get") {
                    realm_value_t val;
                    CHECK(checked(realm_list_get(bars.get(), 0, &val)));
                    CHECK(val.type == RLM_TYPE_LINK);
                    CHECK(val.link.target_table == class_bar.key);
                    CHECK(val.link.target == realm_object_get_key(obj2.get()));

                    CHECK(checked(realm_list_get(bars.get(), 1, &val)));
                    CHECK(val.type == RLM_TYPE_LINK);
                    CHECK(val.link.target_table == class_bar.key);
                    CHECK(val.link.target == realm_object_get_key(obj2.get()));

                    auto result = realm_list_get(bars.get(), 2, &val);
                    CHECK(!result);
                    CHECK_ERR(RLM_ERR_INDEX_OUT_OF_BOUNDS);
                }

                SECTION("set wrong type") {
                    write([&]() {
                        auto foo2 = cptr(realm_object_create(realm, class_foo.key));
                        CHECK(foo2);
                        realm_value_t foo2_link_val;
                        foo2_link_val.type = RLM_TYPE_LINK;
                        foo2_link_val.link = realm_object_as_link(foo2.get());

                        CHECK(!realm_list_set(bars.get(), 0, foo2_link_val));
                        CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);
                    });
                }

                SECTION("realm_list_clear()") {
                    write([&]() {
                        CHECK(realm_list_clear(bars.get()));
                    });
                    size_t size;
                    CHECK(realm_list_size(bars.get(), &size));
                    CHECK(size == 0);

                    size_t num_bars;
                    CHECK(realm_get_num_objects(realm, class_bar.key, &num_bars));
                    CHECK(num_bars != 0);
                }

                SECTION("realm_list_remove_all()") {
                    size_t num_bars;
                    size_t size;

                    write([&]() {
                        CHECK(checked(realm_list_remove_all(bars.get())));
                    });

                    CHECK(realm_list_size(bars.get(), &size));
                    CHECK(size == 0);

                    CHECK(realm_get_num_objects(realm, class_bar.key, &num_bars));
                    CHECK(num_bars == 0);
                }
            }

            SECTION("embedded") {
                CPtr<realm_list_t> subs;
                realm_property_info_t info;
                bool found = false;
                REQUIRE(checked(realm_find_property(realm, class_bar.key, "sub_list", &found, &info)));
                REQUIRE(found);
                subs = cptr_checked(realm_get_list(obj2.get(), info.key));

                write([&]() {
                    auto embedded = cptr_checked(realm_list_insert_embedded(subs.get(), 0));
                    CHECK(embedded);
                });
                auto embedded = cptr_checked(realm_list_get_linked_object(subs.get(), 0));
                CHECK(embedded);
            }

            SECTION("notifications") {
                struct State {
                    CPtr<realm_collection_changes_t> changes;
                    CPtr<realm_async_error_t> error;
                    bool destroyed = false;
                    bool called = false;
                };

                State state;

                auto on_change = [](void* userdata, const realm_collection_changes_t* changes) {
                    auto* state = static_cast<State*>(userdata);
                    state->changes = clone_cptr(changes);
                    state->called = true;
                };

                CPtr<realm_list_t> strings = cptr_checked(realm_get_list(obj2.get(), bar_strings_key));

                auto str1 = rlm_str_val("a");
                auto str2 = rlm_str_val("b");
                auto null = rlm_null();

                auto require_change = [&]() {
                    auto token = cptr_checked(
                        realm_list_add_notification_callback(strings.get(), &state, nullptr, nullptr, on_change));
                    checked(realm_refresh(realm, nullptr));
                    return token;
                };

                SECTION("userdata is freed when the token is destroyed") {
                    auto token = cptr_checked(realm_list_add_notification_callback(
                        strings.get(), &state,
                        [](void* p) {
                            static_cast<State*>(p)->destroyed = true;
                        },
                        nullptr, nullptr));
                    CHECK(!state.destroyed);
                    token.reset();
                    CHECK(state.destroyed);
                }

                SECTION("insertion sends a change callback") {
                    auto token = require_change();
                    write([&]() {
                        checked(realm_list_insert(strings.get(), 0, str1));
                        checked(realm_list_insert(strings.get(), 1, str2));
                        checked(realm_list_insert(strings.get(), 2, null));
                    });
                    CHECK(!state.error);
                    CHECK(state.changes);

                    size_t num_deletion_ranges, num_insertion_ranges, num_modification_ranges, num_moves;
                    realm_collection_changes_get_num_ranges(state.changes.get(), &num_deletion_ranges,
                                                            &num_insertion_ranges, &num_modification_ranges,
                                                            &num_moves);
                    CHECK(num_deletion_ranges == 0);
                    CHECK(num_insertion_ranges == 1);
                    CHECK(num_modification_ranges == 0);
                    CHECK(num_moves == 0);

                    realm_index_range_t insertion_range;
                    realm_collection_changes_get_ranges(state.changes.get(), nullptr, 0, &insertion_range, 1, nullptr,
                                                        0, nullptr, 0, nullptr, 0);
                    CHECK(insertion_range.from == 0);
                    CHECK(insertion_range.to == 3);
                }

                SECTION("modifying target of list with a filter") {
                    auto bars = cptr_checked(realm_get_list(obj1.get(), foo_links_key));
                    write([&]() {
                        auto bar_link = realm_object_as_link(obj2.get());
                        realm_value_t bar_link_val;
                        bar_link_val.type = RLM_TYPE_LINK;
                        bar_link_val.link = bar_link;
                        CHECK(checked(realm_list_insert(bars.get(), 0, bar_link_val)));
                    });

                    SECTION("using valid key") {
                        const char* bar_strings[1] = {"doubles"};
                        auto key_path_array = realm_create_key_path_array(realm, class_bar.key, 1, bar_strings);
                        REQUIRE(key_path_array);
                        auto token = cptr_checked(realm_list_add_notification_callback(bars.get(), &state, nullptr,
                                                                                       key_path_array, on_change));
                        realm_release(key_path_array);
                        checked(realm_refresh(realm, nullptr));

                        state.called = false;
                        write([&]() {
                            checked(realm_set_value(obj2.get(), bar_doubles_key, rlm_double_val(5.0), false));
                        });
                        REQUIRE(state.called);
                        CHECK(!state.error);
                        CHECK(state.changes);

                        state.called = false;
                        write([&]() {
                            checked(realm_list_insert(strings.get(), 0, str1));
                            checked(realm_list_insert(strings.get(), 1, str2));
                            checked(realm_list_insert(strings.get(), 2, null));
                        });
                        REQUIRE(!state.called);
                    }
                    SECTION("using invalid key") {
                        const char* bar_strings[1] = {"dobles"};
                        auto key_path_array = realm_create_key_path_array(realm, class_bar.key, 1, bar_strings);
                        REQUIRE(!key_path_array);
                        realm_clear_last_error();
                    }
                    SECTION("Embedded objects") {
                        realm_property_info_t info;
                        bool found = false;
                        realm_key_path_array_t* key_path_array = nullptr;
                        realm_find_property(realm, class_bar.key, "sub", &found, &info);
                        auto bar_sub_key = info.key;
                        realm_find_property(realm, class_embedded.key, "int", &found, &info);
                        auto embedded_int_key = info.key;
                        CPtr<realm_object_t> embedded;
                        write([&]() {
                            embedded = cptr_checked(realm_set_embedded(obj2.get(), bar_sub_key));
                        });

                        SECTION("using valid nesting") {

                            const char* bar_strings[1] = {"sub.int"};
                            key_path_array = realm_create_key_path_array(realm, class_bar.key, 1, bar_strings);
                            REQUIRE(key_path_array);
                        }
                        SECTION("using star notation") {
                            const char* bar_strings[1] = {"*.int"};
                            key_path_array = realm_create_key_path_array(realm, class_bar.key, 1, bar_strings);
                            // (*realm)->print_key_path_array(*key_path_array);
                        }

                        REQUIRE(key_path_array);
                        auto token = cptr_checked(realm_list_add_notification_callback(bars.get(), &state, nullptr,
                                                                                       key_path_array, on_change));
                        realm_release(key_path_array);

                        checked(realm_refresh(realm, nullptr));

                        state.called = false;
                        write([&]() {
                            checked(realm_set_value(embedded.get(), embedded_int_key, rlm_int_val(999), false));
                        });
                        REQUIRE(state.called);
                        CHECK(!state.error);
                        CHECK(state.changes);
                    }
                    SECTION("using backlink") {
                        const char* bar_strings[1] = {"linking_objects.public_int"};
                        auto key_path_array = realm_create_key_path_array(realm, class_bar.key, 1, bar_strings);
                        REQUIRE(key_path_array);
                        auto token = cptr_checked(realm_list_add_notification_callback(bars.get(), &state, nullptr,
                                                                                       key_path_array, on_change));
                        realm_release(key_path_array);
                        checked(realm_refresh(realm, nullptr));

                        state.called = false;
                        write([&]() {
                            checked(realm_set_value(obj1.get(), foo_int_key, rlm_int_val(999), false));
                        });
                        REQUIRE(state.called);
                        CHECK(!state.error);
                        CHECK(state.changes);
                    }
                    SECTION("using invalid nesting") {
                        const char* bar_strings[1] = {"doubles.age"};
                        auto key_path_array = realm_create_key_path_array(realm, class_bar.key, 1, bar_strings);
                        REQUIRE(!key_path_array);
                        realm_clear_last_error();
                    }
                }

                SECTION("insertion, deletion, modification, modification after") {
                    write([&]() {
                        checked(realm_list_insert(strings.get(), 0, str1));
                        checked(realm_list_insert(strings.get(), 1, str2));
                        checked(realm_list_insert(strings.get(), 2, str1));
                    });

                    auto token = require_change();

                    write([&]() {
                        checked(realm_list_erase(strings.get(), 1));
                        checked(realm_list_insert(strings.get(), 0, null));
                        checked(realm_list_insert(strings.get(), 1, null));

                        // This element was previously at 0, and ends up at 2.
                        checked(realm_list_set(strings.get(), 2, str1));
                    });
                    CHECK(!state.error);
                    CHECK(state.changes);

                    size_t num_deletion_ranges, num_insertion_ranges, num_modification_ranges, num_moves;
                    realm_collection_changes_get_num_ranges(state.changes.get(), &num_deletion_ranges,
                                                            &num_insertion_ranges, &num_modification_ranges,
                                                            &num_moves);
                    CHECK(num_deletion_ranges == 1);
                    CHECK(num_insertion_ranges == 1);
                    CHECK(num_modification_ranges == 1);
                    CHECK(num_moves == 0);

                    size_t num_deletions, num_insertions, num_modifications;
                    bool collection_cleared = false;
                    realm_collection_changes_get_num_changes(state.changes.get(), &num_deletions, &num_insertions,
                                                             &num_modifications, &num_moves, &collection_cleared,
                                                             nullptr);
                    CHECK(num_deletions == 1);
                    CHECK(num_insertions == 2);
                    CHECK(num_modifications == 1);
                    CHECK(collection_cleared == false);

                    realm_index_range_t deletions, insertions, modifications, modifications_after;
                    realm_collection_move_t moves;
                    realm_collection_changes_get_ranges(state.changes.get(), &deletions, 1, &insertions, 1,
                                                        &modifications, 1, &modifications_after, 1, &moves, 1);
                    CHECK(deletions.from == 1);
                    CHECK(deletions.to == 2);

                    CHECK(insertions.from == 0);
                    CHECK(insertions.to == 2);

                    CHECK(modifications.from == 0);
                    CHECK(modifications.to == 1);

                    CHECK(modifications_after.from == 2);
                    CHECK(modifications_after.to == 3);

                    std::vector<size_t> deletions_v, insertions_v, modifications_v, modifications_after_v;
                    std::vector<realm_collection_move_t> moves_v;
                    deletions_v.resize(100, size_t(-1));
                    insertions_v.resize(100, size_t(-1));
                    modifications_v.resize(100, size_t(-1));
                    modifications_after_v.resize(100, size_t(-1));
                    moves_v.resize(100, realm_collection_move_t{size_t(-1), size_t(-1)});
                    realm_collection_changes_get_changes(state.changes.get(), deletions_v.data(), 100,
                                                         insertions_v.data(), 100, modifications_v.data(), 100,
                                                         modifications_after_v.data(), 100, moves_v.data(), 100);
                    CHECK(deletions_v[0] == 1);
                    CHECK(deletions_v[1] == size_t(-1));
                    CHECK(insertions_v[0] == 0);
                    CHECK(insertions_v[1] == 1);
                    CHECK(insertions_v[2] == size_t(-1));
                    CHECK(modifications_v[0] == 0);
                    CHECK(modifications_v[1] == size_t(-1));
                    CHECK(modifications_after_v[0] == 2);
                    CHECK(modifications_after_v[1] == size_t(-1));

                    write([&]() {
                        checked(realm_list_clear(strings.get()));
                    });

                    realm_collection_changes_get_num_changes(state.changes.get(), &num_deletions, &num_insertions,
                                                             &num_modifications, &num_moves, &collection_cleared,
                                                             nullptr);
                    CHECK(collection_cleared == true);
                }
            }
        }

        SECTION("sets") {
            SECTION("realm_get_set() errors") {
                CHECK(!realm_get_set(obj1.get(), foo_properties["int"]));
                CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);

                CHECK(!realm_get_set(obj1.get(), 123123123));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("nullable strings") {
                auto strings = cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_string_set"]));
                CHECK(strings);
                CHECK(!realm_is_frozen(strings.get()));

                realm_value_t a = rlm_str_val("a");
                realm_value_t b = rlm_str_val("b");
                realm_value_t c = rlm_null();

                SECTION("realm_equals() type check") {
                    CHECK(!realm_equals(strings.get(), obj1.get()));
                }

                SECTION("realm_clone()") {
                    auto set2 = clone_cptr(strings.get());
                    CHECK(realm_equals(strings.get(), set2.get()));
                    CHECK(strings.get() != set2.get());
                }

                SECTION("insert, then get, then erase") {
                    write([&]() {
                        bool inserted = false;
                        CHECK(checked(realm_set_insert(strings.get(), a, nullptr, &inserted)));
                        CHECK(inserted);
                        CHECK(checked(realm_set_insert(strings.get(), b, nullptr, &inserted)));
                        CHECK(inserted);
                        CHECK(checked(realm_set_insert(strings.get(), c, nullptr, &inserted)));
                        CHECK(inserted);

                        size_t a_index, b_index, c_index;
                        bool found = false;
                        CHECK(checked(realm_set_find(strings.get(), a, &a_index, &found)));
                        CHECK(found);
                        CHECK(checked(realm_set_find(strings.get(), b, &b_index, &found)));
                        CHECK(found);
                        CHECK(checked(realm_set_find(strings.get(), c, &c_index, &found)));
                        CHECK(found);

                        realm_value_t a2, b2, c2;
                        CHECK(checked(realm_set_get(strings.get(), a_index, &a2)));
                        CHECK(checked(realm_set_get(strings.get(), b_index, &b2)));
                        CHECK(checked(realm_set_get(strings.get(), c_index, &c2)));

                        CHECK(rlm_stdstr(a2) == "a");
                        CHECK(rlm_stdstr(b2) == "b");
                        CHECK(c2.type == RLM_TYPE_NULL);

                        bool erased = false;
                        CHECK(checked(realm_set_erase(strings.get(), a2, &erased)));
                        CHECK(erased);
                        CHECK(checked(realm_set_erase(strings.get(), rlm_int_val(987), &erased)));
                        CHECK(!erased);
                    });
                }

                SECTION("equality") {
                    auto strings2 = cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_string_set"]));
                    CHECK(strings2);
                    CHECK(realm_equals(strings.get(), strings2.get()));

                    write([&]() {
                        auto obj3 = cptr_checked(realm_object_create(realm, class_foo.key));
                        CHECK(obj3);
                        auto strings3 =
                            cptr_checked(realm_get_set(obj3.get(), foo_properties["nullable_string_set"]));
                        CHECK(!realm_equals(strings.get(), strings3.get()));
                    });
                }

                SECTION("parse query for sets") {
                    auto links = cptr_checked(realm_get_set(obj1.get(), foo_properties["link_set"]));
                    CHECK(links);
                    cptr_checked(realm_query_parse_for_set(links.get(), "TRUEPREDICATE", 0, nullptr));
                }
            }

            SECTION("get/insert all property types") {
                realm_value_t null = rlm_null();
                realm_value_t integer = rlm_int_val(987);
                realm_value_t boolean = rlm_bool_val(true);
                realm_value_t string = rlm_str_val("My string");
                const uint8_t binary_data[] = {0, 1, 2, 3, 4, 5, 6, 7};
                realm_value_t binary = rlm_binary_val(binary_data, sizeof(binary_data));
                realm_value_t timestamp = rlm_timestamp_val(1000000, 123123123);
                realm_value_t fnum = rlm_float_val(123.f);
                realm_value_t dnum = rlm_double_val(456.0);
                realm_value_t decimal = rlm_decimal_val(999.0);
                realm_value_t object_id = rlm_object_id_val("abc123abc123");
                realm_value_t uuid = rlm_uuid_val("01234567-9abc-4def-9012-3456789abcde");

                auto int_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["int_set"]));
                auto bool_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["bool_set"]));
                auto string_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["string_set"]));
                auto binary_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["binary_set"]));
                auto timestamp_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["timestamp_set"]));
                auto float_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["float_set"]));
                auto double_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["double_set"]));
                auto decimal_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["decimal_set"]));
                auto object_id_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["object_id_set"]));
                auto uuid_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["uuid_set"]));
                auto nullable_int_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_int_set"]));
                auto nullable_bool_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_bool_set"]));
                auto nullable_string_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_string_set"]));
                auto nullable_binary_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_binary_set"]));
                auto nullable_timestamp_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_timestamp_set"]));
                auto nullable_float_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_float_set"]));
                auto nullable_double_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_double_set"]));
                auto nullable_decimal_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_decimal_set"]));
                auto nullable_object_id_set =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_object_id_set"]));
                auto nullable_uuid_set = cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_uuid_set"]));

                write([&]() {
                    CHECK(realm_set_insert(int_set.get(), integer, nullptr, nullptr));
                    CHECK(realm_set_insert(bool_set.get(), boolean, nullptr, nullptr));
                    CHECK(realm_set_insert(string_set.get(), string, nullptr, nullptr));
                    CHECK(realm_set_insert(binary_set.get(), binary, nullptr, nullptr));
                    CHECK(realm_set_insert(timestamp_set.get(), timestamp, nullptr, nullptr));
                    CHECK(realm_set_insert(float_set.get(), fnum, nullptr, nullptr));
                    CHECK(realm_set_insert(double_set.get(), dnum, nullptr, nullptr));
                    CHECK(realm_set_insert(decimal_set.get(), decimal, nullptr, nullptr));
                    CHECK(realm_set_insert(object_id_set.get(), object_id, nullptr, nullptr));
                    CHECK(realm_set_insert(uuid_set.get(), uuid, nullptr, nullptr));

                    CHECK(realm_set_insert(nullable_int_set.get(), integer, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_bool_set.get(), boolean, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_string_set.get(), string, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_binary_set.get(), binary, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_timestamp_set.get(), timestamp, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_float_set.get(), fnum, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_double_set.get(), dnum, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_decimal_set.get(), decimal, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_object_id_set.get(), object_id, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_uuid_set.get(), uuid, nullptr, nullptr));

                    CHECK(realm_set_insert(nullable_int_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_bool_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_string_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_binary_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_timestamp_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_float_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_double_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_decimal_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_object_id_set.get(), null, nullptr, nullptr));
                    CHECK(realm_set_insert(nullable_uuid_set.get(), null, nullptr, nullptr));
                });

                realm_value_t value;

                CHECK(realm_set_get(int_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, integer));
                CHECK(realm_set_get(bool_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, boolean));
                CHECK(realm_set_get(string_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, string));
                CHECK(realm_set_get(binary_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, binary));
                CHECK(realm_set_get(timestamp_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(realm_set_get(float_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, fnum));
                CHECK(realm_set_get(double_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, dnum));
                CHECK(realm_set_get(decimal_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, decimal));
                CHECK(realm_set_get(object_id_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, object_id));
                CHECK(realm_set_get(uuid_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, uuid));
                CHECK(realm_set_get(nullable_int_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, integer));
                CHECK(realm_set_get(nullable_bool_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, boolean));
                CHECK(realm_set_get(nullable_string_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, string));
                CHECK(realm_set_get(nullable_binary_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, binary));
                CHECK(realm_set_get(nullable_timestamp_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(realm_set_get(nullable_float_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, fnum));
                CHECK(realm_set_get(nullable_double_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, dnum));
                CHECK(realm_set_get(nullable_decimal_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, decimal));
                CHECK(realm_set_get(nullable_object_id_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, object_id));
                CHECK(realm_set_get(nullable_uuid_set.get(), 1, &value));
                CHECK(rlm_val_eq(value, uuid));

                write([&]() {
                    size_t index;
                    bool inserted;
                    CHECK(realm_set_insert(nullable_int_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_bool_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_string_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_binary_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_timestamp_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_float_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_double_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_decimal_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_object_id_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                    CHECK(realm_set_insert(nullable_uuid_set.get(), null, &index, &inserted));
                    CHECK((index == 0 && !inserted));
                });

                // Note: This relies on the fact that NULL is "less than" other
                // values in the internal sort order.
                CHECK(realm_set_get(nullable_int_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_bool_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_string_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_binary_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_timestamp_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_float_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_double_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_decimal_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_object_id_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_set_get(nullable_uuid_set.get(), 0, &value));
                CHECK(rlm_val_eq(value, null));
            }

            SECTION("links") {
                CPtr<realm_set_t> bars;

                write([&]() {
                    bars = cptr_checked(realm_get_set(obj1.get(), foo_properties["link_set"]));
                    auto bar_link = realm_object_as_link(obj2.get());
                    realm_value_t bar_link_val;
                    bar_link_val.type = RLM_TYPE_LINK;
                    bar_link_val.link = bar_link;
                    size_t index;
                    bool inserted;
                    CHECK(checked(realm_set_insert(bars.get(), bar_link_val, &index, &inserted)));
                    CHECK((index == 0 && inserted));
                    CHECK(checked(realm_set_insert(bars.get(), bar_link_val, &index, &inserted)));
                    CHECK((index == 0 && !inserted));
                    size_t size;
                    CHECK(checked(realm_set_size(bars.get(), &size)));
                    CHECK(size == 1);

                    auto results =
                        cptr_checked(realm_get_backlinks(obj2.get(), class_foo.key, foo_properties["link_set"]));
                    CHECK(results->size() == 1);
                    auto mixed_link = results->get_any(0);
                    CHECK(!mixed_link.is_unresolved_link());
                    CHECK(mixed_link.is_type(type_TypedLink));
                    auto link = mixed_link.get_link();
                    CHECK(link.get_obj_key() == obj1->get_obj().get_key());
                    CHECK(link.get_table_key() == obj1->get_obj().get_table()->get_key());
                });

                SECTION("get") {
                    realm_value_t val;
                    CHECK(checked(realm_set_get(bars.get(), 0, &val)));
                    CHECK(val.type == RLM_TYPE_LINK);
                    CHECK(val.link.target_table == class_bar.key);
                    CHECK(val.link.target == realm_object_get_key(obj2.get()));

                    auto result = realm_set_get(bars.get(), 1, &val);
                    CHECK(!result);
                    CHECK_ERR(RLM_ERR_INDEX_OUT_OF_BOUNDS);
                }

                SECTION("insert wrong type") {
                    write([&]() {
                        auto foo2 = cptr(realm_object_create(realm, class_foo.key));
                        CHECK(foo2);
                        realm_value_t foo2_link_val;
                        foo2_link_val.type = RLM_TYPE_LINK;
                        foo2_link_val.link = realm_object_as_link(foo2.get());

                        CHECK(!realm_set_insert(bars.get(), foo2_link_val, nullptr, nullptr));
                        CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);
                    });
                }

                SECTION("realm_set_clear()") {
                    write([&]() {
                        CHECK(realm_set_clear(bars.get()));
                    });
                    size_t size;
                    CHECK(realm_set_size(bars.get(), &size));
                    CHECK(size == 0);

                    size_t num_bars;
                    CHECK(realm_get_num_objects(realm, class_bar.key, &num_bars));
                    CHECK(num_bars != 0);
                }

                SECTION("realm_set_remove_all()") {
                    realm_value_t val;
                    CHECK(checked(realm_set_get(bars.get(), 0, &val)));
                    CHECK(val.type == RLM_TYPE_LINK);
                    CHECK(val.link.target_table == class_bar.key);
                    CHECK(val.link.target == realm_object_get_key(obj2.get()));

                    size_t num_bars;
                    size_t size;

                    write([&]() {
                        CHECK(checked(realm_set_remove_all(bars.get())));
                    });

                    CHECK(realm_set_size(bars.get(), &size));
                    CHECK(size == 0);

                    CHECK(realm_get_num_objects(realm, class_bar.key, &num_bars));
                    CHECK(num_bars == 0);
                }
            }

            SECTION("notifications") {
                struct State {
                    CPtr<realm_collection_changes_t> changes;
                    CPtr<realm_async_error_t> error;
                    bool destroyed = false;
                };

                State state;

                auto on_change = [](void* userdata, const realm_collection_changes_t* changes) {
                    auto* state = static_cast<State*>(userdata);
                    state->changes = clone_cptr(changes);
                };

                CPtr<realm_set_t> strings =
                    cptr_checked(realm_get_set(obj1.get(), foo_properties["nullable_string_set"]));

                auto str1 = rlm_str_val("a");
                auto str2 = rlm_str_val("b");
                auto null = rlm_null();

                auto require_change = [&]() {
                    auto token = cptr_checked(
                        realm_set_add_notification_callback(strings.get(), &state, nullptr, nullptr, on_change));
                    checked(realm_refresh(realm, nullptr));
                    return token;
                };

                SECTION("userdata is freed when the token is destroyed") {
                    auto token = cptr_checked(realm_set_add_notification_callback(
                        strings.get(), &state,
                        [](void* p) {
                            static_cast<State*>(p)->destroyed = true;
                        },
                        nullptr, nullptr));
                    CHECK(!state.destroyed);
                    token.reset();
                    CHECK(state.destroyed);
                }

                SECTION("insertion,deletion sends a change callback") {
                    write([&]() {
                        checked(realm_set_insert(strings.get(), str1, nullptr, nullptr));
                    });

                    auto token = require_change();
                    write([&]() {
                        checked(realm_set_erase(strings.get(), str1, nullptr));
                        checked(realm_set_insert(strings.get(), str2, nullptr, nullptr));
                        checked(realm_set_insert(strings.get(), null, nullptr, nullptr));
                    });
                    CHECK(!state.error);
                    CHECK(state.changes);

                    size_t num_deletion_ranges, num_insertion_ranges, num_modification_ranges, num_moves;
                    realm_collection_changes_get_num_ranges(state.changes.get(), &num_deletion_ranges,
                                                            &num_insertion_ranges, &num_modification_ranges,
                                                            &num_moves);
                    CHECK(num_deletion_ranges == 1);
                    CHECK(num_insertion_ranges == 1);
                    CHECK(num_modification_ranges == 0);
                    CHECK(num_moves == 0);

                    realm_index_range_t insertion_range, deletion_range;
                    realm_collection_changes_get_ranges(state.changes.get(), &deletion_range, 1, &insertion_range, 1,
                                                        nullptr, 0, nullptr, 0, nullptr, 0);
                    CHECK(deletion_range.from == 0);
                    CHECK(deletion_range.to == 1);
                    CHECK(insertion_range.from == 0);
                    CHECK(insertion_range.to == 2);

                    write([&]() {
                        checked(realm_set_clear(strings.get()));
                    });

                    size_t num_deletions, num_insertions, num_modifications;
                    bool collection_cleared = false;
                    realm_collection_changes_get_num_changes(state.changes.get(), &num_deletions, &num_insertions,
                                                             &num_modifications, &num_moves, &collection_cleared,
                                                             nullptr);
                    CHECK(collection_cleared == true);
                }
            }
        }

        SECTION("dictionaries") {
            SECTION("realm_get_dictionary() errors") {
                CHECK(!realm_get_dictionary(obj1.get(), foo_properties["int"]));
                CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);

                CHECK(!realm_get_dictionary(obj1.get(), 123123123));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("nullable strings") {
                auto strings = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_string_dict"]));
                CHECK(strings);
                CHECK(!realm_is_frozen(strings.get()));

                realm_value_t a = rlm_str_val("a");
                realm_value_t b = rlm_str_val("b");
                realm_value_t c = rlm_null();
                realm_value_t key_a = rlm_str_val("key_a");
                realm_value_t key_b = rlm_str_val("key_b");
                realm_value_t key_c = rlm_str_val("key_c");

                SECTION("realm_equals() type check") {
                    CHECK(!realm_equals(strings.get(), obj1.get()));
                }

                SECTION("realm_clone()") {
                    auto dict2 = clone_cptr(strings.get());
                    CHECK(realm_equals(strings.get(), dict2.get()));
                    CHECK(strings.get() != dict2.get());
                }

                SECTION("insert, then get, then erase") {
                    write([&]() {
                        bool inserted = false;
                        CHECK(checked(realm_dictionary_insert(strings.get(), key_a, a, nullptr, &inserted)));
                        CHECK(inserted);
                        CHECK(checked(realm_dictionary_insert(strings.get(), key_b, b, nullptr, &inserted)));
                        CHECK(inserted);
                        CHECK(checked(realm_dictionary_insert(strings.get(), key_c, c, nullptr, &inserted)));
                        CHECK(inserted);

                        realm_value_t a2, b2, c2;
                        bool found = false;
                        CHECK(checked(realm_dictionary_find(strings.get(), key_a, &a2, &found)));
                        CHECK(found);
                        CHECK(checked(realm_dictionary_find(strings.get(), key_b, &b2, &found)));
                        CHECK(found);
                        CHECK(checked(realm_dictionary_find(strings.get(), key_c, &c2, &found)));
                        CHECK(found);

                        CHECK(rlm_stdstr(a2) == "a");
                        CHECK(rlm_stdstr(b2) == "b");
                        CHECK(c2.type == RLM_TYPE_NULL);

                        bool erased = false;
                        CHECK(checked(realm_dictionary_erase(strings.get(), key_a, &erased)));
                        CHECK(erased);
                        CHECK(checked(realm_dictionary_erase(strings.get(), rlm_int_val(987), &erased)));
                        CHECK(!erased);
                    });
                }

                SECTION("equality") {
                    auto strings2 =
                        cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_string_dict"]));
                    CHECK(strings2);
                    CHECK(realm_equals(strings.get(), strings2.get()));

                    write([&]() {
                        auto obj3 = cptr_checked(realm_object_create(realm, class_foo.key));
                        CHECK(obj3);
                        auto strings3 =
                            cptr_checked(realm_get_dictionary(obj3.get(), foo_properties["nullable_string_dict"]));
                        CHECK(!realm_equals(strings.get(), strings3.get()));
                    });
                }
            }

            SECTION("get/insert all property types") {
                realm_value_t key = rlm_str_val("k");
                realm_value_t key2 = rlm_str_val("k2");

                realm_value_t null = rlm_null();
                realm_value_t integer = rlm_int_val(987);
                realm_value_t boolean = rlm_bool_val(true);
                realm_value_t string = rlm_str_val("My string");
                const uint8_t binary_data[] = {0, 1, 2, 3, 4, 5, 6, 7};
                realm_value_t binary = rlm_binary_val(binary_data, sizeof(binary_data));
                realm_value_t timestamp = rlm_timestamp_val(1000000, 123123123);
                realm_value_t fnum = rlm_float_val(123.f);
                realm_value_t dnum = rlm_double_val(456.0);
                realm_value_t decimal = rlm_decimal_val(999.0);
                realm_value_t object_id = rlm_object_id_val("abc123abc123");
                realm_value_t uuid = rlm_uuid_val("01234567-9abc-4def-9012-3456789abcde");

                auto int_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["int_dict"]));
                auto bool_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["bool_dict"]));
                auto string_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["string_dict"]));
                auto binary_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["binary_dict"]));
                auto timestamp_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["timestamp_dict"]));
                auto float_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["float_dict"]));
                auto double_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["double_dict"]));
                auto decimal_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["decimal_dict"]));
                auto object_id_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["object_id_dict"]));
                auto uuid_dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["uuid_dict"]));
                auto nullable_int_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_int_dict"]));
                auto nullable_bool_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_bool_dict"]));
                auto nullable_string_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_string_dict"]));
                auto nullable_binary_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_binary_dict"]));
                auto nullable_timestamp_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_timestamp_dict"]));
                auto nullable_float_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_float_dict"]));
                auto nullable_double_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_double_dict"]));
                auto nullable_decimal_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_decimal_dict"]));
                auto nullable_object_id_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_object_id_dict"]));
                auto nullable_uuid_dict =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_uuid_dict"]));

                write([&]() {
                    size_t index;
                    bool inserted;
                    CHECK(!realm_dictionary_insert(int_dict.get(), rlm_int_val(987), integer, &index, &inserted));

                    CHECK(realm_dictionary_insert(int_dict.get(), key, integer, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(bool_dict.get(), key, boolean, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(string_dict.get(), key, string, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(binary_dict.get(), key, binary, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(timestamp_dict.get(), key, timestamp, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(float_dict.get(), key, fnum, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(double_dict.get(), key, dnum, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(decimal_dict.get(), key, decimal, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(object_id_dict.get(), key, object_id, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(uuid_dict.get(), key, uuid, &index, &inserted));
                    CHECK((inserted && index == 0));

                    CHECK(realm_dictionary_insert(nullable_int_dict.get(), key, integer, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_bool_dict.get(), key, boolean, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_string_dict.get(), key, string, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_binary_dict.get(), key, binary, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_timestamp_dict.get(), key, timestamp, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_float_dict.get(), key, fnum, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_double_dict.get(), key, dnum, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_decimal_dict.get(), key, decimal, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_object_id_dict.get(), key, object_id, &index, &inserted));
                    CHECK((inserted && index == 0));
                    CHECK(realm_dictionary_insert(nullable_uuid_dict.get(), key, uuid, &index, &inserted));
                    CHECK((inserted && index == 0));

                    CHECK(realm_dictionary_insert(nullable_int_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_bool_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_string_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_binary_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_timestamp_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_float_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_double_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_decimal_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_object_id_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                    CHECK(realm_dictionary_insert(nullable_uuid_dict.get(), key2, null, &index, &inserted));
                    CHECK((inserted && index == 1));
                });

                realm_value_t k, value;

                CHECK(realm_dictionary_get(int_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, integer));
                CHECK(realm_dictionary_get(bool_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, boolean));
                CHECK(realm_dictionary_get(string_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, string));
                CHECK(realm_dictionary_get(binary_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, binary));
                CHECK(realm_dictionary_get(timestamp_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(realm_dictionary_get(float_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, fnum));
                CHECK(realm_dictionary_get(double_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, dnum));
                CHECK(realm_dictionary_get(decimal_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, decimal));
                CHECK(realm_dictionary_get(object_id_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, object_id));
                CHECK(realm_dictionary_get(uuid_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, uuid));
                CHECK(realm_dictionary_get(nullable_int_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, integer));
                CHECK(realm_dictionary_get(nullable_bool_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, boolean));
                CHECK(realm_dictionary_get(nullable_string_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, string));
                CHECK(realm_dictionary_get(nullable_binary_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, binary));
                CHECK(realm_dictionary_get(nullable_timestamp_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(realm_dictionary_get(nullable_float_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, fnum));
                CHECK(realm_dictionary_get(nullable_double_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, dnum));
                CHECK(realm_dictionary_get(nullable_decimal_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, decimal));
                CHECK(realm_dictionary_get(nullable_object_id_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, object_id));
                CHECK(realm_dictionary_get(nullable_uuid_dict.get(), 0, &k, &value));
                CHECK(rlm_val_eq(k, key));
                CHECK(rlm_val_eq(value, uuid));

                write([&]() {
                    size_t index;
                    bool inserted;
                    CHECK(realm_dictionary_insert(nullable_int_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_bool_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_string_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_binary_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_timestamp_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_float_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_double_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_decimal_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_object_id_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                    CHECK(realm_dictionary_insert(nullable_uuid_dict.get(), key2, null, &index, &inserted));
                    CHECK(!inserted);
                });

                CHECK(realm_dictionary_find(int_dict.get(), rlm_int_val(987), &value, &found));
                CHECK(!found);
                CHECK(realm_dictionary_find(int_dict.get(), rlm_str_val("Boogeyman"), &value, &found));
                CHECK(!found);
                CHECK(realm_dictionary_find(int_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, integer));
                CHECK(realm_dictionary_find(bool_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, boolean));
                CHECK(realm_dictionary_find(string_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, string));
                CHECK(realm_dictionary_find(binary_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, binary));
                CHECK(realm_dictionary_find(timestamp_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(realm_dictionary_find(float_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, fnum));
                CHECK(realm_dictionary_find(double_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, dnum));
                CHECK(realm_dictionary_find(decimal_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, decimal));
                CHECK(realm_dictionary_find(object_id_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, object_id));
                CHECK(realm_dictionary_find(uuid_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, uuid));
                CHECK(realm_dictionary_find(nullable_int_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, integer));
                CHECK(realm_dictionary_find(nullable_bool_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, boolean));
                CHECK(realm_dictionary_find(nullable_string_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, string));
                CHECK(realm_dictionary_find(nullable_binary_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, binary));
                CHECK(realm_dictionary_find(nullable_timestamp_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, timestamp));
                CHECK(realm_dictionary_find(nullable_float_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, fnum));
                CHECK(realm_dictionary_find(nullable_double_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, dnum));
                CHECK(realm_dictionary_find(nullable_decimal_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, decimal));
                CHECK(realm_dictionary_find(nullable_object_id_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, object_id));
                CHECK(realm_dictionary_find(nullable_uuid_dict.get(), key, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, uuid));

                CHECK(realm_dictionary_find(nullable_int_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_bool_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_string_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_binary_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_timestamp_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_float_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_double_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_decimal_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_object_id_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
                CHECK(realm_dictionary_find(nullable_uuid_dict.get(), key2, &value, &found));
                CHECK(found);
                CHECK(rlm_val_eq(value, null));
            }

            SECTION("links") {
                CPtr<realm_dictionary_t> bars;
                realm_value_t key = rlm_str_val("k");

                write([&]() {
                    bars = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["link_dict"]));
                    auto bar_link = realm_object_as_link(obj2.get());
                    realm_value_t bar_link_val;
                    bar_link_val.type = RLM_TYPE_LINK;
                    bar_link_val.link = bar_link;
                    size_t index;
                    bool inserted;
                    CHECK(checked(realm_dictionary_insert(bars.get(), key, bar_link_val, &index, &inserted)));
                    CHECK((index == 0 && inserted));
                    CHECK(checked(realm_dictionary_insert(bars.get(), key, bar_link_val, &index, &inserted)));
                    CHECK((index == 0 && !inserted));
                    size_t size;
                    CHECK(checked(realm_dictionary_size(bars.get(), &size)));
                    CHECK(size == 1);
                });

                SECTION("get") {
                    realm_value_t k, val;
                    CHECK(checked(realm_dictionary_get(bars.get(), 0, &k, &val)));
                    CHECK(rlm_val_eq(k, key));
                    CHECK(val.type == RLM_TYPE_LINK);
                    CHECK(val.link.target_table == class_bar.key);
                    CHECK(val.link.target == realm_object_get_key(obj2.get()));

                    auto result = realm_dictionary_get(bars.get(), 1, &k, &val);
                    CHECK(!result);
                    CHECK_ERR(RLM_ERR_INDEX_OUT_OF_BOUNDS);
                }

                SECTION("insert wrong type") {
                    write([&]() {
                        auto foo2 = cptr(realm_object_create(realm, class_foo.key));
                        CHECK(foo2);
                        realm_value_t foo2_link_val;
                        foo2_link_val.type = RLM_TYPE_LINK;
                        foo2_link_val.link = realm_object_as_link(foo2.get());

                        CHECK(!realm_dictionary_insert(bars.get(), key, foo2_link_val, nullptr, nullptr));
                        CHECK_ERR(RLM_ERR_PROPERTY_TYPE_MISMATCH);
                    });
                }

                SECTION("realm_dictionary_clear()") {
                    write([&]() {
                        CHECK(realm_dictionary_clear(bars.get()));
                    });
                    size_t size;
                    CHECK(realm_dictionary_size(bars.get(), &size));
                    CHECK(size == 0);

                    size_t num_bars;
                    CHECK(realm_get_num_objects(realm, class_bar.key, &num_bars));
                    CHECK(num_bars != 0);
                }
            }

            SECTION("notifications") {
                struct State {
                    CPtr<realm_collection_changes_t> changes;
                    CPtr<realm_dictionary_changes_t> dictionary_changes;
                    CPtr<realm_async_error_t> error;
                    bool destroyed = false;
                };

                State state;
                auto on_dictionary_change = [](void* userdata, const realm_dictionary_changes_t* changes) {
                    auto* state = static_cast<State*>(userdata);
                    state->dictionary_changes = clone_cptr(changes);
                };

                CPtr<realm_dictionary_t> strings =
                    cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["nullable_string_dict"]));

                auto str1 = rlm_str_val("a");
                auto str2 = rlm_str_val("b");
                auto null = rlm_null();


                auto require_change = [&]() {
                    auto token = cptr_checked(realm_dictionary_add_notification_callback(
                        strings.get(), &state, nullptr, nullptr, on_dictionary_change));
                    checked(realm_refresh(realm, nullptr));
                    return token;
                };

                SECTION("userdata is freed when the token is destroyed") {
                    auto token = cptr_checked(realm_dictionary_add_notification_callback(
                        strings.get(), &state,
                        [](void* p) {
                            static_cast<State*>(p)->destroyed = true;
                        },
                        nullptr, nullptr));
                    CHECK(!state.destroyed);
                    token.reset();
                    CHECK(state.destroyed);
                }

                SECTION("insertion, deletions sends a change callback") {
                    write([&]() {
                        checked(realm_dictionary_insert(strings.get(), rlm_str_val("a"), str1, nullptr, nullptr));
                    });
                    auto token = require_change();
                    write([&]() {
                        checked(realm_dictionary_erase(strings.get(), rlm_str_val("a"), nullptr));
                        checked(realm_dictionary_insert(strings.get(), rlm_str_val("b"), str2, nullptr, nullptr));
                        checked(realm_dictionary_insert(strings.get(), rlm_str_val("c"), null, nullptr, nullptr));
                    });
                    CHECK(!state.error);
                    CHECK(state.dictionary_changes);

                    size_t num_deletions, num_insertions, num_modifications;
                    realm_dictionary_get_changes(state.dictionary_changes.get(), &num_deletions, &num_insertions,
                                                 &num_modifications, nullptr);
                    CHECK(num_deletions == 1);
                    CHECK(num_insertions == 2);
                    CHECK(num_modifications == 0);
                    realm_value_t *deletions = nullptr, *insertions = nullptr, *modifications = nullptr;
                    bool collection_cleared = false;
                    deletions = (realm_value_t*)malloc(sizeof(realm_value_t) * num_deletions);
                    insertions = (realm_value_t*)malloc(sizeof(realm_value_t) * num_insertions);
                    realm_dictionary_get_changed_keys(state.dictionary_changes.get(), deletions, &num_deletions,
                                                      insertions, &num_insertions, modifications, &num_modifications,
                                                      &collection_cleared);
                    CHECK(deletions != nullptr);
                    CHECK(insertions != nullptr);
                    CHECK(modifications == nullptr);
                    realm_free(deletions);
                    realm_free(insertions);
                    realm_free(modifications);

                    write([&]() {
                        checked(realm_dictionary_clear(strings.get()));
                    });
                    realm_dictionary_get_changed_keys(state.dictionary_changes.get(), deletions, &num_deletions,
                                                      insertions, &num_insertions, modifications, &num_modifications,
                                                      &collection_cleared);
                    CHECK(collection_cleared == true);
                }
            }

            SECTION("realm_dictionary_content_checks") {
                auto ints = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["int_dict"]));
                CHECK(ints);
                CHECK(!realm_is_frozen(ints.get()));
                realm_value_t key1 = rlm_str_val("k");
                realm_value_t key2 = rlm_str_val("k2");
                realm_value_t integer1 = rlm_int_val(987);
                realm_value_t integer2 = rlm_int_val(988);

                write([&]() {
                    bool inserted = false;
                    CHECK(checked(realm_dictionary_insert(ints.get(), key1, integer1, nullptr, &inserted)));
                    CHECK(inserted);
                    CHECK(checked(realm_dictionary_insert(ints.get(), key2, integer2, nullptr, &inserted)));
                    CHECK(inserted);
                });

                SECTION("realm_dictionary_get_keys") {
                    size_t size = 0;
                    realm_results_t* keys = nullptr;
                    CHECK(checked(realm_dictionary_get_keys(ints.get(), &size, &keys)));
                    CHECK(keys);
                    CHECK((*keys).size() == size);
                    realm_release(keys);
                }

                SECTION("realm_dictionary_contains_key") {
                    bool found = false;
                    CHECK(checked(realm_dictionary_contains_key(ints.get(), key1, &found)));
                    CHECK(found);
                    found = false;
                    CHECK(checked(realm_dictionary_contains_key(ints.get(), key2, &found)));
                    CHECK(found);
                    realm_value_t key_no_present = rlm_str_val("kkkk");
                    CHECK(checked(realm_dictionary_contains_key(ints.get(), key_no_present, &found)));
                    CHECK(!found);
                }

                SECTION("realm_dictionary_contains_value") {
                    size_t index = -1;
                    CHECK(checked(realm_dictionary_contains_value(ints.get(), integer1, &index)));
                    CHECK(index == 0);
                    CHECK(checked(realm_dictionary_contains_value(ints.get(), integer2, &index)));
                    CHECK(index == 1);
                    realm_value_t integer_no_present = rlm_int_val(678);
                    CHECK(checked(realm_dictionary_contains_value(ints.get(), integer_no_present, &index)));
                    CHECK(index == realm::npos);
                }
            }
        }

        SECTION("notifications") {
            struct State {
                CPtr<realm_object_changes_t> changes;
                CPtr<realm_async_error_t> error;
                bool called;
            };

            State state;

            auto on_change = [](void* userdata, const realm_object_changes_t* changes) {
                auto state = static_cast<State*>(userdata);
                state->changes = clone_cptr(changes);
                state->called = true;
            };

            auto require_change = [&]() {
                auto token =
                    cptr(realm_object_add_notification_callback(obj1.get(), &state, nullptr, nullptr, on_change));
                checked(realm_refresh(realm, nullptr));
                return token;
            };

            SECTION("deleting the object sends a change notification") {
                auto token = require_change();
                write([&]() {
                    checked(realm_object_delete(obj1.get()));
                });
                CHECK(!state.error);
                CHECK(state.changes);
                bool deleted = realm_object_changes_is_deleted(state.changes.get());
                CHECK(deleted);
            }

            SECTION("modifying the object sends a change notification for the object, and for the changed column") {
                auto token = require_change();
                write([&]() {
                    checked(realm_set_value(obj1.get(), foo_int_key, rlm_int_val(999), false));
                    checked(realm_set_value(obj1.get(), foo_str_key, rlm_str_val("aaa"), false));
                });
                CHECK(!state.error);
                CHECK(state.changes);
                bool deleted = realm_object_changes_is_deleted(state.changes.get());
                CHECK(!deleted);
                size_t num_modified = realm_object_changes_get_num_modified_properties(state.changes.get());
                CHECK(num_modified == 2);
                realm_property_key_t modified_keys[2];
                size_t n = realm_object_changes_get_modified_properties(state.changes.get(), modified_keys, 2);
                CHECK(n == 2);
                CHECK(modified_keys[0] == foo_int_key);
                CHECK(modified_keys[1] == foo_str_key);

                n = realm_object_changes_get_modified_properties(state.changes.get(), nullptr, 2);
                CHECK(n == 2);

                n = realm_object_changes_get_modified_properties(state.changes.get(), modified_keys, 0);
                CHECK(n == 0);
            }
            SECTION("modifying the object while observing a specific value") {
                const char* foo_strings[1] = {"public_int"};
                auto key_path_array = realm_create_key_path_array(realm, class_foo.key, 1, foo_strings);
                REQUIRE(key_path_array);
                auto token = cptr(
                    realm_object_add_notification_callback(obj1.get(), &state, nullptr, key_path_array, on_change));
                realm_release(key_path_array);
                checked(realm_refresh(realm, nullptr));
                state.called = false;
                write([&]() {
                    checked(realm_set_value(obj1.get(), foo_int_key, rlm_int_val(999), false));
                });
                REQUIRE(state.called);
                CHECK(!state.error);
                CHECK(state.changes);
                realm_property_key_t modified_keys[2];
                size_t n = realm_object_changes_get_modified_properties(state.changes.get(), modified_keys, 2);
                CHECK(n == 1);
                CHECK(modified_keys[0] == foo_int_key);

                state.called = false;
                write([&]() {
                    // checked(realm_set_value(obj1.get(), foo_int_key, rlm_int_val(999), false));
                    checked(realm_set_value(obj1.get(), foo_str_key, rlm_str_val("aaa"), false));
                });
                REQUIRE(!state.called);
            }
        }
    }

    SECTION("threads") {
        CPtr<realm_object_t> foo_obj, bar_obj;
        write([&]() {
            foo_obj = cptr_checked(realm_object_create(realm, class_foo.key));
            realm_set_value(foo_obj.get(), foo_int_key, rlm_int_val(123), false);
            bar_obj = cptr_checked(realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(123)));
        });

        auto list = cptr_checked(realm_get_list(foo_obj.get(), foo_properties["int_list"]));
        auto set = cptr_checked(realm_get_set(foo_obj.get(), foo_properties["int_set"]));
        auto dictionary = cptr_checked(realm_get_dictionary(foo_obj.get(), foo_properties["int_dict"]));
        auto results = cptr_checked(realm_object_find_all(realm, class_foo.key));

        SECTION("wrong thread") {
            std::thread t{[&]() {
                realm_value_t val;
                CHECK(!realm_get_value(foo_obj.get(), foo_int_key, &val));
                CHECK_ERR(RLM_ERR_WRONG_THREAD);
            }};

            t.join();
        }

        SECTION("thread-safe references") {
            auto foo_obj_tsr = cptr_checked(realm_create_thread_safe_reference(foo_obj.get()));
            auto bar_obj_tsr = cptr_checked(realm_create_thread_safe_reference(bar_obj.get()));
            auto list_tsr = cptr_checked(realm_create_thread_safe_reference(list.get()));
            auto set_tsr = cptr_checked(realm_create_thread_safe_reference(set.get()));
            auto dict_tsr = cptr_checked(realm_create_thread_safe_reference(dictionary.get()));
            auto results_tsr = cptr_checked(realm_create_thread_safe_reference(results.get()));

            SECTION("resolve") {
                std::thread t{[&]() {
                    auto config = make_config(test_file.path.c_str());
                    auto realm2 = cptr_checked(realm_open(config.get()));
                    auto foo_obj2 =
                        cptr_checked(realm_object_from_thread_safe_reference(realm2.get(), foo_obj_tsr.get()));
                    auto bar_obj2 =
                        cptr_checked(realm_object_from_thread_safe_reference(realm2.get(), bar_obj_tsr.get()));
                    auto results2 =
                        cptr_checked(realm_results_from_thread_safe_reference(realm2.get(), results_tsr.get()));
                    auto list2 = cptr_checked(realm_list_from_thread_safe_reference(realm2.get(), list_tsr.get()));
                    auto set2 = cptr_checked(realm_set_from_thread_safe_reference(realm2.get(), set_tsr.get()));
                    auto dict2 =
                        cptr_checked(realm_dictionary_from_thread_safe_reference(realm2.get(), dict_tsr.get()));

                    realm_value_t foo_obj_int;
                    CHECK(realm_get_value(foo_obj2.get(), foo_int_key, &foo_obj_int));
                    CHECK(rlm_val_eq(foo_obj_int, rlm_int_val(123)));

                    size_t count;
                    CHECK(realm_results_count(results2.get(), &count));
                    CHECK(count == 1);
                }};

                t.join();
            }

            SECTION("resolve in frozen") {
                auto realm2 = cptr_checked(realm_freeze(realm));
                CHECK(realm_is_frozen(realm2.get()));
                CHECK(realm != realm2.get());

                auto foo_obj2 =
                    cptr_checked(realm_object_from_thread_safe_reference(realm2.get(), foo_obj_tsr.get()));
                CHECK(realm_is_frozen(foo_obj2.get()));
            }

            SECTION("type error") {
                CHECK(!realm_object_from_thread_safe_reference(realm, list_tsr.get()));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
                CHECK(!realm_list_from_thread_safe_reference(realm, foo_obj_tsr.get()));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
                CHECK(!realm_set_from_thread_safe_reference(realm, list_tsr.get()));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
                CHECK(!realm_dictionary_from_thread_safe_reference(realm, set_tsr.get()));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
                CHECK(!realm_results_from_thread_safe_reference(realm, list_tsr.get()));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
                CHECK(!realm_from_thread_safe_reference(list_tsr.get(), nullptr));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
            }

            SECTION("non-sendable") {
                auto c = cptr(realm_config_new());
                CHECK(!realm_create_thread_safe_reference(c.get()));
                CHECK_ERR(RLM_ERR_ILLEGAL_OPERATION);
            }
        }
    }

    SECTION("freeze and thaw") {
        SECTION("realm") {
            auto frozen_realm = cptr_checked(realm_freeze(realm));
            CHECK(!realm_is_frozen(realm));
            CHECK(realm_is_frozen(frozen_realm.get()));
        }

        SECTION("objects") {
            CPtr<realm_object_t> obj1;
            realm_value_t value;

            write([&]() {
                obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
                CHECK(obj1);
            });
            CHECK(checked(realm_get_value(obj1.get(), foo_str_key, &value)));
            CHECK(value.type == RLM_TYPE_STRING);
            CHECK(strncmp(value.string.data, "", value.string.size) == 0);

            auto frozen_realm = cptr_checked(realm_freeze(realm));
            realm_object_t* frozen_obj1;
            CHECK(realm_object_resolve_in(obj1.get(), frozen_realm.get(), &frozen_obj1));

            write([&]() {
                CHECK(checked(realm_set_value(obj1.get(), foo_str_key, rlm_str_val("Hello, World!"), false)));
            });

            CHECK(checked(realm_get_value(obj1.get(), foo_str_key, &value)));
            CHECK(value.type == RLM_TYPE_STRING);
            CHECK(strncmp(value.string.data, "Hello, World!", value.string.size) == 0);

            CHECK(checked(realm_get_value(frozen_obj1, foo_str_key, &value)));
            CHECK(value.type == RLM_TYPE_STRING);
            CHECK(strncmp(value.string.data, "", value.string.size) == 0);
            realm_object_t* thawed_obj1;
            CHECK(realm_object_resolve_in(obj1.get(), realm, &thawed_obj1));
            CHECK(thawed_obj1);
            CHECK(checked(realm_get_value(thawed_obj1, foo_str_key, &value)));
            CHECK(value.type == RLM_TYPE_STRING);
            CHECK(strncmp(value.string.data, "Hello, World!", value.string.size) == 0);

            write([&]() {
                CHECK(checked(realm_object_delete(obj1.get())));
            });
            realm_object_t* deleted_obj;
            auto b = realm_object_resolve_in(frozen_obj1, realm, &deleted_obj);
            CHECK(b);
            CHECK(deleted_obj == nullptr);
            realm_release(frozen_obj1);
            realm_release(thawed_obj1);
        }

        SECTION("results") {
            auto results = cptr_checked(realm_object_find_all(realm, class_foo.key));
            realm_results_delete_all(results.get());

            write([&]() {
                // Ensure that we start from a known initial state
                CHECK(realm_results_delete_all(results.get()));

                auto obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
                CHECK(obj1);
            });

            size_t count;
            realm_results_count(results.get(), &count);
            CHECK(count == 1);

            auto frozen_realm = cptr_checked(realm_freeze(realm));
            auto frozen_results = cptr_checked(realm_results_resolve_in(results.get(), frozen_realm.get()));
            write([&]() {
                auto obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
                CHECK(obj1);
            });
            realm_results_count(frozen_results.get(), &count);
            CHECK(count == 1);
            realm_results_count(results.get(), &count);
            CHECK(count == 2);

            auto thawed_results = cptr_checked(realm_results_resolve_in(frozen_results.get(), realm));
            realm_results_count(thawed_results.get(), &count);
            CHECK(count == 2);
        }

        SECTION("lists") {
            CPtr<realm_object_t> obj1;
            size_t count;

            write([&]() {
                obj1 = cptr_checked(realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(1)));
                CHECK(obj1);
            });

            auto list = cptr_checked(realm_get_list(obj1.get(), bar_properties["strings"]));
            realm_list_size(list.get(), &count);
            CHECK(count == 0);

            auto frozen_realm = cptr_checked(realm_freeze(realm));
            realm_list_t* frozen_list;
            CHECK(realm_list_resolve_in(list.get(), frozen_realm.get(), &frozen_list));
            realm_list_size(frozen_list, &count);
            CHECK(count == 0);

            write([&]() {
                checked(realm_list_insert(list.get(), 0, rlm_str_val("Hello")));
            });

            realm_list_size(frozen_list, &count);
            CHECK(count == 0);
            realm_list_size(list.get(), &count);
            CHECK(count == 1);

            realm_list_t* thawed_list;
            CHECK(realm_list_resolve_in(frozen_list, realm, &thawed_list));
            realm_list_size(thawed_list, &count);
            CHECK(count == 1);

            CHECK(realm_list_is_valid(thawed_list));
            write([&]() {
                CHECK(checked(realm_object_delete(obj1.get())));
            });
            CHECK(!realm_list_is_valid(thawed_list));
            realm_release(thawed_list);
            CHECK(realm_list_resolve_in(frozen_list, realm, &thawed_list));
            CHECK(thawed_list == nullptr);
            realm_release(frozen_list);
        }

        SECTION("sets") {
            CPtr<realm_object_t> obj1;
            size_t count;

            write([&]() {
                obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
                CHECK(obj1);
            });

            auto set = cptr_checked(realm_get_set(obj1.get(), foo_properties["string_set"]));
            realm_set_size(set.get(), &count);
            CHECK(count == 0);

            auto frozen_realm = cptr_checked(realm_freeze(realm));
            realm_set_t* frozen_set;
            CHECK(realm_set_resolve_in(set.get(), frozen_realm.get(), &frozen_set));
            realm_set_size(frozen_set, &count);
            CHECK(count == 0);

            write([&]() {
                checked(realm_set_insert(set.get(), rlm_str_val("Hello"), nullptr, nullptr));
            });

            realm_set_size(frozen_set, &count);
            CHECK(count == 0);
            realm_set_size(set.get(), &count);
            CHECK(count == 1);

            realm_set_t* thawed_set;
            CHECK(realm_set_resolve_in(frozen_set, realm, &thawed_set));
            realm_set_size(thawed_set, &count);
            CHECK(count == 1);

            CHECK(realm_set_is_valid(thawed_set));
            write([&]() {
                CHECK(checked(realm_object_delete(obj1.get())));
            });
            CHECK(!realm_set_is_valid(thawed_set));
            realm_release(thawed_set);
            CHECK(realm_set_resolve_in(frozen_set, realm, &thawed_set));
            CHECK(thawed_set == nullptr);
            realm_release(frozen_set);
        }

        SECTION("dictionaries") {
            CPtr<realm_object_t> obj1;
            size_t count;

            write([&]() {
                obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
                CHECK(obj1);
            });

            auto dictionary = cptr_checked(realm_get_dictionary(obj1.get(), foo_properties["string_dict"]));
            realm_dictionary_size(dictionary.get(), &count);
            CHECK(count == 0);

            auto frozen_realm = cptr_checked(realm_freeze(realm));
            realm_dictionary_t* frozen_dictionary;
            CHECK(realm_dictionary_resolve_in(dictionary.get(), frozen_realm.get(), &frozen_dictionary));
            realm_dictionary_size(frozen_dictionary, &count);
            CHECK(count == 0);

            write([&]() {
                checked(realm_dictionary_insert(dictionary.get(), rlm_str_val("Hello"), rlm_str_val("world"), nullptr,
                                                nullptr));
            });

            realm_dictionary_size(frozen_dictionary, &count);
            CHECK(count == 0);
            realm_dictionary_size(dictionary.get(), &count);
            CHECK(count == 1);

            realm_dictionary_t* thawed_dictionary;
            CHECK(realm_dictionary_resolve_in(frozen_dictionary, realm, &thawed_dictionary));
            realm_dictionary_size(thawed_dictionary, &count);
            CHECK(count == 1);

            CHECK(realm_dictionary_is_valid(thawed_dictionary));
            write([&]() {
                CHECK(checked(realm_object_delete(obj1.get())));
            });
            CHECK(!realm_dictionary_is_valid(thawed_dictionary));
            realm_release(thawed_dictionary);
            CHECK(realm_dictionary_resolve_in(frozen_dictionary, realm, &thawed_dictionary));
            CHECK(thawed_dictionary == nullptr);
            realm_release(frozen_dictionary);
        }
    }

    realm_close(realm);
    REQUIRE(realm_is_closed(realm));
    realm_release(realm);
}

TEST_CASE("C API - queries", "[c_api]") {
    TestFile test_file;
    realm_t* realm = open_realm(test_file);

    auto write = [&](auto&& f) {
        checked(realm_begin_write(realm));
        f();
        checked(realm_commit(realm));
        checked(realm_refresh(realm, nullptr));
    };

    bool found = false;

    realm_class_info_t class_foo, class_bar;
    CHECK(checked(realm_find_class(realm, "Foo", &found, &class_foo)));
    REQUIRE(found);
    CHECK(checked(realm_find_class(realm, "Bar", &found, &class_bar)));
    REQUIRE(found);

    auto foo_properties = [&](const char* prop) {
        realm_property_info_t property;
        bool found;
        realm_find_property(realm, class_foo.key, prop, &found, &property);
        CHECK(found);
        return property.key;
    };

    auto bar_properties = [&](const char* prop) {
        realm_property_info_t property;
        bool found;
        realm_find_property(realm, class_bar.key, prop, &found, &property);
        CHECK(found);
        return property.key;
    };

    auto foo_int_key = foo_properties("int");
    auto foo_str_key = foo_properties("string");

    CPtr<realm_object_t> obj1;
    CPtr<realm_object_t> obj2;
    auto int_val1 = rlm_int_val(123);
    auto int_val2 = rlm_int_val(456);
    write([&]() {
        obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
        CHECK(obj1);
        CHECK(checked(realm_set_value(obj1.get(), foo_int_key, int_val1, false)));
        CHECK(checked(realm_set_value(obj1.get(), foo_str_key, rlm_str_val("Hello, World!"), false)));
        obj2 = cptr_checked(realm_object_create_with_primary_key(realm, class_bar.key, rlm_int_val(1)));
        CHECK(obj2);
        CPtr<realm_object_t> obj3 = cptr_checked(realm_object_create(realm, class_foo.key));
        CHECK(obj3);
        CHECK(checked(realm_set_value(obj3.get(), foo_int_key, int_val2, false)));
        CPtr<realm_object_t> obj4 = cptr_checked(realm_object_create(realm, class_foo.key));
        CHECK(obj3);
        CHECK(checked(realm_set_value(obj4.get(), foo_int_key, int_val1, false)));
    });

    SECTION("find with primary key") {
        bool found = false;

        auto p = cptr_checked(realm_object_find_with_primary_key(realm, class_bar.key, rlm_int_val(1), &found));
        CHECK(found);
        auto p_key = realm_object_get_key(p.get());
        auto obj2_key = realm_object_get_key(obj2.get());
        CHECK(p_key == obj2_key);
        CHECK(realm_equals(p.get(), obj2.get()));

        CHECK(!realm_object_find_with_primary_key(realm, class_bar.key, rlm_int_val(2), &found));
        CHECK(!found);
        CHECK(!realm_object_find_with_primary_key(realm, class_bar.key, rlm_int_val(2), nullptr));

        // Check that finding by type-mismatched values just find nothing.
        CHECK(!realm_object_find_with_primary_key(realm, class_bar.key, rlm_null(), &found));
        CHECK(!found);
        CHECK(!realm_object_find_with_primary_key(realm, class_bar.key, rlm_str_val("a"), &found));
        CHECK(!found);
        CHECK(!realm_object_find_with_primary_key(realm, class_bar.key, rlm_str_val("a"), nullptr));

        // Invalid class key
        CHECK(!realm_object_find_with_primary_key(realm, 123123123, rlm_int_val(1), nullptr));
        CHECK_ERR(RLM_ERR_NO_SUCH_TABLE);
    }

    SECTION("find all") {
        auto r = cptr_checked(realm_object_find_all(realm, class_bar.key));
        size_t count;
        realm_results_count(r.get(), &count);
        CHECK(count == 1);
    }

    SECTION("query") {
        realm_value_t arg_data[1] = {rlm_str_val("Hello, World!")};
        size_t num_args = 2;
        realm_query_arg_t args[2] = {realm_query_arg_t{1, false, &arg_data[0]},
                                     realm_query_arg_t{1, false, &int_val2}};
        realm_query_arg_t* arg_list = &args[0];
        auto q =
            cptr_checked(realm_query_parse(realm, class_foo.key, "string == $0 SORT(int ASCENDING)", 1, arg_list));

        SECTION("realm_query_description()") {
            const char* descr = realm_query_get_description(q.get());
            std::string expected = "string == \"Hello, World!\" SORT(int ASC)";
            CHECK(descr == expected);
        }

        SECTION("realm_query_count()") {
            size_t count;
            CHECK(checked(realm_query_count(q.get(), &count)));
            CHECK(count == 1);

            SECTION("cloned") {
                auto q2 = clone_cptr(q.get());
                size_t count2;
                CHECK(checked(realm_query_count(q2.get(), &count2)));
                CHECK(count == count2);
            }
            SECTION("realm_query_append_query") {
                auto q2 =
                    cptr_checked(realm_query_append_query(q.get(), "TRUEPREDICATE LIMIT(1)", num_args, arg_list));
                size_t count;
                CHECK(checked(realm_query_count(q2.get(), &count)));
                CHECK(count == 1);
                q2 = cptr_checked(realm_query_append_query(q.get(), "FALSEPREDICATE", num_args, arg_list));
                CHECK(checked(realm_query_count(q2.get(), &count)));
                CHECK(count == 0);
                q2 = cptr_checked(realm_query_append_query(q.get(), "TRUEPREDICATE LIMIT(0)", num_args, arg_list));
                CHECK(checked(realm_query_count(q2.get(), &count)));
                CHECK(count == 0);
                q2 = cptr_checked(realm_query_append_query(q.get(), "TRUEPREDICATE LIMIT(10)", num_args, arg_list));
                CHECK(checked(realm_query_count(q2.get(), &count)));
                CHECK(count == 1);
                q2 = cptr_checked(realm_query_append_query(q.get(), "int == $1", num_args, arg_list));
                CHECK(checked(realm_query_count(q2.get(), &count)));
                CHECK(count == 0);
            }
        }

        SECTION("realm_query_parse() errors") {
            // Invalid class key
            CHECK(!realm_query_parse(realm, 123123123, "string == $0", num_args, arg_list));
            CHECK_ERR_CAT(RLM_ERR_NO_SUCH_TABLE, (RLM_ERR_CAT_INVALID_ARG | RLM_ERR_CAT_LOGIC));

            // Invalid syntax
            CHECK(!realm_query_parse(realm, class_foo.key, "lel", 0, nullptr));
            CHECK_ERR_CAT(RLM_ERR_INVALID_QUERY_STRING, (RLM_ERR_CAT_INVALID_ARG | RLM_ERR_CAT_LOGIC));

            // Invalid property
            CHECK(!realm_query_parse(realm, class_foo.key, "strong = 5", 0, nullptr));
            CHECK_ERR_CAT(RLM_ERR_INVALID_QUERY, (RLM_ERR_CAT_INVALID_ARG | RLM_ERR_CAT_LOGIC));

            // Invalid number of arguments
            CHECK(!realm_query_parse(realm, class_foo.key, "string == $0", 0, nullptr));
            CHECK_ERR_CAT(RLM_ERR_INVALID_QUERY_ARG, (RLM_ERR_CAT_INVALID_ARG | RLM_ERR_CAT_LOGIC));
        }

        SECTION("string in list") {
            char foo[] = "foo";
            realm_value_t str = rlm_str_val(foo);
            realm_value_t list_arg[2] = {str, rlm_str_val("bar")};

            write([&]() {
                CHECK(realm_set_value(obj1.get(), foo_properties("string"), rlm_str_val("foo"), false));
            });

            static const size_t num_args = 1;
            realm_query_arg_t args[num_args] = {realm_query_arg_t{1, false, &str}};
            realm_query_arg_t* arg_list_simple = &args[0];

            realm_query_arg_t args_in_list[num_args] = {realm_query_arg_t{2, true, &list_arg[0]}};
            realm_query_arg_t* arg_list = &args_in_list[0];

            auto q_string_single_param =
                cptr_checked(realm_query_parse(realm, class_foo.key, "string == $0", num_args, arg_list_simple));
            auto q_string_in_list =
                cptr_checked(realm_query_parse(realm, class_foo.key, "string IN $0", num_args, arg_list));

            // changing the value for one of the parameters passed should not change the result of the query.
            // essentially we must assure that core is copying all the arguments passed inside the list (like for
            // normal query arguments), and after realm_query_parse completes any modification of the memory that
            // was used to store the parameter does not impact in any way core.
            char* s = foo;
            s[0] = 'a';
            size_t count, count_list;

            CHECK(checked(realm_query_count(q_string_single_param.get(), &count)));
            CHECK(1 == count);
            CHECK(checked(realm_query_count(q_string_in_list.get(), &count_list)));
            CHECK(1 == count_list);
        }

        SECTION("link in list") {
            auto link = rlm_link_val(class_bar.key, realm_object_get_key(obj2.get()));
            realm_value_t link_value = link;
            write([&]() {
                CHECK(realm_set_value(obj1.get(), foo_properties("link"), link_value, false));
            });

            static const size_t num_args = 1;
            realm_query_arg_t args[num_args] = {realm_query_arg_t{1, false, &link_value}};
            realm_query_arg_t* arg = &args[0];

            realm_value_t list_arg[num_args] = {link_value};
            realm_query_arg_t args_in_list[num_args] = {realm_query_arg_t{num_args, true, &list_arg[0]}};
            realm_query_arg_t* arg_list = &args_in_list[0];

            auto q_link_single_param =
                cptr_checked(realm_query_parse(realm, class_foo.key, "link == $0", num_args, arg));
            auto q_link_in_list =
                cptr_checked(realm_query_parse(realm, class_foo.key, "link IN $0", num_args, arg_list));

            size_t count, count_list;

            // change the link
            link = rlm_null();

            CHECK(checked(realm_query_count(q_link_single_param.get(), &count)));
            CHECK(1 == count);
            CHECK(checked(realm_query_count(q_link_in_list.get(), &count_list)));
            CHECK(1 == count_list);
        }

        SECTION("decimal NaN") {
            realm_value_t decimal = rlm_decimal_nan();

            write([&]() {
                CHECK(realm_set_value(obj1.get(), foo_properties("decimal"), decimal, false));
            });
            realm_query_arg_t args[] = {realm_query_arg_t{1, false, &decimal}};
            auto q_decimal = cptr_checked(realm_query_parse(realm, class_foo.key, "decimal == $0", 1, args));
            realm_value_t out_value;
            bool out_found;
            CHECK(realm_query_find_first(q_decimal.get(), &out_value, &out_found));
            CHECK(out_found);
            auto link = obj1->get_obj().get_link();
            realm_value_t expected;
            expected.type = RLM_TYPE_LINK;
            expected.link.target_table = link.get_table_key().value;
            expected.link.target = link.get_obj_key().value;
            CHECK(rlm_val_eq(out_value, expected));
        }

        SECTION("interpolate all types") {
            realm_value_t int_arg = rlm_int_val(123);
            realm_value_t bool_arg = rlm_bool_val(true);
            realm_value_t string_arg = rlm_str_val("foobar");
            static const uint8_t binary_data[3] = {1, 2, 3};
            realm_value_t binary_arg = rlm_binary_val(binary_data, 3);
            realm_value_t timestamp_arg = rlm_timestamp_val(1000000, 1);
            realm_value_t float_arg = rlm_float_val(123.f);
            realm_value_t double_arg = rlm_double_val(456.0);
            realm_value_t decimal_arg = rlm_decimal_val(789.0);
            realm_value_t object_id_arg = rlm_object_id_val("abc123abc123");
            realm_value_t uuid_arg = rlm_uuid_val("01234567-9abc-4def-9012-3456789abcde");
            realm_value_t link_arg = rlm_link_val(class_bar.key, realm_object_get_key(obj2.get()));
            realm_value_t list_arg[3] = {rlm_int_val(456), rlm_str_val("lol"), rlm_double_val(3.14)};

            static const size_t num_args = 13;
            realm_query_arg_t args[num_args] = {
                realm_query_arg_t{1, false, &int_arg},       realm_query_arg_t{1, false, &bool_arg},
                realm_query_arg_t{1, false, &string_arg},    realm_query_arg_t{1, false, &binary_arg},
                realm_query_arg_t{1, false, &timestamp_arg}, realm_query_arg_t{1, false, &float_arg},
                realm_query_arg_t{1, false, &double_arg},    realm_query_arg_t{1, false, &decimal_arg},
                realm_query_arg_t{1, false, &object_id_arg}, realm_query_arg_t{1, false, &uuid_arg},
                realm_query_arg_t{1, false, &link_arg},      realm_query_arg_t{3, true, &list_arg[0]},
                realm_query_arg_t{0, true, nullptr}};
            realm_query_arg_t* arg_list = &args[0];

            auto q_int = cptr_checked(realm_query_parse(realm, class_foo.key, "int == $0", num_args, arg_list));
            auto q_bool = cptr_checked(realm_query_parse(realm, class_foo.key, "bool == $1", num_args, arg_list));
            auto q_string = cptr_checked(realm_query_parse(realm, class_foo.key, "string == $2", num_args, arg_list));
            auto q_binary = cptr_checked(realm_query_parse(realm, class_foo.key, "binary == $3", num_args, arg_list));
            auto q_timestamp =
                cptr_checked(realm_query_parse(realm, class_foo.key, "timestamp == $4", num_args, arg_list));
            auto q_float = cptr_checked(realm_query_parse(realm, class_foo.key, "float == $5", num_args, arg_list));
            auto q_double = cptr_checked(realm_query_parse(realm, class_foo.key, "double == $6", num_args, arg_list));
            auto q_decimal =
                cptr_checked(realm_query_parse(realm, class_foo.key, "decimal == $7", num_args, arg_list));
            auto q_object_id =
                cptr_checked(realm_query_parse(realm, class_foo.key, "object_id == $8", num_args, arg_list));
            auto q_uuid = cptr_checked(realm_query_parse(realm, class_foo.key, "uuid == $9", num_args, arg_list));
            auto q_link = cptr_checked(realm_query_parse(realm, class_foo.key, "link == $10", num_args, arg_list));
            auto q_list = cptr_checked(realm_query_parse(realm, class_foo.key, "int == ANY $11", num_args, arg_list));
            auto q_empty_list =
                cptr_checked(realm_query_parse(realm, class_foo.key, "int == ALL $12", num_args, arg_list));

            CHECK(cptr_checked(realm_query_find_all(q_int.get())));
            CHECK(cptr_checked(realm_query_find_all(q_bool.get())));
            CHECK(cptr_checked(realm_query_find_all(q_string.get())));
            CHECK(cptr_checked(realm_query_find_all(q_binary.get())));
            CHECK(cptr_checked(realm_query_find_all(q_timestamp.get())));
            CHECK(cptr_checked(realm_query_find_all(q_float.get())));
            CHECK(cptr_checked(realm_query_find_all(q_double.get())));
            CHECK(cptr_checked(realm_query_find_all(q_decimal.get())));
            CHECK(cptr_checked(realm_query_find_all(q_object_id.get())));
            CHECK(cptr_checked(realm_query_find_all(q_uuid.get())));
            CHECK(cptr_checked(realm_query_find_all(q_link.get())));
            CHECK(cptr_checked(realm_query_find_all(q_list.get())));
            CHECK(cptr_checked(realm_query_find_all(q_empty_list.get())));

            SECTION("type mismatch") {
                CHECK(!realm_query_parse(realm, class_foo.key, "int == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "bool == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "string == $7", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "timestamp == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "double == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "float == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "binary == $0", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "decimal == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "object_id == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "uuid == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
                CHECK(!realm_query_parse(realm, class_foo.key, "link == $2", num_args, arg_list));
                CHECK_ERR(RLM_ERR_INVALID_QUERY_ARG);
            }
        }

        SECTION("realm_query_find_first()") {
            realm_value_t found_value = rlm_null();
            bool found;
            CHECK(checked(realm_query_find_first(q.get(), &found_value, &found)));
            CHECK(found);
            CHECK(found_value.type == RLM_TYPE_LINK);
            CHECK(found_value.link.target_table == class_foo.key);
            CHECK(found_value.link.target == realm_object_get_key(obj1.get()));
        }

        SECTION("verify order realm_query_find_first()") {
            realm_property_info_t info_string;
            realm_property_info_t info_int;
            bool found_string = false, found_int = false;
            REQUIRE(realm_find_property(realm, class_foo.key, "string", &found_string, &info_string));
            REQUIRE(realm_find_property(realm, class_foo.key, "int", &found_int, &info_int));
            CHECK(info_string.key != RLM_INVALID_PROPERTY_KEY);
            CHECK(info_int.key != RLM_INVALID_PROPERTY_KEY);
            CPtr<realm_object_t> obj1, obj2;
            checked(realm_begin_write(realm));
            obj1 = cptr_checked(realm_object_create(realm, class_foo.key));
            obj2 = cptr_checked(realm_object_create(realm, class_foo.key));
            CHECK(obj1);
            CHECK(obj2);
            CHECK(checked(realm_set_value(obj1.get(), info_string.key, rlm_str_val("Test"), false)));
            CHECK(checked(realm_set_value(obj2.get(), info_string.key, rlm_str_val("Test"), false)));
            CHECK(checked(realm_set_value(obj1.get(), info_int.key, rlm_int_val(10), false)));
            CHECK(checked(realm_set_value(obj2.get(), info_int.key, rlm_int_val(11), false)));
            checked(realm_commit(realm));
            checked(realm_refresh(realm, nullptr));

            size_t count = 0;
            realm_value_t arg_data[1] = {rlm_str_val("Test")};
            realm_query_arg_t args[1] = {realm_query_arg_t{1, false, &arg_data[0]}};
            realm_query_arg_t* arg_list = &args[0];
            auto q = cptr_checked(realm_query_parse(realm, class_foo.key, "string == $0", 1, arg_list));
            CHECK(checked(realm_query_count(q.get(), &count)));
            CHECK(count == 2);

            auto q2 =
                cptr_checked(realm_query_append_query(q.get(), "string == $0 SORT(int ASCENDING)", 1, arg_list));
            realm_value_t found_value = rlm_null();
            bool found_sorted;
            CHECK(checked(realm_query_find_first(q2.get(), &found_value, &found_sorted)));
            CHECK(found_sorted);
            CHECK(found_value.type == RLM_TYPE_LINK);
            CHECK(found_value.link.target_table == class_foo.key);
            CHECK(found_value.link.target == realm_object_get_key(obj1.get()));

            auto q3 =
                cptr_checked(realm_query_append_query(q.get(), "string == $0 SORT(int DESCENDING)", 1, arg_list));
            found_value = rlm_null();
            found_sorted = false;
            CHECK(checked(realm_query_find_first(q3.get(), &found_value, &found_sorted)));
            CHECK(found_sorted);
            CHECK(found_value.type == RLM_TYPE_LINK);
            CHECK(found_value.link.target_table == class_foo.key);
            CHECK(found_value.link.target == realm_object_get_key(obj2.get()));
        }

        SECTION("results") {
            auto r = cptr_checked(realm_query_find_all(q.get()));
            CHECK(!realm_is_frozen(r.get()));

            SECTION("realm_results_is_valid") {
                bool valid;
                CHECK(checked(realm_results_is_valid(r.get(), &valid)));
                CHECK(valid);
            }

            SECTION("realm_results_is_valid delete objects") {
                write([&] {
                    realm_object_delete(obj1.get());
                    realm_object_delete(obj2.get());
                    realm_results_delete_all(r.get());
                });
                bool valid;
                CHECK(checked(realm_results_is_valid(r.get(), &valid)));
                CHECK(valid);
            }

            SECTION("realm_results_is_valid delete collection") {
                auto strings = cptr_checked(realm_get_list(obj2.get(), bar_properties("strings")));
                CHECK(strings);
                CHECK(!realm_is_frozen(strings.get()));

                realm_value_t a = rlm_str_val("a");
                realm_value_t b = rlm_str_val("b");
                realm_value_t c = rlm_null();

                write([&] {
                    CHECK(checked(realm_list_insert(strings.get(), 0, a)));
                    CHECK(checked(realm_list_insert(strings.get(), 1, b)));
                    CHECK(checked(realm_list_insert(strings.get(), 2, c)));
                });
                bool valid;
                auto results = cptr_checked(realm_list_to_results(strings.get()));
                CHECK(checked(realm_results_is_valid(results.get(), &valid)));
                CHECK(valid);

                write([&] {
                    CHECK(checked(realm_object_delete(obj2.get())));
                });

                CHECK(checked(realm_results_is_valid(results.get(), &valid)));
                CHECK_FALSE(valid);
                size_t count;

                CHECK_FALSE(realm_results_count(results.get(), &count));
                CHECK_ERR(RLM_ERR_STALE_ACCESSOR);

                CHECK_FALSE(realm_results_resolve_in(results.get(), realm));
                CHECK_ERR(RLM_ERR_STALE_ACCESSOR);
            }

            SECTION("realm_results_count()") {
                size_t count;
                CHECK(checked(realm_results_count(r.get(), &count)));
                CHECK(count == 1);

                SECTION("cloned") {
                    auto r2 = clone_cptr(r.get());
                    size_t count2;
                    CHECK(checked(realm_results_count(r2.get(), &count2)));
                    CHECK(count == count2);
                }
            }

            SECTION("empty result") {
                auto q2 = cptr_checked(realm_query_parse(realm, class_foo.key, "string == 'boogeyman'", 0, nullptr));
                auto r2 = cptr_checked(realm_query_find_all(q2.get()));
                size_t count;
                CHECK(checked(realm_results_count(r2.get(), &count)));
                CHECK(count == 0);
                realm_value_t value = rlm_null();
                CHECK(!realm_results_get(r2.get(), 0, &value));
                CHECK_ERR(RLM_ERR_INDEX_OUT_OF_BOUNDS);
                size_t index = -1;
                bool found = false;
                CHECK(realm_results_find(r2.get(), &value, &index, &found));
                CHECK(index == realm::not_found);
                CHECK(found == false);
            }

            SECTION("realm_results_get()") {
                realm_value_t value = rlm_null();
                CHECK(checked(realm_results_get(r.get(), 0, &value)));
                CHECK(value.type == RLM_TYPE_LINK);
                CHECK(value.link.target_table == class_foo.key);
                CHECK(value.link.target == realm_object_get_key(obj1.get()));
                size_t index = -1;
                bool found = false;
                CHECK(realm_results_find(r.get(), &value, &index, &found));
                CHECK(index == 0);
                CHECK(found == true);

                value = rlm_null();
                CHECK(!realm_results_get(r.get(), 1, &value));
                CHECK_ERR(RLM_ERR_INDEX_OUT_OF_BOUNDS);
                index = -1;
                found = false;
                CHECK(realm_results_find(r.get(), &value, &index, &found));
                CHECK(index == realm::not_found);
                CHECK(found == false);
            }

            SECTION("realm_results_get_query()") {
                auto q2 = cptr_checked(realm_query_parse(realm, class_foo.key, "int == 123", 0, nullptr));
                auto r2 = cptr_checked(realm_results_filter(r.get(), q2.get()));
                size_t count;
                CHECK(checked(realm_results_count(r2.get(), &count)));
                CHECK(count == 1);
                auto results_query = cptr_checked(realm_results_get_query(r2.get()));
                auto result = cptr_checked(realm_query_find_all(results_query.get()));
                size_t count1 = 0;
                CHECK(checked(realm_results_count(result.get(), &count1)));
                CHECK(count == count1);
            }

            SECTION("realm_results_get_object()") {
                auto p = cptr_checked(realm_results_get_object(r.get(), 0));
                CHECK(p.get());
                CHECK(realm_equals(p.get(), obj1.get()));
                size_t index = -1;
                bool found = false;
                CHECK(realm_results_find_object(r.get(), p.get(), &index, &found));
                CHECK(found == true);
                CHECK(index == 0);

                CHECK(!realm_results_get_object(r.get(), 1));
                CHECK_ERR(RLM_ERR_INDEX_OUT_OF_BOUNDS);
                CHECK(!realm_results_find_object(r.get(), obj2.get(), &index, &found));
                CHECK(found == false);
                CHECK(index == realm::not_found);
            }

            SECTION("realm_results_filter()") {
                auto q2 = cptr_checked(realm_query_parse(realm, class_foo.key, "int == 789", 0, nullptr));
                auto r2 = cptr_checked(realm_results_filter(r.get(), q2.get()));
                size_t count;
                CHECK(checked(realm_results_count(r2.get(), &count)));
                CHECK(count == 0);
            }

            SECTION("realm_results_sort()") {
                auto r_all = cptr_checked(realm_object_find_all(realm, class_foo.key));
                auto p = cptr_checked(realm_results_get_object(r_all.get(), 0));
                CHECK(p.get());
                CHECK(realm_equals(p.get(), obj1.get()));
                auto r2 = cptr_checked(realm_results_sort(r_all.get(), "int DESCENDING, float ASCENDING"));
                p = cptr_checked(realm_results_get_object(r2.get(), 1));
                CHECK(p.get());
                CHECK(realm_equals(p.get(), obj1.get()));
            }

            SECTION("realm_results_distinct()") {
                auto r_all = cptr_checked(realm_object_find_all(realm, class_foo.key));
                size_t count;
                realm_results_count(r_all.get(), &count);
                CHECK(count == 3);
                auto r2 = cptr_checked(realm_results_distinct(r_all.get(), "int"));
                realm_results_count(r2.get(), &count);
                CHECK(count == 2);
            }

            SECTION("realm_results_limit()") {
                auto r_all = cptr_checked(realm_object_find_all(realm, class_foo.key));
                size_t count;
                realm_results_count(r_all.get(), &count);
                CHECK(count == 3);
                auto r2 = cptr_checked(realm_results_limit(r_all.get(), 1));
                realm_results_count(r2.get(), &count);
                CHECK(count == 1);
            }

            SECTION("realm_results_snapshot()") {
                auto r_all = cptr_checked(realm_object_find_all(realm, class_foo.key));
                auto r_snapshot = cptr_checked(realm_results_snapshot(r_all.get()));
                size_t count;
                realm_results_count(r_all.get(), &count);
                CHECK(count == 3);
                realm_results_count(r_snapshot.get(), &count);
                CHECK(count == 3);
                write([&]() {
                    auto p = cptr_checked(realm_results_get_object(r_all.get(), 0));
                    realm_object_delete(p.get());
                });
                realm_results_count(r_all.get(), &count);
                CHECK(count == 2);
                realm_results_count(r_snapshot.get(), &count);
                CHECK(count == 3);
            }

            SECTION("realm_results_min()") {
                realm_value_t value = rlm_null();
                CHECK(checked(realm_results_min(r.get(), foo_int_key, &value, &found)));
                CHECK(found);
                CHECK(value.type == RLM_TYPE_INT);
                CHECK(value.integer == 123);

                CHECK(!realm_results_min(r.get(), RLM_INVALID_PROPERTY_KEY, nullptr, nullptr));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("realm_results_max()") {
                realm_value_t value = rlm_null();
                CHECK(checked(realm_results_max(r.get(), foo_int_key, &value, &found)));
                CHECK(found);
                CHECK(value.type == RLM_TYPE_INT);
                CHECK(value.integer == 123);

                CHECK(!realm_results_max(r.get(), RLM_INVALID_PROPERTY_KEY, nullptr, nullptr));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("realm_results_sum()") {
                realm_value_t value = rlm_null();
                CHECK(checked(realm_results_sum(r.get(), foo_int_key, &value, &found)));
                CHECK(found);
                CHECK(value.type == RLM_TYPE_INT);
                CHECK(value.integer == 123);

                size_t count;
                realm_results_count(r.get(), &count);
                CHECK(count == 1);

                CHECK(!realm_results_sum(r.get(), RLM_INVALID_PROPERTY_KEY, nullptr, nullptr));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("realm_results_average()") {
                realm_value_t value = rlm_null();
                CHECK(checked(realm_results_average(r.get(), foo_int_key, &value, &found)));
                CHECK(found);
                CHECK(value.type == RLM_TYPE_DOUBLE);
                CHECK(value.dnum == 123.0);

                CHECK(!realm_results_average(r.get(), RLM_INVALID_PROPERTY_KEY, nullptr, nullptr));
                CHECK_ERR(RLM_ERR_INVALID_PROPERTY);
            }

            SECTION("realm_results_delete_all()") {
                CHECK(!realm_results_delete_all(r.get()));
                CHECK_ERR(RLM_ERR_WRONG_TRANSACTION_STATE);

                write([&]() {
                    size_t num_objects;
                    CHECK(checked(realm_get_num_objects(realm, class_foo.key, &num_objects)));
                    CHECK(num_objects == 3);
                    CHECK(checked(realm_results_delete_all(r.get())));
                    CHECK(checked(realm_get_num_objects(realm, class_foo.key, &num_objects)));
                    CHECK(num_objects == 2);
                });
            }

            SECTION("lists") {
                auto list = cptr_checked(realm_get_list(obj1.get(), foo_properties("link_list")));
                cptr_checked(realm_query_parse_for_list(list.get(), "TRUEPREDICATE", 0, nullptr));
            }

            SECTION("lists append query") {
                auto list = cptr_checked(realm_get_list(obj1.get(), foo_properties("link_list")));

                auto bar_link = realm_object_as_link(obj2.get());
                realm_value_t bar_link_val;
                bar_link_val.type = RLM_TYPE_LINK;
                bar_link_val.link = bar_link;

                write([&]() {
                    CHECK(checked(realm_list_insert(list.get(), 0, bar_link_val)));
                    CHECK(checked(realm_list_insert(list.get(), 1, bar_link_val)));
                    CHECK(checked(realm_list_insert(list.get(), 2, bar_link_val)));
                });

                size_t n = 0;
                realm_list_size(list.get(), &n);
                CHECK(n == 3);
                auto query = cptr_checked(realm_query_parse_for_list(list.get(), "TRUEPREDICATE ", 0, nullptr));
                n = 0;
                realm_query_count(query.get(), &n);
                CHECK(n == 3);

                write([&]() {
                    realm_list_clear(list.get());
                });
            }

            SECTION("combine results query") {
                realm_value_t int_arg = rlm_int_val(123);
                const size_t num_args = 1;
                realm_query_arg_t args[num_args] = {realm_query_arg_t{1, false, &int_arg}};
                realm_query_arg_t* arg_list = &args[0];
                auto q_int = cptr_checked(realm_query_parse(realm, class_foo.key, "int == $0", num_args, arg_list));
                auto combined_result_q =
                    cptr_checked(realm_query_parse_for_results(r.get(), q_int->get_description(), 0, nullptr));
                auto result = cptr_checked(realm_query_find_all(combined_result_q.get()));
                size_t count;
                CHECK(realm_results_count(result.get(), &count));
                CHECK(count == 1);
            }

            SECTION("empty results") {
                auto empty_q = cptr_checked(realm_query_parse_for_results(r.get(), "FALSEPREDICATE", 0, nullptr));
                auto empty_r = cptr_checked(realm_query_find_all(empty_q.get()));

                SECTION("realm_results_count()") {
                    size_t count;
                    CHECK(realm_results_count(empty_r.get(), &count));
                    CHECK(count == 0);
                }

                SECTION("realm_results_min()") {
                    realm_value_t value;
                    bool found = true;
                    CHECK(realm_results_min(empty_r.get(), foo_int_key, &value, &found));
                    CHECK(rlm_val_eq(value, rlm_null()));
                    CHECK(!found);
                }

                SECTION("realm_results_max()") {
                    realm_value_t value;
                    bool found = true;
                    CHECK(realm_results_max(empty_r.get(), foo_int_key, &value, &found));
                    CHECK(rlm_val_eq(value, rlm_null()));
                    CHECK(!found);
                }

                SECTION("realm_results_sum()") {
                    realm_value_t value;
                    bool found = true;
                    CHECK(realm_results_sum(empty_r.get(), foo_int_key, &value, &found));
                    CHECK(rlm_val_eq(value, rlm_int_val(0)));
                    CHECK(!found);
                }

                SECTION("realm_results_average()") {
                    realm_value_t value;
                    bool found = true;
                    CHECK(realm_results_average(empty_r.get(), foo_int_key, &value, &found));
                    CHECK(rlm_val_eq(value, rlm_null()));
                    CHECK(!found);
                }
            }
        }
    }

    realm_close(realm);
    REQUIRE(realm_is_closed(realm));
    realm_release(realm);
}

TEST_CASE("C API: nested collections", "[c_api]") {
    TestFile test_file;
    realm_t* realm;
    ObjectSchema object_schema = {"Foo",
                                  {
                                      {"_id", PropertyType::Int, Property::IsPrimary{true}},
                                      {"any", PropertyType::Mixed | PropertyType::Nullable},
                                  }};

    auto config = make_config(test_file.path.c_str(), false);
    config->schema = Schema{object_schema};
    config->schema_version = 0;
    realm = realm_open(config.get());

    realm_class_info_t class_foo;
    bool found = false;
    CHECK(checked(realm_find_class(realm, "Foo", &found, &class_foo)));
    REQUIRE(found);

    realm_property_info_t info;
    found = false;
    REQUIRE(realm_find_property(realm, class_foo.key, "any", &found, &info));
    REQUIRE(found);
    CHECK(info.key != RLM_INVALID_PROPERTY_KEY);
    realm_property_key_t foo_any_col_key = info.key;

    CPtr<realm_object_t> obj1;
    checked(realm_begin_write(realm));
    realm_value_t pk = rlm_int_val(42);
    obj1 = cptr_checked(realm_object_create_with_primary_key(realm, class_foo.key, pk));

    auto write = [&](auto&& f) {
        checked(realm_begin_write(realm));
        f();
        checked(realm_commit(realm));
        checked(realm_refresh(realm, nullptr));
    };

    SECTION("results of mixed") {
        SECTION("dictionary") {
            auto parent_dict = cptr_checked(realm_set_dictionary(obj1.get(), foo_any_col_key));
            REQUIRE(parent_dict);
            realm_value_t value;
            realm_get_value(obj1.get(), foo_any_col_key, &value);
            REQUIRE(value.type == RLM_TYPE_DICTIONARY);
            auto dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_any_col_key));
            auto nlist = cptr_checked(realm_dictionary_insert_list(dict.get(), rlm_str_val("A")));
            auto ndict = cptr_checked(realm_dictionary_insert_dictionary(dict.get(), rlm_str_val("B")));

            // verify that we can fetch a collection from a result of mixed
            auto results = cptr_checked(realm_dictionary_to_results(dict.get()));
            const auto sz = results->size();
            REQUIRE(sz == dict->size());
            REQUIRE(results->is_valid());
            realm_value_t val;
            realm_results_get(results.get(), 0, &val);
            REQUIRE(val.type == RLM_TYPE_LIST);
            realm_results_get(results.get(), 1, &val);
            REQUIRE(val.type == RLM_TYPE_DICTIONARY);
            auto result_list = cptr_checked(realm_results_get_list(results.get(), 0));
            REQUIRE(result_list);
            REQUIRE(result_list->size() == nlist->size());
            auto result_dictionary = cptr_checked(realm_results_get_dictionary(results.get(), 1));
            REQUIRE(result_dictionary);
            REQUIRE(result_dictionary->size() == ndict->size());
        }
        SECTION("list") {
            auto parent_list = cptr_checked(realm_set_list(obj1.get(), foo_any_col_key));
            REQUIRE(parent_list);
            realm_value_t value;
            realm_get_value(obj1.get(), foo_any_col_key, &value);
            REQUIRE(value.type == RLM_TYPE_LIST);
            auto list = cptr_checked(realm_get_list(obj1.get(), foo_any_col_key));
            auto nlist = cptr_checked(realm_list_insert_list(list.get(), 0));
            auto ndict = cptr_checked(realm_list_insert_dictionary(list.get(), 1));

            // verify that we can fetch a collection from a result of mixed
            auto results = cptr_checked(realm_list_to_results(list.get()));
            const auto sz = results->size();
            REQUIRE(sz == list->size());
            REQUIRE(results->is_valid());
            realm_value_t val;
            realm_results_get(results.get(), 0, &val);
            REQUIRE(val.type == RLM_TYPE_LIST);
            realm_results_get(results.get(), 1, &val);
            REQUIRE(val.type == RLM_TYPE_DICTIONARY);
            auto result_list = cptr_checked(realm_results_get_list(results.get(), 0));
            REQUIRE(result_list);
            REQUIRE(result_list->size() == nlist->size());
            auto result_dictionary = cptr_checked(realm_results_get_dictionary(results.get(), 1));
            REQUIRE(result_dictionary);
            REQUIRE(result_dictionary->size() == ndict->size());
        }
    }

    SECTION("dictionary") {
        struct UserData {
            size_t deletions;
            size_t insertions;
            size_t modifications;
            bool was_deleted;
            realm_dictionary_t* dict;
        } user_data;

        auto parent_dict = cptr_checked(realm_set_dictionary(obj1.get(), foo_any_col_key));
        REQUIRE(parent_dict);
        realm_value_t value;
        realm_get_value(obj1.get(), foo_any_col_key, &value);
        REQUIRE(value.type == RLM_TYPE_DICTIONARY);
        auto dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_any_col_key));
        checked(realm_dictionary_insert(dict.get(), rlm_str_val("Hello"), rlm_str_val("world"), nullptr, nullptr));
        // dict -> list
        auto list = cptr_checked(realm_dictionary_insert_list(dict.get(), rlm_str_val("Goodbye")));
        realm_list_insert(list.get(), 0, rlm_str_val("Hello"));
        realm_list_insert(list.get(), 0, rlm_str_val("42"));
        realm_list_insert(list.get(), 0, rlm_int_val(42));
        // dict -> dict
        auto dict2 = cptr_checked(realm_dictionary_insert_dictionary(dict.get(), rlm_str_val("Hi")));
        user_data.dict = dict2.get();
        checked(realm_dictionary_insert(dict2.get(), rlm_str_val("Nested-Hello"), rlm_str_val("Nested-World"),
                                        nullptr, nullptr));
        checked(realm_commit(realm));

        auto on_dictionary_change = [](void* data, const realm_dictionary_changes_t* changes) {
            auto* user_data = static_cast<UserData*>(data);
            realm_dictionary_get_changes(changes, &user_data->deletions, &user_data->insertions,
                                         &user_data->modifications, &user_data->was_deleted);
            if (user_data->was_deleted) {
                CHECK(!realm_dictionary_is_valid(user_data->dict));
            }
        };
        auto require_change = [&]() {
            auto token = cptr_checked(realm_dictionary_add_notification_callback(dict2.get(), &user_data, nullptr,
                                                                                 nullptr, on_dictionary_change));
            checked(realm_refresh(realm, nullptr));
            return token;
        };

        auto token = require_change();

        write([&] {
            checked(realm_dictionary_insert(dict2.get(), rlm_str_val("Nested-Godbye"),
                                            rlm_str_val("Nested-CruelWorld"), nullptr, nullptr));
        });
        CHECK(user_data.insertions == 1);

        write([&] {
            realm_dictionary_insert(dict.get(), rlm_str_val("Hi"), rlm_str_val("Foo"), nullptr, nullptr);
        });
        CHECK(user_data.deletions == 2);
        CHECK(user_data.was_deleted);
    }

    SECTION("list") {
        struct UserData {
            size_t deletions;
            size_t insertions;
            size_t modifications;
            bool was_deleted;
            realm_list_t* list;
        } user_data;

        auto parent_list = cptr_checked(realm_set_list(obj1.get(), foo_any_col_key));
        REQUIRE(parent_list);
        realm_value_t value;
        realm_get_value(obj1.get(), foo_any_col_key, &value);
        REQUIRE(value.type == RLM_TYPE_LIST);
        auto list = cptr_checked(realm_get_list(obj1.get(), foo_any_col_key));
        realm_list_insert(list.get(), 0, rlm_str_val("Hello"));
        realm_list_insert(list.get(), 1, rlm_str_val("World"));
        // list -> dict
        auto dict = cptr_checked(realm_list_insert_dictionary(list.get(), 1));
        checked(realm_dictionary_insert(dict.get(), rlm_str_val("Hello"), rlm_str_val("world"), nullptr, nullptr));
        // list -> list
        auto list2 = cptr_checked(realm_list_insert_list(list.get(), 2));
        user_data.list = list2.get();

        checked(realm_commit(realm));

        auto on_list_change = [](void* data, const realm_collection_changes_t* changes) {
            auto* user_data = static_cast<UserData*>(data);
            realm_collection_changes_get_num_changes(changes, &user_data->deletions, &user_data->insertions,
                                                     &user_data->modifications, nullptr, nullptr,
                                                     &user_data->was_deleted);
            if (user_data->was_deleted) {
                CHECK(!realm_list_is_valid(user_data->list));
            }
        };
        auto require_change = [&]() {
            auto token = cptr_checked(
                realm_list_add_notification_callback(list2.get(), &user_data, nullptr, nullptr, on_list_change));
            checked(realm_refresh(realm, nullptr));
            return token;
        };

        auto token = require_change();

        write([&] {
            realm_list_insert(list2.get(), 0, rlm_str_val("Nested-Hello"));
            realm_list_insert(list2.get(), 1, rlm_str_val("Nested-World"));
        });
        CHECK(user_data.insertions == 2);

        write([&] {
            realm_list_set(list.get(), 2, rlm_str_val("Foo"));
        });
        CHECK(user_data.deletions == 2);
        CHECK(user_data.was_deleted);
    }

    SECTION("set list for collection in mixed, verify that previous reference is invalid") {
        auto parent_list = cptr_checked(realm_set_list(obj1.get(), foo_any_col_key));
        REQUIRE(parent_list);
        realm_value_t value;
        realm_get_value(obj1.get(), foo_any_col_key, &value);
        REQUIRE(value.type == RLM_TYPE_LIST);
        auto list = cptr_checked(realm_get_list(obj1.get(), foo_any_col_key));
        auto n_list = cptr_checked(realm_list_insert_list(list.get(), 0));
        size_t size;
        checked(realm_list_size(list.get(), &size));
        REQUIRE(size == 1);
        realm_list_insert(n_list.get(), 0, rlm_str_val("Test1"));
        auto n_dict = cptr_checked(realm_list_set_dictionary(list.get(), 0));
        // accessor has become invalid
        REQUIRE(!realm_list_insert(n_list.get(), 1, rlm_str_val("Test2")));
        CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);
        // try to get a dictionary should work
        n_dict = cptr_checked(realm_list_get_dictionary(list.get(), 0));
        bool inserted = false;
        size_t ndx;
        realm_value_t key = rlm_str_val("key");
        realm_value_t val = rlm_str_val("value");
        REQUIRE(realm_dictionary_insert(n_dict.get(), key, val, &ndx, &inserted));
        REQUIRE(ndx == 0);
        REQUIRE(inserted);

        CHECK(realm_list_set(list.get(), 0, rlm_int_val(5)));
        // accessor invalid
        REQUIRE(!realm_dictionary_insert(n_dict.get(), key, val, &ndx, &inserted));
        CHECK_ERR(RLM_ERR_INVALIDATED_OBJECT);
        realm_value_t out;
        CHECK(realm_list_get(list.get(), 0, &out));

        n_list = cptr_checked(realm_list_set_list(list.get(), 0));
        // get a list should work
        n_list = cptr_checked(realm_list_get_list(list.get(), 0));
        REQUIRE(realm_list_insert(n_list.get(), 0, rlm_str_val("Test1")));
        // reset the collection type to the same type (nop)
        n_list = cptr_checked(realm_list_set_list(list.get(), 0));
        // accessor is still valid
        REQUIRE(realm_list_insert(n_list.get(), 0, rlm_str_val("Test2")));
        checked(realm_list_size(n_list.get(), &size));
        REQUIRE(size == 2);
    }

    SECTION("json") {
        REQUIRE(realm_set_json(
            obj1.get(), foo_any_col_key,
            R"( [ { "Seven":7, "Six":6 }, "Hello", { "Points": [1.25, 4.5, 6.75], "Hello": "World" } ])"));
        realm_value_t value;
        realm_get_value(obj1.get(), foo_any_col_key, &value);
        REQUIRE(value.type == RLM_TYPE_LIST);
        auto list = cptr_checked(realm_get_list(obj1.get(), foo_any_col_key));
        size_t size;
        checked(realm_list_size(list.get(), &size));
        CHECK(size == 3);
    }

    SECTION("freeze list") {
        auto parent_dict = cptr_checked(realm_set_dictionary(obj1.get(), foo_any_col_key));
        REQUIRE(parent_dict);
        auto dict = cptr_checked(realm_get_dictionary(obj1.get(), foo_any_col_key));
        auto list = cptr_checked(realm_dictionary_insert_list(dict.get(), rlm_str_val("List")));
        realm_list_insert(list.get(), 0, rlm_str_val("Hello"));
        realm_list_insert(list.get(), 0, rlm_str_val("42"));
        checked(realm_commit(realm));
        size_t size;
        checked(realm_list_size(list.get(), &size));
        REQUIRE(size == 2);
        auto frozen_realm = cptr_checked(realm_freeze(realm));

        realm_list_t* frozen_list;
        realm_list_resolve_in(list.get(), frozen_realm.get(), &frozen_list);
        checked(realm_list_size(frozen_list, &size));
        REQUIRE(size == 2);
        realm_release(frozen_list);
    }
    realm_release(realm);
}

TEST_CASE("C API: convert", "[c_api]") {
    TestFile test_file;
    TestFile dest_test_file;
    realm_t* realm;
    ObjectSchema object_schema = {"Foo",
                                  {
                                      {"_id", PropertyType::Int, Property::IsPrimary{true}},
                                      {"string_value", PropertyType::String},
                                  }};

    { // seed a Realm with an object
        auto config = make_config(test_file.path.c_str(), false);
        config->schema = Schema{object_schema};
        config->schema_version = 0;
        realm = realm_open(config.get());
        REQUIRE(checked(realm));
        CHECK(!realm_equals(realm, nullptr));
        realm_class_info_t class_foo;
        bool found = false;
        CHECK(checked(realm_find_class(realm, "Foo", &found, &class_foo)));
        REQUIRE(found);

        realm_property_key_t foo_str_col_key;
        realm_property_info_t info;
        found = false;
        REQUIRE(realm_find_property(realm, class_foo.key, "string_value", &found, &info));
        REQUIRE(found);
        CHECK(info.key != RLM_INVALID_PROPERTY_KEY);
        foo_str_col_key = info.key;

        CPtr<realm_object_t> obj1;
        checked(realm_begin_write(realm));
        realm_value_t pk = rlm_int_val(42);
        obj1 = cptr_checked(realm_object_create_with_primary_key(realm, class_foo.key, pk));
        CHECK(obj1);
        CHECK(checked(realm_set_value(obj1.get(), foo_str_col_key, rlm_str_val("Hello, World!"), false)));
        checked(realm_commit(realm));
        checked(realm_refresh(realm, nullptr));

        size_t foo_count;
        CHECK(checked(realm_get_num_objects(realm, class_foo.key, &foo_count)));
        REQUIRE(foo_count == 1);
    }

    CHECK(realm_get_num_classes(realm) == 1);

    SECTION("convert with path") {
        bool merge_with_existing = false;
        realm_binary encryption_key{nullptr, 0};

        REQUIRE(realm_convert_with_path(realm, dest_test_file.path.c_str(), encryption_key, merge_with_existing));

        SECTION("convert again without merge should fail") {
            REQUIRE_FALSE(
                realm_convert_with_path(realm, dest_test_file.path.c_str(), encryption_key, merge_with_existing));
        }
        SECTION("convert again with merge should succeed") {
            merge_with_existing = true;
            REQUIRE(realm_convert_with_path(realm, dest_test_file.path.c_str(), encryption_key, merge_with_existing));
        }
    }

    SECTION("convert with config") {
        auto dest_config = make_config(dest_test_file.path.c_str(), false);
        dest_config->schema = Schema{object_schema};
        dest_config->schema_version = 0;
        bool merge_with_existing = false;
        REQUIRE(realm_convert_with_config(realm, dest_config.get(), merge_with_existing));
        SECTION("convert again without merge should fail") {
            REQUIRE_FALSE(realm_convert_with_config(realm, dest_config.get(), merge_with_existing));
        }
        SECTION("convert again with merge should succeed") {
            merge_with_existing = true;
            REQUIRE(realm_convert_with_config(realm, dest_config.get(), merge_with_existing));
        }
    }
    realm_close(realm);
    REQUIRE(realm_is_closed(realm));
    realm_release(realm);
}

struct Userdata {
    std::atomic<bool> called{false};
    bool has_error;
    realm_error_t error;
    realm_thread_safe_reference_t* realm_ref = nullptr;
    std::string error_message;
};

#if REALM_ENABLE_SYNC

static void task_completion_func(void* p, realm_thread_safe_reference_t* realm,
                                 const realm_async_error_t* async_error)
{
    auto userdata_p = static_cast<Userdata*>(p);

    userdata_p->realm_ref = realm;
    userdata_p->has_error = realm_get_async_error(async_error, &userdata_p->error);
    userdata_p->called = true;
}

static void task_init_subscription(realm_thread_safe_reference_t* realm, void*)
{
    REQUIRE(realm);
}

static void sync_error_handler(void* p, realm_sync_session_t*, const realm_sync_error_t error)
{
    auto userdata_p = static_cast<Userdata*>(p);
    userdata_p->has_error = true;
    userdata_p->error_message = error.status.message;
    userdata_p->error.error = error.status.error;
    userdata_p->error.categories = error.status.categories;
    userdata_p->error.message = userdata_p->error_message.c_str();
}

TEST_CASE("C API - async_open", "[sync][pbs][c_api]") {
    TestSyncManager init_sync_manager;
    SyncTestFile test_config(init_sync_manager, "default");
    ObjectSchema object_schema = {"object",
                                  {
                                      {"_id", PropertyType::Int, Property::IsPrimary{true}},
                                      {"value", PropertyType::Int},
                                  }};
    test_config.schema = Schema{object_schema};

    SECTION("can open synced Realms that don't already exist") {
        realm_config_t* config = realm_config_new();
        config->schema = Schema{object_schema};
        realm_user user(test_config.sync_config->user);
        realm_sync_config_t* sync_config = realm_sync_config_new(&user, "default");
        realm_sync_config_set_initial_subscription_handler(sync_config, task_init_subscription, false, nullptr,
                                                           nullptr);
        realm_config_set_path(config, test_config.path.c_str());
        realm_config_set_sync_config(config, sync_config);
        realm_config_set_schema_version(config, 1);
        realm_async_open_task_t* task = realm_open_synchronized(config);
        REQUIRE(task);
        Userdata userdata;
        realm_async_open_task_start(task, task_completion_func, &userdata, nullptr);
        util::EventLoop::main().run_until([&] {
            return userdata.called.load();
        });
        REQUIRE(userdata.called);
        REQUIRE(userdata.realm_ref);
        realm_release(task);

        realm_t* realm = realm_from_thread_safe_reference(userdata.realm_ref, nullptr);
        realm_release(userdata.realm_ref);

        bool found;
        realm_class_info_t class_info;
        realm_find_class(realm, "object", &found, &class_info);
        REQUIRE(found);
        realm_release(realm);
        realm_release(config);
        realm_release(sync_config);
    }

    SECTION("cancels download and reports an error on auth error") {
        auto expired_token = encode_fake_jwt("", 123, 456);

        struct Transport : UnitTestTransport {
            void send_request_to_server(
                const realm::app::Request& req,
                realm::util::UniqueFunction<void(const realm::app::Response&)>&& completion) override
            {
                if (req.url.find("/auth/session") != std::string::npos) {
                    completion(app::Response{403});
                }
                else {
                    UnitTestTransport::send_request_to_server(req, std::move(completion));
                }
            }
        };
        OfflineAppSession::Config oas_config;
        oas_config.transport = std::make_shared<Transport>();
        OfflineAppSession oas(oas_config);
        SyncTestFile test_config(oas, "realm");
        test_config.sync_config->user->log_in(expired_token, expired_token);

        realm_config_t* config = realm_config_new();
        config->schema = Schema{object_schema};
        realm_user user(test_config.sync_config->user);
        realm_sync_config_t* sync_config = realm_sync_config_new(&user, "realm");
        realm_sync_config_set_initial_subscription_handler(sync_config, task_init_subscription, false, nullptr,
                                                           nullptr);
        realm_config_set_path(config, test_config.path.c_str());
        realm_config_set_schema_version(config, 1);
        Userdata userdata;
        realm_sync_config_set_error_handler(sync_config, sync_error_handler, &userdata, nullptr);
        realm_config_set_sync_config(config, sync_config);

        realm_async_open_task_t* task = realm_open_synchronized(config);
        REQUIRE(task);
        realm_async_open_task_start(task, task_completion_func, &userdata, nullptr);
        util::EventLoop::main().run_until([&] {
            return userdata.called.load();
        });
        REQUIRE(userdata.called);
        REQUIRE(!userdata.realm_ref);
        REQUIRE(userdata.error.error == RLM_ERR_AUTH_ERROR);
        REQUIRE(userdata.error_message ==
                "Unable to refresh the user access token: http error code considered fatal. Client Error: 403");
        realm_release(task);
        realm_release(config);
        realm_release(sync_config);
    }
}

struct BCTOState {
    bool bcto_deleted = false;
    bool thread_create_called = false;
    bool thread_destroy_called = false;
    std::string thread_on_error_message;
    std::string id = "BTCO-STATE";
};


TEST_CASE("C API - binding callback thread observer", "[sync][c_api]") {
    auto bcto_user_data = BCTOState();

    auto bcto_free_userdata = [](realm_userdata_t userdata) {
        REQUIRE(userdata);
        auto user_data = static_cast<BCTOState*>(userdata);
        REQUIRE(user_data->bcto_deleted == false);
        REQUIRE((user_data && user_data->id == "BTCO-STATE"));
        user_data->id.clear();
        user_data->bcto_deleted = true;
    };

    auto bcto_on_thread_create = [](realm_userdata_t userdata) {
        REQUIRE(userdata);
        auto user_data = static_cast<BCTOState*>(userdata);
        REQUIRE(user_data->bcto_deleted == false);
        REQUIRE((user_data && user_data->id == "BTCO-STATE"));
        REQUIRE(!user_data->thread_create_called);
        user_data->thread_create_called = true;
    };

    auto bcto_on_thread_destroy = [](realm_userdata_t userdata) {
        REQUIRE(userdata);
        auto user_data = static_cast<BCTOState*>(userdata);
        REQUIRE(user_data->bcto_deleted == false);
        REQUIRE((user_data && user_data->id == "BTCO-STATE"));
        REQUIRE(!user_data->thread_destroy_called);
        user_data->thread_destroy_called = true;
    };

    auto bcto_on_thread_error = [](realm_userdata_t userdata, const char* err_message) {
        REQUIRE(userdata);
        REQUIRE(err_message);
        auto user_data = static_cast<BCTOState*>(userdata);
        REQUIRE(user_data->bcto_deleted == false);
        REQUIRE((user_data && user_data->id == "BTCO-STATE"));
        REQUIRE(user_data->thread_on_error_message.empty());
        user_data->thread_on_error_message = err_message;
        return true;
    };

    {
        auto config = cptr(realm_sync_client_config_new());
        realm_sync_client_config_set_default_binding_thread_observer(
            config.get(), bcto_on_thread_create, bcto_on_thread_destroy, bcto_on_thread_error,
            static_cast<realm_userdata_t>(&bcto_user_data), bcto_free_userdata);
        REQUIRE(config->default_socket_provider_thread_observer);
        auto observer_ptr =
            static_cast<CBindingThreadObserver*>(config->default_socket_provider_thread_observer.get());
        REQUIRE(observer_ptr->test_get_create_callback_func() == bcto_on_thread_create);
        REQUIRE(observer_ptr->test_get_destroy_callback_func() == bcto_on_thread_destroy);
        REQUIRE(observer_ptr->test_get_error_callback_func() == bcto_on_thread_error);
        REQUIRE(observer_ptr->has_handle_error());
        REQUIRE(observer_ptr->test_get_userdata_ptr() == &bcto_user_data);

        auto test_thread = std::thread([&]() {
            auto bcto_ptr = std::static_pointer_cast<realm::BindingCallbackThreadObserver>(
                config->default_socket_provider_thread_observer);
            REQUIRE(bcto_ptr);
            auto will_destroy_thread = util::make_scope_exit([&bcto_ptr]() noexcept {
                bcto_ptr->will_destroy_thread();
            });
            bcto_ptr->did_create_thread();
            REQUIRE(bcto_ptr->handle_error(MultipleSyncAgents()));
        });

        // Wait for the thread to exit
        test_thread.join();

        REQUIRE(bcto_user_data.thread_create_called);
        REQUIRE(bcto_user_data.thread_on_error_message.find(
                    "Multiple sync agents attempted to join the same session") != std::string::npos);
        REQUIRE(bcto_user_data.thread_destroy_called);
    }

    REQUIRE(bcto_user_data.bcto_deleted == true);

    {
        auto config = cptr(realm_sync_client_config_new());
        realm_sync_client_config_set_default_binding_thread_observer(config.get(), nullptr, nullptr, nullptr, nullptr,
                                                                     nullptr);
        auto no_handle_error_ptr =
            static_cast<CBindingThreadObserver*>(config->default_socket_provider_thread_observer.get());
        no_handle_error_ptr->did_create_thread();                          // should not crash
        no_handle_error_ptr->will_destroy_thread();                        // should not crash
        REQUIRE(!no_handle_error_ptr->has_handle_error());                 // no handler, returns false
        REQUIRE(!no_handle_error_ptr->handle_error(MultipleSyncAgents())); // no handler, returns false
        // No free_user_data function was provided and internal default should be used
        // Should not crash at scope exit
    }
}
#endif

#if REALM_ENABLE_AUTH_TESTS

std::atomic_bool baas_client_stop{false};
std::atomic<std::size_t> error_handler_counter{0};
std::atomic<std::size_t> before_client_reset_counter{0};
std::atomic<std::size_t> after_client_reset_counter{0};

TEST_CASE("C API - client reset", "[sync][pbs][c_api][client reset][baas]") {
    reset_utils::Partition partition{"realm_id", random_string(20)};
    Property partition_prop = {partition.property_name, PropertyType::String | PropertyType::Nullable};
    Schema schema{
        {"object",
         {
             {"_id", PropertyType::ObjectId, Property::IsPrimary{true}},
             {"value", PropertyType::Int},
             partition_prop,
         }},
    };

    auto server_app_config = minimal_app_config("c_api_client_reset_tests", schema);
    server_app_config.partition_key = partition_prop;
    TestAppSession test_app_session(create_app(server_app_config));

    auto app = test_app_session.app();
    auto get_valid_config = [&]() -> SyncTestFile {
        create_user_and_log_in(app);
        return SyncTestFile(app->current_user(), partition.value, schema);
    };
    SyncTestFile local_config = get_valid_config();
    SyncTestFile remote_config = get_valid_config();

    auto make_reset = [&](Realm::Config config_local,
                          Realm::Config config_remote) -> std::unique_ptr<reset_utils::TestClientReset> {
        return reset_utils::make_baas_client_reset(config_local, config_remote, test_app_session);
    };

    local_config.sync_config = std::make_shared<realm_sync_config_t>(*local_config.sync_config);
    realm_sync_config_t* local_sync_config = static_cast<realm_sync_config_t*>(local_config.sync_config.get());

    struct ResetRealmFiles {
        void set_app(std::shared_ptr<realm::app::App> app)
        {
            m_app = app;
        }
        void reset_realm(const char* path)
        {
            realm_app_t realm_app{m_app};
            bool did_run;
            realm_sync_immediately_run_file_actions(&realm_app, path, &did_run);
        }
        static ResetRealmFiles& instance()
        {
            static ResetRealmFiles instance;
            return instance;
        }
        std::shared_ptr<realm::app::App> m_app;
    };
    ResetRealmFiles::instance().set_app(app);

    SECTION("Manual reset") {
        realm_sync_config_set_resync_mode(local_sync_config, RLM_SYNC_SESSION_RESYNC_MODE_MANUAL);

        realm_sync_config_set_error_handler(
            local_sync_config,
            [](realm_userdata_t, realm_sync_session_t*, const realm_sync_error_t sync_error) {
                REQUIRE(sync_error.c_original_file_path_key);
                REQUIRE(sync_error.c_recovery_file_path_key);
                REQUIRE(sync_error.is_client_reset_requested);
                REQUIRE(sync_error.server_requests_action == RLM_SYNC_ERROR_ACTION_CLIENT_RESET);
                ResetRealmFiles::instance().reset_realm(sync_error.c_original_file_path_key);
                baas_client_stop.store(true);
            },
            nullptr, nullptr);

        make_reset(local_config, remote_config)
            ->on_post_reset([&](SharedRealm) {
                util::EventLoop::main().run_until([&] {
                    return baas_client_stop.load();
                });
            })
            ->run();
    }

    SECTION("Local Discard") {
        realm_sync_config_set_resync_mode(local_sync_config, RLM_SYNC_SESSION_RESYNC_MODE_DISCARD_LOCAL);

        SECTION("Before client reset success") {
            realm_sync_config_set_before_client_reset_handler(
                local_sync_config,
                [](realm_userdata_t, realm_t*) -> bool {
                    before_client_reset_counter.fetch_add(1);
                    return true;
                },
                nullptr, nullptr);

            realm_sync_config_set_after_client_reset_handler(
                local_sync_config,
                [](realm_userdata_t, realm_t*, realm_thread_safe_reference_t*, bool) -> bool {
                    after_client_reset_counter.fetch_add(1);
                    baas_client_stop.store(true);
                    return true;
                },
                nullptr, nullptr);

            make_reset(local_config, remote_config)
                ->on_post_reset([&](SharedRealm) {
                    util::EventLoop::main().run_until([&] {
                        return baas_client_stop.load();
                    });
                })
                ->run();

            REQUIRE(before_client_reset_counter.load() == 1);
            REQUIRE(after_client_reset_counter.load() == 1);
        }

        SECTION("Before client reset fails") {
            baas_client_stop.store(false);
            before_client_reset_counter.store(0);
            after_client_reset_counter.store(0);

            realm_sync_config_set_error_handler(
                local_sync_config,
                [](realm_userdata_t, realm_sync_session_t*, const realm_sync_error_t sync_error) {
                    REQUIRE(sync_error.c_original_file_path_key);
                    REQUIRE(sync_error.c_recovery_file_path_key);
                    REQUIRE(sync_error.is_client_reset_requested);
                    // Callback in `realm_sync_config_set_before_client_reset_handler` fails, so
                    // a synthetic error is created with no action.
                    REQUIRE(sync_error.server_requests_action == RLM_SYNC_ERROR_ACTION_NO_ACTION);
                    ResetRealmFiles::instance().reset_realm(sync_error.c_original_file_path_key);
                    error_handler_counter.fetch_add(1);
                    baas_client_stop.store(true);
                },
                nullptr, nullptr);

            realm_sync_config_set_before_client_reset_handler(
                local_sync_config,
                [](realm_userdata_t, realm_t*) -> bool {
                    before_client_reset_counter.fetch_add(1);
                    return false;
                },
                nullptr, nullptr);

            realm_sync_config_set_after_client_reset_handler(
                local_sync_config,
                [](realm_userdata_t, realm_t*, realm_thread_safe_reference_t*, bool) -> bool {
                    after_client_reset_counter.fetch_add(1);
                    return true;
                },
                nullptr, nullptr);

            make_reset(local_config, remote_config)
                ->on_post_reset([&](SharedRealm) {
                    util::EventLoop::main().run_until([&] {
                        return baas_client_stop.load();
                    });
                })
                ->run();

            REQUIRE(error_handler_counter.load() == 1);
            REQUIRE(before_client_reset_counter.load() == 1);
            REQUIRE(after_client_reset_counter.load() == 0);
        }

        SECTION("Simulate failure during client reset with expection in the user code callback") {
            error_handler_counter.store(0);
            baas_client_stop.store(false);

            struct ErrorState {
                uintptr_t target_user_code_data = static_cast<uintptr_t>(random_int());
                std::optional<uintptr_t> observed_user_code_data;
            };
            ErrorState state;
            realm_sync_config_set_error_handler(
                local_sync_config,
                [](realm_userdata_t uncast_state, realm_sync_session_t*, const realm_sync_error_t sync_error) {
                    REQUIRE(sync_error.c_original_file_path_key);
                    REQUIRE(sync_error.c_recovery_file_path_key);
                    REQUIRE(sync_error.is_client_reset_requested);
                    // Callback in `realm_sync_config_set_before_client_reset_handler` fails, so
                    // a synthetic error is created with no action.
                    // Since this is a failure triggered by some exception in the user code
                    // an opaque ptr should have passed back to this callback in order to let
                    // the SDK re-throw the excpetion.
                    REQUIRE(sync_error.server_requests_action == RLM_SYNC_ERROR_ACTION_NO_ACTION);
                    ResetRealmFiles::instance().reset_realm(sync_error.c_original_file_path_key);
                    auto state = static_cast<ErrorState*>(uncast_state);
                    state->observed_user_code_data = reinterpret_cast<uintptr_t>(sync_error.user_code_error);
                    error_handler_counter.fetch_add(1);
                    baas_client_stop.store(true);
                },
                &state, nullptr);

            SECTION("before reset exception") {
                realm_sync_config_set_before_client_reset_handler(
                    local_sync_config,
                    [](realm_userdata_t uncast_state, realm_t*) -> bool {
                        auto state = static_cast<ErrorState*>(uncast_state);
                        realm_register_user_code_callback_error(
                            reinterpret_cast<void*>(state->target_user_code_data));
                        return false;
                    },
                    &state, nullptr);

                make_reset(local_config, remote_config)
                    ->on_post_reset([&](SharedRealm) {
                        util::EventLoop::main().run_until([&] {
                            return baas_client_stop.load();
                        });
                    })
                    ->run();
            }
            SECTION("After reset exception") {
                realm_sync_config_set_before_client_reset_handler(
                    local_sync_config,
                    [](realm_userdata_t, realm_t*) -> bool {
                        return true;
                    },
                    nullptr, nullptr);

                realm_sync_config_set_after_client_reset_handler(
                    local_sync_config,
                    [](realm_userdata_t uncast_state, realm_t*, realm_thread_safe_reference_t*, bool) -> bool {
                        auto state = static_cast<ErrorState*>(uncast_state);
                        realm_register_user_code_callback_error(
                            reinterpret_cast<void*>(state->target_user_code_data));
                        return false;
                    },
                    &state, nullptr);

                make_reset(local_config, remote_config)
                    ->on_post_reset([&](SharedRealm) {
                        util::EventLoop::main().run_until([&] {
                            return baas_client_stop.load();
                        });
                    })
                    ->run();
            }
            REQUIRE(error_handler_counter.load() == 1);
            REQUIRE(state.observed_user_code_data == state.target_user_code_data);
        }
    }
}

static void realm_app_void_completion(void*, const realm_app_error_t*) {}

static void realm_app_user1(void* p, realm_user_t* user, const realm_app_error_t*)
{
    auto clone_ptr = realm_clone(user);
    CHECK(realm_equals(user, clone_ptr));
    *(static_cast<realm_user_t**>(p)) = static_cast<realm_user_t*>(clone_ptr);
}

static void realm_app_user2(void* p, realm_user_t* user, const realm_app_error_t*)
{
    realm_user_identity_t idents[10];
    size_t n;
    realm_user_get_all_identities(user, idents, 10, &n);
    *static_cast<bool*>(p) = n == 2;
    for (size_t i = 0; i < n; i++) {
        realm_free(idents[i].id);
    }
}

TEST_CASE("C API app: link_user integration w/c_api transport", "[sync][app][c_api][baas]") {
    struct TestTransportUserData {
        TestTransportUserData()
            : logger(util::Logger::get_default_logger())
            , transport(std::make_unique<SynchronousTestTransport>())
        {
        }
        std::shared_ptr<util::Logger> logger;
        std::unique_ptr<realm::app::GenericNetworkTransport> transport;
    };

    auto send_request_to_server = [](realm_userdata_t userdata, const realm_http_request_t request,
                                     void* request_context) {
        using namespace realm::app;

        constexpr uint64_t default_timeout_ms = 60000;
        REQUIRE(userdata != nullptr);
        TestTransportUserData* user_data(static_cast<TestTransportUserData*>(userdata));
        REQUIRE(user_data != nullptr);
        REQUIRE(user_data->transport != nullptr);
        REQUIRE(user_data->logger != nullptr);
        REQUIRE(strlen(request.url) > 0);
        HttpHeaders headers;
        for (size_t i = 0; i < request.num_headers; i++) {
            REQUIRE(request.headers[i].name != nullptr);
            REQUIRE(request.headers[i].value != nullptr);
            std::string name(request.headers[i].name);
            std::string value(request.headers[i].value);
            REQUIRE(!name.empty());
            REQUIRE(!value.empty());
            headers.emplace(name, value);
        }
        REQUIRE(request_context != nullptr);
        auto new_request = Request{HttpMethod(request.method), request.url, default_timeout_ms, std::move(headers),
                                   std::string(request.body, request.body_size)};
        user_data->logger->trace("CAPI: Request URL (%1): %2", httpmethod_to_string(new_request.method),
                                 new_request.url);
        user_data->logger->trace("CAPI: Request body: %1", new_request.body);
        user_data->transport->send_request_to_server(new_request, [&](const Response& response) mutable {
            std::vector<realm_http_header_t> c_headers;
            c_headers.reserve(response.headers.size());
            for (auto&& header : response.headers) {
                c_headers.push_back({header.first.c_str(), header.second.c_str()});
            }

            auto c_response = std::make_unique<realm_http_response_t>();
            c_response->status_code = response.http_status_code;
            c_response->custom_status_code = response.custom_status_code;
            c_response->headers = c_headers.data();
            c_response->num_headers = c_headers.size();
            c_response->body = response.body.data();
            c_response->body_size = response.body.size();
            user_data->logger->trace("CAPI: Response (%1): %2", c_response->status_code,
                                     std::string(c_response->body, c_response->body_size));
            realm_http_transport_complete_request(request_context, c_response.get());
        });
    };

    auto user_data_free = [](void* userdata) {
        REQUIRE(userdata != nullptr);
        std::unique_ptr<TestTransportUserData> user_data(static_cast<TestTransportUserData*>(userdata));
        REQUIRE(user_data != nullptr);
        REQUIRE(user_data->transport != nullptr);
        REQUIRE(user_data->logger != nullptr);
        user_data->logger->trace("CAPI: user_data free called");
    };

    // user_data will be deleted when user_data_free() is called
    auto user_data = new TestTransportUserData();
    auto http_transport = realm_http_transport_new(send_request_to_server, user_data, user_data_free);
    auto app_session = get_runtime_app_session();
    TestAppSession session(app_session, *http_transport, DeleteApp{false});
    realm_app app(session.app());

    SECTION("remove_user integration") {
        AutoVerifiedEmailCredentials creds;
        realm_user_t* sync_user_1 = nullptr;
        realm_string_t password{creds.password.c_str(), creds.password.length()};
        realm_app_email_password_provider_client_register_email(&app, creds.email.c_str(), password,
                                                                realm_app_void_completion, nullptr, nullptr);
        realm_app_credentials anonymous(app::AppCredentials::anonymous());
        realm_app_log_in_with_credentials(&app, &anonymous, realm_app_user1, &sync_user_1, nullptr);

        realm_app_remove_user(&app, sync_user_1, realm_app_void_completion, nullptr, nullptr);
        auto state = realm_user_get_state(sync_user_1);
        CHECK(state == RLM_USER_STATE_REMOVED);
        realm_release(sync_user_1);
    }
    SECTION("delete_user integration") {
        AutoVerifiedEmailCredentials creds;
        realm_user_t* sync_user = nullptr;
        realm_string_t password{creds.password.c_str(), creds.password.length()};
        realm_app_email_password_provider_client_register_email(&app, creds.email.c_str(), password,
                                                                realm_app_void_completion, nullptr, nullptr);
        realm_app_credentials anonymous(app::AppCredentials::anonymous());
        realm_app_log_in_with_credentials(&app, &anonymous, realm_app_user1, &sync_user, nullptr);

        realm_app_delete_user(&app, sync_user, realm_app_void_completion, nullptr, nullptr);
        auto state = realm_user_get_state(sync_user);
        CHECK(state == RLM_USER_STATE_REMOVED);
        realm_release(sync_user);
    }
    SECTION("link_user integration") {
        AutoVerifiedEmailCredentials creds;
        bool processed = false;
        realm_user_t* sync_user = nullptr;

        realm_string_t password{creds.password.c_str(), creds.password.length()};
        realm_app_email_password_provider_client_register_email(&app, creds.email.c_str(), password,
                                                                realm_app_void_completion, nullptr, nullptr);

        realm_app_credentials anonymous(app::AppCredentials::anonymous());
        realm_app_log_in_with_credentials(&app, &anonymous, realm_app_user1, &sync_user, nullptr);

        realm_app_credentials email_creds(creds);
        realm_app_link_user(&app, sync_user, &email_creds, realm_app_user2, &processed, nullptr);

        CHECK(processed);
        realm_release(sync_user);
    }
    SECTION("realm_app_get_all_users integration") {

        AutoVerifiedEmailCredentials creds;
        realm_user_t* sync_user_1 = nullptr;
        realm_string_t password{creds.password.c_str(), creds.password.length()};
        realm_app_email_password_provider_client_register_email(&app, creds.email.c_str(), password,
                                                                realm_app_void_completion, nullptr, nullptr);
        realm_app_credentials anonymous(app::AppCredentials::anonymous());
        realm_app_log_in_with_credentials(&app, &anonymous, realm_app_user1, &sync_user_1, nullptr);
        auto current_user = realm_app_get_current_user(&app);
        CHECK(realm_equals(sync_user_1, current_user));
        realm_release(current_user);

        realm_user_t* sync_user_2;
        realm_app_switch_user(&app, sync_user_1, &sync_user_2);
        size_t out_n = 0;

        realm_app_get_all_users(&app, nullptr, 0, &out_n);
        CHECK(out_n == 2);

        std::vector<realm_user_t*> out_users;
        out_users.resize(out_n);
        size_t n = 0;
        realm_app_get_all_users(&app, out_users.data(), out_n, &n);
        CHECK(n == out_n);

        for (size_t i = 0; i < out_n; ++i)
            realm_release(out_users[i]);
        realm_release(sync_user_1);
        realm_release(sync_user_2);
    }
    SECTION("realm_app_user_apikey_provider_client_fetch_apikeys") {
        SECTION("Failure") {
            AutoVerifiedEmailCredentials creds;
            realm_user_t* sync_user_1 = nullptr;
            realm_string_t password{creds.password.c_str(), creds.password.length()};
            realm_app_email_password_provider_client_register_email(&app, creds.email.c_str(), password,
                                                                    realm_app_void_completion, nullptr, nullptr);
            realm_app_credentials anonymous(app::AppCredentials::anonymous());
            realm_app_log_in_with_credentials(&app, &anonymous, realm_app_user1, &sync_user_1, nullptr);
            auto callback = [](realm_userdata_t, realm_app_user_apikey_t[], size_t count, realm_app_error_t* error) {
                CHECK(error);
                CHECK(count == 0);
            };
            // Should fail with 403
            auto res =
                realm_app_user_apikey_provider_client_fetch_apikeys(&app, sync_user_1, callback, nullptr, nullptr);
            REQUIRE(res == true);
            realm_release(sync_user_1);
        }
        SECTION("Success") {
            TestAppSession session;
            realm_app app(session.app());

            class AppObject {
            public:
                static AppObject& create()
                {
                    static AppObject obj;
                    return obj;
                }
                const char* key() const
                {
                    return api_key_name.c_str();
                }

            private:
                AppObject()
                {
                    api_key_name = util::format("%1", random_string(15));
                }
                std::string api_key_name;
            };

            auto create_api_callback = [](realm_userdata_t, realm_app_user_apikey_t* api_key,
                                          const realm_app_error_t* error) {
                REQUIRE_FALSE(error);
                REQUIRE(api_key);
                CHECK(strcmp(api_key->name, AppObject::create().key()) == 0);
            };
            auto current_user = realm_app_get_current_user(&app);
            auto state = realm_app_user_apikey_provider_client_create_apikey(
                &app, current_user, AppObject::create().key(), create_api_callback, nullptr, nullptr);
            REQUIRE(state);

            auto fetch_apikey_callback = [](realm_userdata_t, realm_app_user_apikey_t* keys, size_t count,
                                            realm_app_error_t* error) {
                REQUIRE_FALSE(error);
                REQUIRE(keys);
                REQUIRE(count == 1);
                CHECK(strcmp(keys[0].name, AppObject::create().key()) == 0);
            };
            state = realm_app_user_apikey_provider_client_fetch_apikeys(&app, current_user, fetch_apikey_callback,
                                                                        nullptr, nullptr);
            REQUIRE(state);
            realm_release(current_user);
        }
    }
    realm_release(http_transport);
}

TEST_CASE("app: flx-sync compensating writes C API support", "[sync][flx][c_api][baas]") {
    using namespace realm::app;
    FLXSyncTestHarness harness("c_api_comp_writes");
    create_user_and_log_in(harness.app());
    SyncTestFile test_config(harness.app()->current_user(), harness.schema(), realm::SyncConfig::FLXSyncEnabled{});
    test_config.sync_config = std::make_shared<realm_sync_config_t>(*test_config.sync_config);
    realm_sync_config_t* sync_config = static_cast<realm_sync_config_t*>(test_config.sync_config.get());

    struct TestState {
        std::mutex mutex;
        std::condition_variable cond_var;
        std::vector<sync::CompensatingWriteErrorInfo> compensating_writes;
    };
    auto state = std::make_unique<TestState>();
    realm_sync_config_set_error_handler(
        sync_config,
        [](realm_userdata_t user_data, realm_sync_session_t*, const realm_sync_error_t error) {
            auto state = reinterpret_cast<TestState*>(user_data);
            REQUIRE(error.status.error == RLM_ERR_SYNC_COMPENSATING_WRITE);
            REQUIRE(error.compensating_writes_length > 0);

            std::lock_guard<std::mutex> lk(state->mutex);
            for (size_t i = 0; i < error.compensating_writes_length; ++i) {
                sync::CompensatingWriteErrorInfo err_info;
                err_info.object_name = error.compensating_writes[i].object_name;
                err_info.reason = error.compensating_writes[i].reason;
                Mixed pk(c_api::from_capi(error.compensating_writes[i].primary_key));
                err_info.primary_key = pk;
                state->compensating_writes.push_back(std::move(err_info));
            }

            state->cond_var.notify_one();
        },
        state.get(), [](realm_userdata_t) {});

    auto realm = Realm::get_shared_realm(test_config);

    auto mut_subs = realm->get_latest_subscription_set().make_mutable_copy();
    auto table = realm->read_group().get_table("class_TopLevel");
    mut_subs.insert_or_assign(Query(table).equal(table->get_column_key("queryable_str_field"), "bizz"));
    mut_subs.commit();

    CppContext c(realm);
    realm->begin_transaction();
    auto obj_1_id = ObjectId::gen();
    auto obj_2_id = ObjectId::gen();
    Object::create(c, realm, "TopLevel",
                   std::any(AnyDict{
                       {"_id", obj_1_id},
                       {"queryable_str_field", std::string{"foo"}},
                   }));
    Object::create(c, realm, "TopLevel",
                   std::any(AnyDict{
                       {"_id", obj_2_id},
                       {"queryable_str_field", std::string{"bar"}},
                   }));
    realm->commit_transaction();

    std::unique_lock<std::mutex> lk(state->mutex);
    state->cond_var.wait_for(lk, std::chrono::seconds(30), [&] {
        return state->compensating_writes.size() == 2;
    });

    auto errors = std::move(state->compensating_writes);
    lk.unlock();

    std::sort(errors.begin(), errors.end(), [](const auto& lhs, const auto& rhs) {
        return lhs.primary_key < rhs.primary_key;
    });

    REQUIRE(errors.size() == 2);
    REQUIRE(errors[0].primary_key == obj_1_id);
    REQUIRE(errors[0].object_name == "TopLevel");
    REQUIRE_THAT(errors[0].reason, Catch::Matchers::ContainsSubstring("object is outside of the current query view"));
    REQUIRE(errors[1].primary_key == obj_2_id);
    REQUIRE(errors[1].object_name == "TopLevel");
    REQUIRE_THAT(errors[1].reason, Catch::Matchers::ContainsSubstring("object is outside of the current query view"));
}

TEST_CASE("app: flx-sync basic tests", "[sync][flx][c_api][baas]") {
    using namespace realm::app;

    auto make_schema = [] {
        Schema schema{{"Obj",
                       {{"_id", PropertyType::ObjectId, Property::IsPrimary{true}},
                        {"name", PropertyType::String | PropertyType::Nullable},
                        {"value", PropertyType::Int | PropertyType::Nullable}}}};

        return FLXSyncTestHarness::ServerSchema{std::move(schema), {"name", "value"}};
    };

    FLXSyncTestHarness harness("c_api_flx_sync_test", make_schema());
    auto foo_obj_id = ObjectId::gen();
    auto bar_obj_id = ObjectId::gen();

    harness.load_initial_data([&](SharedRealm& realm) {
        CppContext c(realm);
        Object::create(
            c, realm, "Obj",
            std::any(AnyDict{{"_id", foo_obj_id}, {"name", std::string{"foo"}}, {"value", static_cast<int64_t>(5)}}));
        Object::create(c, realm, "Obj",
                       std::any(AnyDict{
                           {"_id", bar_obj_id}, {"name", std::string{"bar"}}, {"value", static_cast<int64_t>(10)}}));
    });

    harness.do_with_new_realm([&](SharedRealm realm) {
        realm_t c_wrap_realm(realm);

        wait_for_download(*realm);
        {
            auto empty_subs = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            CHECK(realm_sync_subscription_set_size(empty_subs) == 0);
            CHECK(realm_sync_subscription_set_version(empty_subs) == 0);
            realm_sync_on_subscription_set_state_change_wait(
                empty_subs, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(empty_subs);
        }
        realm_class_info_t table_info;
        bool found;
        CHECK(realm_find_class(&c_wrap_realm, "Obj", &found, &table_info));
        auto c_wrap_query_foo = realm_query_parse(&c_wrap_realm, table_info.key, "name = 'foo'", 0, nullptr);
        auto c_wrap_query_bar = realm_query_parse(&c_wrap_realm, table_info.key, "name = 'bar'", 0, nullptr);
        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            CHECK(sub != nullptr);
            auto new_subs = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            // realm_results_t
            auto res = realm_sync_subscription_set_insert_or_assign_query(new_subs, c_wrap_query_foo, nullptr, &index,
                                                                          &inserted);
            CHECK(inserted == true);
            CHECK(index == 0);
            CHECK(res);
            auto subs = realm_sync_subscription_set_commit(new_subs);
            auto state = realm_sync_on_subscription_set_state_change_wait(
                subs, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            CHECK(state == realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(sub);
            realm_release(new_subs);
            realm_release(subs);
        }

        wait_for_download(*realm);
        {
            realm_refresh(&c_wrap_realm, nullptr);
            auto results = realm_object_find_all(&c_wrap_realm, table_info.key);
            size_t count = 0;
            realm_results_count(results, &count);
            CHECK(count == 1);
            auto object = realm_results_get_object(results, 0);
            REQUIRE(realm_object_is_valid(object));
            REQUIRE(object->get_column_value<ObjectId>("_id") == foo_obj_id);
            realm_release(object);
            realm_release(results);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            realm_sync_subscription_set_insert_or_assign_query(mut_sub, c_wrap_query_bar, nullptr, &index, &inserted);
            CHECK(inserted);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto state = realm_sync_on_subscription_set_state_change_wait(
                sub_c, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            CHECK(state == realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(sub);
            realm_release(mut_sub);
            realm_release(sub_c);
        }

        {
            realm_refresh(&c_wrap_realm, nullptr);
            auto results = realm_object_find_all(&c_wrap_realm, table_info.key);
            size_t count = 0;
            realm_results_count(results, &count);
            CHECK(count == 2);
            realm_release(results);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            auto s = realm_sync_find_subscription_by_query(sub, c_wrap_query_foo);
            CHECK(s != nullptr);
            auto cloned_s = realm_clone(s);
            CHECK(realm_equals(s, cloned_s));
            bool erased = false;
            auto result = realm_sync_subscription_set_erase_by_query(mut_sub, c_wrap_query_foo, &erased);
            CHECK(erased);
            CHECK(result);
            auto c_wrap_new_query_bar = realm_query_parse(&c_wrap_realm, table_info.key, "name = 'bar'", 0, nullptr);
            std::size_t index = -1;
            bool inserted = false;
            auto results = realm_query_find_all(c_wrap_new_query_bar);
            bool updated =
                realm_sync_subscription_set_insert_or_assign_results(mut_sub, results, nullptr, &index, &inserted);
            CHECK(!inserted);
            CHECK(updated);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto state = realm_sync_on_subscription_set_state_change_wait(
                sub_c, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            CHECK(state == realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(s);
            realm_release(cloned_s);
            realm_release(sub);
            realm_release(mut_sub);
            realm_release(sub_c);
            realm_release(results);
            realm_release(c_wrap_new_query_bar);
        }

        {
            realm_refresh(&c_wrap_realm, nullptr);
            auto results = realm_object_find_all(&c_wrap_realm, table_info.key);
            size_t count = 0;
            realm_results_count(results, &count);
            CHECK(count == 1);
            auto object = realm_results_get_object(results, 0);
            REQUIRE(realm_object_is_valid(object));
            REQUIRE(object->get_column_value<ObjectId>("_id") == bar_obj_id);
            realm_release(object);
            realm_release(results);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            auto cleared = realm_sync_subscription_set_clear(mut_sub);
            CHECK(cleared);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto state = realm_sync_on_subscription_set_state_change_wait(
                sub_c, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            CHECK(state == realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(sub);
            realm_release(mut_sub);
            realm_release(sub_c);
        }

        {
            realm_refresh(&c_wrap_realm, nullptr);
            auto results = realm_object_find_all(&c_wrap_realm, table_info.key);
            size_t count = std::numeric_limits<std::size_t>::max();
            realm_results_count(results, &count);
            CHECK(count == 0);
            realm_release(results);
        }

        {
            auto c_wrap_new_query_bar = realm_query_parse(&c_wrap_realm, table_info.key, "name = 'bar'", 0, nullptr);
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            auto results = realm_query_find_all(c_wrap_new_query_bar);
            bool success =
                realm_sync_subscription_set_insert_or_assign_results(mut_sub, results, "bar", &index, &inserted);
            CHECK(inserted);
            CHECK(success);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto state = realm_sync_on_subscription_set_state_change_wait(
                sub_c, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            CHECK(state == realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(sub);
            realm_release(mut_sub);
            realm_release(sub_c);
            realm_release(results);
            realm_release(c_wrap_new_query_bar);
        }

        {
            realm->refresh();
            auto results = realm_object_find_all(&c_wrap_realm, table_info.key);
            size_t count = std::numeric_limits<std::size_t>::max();
            realm_results_count(results, &count);
            CHECK(count == 1);
            realm_release(results);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            bool erased = false;
            realm_sync_subscription_set_erase_by_name(mut_sub, "bar", &erased);
            CHECK(erased);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto state = realm_sync_on_subscription_set_state_change_wait(
                sub_c, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            CHECK(state == realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);
            realm_release(sub);
            realm_release(mut_sub);
            realm_release(sub_c);
        }

        {
            realm_refresh(&c_wrap_realm, nullptr);
            auto results = realm_object_find_all(&c_wrap_realm, table_info.key);
            size_t count = std::numeric_limits<std::size_t>::max();
            realm_results_count(results, &count);
            CHECK(count == 0);
            realm_release(results);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            auto results = realm_query_find_all(c_wrap_query_bar);
            bool success =
                realm_sync_subscription_set_insert_or_assign_results(mut_sub, results, nullptr, &index, &inserted);
            CHECK(inserted);
            CHECK(success);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            // lambdas with state cannot be easily converted to function pointers, add a simple singleton that syncs
            // the state among threads
            struct SyncObject {
                std::mutex m_mutex;
                std::condition_variable m_cv;
                realm_flx_sync_subscription_set_state_e m_state{RLM_SYNC_SUBSCRIPTION_UNCOMMITTED};
                void* m_userdata;

                static SyncObject& create()
                {
                    static SyncObject sync_object;
                    return sync_object;
                }

                void set_state_and_notify(void* userdata, realm_flx_sync_subscription_set_state_e state)
                {
                    {
                        std::lock_guard<std::mutex> guard{m_mutex};
                        m_state = state;
                        m_userdata = userdata;
                    }
                    m_cv.notify_one();
                }

                realm_flx_sync_subscription_set_state_e wait_state()
                {
                    using namespace std::chrono_literals;
                    std::unique_lock<std::mutex> lock{m_mutex};
                    const auto delay = TEST_TIMEOUT_EXTRA > 0 ? std::chrono::seconds(5 + TEST_TIMEOUT_EXTRA) : 5s;
                    bool completed_within_time_limit = m_cv.wait_for(lock, delay, [this]() {
                        return m_state == RLM_SYNC_SUBSCRIPTION_COMPLETE && m_userdata != nullptr;
                    });
                    CHECK(completed_within_time_limit);
                    return m_state;
                }
            };

            auto callback = [](void* userdata, realm_flx_sync_subscription_set_state_e sub_state) {
                SyncObject::create().set_state_and_notify(userdata, sub_state);
            };
            int userdata = 0;
            realm_sync_on_subscription_set_state_change_async(
                sub_c, realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE, callback, &userdata,
                nullptr);
            CHECK(SyncObject::create().wait_state() ==
                  realm_flx_sync_subscription_set_state_e::RLM_SYNC_SUBSCRIPTION_COMPLETE);

            realm_release(sub);
            realm_release(mut_sub);
            realm_release(sub_c);
            realm_release(results);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            auto results = realm_query_find_all(c_wrap_query_bar);
            bool success =
                realm_sync_subscription_set_insert_or_assign_results(mut_sub, results, "test_bar", &index, &inserted);
            CHECK(inserted);
            CHECK(success);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto sub_by_res = realm_sync_find_subscription_by_results(sub_c, results);
            CHECK(sub_by_res);
            const auto realm_flx_sync_sub = realm_sync_find_subscription_by_name(sub_c, "test_bar");
            REQUIRE(realm_flx_sync_sub);

            const realm_object_id_t& object_id = realm_sync_subscription_id(realm_flx_sync_sub);
            CHECK(!realm::c_api::from_capi(object_id).to_string().empty());

            realm_timestamp_t create_time = realm_sync_subscription_created_at(realm_flx_sync_sub);
            realm_timestamp_t update_time = realm_sync_subscription_updated_at(realm_flx_sync_sub);
            CHECK(create_time.seconds == update_time.seconds);
            CHECK(create_time.nanoseconds == update_time.nanoseconds);
            CHECK(create_time.seconds != 0);
            CHECK(create_time.seconds != 0);

            const realm_string_t& name = realm_sync_subscription_name(realm_flx_sync_sub);
            REQUIRE(name.size != 0);
            CHECK(std::string{name.data, name.size} == "test_bar");

            auto mut_sub_1 = realm_sync_make_subscription_set_mutable(sub_c);
            bool erased = false;
            CHECK(realm_sync_subscription_set_erase_by_id(mut_sub_1, &object_id, &erased));
            CHECK(erased);
            auto sub_c_1 = realm_sync_subscription_set_commit(mut_sub_1);

            const auto sub_not_found = realm_sync_find_subscription_by_name(sub_c_1, "test_bar");
            CHECK(!sub_not_found);

            realm_release(sub);
            realm_release(mut_sub);
            realm_release(results);
            realm_release(sub_c);
            realm_release(sub_by_res);
            realm_release(realm_flx_sync_sub);
            realm_release(mut_sub_1);
            realm_release(sub_c_1);
            realm_release(sub_not_found);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            auto results = realm_query_find_all(c_wrap_query_bar);
            bool success =
                realm_sync_subscription_set_insert_or_assign_results(mut_sub, results, "test_bar", &index, &inserted);
            CHECK(inserted);
            CHECK(success);
            auto sub_c = realm_sync_subscription_set_commit(mut_sub);
            auto sub_by_res = realm_sync_find_subscription_by_results(sub_c, results);
            CHECK(sub_by_res);

            auto mut_sub_1 = realm_sync_make_subscription_set_mutable(sub_c);
            bool erased = false;
            realm_sync_subscription_set_erase_by_results(mut_sub_1, results, &erased);
            CHECK(erased);
            auto sub_c_1 = realm_sync_subscription_set_commit(mut_sub_1);

            realm_release(sub);
            realm_release(mut_sub);
            realm_release(results);
            realm_release(sub_c);
            realm_release(sub_by_res);
            realm_release(mut_sub_1);
            realm_release(sub_c_1);
        }

        {
            auto sub = realm_sync_get_latest_subscription_set(&c_wrap_realm);
            auto mut_sub = realm_sync_make_subscription_set_mutable(sub);
            std::size_t index = -1;
            bool inserted = false;
            CHECK(realm_sync_subscription_set_insert_or_assign_query(mut_sub, c_wrap_query_bar, nullptr, &index,
                                                                     &inserted));
            CHECK(inserted);
            CHECK(realm_sync_subscription_set_insert_or_assign_query(mut_sub, c_wrap_query_foo, nullptr, &index,
                                                                     &inserted));
            CHECK(inserted);
            bool erased = false;
            CHECK(realm_sync_subscription_set_erase_by_class_name(mut_sub, "Obj", &erased));
            CHECK(erased);
            // Nothing to remove when trying again.
            CHECK(realm_sync_subscription_set_erase_by_class_name(mut_sub, "Obj", &erased));
            CHECK_FALSE(erased);
            realm_release(sub);
            realm_release(mut_sub);
        }

        realm_release(c_wrap_query_foo);
        realm_release(c_wrap_query_bar);
    });
}

TEST_CASE("C API app: websocket provider", "[sync][app][c_api][baas]") {
    using namespace realm::app;
    using namespace realm::sync;
    using namespace realm::sync::websocket;

    struct TestWebSocketObserverShim : sync::WebSocketObserver {
    public:
        explicit TestWebSocketObserverShim(realm_websocket_observer_t* observer)
            : m_observer(observer)
        {
        }

        void websocket_connected_handler(const std::string& protocol) override
        {
            REALM_ASSERT(m_observer);
            realm_sync_socket_websocket_connected(m_observer, protocol.c_str());
        }

        void websocket_error_handler() override
        {
            REALM_ASSERT(m_observer);
            realm_sync_socket_websocket_error(m_observer);
        }

        bool websocket_binary_message_received(util::Span<const char> data) override
        {
            REALM_ASSERT(m_observer);
            return realm_sync_socket_websocket_message(m_observer, data.data(), data.size());
        }

        bool websocket_closed_handler(bool was_clean, WebSocketError error, std::string_view msg) override
        {
            REALM_ASSERT(m_observer);
            return realm_sync_socket_websocket_closed(m_observer, was_clean,
                                                      static_cast<realm_web_socket_errno_e>(error), msg.data());
        }

    private:
        realm_websocket_observer_t* m_observer;
    };

    struct TestWebSocket : realm::c_api::WrapC, WebSocketInterface {
    public:
        TestWebSocket(DefaultSocketProvider& socket_provider, realm_websocket_endpoint_t endpoint,
                      realm_websocket_observer_t* realm_websocket_observer)
        {
            WebSocketEndpoint ws_endpoint;
            ws_endpoint.address = endpoint.address;
            ws_endpoint.port = endpoint.port;
            ws_endpoint.path = endpoint.path;
            for (size_t i = 0; i < endpoint.num_protocols; ++i) {
                ws_endpoint.protocols.push_back(endpoint.protocols[i]);
            }
            ws_endpoint.is_ssl = endpoint.is_ssl;

            auto observer = std::make_unique<TestWebSocketObserverShim>(realm_websocket_observer);
            m_websocket = socket_provider.connect(std::move(observer), std::move(ws_endpoint));
        }

        void async_write_binary(util::Span<const char> data, SyncSocketProvider::FunctionHandler&& handler) override
        {
            m_websocket->async_write_binary(data, std::move(handler));
        }

    private:
        std::unique_ptr<WebSocketInterface> m_websocket;
    };

    struct TestSyncTimer : realm::c_api::WrapC, SyncSocketProvider::Timer {
    public:
        TestSyncTimer(DefaultSocketProvider& socket_provider, std::chrono::milliseconds delay,
                      realm_sync_socket_timer_callback_t* callback)
        {
            m_timer = socket_provider.create_timer(delay, [capi_callback = callback](Status s) {
                if (s.code() == ErrorCodes::Error::OperationAborted) {
                    return realm_sync_socket_timer_canceled(capi_callback);
                }
                realm_sync_socket_timer_complete(
                    capi_callback, static_cast<realm_sync_socket_callback_result_e>(s.code()), s.reason().c_str());
            });
        }

        void cancel() override
        {
            m_timer->cancel();
        }

    private:
        SyncSocketProvider::SyncTimer m_timer;
    };

    struct TestData {
        DefaultSocketProvider* socket_provider;
        int free_count = 0;
    };

    DefaultSocketProvider default_socket_provider(util::Logger::get_default_logger(), "SocketProvider");

    static std::mutex catch_mutex;
#define LOCKED_REQUIRE(...)                                                                                          \
    do {                                                                                                             \
        std::lock_guard lock(catch_mutex);                                                                           \
        REQUIRE(__VA_ARGS__);                                                                                        \
    } while (0)

    auto userdata_free_fn = [](realm_userdata_t user_ptr) {
        auto test_data = static_cast<TestData*>(user_ptr);
        LOCKED_REQUIRE(test_data);
        test_data->free_count++;
    };
    auto post_fn = [](realm_userdata_t userdata, realm_sync_socket_post_callback_t* callback) {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        test_data->socket_provider->post([capi_callback = callback](Status s) {
            realm_sync_socket_post_complete(capi_callback, static_cast<realm_sync_socket_callback_result_e>(s.code()),
                                            s.reason().c_str());
        });
    };
    auto create_timer_fn = [](realm_userdata_t userdata, uint64_t delay_ms,
                              realm_sync_socket_timer_callback_t* callback) -> realm_sync_socket_timer_t {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        return static_cast<realm_sync_socket_timer_t>(
            new TestSyncTimer(*test_data->socket_provider, std::chrono::milliseconds(delay_ms), callback));
    };
    auto cancel_timer_fn = [](realm_userdata_t userdata, realm_sync_socket_timer_t sync_timer) {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        auto timer = static_cast<TestSyncTimer*>(sync_timer);
        LOCKED_REQUIRE(timer);
        timer->cancel();
    };
    auto free_timer_fn = [](realm_userdata_t userdata, realm_sync_socket_timer_t sync_timer) {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        realm_release(sync_timer);
    };
    auto websocket_connect_fn =
        [](realm_userdata_t userdata, realm_websocket_endpoint_t endpoint,
           realm_websocket_observer_t* realm_websocket_observer) -> realm_sync_socket_websocket_t {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        return static_cast<realm_sync_socket_websocket_t>(
            new TestWebSocket(*test_data->socket_provider, endpoint, realm_websocket_observer));
    };
    auto websocket_async_write_fn = [](realm_userdata_t userdata, realm_sync_socket_websocket_t sync_websocket,
                                       const char* data, size_t size, realm_sync_socket_write_callback_t* callback) {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        auto websocket = static_cast<TestWebSocket*>(sync_websocket);
        LOCKED_REQUIRE(websocket);
        websocket->async_write_binary(util::Span{data, size}, [capi_callback = callback](Status s) {
            realm_sync_socket_write_complete(
                capi_callback, static_cast<realm_sync_socket_callback_result_e>(s.code()), s.reason().c_str());
        });
    };
    auto websocket_free_fn = [](realm_userdata_t userdata, realm_sync_socket_websocket_t sync_websocket) {
        auto test_data = static_cast<TestData*>(userdata);
        LOCKED_REQUIRE(test_data);
        LOCKED_REQUIRE(test_data->socket_provider);
        realm_release(sync_websocket);
    };

    // Test drive.
    TestData test_data{&default_socket_provider};
    auto socket_provider = realm_sync_socket_new(static_cast<realm_userdata_t>(&test_data), userdata_free_fn, post_fn,
                                                 create_timer_fn, cancel_timer_fn, free_timer_fn,
                                                 websocket_connect_fn, websocket_async_write_fn, websocket_free_fn);
    {
        FLXSyncTestHarness harness("c_api_websocket_provider", FLXSyncTestHarness::default_server_schema(),
                                   instance_of<SynchronousTestTransport>, *socket_provider);

        SyncTestFile test_config(harness.app()->current_user(), harness.schema(),
                                 realm::SyncConfig::FLXSyncEnabled{});
        auto realm = Realm::get_shared_realm(test_config);
        bool wait_success = wait_for_download(*realm);
        LOCKED_REQUIRE(!wait_success);
    }
    realm_release(socket_provider);
    default_socket_provider.stop(true);
    LOCKED_REQUIRE(test_data.free_count == 1);
}
#endif // REALM_ENABLE_AUTH_TESTS

realm / realm-core / thomas.goyne_275

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