/*

 * Copyright (c) 2023, Matthew Olsson <mattco@serenityos.org>

 *

 * SPDX-License-Identifier: BSD-2-Clause

 */

#include <LibJS/Runtime/Promise.h>

#include <LibJS/Runtime/PromiseCapability.h>

#include <LibWeb/Streams/AbstractOperations.h>

#include <LibWeb/Streams/ReadableStream.h>

#include <LibWeb/Streams/ReadableStreamGenericReader.h>

#include <LibWeb/WebIDL/Promise.h>

namespace Web::Streams {

// https://streams.spec.whatwg.org/#generic-reader-closed

JS::GCPtr<WebIDL::Promise> ReadableStreamGenericReaderMixin::closed()

{

    // 1. Return this.[[closedPromise]].

    return m_closed_promise;

}

// https://streams.spec.whatwg.org/#generic-reader-cancel

JS::NonnullGCPtr<WebIDL::Promise> ReadableStreamGenericReaderMixin::cancel(JS::Value reason)

{

    // 1. If this.[[stream]] is undefined, return a promise rejected with a TypeError exception.

    if (!m_stream) {

        WebIDL::SimpleException exception { WebIDL::SimpleExceptionType::TypeError, "No stream present to cancel"sv };

        return WebIDL::create_rejected_promise_from_exception(m_realm, move(exception));

    }

    // 2. Return ! ReadableStreamReaderGenericCancel(this, reason).

    return readable_stream_reader_generic_cancel(*this, reason);

}

ReadableStreamGenericReaderMixin::ReadableStreamGenericReaderMixin(JS::Realm& realm)

    : m_realm(realm)

{

}

void ReadableStreamGenericReaderMixin::visit_edges(JS::Cell::Visitor& visitor)

{

    visitor.visit(m_closed_promise);

    visitor.visit(m_stream);

    visitor.visit(m_realm);

}

}