diff options
Diffstat (limited to 'dom/archivereader/ArchiveRequest.cpp')
| -rw-r--r-- | dom/archivereader/ArchiveRequest.cpp | 277 |
1 files changed, 277 insertions, 0 deletions
diff --git a/dom/archivereader/ArchiveRequest.cpp b/dom/archivereader/ArchiveRequest.cpp new file mode 100644 index 000000000..ec1686804 --- /dev/null +++ b/dom/archivereader/ArchiveRequest.cpp @@ -0,0 +1,277 @@ +/* -*- Mode: C++; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 2 -*- */ +/* vim: set ts=8 sts=2 et sw=2 tw=80: */ +/* This Source Code Form is subject to the terms of the Mozilla Public + * License, v. 2.0. If a copy of the MPL was not distributed with this file, + * You can obtain one at http://mozilla.org/MPL/2.0/. */ + +#include "ArchiveRequest.h" + +#include "mozilla/EventDispatcher.h" +#include "mozilla/dom/ArchiveRequestBinding.h" +#include "mozilla/dom/ScriptSettings.h" +#include "nsContentUtils.h" + +using namespace mozilla; + +USING_ARCHIVEREADER_NAMESPACE + +/** + * Class used to make asynchronous the ArchiveRequest. + */ +class ArchiveRequestEvent : public Runnable +{ +public: + NS_DECL_NSIRUNNABLE + + explicit ArchiveRequestEvent(ArchiveRequest* aRequest) + : mRequest(aRequest) + { + MOZ_COUNT_CTOR(ArchiveRequestEvent); + } + +protected: + ~ArchiveRequestEvent() + { + MOZ_COUNT_DTOR(ArchiveRequestEvent); + } + +private: //data + RefPtr<ArchiveRequest> mRequest; +}; + +NS_IMETHODIMP +ArchiveRequestEvent::Run() +{ + MOZ_ASSERT(mRequest, "the request is not longer valid"); + mRequest->Run(); + return NS_OK; +} + +// ArchiveRequest + +ArchiveRequest::ArchiveRequest(nsPIDOMWindowInner* aWindow, + ArchiveReader* aReader) +: DOMRequest(aWindow), + mArchiveReader(aReader) +{ + MOZ_ASSERT(aReader); + + MOZ_COUNT_CTOR(ArchiveRequest); + + /* An event to make this request asynchronous: */ + RefPtr<ArchiveRequestEvent> event = new ArchiveRequestEvent(this); + NS_DispatchToCurrentThread(event); +} + +ArchiveRequest::~ArchiveRequest() +{ + MOZ_COUNT_DTOR(ArchiveRequest); +} + +nsresult +ArchiveRequest::PreHandleEvent(EventChainPreVisitor& aVisitor) +{ + aVisitor.mCanHandle = true; + aVisitor.mParentTarget = nullptr; + return NS_OK; +} + +/* virtual */ JSObject* +ArchiveRequest::WrapObject(JSContext* aCx, JS::Handle<JSObject*> aGivenProto) +{ + return ArchiveRequestBinding::Wrap(aCx, this, aGivenProto); +} + +ArchiveReader* +ArchiveRequest::Reader() const +{ + NS_ASSERTION(NS_IsMainThread(), "Wrong thread!"); + + return mArchiveReader; +} + +// Here the request is processed: +void +ArchiveRequest::Run() +{ + // Register this request to the reader. + // When the reader is ready to return data, a 'Ready()' will be called + nsresult rv = mArchiveReader->RegisterRequest(this); + if (NS_FAILED(rv)) { + FireError(rv); + } +} + +void +ArchiveRequest::OpGetFilenames() +{ + mOperation = GetFilenames; +} + +void +ArchiveRequest::OpGetFile(const nsAString& aFilename) +{ + mOperation = GetFile; + mFilename = aFilename; +} + +void +ArchiveRequest::OpGetFiles() +{ + mOperation = GetFiles; +} + +nsresult +ArchiveRequest::ReaderReady(nsTArray<RefPtr<File>>& aFileList, + nsresult aStatus) +{ + if (NS_FAILED(aStatus)) { + FireError(aStatus); + return NS_OK; + } + + nsresult rv; + + AutoJSAPI jsapi; + if (NS_WARN_IF(!jsapi.Init(GetOwner()))) { + return NS_ERROR_UNEXPECTED; + } + JSContext* cx = jsapi.cx(); + + JS::Rooted<JS::Value> result(cx); + switch (mOperation) { + case GetFilenames: + rv = GetFilenamesResult(cx, result.address(), aFileList); + break; + + case GetFile: + rv = GetFileResult(cx, &result, aFileList); + break; + + case GetFiles: + rv = GetFilesResult(cx, &result, aFileList); + break; + + default: + rv = NS_ERROR_UNEXPECTED; + break; + } + + if (NS_FAILED(rv)) { + NS_WARNING("Get*Result failed!"); + } + + if (NS_SUCCEEDED(rv)) { + FireSuccess(result); + } + else { + FireError(rv); + } + + return NS_OK; +} + +nsresult +ArchiveRequest::GetFilenamesResult(JSContext* aCx, + JS::Value* aValue, + nsTArray<RefPtr<File>>& aFileList) +{ + JS::Rooted<JSObject*> array(aCx, JS_NewArrayObject(aCx, aFileList.Length())); + + if (!array) { + return NS_ERROR_OUT_OF_MEMORY; + } + + JS::Rooted<JSString*> str(aCx); + for (uint32_t i = 0; i < aFileList.Length(); ++i) { + RefPtr<File> file = aFileList[i]; + + nsString filename; + file->GetName(filename); + + str = JS_NewUCStringCopyZ(aCx, filename.get()); + NS_ENSURE_TRUE(str, NS_ERROR_OUT_OF_MEMORY); + + if (!JS_DefineElement(aCx, array, i, str, JSPROP_ENUMERATE)) { + return NS_ERROR_FAILURE; + } + } + + if (!JS_FreezeObject(aCx, array)) { + return NS_ERROR_FAILURE; + } + + aValue->setObject(*array); + return NS_OK; +} + +nsresult +ArchiveRequest::GetFileResult(JSContext* aCx, + JS::MutableHandle<JS::Value> aValue, + nsTArray<RefPtr<File>>& aFileList) +{ + for (uint32_t i = 0; i < aFileList.Length(); ++i) { + RefPtr<File> file = aFileList[i]; + + nsString filename; + file->GetName(filename); + + if (filename == mFilename) { + if (!ToJSValue(aCx, file, aValue)) { + return NS_ERROR_FAILURE; + } + + return NS_OK; + } + } + + return NS_ERROR_FAILURE; +} + +nsresult +ArchiveRequest::GetFilesResult(JSContext* aCx, + JS::MutableHandle<JS::Value> aValue, + nsTArray<RefPtr<File>>& aFileList) +{ + JS::Rooted<JSObject*> array(aCx, JS_NewArrayObject(aCx, aFileList.Length())); + if (!array) { + return NS_ERROR_OUT_OF_MEMORY; + } + + for (uint32_t i = 0; i < aFileList.Length(); ++i) { + RefPtr<File> file = aFileList[i]; + + JS::Rooted<JS::Value> value(aCx); + if (!ToJSValue(aCx, file, &value)) { + return NS_ERROR_FAILURE; + } + + if (!JS_DefineElement(aCx, array, i, value, JSPROP_ENUMERATE)) { + return NS_ERROR_FAILURE; + } + } + + aValue.setObject(*array); + return NS_OK; +} + +// static +already_AddRefed<ArchiveRequest> +ArchiveRequest::Create(nsPIDOMWindowInner* aOwner, + ArchiveReader* aReader) +{ + NS_ASSERTION(NS_IsMainThread(), "Wrong thread!"); + + RefPtr<ArchiveRequest> request = new ArchiveRequest(aOwner, aReader); + + return request.forget(); +} + +NS_IMPL_CYCLE_COLLECTION_INHERITED(ArchiveRequest, DOMRequest, + mArchiveReader) + +NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION_INHERITED(ArchiveRequest) +NS_INTERFACE_MAP_END_INHERITING(DOMRequest) + +NS_IMPL_ADDREF_INHERITED(ArchiveRequest, DOMRequest) +NS_IMPL_RELEASE_INHERITED(ArchiveRequest, DOMRequest) |