FetchBodyConsumer.cpp [plain text]
#include "config.h"
#include "FetchBodyConsumer.h"
#include "JSBlob.h"
#include "ReadableStreamChunk.h"
#include "TextResourceDecoder.h"
namespace WebCore {
static inline Ref<Blob> blobFromData(const unsigned char* data, unsigned length, const String& contentType)
{
Vector<uint8_t> value(length);
memcpy(value.data(), data, length);
return Blob::create(WTFMove(value), contentType);
}
static inline bool shouldPrependBOM(const unsigned char* data, unsigned length)
{
if (length < 3)
return true;
return data[0] != 0xef || data[1] != 0xbb || data[2] != 0xbf;
}
static String textFromUTF8(const unsigned char* data, unsigned length)
{
auto decoder = TextResourceDecoder::create("text/plain", "UTF-8");
if (shouldPrependBOM(data, length))
decoder->decode("\xef\xbb\xbf", 3);
return decoder->decodeAndFlush(reinterpret_cast<const char*>(data), length);
}
static void resolveWithTypeAndData(Ref<DeferredPromise>&& promise, FetchBodyConsumer::Type type, const String& contentType, const unsigned char* data, unsigned length)
{
switch (type) {
case FetchBodyConsumer::Type::ArrayBuffer:
fulfillPromiseWithArrayBuffer(WTFMove(promise), data, length);
return;
case FetchBodyConsumer::Type::Blob:
promise->resolveWithNewlyCreated<IDLInterface<Blob>>(blobFromData(data, length, contentType).get());
return;
case FetchBodyConsumer::Type::JSON:
fulfillPromiseWithJSON(WTFMove(promise), textFromUTF8(data, length));
return;
case FetchBodyConsumer::Type::Text:
promise->resolve<IDLDOMString>(textFromUTF8(data, length));
return;
case FetchBodyConsumer::Type::None:
ASSERT_NOT_REACHED();
return;
}
}
void FetchBodyConsumer::clean()
{
m_buffer = nullptr;
m_consumePromise = nullptr;
if (m_sink) {
m_sink->clearCallback();
return;
}
}
void FetchBodyConsumer::resolveWithData(Ref<DeferredPromise>&& promise, const unsigned char* data, unsigned length)
{
resolveWithTypeAndData(WTFMove(promise), m_type, m_contentType, data, length);
}
void FetchBodyConsumer::extract(ReadableStream& stream, ReadableStreamToSharedBufferSink::Callback&& callback)
{
ASSERT(!m_sink);
m_sink = ReadableStreamToSharedBufferSink::create(WTFMove(callback));
m_sink->pipeFrom(stream);
}
void FetchBodyConsumer::resolve(Ref<DeferredPromise>&& promise, ReadableStream* stream)
{
if (stream) {
ASSERT(!m_sink);
m_sink = ReadableStreamToSharedBufferSink::create([promise = WTFMove(promise), data = SharedBuffer::create(), type = m_type, contentType = m_contentType](auto&& result) mutable {
if (result.hasException()) {
promise->reject(result.releaseException());
return;
}
if (auto chunk = result.returnValue())
data->append(reinterpret_cast<const char*>(chunk->data), chunk->size);
else
resolveWithTypeAndData(WTFMove(promise), type, contentType, reinterpret_cast<const unsigned char*>(data->data()), data->size());
});
m_sink->pipeFrom(*stream);
return;
}
if (m_isLoading) {
m_consumePromise = WTFMove(promise);
return;
}
ASSERT(m_type != Type::None);
switch (m_type) {
case Type::ArrayBuffer:
fulfillPromiseWithArrayBuffer(WTFMove(promise), takeAsArrayBuffer().get());
return;
case Type::Blob:
promise->resolveWithNewlyCreated<IDLInterface<Blob>>(takeAsBlob().get());
return;
case Type::JSON:
fulfillPromiseWithJSON(WTFMove(promise), takeAsText());
return;
case Type::Text:
promise->resolve<IDLDOMString>(takeAsText());
return;
case Type::None:
ASSERT_NOT_REACHED();
return;
}
}
void FetchBodyConsumer::append(const char* data, unsigned size)
{
if (m_source) {
m_source->enqueue(ArrayBuffer::tryCreate(data, size));
return;
}
if (!m_buffer) {
m_buffer = SharedBuffer::create(data, size);
return;
}
m_buffer->append(data, size);
}
void FetchBodyConsumer::append(const unsigned char* data, unsigned size)
{
append(reinterpret_cast<const char*>(data), size);
}
RefPtr<SharedBuffer> FetchBodyConsumer::takeData()
{
return WTFMove(m_buffer);
}
RefPtr<JSC::ArrayBuffer> FetchBodyConsumer::takeAsArrayBuffer()
{
if (!m_buffer)
return ArrayBuffer::tryCreate(nullptr, 0);
auto arrayBuffer = m_buffer->tryCreateArrayBuffer();
m_buffer = nullptr;
return arrayBuffer;
}
Ref<Blob> FetchBodyConsumer::takeAsBlob()
{
if (!m_buffer)
return Blob::create(Vector<uint8_t>(), m_contentType);
return blobFromData(reinterpret_cast<const unsigned char*>(m_buffer->data()), m_buffer->size(), m_contentType);
}
String FetchBodyConsumer::takeAsText()
{
if (!m_buffer)
return String();
auto text = textFromUTF8(reinterpret_cast<const unsigned char*>(m_buffer->data()), m_buffer->size());
m_buffer = nullptr;
return text;
}
void FetchBodyConsumer::setConsumePromise(Ref<DeferredPromise>&& promise)
{
ASSERT(!m_consumePromise);
m_consumePromise = WTFMove(promise);
}
void FetchBodyConsumer::setSource(Ref<FetchBodySource>&& source)
{
m_source = WTFMove(source);
if (m_buffer) {
m_source->enqueue(m_buffer->tryCreateArrayBuffer());
m_buffer = nullptr;
}
}
void FetchBodyConsumer::loadingFailed()
{
m_isLoading = false;
if (m_consumePromise) {
m_consumePromise->reject();
m_consumePromise = nullptr;
}
if (m_source) {
m_source->error("Loading failed"_s);
m_source = nullptr;
}
}
void FetchBodyConsumer::loadingSucceeded()
{
m_isLoading = false;
if (m_consumePromise)
resolve(m_consumePromise.releaseNonNull(), nullptr);
if (m_source) {
m_source->close();
m_source = nullptr;
}
}
}