@forge/bridge
5.10.0-next.35.9.1-experimental-3311bec
out/events/events.js~
out/events/events.jsModified+23−9
Index: package/out/events/events.js
===================================================================
--- package/out/events/events.js
+++ package/out/events/events.js
@@ -3,25 +3,39 @@
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) => {
- 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 });
+ return callBridge('on', { event, callback: wrappedCallback(callback) });
};
+const onPublic = (event, callback) => {
+ return callBridge('onPublic', { event, callback: wrappedCallback(callback) });
+};
exports.events = {
emit,
- on
+ emitPublic,
+ on,
+ onPublic
};