mirror of
				https://github.com/RGBCube/serenity
				synced 2025-10-31 10:02:43 +00:00 
			
		
		
		
	 4a2da10e38
			
		
	
	
		4a2da10e38
		
	
	
	
	
		
			
			This patchset makes ProtocolServer stream the downloads to its client
(LibProtocol), and as such changes the download API; a possible
download lifecycle could be as such:
notation = client->server:'>', server->client:'<', pipe activity:'*'
```
> StartDownload(GET, url, headers, {})
< Response(0, fd 8)
* {data, 1024b}
< HeadersBecameAvailable(0, response_headers, 200)
< DownloadProgress(0, 4K, 1024)
* {data, 1024b}
* {data, 1024b}
< DownloadProgress(0, 4K, 2048)
* {data, 1024b}
< DownloadProgress(0, 4K, 1024)
< DownloadFinished(0, true, 4K)
```
Since managing the received file descriptor is a pain, LibProtocol
implements `Download::stream_into(OutputStream)`, which can be used to
stream the download into any given output stream (be it a file, or
memory, or writing stuff with a delay, etc.).
Also, as some of the users of this API require all the downloaded data
upfront, LibProtocol also implements `set_should_buffer_all_input()`,
which causes the download instance to buffer all the data until the
download is complete, and to call the `on_buffered_download_finish`
hook.
		
	
			
		
			
				
	
	
		
			168 lines
		
	
	
	
		
			5.5 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			168 lines
		
	
	
	
		
			5.5 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| /*
 | |
|  * Copyright (c) 2020, Andreas Kling <kling@serenityos.org>
 | |
|  * All rights reserved.
 | |
|  *
 | |
|  * Redistribution and use in source and binary forms, with or without
 | |
|  * modification, are permitted provided that the following conditions are met:
 | |
|  *
 | |
|  * 1. Redistributions of source code must retain the above copyright notice, this
 | |
|  *    list of conditions and the following disclaimer.
 | |
|  *
 | |
|  * 2. Redistributions in binary form must reproduce the above copyright notice,
 | |
|  *    this list of conditions and the following disclaimer in the documentation
 | |
|  *    and/or other materials provided with the distribution.
 | |
|  *
 | |
|  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
 | |
|  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 | |
|  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 | |
|  * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE
 | |
|  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 | |
|  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
 | |
|  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
 | |
|  * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
 | |
|  * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 | |
|  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 | |
|  */
 | |
| 
 | |
| #include <AK/Function.h>
 | |
| #include <LibCore/MimeData.h>
 | |
| #include <LibWeb/HTML/HTMLImageElement.h>
 | |
| #include <LibWeb/Loader/Resource.h>
 | |
| 
 | |
