BLOB.inl

/*
 * Copyright(c) Sophist Solutions, Inc. 1990-2025.  All rights reserved
 */
#include "Stroika/Foundation/Containers/Common.h"
#include "Stroika/Foundation/Debug/Assertions.h"
#include "Stroika/Foundation/Memory/BlockAllocated.h"
#include "Stroika/Foundation/Memory/Common.h"
#include "Stroika/Foundation/Memory/InlineBuffer.h"
#include "Stroika/Foundation/Traversal/Iterator.h"
 
namespace Stroika::Foundation::Memory {
 
    template <>
    Characters::String Stroika::Foundation::Memory::BLOB::AsBase64 () const;
    template <>
    Characters::String Stroika::Foundation::Memory::BLOB::AsBase64 (const Cryptography::Encoding::Algorithm::Base64::Options& o) const;
 
    struct BLOB::BasicRep_ final : public _IRep, public Memory::UseBlockAllocationIfAppropriate<BasicRep_> {
        //  really not sure what size to use???
        //  May not be any universal, good answer...
        //  Remember - users can subclass BLOB, and provider their own
        //  'rep' type tuned to their application.
        InlineBuffer<byte, 64> fData;
 
        BasicRep_ (span<const byte> s)
            : fData{Memory::eUninitialized, s.size ()}
        {
            CopyBytes (s, span{fData});
        }
 
        BasicRep_ (const initializer_list<pair<const byte*, const byte*>>& startEndPairs);
        BasicRep_ (const initializer_list<BLOB>& list2Concatenate);
        BasicRep_ (const BasicRep_&)            = delete;
        BasicRep_& operator= (const BasicRep_&) = delete;
 
        virtual span<const byte> GetBounds () const override;
    };
 
    struct BLOB::ZeroRep_ final : public _IRep, public Memory::UseBlockAllocationIfAppropriate<ZeroRep_> {
        virtual span<const byte> GetBounds () const override;
        ZeroRep_ ()                           = default;
        ZeroRep_ (const ZeroRep_&)            = delete;
        ZeroRep_& operator= (const ZeroRep_&) = delete;
    };
 
    struct BLOB::AdoptRep_ final : public _IRep, public Memory::UseBlockAllocationIfAppropriate<AdoptRep_> {
        const byte* fStart;
        const byte* fEnd;
 
        AdoptRep_ (const AdoptRep_&) = delete;
        AdoptRep_ (const byte* start, const byte* end);
        ~AdoptRep_ ()                                         = default;
        AdoptRep_&               operator= (const AdoptRep_&) = delete;
        virtual span<const byte> GetBounds () const override;
    };
 
    struct BLOB::AdoptAndDeleteRep_ final : public _IRep, public Memory::UseBlockAllocationIfAppropriate<AdoptAndDeleteRep_> {
        const byte* fStart;
        const byte* fEnd;
 
        AdoptAndDeleteRep_ (const AdoptAndDeleteRep_&) = delete;
        AdoptAndDeleteRep_ (const byte* start, const byte* end);
        ~AdoptAndDeleteRep_ ();
        AdoptAndDeleteRep_&      operator= (const AdoptAndDeleteRep_&) = delete;
        virtual span<const byte> GetBounds () const override;
    };
 
