ladybird/Userland/Libraries/LibWeb/Fetch/Infrastructure/Task.h

/*
 * Copyright (c) 2022, Linus Groh <linusg@serenityos.org>
 *
 * SPDX-License-Identifier: BSD-2-Clause
 */

#pragma once

#include <AK/Variant.h>
#include <LibJS/Forward.h>
#include <LibJS/Heap/GCPtr.h>
#include <LibJS/SafeFunction.h>
#include <LibWeb/Forward.h>

namespace Web::Fetch::Infrastructure {

// FIXME: 'or a parallel queue'
using TaskDestination = Variant<Empty, JS::NonnullGCPtr<JS::Object>>;

int queue_fetch_task(JS::Object&, JS::NonnullGCPtr<JS::HeapFunction<void()>>);
int queue_fetch_task(JS::NonnullGCPtr<FetchController>, JS::Object&, JS::NonnullGCPtr<JS::HeapFunction<void()>>);

}
LibWeb: Implement 'Queue a fetch task' AO 2022-10-25 19:36:50 +01:00			`/*`
			`* Copyright (c) 2022, Linus Groh <linusg@serenityos.org>`
			`*`
			`* SPDX-License-Identifier: BSD-2-Clause`
			`*/`

			`#pragma once`

LibWeb/Fetch: Implement Body's "fully read" function from the spec Required by XHR's reliance on Fetch. 2023-02-28 18:12:44 +00:00			`#include <AK/Variant.h>`
LibWeb: Implement 'Queue a fetch task' AO 2022-10-25 19:36:50 +01:00			`#include <LibJS/Forward.h>`
LibWeb/Fetch: Implement Body's "fully read" function from the spec Required by XHR's reliance on Fetch. 2023-02-28 18:12:44 +00:00			`#include <LibJS/Heap/GCPtr.h>`
LibWeb: Implement 'Queue a fetch task' AO 2022-10-25 19:36:50 +01:00			`#include <LibJS/SafeFunction.h>`
LibWeb: Track fetching-related tasks in FetchController for cancellation The HTMLMediaElement, for example, contains spec text which states any ongoing fetch process must be "stopped". The spec does not indicate how to do this, so our implementation is rather ad-hoc. Our current implementation may cause a crash in places that assume one of the fetch algorithms that we set to null is not null. For example: if (fetch_params.process_response) { queue_fetch_task([]() { fetch_params.process_response(); }; } If the fetch process is stopped after queuing the fetch task, but not before the fetch task is run, we will crash when running this fetch algorithm. We now track queued fetch tasks on the fetch controller. When the fetch process is stopped, we cancel any such pending task. It is a little bit awkward maintaining a fetch task ID. Ideally, we could use the underlying task ID throughout. But we do not have access to the underlying task nor its ID when the task is running, at which point we need some ID to remove from the pending task list. 2024-03-22 15:28:41 -04:00			`#include <LibWeb/Forward.h>`
LibWeb: Implement 'Queue a fetch task' AO 2022-10-25 19:36:50 +01:00
			`namespace Web::Fetch::Infrastructure {`

LibWeb/Fetch: Implement Body's "fully read" function from the spec Required by XHR's reliance on Fetch. 2023-02-28 18:12:44 +00:00			`// FIXME: 'or a parallel queue'`
			`using TaskDestination = Variant<Empty, JS::NonnullGCPtr<JS::Object>>;`

LibWeb: Let queue_fetch_task() take a JS::HeapFunction Changes the signature of queue_fetch_task() from AK:Function to JS::HeapFunction to be more clear to the user of the function that this is what it uses internally. 2024-04-19 10:23:40 +02:00			`int queue_fetch_task(JS::Object&, JS::NonnullGCPtr<JS::HeapFunction<void()>>);`
			`int queue_fetch_task(JS::NonnullGCPtr<FetchController>, JS::Object&, JS::NonnullGCPtr<JS::HeapFunction<void()>>);`
LibWeb: Implement 'Queue a fetch task' AO 2022-10-25 19:36:50 +01:00
			`}`