@forge/bridge
5.9.1-experimental-3311bec5.10.0-next.3-experimental-2969aa0
out/events/events.js~
out/events/events.jsModified+9−23
Index: package/out/events/events.js
===================================================================
--- package/out/events/events.js
+++ package/out/events/events.js
@@ -3,39 +3,25 @@
exports.events = void 0;
const bridge_1 = require("../bridge");
const serialiseBlob_1 = require("./serialiseBlob");
const callBridge = (0, bridge_1.getCallBridge)();
-const wrappedCallback = (callback) => {
- return (payload) => {
- let newPayload = payload;
- if ((0, serialiseBlob_1.containsSerialisedBlobs)(payload)) {
- newPayload = (0, serialiseBlob_1.deserialiseBlobsInPayload)(payload);
- }
- return callback(newPayload);
- };
-};
const emit = async (event, payload) => {
let newPayload = payload;
if ((0, serialiseBlob_1.containsBlobs)(payload)) {
newPayload = await (0, serialiseBlob_1.serialiseBlobsInPayload)(payload);
}
return callBridge('emit', { event, payload: newPayload });
};
-const emitPublic = async (event, payload, options) => {
- let newPayload = payload;
- if ((0, serialiseBlob_1.containsBlobs)(payload)) {
- newPayload = await (0, serialiseBlob_1.serialiseBlobsInPayload)(payload);
- }
- return callBridge('emitPublic', { event, payload: newPayload, allowedRecipients: options === null || options === void 0 ? void 0 : options.allowedRecipients });
-};
const on = (event, callback) => {
- return callBridge('on', { event, callback: wrappedCallback(callback) });
+ const wrappedCallback = (payload) => {
+ let newPayload = payload;
+ if ((0, serialiseBlob_1.containsSerialisedBlobs)(payload)) {
+ newPayload = (0, serialiseBlob_1.deserialiseBlobsInPayload)(payload);
+ }
+ return callback(newPayload);
+ };
+ return callBridge('on', { event, callback: wrappedCallback });
};
-const onPublic = (event, callback) => {
- return callBridge('onPublic', { event, callback: wrappedCallback(callback) });
-};
exports.events = {
emit,
- emitPublic,
- on,
- onPublic
+ on
};