/***
    Copyright (C) 2021 J Reece Wilson (a/k/a "Reece"). All rights reserved.

    File: BlobArbitraryReader.hpp
    Date: 2021-6-10
    Author: Reece
***/
#pragma once

namespace Aurora::IO::Buffered
{
    class BlobArbitraryReader : public IArbitraryStreamer
    {
    public:
        AU_NO_COPY_NO_MOVE(BlobArbitraryReader)

        BlobArbitraryReader(const AuList<AuUInt8> &buffer) : buffer_(buffer) {}
        BlobArbitraryReader() {}
        ~BlobArbitraryReader(){}

        virtual EStreamError Open() override
        {
            return EStreamError::eErrorNone;
        }

        virtual EStreamError ArbitraryRead(AuUInt32 offset, const Memory::MemoryViewStreamWrite &paramters) override
        {
            if (buffer_.empty()) return EStreamError::eErrorEndOfStream;

            auto endOffset     = offset + paramters.length;
            auto realEndOffset = AuMin(buffer_.size(), endOffset);
            auto actualLength  = realEndOffset - offset;

            if (actualLength < 0) return EStreamError::eErrorEndOfStream;

            paramters.outVariable = actualLength;
            AuMemcpy(paramters.ptr, buffer_.data() + offset, paramters.outVariable);

            return EStreamError::eErrorNone;
        }

        virtual void Close() override
        {
            buffer_.clear();
        }

    private:
        AuList<AuUInt8> buffer_;
    };
}