summaryrefslogtreecommitdiffstats
path: root/dom/credentialmanagement/identity/IdentityNetworkHelpers.h
diff options
context:
space:
mode:
Diffstat (limited to 'dom/credentialmanagement/identity/IdentityNetworkHelpers.h')
-rw-r--r--dom/credentialmanagement/identity/IdentityNetworkHelpers.h98
1 files changed, 98 insertions, 0 deletions
diff --git a/dom/credentialmanagement/identity/IdentityNetworkHelpers.h b/dom/credentialmanagement/identity/IdentityNetworkHelpers.h
new file mode 100644
index 0000000000..a580e678c5
--- /dev/null
+++ b/dom/credentialmanagement/identity/IdentityNetworkHelpers.h
@@ -0,0 +1,98 @@
+/* -*- 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/. */
+
+#ifndef mozilla_dom_IdentityNetworkHelpers_h
+#define mozilla_dom_IdentityNetworkHelpers_h
+
+#include "mozilla/dom/Request.h"
+#include "mozilla/dom/Response.h"
+#include "mozilla/dom/WindowGlobalParent.h"
+#include "mozilla/MozPromise.h"
+
+namespace mozilla::dom {
+
+// Helper to get a JSON structure via a Fetch.
+// The Request must already be built and T should be a webidl type with
+// annotation GenerateConversionToJS so it has an Init method.
+template <typename T, typename TPromise = MozPromise<T, nsresult, true>>
+RefPtr<TPromise> FetchJSONStructure(Request* aRequest) {
+ MOZ_ASSERT(XRE_IsParentProcess());
+
+ // Create the returned Promise
+ RefPtr<typename TPromise::Private> resultPromise =
+ new typename TPromise::Private(__func__);
+
+ // Fetch the provided request
+ RequestOrUSVString fetchInput;
+ fetchInput.SetAsRequest() = aRequest;
+ RootedDictionary<RequestInit> requestInit(RootingCx());
+ IgnoredErrorResult error;
+ RefPtr<Promise> fetchPromise =
+ FetchRequest(aRequest->GetParentObject(), fetchInput, requestInit,
+ CallerType::System, error);
+ if (NS_WARN_IF(error.Failed())) {
+ resultPromise->Reject(NS_ERROR_FAILURE, __func__);
+ return resultPromise;
+ }
+
+ // Handle the response
+ RefPtr<DomPromiseListener> listener = new DomPromiseListener(
+ [resultPromise](JSContext* aCx, JS::Handle<JS::Value> aValue) {
+ // Get the Response object from the argument to the callback
+ if (NS_WARN_IF(!aValue.isObject())) {
+ resultPromise->Reject(NS_ERROR_FAILURE, __func__);
+ return;
+ }
+ JS::Rooted<JSObject*> obj(aCx, &aValue.toObject());
+ MOZ_ASSERT(obj);
+ Response* response = nullptr;
+ if (NS_WARN_IF(NS_FAILED(UNWRAP_OBJECT(Response, &obj, response)))) {
+ resultPromise->Reject(NS_ERROR_FAILURE, __func__);
+ return;
+ }
+
+ // Make sure the request was a success
+ if (!response->Ok()) {
+ resultPromise->Reject(NS_ERROR_FAILURE, __func__);
+ return;
+ }
+
+ // Parse the body into JSON, which must be done async
+ IgnoredErrorResult error;
+ RefPtr<Promise> jsonPromise = response->ConsumeBody(
+ aCx, BodyConsumer::ConsumeType::CONSUME_JSON, error);
+ if (NS_WARN_IF(error.Failed())) {
+ resultPromise->Reject(NS_ERROR_FAILURE, __func__);
+ return;
+ }
+
+ // Handle the parsed JSON from the Response body
+ RefPtr<DomPromiseListener> jsonListener = new DomPromiseListener(
+ [resultPromise](JSContext* aCx, JS::Handle<JS::Value> aValue) {
+ // Parse the JSON into the correct type, validating fields and
+ // types
+ T result;
+ bool success = result.Init(aCx, aValue);
+ if (!success) {
+ resultPromise->Reject(NS_ERROR_FAILURE, __func__);
+ return;
+ }
+
+ resultPromise->Resolve(result, __func__);
+ },
+ [resultPromise](nsresult aRv) {
+ resultPromise->Reject(aRv, __func__);
+ });
+ jsonPromise->AppendNativeHandler(jsonListener);
+ },
+ [resultPromise](nsresult aRv) { resultPromise->Reject(aRv, __func__); });
+ fetchPromise->AppendNativeHandler(listener);
+ return resultPromise;
+}
+
+} // namespace mozilla::dom
+
+#endif // mozilla_dom_IdentityNetworkHelpers_h