Base import of Tycho code (warning: huge commit)

1 files changed, 138 insertions, 0 deletions

diff --git a/dom/bluetooth2/BluetoothReplyRunnable.cpp b/dom/bluetooth2/BluetoothReplyRunnable.cpp
new file mode 100644
index 000000000..361b57208
--- /dev/null
+++ b/dom/bluetooth2/BluetoothReplyRunnable.cpp
@@ -0,0 +1,138 @@
+/* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */
+/* vim: set ts=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 "base/basictypes.h"
+#include "BluetoothReplyRunnable.h"
+#include "DOMRequest.h"
+#include "mozilla/dom/ScriptSettings.h"
+#include "mozilla/dom/bluetooth/BluetoothTypes.h"
+#include "mozilla/dom/Promise.h"
+#include "nsServiceManagerUtils.h"
+
+using namespace mozilla::dom;
+
+USING_BLUETOOTH_NAMESPACE
+
+BluetoothReplyRunnable::BluetoothReplyRunnable(nsIDOMDOMRequest* aReq,
+                                               Promise* aPromise,
+                                               const nsAString& aName)
+  : mDOMRequest(aReq)
+  , mPromise(aPromise)
+  , mErrorStatus(STATUS_FAIL)
+  , mName(aName)
+{
+  if (aPromise) {
+    BT_API2_LOGR("<%s>", NS_ConvertUTF16toUTF8(mName).get());
+  }
+}
+
+void
+BluetoothReplyRunnable::SetReply(BluetoothReply* aReply)
+{
+  mReply = aReply;
+}
+
+void
+BluetoothReplyRunnable::ReleaseMembers()
+{
+  mDOMRequest = nullptr;
+  mPromise = nullptr;
+}
+
+BluetoothReplyRunnable::~BluetoothReplyRunnable()
+{}
+
+nsresult
+BluetoothReplyRunnable::FireReplySuccess(JS::Handle<JS::Value> aVal)
+{
+  MOZ_ASSERT(mReply->type() == BluetoothReply::TBluetoothReplySuccess);
+
+  // DOMRequest
+  if (mDOMRequest) {
+    nsCOMPtr<nsIDOMRequestService> rs =
+      do_GetService(DOMREQUEST_SERVICE_CONTRACTID);
+    NS_ENSURE_TRUE(rs, NS_ERROR_FAILURE);
+
+    return rs->FireSuccessAsync(mDOMRequest, aVal);
+  }
+
+  // Promise
+  if (mPromise) {
+    BT_API2_LOGR("<%s>", NS_ConvertUTF16toUTF8(mName).get());
+    mPromise->MaybeResolve(aVal);
+  }
+
+  return NS_OK;
+}
+
+nsresult
+BluetoothReplyRunnable::FireErrorString()
+{
+  // DOMRequest
+  if (mDOMRequest) {
+    nsCOMPtr<nsIDOMRequestService> rs =
+      do_GetService(DOMREQUEST_SERVICE_CONTRACTID);
+    NS_ENSURE_TRUE(rs, NS_ERROR_FAILURE);
+
+    return rs->FireErrorAsync(mDOMRequest, mErrorString);
+  }
+
+  // Promise
+  if (mPromise) {
+    BT_API2_LOGR("<%s>", NS_ConvertUTF16toUTF8(mName).get());
+
+    nsresult rv =
+      NS_ERROR_GENERATE_FAILURE(NS_ERROR_MODULE_DOM_BLUETOOTH, mErrorStatus);
+    mPromise->MaybeReject(rv);
+  }
+
+  return NS_OK;
+}
+
+NS_IMETHODIMP
+BluetoothReplyRunnable::Run()
+{
+  MOZ_ASSERT(NS_IsMainThread());
+  MOZ_ASSERT(mReply);
+
+  AutoSafeJSContext cx;
+  JS::Rooted<JS::Value> v(cx, JS::UndefinedValue());
+
+  nsresult rv;
+  if (mReply->type() != BluetoothReply::TBluetoothReplySuccess) {
+    SetError(mReply->get_BluetoothReplyError().errorString(),
+             mReply->get_BluetoothReplyError().errorStatus());
+    rv = FireErrorString();
+  } else if (!ParseSuccessfulReply(&v)) {
+    rv = FireErrorString();
+  } else {
+    rv = FireReplySuccess(v);
+  }
+
+  if (NS_FAILED(rv)) {
+    BT_WARNING("Could not fire DOMRequest/Promise!");
+  }
+
+  ReleaseMembers();
+  MOZ_ASSERT(!mDOMRequest,
+             "mDOMRequest is still alive! Deriving class should call "
+             "BluetoothReplyRunnable::ReleaseMembers()!");
+  MOZ_ASSERT(!mPromise,
+             "mPromise is still alive! Deriving class should call "
+             "BluetoothReplyRunnable::ReleaseMembers()!");
+
+  return rv;
+}
+
+BluetoothVoidReplyRunnable::BluetoothVoidReplyRunnable(nsIDOMDOMRequest* aReq,
+                                                       Promise* aPromise,
+                                                       const nsAString& aName)
+  : BluetoothReplyRunnable(aReq, aPromise, aName)
+{}
+
+BluetoothVoidReplyRunnable::~BluetoothVoidReplyRunnable()
+{}
+