arrow_array_schema_utils.hpp

Go to the documentation of this file.

// Copyright 2024 Man Group Operations Limited
//
// 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.
 
#pragma once
 
#include <algorithm>
#include <optional>
#include <ranges>
#include <tuple>
#include <type_traits>
#include <vector>
 
#include "sparrow/utils/memory.hpp"
#include "sparrow/utils/mp_utils.hpp"
 
namespace sparrow
{
    template <class T>
    [[nodiscard]] constexpr int64_t ssize(const T& value);

    template <typename T, typename U>
    [[nodiscard]] constexpr T* get_raw_ptr(U& var);

    template <class T, std::ranges::input_range Range, class Allocator = std::allocator<T*>>
        requires(!std::ranges::view<Range>)
    [[nodiscard]] constexpr std::vector<T*, Allocator> to_raw_ptr_vec(Range& range);

    template <class T, class Optional, class Allocator = std::allocator<T*>>
        requires(mpl::is_type_instance_of_v<Optional, std::optional>)
    [[nodiscard]] constexpr std::vector<T*, Allocator> to_raw_ptr_vec(Optional& optional);

    template <class T, class Tuple, class Allocator = std::allocator<T*>>
        requires mpl::is_type_instance_of_v<Tuple, std::tuple>
    [[nodiscard]] constexpr std::vector<T*, Allocator> to_raw_ptr_vec(Tuple& tuple);

    template <class T>
        requires std::same_as<T, std::nullopt_t>
                 || (mpl::is_type_instance_of_v<T, std::optional>
                     && mpl::testable<std::ranges::range_value_t<typename T::value_type>>)
                 || (std::ranges::range<T> && mpl::testable<std::ranges::range_value_t<T>>)
    [[nodiscard]] constexpr bool all_element_are_true(const T& elements);
 
    /******************
     * Implementation *
     ******************/
 
    template <class T>
    constexpr int64_t ssize(const T& value)
    {
        if constexpr (std::ranges::sized_range<T>)
        {
            return static_cast<int64_t>(std::ranges::size(value));
        }
        else if constexpr (mpl::is_type_instance_of_v<T, std::tuple>)
        {
            return std::tuple_size_v<T>;
        }
        else if constexpr (mpl::is_type_instance_of_v<T, std::optional>)
        {
            if (value.has_value())
            {
                return ssize(*value);
            }
            else
            {
                return 0;
            }
        }
        else
        {
            return 0;
        }
    }
 
    template <typename T, typename U>
    constexpr T* get_raw_ptr(U& var)
    {
        if constexpr (std::is_pointer_v<U>)
        {
            return var;
        }
        else if constexpr (requires { typename U::element_type; })
        {
            if constexpr (mpl::smart_ptr<U> || std::is_base_of_v<std::shared_ptr<typename U::element_type>, U>
                          || mpl::is_type_instance_of_v<U, value_ptr>)
            {
                if constexpr (std::ranges::contiguous_range<typename U::element_type>)
                {
                    return std::ranges::data(*var.get());
                }
                else if constexpr (std::same_as<typename U::element_type, T> || std::same_as<T, void>)
                {
                    return var.get();
                }
            }
        }
        else if constexpr (std::ranges::contiguous_range<U>)
        {
            return std::ranges::data(var);
        }
        else if constexpr (std::same_as<T, U> || std::same_as<T, void>)
        {
            return &var;
        }
        else
        {
            static_assert(mpl::dependent_false<T, U>::value, "get_raw_ptr: unsupported type.");
            mpl::unreachable();
        }
    }
 
    template <class T, std::ranges::input_range Range, class Allocator>
        requires(!std::ranges::view<Range>)
    constexpr std::vector<T*, Allocator> to_raw_ptr_vec(Range& range)
    {
        std::vector<T*, Allocator> raw_ptr_vec;
        raw_ptr_vec.reserve(range.size());
        std::ranges::transform(
            range,
            std::back_inserter(raw_ptr_vec),
            [](auto& elem) -> T*
            {
                return get_raw_ptr<T>(elem);
            }
        );
        return raw_ptr_vec;
    }
 
    template <class T, class Optional, class Allocator>
        requires(mpl::is_type_instance_of_v<Optional, std::optional>)
    constexpr std::vector<T*, Allocator> to_raw_ptr_vec(Optional& optional)
    {
        if (!optional.has_value())
        {
            return {};
        }
        return to_raw_ptr_vec<T>(*optional);
    }
 
    template <class T, class Tuple, class Allocator>
        requires mpl::is_type_instance_of_v<Tuple, std::tuple>
    constexpr std::vector<T*, Allocator> to_raw_ptr_vec(Tuple& tuple)
    {
        std::vector<T*, Allocator> raw_ptr_vec;
        raw_ptr_vec.reserve(std::tuple_size_v<Tuple>);
        std::apply(
            [&raw_ptr_vec](auto&&... args)
            {
                (raw_ptr_vec.push_back(get_raw_ptr<T>(args)), ...);
            },
            tuple
        );
        return raw_ptr_vec;
    }
 
    template <class T>
        requires std::same_as<T, std::nullopt_t>
                 || (mpl::is_type_instance_of_v<T, std::optional>
                     && mpl::testable<std::ranges::range_value_t<typename T::value_type>>)
                 || (std::ranges::range<T> && mpl::testable<std::ranges::range_value_t<T>>)
    constexpr bool all_element_are_true(const T& elements)
    {
        if constexpr (!std::same_as<T, std::nullopt_t>)
        {
            if constexpr (mpl::is_type_instance_of_v<T, std::optional>)
            {
                if (elements.has_value())
                {
                    return std::ranges::all_of(
                        *elements,
                        [](const auto& child)
                        {
                            return bool(child);
                        }
                    );
                }
                else
                {
                    return true;
                }
            }
            else
            {
                return std::ranges::all_of(
                    elements,
                    [](const auto& element)
                    {
                        return bool(element);
                    }
                );
            }
        }
        else
        {
            return true;
        }
    }
 
}