| namespace Web {
 | |
| 
 | |
| NonnullRefPtr<Resource> Resource::create(Badge<ResourceLoader>, Type type, const LoadRequest& request)
 | |
| {
 | |
|     if (type == Type::Image)
 | |
|         return adopt(*new ImageResource(request));
 | |
|     return adopt(*new Resource(type, request));
 | |
| }
 | |
| 
 | |
| Resource::Resource(Type type, const LoadRequest& request)
 | |
|     : m_request(request)
 | |
|     , m_type(type)
 | |
| {
 | |
| }
 | |
| 
 | |
| Resource::~Resource()
 | |
| {
 | |
| }
 | |
| 
 | |
| void Resource::for_each_client(Function<void(ResourceClient&)> callback)
 | |
| {
 | |
|     Vector<WeakPtr<ResourceClient>, 16> clients_copy;
 | |
|     clients_copy.ensure_capacity(m_clients.size());
 | |
|     for (auto* client : m_clients)
 | |
|         clients_copy.append(client->make_weak_ptr());
 | |
|     for (auto client : clients_copy) {
 | |
|         if (client)
 | |
|             callback(*client);
 | |
|     }
 | |
| }
 | |
| 
 | |
| static String encoding_from_content_type(const String& content_type)
 | |
| {
 | |
|     auto offset = content_type.index_of("charset=");
 | |
|     if (offset.has_value()) {
 | |
|         auto encoding = content_type.substring(offset.value() + 8, content_type.length() - offset.value() - 8).to_lowercase();
 | |
|         if (encoding.length() >= 2 && encoding.starts_with('"') && encoding.ends_with('"'))
 | |
|             return encoding.substring(1, encoding.length() - 2);
 | |
|         if (encoding.length() >= 2 && encoding.starts_with('\'') && encoding.ends_with('\''))
 | |
|             return encoding.substring(1, encoding.length() - 2);
 | |
|         return encoding;
 | |
|     }
 | |
| 
 | |
|     return "utf-8";
 | |
| }
 | |
| 
 | |
| static String mime_type_from_content_type(const String& content_type)
 | |
| {
 | |
|     auto offset = content_type.index_of(";");
 | |
|     if (offset.has_value())
 | |
|         return content_type.substring(0, offset.value()).to_lowercase();
 | |
| 
 | |
|     return content_type;
 | |
| }
 | |
| 
 | |
| void Resource::did_load(Badge<ResourceLoader>, ReadonlyBytes data, const HashMap<String, String, CaseInsensitiveStringTraits>& headers)
 | |
| {
 | |
|     ASSERT(!m_loaded);
 | |
|     m_encoded_data = ByteBuffer::copy(data);
 | |
|     m_response_headers = headers;
 | |
|     m_loaded = true;
 | |
| 
 | |
|     auto content_type = headers.get("Content-Type");
 | |
|     if (content_type.has_value()) {
 | |
| #ifdef RESOURCE_DEBUG
 | |
|         dbg() << "Content-Type header: _" << content_type.value() << "_";
 | |
| #endif
 | |
|         m_encoding = encoding_from_content_type(content_type.value());
 | |
|         m_mime_type = mime_type_from_content_type(content_type.value());
 | |
|     } else if (url().protocol() == "data" && !url().data_mime_type().is_empty()) {
 | |
| #ifdef RESOURCE_DEBUG
 | |
|         dbg() << "This is a data URL with mime-type _" << url().data_mime_type() << "_";
 | |
| #endif
 | |
|         m_encoding = "utf-8"; // FIXME: This doesn't seem nice.
 | |
|         m_mime_type = url().data_mime_type();
 | |
|     } else {
 | |
| #ifdef RESOURCE_DEBUG
 | |
|         dbg() << "No Content-Type header to go on! Guessing based on filename...";
 | |
| #endif
 | |
|         m_encoding = "utf-8"; // FIXME: This doesn't seem nice.
 | |
|         m_mime_type = Core::guess_mime_type_based_on_filename(url().path());
 | |
|     }
 | |
| 
 | |
|     for_each_client([](auto& client) {
 | |
|         client.resource_did_load();
 | |
|     });
 | |
| }
 | |
| 
 | |
| void Resource::did_fail(Badge<ResourceLoader>, const String& error)
 | |
| {
 | |
|     m_error = error;
 | |
|     m_failed = true;
 | |
| 
 | |
|     for_each_client([](auto& client) {
 | |
|         client.resource_did_fail();
 | |
|     });
 | |
| }
 | |
| 
 | |
| void Resource::register_client(Badge<ResourceClient>, ResourceClient& client)
 | |
| {
 | |
|     ASSERT(!m_clients.contains(&client));
 | |
|     m_clients.set(&client);
 | |
| }
 | |
| 
 | |
| void Resource::unregister_client(Badge<ResourceClient>, ResourceClient& client)
 | |
| {
 | |
|     ASSERT(m_clients.contains(&client));
 | |
|     m_clients.remove(&client);
 | |
| }
 | |
| 
 | |
| void ResourceClient::set_resource(Resource* resource)
 | |
| {
 | |
|     if (m_resource)
 | |
|         m_resource->unregister_client({}, *this);
 | |
|     m_resource = resource;
 | |
|     if (m_resource) {
 | |
|         ASSERT(resource->type() == client_type());
 | |
| 
 | |
|         m_resource->register_client({}, *this);
 | |
| 
 | |
|         // Make sure that reused resources also have their load callback fired.
 | |
|         if (resource->is_loaded())
 | |
|             resource_did_load();
 | |
| 
 | |
|         // Make sure that reused resources also have their fail callback fired.
 | |
|         if (resource->is_failed())
 | |
|             resource_did_fail();
 | |
|     }
 | |
| }
 | |
| 
 | |
| ResourceClient::~ResourceClient()
 | |
| {
 | |
|     if (m_resource)
 | |
|         m_resource->unregister_client({}, *this);
 | |
| }
 | |
| 
 | |
| }
 |