post-me - npm Package Compare versions

Comparing version 0.4.0 to 0.4.1

dist/index.d.ts

 import { ParentHandshake, ChildHandshake } from './handshake';
 import { Connection } from './connection';
-import { Messenger, WindowMessenger, WorkerMessenger, DebugMessenger, debug } from './messenger';
+import { Messenger, WindowMessenger, WorkerMessenger, PortMessenger, BareMessenger, DebugMessenger, debug } from './messenger';
 import { RemoteHandle, LocalHandle } from './handles';
-export { ParentHandshake, ChildHandshake, Connection, RemoteHandle, LocalHandle, Messenger, WindowMessenger, WorkerMessenger, DebugMessenger, debug, };
+export { ParentHandshake, ChildHandshake, Connection, RemoteHandle, LocalHandle, Messenger, WindowMessenger, WorkerMessenger, PortMessenger, BareMessenger, DebugMessenger, debug, };

dist/index.esm.js

@@ -492,19 +492,30 @@ const MARKER = '@post-me';
 }
-class WorkerMessenger {
-    constructor({ worker }) {
-        this.postMessage = (message, transfer = []) => {
-            worker.postMessage(message, transfer);
+class BareMessenger {
+    constructor(postable) {
+        this._postable = postable;
+    }
+    postMessage(message, transfer = []) {
+        this._postable.postMessage(message, transfer);
+    }
+    addMessageListener(listener) {
+        const outerListener = (event) => {
+            listener(event);
         };
-        this.addMessageListener = (listener) => {
-            const outerListener = (event) => {
-                listener(event);
-            };
-            worker.addEventListener('message', outerListener);
-            const removeListener = () => {
-                worker.removeEventListener('message', outerListener);
-            };
-            return removeListener;
+        this._postable.addEventListener('message', outerListener);
+        const removeListener = () => {
+            this._postable.removeEventListener('message', outerListener);
         };
+        return removeListener;
     }
 }
+class WorkerMessenger extends BareMessenger {
+    constructor({ worker }) {
+        super(worker);
+    }
+}
+class PortMessenger extends BareMessenger {
+    constructor({ port }) {
+        super(port);
+    }
+}
 const debug = (namespace, log) => {
@@ -534,2 +545,2 @@ log = log || console.debug || console.log || (() => { });
 
-export { ChildHandshake, DebugMessenger, ParentHandshake, WindowMessenger, WorkerMessenger, debug };
+export { BareMessenger, ChildHandshake, DebugMessenger, ParentHandshake, PortMessenger, WindowMessenger, WorkerMessenger, debug };

dist/index.js

@@ -766,27 +766,70 @@ (function (global, factory) {
 
-    var WorkerMessenger = function WorkerMessenger(_ref2) {
-      var worker = _ref2.worker;
+    var BareMessenger = /*#__PURE__*/function () {
+      function BareMessenger(postable) {
+        _classCallCheck(this, BareMessenger);
 
-      _classCallCheck(this, WorkerMessenger);
+        this._postable = postable;
+      }
 
-      this.postMessage = function (message) {
-        var transfer = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : [];
-        worker.postMessage(message, transfer);
-      };
+      _createClass(BareMessenger, [{
+        key: "postMessage",
+        value: function postMessage(message) {
+          var transfer = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : [];
 
-      this.addMessageListener = function (listener) {
-        var outerListener = function outerListener(event) {
-          listener(event);
-        };
+          this._postable.postMessage(message, transfer);
+        }
+      }, {
+        key: "addMessageListener",
+        value: function addMessageListener(listener) {
+          var _this8 = this;
 
-        worker.addEventListener('message', outerListener);
+          var outerListener = function outerListener(event) {
+            listener(event);
+          };
 
-        var removeListener = function removeListener() {
-          worker.removeEventListener('message', outerListener);
-        };
+          this._postable.addEventListener('message', outerListener);
 
-        return removeListener;
-      };
-    };
+          var removeListener = function removeListener() {
+            _this8._postable.removeEventListener('message', outerListener);
+          };
 
+          return removeListener;
+        }
+      }]);
+
+      return BareMessenger;
+    }();
+
+    var WorkerMessenger = /*#__PURE__*/function (_BareMessenger) {
+      _inherits(WorkerMessenger, _BareMessenger);
+
+      var _super5 = _createSuper(WorkerMessenger);
+
+      function WorkerMessenger(_ref2) {
+        var worker = _ref2.worker;
+
+        _classCallCheck(this, WorkerMessenger);
+
+        return _super5.call(this, worker);
+      }
+
+      return WorkerMessenger;
+    }(BareMessenger);
+
+    var PortMessenger = /*#__PURE__*/function (_BareMessenger2) {
+      _inherits(PortMessenger, _BareMessenger2);
+
+      var _super6 = _createSuper(PortMessenger);
+
+      function PortMessenger(_ref3) {
+        var port = _ref3.port;
+
+        _classCallCheck(this, PortMessenger);
+
+        return _super6.call(this, port);
+      }
+
+      return PortMessenger;
+    }(BareMessenger);
+
     var debug = function debug(namespace, log) {
@@ -824,5 +867,7 @@ log = log || console.debug || console.log || function () {};
 
+    exports.BareMessenger = BareMessenger;
     exports.ChildHandshake = ChildHandshake;
     exports.DebugMessenger = DebugMessenger;
     exports.ParentHandshake = ParentHandshake;
+    exports.PortMessenger = PortMessenger;
     exports.WindowMessenger = WindowMessenger;
@@ -829,0 +874,0 @@ exports.WorkerMessenger = WorkerMessenger;

dist/index.min.js

@@ -1,1 +0,1 @@
-(function(global,factory){typeof exports==="object"&&typeof module!=="undefined"?factory(exports):typeof define==="function"&&define.amd?define(["exports"],factory):(global=typeof globalThis!=="undefined"?globalThis:global||self,factory(global.PostMe={}))})(this,function(exports){"use strict";function _typeof(obj){"@babel/helpers - typeof";if(typeof Symbol==="function"&&typeof Symbol.iterator==="symbol"){_typeof=function _typeof(obj){return typeof obj}}else{_typeof=function _typeof(obj){return obj&&typeof Symbol==="function"&&obj.constructor===Symbol&&obj!==Symbol.prototype?"symbol":typeof obj}}return _typeof(obj)}function _toConsumableArray(arr){return _arrayWithoutHoles(arr)||_iterableToArray(arr)||_unsupportedIterableToArray(arr)||_nonIterableSpread()}function _nonIterableSpread(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}function _unsupportedIterableToArray(o,minLen){if(!o)return;if(typeof o==="string")return _arrayLikeToArray(o,minLen);var n=Object.prototype.toString.call(o).slice(8,-1);if(n==="Object"&&o.constructor)n=o.constructor.name;if(n==="Map"||n==="Set")return Array.from(o);if(n==="Arguments"||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n))return _arrayLikeToArray(o,minLen)}function _iterableToArray(iter){if(typeof Symbol!=="undefined"&&Symbol.iterator in Object(iter))return Array.from(iter)}function _arrayWithoutHoles(arr){if(Array.isArray(arr))return _arrayLikeToArray(arr)}function _arrayLikeToArray(arr,len){if(len==null||len>arr.length)len=arr.length;for(var i=0,arr2=new Array(len);i<len;i++){arr2[i]=arr[i]}return arr2}function _inherits(subClass,superClass){if(typeof superClass!=="function"&&superClass!==null){throw new TypeError("Super expression must either be null or a function")}subClass.prototype=Object.create(superClass&&superClass.prototype,{constructor:{value:subClass,writable:true,configurable:true}});if(superClass)_setPrototypeOf(subClass,superClass)}function _setPrototypeOf(o,p){_setPrototypeOf=Object.setPrototypeOf||function _setPrototypeOf(o,p){o.__proto__=p;return o};return _setPrototypeOf(o,p)}function _createSuper(Derived){var hasNativeReflectConstruct=_isNativeReflectConstruct();return function _createSuperInternal(){var Super=_getPrototypeOf(Derived),result;if(hasNativeReflectConstruct){var NewTarget=_getPrototypeOf(this).constructor;result=Reflect.construct(Super,arguments,NewTarget)}else{result=Super.apply(this,arguments)}return _possibleConstructorReturn(this,result)}}function _possibleConstructorReturn(self,call){if(call&&(_typeof(call)==="object"||typeof call==="function")){return call}return _assertThisInitialized(self)}function _assertThisInitialized(self){if(self===void 0){throw new ReferenceError("this hasn't been initialised - super() hasn't been called")}return self}function _isNativeReflectConstruct(){if(typeof Reflect==="undefined"||!Reflect.construct)return false;if(Reflect.construct.sham)return false;if(typeof Proxy==="function")return true;try{Date.prototype.toString.call(Reflect.construct(Date,[],function(){}));return true}catch(e){return false}}function _getPrototypeOf(o){_getPrototypeOf=Object.setPrototypeOf?Object.getPrototypeOf:function _getPrototypeOf(o){return o.__proto__||Object.getPrototypeOf(o)};return _getPrototypeOf(o)}function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor)){throw new TypeError("Cannot call a class as a function")}}function _defineProperties(target,props){for(var i=0;i<props.length;i++){var descriptor=props[i];descriptor.enumerable=descriptor.enumerable||false;descriptor.configurable=true;if("value"in descriptor)descriptor.writable=true;Object.defineProperty(target,descriptor.key,descriptor)}}function _createClass(Constructor,protoProps,staticProps){if(protoProps)_defineProperties(Constructor.prototype,protoProps);if(staticProps)_defineProperties(Constructor,staticProps);return Constructor}var MARKER="@post-me";function createUniqueIdFn(){var __id=0;return function(){var id=__id;__id+=1;return id}}var Emitter=function(){function Emitter(){_classCallCheck(this,Emitter);this._listeners={}}_createClass(Emitter,[{key:"addEventListener",value:function addEventListener(eventName,listener){var listeners=this._listeners[eventName];if(!listeners){listeners=new Set;this._listeners[eventName]=listeners}listeners.add(listener)}},{key:"removeEventListener",value:function removeEventListener(eventName,listener){var listeners=this._listeners[eventName];if(!listeners){return}listeners["delete"](listener)}},{key:"once",value:function once(eventName){var _this=this;return new Promise(function(resolve){var listener=function listener(data){_this.removeEventListener(eventName,listener);resolve(data)};_this.addEventListener(eventName,listener)})}},{key:"emit",value:function emit(eventName,data){var listeners=this._listeners[eventName];if(!listeners){return}listeners.forEach(function(listener){listener(data)})}},{key:"removeAllListeners",value:function removeAllListeners(){Object.values(this._listeners).forEach(function(listeners){if(listeners){listeners.clear()}})}}]);return Emitter}();var MessageType;(function(MessageType){MessageType["HandshakeRequest"]="handshake-request";MessageType["HandshakeResponse"]="handshake-response";MessageType["Call"]="call";MessageType["Response"]="response";MessageType["Error"]="error";MessageType["Event"]="event";MessageType["Callback"]="callback"})(MessageType||(MessageType={}));function createHandshakeRequestMessage(sessionId){return{type:MARKER,action:MessageType.HandshakeRequest,sessionId:sessionId}}function createHandshakeResponseMessage(sessionId){return{type:MARKER,action:MessageType.HandshakeResponse,sessionId:sessionId}}function createCallMessage(sessionId,requestId,methodName,args){return{type:MARKER,action:MessageType.Call,sessionId:sessionId,requestId:requestId,methodName:methodName,args:args}}function createResponsMessage(sessionId,requestId,result,error){var message={type:MARKER,action:MessageType.Response,sessionId:sessionId,requestId:requestId};if(result!==undefined){message.result=result}if(error!==undefined){message.error=error}return message}function createCallbackMessage(sessionId,requestId,callbackId,args){return{type:MARKER,action:MessageType.Callback,sessionId:sessionId,requestId:requestId,callbackId:callbackId,args:args}}function createEventMessage(sessionId,eventName,payload){return{type:MARKER,action:MessageType.Event,sessionId:sessionId,eventName:eventName,payload:payload}}function isMessage(m){return m.type===MARKER}function isHandshakeRequestMessage(m){return isMessage(m)&&m.action===MessageType.HandshakeRequest}function isHandshakeResponseMessage(m){return isMessage(m)&&m.action===MessageType.HandshakeResponse}function isCallMessage(m){return isMessage(m)&&m.action===MessageType.Call}function isResponseMessage(m){return isMessage(m)&&m.action===MessageType.Response}function isCallbackMessage(m){return isMessage(m)&&m.action===MessageType.Callback}function isEventMessage(m){return isMessage(m)&&m.action===MessageType.Event}function makeCallbackEvent(requestId){return"callback_".concat(requestId)}function makeResponseEvent(requestId){return"response_".concat(requestId)}var Dispatcher=function(_Emitter){_inherits(Dispatcher,_Emitter);var _super=_createSuper(Dispatcher);function Dispatcher(messenger,sessionId){var _this2;_classCallCheck(this,Dispatcher);_this2=_super.call(this);_this2.uniqueId=createUniqueIdFn();_this2.messenger=messenger;_this2.sessionId=sessionId;_this2.removeMessengerListener=_this2.messenger.addMessageListener(_this2.messengerListener.bind(_assertThisInitialized(_this2)));return _this2}_createClass(Dispatcher,[{key:"messengerListener",value:function messengerListener(event){var data=event.data;if(!isMessage(data)){return}if(this.sessionId!==data.sessionId){return}if(isCallMessage(data)){this.emit(MessageType.Call,data)}else if(isResponseMessage(data)){this.emit(makeResponseEvent(data.requestId),data)}else if(isEventMessage(data)){this.emit(MessageType.Event,data)}else if(isCallbackMessage(data)){this.emit(makeCallbackEvent(data.requestId),data)}}},{key:"callOnRemote",value:function callOnRemote(methodName,args,transfer){var requestId=this.uniqueId();var callbackEvent=makeCallbackEvent(requestId);var responseEvent=makeResponseEvent(requestId);var message=createCallMessage(this.sessionId,requestId,methodName,args);this.messenger.postMessage(message,transfer);return{callbackEvent:callbackEvent,responseEvent:responseEvent}}},{key:"respondToRemote",value:function respondToRemote(requestId,value,error,transfer){var message=createResponsMessage(this.sessionId,requestId,value,error);this.messenger.postMessage(message,transfer)}},{key:"callbackToRemote",value:function callbackToRemote(requestId,callbackId,args){var message=createCallbackMessage(this.sessionId,requestId,callbackId,args);this.messenger.postMessage(message)}},{key:"emitToRemote",value:function emitToRemote(eventName,payload,transfer){var message=createEventMessage(this.sessionId,eventName,payload);this.messenger.postMessage(message,transfer)}},{key:"close",value:function close(){this.removeMessengerListener();this.removeAllListeners()}}]);return Dispatcher}(Emitter);var ParentHandshakeDispatcher=function(_Emitter2){_inherits(ParentHandshakeDispatcher,_Emitter2);var _super2=_createSuper(ParentHandshakeDispatcher);function ParentHandshakeDispatcher(messenger,sessionId){var _this3;_classCallCheck(this,ParentHandshakeDispatcher);_this3=_super2.call(this);_this3.messenger=messenger;_this3.sessionId=sessionId;_this3.removeMessengerListener=_this3.messenger.addMessageListener(_this3.messengerListener.bind(_assertThisInitialized(_this3)));return _this3}_createClass(ParentHandshakeDispatcher,[{key:"messengerListener",value:function messengerListener(event){var data=event.data;if(!isMessage(data)){return}if(this.sessionId!==data.sessionId){return}if(isHandshakeResponseMessage(data)){this.emit(data.sessionId,data)}}},{key:"initiateHandshake",value:function initiateHandshake(){var message=createHandshakeRequestMessage(this.sessionId);this.messenger.postMessage(message);return this.sessionId}},{key:"close",value:function close(){this.removeMessengerListener();this.removeAllListeners()}}]);return ParentHandshakeDispatcher}(Emitter);var ChildHandshakeDispatcher=function(_Emitter3){_inherits(ChildHandshakeDispatcher,_Emitter3);var _super3=_createSuper(ChildHandshakeDispatcher);function ChildHandshakeDispatcher(messenger){var _this4;_classCallCheck(this,ChildHandshakeDispatcher);_this4=_super3.call(this);_this4.messenger=messenger;_this4.removeMessengerListener=_this4.messenger.addMessageListener(_this4.messengerListener.bind(_assertThisInitialized(_this4)));return _this4}_createClass(ChildHandshakeDispatcher,[{key:"messengerListener",value:function messengerListener(event){var data=event.data;if(isHandshakeRequestMessage(data)){this.emit(MessageType.HandshakeRequest,data)}}},{key:"acceptHandshake",value:function acceptHandshake(sessionId){var message=createHandshakeResponseMessage(sessionId);this.messenger.postMessage(message)}},{key:"close",value:function close(){this.removeMessengerListener();this.removeAllListeners()}}]);return ChildHandshakeDispatcher}(Emitter);var ProxyType;(function(ProxyType){ProxyType["Callback"]="callback"})(ProxyType||(ProxyType={}));function createCallbackProxy(callbackId){return{type:MARKER,proxy:ProxyType.Callback,callbackId:callbackId}}function isCallbackProxy(p){return p.type===MARKER&&p.proxy===ProxyType.Callback}var ConcreteRemoteHandle=function(_Emitter4){_inherits(ConcreteRemoteHandle,_Emitter4);var _super4=_createSuper(ConcreteRemoteHandle);function ConcreteRemoteHandle(dispatcher){var _this5;_classCallCheck(this,ConcreteRemoteHandle);_this5=_super4.call(this);_this5._dispatcher=dispatcher;_this5._callTransfer={};_this5._dispatcher.addEventListener(MessageType.Event,_this5._handleEvent.bind(_assertThisInitialized(_this5)));return _this5}_createClass(ConcreteRemoteHandle,[{key:"close",value:function close(){this.removeAllListeners()}},{key:"setCallTransfer",value:function setCallTransfer(methodName,transfer){this._callTransfer[methodName]=transfer}},{key:"call",value:function call(methodName){for(var _len=arguments.length,args=new Array(_len>1?_len-1:0),_key=1;_key<_len;_key++){args[_key-1]=arguments[_key]}return this.customCall(methodName,args)}},{key:"customCall",value:function customCall(methodName,args){var _this6=this;var options=arguments.length>2&&arguments[2]!==undefined?arguments[2]:{};return new Promise(function(resolve,reject){var sanitizedArgs=[];var callbacks=[];var callbackId=0;args.forEach(function(arg){if(typeof arg==="function"){callbacks.push(arg);sanitizedArgs.push(createCallbackProxy(callbackId));callbackId+=1}else{sanitizedArgs.push(arg)}});var hasCallbacks=callbacks.length>0;var callbackListener=undefined;if(hasCallbacks){callbackListener=function callbackListener(data){var callbackId=data.callbackId,args=data.args;callbacks[callbackId].apply(callbacks,_toConsumableArray(args))}}var transfer=options.transfer;if(transfer===undefined&&_this6._callTransfer[methodName]){var _this6$_callTransfer;transfer=(_this6$_callTransfer=_this6._callTransfer)[methodName].apply(_this6$_callTransfer,sanitizedArgs)}var _this6$_dispatcher$ca=_this6._dispatcher.callOnRemote(methodName,sanitizedArgs,transfer),callbackEvent=_this6$_dispatcher$ca.callbackEvent,responseEvent=_this6$_dispatcher$ca.responseEvent;if(hasCallbacks){_this6._dispatcher.addEventListener(callbackEvent,callbackListener)}_this6._dispatcher.once(responseEvent).then(function(response){if(callbackListener){_this6._dispatcher.removeEventListener(callbackEvent,callbackListener)}var result=response.result,error=response.error;if(error!==undefined){reject(error)}else{resolve(result)}})})}},{key:"_handleEvent",value:function _handleEvent(data){var eventName=data.eventName,payload=data.payload;this.emit(eventName,payload)}}]);return ConcreteRemoteHandle}(Emitter);var ConcreteLocalHandle=function(){function ConcreteLocalHandle(dispatcher,localMethods){_classCallCheck(this,ConcreteLocalHandle);this._dispatcher=dispatcher;this._methods=localMethods;this._returnTransfer={};this._emitTransfer={};this._dispatcher.addEventListener(MessageType.Call,this._handleCall.bind(this))}_createClass(ConcreteLocalHandle,[{key:"emit",value:function emit(eventName,payload){var options=arguments.length>2&&arguments[2]!==undefined?arguments[2]:{};var transfer=options.transfer;if(transfer===undefined&&this._emitTransfer[eventName]){transfer=this._emitTransfer[eventName](payload)}this._dispatcher.emitToRemote(eventName,payload,transfer)}},{key:"setReturnTransfer",value:function setReturnTransfer(methodName,transfer){this._returnTransfer[methodName]=transfer}},{key:"setEmitTransfer",value:function setEmitTransfer(eventName,transfer){this._emitTransfer[eventName]=transfer}},{key:"_handleCall",value:function _handleCall(data){var _this7=this;var requestId=data.requestId,methodName=data.methodName,args=data.args;var callMethod=new Promise(function(resolve,reject){var method=_this7._methods[methodName];if(typeof method!=="function"){reject(new Error('The method "'.concat(methodName,'" has not been implemented.')));return}var desanitizedArgs=args.map(function(arg){if(isCallbackProxy(arg)){var callbackId=arg.callbackId;return function(){for(var _len2=arguments.length,args=new Array(_len2),_key2=0;_key2<_len2;_key2++){args[_key2]=arguments[_key2]}_this7._dispatcher.callbackToRemote(requestId,callbackId,args)}}else{return arg}});Promise.resolve(method.apply(void 0,_toConsumableArray(desanitizedArgs))).then(resolve)["catch"](reject)});callMethod.then(function(result){var transfer;if(_this7._returnTransfer[methodName]){transfer=_this7._returnTransfer[methodName](result)}_this7._dispatcher.respondToRemote(requestId,result,undefined,transfer)})["catch"](function(error){_this7._dispatcher.respondToRemote(requestId,undefined,error)})}}]);return ConcreteLocalHandle}();var ConcreteConnection=function(){function ConcreteConnection(dispatcher,localMethods){_classCallCheck(this,ConcreteConnection);this._dispatcher=dispatcher;this._localHandle=new ConcreteLocalHandle(dispatcher,localMethods);this._remoteHandle=new ConcreteRemoteHandle(dispatcher)}_createClass(ConcreteConnection,[{key:"close",value:function close(){this._dispatcher.close();this.remoteHandle().close()}},{key:"localHandle",value:function localHandle(){return this._localHandle}},{key:"remoteHandle",value:function remoteHandle(){return this._remoteHandle}}]);return ConcreteConnection}();var uniqueSessionId=createUniqueIdFn();var runUntil=function runUntil(worker,condition,unfulfilled,maxAttempts,attemptInterval){var attempt=0;var fn=function fn(){if(!condition()&&(attempt<maxAttempts||maxAttempts<1)){worker();attempt+=1;setTimeout(fn,attemptInterval)}else if(!condition()&&attempt>=maxAttempts&&maxAttempts>=1){unfulfilled()}};fn()};function ParentHandshake(messenger){var localMethods=arguments.length>1&&arguments[1]!==undefined?arguments[1]:{};var maxAttempts=arguments.length>2&&arguments[2]!==undefined?arguments[2]:5;var attemptsInterval=arguments.length>3&&arguments[3]!==undefined?arguments[3]:100;var thisSessionId=uniqueSessionId();var connected=false;return new Promise(function(resolve,reject){var handshakeDispatcher=new ParentHandshakeDispatcher(messenger,thisSessionId);handshakeDispatcher.once(thisSessionId).then(function(response){connected=true;handshakeDispatcher.close();var sessionId=response.sessionId;var dispatcher=new Dispatcher(messenger,sessionId);var connection=new ConcreteConnection(dispatcher,localMethods);resolve(connection)});runUntil(function(){return handshakeDispatcher.initiateHandshake()},function(){return connected},function(){return reject(new Error("Handshake failed, reached maximum number of attempts"))},maxAttempts,attemptsInterval)})}function ChildHandshake(messenger){var localMethods=arguments.length>1&&arguments[1]!==undefined?arguments[1]:{};return new Promise(function(resolve,reject){var handshakeDispatcher=new ChildHandshakeDispatcher(messenger);handshakeDispatcher.once(MessageType.HandshakeRequest).then(function(response){var sessionId=response.sessionId;handshakeDispatcher.acceptHandshake(sessionId);handshakeDispatcher.close();var dispatcher=new Dispatcher(messenger,sessionId);var connection=new ConcreteConnection(dispatcher,localMethods);resolve(connection)})})}var acceptableMessageEvent=function acceptableMessageEvent(event,remoteWindow,acceptedOrigin){var source=event.source,origin=event.origin;if(source!==remoteWindow){return false}if(origin!==acceptedOrigin&&acceptedOrigin!=="*"){return false}return true};var WindowMessenger=function WindowMessenger(_ref){var localWindow=_ref.localWindow,remoteWindow=_ref.remoteWindow,remoteOrigin=_ref.remoteOrigin;_classCallCheck(this,WindowMessenger);localWindow=localWindow||window;this.postMessage=function(message,transfer){remoteWindow.postMessage(message,remoteOrigin,transfer)};this.addMessageListener=function(listener){var outerListener=function outerListener(event){if(acceptableMessageEvent(event,remoteWindow,remoteOrigin)){listener(event)}};localWindow.addEventListener("message",outerListener);var removeListener=function removeListener(){localWindow.removeEventListener("message",outerListener)};return removeListener}};var WorkerMessenger=function WorkerMessenger(_ref2){var worker=_ref2.worker;_classCallCheck(this,WorkerMessenger);this.postMessage=function(message){var transfer=arguments.length>1&&arguments[1]!==undefined?arguments[1]:[];worker.postMessage(message,transfer)};this.addMessageListener=function(listener){var outerListener=function outerListener(event){listener(event)};worker.addEventListener("message",outerListener);var removeListener=function removeListener(){worker.removeEventListener("message",outerListener)};return removeListener}};var debug=function debug(namespace,log){log=log||console.debug||console.log||function(){};return function(){for(var _len3=arguments.length,data=new Array(_len3),_key3=0;_key3<_len3;_key3++){data[_key3]=arguments[_key3]}log.apply(void 0,[namespace].concat(data))}};function DebugMessenger(messenger,log){log=log||debug("post-me");var debugListener=function debugListener(event){var data=event.data;log("⬅️ received message",data)};messenger.addMessageListener(debugListener);return{postMessage:function postMessage(message){log("➡️ sending message",message);messenger.postMessage(message)},addMessageListener:function addMessageListener(listener){return messenger.addMessageListener(listener)}}}exports.ChildHandshake=ChildHandshake;exports.DebugMessenger=DebugMessenger;exports.ParentHandshake=ParentHandshake;exports.WindowMessenger=WindowMessenger;exports.WorkerMessenger=WorkerMessenger;exports.debug=debug;Object.defineProperty(exports,"__esModule",{value:true})});
+(function(global,factory){typeof exports==="object"&&typeof module!=="undefined"?factory(exports):typeof define==="function"&&define.amd?define(["exports"],factory):(global=typeof globalThis!=="undefined"?globalThis:global||self,factory(global.PostMe={}))})(this,function(exports){"use strict";function _typeof(obj){"@babel/helpers - typeof";if(typeof Symbol==="function"&&typeof Symbol.iterator==="symbol"){_typeof=function _typeof(obj){return typeof obj}}else{_typeof=function _typeof(obj){return obj&&typeof Symbol==="function"&&obj.constructor===Symbol&&obj!==Symbol.prototype?"symbol":typeof obj}}return _typeof(obj)}function _toConsumableArray(arr){return _arrayWithoutHoles(arr)||_iterableToArray(arr)||_unsupportedIterableToArray(arr)||_nonIterableSpread()}function _nonIterableSpread(){throw new TypeError("Invalid attempt to spread non-iterable instance.\nIn order to be iterable, non-array objects must have a [Symbol.iterator]() method.")}function _unsupportedIterableToArray(o,minLen){if(!o)return;if(typeof o==="string")return _arrayLikeToArray(o,minLen);var n=Object.prototype.toString.call(o).slice(8,-1);if(n==="Object"&&o.constructor)n=o.constructor.name;if(n==="Map"||n==="Set")return Array.from(o);if(n==="Arguments"||/^(?:Ui|I)nt(?:8|16|32)(?:Clamped)?Array$/.test(n))return _arrayLikeToArray(o,minLen)}function _iterableToArray(iter){if(typeof Symbol!=="undefined"&&Symbol.iterator in Object(iter))return Array.from(iter)}function _arrayWithoutHoles(arr){if(Array.isArray(arr))return _arrayLikeToArray(arr)}function _arrayLikeToArray(arr,len){if(len==null||len>arr.length)len=arr.length;for(var i=0,arr2=new Array(len);i<len;i++){arr2[i]=arr[i]}return arr2}function _inherits(subClass,superClass){if(typeof superClass!=="function"&&superClass!==null){throw new TypeError("Super expression must either be null or a function")}subClass.prototype=Object.create(superClass&&superClass.prototype,{constructor:{value:subClass,writable:true,configurable:true}});if(superClass)_setPrototypeOf(subClass,superClass)}function _setPrototypeOf(o,p){_setPrototypeOf=Object.setPrototypeOf||function _setPrototypeOf(o,p){o.__proto__=p;return o};return _setPrototypeOf(o,p)}function _createSuper(Derived){var hasNativeReflectConstruct=_isNativeReflectConstruct();return function _createSuperInternal(){var Super=_getPrototypeOf(Derived),result;if(hasNativeReflectConstruct){var NewTarget=_getPrototypeOf(this).constructor;result=Reflect.construct(Super,arguments,NewTarget)}else{result=Super.apply(this,arguments)}return _possibleConstructorReturn(this,result)}}function _possibleConstructorReturn(self,call){if(call&&(_typeof(call)==="object"||typeof call==="function")){return call}return _assertThisInitialized(self)}function _assertThisInitialized(self){if(self===void 0){throw new ReferenceError("this hasn't been initialised - super() hasn't been called")}return self}function _isNativeReflectConstruct(){if(typeof Reflect==="undefined"||!Reflect.construct)return false;if(Reflect.construct.sham)return false;if(typeof Proxy==="function")return true;try{Date.prototype.toString.call(Reflect.construct(Date,[],function(){}));return true}catch(e){return false}}function _getPrototypeOf(o){_getPrototypeOf=Object.setPrototypeOf?Object.getPrototypeOf:function _getPrototypeOf(o){return o.__proto__||Object.getPrototypeOf(o)};return _getPrototypeOf(o)}function _classCallCheck(instance,Constructor){if(!(instance instanceof Constructor)){throw new TypeError("Cannot call a class as a function")}}function _defineProperties(target,props){for(var i=0;i<props.length;i++){var descriptor=props[i];descriptor.enumerable=descriptor.enumerable||false;descriptor.configurable=true;if("value"in descriptor)descriptor.writable=true;Object.defineProperty(target,descriptor.key,descriptor)}}function _createClass(Constructor,protoProps,staticProps){if(protoProps)_defineProperties(Constructor.prototype,protoProps);if(staticProps)_defineProperties(Constructor,staticProps);return Constructor}var MARKER="@post-me";function createUniqueIdFn(){var __id=0;return function(){var id=__id;__id+=1;return id}}var Emitter=function(){function Emitter(){_classCallCheck(this,Emitter);this._listeners={}}_createClass(Emitter,[{key:"addEventListener",value:function addEventListener(eventName,listener){var listeners=this._listeners[eventName];if(!listeners){listeners=new Set;this._listeners[eventName]=listeners}listeners.add(listener)}},{key:"removeEventListener",value:function removeEventListener(eventName,listener){var listeners=this._listeners[eventName];if(!listeners){return}listeners["delete"](listener)}},{key:"once",value:function once(eventName){var _this=this;return new Promise(function(resolve){var listener=function listener(data){_this.removeEventListener(eventName,listener);resolve(data)};_this.addEventListener(eventName,listener)})}},{key:"emit",value:function emit(eventName,data){var listeners=this._listeners[eventName];if(!listeners){return}listeners.forEach(function(listener){listener(data)})}},{key:"removeAllListeners",value:function removeAllListeners(){Object.values(this._listeners).forEach(function(listeners){if(listeners){listeners.clear()}})}}]);return Emitter}();var MessageType;(function(MessageType){MessageType["HandshakeRequest"]="handshake-request";MessageType["HandshakeResponse"]="handshake-response";MessageType["Call"]="call";MessageType["Response"]="response";MessageType["Error"]="error";MessageType["Event"]="event";MessageType["Callback"]="callback"})(MessageType||(MessageType={}));function createHandshakeRequestMessage(sessionId){return{type:MARKER,action:MessageType.HandshakeRequest,sessionId:sessionId}}function createHandshakeResponseMessage(sessionId){return{type:MARKER,action:MessageType.HandshakeResponse,sessionId:sessionId}}function createCallMessage(sessionId,requestId,methodName,args){return{type:MARKER,action:MessageType.Call,sessionId:sessionId,requestId:requestId,methodName:methodName,args:args}}function createResponsMessage(sessionId,requestId,result,error){var message={type:MARKER,action:MessageType.Response,sessionId:sessionId,requestId:requestId};if(result!==undefined){message.result=result}if(error!==undefined){message.error=error}return message}function createCallbackMessage(sessionId,requestId,callbackId,args){return{type:MARKER,action:MessageType.Callback,sessionId:sessionId,requestId:requestId,callbackId:callbackId,args:args}}function createEventMessage(sessionId,eventName,payload){return{type:MARKER,action:MessageType.Event,sessionId:sessionId,eventName:eventName,payload:payload}}function isMessage(m){return m.type===MARKER}function isHandshakeRequestMessage(m){return isMessage(m)&&m.action===MessageType.HandshakeRequest}function isHandshakeResponseMessage(m){return isMessage(m)&&m.action===MessageType.HandshakeResponse}function isCallMessage(m){return isMessage(m)&&m.action===MessageType.Call}function isResponseMessage(m){return isMessage(m)&&m.action===MessageType.Response}function isCallbackMessage(m){return isMessage(m)&&m.action===MessageType.Callback}function isEventMessage(m){return isMessage(m)&&m.action===MessageType.Event}function makeCallbackEvent(requestId){return"callback_".concat(requestId)}function makeResponseEvent(requestId){return"response_".concat(requestId)}var Dispatcher=function(_Emitter){_inherits(Dispatcher,_Emitter);var _super=_createSuper(Dispatcher);function Dispatcher(messenger,sessionId){var _this2;_classCallCheck(this,Dispatcher);_this2=_super.call(this);_this2.uniqueId=createUniqueIdFn();_this2.messenger=messenger;_this2.sessionId=sessionId;_this2.removeMessengerListener=_this2.messenger.addMessageListener(_this2.messengerListener.bind(_assertThisInitialized(_this2)));return _this2}_createClass(Dispatcher,[{key:"messengerListener",value:function messengerListener(event){var data=event.data;if(!isMessage(data)){return}if(this.sessionId!==data.sessionId){return}if(isCallMessage(data)){this.emit(MessageType.Call,data)}else if(isResponseMessage(data)){this.emit(makeResponseEvent(data.requestId),data)}else if(isEventMessage(data)){this.emit(MessageType.Event,data)}else if(isCallbackMessage(data)){this.emit(makeCallbackEvent(data.requestId),data)}}},{key:"callOnRemote",value:function callOnRemote(methodName,args,transfer){var requestId=this.uniqueId();var callbackEvent=makeCallbackEvent(requestId);var responseEvent=makeResponseEvent(requestId);var message=createCallMessage(this.sessionId,requestId,methodName,args);this.messenger.postMessage(message,transfer);return{callbackEvent:callbackEvent,responseEvent:responseEvent}}},{key:"respondToRemote",value:function respondToRemote(requestId,value,error,transfer){var message=createResponsMessage(this.sessionId,requestId,value,error);this.messenger.postMessage(message,transfer)}},{key:"callbackToRemote",value:function callbackToRemote(requestId,callbackId,args){var message=createCallbackMessage(this.sessionId,requestId,callbackId,args);this.messenger.postMessage(message)}},{key:"emitToRemote",value:function emitToRemote(eventName,payload,transfer){var message=createEventMessage(this.sessionId,eventName,payload);this.messenger.postMessage(message,transfer)}},{key:"close",value:function close(){this.removeMessengerListener();this.removeAllListeners()}}]);return Dispatcher}(Emitter);var ParentHandshakeDispatcher=function(_Emitter2){_inherits(ParentHandshakeDispatcher,_Emitter2);var _super2=_createSuper(ParentHandshakeDispatcher);function ParentHandshakeDispatcher(messenger,sessionId){var _this3;_classCallCheck(this,ParentHandshakeDispatcher);_this3=_super2.call(this);_this3.messenger=messenger;_this3.sessionId=sessionId;_this3.removeMessengerListener=_this3.messenger.addMessageListener(_this3.messengerListener.bind(_assertThisInitialized(_this3)));return _this3}_createClass(ParentHandshakeDispatcher,[{key:"messengerListener",value:function messengerListener(event){var data=event.data;if(!isMessage(data)){return}if(this.sessionId!==data.sessionId){return}if(isHandshakeResponseMessage(data)){this.emit(data.sessionId,data)}}},{key:"initiateHandshake",value:function initiateHandshake(){var message=createHandshakeRequestMessage(this.sessionId);this.messenger.postMessage(message);return this.sessionId}},{key:"close",value:function close(){this.removeMessengerListener();this.removeAllListeners()}}]);return ParentHandshakeDispatcher}(Emitter);var ChildHandshakeDispatcher=function(_Emitter3){_inherits(ChildHandshakeDispatcher,_Emitter3);var _super3=_createSuper(ChildHandshakeDispatcher);function ChildHandshakeDispatcher(messenger){var _this4;_classCallCheck(this,ChildHandshakeDispatcher);_this4=_super3.call(this);_this4.messenger=messenger;_this4.removeMessengerListener=_this4.messenger.addMessageListener(_this4.messengerListener.bind(_assertThisInitialized(_this4)));return _this4}_createClass(ChildHandshakeDispatcher,[{key:"messengerListener",value:function messengerListener(event){var data=event.data;if(isHandshakeRequestMessage(data)){this.emit(MessageType.HandshakeRequest,data)}}},{key:"acceptHandshake",value:function acceptHandshake(sessionId){var message=createHandshakeResponseMessage(sessionId);this.messenger.postMessage(message)}},{key:"close",value:function close(){this.removeMessengerListener();this.removeAllListeners()}}]);return ChildHandshakeDispatcher}(Emitter);var ProxyType;(function(ProxyType){ProxyType["Callback"]="callback"})(ProxyType||(ProxyType={}));function createCallbackProxy(callbackId){return{type:MARKER,proxy:ProxyType.Callback,callbackId:callbackId}}function isCallbackProxy(p){return p.type===MARKER&&p.proxy===ProxyType.Callback}var ConcreteRemoteHandle=function(_Emitter4){_inherits(ConcreteRemoteHandle,_Emitter4);var _super4=_createSuper(ConcreteRemoteHandle);function ConcreteRemoteHandle(dispatcher){var _this5;_classCallCheck(this,ConcreteRemoteHandle);_this5=_super4.call(this);_this5._dispatcher=dispatcher;_this5._callTransfer={};_this5._dispatcher.addEventListener(MessageType.Event,_this5._handleEvent.bind(_assertThisInitialized(_this5)));return _this5}_createClass(ConcreteRemoteHandle,[{key:"close",value:function close(){this.removeAllListeners()}},{key:"setCallTransfer",value:function setCallTransfer(methodName,transfer){this._callTransfer[methodName]=transfer}},{key:"call",value:function call(methodName){for(var _len=arguments.length,args=new Array(_len>1?_len-1:0),_key=1;_key<_len;_key++){args[_key-1]=arguments[_key]}return this.customCall(methodName,args)}},{key:"customCall",value:function customCall(methodName,args){var _this6=this;var options=arguments.length>2&&arguments[2]!==undefined?arguments[2]:{};return new Promise(function(resolve,reject){var sanitizedArgs=[];var callbacks=[];var callbackId=0;args.forEach(function(arg){if(typeof arg==="function"){callbacks.push(arg);sanitizedArgs.push(createCallbackProxy(callbackId));callbackId+=1}else{sanitizedArgs.push(arg)}});var hasCallbacks=callbacks.length>0;var callbackListener=undefined;if(hasCallbacks){callbackListener=function callbackListener(data){var callbackId=data.callbackId,args=data.args;callbacks[callbackId].apply(callbacks,_toConsumableArray(args))}}var transfer=options.transfer;if(transfer===undefined&&_this6._callTransfer[methodName]){var _this6$_callTransfer;transfer=(_this6$_callTransfer=_this6._callTransfer)[methodName].apply(_this6$_callTransfer,sanitizedArgs)}var _this6$_dispatcher$ca=_this6._dispatcher.callOnRemote(methodName,sanitizedArgs,transfer),callbackEvent=_this6$_dispatcher$ca.callbackEvent,responseEvent=_this6$_dispatcher$ca.responseEvent;if(hasCallbacks){_this6._dispatcher.addEventListener(callbackEvent,callbackListener)}_this6._dispatcher.once(responseEvent).then(function(response){if(callbackListener){_this6._dispatcher.removeEventListener(callbackEvent,callbackListener)}var result=response.result,error=response.error;if(error!==undefined){reject(error)}else{resolve(result)}})})}},{key:"_handleEvent",value:function _handleEvent(data){var eventName=data.eventName,payload=data.payload;this.emit(eventName,payload)}}]);return ConcreteRemoteHandle}(Emitter);var ConcreteLocalHandle=function(){function ConcreteLocalHandle(dispatcher,localMethods){_classCallCheck(this,ConcreteLocalHandle);this._dispatcher=dispatcher;this._methods=localMethods;this._returnTransfer={};this._emitTransfer={};this._dispatcher.addEventListener(MessageType.Call,this._handleCall.bind(this))}_createClass(ConcreteLocalHandle,[{key:"emit",value:function emit(eventName,payload){var options=arguments.length>2&&arguments[2]!==undefined?arguments[2]:{};var transfer=options.transfer;if(transfer===undefined&&this._emitTransfer[eventName]){transfer=this._emitTransfer[eventName](payload)}this._dispatcher.emitToRemote(eventName,payload,transfer)}},{key:"setReturnTransfer",value:function setReturnTransfer(methodName,transfer){this._returnTransfer[methodName]=transfer}},{key:"setEmitTransfer",value:function setEmitTransfer(eventName,transfer){this._emitTransfer[eventName]=transfer}},{key:"_handleCall",value:function _handleCall(data){var _this7=this;var requestId=data.requestId,methodName=data.methodName,args=data.args;var callMethod=new Promise(function(resolve,reject){var method=_this7._methods[methodName];if(typeof method!=="function"){reject(new Error('The method "'.concat(methodName,'" has not been implemented.')));return}var desanitizedArgs=args.map(function(arg){if(isCallbackProxy(arg)){var callbackId=arg.callbackId;return function(){for(var _len2=arguments.length,args=new Array(_len2),_key2=0;_key2<_len2;_key2++){args[_key2]=arguments[_key2]}_this7._dispatcher.callbackToRemote(requestId,callbackId,args)}}else{return arg}});Promise.resolve(method.apply(void 0,_toConsumableArray(desanitizedArgs))).then(resolve)["catch"](reject)});callMethod.then(function(result){var transfer;if(_this7._returnTransfer[methodName]){transfer=_this7._returnTransfer[methodName](result)}_this7._dispatcher.respondToRemote(requestId,result,undefined,transfer)})["catch"](function(error){_this7._dispatcher.respondToRemote(requestId,undefined,error)})}}]);return ConcreteLocalHandle}();var ConcreteConnection=function(){function ConcreteConnection(dispatcher,localMethods){_classCallCheck(this,ConcreteConnection);this._dispatcher=dispatcher;this._localHandle=new ConcreteLocalHandle(dispatcher,localMethods);this._remoteHandle=new ConcreteRemoteHandle(dispatcher)}_createClass(ConcreteConnection,[{key:"close",value:function close(){this._dispatcher.close();this.remoteHandle().close()}},{key:"localHandle",value:function localHandle(){return this._localHandle}},{key:"remoteHandle",value:function remoteHandle(){return this._remoteHandle}}]);return ConcreteConnection}();var uniqueSessionId=createUniqueIdFn();var runUntil=function runUntil(worker,condition,unfulfilled,maxAttempts,attemptInterval){var attempt=0;var fn=function fn(){if(!condition()&&(attempt<maxAttempts||maxAttempts<1)){worker();attempt+=1;setTimeout(fn,attemptInterval)}else if(!condition()&&attempt>=maxAttempts&&maxAttempts>=1){unfulfilled()}};fn()};function ParentHandshake(messenger){var localMethods=arguments.length>1&&arguments[1]!==undefined?arguments[1]:{};var maxAttempts=arguments.length>2&&arguments[2]!==undefined?arguments[2]:5;var attemptsInterval=arguments.length>3&&arguments[3]!==undefined?arguments[3]:100;var thisSessionId=uniqueSessionId();var connected=false;return new Promise(function(resolve,reject){var handshakeDispatcher=new ParentHandshakeDispatcher(messenger,thisSessionId);handshakeDispatcher.once(thisSessionId).then(function(response){connected=true;handshakeDispatcher.close();var sessionId=response.sessionId;var dispatcher=new Dispatcher(messenger,sessionId);var connection=new ConcreteConnection(dispatcher,localMethods);resolve(connection)});runUntil(function(){return handshakeDispatcher.initiateHandshake()},function(){return connected},function(){return reject(new Error("Handshake failed, reached maximum number of attempts"))},maxAttempts,attemptsInterval)})}function ChildHandshake(messenger){var localMethods=arguments.length>1&&arguments[1]!==undefined?arguments[1]:{};return new Promise(function(resolve,reject){var handshakeDispatcher=new ChildHandshakeDispatcher(messenger);handshakeDispatcher.once(MessageType.HandshakeRequest).then(function(response){var sessionId=response.sessionId;handshakeDispatcher.acceptHandshake(sessionId);handshakeDispatcher.close();var dispatcher=new Dispatcher(messenger,sessionId);var connection=new ConcreteConnection(dispatcher,localMethods);resolve(connection)})})}var acceptableMessageEvent=function acceptableMessageEvent(event,remoteWindow,acceptedOrigin){var source=event.source,origin=event.origin;if(source!==remoteWindow){return false}if(origin!==acceptedOrigin&&acceptedOrigin!=="*"){return false}return true};var WindowMessenger=function WindowMessenger(_ref){var localWindow=_ref.localWindow,remoteWindow=_ref.remoteWindow,remoteOrigin=_ref.remoteOrigin;_classCallCheck(this,WindowMessenger);localWindow=localWindow||window;this.postMessage=function(message,transfer){remoteWindow.postMessage(message,remoteOrigin,transfer)};this.addMessageListener=function(listener){var outerListener=function outerListener(event){if(acceptableMessageEvent(event,remoteWindow,remoteOrigin)){listener(event)}};localWindow.addEventListener("message",outerListener);var removeListener=function removeListener(){localWindow.removeEventListener("message",outerListener)};return removeListener}};var BareMessenger=function(){function BareMessenger(postable){_classCallCheck(this,BareMessenger);this._postable=postable}_createClass(BareMessenger,[{key:"postMessage",value:function postMessage(message){var transfer=arguments.length>1&&arguments[1]!==undefined?arguments[1]:[];this._postable.postMessage(message,transfer)}},{key:"addMessageListener",value:function addMessageListener(listener){var _this8=this;var outerListener=function outerListener(event){listener(event)};this._postable.addEventListener("message",outerListener);var removeListener=function removeListener(){_this8._postable.removeEventListener("message",outerListener)};return removeListener}}]);return BareMessenger}();var WorkerMessenger=function(_BareMessenger){_inherits(WorkerMessenger,_BareMessenger);var _super5=_createSuper(WorkerMessenger);function WorkerMessenger(_ref2){var worker=_ref2.worker;_classCallCheck(this,WorkerMessenger);return _super5.call(this,worker)}return WorkerMessenger}(BareMessenger);var PortMessenger=function(_BareMessenger2){_inherits(PortMessenger,_BareMessenger2);var _super6=_createSuper(PortMessenger);function PortMessenger(_ref3){var port=_ref3.port;_classCallCheck(this,PortMessenger);return _super6.call(this,port)}return PortMessenger}(BareMessenger);var debug=function debug(namespace,log){log=log||console.debug||console.log||function(){};return function(){for(var _len3=arguments.length,data=new Array(_len3),_key3=0;_key3<_len3;_key3++){data[_key3]=arguments[_key3]}log.apply(void 0,[namespace].concat(data))}};function DebugMessenger(messenger,log){log=log||debug("post-me");var debugListener=function debugListener(event){var data=event.data;log("⬅️ received message",data)};messenger.addMessageListener(debugListener);return{postMessage:function postMessage(message){log("➡️ sending message",message);messenger.postMessage(message)},addMessageListener:function addMessageListener(listener){return messenger.addMessageListener(listener)}}}exports.BareMessenger=BareMessenger;exports.ChildHandshake=ChildHandshake;exports.DebugMessenger=DebugMessenger;exports.ParentHandshake=ParentHandshake;exports.PortMessenger=PortMessenger;exports.WindowMessenger=WindowMessenger;exports.WorkerMessenger=WorkerMessenger;exports.debug=debug;Object.defineProperty(exports,"__esModule",{value:true})});

dist/messenger.d.ts

@@ -16,5 +16,14 @@ declare type MessageListener = (event: MessageEvent) => void;
 }
-export declare class WorkerMessenger implements Messenger {
-    postMessage: (message: any, transfer?: Transferable[]) => void;
-    addMessageListener: (listener: MessageListener) => ListenerRemover;
+interface Postable {
+    postMessage(message: any, transfer?: Transferable[]): void;
+    addEventListener(eventName: 'message', listener: MessageListener): void;
+    removeEventListener(eventName: 'message', listener: MessageListener): void;
+}
+export declare class BareMessenger implements Messenger {
+    _postable: Postable;
+    constructor(postable: Postable);
+    postMessage(message: any, transfer?: Transferable[]): void;
+    addMessageListener(listener: MessageListener): ListenerRemover;
+}
+export declare class WorkerMessenger extends BareMessenger implements Messenger {
     constructor({ worker }: {
@@ -24,4 +33,9 @@ worker: Worker;
 }
+export declare class PortMessenger extends BareMessenger implements Messenger {
+    constructor({ port }: {
+        port: MessagePort;
+    });
+}
 export declare const debug: (namespace: string, log?: ((...data: any[]) => void) | undefined) => (...data: any[]) => void;
 export declare function DebugMessenger(messenger: Messenger, log?: (...data: any[]) => void): Messenger;
 export {};

package.json

 {
   "name": "post-me",
-  "version": "0.4.0",
-  "description": "Communicate with web Workers and other Windows using a simple Promise based API",
+  "version": "0.4.1",
+  "description": "Use web Workers and other Windows through a simple Promise API",
   "author": {
@@ -6,0 +6,0 @@ "name": "Alessandro Genova",

README.md

@@ -30,3 +30,5 @@ [![workflow status](https://github.com/alesgenova/post-me/workflows/main/badge.svg?branch=main)](https://github.com/alesgenova/post-me/actions?query=workflow%3Amain+branch%3Amain)
 3. [Typescript Support](#typescript)
-4. [Other Windows](#windows)
+4. [Other Uses](#other)
+    - [Windows](#windows)
+    - [MessageChannels](#channels)
 5. [Callbacks as parameters](#callbacks)
@@ -187,13 +189,16 @@ 6. [Transfer vs Clone](#transfer)
 
-<a id="windows"></a>
+<a id="other"></a>
 
-## Other Windows
-post-me can establish the same level of bidirectional communications not only with workers but with other windows too (e.g. iframes).
+## Other Uses
+post-me can establish the same level of bidirectional communications not only with workers but with other windows too (e.g. iframes) and message channels.
 
-Internally, the low level differences between communicating with a `Worker` or a `Window` have been abstracted, and the `Handshake` will accept any object that implements the `Messenger` interface defined by post-me.
+Internally, the low level differences between communicating with a `Worker`, a `Window`, or a `MessageChannel` have been abstracted, and the `Handshake` will accept any object that implements the `Messenger` interface defined by __post-me__.
 
 This approach makes it easy for post-me to be extended by its users.
 
-A `Messenger` implementation for communicating between window is already provided in the library (`WindowMessenger`).
+A `Messenger` implementation for communicating between `Windows` and `MessagePorts` is already provided in the library (`WindowMessenger` and `PortMessenger`).
 
+<a id="windows"></a>
+
+### Windows
 Here is an example of using post-me to communicate with an iframe.
@@ -233,2 +238,26 @@
 
+<a id="channels"></a>
+
+### MessageChannels
+Here is an example of using post-me to communicate over a `MessageChannel`.
+
+```typescript
+import { ParentHandshake, ChildHandshake, PortMessenger } from 'post-me';
+
+// Create a MessageChannel
+const channel = new MessageChannel();
+const port1 = channel.port1;
+const port2 = channel.port2;
+
+// In the real world  port1 and port2 would be transferred to other workers/windows
+{
+  const messenger = new PortMessenger({port: port1});
+  ParentHandshake(messenger).then(connection => {/* ... */});
+}
+{
+  const messenger = new PortMessenger({port: port2});
+  ChildHandshake(messenger).then(connection => {/* ... */});
+}
+```
+
 <a id="callbacks"></a>
@@ -289,3 +318,3 @@
 
-  // Transfer the the buffer of the array parameter of every call that will be made to 'fillArray'
+  // Transfer the buffer of the array parameter of every call that will be made to 'fillArray'
   remoteHandle.setCallTransfer('fillArray', (array, value) => [array.buffer]);
@@ -292,0 +321,0 @@ {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

98845

increased by3.73%

Lines of code

1492

increased by3.9%

Number of lines in readme file

399

increased by7.84%

No dependency changes