/*
 * Copyright (c) 2026-present, the Ladybird developers.
 *
 * SPDX-License-Identifier: BSD-2-Clause
 */

#pragma once

#include <AK/ByteBuffer.h>
#include <LibWeb/Bindings/PlatformObject.h>
#include <LibWeb/Encoding/TextDecoder.h>
#include <LibWeb/Encoding/TextDecoderCommon.h>
#include <LibWeb/Streams/GenericTransformStream.h>

namespace Web::Encoding {

// https://encoding.spec.whatwg.org/#textdecoderstream
class TextDecoderStream final
    : public Bindings::PlatformObject
    , public Streams::GenericTransformStreamMixin
    , public TextDecoderCommonMixin {
    WEB_PLATFORM_OBJECT(TextDecoderStream, Bindings::PlatformObject);
    GC_DECLARE_ALLOCATOR(TextDecoderStream);

public:
    static WebIDL::ExceptionOr<GC::Ref<TextDecoderStream>> construct_impl(JS::Realm&, FlyString label, Bindings::TextDecoderOptions const&);
    virtual ~TextDecoderStream() override;

private:
    TextDecoderStream(JS::Realm&, GC::Ref<Streams::TransformStream>, TextCodec::Decoder&, FlyString encoding, ErrorMode, bool ignore_bom);

    virtual void initialize(JS::Realm&) override;
    virtual void visit_edges(Cell::Visitor&) override;

    WebIDL::ExceptionOr<void> decode_and_enqueue_chunk(JS::Value);
    WebIDL::ExceptionOr<void> flush_and_enqueue();

    WebIDL::ExceptionOr<void> enqueue_decoded_output(String const&);

    // https://encoding.spec.whatwg.org/#textdecodercommon-i-o-queue
    // NB: We accumulate input bytes that have been pushed to the I/O queue but not yet decoded, so that a multi-byte
    //     sequence which is split across chunks can be reassembled.
    ByteBuffer m_io_queue;
};

}