    /*
     ********************************************************************************
     ************************************** BLOB ************************************
     ********************************************************************************
     */
    inline BLOB::BLOB ()
        : fRep_{MakeSharedPtr<ZeroRep_> ()}
    {
    }
    template <ranges::range CONTAINER_OF_BYTE>
    inline BLOB::BLOB (const CONTAINER_OF_BYTE& data)
        requires (is_convertible_v<typename CONTAINER_OF_BYTE::value_type, byte> or is_convertible_v<typename CONTAINER_OF_BYTE::value_type, uint8_t>)
        : BLOB{as_bytes (span{data.data (), data.size ()})}
    {
    }
    inline BLOB::BLOB (const initializer_list<byte>& bytes)
        : BLOB{span{bytes}}
    {
    }
    inline BLOB::BLOB (const initializer_list<uint8_t>& bytes)
        : BLOB{as_bytes (span{bytes})}
    {
    }
    inline BLOB::BLOB (span<const byte> s)
        : fRep_{s.empty () ? shared_ptr<_IRep>{MakeSharedPtr<ZeroRep_> ()} : shared_ptr<_IRep>{MakeSharedPtr<BasicRep_> (s)}}
    {
        Ensure (s.size () == size ());
    }
    inline BLOB::BLOB (const byte* start, const byte* end)
        : BLOB{span{start, end}}
    {
        Ensure (static_cast<size_t> (end - start) == size ());
    }
    inline BLOB::BLOB (const uint8_t* start, const uint8_t* end)
        : BLOB{as_bytes (span{start, end})}
    {
        Ensure (static_cast<size_t> (end - start) == size ());
    }
    inline BLOB::BLOB (const initializer_list<pair<const byte*, const byte*>>& startEndPairs)
        : fRep_{MakeSharedPtr<BasicRep_> (startEndPairs)}
    {
    }
    inline BLOB::BLOB (const initializer_list<BLOB>& list2Concatenate)
        : fRep_{MakeSharedPtr<BasicRep_> (list2Concatenate)}
    {
    }
    inline BLOB::BLOB (const shared_ptr<_IRep>& rep)
        : fRep_{rep}
    {
    }
    inline BLOB::BLOB (shared_ptr<_IRep>&& rep)
        : fRep_{move (rep)}
    {
    }
    inline BLOB BLOB::FromHex (const char* b)
    {
        RequireNotNull (b);
        return FromHex (span<const char>{b, ::strlen (b)});
    }
    inline BLOB BLOB::FromHex (const char* s, const char* e)
    {
        return FromHex (span<const char>{s, e});
    }
    inline BLOB BLOB::FromHex (string_view s)
    {
        return FromHex (span<const char>{s});
    }
    inline BLOB BLOB::FromBase64 (const char* b)
    {
        RequireNotNull (b);
        return FromBase64 (span<const char>{b, ::strlen (b)});
    }
    inline BLOB BLOB::FromBase64 (string_view s)
    {
        return FromBase64 (span<const char>{s});
    }
    template <Common::trivially_copyable T>
    inline BLOB BLOB::FromRaw (const T* s, const T* e)
    {
        return BLOB{span{reinterpret_cast<const byte*> (s), reinterpret_cast<const byte*> (e)}};
    }
    template <Common::trivially_copyable T>
    inline BLOB BLOB::FromRaw (const T* s, size_t sz)
    {
        return BLOB{span{reinterpret_cast<const byte*> (s), sz}};
    }
    template <Common::trivially_copyable T>
    inline BLOB BLOB::FromRaw (const T* s)
        requires (same_as<typename char_traits<T>::char_type, T>)
    {
        RequireNotNull (s);
        return FromRaw (s, s + char_traits<T>::length (s));
    }
    template <Common::trivially_copyable T>
    inline BLOB BLOB::FromRaw (const basic_string<T>& s)
        requires (same_as<typename char_traits<T>::char_type, T>)
    {
        return FromRaw (s.c_str (), s.c_str () + s.length ());
    }
    template <Common::trivially_copyable T>
    inline BLOB BLOB::FromRaw (const T& s)
    {
        return FromRaw (&s, &s + 1);
    }
    template <typename BYTEISH, size_t EXTENT>
    inline BLOB BLOB::Attach (span<BYTEISH, EXTENT> s)
        requires (convertible_to<BYTEISH, const byte> or convertible_to<BYTEISH, const uint8_t>)
    {
        const byte* b = reinterpret_cast<const byte*> (s.data ());
        return BLOB{MakeSharedPtr<AdoptRep_> (b, b + s.size ())};
    }
    template <typename BYTEISH, size_t EXTENT>
    inline BLOB BLOB::Attach (BYTEISH (&data)[EXTENT])
        requires (convertible_to<BYTEISH, const byte> or convertible_to<BYTEISH, const uint8_t>)
    {
        return Attach (span<const BYTEISH>{data, EXTENT});
    }
    inline BLOB BLOB::AttachAndDelete (const byte* b, size_t arrayLen)
    {
        return BLOB{MakeSharedPtr<AdoptAndDeleteRep_> (b, b + arrayLen)};
    }
    template <>
    Streams::InputStream::Ptr<byte> BLOB::As () const;
    template <typename T>
    inline T BLOB::As () const
#if !qCompilerAndStdLib_template_requires_doesnt_work_with_specialization_Buggy
        // clang-format off
        requires (
            Common::IAnyOf<T,span<const byte>,span<const uint8_t>, pair<const byte*, const byte*>, pair<const uint8_t*, const uint8_t*>, vector<byte> ,vector<uint8_t>, Streams::InputStream::Ptr<byte>,string>
            or is_trivially_copyable_v<T>
        )
    // clang-format on
#endif
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        if constexpr (same_as<T, span<const byte>>) {
            return fRep_->GetBounds ();
        }
        else if constexpr (same_as<T, span<const uint8_t>>) {
            return T{reinterpret_cast<const uint8_t*> (this->data ()), this->size ()};
        }
        else if constexpr (same_as<T, pair<const byte*, const byte*>>) {
            return make_pair (this->data (), this->data () + this->size ());
        }
        else if constexpr (same_as<T, pair<const uint8_t*, const uint8_t*>>) {
            auto s = this->As<span<const uint8_t>> ();
            return make_pair (s.data (), s.data () + s.size ());
        }
        else if constexpr (same_as<T, vector<byte>>) {
            return T{this->begin (), this->end ()};
        }
        else if constexpr (same_as<T, vector<uint8_t>>) {
            auto s = this->As<span<const uint8_t>> ();
            return T{s.begin (), s.end ()};
        }
        else if constexpr (same_as<T, Streams::InputStream::Ptr<byte>>) {
            AssertNotReached (); //template specialized - handled in C++ file
        }
        else if constexpr (same_as<T, string>) {
            span<const byte> tmp = fRep_->GetBounds ();
            return string{reinterpret_cast<const char*> (tmp.data ()), reinterpret_cast<const char*> (tmp.data () + tmp.size ())};
        }
        else if constexpr (is_trivially_copyable_v<T>) {
            Require (size () >= sizeof (T)); // allow object slicing, but not reading garbage data
            return *(reinterpret_cast<const T*> (begin ()));
        }
    }
    inline BLOB::operator Streams::InputStream::Ptr<byte> () const
    {
        return As<Streams::InputStream::Ptr<byte>> ();
    }
    inline byte BLOB::operator[] (const size_t i) const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        span<const byte>                                      tmp = fRep_->GetBounds ();
        Assert (i < tmp.size ());
        return tmp[i];
    }
    inline bool BLOB::empty () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        span<const byte>                                      tmp = fRep_->GetBounds ();
        Assert (tmp.begin () <= tmp.end ());
        return tmp.empty ();
    }
    inline const byte* BLOB::begin () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        return fRep_->GetBounds ().data ();
    }
    inline const byte* BLOB::end () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        auto                                                  b = fRep_->GetBounds ();
        return b.data () + b.size ();
    }
    inline size_t BLOB::GetSize () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        span<const byte>                                      tmp = fRep_->GetBounds ();
        Assert (tmp.begin () <= tmp.end ());
        return tmp.size ();
    }
    inline size_t BLOB::length () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        return GetSize ();
    }
    inline const byte* BLOB::data () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        return begin ();
    }
    inline size_t BLOB::size () const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        return GetSize ();
    }
    inline strong_ordering BLOB::operator<=> (const BLOB& rhs) const
    {
        return TWC_ (*this, rhs);
    }
    inline bool BLOB::operator== (const BLOB& rhs) const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext readLockL{fThisAssertExternallySynchronized_}; // this pattern of double locking might risk a deadlock for real locks, but these locks are fake to assure externally locked
        Debug::AssertExternallySynchronizedMutex::ReadContext readLockR{rhs.fThisAssertExternallySynchronized_};
        if (fRep_ == rhs.fRep_) {
            return true; // cheap optimization for not super uncommon case
        }
        span<const byte> l     = fRep_->GetBounds ();
        span<const byte> r     = rhs.fRep_->GetBounds ();
        size_t           lSize = l.size ();
        size_t           rSize = r.size ();
        if (lSize != rSize) {
            return false;
        }
        return CompareBytes (l, r) == 0;
    }
    inline BLOB BLOB::operator+ (const BLOB& rhs) const
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext declareContext{fThisAssertExternallySynchronized_};
        return BLOB ({*this, rhs});
    }
    inline strong_ordering BLOB::TWC_ (const BLOB& lhs, const BLOB& rhs)
    {
        Debug::AssertExternallySynchronizedMutex::ReadContext readLockL{lhs.fThisAssertExternallySynchronized_}; // this pattern of double locking might risk a deadlock for real locks, but these locks are fake to assure externally locked
        Debug::AssertExternallySynchronizedMutex::ReadContext readLockR{rhs.fThisAssertExternallySynchronized_};
        span<const byte>                                      l            = lhs.fRep_->GetBounds ();
        span<const byte>                                      r            = rhs.fRep_->GetBounds ();
        size_t                                                lSize        = l.size ();
        size_t                                                rSize        = r.size ();
        size_t                                                nCommonBytes = min (lSize, rSize);
        if (nCommonBytes != 0) {
            // see http://stackoverflow.com/questions/16362925/can-i-pass-a-null-pointer-to-memcmp -- illegal to pass nullptr to memcmp() even if size 0
            if (strong_ordering tmp = CompareBytes (l.subspan (0, nCommonBytes), r.subspan (0, nCommonBytes)); tmp != strong_ordering::equal) {
                return tmp;
            }
        }
        // if tmp is zero, and same size - its really zero. But if lhs shorter than right, say lhs < right
        if (lSize == rSize) {
            return strong_ordering::equal;
        }
        return (lSize < rSize) ? strong_ordering::less : strong_ordering::greater;
    }
 
    inline namespace Literals {
        inline BLOB operator"" _blob (const char* str, size_t len)
        {
            return BLOB::Attach (span<const byte>{reinterpret_cast<const byte*> (str), len});
        }
 
    }
 
}