nicola.cabiddu_1040

Committed 26 Sep 2023 05:08PM UTC coverage: 91.056% (-1.9%) from 92.915%

Build # nicola.cabiddu_1040

Build Type

Pull #6766

Evergreen

Committed by

nicola-cab

Commit Message

several fixes and final client reset algo for collection in mixed

Pull Request Pull Request #6766: Client Reset for collections in mixed / nested collections

Run Details

97128 of 178458 branches covered (0.0%)

1524 of 1603 new or added lines in 5 files covered. (95.07%)

4511 existing lines in 109 files now uncovered.

236619 of 259862 relevant lines covered (91.06%)

7169640.31 hits per line

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

88.48

/src/realm/object_converter.cpp

/*************************************************************************
 *
 * Copyright 2022 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 <realm/object_converter.hpp>

#include <realm/dictionary.hpp>
#include <realm/list.hpp>
#include <realm/set.hpp>

#include <realm/util/flat_map.hpp>
#include <iostream>
namespace realm::converters {

// Takes two lists, src and dst, and makes dst equal src. src is unchanged.
void InterRealmValueConverter::copy_list(const LstBase& src, LstBase& dst, bool* update_out) const
{
    // The two arrays are compared by finding the longest common prefix and
    // suffix.  The middle section differs between them and is made equal by
    // updating the middle section of dst.
    //
    // Example:
    // src = abcdefghi
    // dst = abcxyhi
    // The common prefix is abc. The common suffix is hi. xy is replaced by defg.

    bool updated = false;
    size_t len_src = src.size();
    size_t len_dst = dst.size();
    size_t len_min = std::min(len_src, len_dst);

    size_t ndx = 0;
    size_t suffix_len = 0;

    while (ndx < len_min && cmp_src_to_dst(src.get_any(ndx), dst.get_any(ndx), nullptr, update_out) == 0) {
        ndx++;
    }

    size_t suffix_len_max = len_min - ndx;

    while (suffix_len < suffix_len_max &&
           cmp_src_to_dst(src.get_any(len_src - 1 - suffix_len), dst.get_any(len_dst - 1 - suffix_len), nullptr,
                          update_out) == 0) {
        suffix_len++;
    }

    len_min -= (ndx + suffix_len);

    for (size_t i = 0; i < len_min; i++) {
        InterRealmValueConverter::ConversionResult converted_src;
        if (cmp_src_to_dst(src.get_any(ndx), dst.get_any(ndx), &converted_src, update_out)) {
            if (converted_src.requires_new_embedded_object) {
                auto lnklist = dynamic_cast<LnkLst*>(&dst);
                REALM_ASSERT(lnklist); // this is the only type of list that supports embedded objects
                Obj embedded = lnklist->create_and_set_linked_object(ndx);
                track_new_embedded(converted_src.src_embedded_to_check, embedded);
            }
            else {
                dst.set_any(ndx, converted_src.converted_value);
            }
            updated = true;
        }
        ndx++;
    }

    // New elements must be inserted in dst.
    while (len_dst < len_src) {
        InterRealmValueConverter::ConversionResult converted_src;
        cmp_src_to_dst(src.get_any(ndx), Mixed{}, &converted_src, update_out);
        if (converted_src.requires_new_embedded_object) {
            auto lnklist = dynamic_cast<LnkLst*>(&dst);
            REALM_ASSERT(lnklist); // this is the only type of list that supports embedded objects
            Obj embedded = lnklist->create_and_insert_linked_object(ndx);
            track_new_embedded(converted_src.src_embedded_to_check, embedded);
        }
        else {
            dst.insert_any(ndx, converted_src.converted_value);
        }
        len_dst++;
        ndx++;
        updated = true;
    }
    // Excess elements must be removed from ll_dst.
    if (len_dst > len_src) {
        dst.remove(len_src - suffix_len, len_dst - suffix_len);
        updated = true;
    }

    REALM_ASSERT(dst.size() == len_src);
    if (updated && update_out) {
        *update_out = updated;
    }
}

void InterRealmValueConverter::copy_set(const SetBase& src, SetBase& dst, bool* update_out) const
{
    std::vector<size_t> sorted_src, sorted_dst, to_insert, to_delete;
    constexpr bool ascending = true;
    // the implementation could be storing elements in sorted order, but
    // we don't assume that here.
    src.sort(sorted_src, ascending);
    dst.sort(sorted_dst, ascending);

    size_t dst_ndx = 0;
    size_t src_ndx = 0;
    while (src_ndx < sorted_src.size()) {
        if (dst_ndx == sorted_dst.size()) {
            // if we have reached the end of the dst items, all remaining
            // src items should be added
            while (src_ndx < sorted_src.size()) {
                to_insert.push_back(sorted_src[src_ndx++]);
            }
            break;
        }
        size_t ndx_in_src = sorted_src[src_ndx];
        Mixed src_val = src.get_any(ndx_in_src);
        while (dst_ndx < sorted_dst.size()) {
            size_t ndx_in_dst = sorted_dst[dst_ndx];

            int cmp = cmp_src_to_dst(src_val, dst.get_any(ndx_in_dst), nullptr, update_out);
            if (cmp == 0) {
                // equal: advance both src and dst
                ++dst_ndx;
                ++src_ndx;
                break;
            }
            else if (cmp < 0) {
                // src < dst: insert src, advance src only
                to_insert.push_back(ndx_in_src);
                ++src_ndx;
                break;
            }
            else {
                // src > dst: delete dst, advance only dst
                to_delete.push_back(ndx_in_dst);
                ++dst_ndx;
                continue;
            }
        }
    }
    while (dst_ndx < sorted_dst.size()) {
        to_delete.push_back(sorted_dst[dst_ndx++]);
    }

    std::sort(to_delete.begin(), to_delete.end());
    for (auto it = to_delete.rbegin(); it != to_delete.rend(); ++it) {
        dst.erase_any(dst.get_any(*it));
    }
    for (auto ndx : to_insert) {
        InterRealmValueConverter::ConversionResult converted_src;
        cmp_src_to_dst(src.get_any(ndx), Mixed{}, &converted_src, update_out);
        // we do not support a set of embedded objects
        REALM_ASSERT(!converted_src.requires_new_embedded_object);
        dst.insert_any(converted_src.converted_value);
    }

    if (update_out && (to_delete.size() || to_insert.size())) {
        *update_out = true;
    }
}

void InterRealmValueConverter::copy_dictionary(const Dictionary& src, Dictionary& dst, bool* update_out) const
{
    std::vector<size_t> to_insert, to_delete;

    size_t dst_ndx = 0;
    size_t src_ndx = 0;
    while (src_ndx < src.size()) {
        if (dst_ndx == dst.size()) {
            // if we have reached the end of the dst items, all remaining
            // src items should be added
            while (src_ndx < src.size()) {
                to_insert.push_back(src_ndx++);
            }
            break;
        }

        auto src_val = src.get_pair(src_ndx);
        while (dst_ndx < dst.size()) {
            auto dst_val = dst.get_pair(dst_ndx);
            int cmp = src_val.first.compare(dst_val.first);
            if (cmp == 0) {
                // Check if the values differ
                if (cmp_src_to_dst(src_val.second, dst_val.second, nullptr, update_out)) {
                    // values are different - modify destination, advance both
                    to_insert.push_back(src_ndx);
                }
                // keys and values equal: advance both src and dst
                ++dst_ndx;
                ++src_ndx;
                break;
            }
            else if (cmp < 0) {
                // src < dst: insert src, advance src only
                to_insert.push_back(src_ndx++);
                break;
            }
            else {
                // src > dst: delete dst, advance only dst
                to_delete.push_back(dst_ndx++);
                continue;
            }
        }
    }
    // at this point, we've gone through all src items but still have dst items
    // oustanding; these should all be deleted because they are not in src
    while (dst_ndx < dst.size()) {
        to_delete.push_back(dst_ndx++);
    }

    for (auto it = to_delete.rbegin(); it != to_delete.rend(); ++it) {
        dst.erase(dst.begin() + *it);
    }
    for (auto ndx : to_insert) {
        auto pair = src.get_pair(ndx);
        InterRealmValueConverter::ConversionResult converted_val;
        cmp_src_to_dst(pair.second, Mixed{}, &converted_val, update_out);
        if (converted_val.requires_new_embedded_object) {
            Obj new_embedded = dst.create_and_insert_linked_object(pair.first);
            track_new_embedded(converted_val.src_embedded_to_check, new_embedded);
        }
        else {
            dst.insert(pair.first, converted_val.converted_value);
        }
    }
    if (update_out && (to_delete.size() || to_insert.size())) {
        *update_out = true;
    }
}

void InterRealmValueConverter::copy_value(const Obj& src_obj, Obj& dst_obj, bool* update_out)
{
    if (m_src_col.is_list()) {
        LstBasePtr src = src_obj.get_listbase_ptr(m_src_col);
        LstBasePtr dst = dst_obj.get_listbase_ptr(m_dst_col);
        copy_list(*src, *dst, update_out);
    }
    else if (m_src_col.is_dictionary()) {
        Dictionary src = src_obj.get_dictionary(m_src_col);
        Dictionary dst = dst_obj.get_dictionary(m_dst_col);
        copy_dictionary(src, dst, update_out);
    }
    else if (m_src_col.is_set()) {
        SetBasePtr src = src_obj.get_setbase_ptr(m_src_col);
        SetBasePtr dst = dst_obj.get_setbase_ptr(m_dst_col);
        copy_set(*src, *dst, update_out);
    }
    else {
        REALM_ASSERT(!m_src_col.is_collection());
        // nested collections
        auto src_mixed = src_obj.get_any(m_src_col);
        if (src_mixed.is_type(type_List)) {
            dst_obj.set_collection(m_dst_col, CollectionType::List);
            Lst<Mixed> src_list{src_obj, m_src_col};
            Lst<Mixed> dst_list{dst_obj, m_dst_col};
            handle_list_in_mixed(src_list, dst_list);
        }
        else if (src_mixed.is_type(type_Set)) {
            dst_obj.set_collection(m_dst_col, CollectionType::Set);
            realm::Set<Mixed> src_set{src_obj, m_src_col};
            realm::Set<Mixed> dst_set{dst_obj, m_dst_col};
            // sets cannot be nested, so we just need to copy the values
            copy_set(src_set, dst_set, nullptr);
        }
        else if (src_mixed.is_type(type_Dictionary)) {
            dst_obj.set_collection(m_dst_col, CollectionType::Dictionary);
            Dictionary src_dict{src_obj, m_src_col};
            Dictionary dst_dict{dst_obj, m_dst_col};
            handle_dictionary_in_mixed(src_dict, dst_dict);
        }
        else {
            InterRealmValueConverter::ConversionResult converted_src;
            auto dst_mixed = dst_obj.get_any(m_dst_col);
            if (cmp_src_to_dst(src_mixed, dst_mixed, &converted_src, update_out)) {
                if (converted_src.requires_new_embedded_object) {
                    Obj new_embedded = dst_obj.create_and_set_linked_object(m_dst_col);
                    track_new_embedded(converted_src.src_embedded_to_check, new_embedded);
                }
                else {
                    dst_obj.set_any(m_dst_col, converted_src.converted_value);
                }
            }
        }
    }
}

//
// Handle collections in mixed. A collection can have N nested levels (expect for Sets). And these levels can be
// nested in arbitrary way (eg a List within a Dictionary or viceversa). In order to try to merge server changes with
// client changes, the algorithm needs to go throw each single element in the collection, check its type and perform
// the most appropriate action in order to miminize the number of notificiations triggered.
//
void InterRealmValueConverter::handle_list_in_mixed(const Lst<Mixed>& src_list, Lst<Mixed>& dst_list) const
{
    int sz = (int)std::min(src_list.size(), dst_list.size());
    int left = 0;
    int right = (int)sz - 1;

    // find fist not matching element from beginning
    while (left < sz) {
        auto src_any = src_list.get_any(left);
        auto dst_any = dst_list.get_any(left);
        if (src_any != dst_any)
            break;
        if (is_collection(src_any) && !check_matching_list(src_list, dst_list, left, to_collection_type(src_any)))
            break;
        left += 1;
    }

    // find first not matching element from end
    while (right >= 0) {
        auto src_any = src_list.get_any(right);
        auto dst_any = dst_list.get_any(right);
        if (src_any != dst_any)
            break;
        if (is_collection(src_any) && !check_matching_list(src_list, dst_list, right, to_collection_type(src_any)))
            break;
        right -= 1;
    }

    // Replace all different elements in [left, right]
    while (left <= right) {
        auto src_any = src_list.get_any(left);
        auto dst_any = dst_list.get_any(left);

        if (is_collection(src_any)) {
            auto coll_type = to_collection_type(src_any);

            if (!dst_any.is_type(src_any.get_type())) {
                // Mixed vs Collection
                dst_list.set_collection(left, coll_type);
                copy_list_in_mixed(src_list, dst_list, left, coll_type);
            }
            else if (!check_matching_list(src_list, dst_list, left, coll_type)) {
                // Collection vs Collection
                dst_list.set_any(left, src_any);
                copy_list_in_mixed(src_list, dst_list, left, coll_type);
            }
        }
        else if (dst_any != src_any) {
            // Mixed vs Mixed
            dst_list.set_any(left, src_any);
        }
        left += 1;
    }

    // remove dst elements not present in src
    if (dst_list.size() > src_list.size()) {
        auto dst_size = dst_list.size();
        auto src_size = src_list.size();
        while (dst_size > src_size)
            dst_list.remove(--dst_size);
    }

    // append remainig src into dst
    for (size_t i = dst_list.size(); i < src_list.size(); ++i) {
        auto src_any = src_list.get(i);
        if (is_collection(src_any)) {
            auto coll_type = to_collection_type(src_any);
            dst_list.insert_collection(i, coll_type);
            copy_list_in_mixed(src_list, dst_list, i, coll_type);
        }
        else {
            dst_list.insert_any(i, src_any);
        }
    }
}

void InterRealmValueConverter::handle_dictionary_in_mixed(Dictionary& src_dictionary,
                                                          Dictionary& dst_dictionary) const
{
    int sz = (int)std::min(src_dictionary.size(), dst_dictionary.size());
    int left = 0;
    int right = (int)sz - 1;

    // find fist not matching element from beginning
    while (left < sz) {
        const auto [key_src, src_any] = src_dictionary.get_pair(left);
        const auto [key_dst, dst_any] = dst_dictionary.get_pair(left);
        if (src_any != dst_any || key_src != key_dst)
            break;
        if (is_collection(src_any) && !check_matching_dictionary(src_dictionary, dst_dictionary, key_src.get_string(),
                                                                 to_collection_type(src_any)))
            break;
        left += 1;
    }

    // find first not matching element from end
    while (right >= 0) {
        const auto [key_src, src_any] = src_dictionary.get_pair(right);
        const auto [key_dst, dst_any] = dst_dictionary.get_pair(right);
        if (src_any != dst_any || key_src != key_dst)
            break;
        if (is_collection(src_any) && !check_matching_dictionary(src_dictionary, dst_dictionary, key_src.get_string(),
                                                                 to_collection_type(src_any)))
            break;
        right -= 1;
    }

    // Replace all different elements in [left, right]
    while (left <= right) {
        const auto [key_src, src_any] = src_dictionary.get_pair(left);
        const auto [key_dst, dst_any] = dst_dictionary.get_pair(left);

        // handle possible key mismatches
        if (key_src != key_dst) {
            dst_dictionary.erase(key_dst);
            dst_dictionary.insert(key_src, src_any);
        }

        if (is_collection(src_any)) {
            auto coll_type = to_collection_type(src_any);
            const auto key = key_src.get_string();

            if (!dst_any.is_type(src_any.get_type())) {
                // Mixed vs Collection
                const auto key = key_src.get_string();
                dst_dictionary.set_collection(key, coll_type);
                copy_dictionary_in_mixed(src_dictionary, dst_dictionary, key, coll_type);
            }
            else if (!check_matching_dictionary(src_dictionary, dst_dictionary, key, coll_type)) {
                // Collection vs Collection
                dst_dictionary.insert(key_src, src_any);
                copy_dictionary_in_mixed(src_dictionary, dst_dictionary, key, coll_type);
            }
        }
        else if (dst_any != src_any) {
            // Mixed vs Mixed
            dst_dictionary.insert(key_src, src_any);
        }
        left += 1;
    }

    // remove dst elements not present in src
    if (dst_dictionary.size() > src_dictionary.size()) {
        auto dst_size = dst_dictionary.size();
        auto src_size = src_dictionary.size();
        while (dst_size > src_size) {
            const auto [dst_key, dst_any] = dst_dictionary.get_pair(--dst_size);
            dst_dictionary.erase(dst_key);
        }
    }

    // append remainig src into dst
    for (size_t i = dst_dictionary.size(); i < src_dictionary.size(); ++i) {
        const auto [src_key, src_any] = src_dictionary.get_pair(i);
        if (is_collection(src_any)) {
            const auto coll_type = to_collection_type(src_any);
            const auto key = src_key.get_string();
            dst_dictionary.insert_collection(key, coll_type);
            copy_dictionary_in_mixed(src_dictionary, dst_dictionary, key, coll_type);
        }
        else {
            dst_dictionary.insert(src_key, src_any);
        }
    }
}

bool InterRealmValueConverter::check_matching_list(const Lst<Mixed>& src_list, Lst<Mixed>& dst_list, size_t ndx,
                                                   CollectionType type) const
{

    if (type == CollectionType::List) {
        auto nested_src_list = src_list.get_list(ndx);
        auto nested_dst_list = dst_list.get_list(ndx);
        auto size_src = nested_src_list->size();
        auto size_dst = nested_dst_list->size();
        if (size_src != size_dst)
            return false;
        for (size_t i = 0; i < size_src; ++i) {
            auto src_mixed = nested_src_list->get_any(i);
            auto dst_mixed = nested_dst_list->get_any(i);
            if (src_mixed != dst_mixed)
                return false;
        }
    }
    else if (type == CollectionType::Dictionary) {
        auto nested_src_dictionary = src_list.get_dictionary(ndx);
        auto nested_dst_dictionary = dst_list.get_dictionary(ndx);
        auto size_src = nested_src_dictionary->size();
        auto size_dst = nested_dst_dictionary->size();
        if (size_src != size_dst)
            return false;
        for (size_t i = 0; i < size_src; ++i) {
            auto [src_key, src_mixed] = nested_src_dictionary->get_pair(i);
            auto [dst_key, dst_mixed] = nested_dst_dictionary->get_pair(i);
            if (src_key != dst_key)
                return false;
            if (src_mixed != dst_mixed)
                return false;
        }
    }
    return true;
}

bool InterRealmValueConverter::check_matching_dictionary(const Dictionary& src_dictionary,
                                                         const Dictionary& dst_dictionary, StringData key,
                                                         CollectionType type) const
{
    if (type == CollectionType::List) {
        auto n_src_list = src_dictionary.get_list(key);
        auto n_dst_list = dst_dictionary.get_list(key);
        auto size_src = n_src_list->size();
        auto size_dst = n_dst_list->size();
        if (size_src != size_dst)
            return false;
        for (size_t i = 0; i < size_src; ++i) {
            auto src_mixed = n_src_list->get_any(i);
            auto dst_mixed = n_dst_list->get_any(i);
            if (src_mixed != dst_mixed)
                return false;
        }
    }
    else if (type == CollectionType::Dictionary) {
        auto n_src_dictionary = src_dictionary.get_dictionary(key);
        auto n_dst_dictionary = dst_dictionary.get_dictionary(key);
        auto size_src = n_src_dictionary->size();
        auto size_dst = n_dst_dictionary->size();
        if (size_src != size_dst)
            return false;
        for (size_t i = 0; i < size_src; ++i) {
            auto [src_key, src_mixed] = n_src_dictionary->get_pair(i);
            auto [dst_key, dst_mixed] = n_dst_dictionary->get_pair(i);
            if (src_key != dst_key)
                return false;
            if (src_mixed != dst_mixed)
                return false;
        }
    }
    return true;
}

void InterRealmValueConverter::copy_list_in_mixed(const Lst<Mixed>& src_list, Lst<Mixed>& dst_list, size_t ndx,
                                                  CollectionType type) const
{
    if (type == CollectionType::List) {
        auto n_src_list = src_list.get_list(ndx);
        auto n_dst_list = dst_list.get_list(ndx);
        handle_list_in_mixed(*n_src_list, *n_dst_list);
    }
    else if (type == CollectionType::Set) {
        auto n_src_set = src_list.get_set(ndx);
        auto n_dst_set = dst_list.get_set(ndx);
        copy_set(*n_src_set, *n_dst_set, nullptr);
    }
    else if (type == CollectionType::Dictionary) {
        auto n_src_dict = src_list.get_dictionary(ndx);
        auto n_dst_dict = dst_list.get_dictionary(ndx);
        handle_dictionary_in_mixed(*n_src_dict, *n_dst_dict);
    }
}

void InterRealmValueConverter::copy_dictionary_in_mixed(const Dictionary& src_dictionary, Dictionary& dst_dictionary,
                                                        StringData key, CollectionType type) const
{
    if (type == CollectionType::List) {
        auto n_src_list = src_dictionary.get_list(key);
        auto n_dst_list = dst_dictionary.get_list(key);
        handle_list_in_mixed(*n_src_list, *n_dst_list);
    }
    else if (type == CollectionType::Set) {
        auto n_src_set = src_dictionary.get_set(key);
        auto n_dst_set = dst_dictionary.get_set(key);
        copy_set(*n_src_set, *n_dst_set, nullptr);
    }
    else if (type == CollectionType::Dictionary) {
        auto n_src_dictionary = src_dictionary.get_dictionary(key);
        auto n_dst_dictionary = dst_dictionary.get_dictionary(key);
        handle_dictionary_in_mixed(*n_src_dictionary, *n_dst_dictionary);
    }
}

bool InterRealmValueConverter::is_collection(Mixed mixed) const
{
    return mixed.is_type(type_List, type_Set, type_Dictionary);
}

CollectionType InterRealmValueConverter::to_collection_type(Mixed mixed) const
{
    const auto mixed_type = mixed.get_type();
    if (mixed_type == type_List)
        return CollectionType::List;
    if (mixed_type == type_Set)
        return CollectionType::Set;
    if (mixed_type == type_Dictionary)
        return CollectionType::Dictionary;
    REALM_UNREACHABLE();
}

// If an embedded object is encountered, add it to a list of embedded objects to process.
// This relies on the property that embedded objects only have one incoming link
// otherwise there could be an infinite loop while discovering embedded objects.
void EmbeddedObjectConverter::track(const Obj& e_src, const Obj& e_dst)
{
    embedded_pending.push_back({e_src, e_dst});
}

void EmbeddedObjectConverter::process_pending()
{
    util::FlatMap<TableKey, InterRealmObjectConverter> converters;

    while (!embedded_pending.empty()) {
        EmbeddedToCheck pending = embedded_pending.back();
        embedded_pending.pop_back();

        TableRef dst_table = pending.embedded_in_dst.get_table();
        TableKey dst_table_key = dst_table->get_key();
        auto it = converters.find(dst_table_key);
        if (it == converters.end()) {
            TableRef src_table = pending.embedded_in_src.get_table();
            it = converters.insert({dst_table_key, InterRealmObjectConverter{src_table, dst_table, this}}).first;
        }
        InterRealmObjectConverter& converter = it->second;
        converter.copy(pending.embedded_in_src, pending.embedded_in_dst, nullptr);
    }
}

InterRealmValueConverter::InterRealmValueConverter(ConstTableRef src_table, ColKey src_col, ConstTableRef dst_table,
                                                   ColKey dst_col, EmbeddedObjectConverter* ec)
    : m_src_table(src_table)
    , m_dst_table(dst_table)
    , m_src_col(src_col)
    , m_dst_col(dst_col)
    , m_embedded_converter(ec)
    , m_is_embedded_link(false)
    , m_primitive_types_only(!(src_col.get_type() == col_type_TypedLink || src_col.get_type() == col_type_Link ||
                               src_col.get_type() == col_type_LinkList || src_col.get_type() == col_type_Mixed))
{
    if (!m_primitive_types_only) {
        REALM_ASSERT(src_table);
        m_opposite_of_src = src_table->get_opposite_table(src_col);
        m_opposite_of_dst = dst_table->get_opposite_table(dst_col);
        REALM_ASSERT(bool(m_opposite_of_src) == bool(m_opposite_of_dst));
        if (m_opposite_of_src) {
            m_is_embedded_link = m_opposite_of_src->is_embedded();
        }
    }
}

void InterRealmValueConverter::track_new_embedded(const Obj& src, const Obj& dst) const
{
    m_embedded_converter->track(src, dst);
}

// convert `src` to the destination Realm and compare that value with `dst`
// If `converted_src_out` is provided, it will be set to the converted src value
int InterRealmValueConverter::cmp_src_to_dst(Mixed src, Mixed dst, ConversionResult* converted_src_out,
                                             bool* did_update_out) const
{
    int cmp = 0;
    Mixed converted_src;
    if (m_primitive_types_only || !src.is_type(type_Link, type_TypedLink)) {
        converted_src = src;
        cmp = src.compare(dst);
    }
    else if (m_opposite_of_src) {
        ObjKey src_link_key = src.get<ObjKey>();
        if (m_is_embedded_link) {
            Obj src_embedded = m_opposite_of_src->get_object(src_link_key);
            REALM_ASSERT_DEBUG(src_embedded.is_valid());
            if (dst.is_type(type_Link, type_TypedLink)) {
                cmp = 0; // no need to set this link, there is already an embedded object here
                Obj dst_embedded = m_opposite_of_dst->get_object(dst.get<ObjKey>());
                REALM_ASSERT_DEBUG(dst_embedded.is_valid());
                converted_src = dst_embedded.get_key();
                track_new_embedded(src_embedded, dst_embedded);
            }
            else {
                cmp = src.compare(dst);
                if (converted_src_out) {
                    converted_src_out->requires_new_embedded_object = true;
                    converted_src_out->src_embedded_to_check = src_embedded;
                }
            }
        }
        else {
            Obj dst_link;
            if (m_opposite_of_dst == m_opposite_of_src) {
                // if this is the same Realm, we can use the ObjKey
                dst_link = m_opposite_of_dst->get_object(src_link_key);
            }
            else {
                // in different Realms we create a new object
                if (m_opposite_of_src->get_primary_key_column()) {
                    Mixed src_link_pk = m_opposite_of_src->get_primary_key(src_link_key);
                    dst_link = m_opposite_of_dst->create_object_with_primary_key(src_link_pk, did_update_out);
                }
                else {
                    dst_link = m_opposite_of_dst->create_object();
                }
            }
            converted_src = dst_link.get_key();
            if (dst.is_type(type_TypedLink)) {
                cmp = converted_src.compare(dst.get<ObjKey>());
            }
            else {
                cmp = converted_src.compare(dst);
            }
        }
    }
    else {
        ObjLink src_link = src.get<ObjLink>();
        if (src_link.is_unresolved()) {
            converted_src = Mixed{}; // no need to transfer over unresolved links
            cmp = converted_src.compare(dst);
        }
        else {
            TableRef src_link_table = m_src_table->get_parent_group()->get_table(src_link.get_table_key());
            REALM_ASSERT_EX(src_link_table, src_link.get_table_key());
            TableRef dst_link_table = m_dst_table->get_parent_group()->get_table(src_link_table->get_name());
            REALM_ASSERT_EX(dst_link_table, src_link_table->get_name());
            // embedded tables should always be covered by the m_opposite_of_src case above.
            REALM_ASSERT_EX(!src_link_table->is_embedded(), src_link_table->get_name());
            // regular table, convert by pk
            if (src_link_table->get_primary_key_column()) {
                Mixed src_pk = src_link_table->get_primary_key(src_link.get_obj_key());
                Obj dst_link = dst_link_table->create_object_with_primary_key(src_pk, did_update_out);
                converted_src = ObjLink{dst_link_table->get_key(), dst_link.get_key()};
            }
            else if (src_link_table == dst_link_table) {
                // no pk, but this is the same Realm, so convert by ObjKey
                Obj dst_link = dst_link_table->get_object(src_link.get_obj_key());
                converted_src = ObjLink{dst_link_table->get_key(), dst_link.get_key()};
            }
            else {
                // no pk, and different Realm, create an object
                Obj dst_link = dst_link_table->create_object();
                converted_src = ObjLink{dst_link_table->get_key(), dst_link.get_key()};
            }
            cmp = converted_src.compare(dst);
        }
    }
    if (converted_src_out) {
        converted_src_out->converted_value = converted_src;
    }
    if (did_update_out && cmp) {
        *did_update_out = true;
    }
    return cmp;
}

InterRealmObjectConverter::InterRealmObjectConverter(ConstTableRef table_src, TableRef table_dst,
                                                     EmbeddedObjectConverter* embedded_tracker)
    : m_embedded_tracker(embedded_tracker)
{
    m_columns_cache.reserve(table_src->get_column_count());
    ColKey pk_col = table_src->get_primary_key_column();
    for (ColKey col_key_src : table_src->get_column_keys()) {
        if (col_key_src == pk_col)
            continue;
        StringData col_name = table_src->get_column_name(col_key_src);
        ColKey col_key_dst = table_dst->get_column_key(col_name);
        REALM_ASSERT(col_key_dst);
        m_columns_cache.emplace_back(table_src, col_key_src, table_dst, col_key_dst, m_embedded_tracker);
    }
}

void InterRealmObjectConverter::copy(const Obj& src, Obj& dst, bool* update_out)
{
    for (auto& column : m_columns_cache) {
        column.copy_value(src, dst, update_out);
    }
}

//

} // namespace realm::converters

realm / realm-core / nicola.cabiddu_1040

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