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

    File: BlobSeekableWriter.hpp
    Date: 2024-03-05
    Author: Reece
***/
#pragma once

namespace Aurora::IO::Buffered
{
    struct BlobSeekableWriter : ISeekingWriter
    {
        AU_COPY_MOVE_DEF(BlobSeekableWriter)

        inline BlobSeekableWriter(const AuSPtr<Memory::ByteBuffer> &buffer) : pBuffer_(buffer) {}
        inline BlobSeekableWriter(Memory::ByteBuffer &&buffer) : pBuffer_(AuMakeShared<Memory::ByteBuffer>(AuMove(buffer))) {}
        inline BlobSeekableWriter(const Memory::ByteBuffer &buffer) : pBuffer_(AuMakeShared<Memory::ByteBuffer>(buffer)) {}

        inline virtual EStreamError IsOpen() override
        {
            if (!this->pBuffer_)
            {
                return EStreamError::eErrorStreamNotOpen;
            }

            return EStreamError::eErrorNone;
        }

        inline virtual EStreamError ArbitraryWrite(AuUInt offset, const Memory::MemoryViewStreamRead &parameters) override
        {
            if (!this->pBuffer_)
            {
                return EStreamError::eErrorStreamNotOpen;
            }

            if (this->pBuffer_->empty())
            {
                return EStreamError::eErrorEndOfStream;
            }

            this->pBuffer_->writePtr = this->pBuffer_->base + offset;
            parameters.outVariable = this->pBuffer_->Write(parameters.ptr, parameters.length);
            return parameters.outVariable == 0 ? EStreamError::eErrorEndOfStream : EStreamError::eErrorNone;
        }

        inline virtual void Flush() override
        {
        }

        inline virtual void Close() override
        {
            AuResetMember(this->pBuffer_);
        }

    private:
        AuSPtr<Memory::ByteBuffer> pBuffer_;
    };
}