summaryrefslogtreecommitdiffstats
path: root/dom/archivereader/ArchiveRequest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'dom/archivereader/ArchiveRequest.cpp')
-rw-r--r--dom/archivereader/ArchiveRequest.cpp277
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)