diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-07 19:33:14 +0000 |
commit | 36d22d82aa202bb199967e9512281e9a53db42c9 (patch) | |
tree | 105e8c98ddea1c1e4784a60a5a6410fa416be2de /devtools/client/shared/redux/middleware/promise.js | |
parent | Initial commit. (diff) | |
download | firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.tar.xz firefox-esr-36d22d82aa202bb199967e9512281e9a53db42c9.zip |
Adding upstream version 115.7.0esr.upstream/115.7.0esr
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'devtools/client/shared/redux/middleware/promise.js')
-rw-r--r-- | devtools/client/shared/redux/middleware/promise.js | 69 |
1 files changed, 69 insertions, 0 deletions
diff --git a/devtools/client/shared/redux/middleware/promise.js b/devtools/client/shared/redux/middleware/promise.js new file mode 100644 index 0000000000..7f88651a61 --- /dev/null +++ b/devtools/client/shared/redux/middleware/promise.js @@ -0,0 +1,69 @@ +/* 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/. */ +"use strict"; + +loader.lazyRequireGetter( + this, + "generateUUID", + "resource://devtools/shared/generate-uuid.js", + true +); +loader.lazyRequireGetter( + this, + ["entries", "executeSoon", "toObject"], + "resource://devtools/shared/DevToolsUtils.js", + true +); + +const PROMISE = (exports.PROMISE = "@@dispatch/promise"); + +function promiseMiddleware({ dispatch, getState }) { + return next => action => { + if (!(PROMISE in action)) { + return next(action); + } + // Return the promise so action creators can still compose if they + // want to. + return new Promise((resolve, reject) => { + const promiseInst = action[PROMISE]; + const seqId = generateUUID().toString(); + + // Create a new action that doesn't have the promise field and has + // the `seqId` field that represents the sequence id + action = Object.assign( + toObject(entries(action).filter(pair => pair[0] !== PROMISE)), + { seqId } + ); + + dispatch(Object.assign({}, action, { status: "start" })); + + promiseInst.then( + value => { + executeSoon(() => { + dispatch( + Object.assign({}, action, { + status: "done", + value, + }) + ); + resolve(value); + }); + }, + error => { + executeSoon(() => { + dispatch( + Object.assign({}, action, { + status: "error", + error: error.message || error, + }) + ); + reject(error); + }); + } + ); + }); + }; +} + +exports.promise = promiseMiddleware; |