Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
@jumpn/absinthe-phoenix-socket
Advanced tools
@jumpn/absinthe-phoenix-socket - npm Package Compare versions
Comparing version 0.4.0 to 0.4.1
@@ -1,2 +0,2 @@ | ||
| "use strict";function _interopDefault(n){return n&&"object"==typeof n&&"default"in n?n.default:n}var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck"));require("phoenix");var _extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite"),utilsArray=require("@jumpn/utils-array"),_this$2=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$2),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[n]&&e[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,i,e){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(i),e))}.bind(void 0),_this$3=void 0,notifyall=function(n,i,e){return _newArrowCheck(this,_this$3),n.forEach(function(n){return _newArrowCheck(this,_this$3),notify(n,i,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(n,i,e){return _newArrowCheck(this,_this$7),n.find(utilsComposite.hasIn([i],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var t=arguments.length,r=Array(t),o=0;o<t;o++)r[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(n.notifiers,"request",i);s&&e.apply(void 0,[n,s].concat(r))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,e){return _newArrowCheck(this,_this$6),utilsComposite.map(createEventHandler(i,e),n)}.bind(void 0),_this$9=void 0,findIndex=function(n,i,e){return _newArrowCheck(this,_this$9),n.findIndex(utilsComposite.hasIn([i],e))}.bind(void 0),_this$8=void 0,remove$1=function(n){return _newArrowCheck(this,_this$8),function(i){return _newArrowCheck(this,_this$8),utilsArray.remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(n){return _newArrowCheck(this,_this$10),function(i){return _newArrowCheck(this,_this$10),utilsArray.replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$11),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$5=void 0,onQueryOrMutationResponse=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Result",e.payload.result)}.bind(void 0),notifyStart=function(n){return _newArrowCheck(this,_this$5),notify(n,"Start",n)}.bind(void 0),onSubscriptionResponse=function(n,i,e){var t=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:t}))),notifyStart(i)}.bind(void 0),onResponse=function(n,i,e){_newArrowCheck(this,_this$5),e.subscriptionId?onSubscriptionResponse(n,i,e):e.payload&&onQueryOrMutationResponse(n,i,e)}.bind(void 0),abortRequest=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Abort",e)}.bind(void 0),onError=function(n,i,e){return _newArrowCheck(this,_this$5),abortRequest(n,i,new Error(e))}.bind(void 0),onSucceed=function(n,i,e){_newArrowCheck(this,_this$5),e.errors?onError(n,i,utilsGraphql.errorsToString(e.errors)):onResponse(n,i,e)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$5),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(n,i){_newArrowCheck(this,_this$5),"subscription"!==i.operationType&¬ifyStart(i),handlePush(n.channel.push("doc",i.request),createPushHandler(notifierPushHandler,n,i.request))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$1),{onError:function(i){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this$1),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$1),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(n,i){_newArrowCheck(this,_this),updateNotifiers(n,remove$1(i)),notify(i,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"mutation"===i.operationType?mutationOnConnectionClose(n,i):notify(i,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),0!==n.notifiers.length&&(n.isJoining=!0,n.notifiers.forEach(notifierOnConnectionClose(n)))}.bind(this)}.bind(void 0),onSubscriptionData=function(n,i){var e=i.payload;_newArrowCheck(this,_this);var t=find(n.notifiers,"subscriptionId",e.subscriptionId);t&¬ify(t,"Result",e.result)}.bind(void 0),onMessage=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"subscription:data"===i.event&&onSubscriptionData(n,i)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(n){_newArrowCheck(this,_this),0===n.notifiers.length?n.isJoining=!1:joinChannel(n)}.bind(void 0),onConnectionOpen=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),n.isJoining&&joinChannelIfNeeded(n)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(n){_newArrowCheck(this,_this);var i={phoenixSocket:n,channel:n.channel(absintheChannelName),isJoining:!1,notifiers:[]};return n.onOpen(onConnectionOpen(i)),n.onMessage(onMessage(i)),n.onClose(onConnectionClose(i)),i}.bind(void 0);module.exports=create; | ||
| "use strict";function _interopDefault(n){return n&&"object"==typeof n&&"default"in n?n.default:n}var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck"));require("phoenix");var _extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite"),utilsArray=require("@jumpn/utils-array"),_this$2=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$2),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[n]&&e[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,i,e){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(i),e))}.bind(void 0),_this$3=void 0,notifyall=function(n,i,e){return _newArrowCheck(this,_this$3),n.forEach(function(n){return _newArrowCheck(this,_this$3),notify(n,i,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(n,i,e){return _newArrowCheck(this,_this$7),n.find(utilsComposite.hasIn([i],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var t=arguments.length,r=Array(t),o=0;o<t;o++)r[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(n.notifiers,"request",i);s&&e.apply(void 0,[n,s].concat(r))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,e){return _newArrowCheck(this,_this$6),utilsComposite.map(createEventHandler(i,e),n)}.bind(void 0),_this$9=void 0,findIndex=function(n,i,e){return _newArrowCheck(this,_this$9),n.findIndex(utilsComposite.hasIn([i],e))}.bind(void 0),_this$8=void 0,remove$1=function(n){return _newArrowCheck(this,_this$8),function(i){return _newArrowCheck(this,_this$8),utilsArray.remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(n){return _newArrowCheck(this,_this$10),function(i){return _newArrowCheck(this,_this$10),utilsArray.replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$11),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$5=void 0,notifyStart=function(n){return _newArrowCheck(this,_this$5),notify(n,"Start",n)}.bind(void 0),onSubscriptionSucceed=function(n,i,e){var t=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:t}))),notifyStart(i)}.bind(void 0),abortRequest=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Abort",e)}.bind(void 0),onError=function(n,i,e){return _newArrowCheck(this,_this$5),abortRequest(n,i,new Error(e))}.bind(void 0),onSubscriptionResponse=function(n,i,e){_newArrowCheck(this,_this$5),e.errors?onError(n,i,utilsGraphql.errorsToString(e.errors)):onSubscriptionSucceed(n,i,e)}.bind(void 0),onQueryOrMutationResponse=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Result",e.payload.result)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$5),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send=function(n,i,e){return _newArrowCheck(this,_this$5),handlePush(n.channel.push("doc",i),createPushHandler(e,n,i))}.bind(void 0),pushRequest=function(n,i){_newArrowCheck(this,_this$5),"subscription"===i.operationType?send(n,i.request,subcriptionHandler):(notifyStart(i),send(n,i.request,queryOrMutationHandler))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$1),{onError:function(i){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this$1),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$1),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(n,i){_newArrowCheck(this,_this),updateNotifiers(n,remove$1(i)),notify(i,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"mutation"===i.operationType?mutationOnConnectionClose(n,i):notify(i,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),0!==n.notifiers.length&&(n.isJoining=!0,n.notifiers.forEach(notifierOnConnectionClose(n)))}.bind(this)}.bind(void 0),onSubscriptionData=function(n,i){var e=i.payload;_newArrowCheck(this,_this);var t=find(n.notifiers,"subscriptionId",e.subscriptionId);t&¬ify(t,"Result",e.result)}.bind(void 0),onMessage=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"subscription:data"===i.event&&onSubscriptionData(n,i)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(n){_newArrowCheck(this,_this),0===n.notifiers.length?n.isJoining=!1:joinChannel(n)}.bind(void 0),onConnectionOpen=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),n.isJoining&&joinChannelIfNeeded(n)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(n){_newArrowCheck(this,_this);var i={phoenixSocket:n,channel:n.channel(absintheChannelName),isJoining:!1,notifiers:[]};return n.onOpen(onConnectionOpen(i)),n.onMessage(onMessage(i)),n.onClose(onConnectionClose(i)),i}.bind(void 0);module.exports=create; | ||
| //# sourceMappingURL=create.js.map |
@@ -1,2 +0,2 @@ | ||
| "use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}Object.defineProperty(exports,"__esModule",{value:!0});var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsComposite=require("@jumpn/utils-composite");require("phoenix");var utilsArray=require("@jumpn/utils-array"),_extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),_toConsumableArray=_interopDefault(require("babel-runtime/helpers/toConsumableArray")),_objectWithoutProperties=_interopDefault(require("babel-runtime/helpers/objectWithoutProperties")),Observable=_interopDefault(require("zen-observable")),_this$2=void 0,find=function(e,n,i){return _newArrowCheck(this,_this$2),e.find(utilsComposite.hasIn([n],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(e,n){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$1);var s=find(e.notifiers,"request",n);s&&i.apply(void 0,[e,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(e,n,i){return _newArrowCheck(this,_this$1),utilsComposite.map(createEventHandler(n,i),e)}.bind(void 0),_this$3=void 0,handlePush=function(e,n){return _newArrowCheck(this,_this$3),e.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(e,n){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[e]&&i[e](n)}.bind(this)}.bind(void 0),getHandlerName=function(e){return _newArrowCheck(this,_this$4),"on"+String(e)}.bind(void 0),notify=function(e,n,i){return _newArrowCheck(this,_this$4),e.observers.forEach(getNotifier(getHandlerName(n),i))}.bind(void 0),_this$6=void 0,findIndex=function(e,n,i){return _newArrowCheck(this,_this$6),e.findIndex(utilsComposite.hasIn([n],i))}.bind(void 0),_this$5=void 0,remove$1=function(e){return _newArrowCheck(this,_this$5),function(n){return _newArrowCheck(this,_this$5),utilsArray.remove(findIndex(n,"request",e),1,n)}.bind(this)}.bind(void 0),_this$7=void 0,updateNotifiers=function(e,n){return _newArrowCheck(this,_this$7),e.notifiers=n(e.notifiers),e}.bind(void 0),_this=void 0,removeNotifiers=function(e,n){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(n)),notify(n,"Cancel",n)}.bind(void 0),onError=function(e,n,i){_newArrowCheck(this,_this),unsubscribe(e,n),notify(n,"Error","unsubscribe: "+String(i))}.bind(void 0),onTimeout=function(e,n){return _newArrowCheck(this,_this),notify(n,"Error","unsubscribe: timeout")}.bind(void 0),notifierPushHandler={onError:onError,onTimeout:onTimeout,onSucceed:removeNotifiers},unsubscribe=function(e,n){return _newArrowCheck(this,_this),handlePush(e.channel.push("unsubscribe",{subscriptionId:n.subscriptionId}),createPushHandler(notifierPushHandler,e,n.request))}.bind(void 0),cancel=function(e,n){return _newArrowCheck(this,_this),"subscription"===n.operationType?unsubscribe(e,n):removeNotifiers(e,n),e}.bind(void 0),_this$10=void 0,notifyall=function(e,n,i){return _newArrowCheck(this,_this$10),e.forEach(function(e){return _newArrowCheck(this,_this$10),notify(e,n,i)}.bind(this))}.bind(void 0),_this$12=void 0,refresh=function(e){return _newArrowCheck(this,_this$12),function(n){return _newArrowCheck(this,_this$12),utilsArray.replace(findIndex(n,"request",e),[e],n)}.bind(this)}.bind(void 0),_this$11=void 0,onQueryOrMutationResponse=function(e,n,i){_newArrowCheck(this,_this$11),updateNotifiers(e,remove$1(n)),notify(n,"Result",i.payload.result)}.bind(void 0),notifyStart=function(e){return _newArrowCheck(this,_this$11),notify(e,"Start",e)}.bind(void 0),onSubscriptionResponse=function(e,n,i){var r=i.subscriptionId;_newArrowCheck(this,_this$11),updateNotifiers(e,refresh(_extends({},n,{subscriptionId:r}))),notifyStart(n)}.bind(void 0),onResponse=function(e,n,i){_newArrowCheck(this,_this$11),i.subscriptionId?onSubscriptionResponse(e,n,i):i.payload&&onQueryOrMutationResponse(e,n,i)}.bind(void 0),abortRequest=function(e,n,i){_newArrowCheck(this,_this$11),updateNotifiers(e,remove$1(n)),notify(n,"Abort",i)}.bind(void 0),onError$1=function(e,n,i){return _newArrowCheck(this,_this$11),abortRequest(e,n,new Error(i))}.bind(void 0),onSucceed=function(e,n,i){_newArrowCheck(this,_this$11),i.errors?onError$1(e,n,utilsGraphql.errorsToString(i.errors)):onResponse(e,n,i)}.bind(void 0),onTimeout$1=function(e,n){return _newArrowCheck(this,_this$11),notify(n,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler$1={onError:onError$1,onSucceed:onSucceed,onTimeout:onTimeout$1},pushRequest=function(e,n){_newArrowCheck(this,_this$11),"subscription"!==n.operationType&¬ifyStart(n),handlePush(e.channel.push("doc",n.request),createPushHandler(notifierPushHandler$1,e,n.request))}.bind(void 0),_this$9=void 0,createChannelJoinHandler=function(e){return _newArrowCheck(this,_this$9),{onError:function(n){return _newArrowCheck(this,_this$9),notifyall(e.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$9),e.isJoining=!1,e.notifiers.forEach(function(n){return _newArrowCheck(this,_this$9),pushRequest(e,n)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$9),notifyall(e.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(e){return _newArrowCheck(this,_this$9),handlePush(e.channel.join(),createChannelJoinHandler(e))}.bind(void 0),_this$8=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this$8),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(e,n){_newArrowCheck(this,_this$8),updateNotifiers(e,remove$1(n)),notify(n,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(e){return _newArrowCheck(this,_this$8),function(n){_newArrowCheck(this,_this$8),"mutation"===n.operationType?mutationOnConnectionClose(e,n):notify(n,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(e){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),0!==e.notifiers.length&&(e.isJoining=!0,e.notifiers.forEach(notifierOnConnectionClose(e)))}.bind(this)}.bind(void 0),onSubscriptionData=function(e,n){var i=n.payload;_newArrowCheck(this,_this$8);var r=find(e.notifiers,"subscriptionId",i.subscriptionId);r&¬ify(r,"Result",i.result)}.bind(void 0),onMessage=function(e){return _newArrowCheck(this,_this$8),function(n){_newArrowCheck(this,_this$8),"subscription:data"===n.event&&onSubscriptionData(e,n)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(e){_newArrowCheck(this,_this$8),0===e.notifiers.length?e.isJoining=!1:joinChannel(e)}.bind(void 0),onConnectionOpen=function(e){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),e.isJoining&&joinChannelIfNeeded(e)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(e){_newArrowCheck(this,_this$8);var n={phoenixSocket:e,channel:e.channel(absintheChannelName),isJoining:!1,notifiers:[]};return e.onOpen(onConnectionOpen(n)),e.onMessage(onMessage(n)),e.onClose(onConnectionClose(n)),n}.bind(void 0),_this$14=void 0,observe$2=function(e,n){var i=e.observers,r=_objectWithoutProperties(e,["observers"]);return _newArrowCheck(this,_this$14),_extends({},r,{observers:[].concat(_toConsumableArray(i),[n])})}.bind(void 0),_this$13=void 0,observe=function(e,n,i){return _newArrowCheck(this,_this$13),updateNotifiers(e,refresh(observe$2(n,i)))}.bind(void 0),_this$16=void 0,create$2=function(e){return _newArrowCheck(this,_this$16),{request:e,observers:[],operationType:utilsGraphql.getOperationType(e.operation),subscriptionId:void 0}}.bind(void 0),_this$15=void 0,connectOrJoin=function(e){_newArrowCheck(this,_this$15),e.isJoining=!0,e.phoenixSocket.isConnected()?joinChannel(e):e.phoenixSocket.connect()}.bind(void 0),isJoined=function(e){return _newArrowCheck(this,_this$15),e.phoenixSocket.isConnected()&&!e.isJoining}.bind(void 0),send=function(e,n){_newArrowCheck(this,_this$15);var i=create$2(n);return updateNotifiers(e,utilsArray.append([i])),isJoined(e)?pushRequest(e,i):connectOrJoin(e),i}.bind(void 0),_this$17=void 0,onResult=function(e,n){return _newArrowCheck(this,_this$17),function(i){_newArrowCheck(this,_this$17),n.next(i),"subscription"!==e.operationType&&n.complete()}.bind(this)}.bind(void 0),toObservable=function(e,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},r=i.onError,t=i.onStart,o=i.unsubscribe;return _newArrowCheck(this,_this$17),new Observable(function(i){return _newArrowCheck(this,_this$17),observe(e,n,{onError:r,onStart:t,onAbort:i.error,onresult:onResult(n,i)}),o}.bind(this))}.bind(void 0),_this$19=void 0,unobserve$2=function(e,n){var i=e.observers,r=_objectWithoutProperties(e,["observers"]);return _newArrowCheck(this,_this$19),_extends({},r,{observers:utilsArray.remove(i.indexOf(n),1,i)})}.bind(void 0),_this$18=void 0,unobserve=function(e,n,i){return _newArrowCheck(this,_this$18),updateNotifiers(e,refresh(unobserve$2(n,i))),e}.bind(void 0);exports.cancel=cancel,exports.create=create,exports.observe=observe,exports.send=send,exports.toObservable=toObservable,exports.unobserve=unobserve; | ||
| "use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}Object.defineProperty(exports,"__esModule",{value:!0});var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsComposite=require("@jumpn/utils-composite");require("phoenix");var utilsArray=require("@jumpn/utils-array"),_extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),_toConsumableArray=_interopDefault(require("babel-runtime/helpers/toConsumableArray")),_objectWithoutProperties=_interopDefault(require("babel-runtime/helpers/objectWithoutProperties")),Observable=_interopDefault(require("zen-observable")),_this$2=void 0,find=function(e,n,i){return _newArrowCheck(this,_this$2),e.find(utilsComposite.hasIn([n],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(e,n){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$1);var s=find(e.notifiers,"request",n);s&&i.apply(void 0,[e,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(e,n,i){return _newArrowCheck(this,_this$1),utilsComposite.map(createEventHandler(n,i),e)}.bind(void 0),_this$3=void 0,handlePush=function(e,n){return _newArrowCheck(this,_this$3),e.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(e,n){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[e]&&i[e](n)}.bind(this)}.bind(void 0),getHandlerName=function(e){return _newArrowCheck(this,_this$4),"on"+String(e)}.bind(void 0),notify=function(e,n,i){return _newArrowCheck(this,_this$4),e.observers.forEach(getNotifier(getHandlerName(n),i))}.bind(void 0),_this$6=void 0,findIndex=function(e,n,i){return _newArrowCheck(this,_this$6),e.findIndex(utilsComposite.hasIn([n],i))}.bind(void 0),_this$5=void 0,remove$1=function(e){return _newArrowCheck(this,_this$5),function(n){return _newArrowCheck(this,_this$5),utilsArray.remove(findIndex(n,"request",e),1,n)}.bind(this)}.bind(void 0),_this$7=void 0,updateNotifiers=function(e,n){return _newArrowCheck(this,_this$7),e.notifiers=n(e.notifiers),e}.bind(void 0),_this=void 0,removeNotifiers=function(e,n){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(n)),notify(n,"Cancel",n)}.bind(void 0),onError=function(e,n,i){_newArrowCheck(this,_this),unsubscribe(e,n),notify(n,"Error","unsubscribe: "+String(i))}.bind(void 0),onTimeout=function(e,n){return _newArrowCheck(this,_this),notify(n,"Error","unsubscribe: timeout")}.bind(void 0),notifierPushHandler={onError:onError,onTimeout:onTimeout,onSucceed:removeNotifiers},unsubscribe=function(e,n){return _newArrowCheck(this,_this),handlePush(e.channel.push("unsubscribe",{subscriptionId:n.subscriptionId}),createPushHandler(notifierPushHandler,e,n.request))}.bind(void 0),cancel=function(e,n){return _newArrowCheck(this,_this),"subscription"===n.operationType?unsubscribe(e,n):removeNotifiers(e,n),e}.bind(void 0),_this$10=void 0,notifyall=function(e,n,i){return _newArrowCheck(this,_this$10),e.forEach(function(e){return _newArrowCheck(this,_this$10),notify(e,n,i)}.bind(this))}.bind(void 0),_this$12=void 0,refresh=function(e){return _newArrowCheck(this,_this$12),function(n){return _newArrowCheck(this,_this$12),utilsArray.replace(findIndex(n,"request",e),[e],n)}.bind(this)}.bind(void 0),_this$11=void 0,notifyStart=function(e){return _newArrowCheck(this,_this$11),notify(e,"Start",e)}.bind(void 0),onSubscriptionSucceed=function(e,n,i){var r=i.subscriptionId;_newArrowCheck(this,_this$11),updateNotifiers(e,refresh(_extends({},n,{subscriptionId:r}))),notifyStart(n)}.bind(void 0),abortRequest=function(e,n,i){_newArrowCheck(this,_this$11),updateNotifiers(e,remove$1(n)),notify(n,"Abort",i)}.bind(void 0),onError$1=function(e,n,i){return _newArrowCheck(this,_this$11),abortRequest(e,n,new Error(i))}.bind(void 0),onSubscriptionResponse=function(e,n,i){_newArrowCheck(this,_this$11),i.errors?onError$1(e,n,utilsGraphql.errorsToString(i.errors)):onSubscriptionSucceed(e,n,i)}.bind(void 0),onQueryOrMutationResponse=function(e,n,i){_newArrowCheck(this,_this$11),updateNotifiers(e,remove$1(n)),notify(n,"Result",i.payload.result)}.bind(void 0),onTimeout$1=function(e,n){return _newArrowCheck(this,_this$11),notify(n,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError$1,onTimeout:onTimeout$1,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError$1,onTimeout:onTimeout$1,onSucceed:onSubscriptionResponse},send=function(e,n,i){return _newArrowCheck(this,_this$11),handlePush(e.channel.push("doc",n),createPushHandler(i,e,n))}.bind(void 0),pushRequest=function(e,n){_newArrowCheck(this,_this$11),"subscription"===n.operationType?send(e,n.request,subcriptionHandler):(notifyStart(n),send(e,n.request,queryOrMutationHandler))}.bind(void 0),_this$9=void 0,createChannelJoinHandler=function(e){return _newArrowCheck(this,_this$9),{onError:function(n){return _newArrowCheck(this,_this$9),notifyall(e.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$9),e.isJoining=!1,e.notifiers.forEach(function(n){return _newArrowCheck(this,_this$9),pushRequest(e,n)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$9),notifyall(e.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(e){return _newArrowCheck(this,_this$9),handlePush(e.channel.join(),createChannelJoinHandler(e))}.bind(void 0),_this$8=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this$8),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(e,n){_newArrowCheck(this,_this$8),updateNotifiers(e,remove$1(n)),notify(n,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(e){return _newArrowCheck(this,_this$8),function(n){_newArrowCheck(this,_this$8),"mutation"===n.operationType?mutationOnConnectionClose(e,n):notify(n,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(e){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),0!==e.notifiers.length&&(e.isJoining=!0,e.notifiers.forEach(notifierOnConnectionClose(e)))}.bind(this)}.bind(void 0),onSubscriptionData=function(e,n){var i=n.payload;_newArrowCheck(this,_this$8);var r=find(e.notifiers,"subscriptionId",i.subscriptionId);r&¬ify(r,"Result",i.result)}.bind(void 0),onMessage=function(e){return _newArrowCheck(this,_this$8),function(n){_newArrowCheck(this,_this$8),"subscription:data"===n.event&&onSubscriptionData(e,n)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(e){_newArrowCheck(this,_this$8),0===e.notifiers.length?e.isJoining=!1:joinChannel(e)}.bind(void 0),onConnectionOpen=function(e){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),e.isJoining&&joinChannelIfNeeded(e)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(e){_newArrowCheck(this,_this$8);var n={phoenixSocket:e,channel:e.channel(absintheChannelName),isJoining:!1,notifiers:[]};return e.onOpen(onConnectionOpen(n)),e.onMessage(onMessage(n)),e.onClose(onConnectionClose(n)),n}.bind(void 0),_this$14=void 0,observe$2=function(e,n){var i=e.observers,r=_objectWithoutProperties(e,["observers"]);return _newArrowCheck(this,_this$14),_extends({},r,{observers:[].concat(_toConsumableArray(i),[n])})}.bind(void 0),_this$13=void 0,observe=function(e,n,i){return _newArrowCheck(this,_this$13),updateNotifiers(e,refresh(observe$2(n,i)))}.bind(void 0),_this$16=void 0,create$2=function(e){return _newArrowCheck(this,_this$16),{request:e,observers:[],operationType:utilsGraphql.getOperationType(e.operation),subscriptionId:void 0}}.bind(void 0),_this$15=void 0,connectOrJoin=function(e){_newArrowCheck(this,_this$15),e.isJoining=!0,e.phoenixSocket.isConnected()?joinChannel(e):e.phoenixSocket.connect()}.bind(void 0),isJoined=function(e){return _newArrowCheck(this,_this$15),e.phoenixSocket.isConnected()&&!e.isJoining}.bind(void 0),send$1=function(e,n){_newArrowCheck(this,_this$15);var i=create$2(n);return updateNotifiers(e,utilsArray.append([i])),isJoined(e)?pushRequest(e,i):connectOrJoin(e),i}.bind(void 0),_this$17=void 0,onResult=function(e,n){return _newArrowCheck(this,_this$17),function(i){_newArrowCheck(this,_this$17),n.next(i),"subscription"!==e.operationType&&n.complete()}.bind(this)}.bind(void 0),toObservable=function(e,n){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},r=i.onError,t=i.onStart,o=i.unsubscribe;return _newArrowCheck(this,_this$17),new Observable(function(i){return _newArrowCheck(this,_this$17),observe(e,n,{onError:r,onStart:t,onAbort:i.error,onresult:onResult(n,i)}),o}.bind(this))}.bind(void 0),_this$19=void 0,unobserve$2=function(e,n){var i=e.observers,r=_objectWithoutProperties(e,["observers"]);return _newArrowCheck(this,_this$19),_extends({},r,{observers:utilsArray.remove(i.indexOf(n),1,i)})}.bind(void 0),_this$18=void 0,unobserve=function(e,n,i){return _newArrowCheck(this,_this$18),updateNotifiers(e,refresh(unobserve$2(n,i))),e}.bind(void 0);exports.cancel=cancel,exports.create=create,exports.observe=observe,exports.send=send$1,exports.toObservable=toObservable,exports.unobserve=unobserve; | ||
| //# sourceMappingURL=index.js.map |
@@ -1,2 +0,2 @@ | ||
| "use strict";function _interopDefault(i){return i&&"object"==typeof i&&"default"in i?i.default:i}var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck"));require("phoenix");var _extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite"),utilsArray=require("@jumpn/utils-array"),_this$1=void 0,handlePush=function(i,n){return _newArrowCheck(this,_this$1),i.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),_this$3=void 0,getNotifier=function(i,n){return _newArrowCheck(this,_this$3),function(e){return _newArrowCheck(this,_this$3),e[i]&&e[i](n)}.bind(this)}.bind(void 0),getHandlerName=function(i){return _newArrowCheck(this,_this$3),"on"+String(i)}.bind(void 0),notify=function(i,n,e){return _newArrowCheck(this,_this$3),i.observers.forEach(getNotifier(getHandlerName(n),e))}.bind(void 0),_this$2=void 0,notifyall=function(i,n,e){return _newArrowCheck(this,_this$2),i.forEach(function(i){return _newArrowCheck(this,_this$2),notify(i,n,e)}.bind(this))}.bind(void 0),_this$6=void 0,find=function(i,n,e){return _newArrowCheck(this,_this$6),i.find(utilsComposite.hasIn([n],e))}.bind(void 0),_this$5=void 0,createEventHandler=function(i,n){return _newArrowCheck(this,_this$5),function(e){return _newArrowCheck(this,_this$5),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$5);var s=find(i.notifiers,"request",n);s&&e.apply(void 0,[i,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(i,n,e){return _newArrowCheck(this,_this$5),utilsComposite.map(createEventHandler(n,e),i)}.bind(void 0),_this$8=void 0,findIndex=function(i,n,e){return _newArrowCheck(this,_this$8),i.findIndex(utilsComposite.hasIn([n],e))}.bind(void 0),_this$7=void 0,remove$1=function(i){return _newArrowCheck(this,_this$7),function(n){return _newArrowCheck(this,_this$7),utilsArray.remove(findIndex(n,"request",i),1,n)}.bind(this)}.bind(void 0),_this$9=void 0,refresh=function(i){return _newArrowCheck(this,_this$9),function(n){return _newArrowCheck(this,_this$9),utilsArray.replace(findIndex(n,"request",i),[i],n)}.bind(this)}.bind(void 0),_this$10=void 0,updateNotifiers=function(i,n){return _newArrowCheck(this,_this$10),i.notifiers=n(i.notifiers),i}.bind(void 0),_this$4=void 0,onQueryOrMutationResponse=function(i,n,e){_newArrowCheck(this,_this$4),updateNotifiers(i,remove$1(n)),notify(n,"Result",e.payload.result)}.bind(void 0),notifyStart=function(i){return _newArrowCheck(this,_this$4),notify(i,"Start",i)}.bind(void 0),onSubscriptionResponse=function(i,n,e){var r=e.subscriptionId;_newArrowCheck(this,_this$4),updateNotifiers(i,refresh(_extends({},n,{subscriptionId:r}))),notifyStart(n)}.bind(void 0),onResponse=function(i,n,e){_newArrowCheck(this,_this$4),e.subscriptionId?onSubscriptionResponse(i,n,e):e.payload&&onQueryOrMutationResponse(i,n,e)}.bind(void 0),abortRequest=function(i,n,e){_newArrowCheck(this,_this$4),updateNotifiers(i,remove$1(n)),notify(n,"Abort",e)}.bind(void 0),onError=function(i,n,e){return _newArrowCheck(this,_this$4),abortRequest(i,n,new Error(e))}.bind(void 0),onSucceed=function(i,n,e){_newArrowCheck(this,_this$4),e.errors?onError(i,n,utilsGraphql.errorsToString(e.errors)):onResponse(i,n,e)}.bind(void 0),onTimeout=function(i,n){return _newArrowCheck(this,_this$4),notify(n,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(i,n){_newArrowCheck(this,_this$4),"subscription"!==n.operationType&¬ifyStart(n),handlePush(i.channel.push("doc",n.request),createPushHandler(notifierPushHandler,i,n.request))}.bind(void 0),_this=void 0,createChannelJoinHandler=function(i){return _newArrowCheck(this,_this),{onError:function(n){return _newArrowCheck(this,_this),notifyall(i.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this),i.isJoining=!1,i.notifiers.forEach(function(n){return _newArrowCheck(this,_this),pushRequest(i,n)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this),notifyall(i.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(i){return _newArrowCheck(this,_this),handlePush(i.channel.join(),createChannelJoinHandler(i))}.bind(void 0);module.exports=joinChannel; | ||
| "use strict";function _interopDefault(i){return i&&"object"==typeof i&&"default"in i?i.default:i}var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck"));require("phoenix");var _extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite"),utilsArray=require("@jumpn/utils-array"),_this$1=void 0,handlePush=function(i,n){return _newArrowCheck(this,_this$1),i.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),_this$3=void 0,getNotifier=function(i,n){return _newArrowCheck(this,_this$3),function(r){return _newArrowCheck(this,_this$3),r[i]&&r[i](n)}.bind(this)}.bind(void 0),getHandlerName=function(i){return _newArrowCheck(this,_this$3),"on"+String(i)}.bind(void 0),notify=function(i,n,r){return _newArrowCheck(this,_this$3),i.observers.forEach(getNotifier(getHandlerName(n),r))}.bind(void 0),_this$2=void 0,notifyall=function(i,n,r){return _newArrowCheck(this,_this$2),i.forEach(function(i){return _newArrowCheck(this,_this$2),notify(i,n,r)}.bind(this))}.bind(void 0),_this$6=void 0,find=function(i,n,r){return _newArrowCheck(this,_this$6),i.find(utilsComposite.hasIn([n],r))}.bind(void 0),_this$5=void 0,createEventHandler=function(i,n){return _newArrowCheck(this,_this$5),function(r){return _newArrowCheck(this,_this$5),function(){for(var e=arguments.length,t=Array(e),o=0;o<e;o++)t[o]=arguments[o];_newArrowCheck(this,_this$5);var s=find(i.notifiers,"request",n);s&&r.apply(void 0,[i,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(i,n,r){return _newArrowCheck(this,_this$5),utilsComposite.map(createEventHandler(n,r),i)}.bind(void 0),_this$8=void 0,findIndex=function(i,n,r){return _newArrowCheck(this,_this$8),i.findIndex(utilsComposite.hasIn([n],r))}.bind(void 0),_this$7=void 0,remove$1=function(i){return _newArrowCheck(this,_this$7),function(n){return _newArrowCheck(this,_this$7),utilsArray.remove(findIndex(n,"request",i),1,n)}.bind(this)}.bind(void 0),_this$9=void 0,refresh=function(i){return _newArrowCheck(this,_this$9),function(n){return _newArrowCheck(this,_this$9),utilsArray.replace(findIndex(n,"request",i),[i],n)}.bind(this)}.bind(void 0),_this$10=void 0,updateNotifiers=function(i,n){return _newArrowCheck(this,_this$10),i.notifiers=n(i.notifiers),i}.bind(void 0),_this$4=void 0,notifyStart=function(i){return _newArrowCheck(this,_this$4),notify(i,"Start",i)}.bind(void 0),onSubscriptionSucceed=function(i,n,r){var e=r.subscriptionId;_newArrowCheck(this,_this$4),updateNotifiers(i,refresh(_extends({},n,{subscriptionId:e}))),notifyStart(n)}.bind(void 0),abortRequest=function(i,n,r){_newArrowCheck(this,_this$4),updateNotifiers(i,remove$1(n)),notify(n,"Abort",r)}.bind(void 0),onError=function(i,n,r){return _newArrowCheck(this,_this$4),abortRequest(i,n,new Error(r))}.bind(void 0),onSubscriptionResponse=function(i,n,r){_newArrowCheck(this,_this$4),r.errors?onError(i,n,utilsGraphql.errorsToString(r.errors)):onSubscriptionSucceed(i,n,r)}.bind(void 0),onQueryOrMutationResponse=function(i,n,r){_newArrowCheck(this,_this$4),updateNotifiers(i,remove$1(n)),notify(n,"Result",r.payload.result)}.bind(void 0),onTimeout=function(i,n){return _newArrowCheck(this,_this$4),notify(n,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send=function(i,n,r){return _newArrowCheck(this,_this$4),handlePush(i.channel.push("doc",n),createPushHandler(r,i,n))}.bind(void 0),pushRequest=function(i,n){_newArrowCheck(this,_this$4),"subscription"===n.operationType?send(i,n.request,subcriptionHandler):(notifyStart(n),send(i,n.request,queryOrMutationHandler))}.bind(void 0),_this=void 0,createChannelJoinHandler=function(i){return _newArrowCheck(this,_this),{onError:function(n){return _newArrowCheck(this,_this),notifyall(i.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this),i.isJoining=!1,i.notifiers.forEach(function(n){return _newArrowCheck(this,_this),pushRequest(i,n)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this),notifyall(i.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(i){return _newArrowCheck(this,_this),handlePush(i.channel.join(),createChannelJoinHandler(i))}.bind(void 0);module.exports=joinChannel; | ||
| //# sourceMappingURL=joinChannel.js.map |
@@ -1,2 +0,2 @@ | ||
| "use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}var _extends=_interopDefault(require("babel-runtime/helpers/extends")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite");require("phoenix");var utilsArray=require("@jumpn/utils-array"),_this$2=void 0,find=function(e,i,r){return _newArrowCheck(this,_this$2),e.find(utilsComposite.hasIn([i],r))}.bind(void 0),_this$1=void 0,createEventHandler=function(e,i){return _newArrowCheck(this,_this$1),function(r){return _newArrowCheck(this,_this$1),function(){for(var t=arguments.length,n=Array(t),o=0;o<t;o++)n[o]=arguments[o];_newArrowCheck(this,_this$1);var s=find(e.notifiers,"request",i);s&&r.apply(void 0,[e,s].concat(n))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(e,i,r){return _newArrowCheck(this,_this$1),utilsComposite.map(createEventHandler(i,r),e)}.bind(void 0),_this$3=void 0,handlePush=function(e,i){return _newArrowCheck(this,_this$3),e.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(e,i){return _newArrowCheck(this,_this$4),function(r){return _newArrowCheck(this,_this$4),r[e]&&r[e](i)}.bind(this)}.bind(void 0),getHandlerName=function(e){return _newArrowCheck(this,_this$4),"on"+String(e)}.bind(void 0),notify=function(e,i,r){return _newArrowCheck(this,_this$4),e.observers.forEach(getNotifier(getHandlerName(i),r))}.bind(void 0),_this$6=void 0,findIndex=function(e,i,r){return _newArrowCheck(this,_this$6),e.findIndex(utilsComposite.hasIn([i],r))}.bind(void 0),_this$5=void 0,remove$1=function(e){return _newArrowCheck(this,_this$5),function(i){return _newArrowCheck(this,_this$5),utilsArray.remove(findIndex(i,"request",e),1,i)}.bind(this)}.bind(void 0),_this$7=void 0,refresh=function(e){return _newArrowCheck(this,_this$7),function(i){return _newArrowCheck(this,_this$7),utilsArray.replace(findIndex(i,"request",e),[e],i)}.bind(this)}.bind(void 0),_this$8=void 0,updateNotifiers=function(e,i){return _newArrowCheck(this,_this$8),e.notifiers=i(e.notifiers),e}.bind(void 0),_this=void 0,onQueryOrMutationResponse=function(e,i,r){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(i)),notify(i,"Result",r.payload.result)}.bind(void 0),notifyStart=function(e){return _newArrowCheck(this,_this),notify(e,"Start",e)}.bind(void 0),onSubscriptionResponse=function(e,i,r){var t=r.subscriptionId;_newArrowCheck(this,_this),updateNotifiers(e,refresh(_extends({},i,{subscriptionId:t}))),notifyStart(i)}.bind(void 0),onResponse=function(e,i,r){_newArrowCheck(this,_this),r.subscriptionId?onSubscriptionResponse(e,i,r):r.payload&&onQueryOrMutationResponse(e,i,r)}.bind(void 0),abortRequest=function(e,i,r){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(i)),notify(i,"Abort",r)}.bind(void 0),onError=function(e,i,r){return _newArrowCheck(this,_this),abortRequest(e,i,new Error(r))}.bind(void 0),onSucceed=function(e,i,r){_newArrowCheck(this,_this),r.errors?onError(e,i,utilsGraphql.errorsToString(r.errors)):onResponse(e,i,r)}.bind(void 0),onTimeout=function(e,i){return _newArrowCheck(this,_this),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(e,i){_newArrowCheck(this,_this),"subscription"!==i.operationType&¬ifyStart(i),handlePush(e.channel.push("doc",i.request),createPushHandler(notifierPushHandler,e,i.request))}.bind(void 0);module.exports=pushRequest; | ||
| "use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}var _extends=_interopDefault(require("babel-runtime/helpers/extends")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite");require("phoenix");var utilsArray=require("@jumpn/utils-array"),_this$2=void 0,find=function(e,r,i){return _newArrowCheck(this,_this$2),e.find(utilsComposite.hasIn([r],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(e,r){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var t=arguments.length,n=Array(t),o=0;o<t;o++)n[o]=arguments[o];_newArrowCheck(this,_this$1);var s=find(e.notifiers,"request",r);s&&i.apply(void 0,[e,s].concat(n))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(e,r,i){return _newArrowCheck(this,_this$1),utilsComposite.map(createEventHandler(r,i),e)}.bind(void 0),_this$3=void 0,handlePush=function(e,r){return _newArrowCheck(this,_this$3),e.receive("ok",r.onSucceed).receive("error",r.onError).receive("timeout",r.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(e,r){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[e]&&i[e](r)}.bind(this)}.bind(void 0),getHandlerName=function(e){return _newArrowCheck(this,_this$4),"on"+String(e)}.bind(void 0),notify=function(e,r,i){return _newArrowCheck(this,_this$4),e.observers.forEach(getNotifier(getHandlerName(r),i))}.bind(void 0),_this$6=void 0,findIndex=function(e,r,i){return _newArrowCheck(this,_this$6),e.findIndex(utilsComposite.hasIn([r],i))}.bind(void 0),_this$5=void 0,remove$1=function(e){return _newArrowCheck(this,_this$5),function(r){return _newArrowCheck(this,_this$5),utilsArray.remove(findIndex(r,"request",e),1,r)}.bind(this)}.bind(void 0),_this$7=void 0,refresh=function(e){return _newArrowCheck(this,_this$7),function(r){return _newArrowCheck(this,_this$7),utilsArray.replace(findIndex(r,"request",e),[e],r)}.bind(this)}.bind(void 0),_this$8=void 0,updateNotifiers=function(e,r){return _newArrowCheck(this,_this$8),e.notifiers=r(e.notifiers),e}.bind(void 0),_this=void 0,notifyStart=function(e){return _newArrowCheck(this,_this),notify(e,"Start",e)}.bind(void 0),onSubscriptionSucceed=function(e,r,i){var t=i.subscriptionId;_newArrowCheck(this,_this),updateNotifiers(e,refresh(_extends({},r,{subscriptionId:t}))),notifyStart(r)}.bind(void 0),abortRequest=function(e,r,i){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(r)),notify(r,"Abort",i)}.bind(void 0),onError=function(e,r,i){return _newArrowCheck(this,_this),abortRequest(e,r,new Error(i))}.bind(void 0),onSubscriptionResponse=function(e,r,i){_newArrowCheck(this,_this),i.errors?onError(e,r,utilsGraphql.errorsToString(i.errors)):onSubscriptionSucceed(e,r,i)}.bind(void 0),onQueryOrMutationResponse=function(e,r,i){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(r)),notify(r,"Result",i.payload.result)}.bind(void 0),onTimeout=function(e,r){return _newArrowCheck(this,_this),notify(r,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send=function(e,r,i){return _newArrowCheck(this,_this),handlePush(e.channel.push("doc",r),createPushHandler(i,e,r))}.bind(void 0),pushRequest=function(e,r){_newArrowCheck(this,_this),"subscription"===r.operationType?send(e,r.request,subcriptionHandler):(notifyStart(r),send(e,r.request,queryOrMutationHandler))}.bind(void 0);module.exports=pushRequest; | ||
| //# sourceMappingURL=pushRequest.js.map |
@@ -1,2 +0,2 @@ | ||
| "use strict";function _interopDefault(i){return i&&"object"==typeof i&&"default"in i?i.default:i}var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsArray=require("@jumpn/utils-array");require("phoenix");var _extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite"),_this$2=void 0,handlePush=function(i,n){return _newArrowCheck(this,_this$2),i.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(i,n){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[i]&&e[i](n)}.bind(this)}.bind(void 0),getHandlerName=function(i){return _newArrowCheck(this,_this$4),"on"+String(i)}.bind(void 0),notify=function(i,n,e){return _newArrowCheck(this,_this$4),i.observers.forEach(getNotifier(getHandlerName(n),e))}.bind(void 0),_this$3=void 0,notifyall=function(i,n,e){return _newArrowCheck(this,_this$3),i.forEach(function(i){return _newArrowCheck(this,_this$3),notify(i,n,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(i,n,e){return _newArrowCheck(this,_this$7),i.find(utilsComposite.hasIn([n],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(i,n){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(i.notifiers,"request",n);s&&e.apply(void 0,[i,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(i,n,e){return _newArrowCheck(this,_this$6),utilsComposite.map(createEventHandler(n,e),i)}.bind(void 0),_this$9=void 0,findIndex=function(i,n,e){return _newArrowCheck(this,_this$9),i.findIndex(utilsComposite.hasIn([n],e))}.bind(void 0),_this$8=void 0,remove$1=function(i){return _newArrowCheck(this,_this$8),function(n){return _newArrowCheck(this,_this$8),utilsArray.remove(findIndex(n,"request",i),1,n)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(i){return _newArrowCheck(this,_this$10),function(n){return _newArrowCheck(this,_this$10),utilsArray.replace(findIndex(n,"request",i),[i],n)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(i,n){return _newArrowCheck(this,_this$11),i.notifiers=n(i.notifiers),i}.bind(void 0),_this$5=void 0,onQueryOrMutationResponse=function(i,n,e){_newArrowCheck(this,_this$5),updateNotifiers(i,remove$1(n)),notify(n,"Result",e.payload.result)}.bind(void 0),notifyStart=function(i){return _newArrowCheck(this,_this$5),notify(i,"Start",i)}.bind(void 0),onSubscriptionResponse=function(i,n,e){var r=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(i,refresh(_extends({},n,{subscriptionId:r}))),notifyStart(n)}.bind(void 0),onResponse=function(i,n,e){_newArrowCheck(this,_this$5),e.subscriptionId?onSubscriptionResponse(i,n,e):e.payload&&onQueryOrMutationResponse(i,n,e)}.bind(void 0),abortRequest=function(i,n,e){_newArrowCheck(this,_this$5),updateNotifiers(i,remove$1(n)),notify(n,"Abort",e)}.bind(void 0),onError=function(i,n,e){return _newArrowCheck(this,_this$5),abortRequest(i,n,new Error(e))}.bind(void 0),onSucceed=function(i,n,e){_newArrowCheck(this,_this$5),e.errors?onError(i,n,utilsGraphql.errorsToString(e.errors)):onResponse(i,n,e)}.bind(void 0),onTimeout=function(i,n){return _newArrowCheck(this,_this$5),notify(n,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(i,n){_newArrowCheck(this,_this$5),"subscription"!==n.operationType&¬ifyStart(n),handlePush(i.channel.push("doc",n.request),createPushHandler(notifierPushHandler,i,n.request))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(i){return _newArrowCheck(this,_this$1),{onError:function(n){return _newArrowCheck(this,_this$1),notifyall(i.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),i.isJoining=!1,i.notifiers.forEach(function(n){return _newArrowCheck(this,_this$1),pushRequest(i,n)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(i.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(i){return _newArrowCheck(this,_this$1),handlePush(i.channel.join(),createChannelJoinHandler(i))}.bind(void 0),_this$12=void 0,create=function(i){return _newArrowCheck(this,_this$12),{request:i,observers:[],operationType:utilsGraphql.getOperationType(i.operation),subscriptionId:void 0}}.bind(void 0),_this=void 0,connectOrJoin=function(i){_newArrowCheck(this,_this),i.isJoining=!0,i.phoenixSocket.isConnected()?joinChannel(i):i.phoenixSocket.connect()}.bind(void 0),isJoined=function(i){return _newArrowCheck(this,_this),i.phoenixSocket.isConnected()&&!i.isJoining}.bind(void 0),send=function(i,n){_newArrowCheck(this,_this);var e=create(n);return updateNotifiers(i,utilsArray.append([e])),isJoined(i)?pushRequest(i,e):connectOrJoin(i),e}.bind(void 0);module.exports=send; | ||
| "use strict";function _interopDefault(i){return i&&"object"==typeof i&&"default"in i?i.default:i}var _newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsArray=require("@jumpn/utils-array");require("phoenix");var _extends=_interopDefault(require("babel-runtime/helpers/extends")),utilsGraphql=require("@jumpn/utils-graphql"),utilsComposite=require("@jumpn/utils-composite"),_this$2=void 0,handlePush=function(i,n){return _newArrowCheck(this,_this$2),i.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(i,n){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[i]&&e[i](n)}.bind(this)}.bind(void 0),getHandlerName=function(i){return _newArrowCheck(this,_this$4),"on"+String(i)}.bind(void 0),notify=function(i,n,e){return _newArrowCheck(this,_this$4),i.observers.forEach(getNotifier(getHandlerName(n),e))}.bind(void 0),_this$3=void 0,notifyall=function(i,n,e){return _newArrowCheck(this,_this$3),i.forEach(function(i){return _newArrowCheck(this,_this$3),notify(i,n,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(i,n,e){return _newArrowCheck(this,_this$7),i.find(utilsComposite.hasIn([n],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(i,n){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(i.notifiers,"request",n);s&&e.apply(void 0,[i,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(i,n,e){return _newArrowCheck(this,_this$6),utilsComposite.map(createEventHandler(n,e),i)}.bind(void 0),_this$9=void 0,findIndex=function(i,n,e){return _newArrowCheck(this,_this$9),i.findIndex(utilsComposite.hasIn([n],e))}.bind(void 0),_this$8=void 0,remove$1=function(i){return _newArrowCheck(this,_this$8),function(n){return _newArrowCheck(this,_this$8),utilsArray.remove(findIndex(n,"request",i),1,n)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(i){return _newArrowCheck(this,_this$10),function(n){return _newArrowCheck(this,_this$10),utilsArray.replace(findIndex(n,"request",i),[i],n)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(i,n){return _newArrowCheck(this,_this$11),i.notifiers=n(i.notifiers),i}.bind(void 0),_this$5=void 0,notifyStart=function(i){return _newArrowCheck(this,_this$5),notify(i,"Start",i)}.bind(void 0),onSubscriptionSucceed=function(i,n,e){var r=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(i,refresh(_extends({},n,{subscriptionId:r}))),notifyStart(n)}.bind(void 0),abortRequest=function(i,n,e){_newArrowCheck(this,_this$5),updateNotifiers(i,remove$1(n)),notify(n,"Abort",e)}.bind(void 0),onError=function(i,n,e){return _newArrowCheck(this,_this$5),abortRequest(i,n,new Error(e))}.bind(void 0),onSubscriptionResponse=function(i,n,e){_newArrowCheck(this,_this$5),e.errors?onError(i,n,utilsGraphql.errorsToString(e.errors)):onSubscriptionSucceed(i,n,e)}.bind(void 0),onQueryOrMutationResponse=function(i,n,e){_newArrowCheck(this,_this$5),updateNotifiers(i,remove$1(n)),notify(n,"Result",e.payload.result)}.bind(void 0),onTimeout=function(i,n){return _newArrowCheck(this,_this$5),notify(n,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send$2=function(i,n,e){return _newArrowCheck(this,_this$5),handlePush(i.channel.push("doc",n),createPushHandler(e,i,n))}.bind(void 0),pushRequest=function(i,n){_newArrowCheck(this,_this$5),"subscription"===n.operationType?send$2(i,n.request,subcriptionHandler):(notifyStart(n),send$2(i,n.request,queryOrMutationHandler))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(i){return _newArrowCheck(this,_this$1),{onError:function(n){return _newArrowCheck(this,_this$1),notifyall(i.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),i.isJoining=!1,i.notifiers.forEach(function(n){return _newArrowCheck(this,_this$1),pushRequest(i,n)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(i.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(i){return _newArrowCheck(this,_this$1),handlePush(i.channel.join(),createChannelJoinHandler(i))}.bind(void 0),_this$12=void 0,create=function(i){return _newArrowCheck(this,_this$12),{request:i,observers:[],operationType:utilsGraphql.getOperationType(i.operation),subscriptionId:void 0}}.bind(void 0),_this=void 0,connectOrJoin=function(i){_newArrowCheck(this,_this),i.isJoining=!0,i.phoenixSocket.isConnected()?joinChannel(i):i.phoenixSocket.connect()}.bind(void 0),isJoined=function(i){return _newArrowCheck(this,_this),i.phoenixSocket.isConnected()&&!i.isJoining}.bind(void 0),send=function(i,n){_newArrowCheck(this,_this);var e=create(n);return updateNotifiers(i,utilsArray.append([e])),isJoined(i)?pushRequest(i,e):connectOrJoin(i),e}.bind(void 0);module.exports=send; | ||
| //# sourceMappingURL=send.js.map |
@@ -1,2 +0,2 @@ | ||
| !function(t,n){"object"==typeof exports&&"undefined"!=typeof module?n(exports):"function"==typeof define&&define.amd?define(["exports"],n):n(t.AbsinthePhoenixSocket={})}(this,function(t){"use strict";function n(t){return t&&t.__esModule&&Object.prototype.hasOwnProperty.call(t,"default")?t.default:t}function e(t,n){return n={exports:{}},t(n,n.exports),n.exports}"undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self&&self;var i=n(e(function(t,n){n.__esModule=!0,n.default=function(t,n){if(t!==n)throw new TypeError("Cannot instantiate an arrow function")}})),r=e(function(t,n){function e(t,n,i){return function(){var r=i.concat(Array.prototype.slice.call(arguments));return r.length>=n?t.apply(this,r):e(t,n,r)}}Object.defineProperty(n,"__esModule",{value:!0}),n.flip=function(t){return function(n,e){return t(e,n)}},n.constant=function(t){return function(){return t}},n.on=function(t,n){return function(e,i){return t(n(e),n(i))}},n.compose=function(){for(var t=this,n=arguments.length,e=Array(n),i=0;i<n;i++)e[i]=arguments[i];var r=e.length-1;return function(n){for(var i=n,o=r;o>-1;o--)i=e[o].call(t,i);return i}},n.pipe=function(){for(var t=this,n=arguments.length,e=Array(n),i=0;i<n;i++)e[i]=arguments[i];var r=e.length-1;return function(n){for(var i=n,o=0;o<=r;o++)i=e[o].call(t,i);return i}},n.curry=function(t){return e(t,t.length,[])}});n(r);var o=r.curry,u=Math.ceil,s=Math.floor,c=function(t){return isNaN(t=+t)?0:(t>0?s:u)(t)},a=function(t){if(void 0==t)throw TypeError("Can't call method on "+t);return t},f=e(function(t){var n=t.exports="undefined"!=typeof window&&window.Math==Math?window:"undefined"!=typeof self&&self.Math==Math?self:Function("return this")();"number"==typeof __g&&(__g=n)}),l=e(function(t){var n=t.exports={version:"2.5.1"};"number"==typeof __e&&(__e=n)}),h=function(t){if("function"!=typeof t)throw TypeError(t+" is not a function!");return t},d=function(t,n,e){if(h(t),void 0===n)return t;switch(e){case 1:return function(e){return t.call(n,e)};case 2:return function(e,i){return t.call(n,e,i)};case 3:return function(e,i,r){return t.call(n,e,i,r)}}return function(){return t.apply(n,arguments)}},v=function(t){return"object"==typeof t?null!==t:"function"==typeof t},p=function(t){if(!v(t))throw TypeError(t+" is not an object!");return t},b=function(t){try{return!!t()}catch(t){return!0}},y=!b(function(){return 7!=Object.defineProperty({},"a",{get:function(){return 7}}).a}),m=f.document,g=v(m)&&v(m.createElement),w=function(t){return g?m.createElement(t):{}},k=!y&&!b(function(){return 7!=Object.defineProperty(w("div"),"a",{get:function(){return 7}}).a}),j=function(t,n){if(!v(t))return t;var e,i;if(n&&"function"==typeof(e=t.toString)&&!v(i=e.call(t)))return i;if("function"==typeof(e=t.valueOf)&&!v(i=e.call(t)))return i;if(!n&&"function"==typeof(e=t.toString)&&!v(i=e.call(t)))return i;throw TypeError("Can't convert object to primitive value")},S=Object.defineProperty,_={f:y?Object.defineProperty:function(t,n,e){if(p(t),n=j(n,!0),p(e),k)try{return S(t,n,e)}catch(t){}if("get"in e||"set"in e)throw TypeError("Accessors not supported!");return"value"in e&&(t[n]=e.value),t}},O=function(t,n){return{enumerable:!(1&t),configurable:!(2&t),writable:!(4&t),value:n}},E=y?function(t,n,e){return _.f(t,n,O(1,e))}:function(t,n,e){return t[n]=e,t},T=function(t,n,e){var i,r,o,u=t&T.F,s=t&T.G,c=t&T.S,a=t&T.P,h=t&T.B,v=t&T.W,p=s?l:l[n]||(l[n]={}),b=p.prototype,y=s?f:c?f[n]:(f[n]||{}).prototype;s&&(e=n);for(i in e)(r=!u&&y&&void 0!==y[i])&&i in p||(o=r?y[i]:e[i],p[i]=s&&"function"!=typeof y[i]?e[i]:h&&r?d(o,f):v&&y[i]==o?function(t){var n=function(n,e,i){if(this instanceof t){switch(arguments.length){case 0:return new t;case 1:return new t(n);case 2:return new t(n,e)}return new t(n,e,i)}return t.apply(this,arguments)};return n.prototype=t.prototype,n}(o):a&&"function"==typeof o?d(Function.call,o):o,a&&((p.virtual||(p.virtual={}))[i]=o,t&T.R&&b&&!b[i]&&E(b,i,o)))};T.F=1,T.G=2,T.S=4,T.P=8,T.B=16,T.W=32,T.U=64,T.R=128;var x=T,P=E,A={}.hasOwnProperty,C=function(t,n){return A.call(t,n)},M={},R={}.toString,L=function(t){return R.call(t).slice(8,-1)},I=Object("z").propertyIsEnumerable(0)?Object:function(t){return"String"==L(t)?t.split(""):Object(t)},N=function(t){return I(a(t))},J=Math.min,q=function(t){return t>0?J(c(t),9007199254740991):0},H=Math.max,F=Math.min,D=function(t,n){return(t=c(t))<0?H(t+n,0):F(t,n)},B=f["__core-js_shared__"]||(f["__core-js_shared__"]={}),U=function(t){return B[t]||(B[t]={})},G=0,z=Math.random(),V=function(t){return"Symbol(".concat(void 0===t?"":t,")_",(++G+z).toString(36))},W=U("keys"),X=function(t){return W[t]||(W[t]=V(t))},K=function(t){return function(n,e,i){var r,o=N(n),u=q(o.length),s=D(i,u);if(t&&e!=e){for(;u>s;)if((r=o[s++])!=r)return!0}else for(;u>s;s++)if((t||s in o)&&o[s]===e)return t||s||0;return!t&&-1}}(!1),Y=X("IE_PROTO"),Q=function(t,n){var e,i=N(t),r=0,o=[];for(e in i)e!=Y&&C(i,e)&&o.push(e);for(;n.length>r;)C(i,e=n[r++])&&(~K(o,e)||o.push(e));return o},$="constructor,hasOwnProperty,isPrototypeOf,propertyIsEnumerable,toLocaleString,toString,valueOf".split(","),Z=Object.keys||function(t){return Q(t,$)},tt=y?Object.defineProperties:function(t,n){p(t);for(var e,i=Z(n),r=i.length,o=0;r>o;)_.f(t,e=i[o++],n[e]);return t},nt=f.document,et=nt&&nt.documentElement,it=X("IE_PROTO"),rt=function(){},ot=function(){var t,n=w("iframe"),e=$.length;for(n.style.display="none",et.appendChild(n),n.src="javascript:",(t=n.contentWindow.document).open(),t.write("<script>document.F=Object<\/script>"),t.close(),ot=t.F;e--;)delete ot.prototype[$[e]];return ot()},ut=Object.create||function(t,n){var e;return null!==t?(rt.prototype=p(t),e=new rt,rt.prototype=null,e[it]=t):e=ot(),void 0===n?e:tt(e,n)},st=e(function(t){var n=U("wks"),e=f.Symbol,i="function"==typeof e;(t.exports=function(t){return n[t]||(n[t]=i&&e[t]||(i?e:V)("Symbol."+t))}).store=n}),ct=_.f,at=st("toStringTag"),ft=function(t,n,e){t&&!C(t=e?t:t.prototype,at)&&ct(t,at,{configurable:!0,value:n})},lt={};E(lt,st("iterator"),function(){return this});var ht=function(t,n,e){t.prototype=ut(lt,{next:O(1,e)}),ft(t,n+" Iterator")},dt=function(t){return Object(a(t))},vt=X("IE_PROTO"),pt=Object.prototype,bt=Object.getPrototypeOf||function(t){return t=dt(t),C(t,vt)?t[vt]:"function"==typeof t.constructor&&t instanceof t.constructor?t.constructor.prototype:t instanceof Object?pt:null},yt=st("iterator"),mt=!([].keys&&"next"in[].keys()),gt=function(){return this},wt=function(t,n,e,i,r,o,u){ht(e,n,i);var s,c,a,f=function(t){if(!mt&&t in v)return v[t];switch(t){case"keys":case"values":return function(){return new e(this,t)}}return function(){return new e(this,t)}},l=n+" Iterator",h="values"==r,d=!1,v=t.prototype,p=v[yt]||v["@@iterator"]||r&&v[r],b=p||f(r),y=r?h?f("entries"):b:void 0,m="Array"==n?v.entries||p:p;if(m&&(a=bt(m.call(new t)))!==Object.prototype&&a.next&&ft(a,l,!0),h&&p&&"values"!==p.name&&(d=!0,b=function(){return p.call(this)}),u&&(mt||d||!v[yt])&&E(v,yt,b),M[n]=b,M[l]=gt,r)if(s={values:h?b:f("values"),keys:o?b:f("keys"),entries:y},u)for(c in s)c in v||P(v,c,s[c]);else x(x.P+x.F*(mt||d),n,s);return s},kt=function(t){return function(n,e){var i,r,o=String(a(n)),u=c(e),s=o.length;return u<0||u>=s?t?"":void 0:(i=o.charCodeAt(u))<55296||i>56319||u+1===s||(r=o.charCodeAt(u+1))<56320||r>57343?t?o.charAt(u):i:t?o.slice(u,u+2):r-56320+(i-55296<<10)+65536}}(!0);wt(String,"String",function(t){this._t=String(t),this._i=0},function(){var t,n=this._t,e=this._i;return e>=n.length?{value:void 0,done:!0}:(t=kt(n,e),this._i+=t.length,{value:t,done:!1})});var jt=function(t,n,e,i){try{return i?n(p(e)[0],e[1]):n(e)}catch(n){var r=t.return;throw void 0!==r&&p(r.call(t)),n}},St=st("iterator"),_t=Array.prototype,Ot=function(t){return void 0!==t&&(M.Array===t||_t[St]===t)},Et=function(t,n,e){n in t?_.f(t,n,O(0,e)):t[n]=e},Tt=st("toStringTag"),xt="Arguments"==L(function(){return arguments}()),Pt=function(t,n){try{return t[n]}catch(t){}},At=function(t){var n,e,i;return void 0===t?"Undefined":null===t?"Null":"string"==typeof(e=Pt(n=Object(t),Tt))?e:xt?L(n):"Object"==(i=L(n))&&"function"==typeof n.callee?"Arguments":i},Ct=st("iterator"),Mt=l.getIteratorMethod=function(t){if(void 0!=t)return t[Ct]||t["@@iterator"]||M[At(t)]},Rt=st("iterator"),Lt=!1;try{[7][Rt]().return=function(){Lt=!0}}catch(t){}x(x.S+x.F*!function(t,n){if(!n&&!Lt)return!1;var e=!1;try{var i=[7],r=i[Rt]();r.next=function(){return{done:e=!0}},i[Rt]=function(){return r},t(i)}catch(t){}return e}(function(t){}),"Array",{from:function(t){var n,e,i,r,o=dt(t),u="function"==typeof this?this:Array,s=arguments.length,c=s>1?arguments[1]:void 0,a=void 0!==c,f=0,l=Mt(o);if(a&&(c=d(c,s>2?arguments[2]:void 0,2)),void 0==l||u==Array&&Ot(l))for(e=new u(n=q(o.length));n>f;f++)Et(e,f,a?c(o[f],f):o[f]);else for(r=l.call(o),e=new u;!(i=r.next()).done;f++)Et(e,f,a?jt(r,c,[i.value,f],!0):i.value);return e.length=f,e}});var It=l.Array.from,Nt=e(function(t){t.exports={default:It,__esModule:!0}}),Jt=n(Nt),qt=n(e(function(t,n){n.__esModule=!0;var e=function(t){return t&&t.__esModule?t:{default:t}}(Nt);n.default=function(t){if(Array.isArray(t)){for(var n=0,i=Array(t.length);n<t.length;n++)i[n]=t[n];return i}return(0,e.default)(t)}})),Ht={f:Object.getOwnPropertySymbols},Ft={f:{}.propertyIsEnumerable},Dt=Object.assign,Bt=!Dt||b(function(){var t={},n={},e=Symbol(),i="abcdefghijklmnopqrst";return t[e]=7,i.split("").forEach(function(t){n[t]=t}),7!=Dt({},t)[e]||Object.keys(Dt({},n)).join("")!=i})?function(t,n){for(var e=dt(t),i=arguments.length,r=1,o=Ht.f,u=Ft.f;i>r;)for(var s,c=I(arguments[r++]),a=o?Z(c).concat(o(c)):Z(c),f=a.length,l=0;f>l;)u.call(c,s=a[l++])&&(e[s]=c[s]);return e}:Dt;x(x.S+x.F,"Object",{assign:Bt});var Ut=l.Object.assign,Gt=e(function(t){t.exports={default:Ut,__esModule:!0}});n(Gt);var zt=n(e(function(t,n){n.__esModule=!0;var e=function(t){return t&&t.__esModule?t:{default:t}}(Gt);n.default=e.default||function(t){for(var n=1;n<arguments.length;n++){var e=arguments[n];for(var i in e)Object.prototype.hasOwnProperty.call(e,i)&&(t[i]=e[i])}return t}}));!function(t,n){var e=(l.Object||{})[t]||Object[t],i={};i[t]=n(e),x(x.S+x.F*b(function(){e(1)}),"Object",i)}("keys",function(){return function(t){return Z(dt(t))}});var Vt=l.Object.keys,Wt=n(e(function(t){t.exports={default:Vt,__esModule:!0}})),Xt=Math.floor;x(x.S,"Number",{isInteger:function(t){return!v(t)&&isFinite(t)&&Xt(t)===t}});var Kt=l.Number.isInteger,Yt=n(e(function(t){t.exports={default:Kt,__esModule:!0}})),Qt=n(e(function(t,n){n.__esModule=!0,n.default=function(t,n){var e={};for(var i in t)n.indexOf(i)>=0||Object.prototype.hasOwnProperty.call(t,i)&&(e[i]=t[i]);return e}})),$t=o(function(t,n){return i(this,void 0),[].concat(qt(n),qt(t))}.bind(void 0)),Zt=(function(t){return i(this,void 0),Array.isArray(t)?t:[t]}.bind(void 0),o(function(t,n){return i(this,void 0),n===t.length-1}.bind(void 0))),tn=(o(function(t,n){return i(this,void 0),Zt(t,n)?0:n+1}.bind(void 0)),function(t){return i(this,void 0),Math.max.apply(Math,qt(Wt(t)))+1}.bind(void 0)),nn=(function(t){return i(this,void 0),Jt("length"in t?t:zt({},t,{length:tn(t)}))}.bind(void 0),o(function(t,n,e){return i(this,void 0),[].concat(qt(e.slice(0,t)),qt(n),qt(e.slice(t+1)))}.bind(void 0)),function(t,n){return i(this,void 0),Yt(t)&&t>=n}.bind(void 0)),en=function(t){return i(this,void 0),nn(Number(t),0)}.bind(void 0),rn=(function(t){t.length;var n=Qt(t,["length"]);return i(this,void 0),Wt(n).every(en)}.bind(void 0),o(function(t,n){return i(this,void 0),[].concat(qt(t),qt(n))}.bind(void 0)),o(function(t,n,e,r){return i(this,void 0),r.reduce(function(e,r,o){return i(this,void 0),t(r,o,e)?n(e,r,o):e}.bind(this),e)}.bind(void 0)),o(function(t,n,e,r){i(this,void 0);var o=e;return r.every(function(e,r){i(this,void 0);var u=t(e,r,o);return u&&(o=n(o,e,r)),u}.bind(this)),o}.bind(void 0)),o(function(t,n,e){return i(this,void 0),[].concat(qt(e.slice(0,t)),qt(e.slice(t+n)))}.bind(void 0))),on=(o(function(t,n){return i(this,void 0),[].concat(qt(Array(t))).map(function(){return i(this,void 0),n}.bind(this))}.bind(void 0)),o(function(t,n,e){return i(this,void 0),[].concat(qt(e.slice(0,t)),qt(n),qt(e.slice(t+n.length)))}.bind(void 0)));o(function(t,n){return i(this,void 0),n<0?t.length-n:n}.bind(void 0));x(x.S+x.F*!y,"Object",{defineProperty:_.f});var un=l.Object,sn=function(t,n,e){return un.defineProperty(t,n,e)},cn=e(function(t){t.exports={default:sn,__esModule:!0}});n(cn);var an=n(e(function(t,n){n.__esModule=!0;var e=function(t){return t&&t.__esModule?t:{default:t}}(cn);n.default=function(t,n,i){return n in t?(0,e.default)(t,n,{value:i,enumerable:!0,configurable:!0,writable:!0}):t[n]=i,t}})),fn=function(t,n){return{value:n,done:!!t}};wt(Array,"Array",function(t,n){this._t=N(t),this._i=0,this._k=n},function(){var t=this._t,n=this._k,e=this._i++;return!t||e>=t.length?(this._t=void 0,fn(1)):"keys"==n?fn(0,e):"values"==n?fn(0,t[e]):fn(0,[e,t[e]])},"values");M.Arguments=M.Array;for(var ln=st("toStringTag"),hn="CSSRuleList,CSSStyleDeclaration,CSSValueList,ClientRectList,DOMRectList,DOMStringList,DOMTokenList,DataTransferItemList,FileList,HTMLAllCollection,HTMLCollection,HTMLFormElement,HTMLSelectElement,MediaList,MimeTypeArray,NamedNodeMap,NodeList,PaintRequestList,Plugin,PluginArray,SVGLengthList,SVGNumberList,SVGPathSegList,SVGPointList,SVGStringList,SVGTransformList,SourceBufferList,StyleSheetList,TextTrackCueList,TextTrackList,TouchList".split(","),dn=0;dn<hn.length;dn++){var vn=hn[dn],pn=f[vn],bn=pn&&pn.prototype;bn&&!bn[ln]&&E(bn,ln,vn),M[vn]=M.Array}var yn=st("iterator"),mn=l.isIterable=function(t){var n=Object(t);return void 0!==n[yn]||"@@iterator"in n||M.hasOwnProperty(At(n))},gn=e(function(t){t.exports={default:mn,__esModule:!0}});n(gn);var wn=l.getIterator=function(t){var n=Mt(t);if("function"!=typeof n)throw TypeError(t+" is not iterable!");return p(n.call(t))},kn=e(function(t){t.exports={default:wn,__esModule:!0}});n(kn);var jn=n(e(function(t,n){function e(t){return t&&t.__esModule?t:{default:t}}n.__esModule=!0;var i=e(gn),r=e(kn);n.default=function(){function t(t,n){var e=[],i=!0,o=!1,u=void 0;try{for(var s,c=(0,r.default)(t);!(i=(s=c.next()).done)&&(e.push(s.value),!n||e.length!==n);i=!0);}catch(t){o=!0,u=t}finally{try{!i&&c.return&&c.return()}finally{if(o)throw u}}return e}return function(n,e){if(Array.isArray(n))return n;if((0,i.default)(Object(n)))return t(n,e);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}()})),Sn=Ft.f,_n=function(t){return function(n){for(var e,i=N(n),r=Z(i),o=r.length,u=0,s=[];o>u;)Sn.call(i,e=r[u++])&&s.push(t?[e,i[e]]:i[e]);return s}}(!0);x(x.S,"Object",{entries:function(t){return _n(t)}});var On=l.Object.entries,En=n(e(function(t){t.exports={default:On,__esModule:!0}})),Tn=e(function(t){var n=V("meta"),e=_.f,i=0,r=Object.isExtensible||function(){return!0},o=!b(function(){return r(Object.preventExtensions({}))}),u=function(t){e(t,n,{value:{i:"O"+ ++i,w:{}}})},s=t.exports={KEY:n,NEED:!1,fastKey:function(t,e){if(!v(t))return"symbol"==typeof t?t:("string"==typeof t?"S":"P")+t;if(!C(t,n)){if(!r(t))return"F";if(!e)return"E";u(t)}return t[n].i},getWeak:function(t,e){if(!C(t,n)){if(!r(t))return!0;if(!e)return!1;u(t)}return t[n].w},onFreeze:function(t){return o&&s.NEED&&r(t)&&!C(t,n)&&u(t),t}}}),xn={f:st},Pn=_.f,An=function(t){var n=l.Symbol||(l.Symbol={});"_"==t.charAt(0)||t in n||Pn(n,t,{value:xn.f(t)})},Cn=function(t){var n=Z(t),e=Ht.f;if(e)for(var i,r=e(t),o=Ft.f,u=0;r.length>u;)o.call(t,i=r[u++])&&n.push(i);return n},Mn=Array.isArray||function(t){return"Array"==L(t)},Rn=$.concat("length","prototype"),Ln={f:Object.getOwnPropertyNames||function(t){return Q(t,Rn)}},In=Ln.f,Nn={}.toString,Jn="object"==typeof window&&window&&Object.getOwnPropertyNames?Object.getOwnPropertyNames(window):[],qn=function(t){try{return In(t)}catch(t){return Jn.slice()}},Hn={f:function(t){return Jn&&"[object Window]"==Nn.call(t)?qn(t):In(N(t))}},Fn=Object.getOwnPropertyDescriptor,Dn={f:y?Fn:function(t,n){if(t=N(t),n=j(n,!0),k)try{return Fn(t,n)}catch(t){}if(C(t,n))return O(!Ft.f.call(t,n),t[n])}},Bn=Tn.KEY,Un=Dn.f,Gn=_.f,zn=Hn.f,Vn=f.Symbol,Wn=f.JSON,Xn=Wn&&Wn.stringify,Kn=st("_hidden"),Yn=st("toPrimitive"),Qn={}.propertyIsEnumerable,$n=U("symbol-registry"),Zn=U("symbols"),te=U("op-symbols"),ne=Object.prototype,ee="function"==typeof Vn,ie=f.QObject,re=!ie||!ie.prototype||!ie.prototype.findChild,oe=y&&b(function(){return 7!=ut(Gn({},"a",{get:function(){return Gn(this,"a",{value:7}).a}})).a})?function(t,n,e){var i=Un(ne,n);i&&delete ne[n],Gn(t,n,e),i&&t!==ne&&Gn(ne,n,i)}:Gn,ue=function(t){var n=Zn[t]=ut(Vn.prototype);return n._k=t,n},se=ee&&"symbol"==typeof Vn.iterator?function(t){return"symbol"==typeof t}:function(t){return t instanceof Vn},ce=function(t,n,e){return t===ne&&ce(te,n,e),p(t),n=j(n,!0),p(e),C(Zn,n)?(e.enumerable?(C(t,Kn)&&t[Kn][n]&&(t[Kn][n]=!1),e=ut(e,{enumerable:O(0,!1)})):(C(t,Kn)||Gn(t,Kn,O(1,{})),t[Kn][n]=!0),oe(t,n,e)):Gn(t,n,e)},ae=function(t,n){p(t);for(var e,i=Cn(n=N(n)),r=0,o=i.length;o>r;)ce(t,e=i[r++],n[e]);return t},fe=function(t){var n=Qn.call(this,t=j(t,!0));return!(this===ne&&C(Zn,t)&&!C(te,t))&&(!(n||!C(this,t)||!C(Zn,t)||C(this,Kn)&&this[Kn][t])||n)},le=function(t,n){if(t=N(t),n=j(n,!0),t!==ne||!C(Zn,n)||C(te,n)){var e=Un(t,n);return!e||!C(Zn,n)||C(t,Kn)&&t[Kn][n]||(e.enumerable=!0),e}},he=function(t){for(var n,e=zn(N(t)),i=[],r=0;e.length>r;)C(Zn,n=e[r++])||n==Kn||n==Bn||i.push(n);return i},de=function(t){for(var n,e=t===ne,i=zn(e?te:N(t)),r=[],o=0;i.length>o;)!C(Zn,n=i[o++])||e&&!C(ne,n)||r.push(Zn[n]);return r};ee||(P((Vn=function(){if(this instanceof Vn)throw TypeError("Symbol is not a constructor!");var t=V(arguments.length>0?arguments[0]:void 0),n=function(e){this===ne&&n.call(te,e),C(this,Kn)&&C(this[Kn],t)&&(this[Kn][t]=!1),oe(this,t,O(1,e))};return y&&re&&oe(ne,t,{configurable:!0,set:n}),ue(t)}).prototype,"toString",function(){return this._k}),Dn.f=le,_.f=ce,Ln.f=Hn.f=he,Ft.f=fe,Ht.f=de,xn.f=function(t){return ue(st(t))}),x(x.G+x.W+x.F*!ee,{Symbol:Vn});for(var ve="hasInstance,isConcatSpreadable,iterator,match,replace,search,species,split,toPrimitive,toStringTag,unscopables".split(","),pe=0;ve.length>pe;)st(ve[pe++]);for(var be=Z(st.store),ye=0;be.length>ye;)An(be[ye++]);x(x.S+x.F*!ee,"Symbol",{for:function(t){return C($n,t+="")?$n[t]:$n[t]=Vn(t)},keyFor:function(t){if(!se(t))throw TypeError(t+" is not a symbol!");for(var n in $n)if($n[n]===t)return n},useSetter:function(){re=!0},useSimple:function(){re=!1}}),x(x.S+x.F*!ee,"Object",{create:function(t,n){return void 0===n?ut(t):ae(ut(t),n)},defineProperty:ce,defineProperties:ae,getOwnPropertyDescriptor:le,getOwnPropertyNames:he,getOwnPropertySymbols:de}),Wn&&x(x.S+x.F*(!ee||b(function(){var t=Vn();return"[null]"!=Xn([t])||"{}"!=Xn({a:t})||"{}"!=Xn(Object(t))})),"JSON",{stringify:function(t){if(void 0!==t&&!se(t)){for(var n,e,i=[t],r=1;arguments.length>r;)i.push(arguments[r++]);return"function"==typeof(n=i[1])&&(e=n),!e&&Mn(n)||(n=function(t,n){if(e&&(n=e.call(this,t,n)),!se(n))return n}),i[1]=n,Xn.apply(Wn,i)}}}),Vn.prototype[Yn]||E(Vn.prototype,Yn,Vn.prototype.valueOf),ft(Vn,"Symbol"),ft(Math,"Math",!0),ft(f.JSON,"JSON",!0),An("asyncIterator"),An("observable");var me=l.Symbol,ge=n(e(function(t){t.exports={default:me,__esModule:!0}})),we=o(function(t,n){return i(this,void 0),n[t]}.bind(void 0)),ke=o(function(t,n){return i(this,void 0),Object.prototype.hasOwnProperty.call(n,t)}.bind(void 0)),je=function(t,n,e){return i(this,void 0),Zt(n,t)?we(n[t],e):ke(n[t],e)?je(t+1,n,we(n[t],e)):void 0}.bind(void 0),Se=o(function(t,n){return i(this,void 0),0===t.length?void 0:je(0,t,n)}.bind(void 0)),_e=function(t){return i(this,void 0),Array.isArray(t)?[].concat(qt(t.keys())):Wt(t)}.bind(void 0),Oe=o(function(t,n,e){return i(this,void 0),Se(t,e)===n}.bind(void 0)),Ee=o(function(t,n){i(this,void 0);var e=_e(t);return e.length===_e(n).length&&e.every(function(e){return i(this,void 0),ke(e,n)&&we(e,t)===we(e,n)}.bind(this))}.bind(void 0)),Te=function(t,n){return i(this,void 0),En(n).reduce(function(e,r){var o=jn(r,2),u=o[0],s=o[1];return i(this,void 0),zt({},e,an({},u,t(s,u,n)))}.bind(this),{})}.bind(void 0),xe=o(function(t,n){return i(this,void 0),Array.isArray(n)?n.map(t):Te(t,n)}.bind(void 0)),Pe=function(t,n){n[t];var e=Qt(n,[t]);return i(this,void 0),e}.bind(void 0),Ae=o(function(t,n){return i(this,void 0),Array.isArray(n)?rn(t,1,n):Pe(t,n)}.bind(void 0)),Ce=function(t){return i(this,void 0),Array.isArray(t)?[].concat(qt(t)):zt({},t)}.bind(void 0),Me=function(t){i(this,void 0);var n=Ce(t);return{origin:n,previous:void 0,current:n}}.bind(void 0),Re=function(t){return i(this,void 0),"number"==typeof t?[]:{}}.bind(void 0),Le=function(t,n,e){return i(this,void 0),ke(t,e)?Ce(we(t,e)):Re(n)}.bind(void 0),Ie=function(t,n,e,r){return i(this,void 0),Zt(t,e)?n(we(t[e],r)):Le(t[e],t[e+1],r)}.bind(void 0),Ne=function(t,n,e){return i(this,void 0),e[t]=n,we(t,e)}.bind(void 0),Je=function(t,n,e,r){return i(this,void 0),zt({},r,{current:Ne(t[n],e,r.current)})}.bind(void 0),qe=function(t,n,e){i(this,void 0);var r=Ae(t[n],e.current);return 0===n?zt({},e,{current:r,origin:r}):zt({},e,{previous:Ne(t[n-1],r,e.previous)})}.bind(void 0),He=ge("composite.updateIn.removeAction"),Fe=function(t,n,e,r){return i(this,void 0),e===He?qe(t,n,r):Je(t,n,e,r)}.bind(void 0),De=function(t,n){return i(this,void 0),function(e,r,o){return i(this,void 0),Fe(t,o,Ie(t,n,o,e.current),e)}.bind(this)}.bind(void 0),Be=o(function(t,n,e){return i(this,void 0),0===t.length?e:t.reduce(De(t,n),Me(e)).origin}.bind(void 0));Be.remove=He;var Ue=function(){return i(this,void 0),Be.remove}.bind(void 0),Ge=(o(function(t,n){return i(this,void 0),Be(t,Ue,n)}.bind(void 0)),o(function(t,n,e){i(this,void 0);var r=Ce(e);return r[t]=n,r}.bind(void 0)),o(function(t,n,e){return i(this,void 0),Be(t,function(){return i(this,void 0),n}.bind(this),e)}.bind(void 0)),function(t,n){return i(this,void 0),Boolean(Number(t)^Number(n))}.bind(void 0)),ze=(o(function(t,n){return i(this,void 0),t===n||!Ge(Array.isArray(t),Array.isArray(n))&&Ee(t,n)}.bind(void 0)),function(t,n,e){return i(this,void 0),t.find(Oe([n],e))}.bind(void 0)),Ve=function(t,n){return i(this,void 0),function(e){return i(this,void 0),function(){for(var r=arguments.length,o=Array(r),u=0;u<r;u++)o[u]=arguments[u];i(this,void 0);var s=ze(t.notifiers,"request",n);s&&e.apply(void 0,[t,s].concat(o))}.bind(this)}.bind(this)}.bind(void 0),We=function(t,n,e){return i(this,void 0),xe(Ve(n,e),t)}.bind(void 0);n(e(function(t,n){!function(t,e){e(n)}(0,function(t){function n(t){if(Array.isArray(t)){for(var n=0,e=Array(t.length);n<t.length;n++)e[n]=t[n];return e}return Array.from(t)}function e(t,n){if(!(t instanceof n))throw new TypeError("Cannot call a class as a function")}Object.defineProperty(t,"__esModule",{value:!0});var i="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(t){return typeof t}:function(t){return t&&"function"==typeof Symbol&&t.constructor===Symbol&&t!==Symbol.prototype?"symbol":typeof t},r=function(){function t(t,n){var e=[],i=!0,r=!1,o=void 0;try{for(var u,s=t[Symbol.iterator]();!(i=(u=s.next()).done)&&(e.push(u.value),!n||e.length!==n);i=!0);}catch(t){r=!0,o=t}finally{try{!i&&s.return&&s.return()}finally{if(r)throw o}}return e}return function(n,e){if(Array.isArray(n))return n;if(Symbol.iterator in Object(n))return t(n,e);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}(),o=function(){function t(t,n){for(var e=0;e<n.length;e++){var i=n[e];i.enumerable=i.enumerable||!1,i.configurable=!0,"value"in i&&(i.writable=!0),Object.defineProperty(t,i.key,i)}}return function(n,e,i){return e&&t(n.prototype,e),i&&t(n,i),n}}(),u={connecting:0,open:1,closing:2,closed:3},s=1e4,c={closed:"closed",errored:"errored",joined:"joined",joining:"joining",leaving:"leaving"},a={close:"phx_close",error:"phx_error",join:"phx_join",reply:"phx_reply",leave:"phx_leave"},f=[a.close,a.error,a.join,a.reply,a.leave],l={longpoll:"longpoll",websocket:"websocket"},h=function(){function t(n,i,r,o){e(this,t),this.channel=n,this.event=i,this.payload=r||{},this.receivedResp=null,this.timeout=o,this.timeoutTimer=null,this.recHooks=[],this.sent=!1}return o(t,[{key:"resend",value:function(t){this.timeout=t,this.reset(),this.send()}},{key:"send",value:function(){this.hasReceived("timeout")||(this.startTimeout(),this.sent=!0,this.channel.socket.push({topic:this.channel.topic,event:this.event,payload:this.payload,ref:this.ref,join_ref:this.channel.joinRef()}))}},{key:"receive",value:function(t,n){return this.hasReceived(t)&&n(this.receivedResp.response),this.recHooks.push({status:t,callback:n}),this}},{key:"reset",value:function(){this.cancelRefEvent(),this.ref=null,this.refEvent=null,this.receivedResp=null,this.sent=!1}},{key:"matchReceive",value:function(t){var n=t.status,e=t.response;this.recHooks.filter(function(t){return t.status===n}).forEach(function(t){return t.callback(e)})}},{key:"cancelRefEvent",value:function(){this.refEvent&&this.channel.off(this.refEvent)}},{key:"cancelTimeout",value:function(){clearTimeout(this.timeoutTimer),this.timeoutTimer=null}},{key:"startTimeout",value:function(){var t=this;this.timeoutTimer&&this.cancelTimeout(),this.ref=this.channel.socket.makeRef(),this.refEvent=this.channel.replyEventName(this.ref),this.channel.on(this.refEvent,function(n){t.cancelRefEvent(),t.cancelTimeout(),t.receivedResp=n,t.matchReceive(n)}),this.timeoutTimer=setTimeout(function(){t.trigger("timeout",{})},this.timeout)}},{key:"hasReceived",value:function(t){return this.receivedResp&&this.receivedResp.status===t}},{key:"trigger",value:function(t,n){this.channel.trigger(this.refEvent,{status:t,response:n})}}]),t}(),d=t.Channel=function(){function t(n,i,r){var o=this;e(this,t),this.state=c.closed,this.topic=n,this.params=i||{},this.socket=r,this.bindings=[],this.timeout=this.socket.timeout,this.joinedOnce=!1,this.joinPush=new h(this,a.join,this.params,this.timeout),this.pushBuffer=[],this.rejoinTimer=new y(function(){return o.rejoinUntilConnected()},this.socket.reconnectAfterMs),this.joinPush.receive("ok",function(){o.state=c.joined,o.rejoinTimer.reset(),o.pushBuffer.forEach(function(t){return t.send()}),o.pushBuffer=[]}),this.onClose(function(){o.rejoinTimer.reset(),o.socket.log("channel","close "+o.topic+" "+o.joinRef()),o.state=c.closed,o.socket.remove(o)}),this.onError(function(t){o.isLeaving()||o.isClosed()||(o.socket.log("channel","error "+o.topic,t),o.state=c.errored,o.rejoinTimer.scheduleTimeout())}),this.joinPush.receive("timeout",function(){o.isJoining()&&(o.socket.log("channel","timeout "+o.topic+" ("+o.joinRef()+")",o.joinPush.timeout),new h(o,a.leave,{},o.timeout).send(),o.state=c.errored,o.joinPush.reset(),o.rejoinTimer.scheduleTimeout())}),this.on(a.reply,function(t,n){o.trigger(o.replyEventName(n),t)})}return o(t,[{key:"rejoinUntilConnected",value:function(){this.rejoinTimer.scheduleTimeout(),this.socket.isConnected()&&this.rejoin()}},{key:"join",value:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.timeout;if(this.joinedOnce)throw"tried to join multiple times. 'join' can only be called a single time per channel instance";return this.joinedOnce=!0,this.rejoin(t),this.joinPush}},{key:"onClose",value:function(t){this.on(a.close,t)}},{key:"onError",value:function(t){this.on(a.error,function(n){return t(n)})}},{key:"on",value:function(t,n){this.bindings.push({event:t,callback:n})}},{key:"off",value:function(t){this.bindings=this.bindings.filter(function(n){return n.event!==t})}},{key:"canPush",value:function(){return this.socket.isConnected()&&this.isJoined()}},{key:"push",value:function(t,n){var e=arguments.length>2&&void 0!==arguments[2]?arguments[2]:this.timeout;if(!this.joinedOnce)throw"tried to push '"+t+"' to '"+this.topic+"' before joining. Use channel.join() before pushing events";var i=new h(this,t,n,e);return this.canPush()?i.send():(i.startTimeout(),this.pushBuffer.push(i)),i}},{key:"leave",value:function(){var t=this,n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.timeout;this.state=c.leaving;var e=function(){t.socket.log("channel","leave "+t.topic),t.trigger(a.close,"leave")},i=new h(this,a.leave,{},n);return i.receive("ok",function(){return e()}).receive("timeout",function(){return e()}),i.send(),this.canPush()||i.trigger("ok",{}),i}},{key:"onMessage",value:function(t,n,e){return n}},{key:"isMember",value:function(t,n,e,i){if(this.topic!==t)return!1;var r=f.indexOf(n)>=0;return!i||!r||i===this.joinRef()||(this.socket.log("channel","dropping outdated message",{topic:t,event:n,payload:e,joinRef:i}),!1)}},{key:"joinRef",value:function(){return this.joinPush.ref}},{key:"sendJoin",value:function(t){this.state=c.joining,this.joinPush.resend(t)}},{key:"rejoin",value:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.timeout;this.isLeaving()||this.sendJoin(t)}},{key:"trigger",value:function(t,n,e,i){var r=this,o=this.onMessage(t,n,e,i);if(n&&!o)throw"channel onMessage callbacks must return the payload, modified or unmodified";this.bindings.filter(function(n){return n.event===t}).map(function(t){return t.callback(o,e,i||r.joinRef())})}},{key:"replyEventName",value:function(t){return"chan_reply_"+t}},{key:"isClosed",value:function(){return this.state===c.closed}},{key:"isErrored",value:function(){return this.state===c.errored}},{key:"isJoined",value:function(){return this.state===c.joined}},{key:"isJoining",value:function(){return this.state===c.joining}},{key:"isLeaving",value:function(){return this.state===c.leaving}}]),t}(),v={encode:function(t,n){var e=[t.join_ref,t.ref,t.topic,t.event,t.payload];return n(JSON.stringify(e))},decode:function(t,n){var e=JSON.parse(t),i=r(e,5);return n({join_ref:i[0],ref:i[1],topic:i[2],event:i[3],payload:i[4]})}},p=(t.Socket=function(){function t(n){var i=this,r=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{};e(this,t),this.stateChangeCallbacks={open:[],close:[],error:[],message:[]},this.channels=[],this.sendBuffer=[],this.ref=0,this.timeout=r.timeout||s,this.transport=r.transport||window.WebSocket||p,this.defaultEncoder=v.encode,this.defaultDecoder=v.decode,this.transport!==p?(this.encode=r.encode||this.defaultEncoder,this.decode=r.decode||this.defaultDecoder):(this.encode=this.defaultEncoder,this.decode=this.defaultDecoder),this.heartbeatIntervalMs=r.heartbeatIntervalMs||3e4,this.reconnectAfterMs=r.reconnectAfterMs||function(t){return[1e3,2e3,5e3,1e4][t-1]||1e4},this.logger=r.logger||function(){},this.longpollerTimeout=r.longpollerTimeout||2e4,this.params=r.params||{},this.endPoint=n+"/"+l.websocket,this.heartbeatTimer=null,this.pendingHeartbeatRef=null,this.reconnectTimer=new y(function(){i.disconnect(function(){return i.connect()})},this.reconnectAfterMs)}return o(t,[{key:"protocol",value:function(){return location.protocol.match(/^https/)?"wss":"ws"}},{key:"endPointURL",value:function(){var t=b.appendParams(b.appendParams(this.endPoint,this.params),{vsn:"2.0.0"});return"/"!==t.charAt(0)?t:"/"===t.charAt(1)?this.protocol()+":"+t:this.protocol()+"://"+location.host+t}},{key:"disconnect",value:function(t,n,e){this.conn&&(this.conn.onclose=function(){},n?this.conn.close(n,e||""):this.conn.close(),this.conn=null),t&&t()}},{key:"connect",value:function(t){var n=this;t&&(console&&console.log("passing params to connect is deprecated. Instead pass :params to the Socket constructor"),this.params=t),this.conn||(this.conn=new this.transport(this.endPointURL()),this.conn.timeout=this.longpollerTimeout,this.conn.onopen=function(){return n.onConnOpen()},this.conn.onerror=function(t){return n.onConnError(t)},this.conn.onmessage=function(t){return n.onConnMessage(t)},this.conn.onclose=function(t){return n.onConnClose(t)})}},{key:"log",value:function(t,n,e){this.logger(t,n,e)}},{key:"onOpen",value:function(t){this.stateChangeCallbacks.open.push(t)}},{key:"onClose",value:function(t){this.stateChangeCallbacks.close.push(t)}},{key:"onError",value:function(t){this.stateChangeCallbacks.error.push(t)}},{key:"onMessage",value:function(t){this.stateChangeCallbacks.message.push(t)}},{key:"onConnOpen",value:function(){var t=this;this.log("transport","connected to "+this.endPointURL()),this.flushSendBuffer(),this.reconnectTimer.reset(),this.conn.skipHeartbeat||(clearInterval(this.heartbeatTimer),this.heartbeatTimer=setInterval(function(){return t.sendHeartbeat()},this.heartbeatIntervalMs)),this.stateChangeCallbacks.open.forEach(function(t){return t()})}},{key:"onConnClose",value:function(t){this.log("transport","close",t),this.triggerChanError(),clearInterval(this.heartbeatTimer),this.reconnectTimer.scheduleTimeout(),this.stateChangeCallbacks.close.forEach(function(n){return n(t)})}},{key:"onConnError",value:function(t){this.log("transport",t),this.triggerChanError(),this.stateChangeCallbacks.error.forEach(function(n){return n(t)})}},{key:"triggerChanError",value:function(){this.channels.forEach(function(t){return t.trigger(a.error)})}},{key:"connectionState",value:function(){switch(this.conn&&this.conn.readyState){case u.connecting:return"connecting";case u.open:return"open";case u.closing:return"closing";default:return"closed"}}},{key:"isConnected",value:function(){return"open"===this.connectionState()}},{key:"remove",value:function(t){this.channels=this.channels.filter(function(n){return n.joinRef()!==t.joinRef()})}},{key:"channel",value:function(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{},e=new d(t,n,this);return this.channels.push(e),e}},{key:"push",value:function(t){var n=this,e=t.topic,i=t.event,r=t.payload,o=t.ref,u=t.join_ref,s=function(){n.encode(t,function(t){n.conn.send(t)})};this.log("push",e+" "+i+" ("+u+", "+o+")",r),this.isConnected()?s():this.sendBuffer.push(s)}},{key:"makeRef",value:function(){var t=this.ref+1;return t===this.ref?this.ref=0:this.ref=t,this.ref.toString()}},{key:"sendHeartbeat",value:function(){if(this.isConnected()){if(this.pendingHeartbeatRef)return this.pendingHeartbeatRef=null,this.log("transport","heartbeat timeout. Attempting to re-establish connection"),void this.conn.close(1e3,"hearbeat timeout");this.pendingHeartbeatRef=this.makeRef(),this.push({topic:"phoenix",event:"heartbeat",payload:{},ref:this.pendingHeartbeatRef})}}},{key:"flushSendBuffer",value:function(){this.isConnected()&&this.sendBuffer.length>0&&(this.sendBuffer.forEach(function(t){return t()}),this.sendBuffer=[])}},{key:"onConnMessage",value:function(t){var n=this;this.decode(t.data,function(t){var e=t.topic,i=t.event,r=t.payload,o=t.ref,u=t.join_ref;o&&o===n.pendingHeartbeatRef&&(n.pendingHeartbeatRef=null),n.log("receive",(r.status||"")+" "+e+" "+i+" "+(o&&"("+o+")"||""),r),n.channels.filter(function(t){return t.isMember(e,i,r,u)}).forEach(function(t){return t.trigger(i,r,o,u)}),n.stateChangeCallbacks.message.forEach(function(n){return n(t)})})}}]),t}(),t.LongPoll=function(){function t(n){e(this,t),this.endPoint=null,this.token=null,this.skipHeartbeat=!0,this.onopen=function(){},this.onerror=function(){},this.onmessage=function(){},this.onclose=function(){},this.pollEndpoint=this.normalizeEndpoint(n),this.readyState=u.connecting,this.poll()}return o(t,[{key:"normalizeEndpoint",value:function(t){return t.replace("ws://","http://").replace("wss://","https://").replace(new RegExp("(.*)/"+l.websocket),"$1/"+l.longpoll)}},{key:"endpointURL",value:function(){return b.appendParams(this.pollEndpoint,{token:this.token})}},{key:"closeAndRetry",value:function(){this.close(),this.readyState=u.connecting}},{key:"ontimeout",value:function(){this.onerror("timeout"),this.closeAndRetry()}},{key:"poll",value:function(){var t=this;this.readyState!==u.open&&this.readyState!==u.connecting||b.request("GET",this.endpointURL(),"application/json",null,this.timeout,this.ontimeout.bind(this),function(n){if(n){var e=n.status,i=n.token,r=n.messages;t.token=i}else e=0;switch(e){case 200:r.forEach(function(n){return t.onmessage({data:n})}),t.poll();break;case 204:t.poll();break;case 410:t.readyState=u.open,t.onopen(),t.poll();break;case 0:case 500:t.onerror(),t.closeAndRetry();break;default:throw"unhandled poll status "+e}})}},{key:"send",value:function(t){var n=this;b.request("POST",this.endpointURL(),"application/json",t,this.timeout,this.onerror.bind(this,"timeout"),function(t){t&&200===t.status||(n.onerror(t&&t.status),n.closeAndRetry())})}},{key:"close",value:function(t,n){this.readyState=u.closed,this.onclose()}}]),t}()),b=t.Ajax=function(){function t(){e(this,t)}return o(t,null,[{key:"request",value:function(t,n,e,i,r,o,u){if(window.XDomainRequest){var s=new XDomainRequest;this.xdomainRequest(s,t,n,i,r,o,u)}else{var c=window.XMLHttpRequest?new window.XMLHttpRequest:new ActiveXObject("Microsoft.XMLHTTP");this.xhrRequest(c,t,n,e,i,r,o,u)}}},{key:"xdomainRequest",value:function(t,n,e,i,r,o,u){var s=this;t.timeout=r,t.open(n,e),t.onload=function(){var n=s.parseJSON(t.responseText);u&&u(n)},o&&(t.ontimeout=o),t.onprogress=function(){},t.send(i)}},{key:"xhrRequest",value:function(t,n,e,i,r,o,u,s){var c=this;t.open(n,e,!0),t.timeout=o,t.setRequestHeader("Content-Type",i),t.onerror=function(){s&&s(null)},t.onreadystatechange=function(){if(t.readyState===c.states.complete&&s){var n=c.parseJSON(t.responseText);s(n)}},u&&(t.ontimeout=u),t.send(r)}},{key:"parseJSON",value:function(t){if(!t||""===t)return null;try{return JSON.parse(t)}catch(n){return console&&console.log("failed to parse JSON response",t),null}}},{key:"serialize",value:function(t,n){var e=[];for(var r in t)if(t.hasOwnProperty(r)){var o=n?n+"["+r+"]":r,u=t[r];"object"===(void 0===u?"undefined":i(u))?e.push(this.serialize(u,o)):e.push(encodeURIComponent(o)+"="+encodeURIComponent(u))}return e.join("&")}},{key:"appendParams",value:function(t,n){return 0===Object.keys(n).length?t:""+t+(t.match(/\?/)?"&":"?")+this.serialize(n)}}]),t}();b.states={complete:4};t.Presence={syncState:function(t,n,e,i){var r=this,o=this.clone(t),u={},s={};return this.map(o,function(t,e){n[t]||(s[t]=e)}),this.map(n,function(t,n){var e=o[t];if(e){var i=n.metas.map(function(t){return t.phx_ref}),c=e.metas.map(function(t){return t.phx_ref}),a=n.metas.filter(function(t){return c.indexOf(t.phx_ref)<0}),f=e.metas.filter(function(t){return i.indexOf(t.phx_ref)<0});a.length>0&&(u[t]=n,u[t].metas=a),f.length>0&&(s[t]=r.clone(e),s[t].metas=f)}else u[t]=n}),this.syncDiff(o,{joins:u,leaves:s},e,i)},syncDiff:function(t,e,i,r){var o=e.joins,u=e.leaves,s=this.clone(t);return i||(i=function(){}),r||(r=function(){}),this.map(o,function(t,e){var r=s[t];if(s[t]=e,r){var o;(o=s[t].metas).unshift.apply(o,n(r.metas))}i(t,r,e)}),this.map(u,function(t,n){var e=s[t];if(e){var i=n.metas.map(function(t){return t.phx_ref});e.metas=e.metas.filter(function(t){return i.indexOf(t.phx_ref)<0}),r(t,e,n),0===e.metas.length&&delete s[t]}}),s},list:function(t,n){return n||(n=function(t,n){return n}),this.map(t,function(t,e){return n(t,e)})},map:function(t,n){return Object.getOwnPropertyNames(t).map(function(e){return n(e,t[e])})},clone:function(t){return JSON.parse(JSON.stringify(t))}};var y=function(){function t(n,i){e(this,t),this.callback=n,this.timerCalc=i,this.timer=null,this.tries=0}return o(t,[{key:"reset",value:function(){this.tries=0,clearTimeout(this.timer)}},{key:"scheduleTimeout",value:function(){var t=this;clearTimeout(this.timer),this.timer=setTimeout(function(){t.tries=t.tries+1,t.callback()},this.timerCalc(this.tries+1))}}]),t}()})}));var Xe=function(t,n){return i(this,void 0),t.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),Ke=function(t,n){return i(this,void 0),function(e){return i(this,void 0),e[t]&&e[t](n)}.bind(this)}.bind(void 0),Ye=function(t){return i(this,void 0),"on"+String(t)}.bind(void 0),Qe=function(t,n,e){return i(this,void 0),t.observers.forEach(Ke(Ye(n),e))}.bind(void 0),$e=function(t,n,e){return i(this,void 0),t.findIndex(Oe([n],e))}.bind(void 0),Ze=function(t){return i(this,void 0),function(n){return i(this,void 0),rn($e(n,"request",t),1,n)}.bind(this)}.bind(void 0),ti=function(t,n){return i(this,void 0),t.notifiers=n(t.notifiers),t}.bind(void 0),ni=function(t,n){i(this,void 0),ti(t,Ze(n)),Qe(n,"Cancel",n)}.bind(void 0),ei={onError:function(t,n,e){i(this,void 0),ii(t,n),Qe(n,"Error","unsubscribe: "+String(e))}.bind(void 0),onTimeout:function(t,n){return i(this,void 0),Qe(n,"Error","unsubscribe: timeout")}.bind(void 0),onSucceed:ni},ii=function(t,n){return i(this,void 0),Xe(t.channel.push("unsubscribe",{subscriptionId:n.subscriptionId}),We(ei,t,n.request))}.bind(void 0),ri=function(t,n){return i(this,void 0),"subscription"===n.operationType?ii(t,n):ni(t,n),t}.bind(void 0),oi=function(t,n,e){return i(this,void 0),t.forEach(function(t){return i(this,void 0),Qe(t,n,e)}.bind(this))}.bind(void 0),ui=function(t){return i(this,void 0),t.map(function(t){var n=t.column,e=t.line;return i(this,void 0),String(e)+":"+String(n)}.bind(this)).join("; ")}.bind(void 0),si=function(t){var n=t.message,e=t.locations;return i(this,void 0),n+(e?" ("+String(ui(e))+")":"")}.bind(void 0),ci=function(t){return i(this,void 0),t.map(si).join("\n")}.bind(void 0),ai=/^\s*(query|mutation|subscription|\{)/,fi=function(t){return i(this,void 0),"{"===t?"query":t}.bind(void 0),li=function(t){i(this,void 0);var n=t.match(ai);if(!n)throw new TypeError("Invalid operation:\n"+String(t));return fi(n[1])}.bind(void 0),hi=function(t){return i(this,void 0),function(n){return i(this,void 0),on($e(n,"request",t),[t],n)}.bind(this)}.bind(void 0),di=function(t,n,e){i(this,void 0),ti(t,Ze(n)),Qe(n,"Result",e.payload.result)}.bind(void 0),vi=function(t){return i(this,void 0),Qe(t,"Start",t)}.bind(void 0),pi=function(t,n,e){var r=e.subscriptionId;i(this,void 0),ti(t,hi(zt({},n,{subscriptionId:r}))),vi(n)}.bind(void 0),bi=function(t,n,e){i(this,void 0),e.subscriptionId?pi(t,n,e):e.payload&&di(t,n,e)}.bind(void 0),yi=function(t,n,e){i(this,void 0),ti(t,Ze(n)),Qe(n,"Abort",e)}.bind(void 0),mi=function(t,n,e){return i(this,void 0),yi(t,n,new Error(e))}.bind(void 0),gi=function(t,n,e){i(this,void 0),e.errors?mi(t,n,ci(e.errors)):bi(t,n,e)}.bind(void 0),wi=function(t,n){return i(this,void 0),Qe(n,"Error",new Error("request: timeout"))}.bind(void 0),ki={onError:mi,onSucceed:gi,onTimeout:wi},ji=function(t,n){i(this,void 0),"subscription"!==n.operationType&&vi(n),Xe(t.channel.push("doc",n.request),We(ki,t,n.request))}.bind(void 0),Si=function(t){return i(this,void 0),{onError:function(n){return i(this,void 0),oi(t.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){i(this,void 0),t.isJoining=!1,t.notifiers.forEach(function(n){return i(this,void 0),ji(t,n)}.bind(this))}.bind(this),onTimeout:function(){return i(this,void 0),oi(t.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),_i=function(t){return i(this,void 0),Xe(t.channel.join(),Si(t))}.bind(void 0),Oi=function(){return i(this,void 0),new Error("connection: close")}.bind(void 0),Ei=function(t,n){i(this,void 0),ti(t,Ze(n)),Qe(n,"Abort",Oi())}.bind(void 0),Ti=function(t){return i(this,void 0),function(n){i(this,void 0),"mutation"===n.operationType?Ei(t,n):Qe(n,"Error",Oi())}.bind(this)}.bind(void 0),xi=function(t){return i(this,void 0),function(){i(this,void 0),0!==t.notifiers.length&&(t.isJoining=!0,t.notifiers.forEach(Ti(t)))}.bind(this)}.bind(void 0),Pi=function(t,n){var e=n.payload;i(this,void 0);var r=ze(t.notifiers,"subscriptionId",e.subscriptionId);r&&Qe(r,"Result",e.result)}.bind(void 0),Ai=function(t){return i(this,void 0),function(n){i(this,void 0),"subscription:data"===n.event&&Pi(t,n)}.bind(this)}.bind(void 0),Ci=function(t){i(this,void 0),0===t.notifiers.length?t.isJoining=!1:_i(t)}.bind(void 0),Mi=function(t){return i(this,void 0),function(){i(this,void 0),t.isJoining&&Ci(t)}.bind(this)}.bind(void 0),Ri=function(t){i(this,void 0);var n={phoenixSocket:t,channel:t.channel("__absinthe__:control"),isJoining:!1,notifiers:[]};return t.onOpen(Mi(n)),t.onMessage(Ai(n)),t.onClose(xi(n)),n}.bind(void 0),Li=function(t,n){var e=t.observers,r=Qt(t,["observers"]);return i(this,void 0),zt({},r,{observers:[].concat(qt(e),[n])})}.bind(void 0),Ii=function(t,n,e){return i(this,void 0),ti(t,hi(Li(n,e)))}.bind(void 0),Ni=function(t){return i(this,void 0),{request:t,observers:[],operationType:li(t.operation),subscriptionId:void 0}}.bind(void 0),Ji=function(t){i(this,void 0),t.isJoining=!0,t.phoenixSocket.isConnected()?_i(t):t.phoenixSocket.connect()}.bind(void 0),qi=function(t){return i(this,void 0),t.phoenixSocket.isConnected()&&!t.isJoining}.bind(void 0),Hi=function(t,n){i(this,void 0);var e=Ni(n);return ti(t,$t([e])),qi(t)?ji(t,e):Ji(t),e}.bind(void 0),Fi=e(function(t,n){!function(e,i){e(n,t)}(function(t,n){function e(t){return"function"==typeof Symbol&&Boolean(Symbol[t])}function i(t){return e(t)?Symbol[t]:"@@"+t}function r(t,n){var e=t[n];if(null!=e){if("function"!=typeof e)throw new TypeError(e+" is not a function");return e}}function o(t){var n=t.constructor;return void 0!==n&&null===(n=n[i("species")])&&(n=void 0),void 0!==n?n:d}function u(t,n){Object.keys(n).forEach(function(e){var i=Object.getOwnPropertyDescriptor(n,e);i.enumerable=!1,Object.defineProperty(t,e,i)})}function s(t){var n=t._cleanup;n&&(t._cleanup=void 0,n())}function c(t){return void 0===t._observer}function a(t){c(t)||(t._observer=void 0,s(t))}function f(t){return function(){t.unsubscribe()}}function l(t,n){if(Object(t)!==t)throw new TypeError("Observer must be an object");this._cleanup=void 0,this._observer=t;var e=r(t,"start");if(e&&e.call(t,this),!c(this)){t=new h(this);try{var i=n.call(void 0,t);if(null!=i){if("function"==typeof i.unsubscribe)i=f(i);else if("function"!=typeof i)throw new TypeError(i+" is not a function");this._cleanup=i}}catch(n){return void t.error(n)}c(this)&&s(this)}}function h(t){this._subscription=t}function d(t){if("function"!=typeof t)throw new TypeError("Observable initializer must be a function");this._subscriber=t}"function"!=typeof Symbol||Symbol.observable||(Symbol.observable=Symbol("observable")),u(l.prototype={},{get closed(){return c(this)},unsubscribe:function(){a(this)}}),u(h.prototype={},{get closed(){return c(this._subscription)},next:function(t){var n=this._subscription;if(!c(n)){var e=n._observer,i=r(e,"next");if(i)return i.call(e,t)}},error:function(t){var n=this._subscription;if(c(n))throw t;var e=n._observer;n._observer=void 0;try{var i=r(e,"error");if(!i)throw t;t=i.call(e,t)}catch(t){try{s(n)}finally{throw t}}return s(n),t},complete:function(t){var n=this._subscription;if(!c(n)){var e=n._observer;n._observer=void 0;try{var i=r(e,"complete");t=i?i.call(e,t):void 0}catch(t){try{s(n)}finally{throw t}}return s(n),t}}}),u(d.prototype,{subscribe:function(t){for(var n=[],e=1;e<arguments.length;++e)n.push(arguments[e]);return"function"==typeof t&&(t={next:t,error:n[0],complete:n[1]}),new l(t,this._subscriber)},forEach:function(t){var n=this;return new Promise(function(e,i){if("function"!=typeof t)return Promise.reject(new TypeError(t+" is not a function"));n.subscribe({_subscription:null,start:function(t){if(Object(t)!==t)throw new TypeError(t+" is not an object");this._subscription=t},next:function(n){var e=this._subscription;if(!e.closed)try{return t(n)}catch(t){i(t),e.unsubscribe()}},error:i,complete:e})})},map:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");return new(o(this))(function(e){return n.subscribe({next:function(n){if(!e.closed){try{n=t(n)}catch(t){return e.error(t)}return e.next(n)}},error:function(t){return e.error(t)},complete:function(t){return e.complete(t)}})})},filter:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");return new(o(this))(function(e){return n.subscribe({next:function(n){if(!e.closed){try{if(!t(n))return}catch(t){return e.error(t)}return e.next(n)}},error:function(t){return e.error(t)},complete:function(){return e.complete()}})})},reduce:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");var e=o(this),i=arguments.length>1,r=!1,u=arguments[1];return new e(function(e){return n.subscribe({next:function(n){if(!e.closed){var o=!r;if(r=!0,!o||i)try{u=t(u,n)}catch(t){return e.error(t)}else u=n}},error:function(t){e.error(t)},complete:function(){r||i?(e.next(u),e.complete()):e.error(new TypeError("Cannot reduce an empty sequence"))}})})},flatMap:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");return new(o(this))(function(e){function i(){r&&0===o.length&&e.complete()}var r=!1,o=[],u=n.subscribe({next:function(n){if(t)try{n=t(n)}catch(t){return void e.error(t)}d.from(n).subscribe({_subscription:null,start:function(t){o.push(this._subscription=t)},next:function(t){e.next(t)},error:function(t){e.error(t)},complete:function(){var t=o.indexOf(this._subscription);t>=0&&o.splice(t,1),i()}})},error:function(t){return e.error(t)},complete:function(){r=!0,i()}});return function(){o.forEach(function(t){return t.unsubscribe()}),u.unsubscribe()}})}}),Object.defineProperty(d.prototype,i("observable"),{value:function(){return this},writable:!0,configurable:!0}),u(d,{from:function(t){var n="function"==typeof this?this:d;if(null==t)throw new TypeError(t+" is not an object");var o=r(t,i("observable"));if(o){var u=o.call(t);if(Object(u)!==u)throw new TypeError(u+" is not an object");return u.constructor===n?u:new n(function(t){return u.subscribe(t)})}if(e("iterator")&&(o=r(t,i("iterator"))))return new n(function(n){for(var e,i=o.call(t)[Symbol.iterator]();!(e=i.next()).done;){var r=e.value;if(n.next(r),n.closed)return}n.complete()});if(Array.isArray(t))return new n(function(n){for(var e=0;e<t.length;++e)if(n.next(t[e]),n.closed)return;n.complete()});throw new TypeError(t+" is not observable")},of:function(){for(var t=[],n=0;n<arguments.length;++n)t.push(arguments[n]);return new("function"==typeof this?this:d)(function(n){for(var e=0;e<t.length;++e)if(n.next(t[e]),n.closed)return;n.complete()})}}),Object.defineProperty(d,i("species"),{get:function(){return this},configurable:!0}),t.Observable=d})}).Observable,Di=function(t,n){return i(this,void 0),function(e){i(this,void 0),n.next(e),"subscription"!==t.operationType&&n.complete()}.bind(this)}.bind(void 0),Bi=function(t,n){var e=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},r=e.onError,o=e.onStart,u=e.unsubscribe;return i(this,void 0),new Fi(function(e){return i(this,void 0),Ii(t,n,{onError:r,onStart:o,onAbort:e.error,onresult:Di(n,e)}),u}.bind(this))}.bind(void 0),Ui=function(t,n){var e=t.observers,r=Qt(t,["observers"]);return i(this,void 0),zt({},r,{observers:rn(e.indexOf(n),1,e)})}.bind(void 0),Gi=function(t,n,e){return i(this,void 0),ti(t,hi(Ui(n,e))),t}.bind(void 0);t.cancel=ri,t.create=Ri,t.observe=Ii,t.send=Hi,t.toObservable=Bi,t.unobserve=Gi,Object.defineProperty(t,"__esModule",{value:!0})}); | ||
| !function(t,n){"object"==typeof exports&&"undefined"!=typeof module?n(exports):"function"==typeof define&&define.amd?define(["exports"],n):n(t.AbsinthePhoenixSocket={})}(this,function(t){"use strict";function n(t){return t&&t.__esModule&&Object.prototype.hasOwnProperty.call(t,"default")?t.default:t}function e(t,n){return n={exports:{}},t(n,n.exports),n.exports}"undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof self&&self;var i=n(e(function(t,n){n.__esModule=!0,n.default=function(t,n){if(t!==n)throw new TypeError("Cannot instantiate an arrow function")}})),r=e(function(t,n){function e(t,n,i){return function(){var r=i.concat(Array.prototype.slice.call(arguments));return r.length>=n?t.apply(this,r):e(t,n,r)}}Object.defineProperty(n,"__esModule",{value:!0}),n.flip=function(t){return function(n,e){return t(e,n)}},n.constant=function(t){return function(){return t}},n.on=function(t,n){return function(e,i){return t(n(e),n(i))}},n.compose=function(){for(var t=this,n=arguments.length,e=Array(n),i=0;i<n;i++)e[i]=arguments[i];var r=e.length-1;return function(n){for(var i=n,o=r;o>-1;o--)i=e[o].call(t,i);return i}},n.pipe=function(){for(var t=this,n=arguments.length,e=Array(n),i=0;i<n;i++)e[i]=arguments[i];var r=e.length-1;return function(n){for(var i=n,o=0;o<=r;o++)i=e[o].call(t,i);return i}},n.curry=function(t){return e(t,t.length,[])}});n(r);var o=r.curry,u=Math.ceil,s=Math.floor,c=function(t){return isNaN(t=+t)?0:(t>0?s:u)(t)},a=function(t){if(void 0==t)throw TypeError("Can't call method on "+t);return t},f=e(function(t){var n=t.exports="undefined"!=typeof window&&window.Math==Math?window:"undefined"!=typeof self&&self.Math==Math?self:Function("return this")();"number"==typeof __g&&(__g=n)}),l=e(function(t){var n=t.exports={version:"2.5.1"};"number"==typeof __e&&(__e=n)}),h=function(t){if("function"!=typeof t)throw TypeError(t+" is not a function!");return t},d=function(t,n,e){if(h(t),void 0===n)return t;switch(e){case 1:return function(e){return t.call(n,e)};case 2:return function(e,i){return t.call(n,e,i)};case 3:return function(e,i,r){return t.call(n,e,i,r)}}return function(){return t.apply(n,arguments)}},v=function(t){return"object"==typeof t?null!==t:"function"==typeof t},p=function(t){if(!v(t))throw TypeError(t+" is not an object!");return t},b=function(t){try{return!!t()}catch(t){return!0}},y=!b(function(){return 7!=Object.defineProperty({},"a",{get:function(){return 7}}).a}),m=f.document,g=v(m)&&v(m.createElement),w=function(t){return g?m.createElement(t):{}},k=!y&&!b(function(){return 7!=Object.defineProperty(w("div"),"a",{get:function(){return 7}}).a}),j=function(t,n){if(!v(t))return t;var e,i;if(n&&"function"==typeof(e=t.toString)&&!v(i=e.call(t)))return i;if("function"==typeof(e=t.valueOf)&&!v(i=e.call(t)))return i;if(!n&&"function"==typeof(e=t.toString)&&!v(i=e.call(t)))return i;throw TypeError("Can't convert object to primitive value")},S=Object.defineProperty,_={f:y?Object.defineProperty:function(t,n,e){if(p(t),n=j(n,!0),p(e),k)try{return S(t,n,e)}catch(t){}if("get"in e||"set"in e)throw TypeError("Accessors not supported!");return"value"in e&&(t[n]=e.value),t}},O=function(t,n){return{enumerable:!(1&t),configurable:!(2&t),writable:!(4&t),value:n}},E=y?function(t,n,e){return _.f(t,n,O(1,e))}:function(t,n,e){return t[n]=e,t},T=function(t,n,e){var i,r,o,u=t&T.F,s=t&T.G,c=t&T.S,a=t&T.P,h=t&T.B,v=t&T.W,p=s?l:l[n]||(l[n]={}),b=p.prototype,y=s?f:c?f[n]:(f[n]||{}).prototype;s&&(e=n);for(i in e)(r=!u&&y&&void 0!==y[i])&&i in p||(o=r?y[i]:e[i],p[i]=s&&"function"!=typeof y[i]?e[i]:h&&r?d(o,f):v&&y[i]==o?function(t){var n=function(n,e,i){if(this instanceof t){switch(arguments.length){case 0:return new t;case 1:return new t(n);case 2:return new t(n,e)}return new t(n,e,i)}return t.apply(this,arguments)};return n.prototype=t.prototype,n}(o):a&&"function"==typeof o?d(Function.call,o):o,a&&((p.virtual||(p.virtual={}))[i]=o,t&T.R&&b&&!b[i]&&E(b,i,o)))};T.F=1,T.G=2,T.S=4,T.P=8,T.B=16,T.W=32,T.U=64,T.R=128;var x=T,P=E,A={}.hasOwnProperty,C=function(t,n){return A.call(t,n)},M={},R={}.toString,L=function(t){return R.call(t).slice(8,-1)},I=Object("z").propertyIsEnumerable(0)?Object:function(t){return"String"==L(t)?t.split(""):Object(t)},N=function(t){return I(a(t))},J=Math.min,q=function(t){return t>0?J(c(t),9007199254740991):0},H=Math.max,F=Math.min,D=function(t,n){return(t=c(t))<0?H(t+n,0):F(t,n)},B=f["__core-js_shared__"]||(f["__core-js_shared__"]={}),U=function(t){return B[t]||(B[t]={})},G=0,z=Math.random(),V=function(t){return"Symbol(".concat(void 0===t?"":t,")_",(++G+z).toString(36))},W=U("keys"),X=function(t){return W[t]||(W[t]=V(t))},K=function(t){return function(n,e,i){var r,o=N(n),u=q(o.length),s=D(i,u);if(t&&e!=e){for(;u>s;)if((r=o[s++])!=r)return!0}else for(;u>s;s++)if((t||s in o)&&o[s]===e)return t||s||0;return!t&&-1}}(!1),Y=X("IE_PROTO"),Q=function(t,n){var e,i=N(t),r=0,o=[];for(e in i)e!=Y&&C(i,e)&&o.push(e);for(;n.length>r;)C(i,e=n[r++])&&(~K(o,e)||o.push(e));return o},$="constructor,hasOwnProperty,isPrototypeOf,propertyIsEnumerable,toLocaleString,toString,valueOf".split(","),Z=Object.keys||function(t){return Q(t,$)},tt=y?Object.defineProperties:function(t,n){p(t);for(var e,i=Z(n),r=i.length,o=0;r>o;)_.f(t,e=i[o++],n[e]);return t},nt=f.document,et=nt&&nt.documentElement,it=X("IE_PROTO"),rt=function(){},ot=function(){var t,n=w("iframe"),e=$.length;for(n.style.display="none",et.appendChild(n),n.src="javascript:",(t=n.contentWindow.document).open(),t.write("<script>document.F=Object<\/script>"),t.close(),ot=t.F;e--;)delete ot.prototype[$[e]];return ot()},ut=Object.create||function(t,n){var e;return null!==t?(rt.prototype=p(t),e=new rt,rt.prototype=null,e[it]=t):e=ot(),void 0===n?e:tt(e,n)},st=e(function(t){var n=U("wks"),e=f.Symbol,i="function"==typeof e;(t.exports=function(t){return n[t]||(n[t]=i&&e[t]||(i?e:V)("Symbol."+t))}).store=n}),ct=_.f,at=st("toStringTag"),ft=function(t,n,e){t&&!C(t=e?t:t.prototype,at)&&ct(t,at,{configurable:!0,value:n})},lt={};E(lt,st("iterator"),function(){return this});var ht=function(t,n,e){t.prototype=ut(lt,{next:O(1,e)}),ft(t,n+" Iterator")},dt=function(t){return Object(a(t))},vt=X("IE_PROTO"),pt=Object.prototype,bt=Object.getPrototypeOf||function(t){return t=dt(t),C(t,vt)?t[vt]:"function"==typeof t.constructor&&t instanceof t.constructor?t.constructor.prototype:t instanceof Object?pt:null},yt=st("iterator"),mt=!([].keys&&"next"in[].keys()),gt=function(){return this},wt=function(t,n,e,i,r,o,u){ht(e,n,i);var s,c,a,f=function(t){if(!mt&&t in v)return v[t];switch(t){case"keys":case"values":return function(){return new e(this,t)}}return function(){return new e(this,t)}},l=n+" Iterator",h="values"==r,d=!1,v=t.prototype,p=v[yt]||v["@@iterator"]||r&&v[r],b=p||f(r),y=r?h?f("entries"):b:void 0,m="Array"==n?v.entries||p:p;if(m&&(a=bt(m.call(new t)))!==Object.prototype&&a.next&&ft(a,l,!0),h&&p&&"values"!==p.name&&(d=!0,b=function(){return p.call(this)}),u&&(mt||d||!v[yt])&&E(v,yt,b),M[n]=b,M[l]=gt,r)if(s={values:h?b:f("values"),keys:o?b:f("keys"),entries:y},u)for(c in s)c in v||P(v,c,s[c]);else x(x.P+x.F*(mt||d),n,s);return s},kt=function(t){return function(n,e){var i,r,o=String(a(n)),u=c(e),s=o.length;return u<0||u>=s?t?"":void 0:(i=o.charCodeAt(u))<55296||i>56319||u+1===s||(r=o.charCodeAt(u+1))<56320||r>57343?t?o.charAt(u):i:t?o.slice(u,u+2):r-56320+(i-55296<<10)+65536}}(!0);wt(String,"String",function(t){this._t=String(t),this._i=0},function(){var t,n=this._t,e=this._i;return e>=n.length?{value:void 0,done:!0}:(t=kt(n,e),this._i+=t.length,{value:t,done:!1})});var jt=function(t,n,e,i){try{return i?n(p(e)[0],e[1]):n(e)}catch(n){var r=t.return;throw void 0!==r&&p(r.call(t)),n}},St=st("iterator"),_t=Array.prototype,Ot=function(t){return void 0!==t&&(M.Array===t||_t[St]===t)},Et=function(t,n,e){n in t?_.f(t,n,O(0,e)):t[n]=e},Tt=st("toStringTag"),xt="Arguments"==L(function(){return arguments}()),Pt=function(t,n){try{return t[n]}catch(t){}},At=function(t){var n,e,i;return void 0===t?"Undefined":null===t?"Null":"string"==typeof(e=Pt(n=Object(t),Tt))?e:xt?L(n):"Object"==(i=L(n))&&"function"==typeof n.callee?"Arguments":i},Ct=st("iterator"),Mt=l.getIteratorMethod=function(t){if(void 0!=t)return t[Ct]||t["@@iterator"]||M[At(t)]},Rt=st("iterator"),Lt=!1;try{[7][Rt]().return=function(){Lt=!0}}catch(t){}x(x.S+x.F*!function(t,n){if(!n&&!Lt)return!1;var e=!1;try{var i=[7],r=i[Rt]();r.next=function(){return{done:e=!0}},i[Rt]=function(){return r},t(i)}catch(t){}return e}(function(t){}),"Array",{from:function(t){var n,e,i,r,o=dt(t),u="function"==typeof this?this:Array,s=arguments.length,c=s>1?arguments[1]:void 0,a=void 0!==c,f=0,l=Mt(o);if(a&&(c=d(c,s>2?arguments[2]:void 0,2)),void 0==l||u==Array&&Ot(l))for(e=new u(n=q(o.length));n>f;f++)Et(e,f,a?c(o[f],f):o[f]);else for(r=l.call(o),e=new u;!(i=r.next()).done;f++)Et(e,f,a?jt(r,c,[i.value,f],!0):i.value);return e.length=f,e}});var It=l.Array.from,Nt=e(function(t){t.exports={default:It,__esModule:!0}}),Jt=n(Nt),qt=n(e(function(t,n){n.__esModule=!0;var e=function(t){return t&&t.__esModule?t:{default:t}}(Nt);n.default=function(t){if(Array.isArray(t)){for(var n=0,i=Array(t.length);n<t.length;n++)i[n]=t[n];return i}return(0,e.default)(t)}})),Ht={f:Object.getOwnPropertySymbols},Ft={f:{}.propertyIsEnumerable},Dt=Object.assign,Bt=!Dt||b(function(){var t={},n={},e=Symbol(),i="abcdefghijklmnopqrst";return t[e]=7,i.split("").forEach(function(t){n[t]=t}),7!=Dt({},t)[e]||Object.keys(Dt({},n)).join("")!=i})?function(t,n){for(var e=dt(t),i=arguments.length,r=1,o=Ht.f,u=Ft.f;i>r;)for(var s,c=I(arguments[r++]),a=o?Z(c).concat(o(c)):Z(c),f=a.length,l=0;f>l;)u.call(c,s=a[l++])&&(e[s]=c[s]);return e}:Dt;x(x.S+x.F,"Object",{assign:Bt});var Ut=l.Object.assign,Gt=e(function(t){t.exports={default:Ut,__esModule:!0}});n(Gt);var zt=n(e(function(t,n){n.__esModule=!0;var e=function(t){return t&&t.__esModule?t:{default:t}}(Gt);n.default=e.default||function(t){for(var n=1;n<arguments.length;n++){var e=arguments[n];for(var i in e)Object.prototype.hasOwnProperty.call(e,i)&&(t[i]=e[i])}return t}}));!function(t,n){var e=(l.Object||{})[t]||Object[t],i={};i[t]=n(e),x(x.S+x.F*b(function(){e(1)}),"Object",i)}("keys",function(){return function(t){return Z(dt(t))}});var Vt=l.Object.keys,Wt=n(e(function(t){t.exports={default:Vt,__esModule:!0}})),Xt=Math.floor;x(x.S,"Number",{isInteger:function(t){return!v(t)&&isFinite(t)&&Xt(t)===t}});var Kt=l.Number.isInteger,Yt=n(e(function(t){t.exports={default:Kt,__esModule:!0}})),Qt=n(e(function(t,n){n.__esModule=!0,n.default=function(t,n){var e={};for(var i in t)n.indexOf(i)>=0||Object.prototype.hasOwnProperty.call(t,i)&&(e[i]=t[i]);return e}})),$t=o(function(t,n){return i(this,void 0),[].concat(qt(n),qt(t))}.bind(void 0)),Zt=(function(t){return i(this,void 0),Array.isArray(t)?t:[t]}.bind(void 0),o(function(t,n){return i(this,void 0),n===t.length-1}.bind(void 0))),tn=(o(function(t,n){return i(this,void 0),Zt(t,n)?0:n+1}.bind(void 0)),function(t){return i(this,void 0),Math.max.apply(Math,qt(Wt(t)))+1}.bind(void 0)),nn=(function(t){return i(this,void 0),Jt("length"in t?t:zt({},t,{length:tn(t)}))}.bind(void 0),o(function(t,n,e){return i(this,void 0),[].concat(qt(e.slice(0,t)),qt(n),qt(e.slice(t+1)))}.bind(void 0)),function(t,n){return i(this,void 0),Yt(t)&&t>=n}.bind(void 0)),en=function(t){return i(this,void 0),nn(Number(t),0)}.bind(void 0),rn=(function(t){t.length;var n=Qt(t,["length"]);return i(this,void 0),Wt(n).every(en)}.bind(void 0),o(function(t,n){return i(this,void 0),[].concat(qt(t),qt(n))}.bind(void 0)),o(function(t,n,e,r){return i(this,void 0),r.reduce(function(e,r,o){return i(this,void 0),t(r,o,e)?n(e,r,o):e}.bind(this),e)}.bind(void 0)),o(function(t,n,e,r){i(this,void 0);var o=e;return r.every(function(e,r){i(this,void 0);var u=t(e,r,o);return u&&(o=n(o,e,r)),u}.bind(this)),o}.bind(void 0)),o(function(t,n,e){return i(this,void 0),[].concat(qt(e.slice(0,t)),qt(e.slice(t+n)))}.bind(void 0))),on=(o(function(t,n){return i(this,void 0),[].concat(qt(Array(t))).map(function(){return i(this,void 0),n}.bind(this))}.bind(void 0)),o(function(t,n,e){return i(this,void 0),[].concat(qt(e.slice(0,t)),qt(n),qt(e.slice(t+n.length)))}.bind(void 0)));o(function(t,n){return i(this,void 0),n<0?t.length-n:n}.bind(void 0));x(x.S+x.F*!y,"Object",{defineProperty:_.f});var un=l.Object,sn=function(t,n,e){return un.defineProperty(t,n,e)},cn=e(function(t){t.exports={default:sn,__esModule:!0}});n(cn);var an=n(e(function(t,n){n.__esModule=!0;var e=function(t){return t&&t.__esModule?t:{default:t}}(cn);n.default=function(t,n,i){return n in t?(0,e.default)(t,n,{value:i,enumerable:!0,configurable:!0,writable:!0}):t[n]=i,t}})),fn=function(t,n){return{value:n,done:!!t}};wt(Array,"Array",function(t,n){this._t=N(t),this._i=0,this._k=n},function(){var t=this._t,n=this._k,e=this._i++;return!t||e>=t.length?(this._t=void 0,fn(1)):"keys"==n?fn(0,e):"values"==n?fn(0,t[e]):fn(0,[e,t[e]])},"values");M.Arguments=M.Array;for(var ln=st("toStringTag"),hn="CSSRuleList,CSSStyleDeclaration,CSSValueList,ClientRectList,DOMRectList,DOMStringList,DOMTokenList,DataTransferItemList,FileList,HTMLAllCollection,HTMLCollection,HTMLFormElement,HTMLSelectElement,MediaList,MimeTypeArray,NamedNodeMap,NodeList,PaintRequestList,Plugin,PluginArray,SVGLengthList,SVGNumberList,SVGPathSegList,SVGPointList,SVGStringList,SVGTransformList,SourceBufferList,StyleSheetList,TextTrackCueList,TextTrackList,TouchList".split(","),dn=0;dn<hn.length;dn++){var vn=hn[dn],pn=f[vn],bn=pn&&pn.prototype;bn&&!bn[ln]&&E(bn,ln,vn),M[vn]=M.Array}var yn=st("iterator"),mn=l.isIterable=function(t){var n=Object(t);return void 0!==n[yn]||"@@iterator"in n||M.hasOwnProperty(At(n))},gn=e(function(t){t.exports={default:mn,__esModule:!0}});n(gn);var wn=l.getIterator=function(t){var n=Mt(t);if("function"!=typeof n)throw TypeError(t+" is not iterable!");return p(n.call(t))},kn=e(function(t){t.exports={default:wn,__esModule:!0}});n(kn);var jn=n(e(function(t,n){function e(t){return t&&t.__esModule?t:{default:t}}n.__esModule=!0;var i=e(gn),r=e(kn);n.default=function(){function t(t,n){var e=[],i=!0,o=!1,u=void 0;try{for(var s,c=(0,r.default)(t);!(i=(s=c.next()).done)&&(e.push(s.value),!n||e.length!==n);i=!0);}catch(t){o=!0,u=t}finally{try{!i&&c.return&&c.return()}finally{if(o)throw u}}return e}return function(n,e){if(Array.isArray(n))return n;if((0,i.default)(Object(n)))return t(n,e);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}()})),Sn=Ft.f,_n=function(t){return function(n){for(var e,i=N(n),r=Z(i),o=r.length,u=0,s=[];o>u;)Sn.call(i,e=r[u++])&&s.push(t?[e,i[e]]:i[e]);return s}}(!0);x(x.S,"Object",{entries:function(t){return _n(t)}});var On=l.Object.entries,En=n(e(function(t){t.exports={default:On,__esModule:!0}})),Tn=e(function(t){var n=V("meta"),e=_.f,i=0,r=Object.isExtensible||function(){return!0},o=!b(function(){return r(Object.preventExtensions({}))}),u=function(t){e(t,n,{value:{i:"O"+ ++i,w:{}}})},s=t.exports={KEY:n,NEED:!1,fastKey:function(t,e){if(!v(t))return"symbol"==typeof t?t:("string"==typeof t?"S":"P")+t;if(!C(t,n)){if(!r(t))return"F";if(!e)return"E";u(t)}return t[n].i},getWeak:function(t,e){if(!C(t,n)){if(!r(t))return!0;if(!e)return!1;u(t)}return t[n].w},onFreeze:function(t){return o&&s.NEED&&r(t)&&!C(t,n)&&u(t),t}}}),xn={f:st},Pn=_.f,An=function(t){var n=l.Symbol||(l.Symbol={});"_"==t.charAt(0)||t in n||Pn(n,t,{value:xn.f(t)})},Cn=function(t){var n=Z(t),e=Ht.f;if(e)for(var i,r=e(t),o=Ft.f,u=0;r.length>u;)o.call(t,i=r[u++])&&n.push(i);return n},Mn=Array.isArray||function(t){return"Array"==L(t)},Rn=$.concat("length","prototype"),Ln={f:Object.getOwnPropertyNames||function(t){return Q(t,Rn)}},In=Ln.f,Nn={}.toString,Jn="object"==typeof window&&window&&Object.getOwnPropertyNames?Object.getOwnPropertyNames(window):[],qn=function(t){try{return In(t)}catch(t){return Jn.slice()}},Hn={f:function(t){return Jn&&"[object Window]"==Nn.call(t)?qn(t):In(N(t))}},Fn=Object.getOwnPropertyDescriptor,Dn={f:y?Fn:function(t,n){if(t=N(t),n=j(n,!0),k)try{return Fn(t,n)}catch(t){}if(C(t,n))return O(!Ft.f.call(t,n),t[n])}},Bn=Tn.KEY,Un=Dn.f,Gn=_.f,zn=Hn.f,Vn=f.Symbol,Wn=f.JSON,Xn=Wn&&Wn.stringify,Kn=st("_hidden"),Yn=st("toPrimitive"),Qn={}.propertyIsEnumerable,$n=U("symbol-registry"),Zn=U("symbols"),te=U("op-symbols"),ne=Object.prototype,ee="function"==typeof Vn,ie=f.QObject,re=!ie||!ie.prototype||!ie.prototype.findChild,oe=y&&b(function(){return 7!=ut(Gn({},"a",{get:function(){return Gn(this,"a",{value:7}).a}})).a})?function(t,n,e){var i=Un(ne,n);i&&delete ne[n],Gn(t,n,e),i&&t!==ne&&Gn(ne,n,i)}:Gn,ue=function(t){var n=Zn[t]=ut(Vn.prototype);return n._k=t,n},se=ee&&"symbol"==typeof Vn.iterator?function(t){return"symbol"==typeof t}:function(t){return t instanceof Vn},ce=function(t,n,e){return t===ne&&ce(te,n,e),p(t),n=j(n,!0),p(e),C(Zn,n)?(e.enumerable?(C(t,Kn)&&t[Kn][n]&&(t[Kn][n]=!1),e=ut(e,{enumerable:O(0,!1)})):(C(t,Kn)||Gn(t,Kn,O(1,{})),t[Kn][n]=!0),oe(t,n,e)):Gn(t,n,e)},ae=function(t,n){p(t);for(var e,i=Cn(n=N(n)),r=0,o=i.length;o>r;)ce(t,e=i[r++],n[e]);return t},fe=function(t){var n=Qn.call(this,t=j(t,!0));return!(this===ne&&C(Zn,t)&&!C(te,t))&&(!(n||!C(this,t)||!C(Zn,t)||C(this,Kn)&&this[Kn][t])||n)},le=function(t,n){if(t=N(t),n=j(n,!0),t!==ne||!C(Zn,n)||C(te,n)){var e=Un(t,n);return!e||!C(Zn,n)||C(t,Kn)&&t[Kn][n]||(e.enumerable=!0),e}},he=function(t){for(var n,e=zn(N(t)),i=[],r=0;e.length>r;)C(Zn,n=e[r++])||n==Kn||n==Bn||i.push(n);return i},de=function(t){for(var n,e=t===ne,i=zn(e?te:N(t)),r=[],o=0;i.length>o;)!C(Zn,n=i[o++])||e&&!C(ne,n)||r.push(Zn[n]);return r};ee||(P((Vn=function(){if(this instanceof Vn)throw TypeError("Symbol is not a constructor!");var t=V(arguments.length>0?arguments[0]:void 0),n=function(e){this===ne&&n.call(te,e),C(this,Kn)&&C(this[Kn],t)&&(this[Kn][t]=!1),oe(this,t,O(1,e))};return y&&re&&oe(ne,t,{configurable:!0,set:n}),ue(t)}).prototype,"toString",function(){return this._k}),Dn.f=le,_.f=ce,Ln.f=Hn.f=he,Ft.f=fe,Ht.f=de,xn.f=function(t){return ue(st(t))}),x(x.G+x.W+x.F*!ee,{Symbol:Vn});for(var ve="hasInstance,isConcatSpreadable,iterator,match,replace,search,species,split,toPrimitive,toStringTag,unscopables".split(","),pe=0;ve.length>pe;)st(ve[pe++]);for(var be=Z(st.store),ye=0;be.length>ye;)An(be[ye++]);x(x.S+x.F*!ee,"Symbol",{for:function(t){return C($n,t+="")?$n[t]:$n[t]=Vn(t)},keyFor:function(t){if(!se(t))throw TypeError(t+" is not a symbol!");for(var n in $n)if($n[n]===t)return n},useSetter:function(){re=!0},useSimple:function(){re=!1}}),x(x.S+x.F*!ee,"Object",{create:function(t,n){return void 0===n?ut(t):ae(ut(t),n)},defineProperty:ce,defineProperties:ae,getOwnPropertyDescriptor:le,getOwnPropertyNames:he,getOwnPropertySymbols:de}),Wn&&x(x.S+x.F*(!ee||b(function(){var t=Vn();return"[null]"!=Xn([t])||"{}"!=Xn({a:t})||"{}"!=Xn(Object(t))})),"JSON",{stringify:function(t){if(void 0!==t&&!se(t)){for(var n,e,i=[t],r=1;arguments.length>r;)i.push(arguments[r++]);return"function"==typeof(n=i[1])&&(e=n),!e&&Mn(n)||(n=function(t,n){if(e&&(n=e.call(this,t,n)),!se(n))return n}),i[1]=n,Xn.apply(Wn,i)}}}),Vn.prototype[Yn]||E(Vn.prototype,Yn,Vn.prototype.valueOf),ft(Vn,"Symbol"),ft(Math,"Math",!0),ft(f.JSON,"JSON",!0),An("asyncIterator"),An("observable");var me=l.Symbol,ge=n(e(function(t){t.exports={default:me,__esModule:!0}})),we=o(function(t,n){return i(this,void 0),n[t]}.bind(void 0)),ke=o(function(t,n){return i(this,void 0),Object.prototype.hasOwnProperty.call(n,t)}.bind(void 0)),je=function(t,n,e){return i(this,void 0),Zt(n,t)?we(n[t],e):ke(n[t],e)?je(t+1,n,we(n[t],e)):void 0}.bind(void 0),Se=o(function(t,n){return i(this,void 0),0===t.length?void 0:je(0,t,n)}.bind(void 0)),_e=function(t){return i(this,void 0),Array.isArray(t)?[].concat(qt(t.keys())):Wt(t)}.bind(void 0),Oe=o(function(t,n,e){return i(this,void 0),Se(t,e)===n}.bind(void 0)),Ee=o(function(t,n){i(this,void 0);var e=_e(t);return e.length===_e(n).length&&e.every(function(e){return i(this,void 0),ke(e,n)&&we(e,t)===we(e,n)}.bind(this))}.bind(void 0)),Te=function(t,n){return i(this,void 0),En(n).reduce(function(e,r){var o=jn(r,2),u=o[0],s=o[1];return i(this,void 0),zt({},e,an({},u,t(s,u,n)))}.bind(this),{})}.bind(void 0),xe=o(function(t,n){return i(this,void 0),Array.isArray(n)?n.map(t):Te(t,n)}.bind(void 0)),Pe=function(t,n){n[t];var e=Qt(n,[t]);return i(this,void 0),e}.bind(void 0),Ae=o(function(t,n){return i(this,void 0),Array.isArray(n)?rn(t,1,n):Pe(t,n)}.bind(void 0)),Ce=function(t){return i(this,void 0),Array.isArray(t)?[].concat(qt(t)):zt({},t)}.bind(void 0),Me=function(t){i(this,void 0);var n=Ce(t);return{origin:n,previous:void 0,current:n}}.bind(void 0),Re=function(t){return i(this,void 0),"number"==typeof t?[]:{}}.bind(void 0),Le=function(t,n,e){return i(this,void 0),ke(t,e)?Ce(we(t,e)):Re(n)}.bind(void 0),Ie=function(t,n,e,r){return i(this,void 0),Zt(t,e)?n(we(t[e],r)):Le(t[e],t[e+1],r)}.bind(void 0),Ne=function(t,n,e){return i(this,void 0),e[t]=n,we(t,e)}.bind(void 0),Je=function(t,n,e,r){return i(this,void 0),zt({},r,{current:Ne(t[n],e,r.current)})}.bind(void 0),qe=function(t,n,e){i(this,void 0);var r=Ae(t[n],e.current);return 0===n?zt({},e,{current:r,origin:r}):zt({},e,{previous:Ne(t[n-1],r,e.previous)})}.bind(void 0),He=ge("composite.updateIn.removeAction"),Fe=function(t,n,e,r){return i(this,void 0),e===He?qe(t,n,r):Je(t,n,e,r)}.bind(void 0),De=function(t,n){return i(this,void 0),function(e,r,o){return i(this,void 0),Fe(t,o,Ie(t,n,o,e.current),e)}.bind(this)}.bind(void 0),Be=o(function(t,n,e){return i(this,void 0),0===t.length?e:t.reduce(De(t,n),Me(e)).origin}.bind(void 0));Be.remove=He;var Ue=function(){return i(this,void 0),Be.remove}.bind(void 0),Ge=(o(function(t,n){return i(this,void 0),Be(t,Ue,n)}.bind(void 0)),o(function(t,n,e){i(this,void 0);var r=Ce(e);return r[t]=n,r}.bind(void 0)),o(function(t,n,e){return i(this,void 0),Be(t,function(){return i(this,void 0),n}.bind(this),e)}.bind(void 0)),function(t,n){return i(this,void 0),Boolean(Number(t)^Number(n))}.bind(void 0)),ze=(o(function(t,n){return i(this,void 0),t===n||!Ge(Array.isArray(t),Array.isArray(n))&&Ee(t,n)}.bind(void 0)),function(t,n,e){return i(this,void 0),t.find(Oe([n],e))}.bind(void 0)),Ve=function(t,n){return i(this,void 0),function(e){return i(this,void 0),function(){for(var r=arguments.length,o=Array(r),u=0;u<r;u++)o[u]=arguments[u];i(this,void 0);var s=ze(t.notifiers,"request",n);s&&e.apply(void 0,[t,s].concat(o))}.bind(this)}.bind(this)}.bind(void 0),We=function(t,n,e){return i(this,void 0),xe(Ve(n,e),t)}.bind(void 0);n(e(function(t,n){!function(t,e){e(n)}(0,function(t){function n(t){if(Array.isArray(t)){for(var n=0,e=Array(t.length);n<t.length;n++)e[n]=t[n];return e}return Array.from(t)}function e(t,n){if(!(t instanceof n))throw new TypeError("Cannot call a class as a function")}Object.defineProperty(t,"__esModule",{value:!0});var i="function"==typeof Symbol&&"symbol"==typeof Symbol.iterator?function(t){return typeof t}:function(t){return t&&"function"==typeof Symbol&&t.constructor===Symbol&&t!==Symbol.prototype?"symbol":typeof t},r=function(){function t(t,n){var e=[],i=!0,r=!1,o=void 0;try{for(var u,s=t[Symbol.iterator]();!(i=(u=s.next()).done)&&(e.push(u.value),!n||e.length!==n);i=!0);}catch(t){r=!0,o=t}finally{try{!i&&s.return&&s.return()}finally{if(r)throw o}}return e}return function(n,e){if(Array.isArray(n))return n;if(Symbol.iterator in Object(n))return t(n,e);throw new TypeError("Invalid attempt to destructure non-iterable instance")}}(),o=function(){function t(t,n){for(var e=0;e<n.length;e++){var i=n[e];i.enumerable=i.enumerable||!1,i.configurable=!0,"value"in i&&(i.writable=!0),Object.defineProperty(t,i.key,i)}}return function(n,e,i){return e&&t(n.prototype,e),i&&t(n,i),n}}(),u={connecting:0,open:1,closing:2,closed:3},s=1e4,c={closed:"closed",errored:"errored",joined:"joined",joining:"joining",leaving:"leaving"},a={close:"phx_close",error:"phx_error",join:"phx_join",reply:"phx_reply",leave:"phx_leave"},f=[a.close,a.error,a.join,a.reply,a.leave],l={longpoll:"longpoll",websocket:"websocket"},h=function(){function t(n,i,r,o){e(this,t),this.channel=n,this.event=i,this.payload=r||{},this.receivedResp=null,this.timeout=o,this.timeoutTimer=null,this.recHooks=[],this.sent=!1}return o(t,[{key:"resend",value:function(t){this.timeout=t,this.reset(),this.send()}},{key:"send",value:function(){this.hasReceived("timeout")||(this.startTimeout(),this.sent=!0,this.channel.socket.push({topic:this.channel.topic,event:this.event,payload:this.payload,ref:this.ref,join_ref:this.channel.joinRef()}))}},{key:"receive",value:function(t,n){return this.hasReceived(t)&&n(this.receivedResp.response),this.recHooks.push({status:t,callback:n}),this}},{key:"reset",value:function(){this.cancelRefEvent(),this.ref=null,this.refEvent=null,this.receivedResp=null,this.sent=!1}},{key:"matchReceive",value:function(t){var n=t.status,e=t.response;this.recHooks.filter(function(t){return t.status===n}).forEach(function(t){return t.callback(e)})}},{key:"cancelRefEvent",value:function(){this.refEvent&&this.channel.off(this.refEvent)}},{key:"cancelTimeout",value:function(){clearTimeout(this.timeoutTimer),this.timeoutTimer=null}},{key:"startTimeout",value:function(){var t=this;this.timeoutTimer&&this.cancelTimeout(),this.ref=this.channel.socket.makeRef(),this.refEvent=this.channel.replyEventName(this.ref),this.channel.on(this.refEvent,function(n){t.cancelRefEvent(),t.cancelTimeout(),t.receivedResp=n,t.matchReceive(n)}),this.timeoutTimer=setTimeout(function(){t.trigger("timeout",{})},this.timeout)}},{key:"hasReceived",value:function(t){return this.receivedResp&&this.receivedResp.status===t}},{key:"trigger",value:function(t,n){this.channel.trigger(this.refEvent,{status:t,response:n})}}]),t}(),d=t.Channel=function(){function t(n,i,r){var o=this;e(this,t),this.state=c.closed,this.topic=n,this.params=i||{},this.socket=r,this.bindings=[],this.timeout=this.socket.timeout,this.joinedOnce=!1,this.joinPush=new h(this,a.join,this.params,this.timeout),this.pushBuffer=[],this.rejoinTimer=new y(function(){return o.rejoinUntilConnected()},this.socket.reconnectAfterMs),this.joinPush.receive("ok",function(){o.state=c.joined,o.rejoinTimer.reset(),o.pushBuffer.forEach(function(t){return t.send()}),o.pushBuffer=[]}),this.onClose(function(){o.rejoinTimer.reset(),o.socket.log("channel","close "+o.topic+" "+o.joinRef()),o.state=c.closed,o.socket.remove(o)}),this.onError(function(t){o.isLeaving()||o.isClosed()||(o.socket.log("channel","error "+o.topic,t),o.state=c.errored,o.rejoinTimer.scheduleTimeout())}),this.joinPush.receive("timeout",function(){o.isJoining()&&(o.socket.log("channel","timeout "+o.topic+" ("+o.joinRef()+")",o.joinPush.timeout),new h(o,a.leave,{},o.timeout).send(),o.state=c.errored,o.joinPush.reset(),o.rejoinTimer.scheduleTimeout())}),this.on(a.reply,function(t,n){o.trigger(o.replyEventName(n),t)})}return o(t,[{key:"rejoinUntilConnected",value:function(){this.rejoinTimer.scheduleTimeout(),this.socket.isConnected()&&this.rejoin()}},{key:"join",value:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.timeout;if(this.joinedOnce)throw"tried to join multiple times. 'join' can only be called a single time per channel instance";return this.joinedOnce=!0,this.rejoin(t),this.joinPush}},{key:"onClose",value:function(t){this.on(a.close,t)}},{key:"onError",value:function(t){this.on(a.error,function(n){return t(n)})}},{key:"on",value:function(t,n){this.bindings.push({event:t,callback:n})}},{key:"off",value:function(t){this.bindings=this.bindings.filter(function(n){return n.event!==t})}},{key:"canPush",value:function(){return this.socket.isConnected()&&this.isJoined()}},{key:"push",value:function(t,n){var e=arguments.length>2&&void 0!==arguments[2]?arguments[2]:this.timeout;if(!this.joinedOnce)throw"tried to push '"+t+"' to '"+this.topic+"' before joining. Use channel.join() before pushing events";var i=new h(this,t,n,e);return this.canPush()?i.send():(i.startTimeout(),this.pushBuffer.push(i)),i}},{key:"leave",value:function(){var t=this,n=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.timeout;this.state=c.leaving;var e=function(){t.socket.log("channel","leave "+t.topic),t.trigger(a.close,"leave")},i=new h(this,a.leave,{},n);return i.receive("ok",function(){return e()}).receive("timeout",function(){return e()}),i.send(),this.canPush()||i.trigger("ok",{}),i}},{key:"onMessage",value:function(t,n,e){return n}},{key:"isMember",value:function(t,n,e,i){if(this.topic!==t)return!1;var r=f.indexOf(n)>=0;return!i||!r||i===this.joinRef()||(this.socket.log("channel","dropping outdated message",{topic:t,event:n,payload:e,joinRef:i}),!1)}},{key:"joinRef",value:function(){return this.joinPush.ref}},{key:"sendJoin",value:function(t){this.state=c.joining,this.joinPush.resend(t)}},{key:"rejoin",value:function(){var t=arguments.length>0&&void 0!==arguments[0]?arguments[0]:this.timeout;this.isLeaving()||this.sendJoin(t)}},{key:"trigger",value:function(t,n,e,i){var r=this,o=this.onMessage(t,n,e,i);if(n&&!o)throw"channel onMessage callbacks must return the payload, modified or unmodified";this.bindings.filter(function(n){return n.event===t}).map(function(t){return t.callback(o,e,i||r.joinRef())})}},{key:"replyEventName",value:function(t){return"chan_reply_"+t}},{key:"isClosed",value:function(){return this.state===c.closed}},{key:"isErrored",value:function(){return this.state===c.errored}},{key:"isJoined",value:function(){return this.state===c.joined}},{key:"isJoining",value:function(){return this.state===c.joining}},{key:"isLeaving",value:function(){return this.state===c.leaving}}]),t}(),v={encode:function(t,n){var e=[t.join_ref,t.ref,t.topic,t.event,t.payload];return n(JSON.stringify(e))},decode:function(t,n){var e=JSON.parse(t),i=r(e,5);return n({join_ref:i[0],ref:i[1],topic:i[2],event:i[3],payload:i[4]})}},p=(t.Socket=function(){function t(n){var i=this,r=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{};e(this,t),this.stateChangeCallbacks={open:[],close:[],error:[],message:[]},this.channels=[],this.sendBuffer=[],this.ref=0,this.timeout=r.timeout||s,this.transport=r.transport||window.WebSocket||p,this.defaultEncoder=v.encode,this.defaultDecoder=v.decode,this.transport!==p?(this.encode=r.encode||this.defaultEncoder,this.decode=r.decode||this.defaultDecoder):(this.encode=this.defaultEncoder,this.decode=this.defaultDecoder),this.heartbeatIntervalMs=r.heartbeatIntervalMs||3e4,this.reconnectAfterMs=r.reconnectAfterMs||function(t){return[1e3,2e3,5e3,1e4][t-1]||1e4},this.logger=r.logger||function(){},this.longpollerTimeout=r.longpollerTimeout||2e4,this.params=r.params||{},this.endPoint=n+"/"+l.websocket,this.heartbeatTimer=null,this.pendingHeartbeatRef=null,this.reconnectTimer=new y(function(){i.disconnect(function(){return i.connect()})},this.reconnectAfterMs)}return o(t,[{key:"protocol",value:function(){return location.protocol.match(/^https/)?"wss":"ws"}},{key:"endPointURL",value:function(){var t=b.appendParams(b.appendParams(this.endPoint,this.params),{vsn:"2.0.0"});return"/"!==t.charAt(0)?t:"/"===t.charAt(1)?this.protocol()+":"+t:this.protocol()+"://"+location.host+t}},{key:"disconnect",value:function(t,n,e){this.conn&&(this.conn.onclose=function(){},n?this.conn.close(n,e||""):this.conn.close(),this.conn=null),t&&t()}},{key:"connect",value:function(t){var n=this;t&&(console&&console.log("passing params to connect is deprecated. Instead pass :params to the Socket constructor"),this.params=t),this.conn||(this.conn=new this.transport(this.endPointURL()),this.conn.timeout=this.longpollerTimeout,this.conn.onopen=function(){return n.onConnOpen()},this.conn.onerror=function(t){return n.onConnError(t)},this.conn.onmessage=function(t){return n.onConnMessage(t)},this.conn.onclose=function(t){return n.onConnClose(t)})}},{key:"log",value:function(t,n,e){this.logger(t,n,e)}},{key:"onOpen",value:function(t){this.stateChangeCallbacks.open.push(t)}},{key:"onClose",value:function(t){this.stateChangeCallbacks.close.push(t)}},{key:"onError",value:function(t){this.stateChangeCallbacks.error.push(t)}},{key:"onMessage",value:function(t){this.stateChangeCallbacks.message.push(t)}},{key:"onConnOpen",value:function(){var t=this;this.log("transport","connected to "+this.endPointURL()),this.flushSendBuffer(),this.reconnectTimer.reset(),this.conn.skipHeartbeat||(clearInterval(this.heartbeatTimer),this.heartbeatTimer=setInterval(function(){return t.sendHeartbeat()},this.heartbeatIntervalMs)),this.stateChangeCallbacks.open.forEach(function(t){return t()})}},{key:"onConnClose",value:function(t){this.log("transport","close",t),this.triggerChanError(),clearInterval(this.heartbeatTimer),this.reconnectTimer.scheduleTimeout(),this.stateChangeCallbacks.close.forEach(function(n){return n(t)})}},{key:"onConnError",value:function(t){this.log("transport",t),this.triggerChanError(),this.stateChangeCallbacks.error.forEach(function(n){return n(t)})}},{key:"triggerChanError",value:function(){this.channels.forEach(function(t){return t.trigger(a.error)})}},{key:"connectionState",value:function(){switch(this.conn&&this.conn.readyState){case u.connecting:return"connecting";case u.open:return"open";case u.closing:return"closing";default:return"closed"}}},{key:"isConnected",value:function(){return"open"===this.connectionState()}},{key:"remove",value:function(t){this.channels=this.channels.filter(function(n){return n.joinRef()!==t.joinRef()})}},{key:"channel",value:function(t){var n=arguments.length>1&&void 0!==arguments[1]?arguments[1]:{},e=new d(t,n,this);return this.channels.push(e),e}},{key:"push",value:function(t){var n=this,e=t.topic,i=t.event,r=t.payload,o=t.ref,u=t.join_ref,s=function(){n.encode(t,function(t){n.conn.send(t)})};this.log("push",e+" "+i+" ("+u+", "+o+")",r),this.isConnected()?s():this.sendBuffer.push(s)}},{key:"makeRef",value:function(){var t=this.ref+1;return t===this.ref?this.ref=0:this.ref=t,this.ref.toString()}},{key:"sendHeartbeat",value:function(){if(this.isConnected()){if(this.pendingHeartbeatRef)return this.pendingHeartbeatRef=null,this.log("transport","heartbeat timeout. Attempting to re-establish connection"),void this.conn.close(1e3,"hearbeat timeout");this.pendingHeartbeatRef=this.makeRef(),this.push({topic:"phoenix",event:"heartbeat",payload:{},ref:this.pendingHeartbeatRef})}}},{key:"flushSendBuffer",value:function(){this.isConnected()&&this.sendBuffer.length>0&&(this.sendBuffer.forEach(function(t){return t()}),this.sendBuffer=[])}},{key:"onConnMessage",value:function(t){var n=this;this.decode(t.data,function(t){var e=t.topic,i=t.event,r=t.payload,o=t.ref,u=t.join_ref;o&&o===n.pendingHeartbeatRef&&(n.pendingHeartbeatRef=null),n.log("receive",(r.status||"")+" "+e+" "+i+" "+(o&&"("+o+")"||""),r),n.channels.filter(function(t){return t.isMember(e,i,r,u)}).forEach(function(t){return t.trigger(i,r,o,u)}),n.stateChangeCallbacks.message.forEach(function(n){return n(t)})})}}]),t}(),t.LongPoll=function(){function t(n){e(this,t),this.endPoint=null,this.token=null,this.skipHeartbeat=!0,this.onopen=function(){},this.onerror=function(){},this.onmessage=function(){},this.onclose=function(){},this.pollEndpoint=this.normalizeEndpoint(n),this.readyState=u.connecting,this.poll()}return o(t,[{key:"normalizeEndpoint",value:function(t){return t.replace("ws://","http://").replace("wss://","https://").replace(new RegExp("(.*)/"+l.websocket),"$1/"+l.longpoll)}},{key:"endpointURL",value:function(){return b.appendParams(this.pollEndpoint,{token:this.token})}},{key:"closeAndRetry",value:function(){this.close(),this.readyState=u.connecting}},{key:"ontimeout",value:function(){this.onerror("timeout"),this.closeAndRetry()}},{key:"poll",value:function(){var t=this;this.readyState!==u.open&&this.readyState!==u.connecting||b.request("GET",this.endpointURL(),"application/json",null,this.timeout,this.ontimeout.bind(this),function(n){if(n){var e=n.status,i=n.token,r=n.messages;t.token=i}else e=0;switch(e){case 200:r.forEach(function(n){return t.onmessage({data:n})}),t.poll();break;case 204:t.poll();break;case 410:t.readyState=u.open,t.onopen(),t.poll();break;case 0:case 500:t.onerror(),t.closeAndRetry();break;default:throw"unhandled poll status "+e}})}},{key:"send",value:function(t){var n=this;b.request("POST",this.endpointURL(),"application/json",t,this.timeout,this.onerror.bind(this,"timeout"),function(t){t&&200===t.status||(n.onerror(t&&t.status),n.closeAndRetry())})}},{key:"close",value:function(t,n){this.readyState=u.closed,this.onclose()}}]),t}()),b=t.Ajax=function(){function t(){e(this,t)}return o(t,null,[{key:"request",value:function(t,n,e,i,r,o,u){if(window.XDomainRequest){var s=new XDomainRequest;this.xdomainRequest(s,t,n,i,r,o,u)}else{var c=window.XMLHttpRequest?new window.XMLHttpRequest:new ActiveXObject("Microsoft.XMLHTTP");this.xhrRequest(c,t,n,e,i,r,o,u)}}},{key:"xdomainRequest",value:function(t,n,e,i,r,o,u){var s=this;t.timeout=r,t.open(n,e),t.onload=function(){var n=s.parseJSON(t.responseText);u&&u(n)},o&&(t.ontimeout=o),t.onprogress=function(){},t.send(i)}},{key:"xhrRequest",value:function(t,n,e,i,r,o,u,s){var c=this;t.open(n,e,!0),t.timeout=o,t.setRequestHeader("Content-Type",i),t.onerror=function(){s&&s(null)},t.onreadystatechange=function(){if(t.readyState===c.states.complete&&s){var n=c.parseJSON(t.responseText);s(n)}},u&&(t.ontimeout=u),t.send(r)}},{key:"parseJSON",value:function(t){if(!t||""===t)return null;try{return JSON.parse(t)}catch(n){return console&&console.log("failed to parse JSON response",t),null}}},{key:"serialize",value:function(t,n){var e=[];for(var r in t)if(t.hasOwnProperty(r)){var o=n?n+"["+r+"]":r,u=t[r];"object"===(void 0===u?"undefined":i(u))?e.push(this.serialize(u,o)):e.push(encodeURIComponent(o)+"="+encodeURIComponent(u))}return e.join("&")}},{key:"appendParams",value:function(t,n){return 0===Object.keys(n).length?t:""+t+(t.match(/\?/)?"&":"?")+this.serialize(n)}}]),t}();b.states={complete:4};t.Presence={syncState:function(t,n,e,i){var r=this,o=this.clone(t),u={},s={};return this.map(o,function(t,e){n[t]||(s[t]=e)}),this.map(n,function(t,n){var e=o[t];if(e){var i=n.metas.map(function(t){return t.phx_ref}),c=e.metas.map(function(t){return t.phx_ref}),a=n.metas.filter(function(t){return c.indexOf(t.phx_ref)<0}),f=e.metas.filter(function(t){return i.indexOf(t.phx_ref)<0});a.length>0&&(u[t]=n,u[t].metas=a),f.length>0&&(s[t]=r.clone(e),s[t].metas=f)}else u[t]=n}),this.syncDiff(o,{joins:u,leaves:s},e,i)},syncDiff:function(t,e,i,r){var o=e.joins,u=e.leaves,s=this.clone(t);return i||(i=function(){}),r||(r=function(){}),this.map(o,function(t,e){var r=s[t];if(s[t]=e,r){var o;(o=s[t].metas).unshift.apply(o,n(r.metas))}i(t,r,e)}),this.map(u,function(t,n){var e=s[t];if(e){var i=n.metas.map(function(t){return t.phx_ref});e.metas=e.metas.filter(function(t){return i.indexOf(t.phx_ref)<0}),r(t,e,n),0===e.metas.length&&delete s[t]}}),s},list:function(t,n){return n||(n=function(t,n){return n}),this.map(t,function(t,e){return n(t,e)})},map:function(t,n){return Object.getOwnPropertyNames(t).map(function(e){return n(e,t[e])})},clone:function(t){return JSON.parse(JSON.stringify(t))}};var y=function(){function t(n,i){e(this,t),this.callback=n,this.timerCalc=i,this.timer=null,this.tries=0}return o(t,[{key:"reset",value:function(){this.tries=0,clearTimeout(this.timer)}},{key:"scheduleTimeout",value:function(){var t=this;clearTimeout(this.timer),this.timer=setTimeout(function(){t.tries=t.tries+1,t.callback()},this.timerCalc(this.tries+1))}}]),t}()})}));var Xe=function(t,n){return i(this,void 0),t.receive("ok",n.onSucceed).receive("error",n.onError).receive("timeout",n.onTimeout)}.bind(void 0),Ke=function(t,n){return i(this,void 0),function(e){return i(this,void 0),e[t]&&e[t](n)}.bind(this)}.bind(void 0),Ye=function(t){return i(this,void 0),"on"+String(t)}.bind(void 0),Qe=function(t,n,e){return i(this,void 0),t.observers.forEach(Ke(Ye(n),e))}.bind(void 0),$e=function(t,n,e){return i(this,void 0),t.findIndex(Oe([n],e))}.bind(void 0),Ze=function(t){return i(this,void 0),function(n){return i(this,void 0),rn($e(n,"request",t),1,n)}.bind(this)}.bind(void 0),ti=function(t,n){return i(this,void 0),t.notifiers=n(t.notifiers),t}.bind(void 0),ni=function(t,n){i(this,void 0),ti(t,Ze(n)),Qe(n,"Cancel",n)}.bind(void 0),ei={onError:function(t,n,e){i(this,void 0),ii(t,n),Qe(n,"Error","unsubscribe: "+String(e))}.bind(void 0),onTimeout:function(t,n){return i(this,void 0),Qe(n,"Error","unsubscribe: timeout")}.bind(void 0),onSucceed:ni},ii=function(t,n){return i(this,void 0),Xe(t.channel.push("unsubscribe",{subscriptionId:n.subscriptionId}),We(ei,t,n.request))}.bind(void 0),ri=function(t,n){return i(this,void 0),"subscription"===n.operationType?ii(t,n):ni(t,n),t}.bind(void 0),oi=function(t,n,e){return i(this,void 0),t.forEach(function(t){return i(this,void 0),Qe(t,n,e)}.bind(this))}.bind(void 0),ui=function(t){return i(this,void 0),t.map(function(t){var n=t.column,e=t.line;return i(this,void 0),String(e)+":"+String(n)}.bind(this)).join("; ")}.bind(void 0),si=function(t){var n=t.message,e=t.locations;return i(this,void 0),n+(e?" ("+String(ui(e))+")":"")}.bind(void 0),ci=function(t){return i(this,void 0),t.map(si).join("\n")}.bind(void 0),ai=/^\s*(query|mutation|subscription|\{)/,fi=function(t){return i(this,void 0),"{"===t?"query":t}.bind(void 0),li=function(t){i(this,void 0);var n=t.match(ai);if(!n)throw new TypeError("Invalid operation:\n"+String(t));return fi(n[1])}.bind(void 0),hi=function(t){return i(this,void 0),function(n){return i(this,void 0),on($e(n,"request",t),[t],n)}.bind(this)}.bind(void 0),di=function(t){return i(this,void 0),Qe(t,"Start",t)}.bind(void 0),vi=function(t,n,e){var r=e.subscriptionId;i(this,void 0),ti(t,hi(zt({},n,{subscriptionId:r}))),di(n)}.bind(void 0),pi=function(t,n,e){i(this,void 0),ti(t,Ze(n)),Qe(n,"Abort",e)}.bind(void 0),bi=function(t,n,e){return i(this,void 0),pi(t,n,new Error(e))}.bind(void 0),yi=function(t,n,e){i(this,void 0),e.errors?bi(t,n,ci(e.errors)):vi(t,n,e)}.bind(void 0),mi=function(t,n,e){i(this,void 0),ti(t,Ze(n)),Qe(n,"Result",e.payload.result)}.bind(void 0),gi=function(t,n){return i(this,void 0),Qe(n,"Error",new Error("request: timeout"))}.bind(void 0),wi={onError:bi,onTimeout:gi,onSucceed:mi},ki={onError:bi,onTimeout:gi,onSucceed:yi},ji=function(t,n,e){return i(this,void 0),Xe(t.channel.push("doc",n),We(e,t,n))}.bind(void 0),Si=function(t,n){i(this,void 0),"subscription"===n.operationType?ji(t,n.request,ki):(di(n),ji(t,n.request,wi))}.bind(void 0),_i=function(t){return i(this,void 0),{onError:function(n){return i(this,void 0),oi(t.notifiers,"Error",new Error("channel join: "+String(n)))}.bind(this),onSucceed:function(){i(this,void 0),t.isJoining=!1,t.notifiers.forEach(function(n){return i(this,void 0),Si(t,n)}.bind(this))}.bind(this),onTimeout:function(){return i(this,void 0),oi(t.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),Oi=function(t){return i(this,void 0),Xe(t.channel.join(),_i(t))}.bind(void 0),Ei=function(){return i(this,void 0),new Error("connection: close")}.bind(void 0),Ti=function(t,n){i(this,void 0),ti(t,Ze(n)),Qe(n,"Abort",Ei())}.bind(void 0),xi=function(t){return i(this,void 0),function(n){i(this,void 0),"mutation"===n.operationType?Ti(t,n):Qe(n,"Error",Ei())}.bind(this)}.bind(void 0),Pi=function(t){return i(this,void 0),function(){i(this,void 0),0!==t.notifiers.length&&(t.isJoining=!0,t.notifiers.forEach(xi(t)))}.bind(this)}.bind(void 0),Ai=function(t,n){var e=n.payload;i(this,void 0);var r=ze(t.notifiers,"subscriptionId",e.subscriptionId);r&&Qe(r,"Result",e.result)}.bind(void 0),Ci=function(t){return i(this,void 0),function(n){i(this,void 0),"subscription:data"===n.event&&Ai(t,n)}.bind(this)}.bind(void 0),Mi=function(t){i(this,void 0),0===t.notifiers.length?t.isJoining=!1:Oi(t)}.bind(void 0),Ri=function(t){return i(this,void 0),function(){i(this,void 0),t.isJoining&&Mi(t)}.bind(this)}.bind(void 0),Li=function(t){i(this,void 0);var n={phoenixSocket:t,channel:t.channel("__absinthe__:control"),isJoining:!1,notifiers:[]};return t.onOpen(Ri(n)),t.onMessage(Ci(n)),t.onClose(Pi(n)),n}.bind(void 0),Ii=function(t,n){var e=t.observers,r=Qt(t,["observers"]);return i(this,void 0),zt({},r,{observers:[].concat(qt(e),[n])})}.bind(void 0),Ni=function(t,n,e){return i(this,void 0),ti(t,hi(Ii(n,e)))}.bind(void 0),Ji=function(t){return i(this,void 0),{request:t,observers:[],operationType:li(t.operation),subscriptionId:void 0}}.bind(void 0),qi=function(t){i(this,void 0),t.isJoining=!0,t.phoenixSocket.isConnected()?Oi(t):t.phoenixSocket.connect()}.bind(void 0),Hi=function(t){return i(this,void 0),t.phoenixSocket.isConnected()&&!t.isJoining}.bind(void 0),Fi=function(t,n){i(this,void 0);var e=Ji(n);return ti(t,$t([e])),Hi(t)?Si(t,e):qi(t),e}.bind(void 0),Di=e(function(t,n){!function(e,i){e(n,t)}(function(t,n){function e(t){return"function"==typeof Symbol&&Boolean(Symbol[t])}function i(t){return e(t)?Symbol[t]:"@@"+t}function r(t,n){var e=t[n];if(null!=e){if("function"!=typeof e)throw new TypeError(e+" is not a function");return e}}function o(t){var n=t.constructor;return void 0!==n&&null===(n=n[i("species")])&&(n=void 0),void 0!==n?n:d}function u(t,n){Object.keys(n).forEach(function(e){var i=Object.getOwnPropertyDescriptor(n,e);i.enumerable=!1,Object.defineProperty(t,e,i)})}function s(t){var n=t._cleanup;n&&(t._cleanup=void 0,n())}function c(t){return void 0===t._observer}function a(t){c(t)||(t._observer=void 0,s(t))}function f(t){return function(){t.unsubscribe()}}function l(t,n){if(Object(t)!==t)throw new TypeError("Observer must be an object");this._cleanup=void 0,this._observer=t;var e=r(t,"start");if(e&&e.call(t,this),!c(this)){t=new h(this);try{var i=n.call(void 0,t);if(null!=i){if("function"==typeof i.unsubscribe)i=f(i);else if("function"!=typeof i)throw new TypeError(i+" is not a function");this._cleanup=i}}catch(n){return void t.error(n)}c(this)&&s(this)}}function h(t){this._subscription=t}function d(t){if("function"!=typeof t)throw new TypeError("Observable initializer must be a function");this._subscriber=t}"function"!=typeof Symbol||Symbol.observable||(Symbol.observable=Symbol("observable")),u(l.prototype={},{get closed(){return c(this)},unsubscribe:function(){a(this)}}),u(h.prototype={},{get closed(){return c(this._subscription)},next:function(t){var n=this._subscription;if(!c(n)){var e=n._observer,i=r(e,"next");if(i)return i.call(e,t)}},error:function(t){var n=this._subscription;if(c(n))throw t;var e=n._observer;n._observer=void 0;try{var i=r(e,"error");if(!i)throw t;t=i.call(e,t)}catch(t){try{s(n)}finally{throw t}}return s(n),t},complete:function(t){var n=this._subscription;if(!c(n)){var e=n._observer;n._observer=void 0;try{var i=r(e,"complete");t=i?i.call(e,t):void 0}catch(t){try{s(n)}finally{throw t}}return s(n),t}}}),u(d.prototype,{subscribe:function(t){for(var n=[],e=1;e<arguments.length;++e)n.push(arguments[e]);return"function"==typeof t&&(t={next:t,error:n[0],complete:n[1]}),new l(t,this._subscriber)},forEach:function(t){var n=this;return new Promise(function(e,i){if("function"!=typeof t)return Promise.reject(new TypeError(t+" is not a function"));n.subscribe({_subscription:null,start:function(t){if(Object(t)!==t)throw new TypeError(t+" is not an object");this._subscription=t},next:function(n){var e=this._subscription;if(!e.closed)try{return t(n)}catch(t){i(t),e.unsubscribe()}},error:i,complete:e})})},map:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");return new(o(this))(function(e){return n.subscribe({next:function(n){if(!e.closed){try{n=t(n)}catch(t){return e.error(t)}return e.next(n)}},error:function(t){return e.error(t)},complete:function(t){return e.complete(t)}})})},filter:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");return new(o(this))(function(e){return n.subscribe({next:function(n){if(!e.closed){try{if(!t(n))return}catch(t){return e.error(t)}return e.next(n)}},error:function(t){return e.error(t)},complete:function(){return e.complete()}})})},reduce:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");var e=o(this),i=arguments.length>1,r=!1,u=arguments[1];return new e(function(e){return n.subscribe({next:function(n){if(!e.closed){var o=!r;if(r=!0,!o||i)try{u=t(u,n)}catch(t){return e.error(t)}else u=n}},error:function(t){e.error(t)},complete:function(){r||i?(e.next(u),e.complete()):e.error(new TypeError("Cannot reduce an empty sequence"))}})})},flatMap:function(t){var n=this;if("function"!=typeof t)throw new TypeError(t+" is not a function");return new(o(this))(function(e){function i(){r&&0===o.length&&e.complete()}var r=!1,o=[],u=n.subscribe({next:function(n){if(t)try{n=t(n)}catch(t){return void e.error(t)}d.from(n).subscribe({_subscription:null,start:function(t){o.push(this._subscription=t)},next:function(t){e.next(t)},error:function(t){e.error(t)},complete:function(){var t=o.indexOf(this._subscription);t>=0&&o.splice(t,1),i()}})},error:function(t){return e.error(t)},complete:function(){r=!0,i()}});return function(){o.forEach(function(t){return t.unsubscribe()}),u.unsubscribe()}})}}),Object.defineProperty(d.prototype,i("observable"),{value:function(){return this},writable:!0,configurable:!0}),u(d,{from:function(t){var n="function"==typeof this?this:d;if(null==t)throw new TypeError(t+" is not an object");var o=r(t,i("observable"));if(o){var u=o.call(t);if(Object(u)!==u)throw new TypeError(u+" is not an object");return u.constructor===n?u:new n(function(t){return u.subscribe(t)})}if(e("iterator")&&(o=r(t,i("iterator"))))return new n(function(n){for(var e,i=o.call(t)[Symbol.iterator]();!(e=i.next()).done;){var r=e.value;if(n.next(r),n.closed)return}n.complete()});if(Array.isArray(t))return new n(function(n){for(var e=0;e<t.length;++e)if(n.next(t[e]),n.closed)return;n.complete()});throw new TypeError(t+" is not observable")},of:function(){for(var t=[],n=0;n<arguments.length;++n)t.push(arguments[n]);return new("function"==typeof this?this:d)(function(n){for(var e=0;e<t.length;++e)if(n.next(t[e]),n.closed)return;n.complete()})}}),Object.defineProperty(d,i("species"),{get:function(){return this},configurable:!0}),t.Observable=d})}).Observable,Bi=function(t,n){return i(this,void 0),function(e){i(this,void 0),n.next(e),"subscription"!==t.operationType&&n.complete()}.bind(this)}.bind(void 0),Ui=function(t,n){var e=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},r=e.onError,o=e.onStart,u=e.unsubscribe;return i(this,void 0),new Di(function(e){return i(this,void 0),Ni(t,n,{onError:r,onStart:o,onAbort:e.error,onresult:Bi(n,e)}),u}.bind(this))}.bind(void 0),Gi=function(t,n){var e=t.observers,r=Qt(t,["observers"]);return i(this,void 0),zt({},r,{observers:rn(e.indexOf(n),1,e)})}.bind(void 0),zi=function(t,n,e){return i(this,void 0),ti(t,hi(Gi(n,e))),t}.bind(void 0);t.cancel=ri,t.create=Li,t.observe=Ni,t.send=Fi,t.toObservable=Ui,t.unobserve=zi,Object.defineProperty(t,"__esModule",{value:!0})}); | ||
| //# sourceMappingURL=index.js.map |
@@ -1,2 +0,2 @@ | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import"phoenix";import _extends from"babel-runtime/helpers/extends";import{errorsToString}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";import{remove,replace}from"@jumpn/utils-array";var _this$2=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$2),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[n]&&e[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,i,e){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(i),e))}.bind(void 0),_this$3=void 0,notifyall=function(n,i,e){return _newArrowCheck(this,_this$3),n.forEach(function(n){return _newArrowCheck(this,_this$3),notify(n,i,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(n,i,e){return _newArrowCheck(this,_this$7),n.find(hasIn([i],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var t=arguments.length,o=Array(t),r=0;r<t;r++)o[r]=arguments[r];_newArrowCheck(this,_this$6);var s=find(n.notifiers,"request",i);s&&e.apply(void 0,[n,s].concat(o))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,e){return _newArrowCheck(this,_this$6),map(createEventHandler(i,e),n)}.bind(void 0),_this$9=void 0,findIndex=function(n,i,e){return _newArrowCheck(this,_this$9),n.findIndex(hasIn([i],e))}.bind(void 0),_this$8=void 0,remove$1=function(n){return _newArrowCheck(this,_this$8),function(i){return _newArrowCheck(this,_this$8),remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(n){return _newArrowCheck(this,_this$10),function(i){return _newArrowCheck(this,_this$10),replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$11),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$5=void 0,onQueryOrMutationResponse=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Result",e.payload.result)}.bind(void 0),notifyStart=function(n){return _newArrowCheck(this,_this$5),notify(n,"Start",n)}.bind(void 0),onSubscriptionResponse=function(n,i,e){var t=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:t}))),notifyStart(i)}.bind(void 0),onResponse=function(n,i,e){_newArrowCheck(this,_this$5),e.subscriptionId?onSubscriptionResponse(n,i,e):e.payload&&onQueryOrMutationResponse(n,i,e)}.bind(void 0),abortRequest=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Abort",e)}.bind(void 0),onError=function(n,i,e){return _newArrowCheck(this,_this$5),abortRequest(n,i,new Error(e))}.bind(void 0),onSucceed=function(n,i,e){_newArrowCheck(this,_this$5),e.errors?onError(n,i,errorsToString(e.errors)):onResponse(n,i,e)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$5),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(n,i){_newArrowCheck(this,_this$5),"subscription"!==i.operationType&¬ifyStart(i),handlePush(n.channel.push("doc",i.request),createPushHandler(notifierPushHandler,n,i.request))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$1),{onError:function(i){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this$1),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$1),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(n,i){_newArrowCheck(this,_this),updateNotifiers(n,remove$1(i)),notify(i,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"mutation"===i.operationType?mutationOnConnectionClose(n,i):notify(i,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),0!==n.notifiers.length&&(n.isJoining=!0,n.notifiers.forEach(notifierOnConnectionClose(n)))}.bind(this)}.bind(void 0),onSubscriptionData=function(n,i){var e=i.payload;_newArrowCheck(this,_this);var t=find(n.notifiers,"subscriptionId",e.subscriptionId);t&¬ify(t,"Result",e.result)}.bind(void 0),onMessage=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"subscription:data"===i.event&&onSubscriptionData(n,i)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(n){_newArrowCheck(this,_this),0===n.notifiers.length?n.isJoining=!1:joinChannel(n)}.bind(void 0),onConnectionOpen=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),n.isJoining&&joinChannelIfNeeded(n)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(n){_newArrowCheck(this,_this);var i={phoenixSocket:n,channel:n.channel(absintheChannelName),isJoining:!1,notifiers:[]};return n.onOpen(onConnectionOpen(i)),n.onMessage(onMessage(i)),n.onClose(onConnectionClose(i)),i}.bind(void 0);export default create; | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import"phoenix";import _extends from"babel-runtime/helpers/extends";import{errorsToString}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";import{remove,replace}from"@jumpn/utils-array";var _this$2=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$2),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[n]&&e[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,i,e){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(i),e))}.bind(void 0),_this$3=void 0,notifyall=function(n,i,e){return _newArrowCheck(this,_this$3),n.forEach(function(n){return _newArrowCheck(this,_this$3),notify(n,i,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(n,i,e){return _newArrowCheck(this,_this$7),n.find(hasIn([i],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(n.notifiers,"request",i);s&&e.apply(void 0,[n,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,e){return _newArrowCheck(this,_this$6),map(createEventHandler(i,e),n)}.bind(void 0),_this$9=void 0,findIndex=function(n,i,e){return _newArrowCheck(this,_this$9),n.findIndex(hasIn([i],e))}.bind(void 0),_this$8=void 0,remove$1=function(n){return _newArrowCheck(this,_this$8),function(i){return _newArrowCheck(this,_this$8),remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(n){return _newArrowCheck(this,_this$10),function(i){return _newArrowCheck(this,_this$10),replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$11),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$5=void 0,notifyStart=function(n){return _newArrowCheck(this,_this$5),notify(n,"Start",n)}.bind(void 0),onSubscriptionSucceed=function(n,i,e){var r=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:r}))),notifyStart(i)}.bind(void 0),abortRequest=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Abort",e)}.bind(void 0),onError=function(n,i,e){return _newArrowCheck(this,_this$5),abortRequest(n,i,new Error(e))}.bind(void 0),onSubscriptionResponse=function(n,i,e){_newArrowCheck(this,_this$5),e.errors?onError(n,i,errorsToString(e.errors)):onSubscriptionSucceed(n,i,e)}.bind(void 0),onQueryOrMutationResponse=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Result",e.payload.result)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$5),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send=function(n,i,e){return _newArrowCheck(this,_this$5),handlePush(n.channel.push("doc",i),createPushHandler(e,n,i))}.bind(void 0),pushRequest=function(n,i){_newArrowCheck(this,_this$5),"subscription"===i.operationType?send(n,i.request,subcriptionHandler):(notifyStart(i),send(n,i.request,queryOrMutationHandler))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$1),{onError:function(i){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this$1),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$1),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(n,i){_newArrowCheck(this,_this),updateNotifiers(n,remove$1(i)),notify(i,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"mutation"===i.operationType?mutationOnConnectionClose(n,i):notify(i,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),0!==n.notifiers.length&&(n.isJoining=!0,n.notifiers.forEach(notifierOnConnectionClose(n)))}.bind(this)}.bind(void 0),onSubscriptionData=function(n,i){var e=i.payload;_newArrowCheck(this,_this);var r=find(n.notifiers,"subscriptionId",e.subscriptionId);r&¬ify(r,"Result",e.result)}.bind(void 0),onMessage=function(n){return _newArrowCheck(this,_this),function(i){_newArrowCheck(this,_this),"subscription:data"===i.event&&onSubscriptionData(n,i)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(n){_newArrowCheck(this,_this),0===n.notifiers.length?n.isJoining=!1:joinChannel(n)}.bind(void 0),onConnectionOpen=function(n){return _newArrowCheck(this,_this),function(){_newArrowCheck(this,_this),n.isJoining&&joinChannelIfNeeded(n)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(n){_newArrowCheck(this,_this);var i={phoenixSocket:n,channel:n.channel(absintheChannelName),isJoining:!1,notifiers:[]};return n.onOpen(onConnectionOpen(i)),n.onMessage(onMessage(i)),n.onClose(onConnectionClose(i)),i}.bind(void 0);export default create; | ||
| //# sourceMappingURL=create.js.map |
@@ -1,2 +0,2 @@ | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{hasIn,map}from"@jumpn/utils-composite";import"phoenix";import{append,remove,replace}from"@jumpn/utils-array";import _extends from"babel-runtime/helpers/extends";import{errorsToString,getOperationType}from"@jumpn/utils-graphql";import _toConsumableArray from"babel-runtime/helpers/toConsumableArray";import _objectWithoutProperties from"babel-runtime/helpers/objectWithoutProperties";import Observable from"zen-observable";var _this$2=void 0,find=function(n,e,i){return _newArrowCheck(this,_this$2),n.find(hasIn([e],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(n,e){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var r=arguments.length,o=Array(r),t=0;t<r;t++)o[t]=arguments[t];_newArrowCheck(this,_this$1);var s=find(n.notifiers,"request",e);s&&i.apply(void 0,[n,s].concat(o))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,e,i){return _newArrowCheck(this,_this$1),map(createEventHandler(e,i),n)}.bind(void 0),_this$3=void 0,handlePush=function(n,e){return _newArrowCheck(this,_this$3),n.receive("ok",e.onSucceed).receive("error",e.onError).receive("timeout",e.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,e){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[n]&&i[n](e)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,e,i){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(e),i))}.bind(void 0),_this$6=void 0,findIndex=function(n,e,i){return _newArrowCheck(this,_this$6),n.findIndex(hasIn([e],i))}.bind(void 0),_this$5=void 0,remove$1=function(n){return _newArrowCheck(this,_this$5),function(e){return _newArrowCheck(this,_this$5),remove(findIndex(e,"request",n),1,e)}.bind(this)}.bind(void 0),_this$7=void 0,updateNotifiers=function(n,e){return _newArrowCheck(this,_this$7),n.notifiers=e(n.notifiers),n}.bind(void 0),_this=void 0,removeNotifiers=function(n,e){_newArrowCheck(this,_this),updateNotifiers(n,remove$1(e)),notify(e,"Cancel",e)}.bind(void 0),onError=function(n,e,i){_newArrowCheck(this,_this),unsubscribe(n,e),notify(e,"Error","unsubscribe: "+String(i))}.bind(void 0),onTimeout=function(n,e){return _newArrowCheck(this,_this),notify(e,"Error","unsubscribe: timeout")}.bind(void 0),notifierPushHandler={onError:onError,onTimeout:onTimeout,onSucceed:removeNotifiers},unsubscribe=function(n,e){return _newArrowCheck(this,_this),handlePush(n.channel.push("unsubscribe",{subscriptionId:e.subscriptionId}),createPushHandler(notifierPushHandler,n,e.request))}.bind(void 0),cancel=function(n,e){return _newArrowCheck(this,_this),"subscription"===e.operationType?unsubscribe(n,e):removeNotifiers(n,e),n}.bind(void 0),_this$10=void 0,notifyall=function(n,e,i){return _newArrowCheck(this,_this$10),n.forEach(function(n){return _newArrowCheck(this,_this$10),notify(n,e,i)}.bind(this))}.bind(void 0),_this$12=void 0,refresh=function(n){return _newArrowCheck(this,_this$12),function(e){return _newArrowCheck(this,_this$12),replace(findIndex(e,"request",n),[n],e)}.bind(this)}.bind(void 0),_this$11=void 0,onQueryOrMutationResponse=function(n,e,i){_newArrowCheck(this,_this$11),updateNotifiers(n,remove$1(e)),notify(e,"Result",i.payload.result)}.bind(void 0),notifyStart=function(n){return _newArrowCheck(this,_this$11),notify(n,"Start",n)}.bind(void 0),onSubscriptionResponse=function(n,e,i){var r=i.subscriptionId;_newArrowCheck(this,_this$11),updateNotifiers(n,refresh(_extends({},e,{subscriptionId:r}))),notifyStart(e)}.bind(void 0),onResponse=function(n,e,i){_newArrowCheck(this,_this$11),i.subscriptionId?onSubscriptionResponse(n,e,i):i.payload&&onQueryOrMutationResponse(n,e,i)}.bind(void 0),abortRequest=function(n,e,i){_newArrowCheck(this,_this$11),updateNotifiers(n,remove$1(e)),notify(e,"Abort",i)}.bind(void 0),onError$1=function(n,e,i){return _newArrowCheck(this,_this$11),abortRequest(n,e,new Error(i))}.bind(void 0),onSucceed=function(n,e,i){_newArrowCheck(this,_this$11),i.errors?onError$1(n,e,errorsToString(i.errors)):onResponse(n,e,i)}.bind(void 0),onTimeout$1=function(n,e){return _newArrowCheck(this,_this$11),notify(e,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler$1={onError:onError$1,onSucceed:onSucceed,onTimeout:onTimeout$1},pushRequest=function(n,e){_newArrowCheck(this,_this$11),"subscription"!==e.operationType&¬ifyStart(e),handlePush(n.channel.push("doc",e.request),createPushHandler(notifierPushHandler$1,n,e.request))}.bind(void 0),_this$9=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$9),{onError:function(e){return _newArrowCheck(this,_this$9),notifyall(n.notifiers,"Error",new Error("channel join: "+String(e)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$9),n.isJoining=!1,n.notifiers.forEach(function(e){return _newArrowCheck(this,_this$9),pushRequest(n,e)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$9),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$9),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this$8=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this$8),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(n,e){_newArrowCheck(this,_this$8),updateNotifiers(n,remove$1(e)),notify(e,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(n){return _newArrowCheck(this,_this$8),function(e){_newArrowCheck(this,_this$8),"mutation"===e.operationType?mutationOnConnectionClose(n,e):notify(e,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(n){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),0!==n.notifiers.length&&(n.isJoining=!0,n.notifiers.forEach(notifierOnConnectionClose(n)))}.bind(this)}.bind(void 0),onSubscriptionData=function(n,e){var i=e.payload;_newArrowCheck(this,_this$8);var r=find(n.notifiers,"subscriptionId",i.subscriptionId);r&¬ify(r,"Result",i.result)}.bind(void 0),onMessage=function(n){return _newArrowCheck(this,_this$8),function(e){_newArrowCheck(this,_this$8),"subscription:data"===e.event&&onSubscriptionData(n,e)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(n){_newArrowCheck(this,_this$8),0===n.notifiers.length?n.isJoining=!1:joinChannel(n)}.bind(void 0),onConnectionOpen=function(n){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),n.isJoining&&joinChannelIfNeeded(n)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(n){_newArrowCheck(this,_this$8);var e={phoenixSocket:n,channel:n.channel(absintheChannelName),isJoining:!1,notifiers:[]};return n.onOpen(onConnectionOpen(e)),n.onMessage(onMessage(e)),n.onClose(onConnectionClose(e)),e}.bind(void 0),_this$14=void 0,observe$2=function(n,e){var i=n.observers,r=_objectWithoutProperties(n,["observers"]);return _newArrowCheck(this,_this$14),_extends({},r,{observers:[].concat(_toConsumableArray(i),[e])})}.bind(void 0),_this$13=void 0,observe=function(n,e,i){return _newArrowCheck(this,_this$13),updateNotifiers(n,refresh(observe$2(e,i)))}.bind(void 0),_this$16=void 0,create$2=function(n){return _newArrowCheck(this,_this$16),{request:n,observers:[],operationType:getOperationType(n.operation),subscriptionId:void 0}}.bind(void 0),_this$15=void 0,connectOrJoin=function(n){_newArrowCheck(this,_this$15),n.isJoining=!0,n.phoenixSocket.isConnected()?joinChannel(n):n.phoenixSocket.connect()}.bind(void 0),isJoined=function(n){return _newArrowCheck(this,_this$15),n.phoenixSocket.isConnected()&&!n.isJoining}.bind(void 0),send=function(n,e){_newArrowCheck(this,_this$15);var i=create$2(e);return updateNotifiers(n,append([i])),isJoined(n)?pushRequest(n,i):connectOrJoin(n),i}.bind(void 0),_this$17=void 0,onResult=function(n,e){return _newArrowCheck(this,_this$17),function(i){_newArrowCheck(this,_this$17),e.next(i),"subscription"!==n.operationType&&e.complete()}.bind(this)}.bind(void 0),toObservable=function(n,e){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},r=i.onError,o=i.onStart,t=i.unsubscribe;return _newArrowCheck(this,_this$17),new Observable(function(i){return _newArrowCheck(this,_this$17),observe(n,e,{onError:r,onStart:o,onAbort:i.error,onresult:onResult(e,i)}),t}.bind(this))}.bind(void 0),_this$19=void 0,unobserve$2=function(n,e){var i=n.observers,r=_objectWithoutProperties(n,["observers"]);return _newArrowCheck(this,_this$19),_extends({},r,{observers:remove(i.indexOf(e),1,i)})}.bind(void 0),_this$18=void 0,unobserve=function(n,e,i){return _newArrowCheck(this,_this$18),updateNotifiers(n,refresh(unobserve$2(e,i))),n}.bind(void 0);export{cancel,create,observe,send,toObservable,unobserve}; | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{hasIn,map}from"@jumpn/utils-composite";import"phoenix";import{append,remove,replace}from"@jumpn/utils-array";import _extends from"babel-runtime/helpers/extends";import{errorsToString,getOperationType}from"@jumpn/utils-graphql";import _toConsumableArray from"babel-runtime/helpers/toConsumableArray";import _objectWithoutProperties from"babel-runtime/helpers/objectWithoutProperties";import Observable from"zen-observable";var _this$2=void 0,find=function(n,e,i){return _newArrowCheck(this,_this$2),n.find(hasIn([e],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(n,e){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var r=arguments.length,o=Array(r),t=0;t<r;t++)o[t]=arguments[t];_newArrowCheck(this,_this$1);var s=find(n.notifiers,"request",e);s&&i.apply(void 0,[n,s].concat(o))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,e,i){return _newArrowCheck(this,_this$1),map(createEventHandler(e,i),n)}.bind(void 0),_this$3=void 0,handlePush=function(n,e){return _newArrowCheck(this,_this$3),n.receive("ok",e.onSucceed).receive("error",e.onError).receive("timeout",e.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,e){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[n]&&i[n](e)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,e,i){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(e),i))}.bind(void 0),_this$6=void 0,findIndex=function(n,e,i){return _newArrowCheck(this,_this$6),n.findIndex(hasIn([e],i))}.bind(void 0),_this$5=void 0,remove$1=function(n){return _newArrowCheck(this,_this$5),function(e){return _newArrowCheck(this,_this$5),remove(findIndex(e,"request",n),1,e)}.bind(this)}.bind(void 0),_this$7=void 0,updateNotifiers=function(n,e){return _newArrowCheck(this,_this$7),n.notifiers=e(n.notifiers),n}.bind(void 0),_this=void 0,removeNotifiers=function(n,e){_newArrowCheck(this,_this),updateNotifiers(n,remove$1(e)),notify(e,"Cancel",e)}.bind(void 0),onError=function(n,e,i){_newArrowCheck(this,_this),unsubscribe(n,e),notify(e,"Error","unsubscribe: "+String(i))}.bind(void 0),onTimeout=function(n,e){return _newArrowCheck(this,_this),notify(e,"Error","unsubscribe: timeout")}.bind(void 0),notifierPushHandler={onError:onError,onTimeout:onTimeout,onSucceed:removeNotifiers},unsubscribe=function(n,e){return _newArrowCheck(this,_this),handlePush(n.channel.push("unsubscribe",{subscriptionId:e.subscriptionId}),createPushHandler(notifierPushHandler,n,e.request))}.bind(void 0),cancel=function(n,e){return _newArrowCheck(this,_this),"subscription"===e.operationType?unsubscribe(n,e):removeNotifiers(n,e),n}.bind(void 0),_this$10=void 0,notifyall=function(n,e,i){return _newArrowCheck(this,_this$10),n.forEach(function(n){return _newArrowCheck(this,_this$10),notify(n,e,i)}.bind(this))}.bind(void 0),_this$12=void 0,refresh=function(n){return _newArrowCheck(this,_this$12),function(e){return _newArrowCheck(this,_this$12),replace(findIndex(e,"request",n),[n],e)}.bind(this)}.bind(void 0),_this$11=void 0,notifyStart=function(n){return _newArrowCheck(this,_this$11),notify(n,"Start",n)}.bind(void 0),onSubscriptionSucceed=function(n,e,i){var r=i.subscriptionId;_newArrowCheck(this,_this$11),updateNotifiers(n,refresh(_extends({},e,{subscriptionId:r}))),notifyStart(e)}.bind(void 0),abortRequest=function(n,e,i){_newArrowCheck(this,_this$11),updateNotifiers(n,remove$1(e)),notify(e,"Abort",i)}.bind(void 0),onError$1=function(n,e,i){return _newArrowCheck(this,_this$11),abortRequest(n,e,new Error(i))}.bind(void 0),onSubscriptionResponse=function(n,e,i){_newArrowCheck(this,_this$11),i.errors?onError$1(n,e,errorsToString(i.errors)):onSubscriptionSucceed(n,e,i)}.bind(void 0),onQueryOrMutationResponse=function(n,e,i){_newArrowCheck(this,_this$11),updateNotifiers(n,remove$1(e)),notify(e,"Result",i.payload.result)}.bind(void 0),onTimeout$1=function(n,e){return _newArrowCheck(this,_this$11),notify(e,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError$1,onTimeout:onTimeout$1,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError$1,onTimeout:onTimeout$1,onSucceed:onSubscriptionResponse},send=function(n,e,i){return _newArrowCheck(this,_this$11),handlePush(n.channel.push("doc",e),createPushHandler(i,n,e))}.bind(void 0),pushRequest=function(n,e){_newArrowCheck(this,_this$11),"subscription"===e.operationType?send(n,e.request,subcriptionHandler):(notifyStart(e),send(n,e.request,queryOrMutationHandler))}.bind(void 0),_this$9=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$9),{onError:function(e){return _newArrowCheck(this,_this$9),notifyall(n.notifiers,"Error",new Error("channel join: "+String(e)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$9),n.isJoining=!1,n.notifiers.forEach(function(e){return _newArrowCheck(this,_this$9),pushRequest(n,e)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$9),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$9),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this$8=void 0,createConnectionCloseError=function(){return _newArrowCheck(this,_this$8),new Error("connection: close")}.bind(void 0),mutationOnConnectionClose=function(n,e){_newArrowCheck(this,_this$8),updateNotifiers(n,remove$1(e)),notify(e,"Abort",createConnectionCloseError())}.bind(void 0),notifierOnConnectionClose=function(n){return _newArrowCheck(this,_this$8),function(e){_newArrowCheck(this,_this$8),"mutation"===e.operationType?mutationOnConnectionClose(n,e):notify(e,"Error",createConnectionCloseError())}.bind(this)}.bind(void 0),onConnectionClose=function(n){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),0!==n.notifiers.length&&(n.isJoining=!0,n.notifiers.forEach(notifierOnConnectionClose(n)))}.bind(this)}.bind(void 0),onSubscriptionData=function(n,e){var i=e.payload;_newArrowCheck(this,_this$8);var r=find(n.notifiers,"subscriptionId",i.subscriptionId);r&¬ify(r,"Result",i.result)}.bind(void 0),onMessage=function(n){return _newArrowCheck(this,_this$8),function(e){_newArrowCheck(this,_this$8),"subscription:data"===e.event&&onSubscriptionData(n,e)}.bind(this)}.bind(void 0),joinChannelIfNeeded=function(n){_newArrowCheck(this,_this$8),0===n.notifiers.length?n.isJoining=!1:joinChannel(n)}.bind(void 0),onConnectionOpen=function(n){return _newArrowCheck(this,_this$8),function(){_newArrowCheck(this,_this$8),n.isJoining&&joinChannelIfNeeded(n)}.bind(this)}.bind(void 0),absintheChannelName="__absinthe__:control",create=function(n){_newArrowCheck(this,_this$8);var e={phoenixSocket:n,channel:n.channel(absintheChannelName),isJoining:!1,notifiers:[]};return n.onOpen(onConnectionOpen(e)),n.onMessage(onMessage(e)),n.onClose(onConnectionClose(e)),e}.bind(void 0),_this$14=void 0,observe$2=function(n,e){var i=n.observers,r=_objectWithoutProperties(n,["observers"]);return _newArrowCheck(this,_this$14),_extends({},r,{observers:[].concat(_toConsumableArray(i),[e])})}.bind(void 0),_this$13=void 0,observe=function(n,e,i){return _newArrowCheck(this,_this$13),updateNotifiers(n,refresh(observe$2(e,i)))}.bind(void 0),_this$16=void 0,create$2=function(n){return _newArrowCheck(this,_this$16),{request:n,observers:[],operationType:getOperationType(n.operation),subscriptionId:void 0}}.bind(void 0),_this$15=void 0,connectOrJoin=function(n){_newArrowCheck(this,_this$15),n.isJoining=!0,n.phoenixSocket.isConnected()?joinChannel(n):n.phoenixSocket.connect()}.bind(void 0),isJoined=function(n){return _newArrowCheck(this,_this$15),n.phoenixSocket.isConnected()&&!n.isJoining}.bind(void 0),send$1=function(n,e){_newArrowCheck(this,_this$15);var i=create$2(e);return updateNotifiers(n,append([i])),isJoined(n)?pushRequest(n,i):connectOrJoin(n),i}.bind(void 0),_this$17=void 0,onResult=function(n,e){return _newArrowCheck(this,_this$17),function(i){_newArrowCheck(this,_this$17),e.next(i),"subscription"!==n.operationType&&e.complete()}.bind(this)}.bind(void 0),toObservable=function(n,e){var i=arguments.length>2&&void 0!==arguments[2]?arguments[2]:{},r=i.onError,o=i.onStart,t=i.unsubscribe;return _newArrowCheck(this,_this$17),new Observable(function(i){return _newArrowCheck(this,_this$17),observe(n,e,{onError:r,onStart:o,onAbort:i.error,onresult:onResult(e,i)}),t}.bind(this))}.bind(void 0),_this$19=void 0,unobserve$2=function(n,e){var i=n.observers,r=_objectWithoutProperties(n,["observers"]);return _newArrowCheck(this,_this$19),_extends({},r,{observers:remove(i.indexOf(e),1,i)})}.bind(void 0),_this$18=void 0,unobserve=function(n,e,i){return _newArrowCheck(this,_this$18),updateNotifiers(n,refresh(unobserve$2(e,i))),n}.bind(void 0);export{cancel,create,observe,send$1 as send,toObservable,unobserve}; | ||
| //# sourceMappingURL=index.js.map |
@@ -1,2 +0,2 @@ | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import"phoenix";import _extends from"babel-runtime/helpers/extends";import{errorsToString}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";import{remove,replace}from"@jumpn/utils-array";var _this$1=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$1),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$3=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$3),function(r){return _newArrowCheck(this,_this$3),r[n]&&r[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$3),"on"+String(n)}.bind(void 0),notify=function(n,i,r){return _newArrowCheck(this,_this$3),n.observers.forEach(getNotifier(getHandlerName(i),r))}.bind(void 0),_this$2=void 0,notifyall=function(n,i,r){return _newArrowCheck(this,_this$2),n.forEach(function(n){return _newArrowCheck(this,_this$2),notify(n,i,r)}.bind(this))}.bind(void 0),_this$6=void 0,find=function(n,i,r){return _newArrowCheck(this,_this$6),n.find(hasIn([i],r))}.bind(void 0),_this$5=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$5),function(r){return _newArrowCheck(this,_this$5),function(){for(var e=arguments.length,t=Array(e),o=0;o<e;o++)t[o]=arguments[o];_newArrowCheck(this,_this$5);var s=find(n.notifiers,"request",i);s&&r.apply(void 0,[n,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,r){return _newArrowCheck(this,_this$5),map(createEventHandler(i,r),n)}.bind(void 0),_this$8=void 0,findIndex=function(n,i,r){return _newArrowCheck(this,_this$8),n.findIndex(hasIn([i],r))}.bind(void 0),_this$7=void 0,remove$1=function(n){return _newArrowCheck(this,_this$7),function(i){return _newArrowCheck(this,_this$7),remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$9=void 0,refresh=function(n){return _newArrowCheck(this,_this$9),function(i){return _newArrowCheck(this,_this$9),replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$10=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$10),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$4=void 0,onQueryOrMutationResponse=function(n,i,r){_newArrowCheck(this,_this$4),updateNotifiers(n,remove$1(i)),notify(i,"Result",r.payload.result)}.bind(void 0),notifyStart=function(n){return _newArrowCheck(this,_this$4),notify(n,"Start",n)}.bind(void 0),onSubscriptionResponse=function(n,i,r){var e=r.subscriptionId;_newArrowCheck(this,_this$4),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:e}))),notifyStart(i)}.bind(void 0),onResponse=function(n,i,r){_newArrowCheck(this,_this$4),r.subscriptionId?onSubscriptionResponse(n,i,r):r.payload&&onQueryOrMutationResponse(n,i,r)}.bind(void 0),abortRequest=function(n,i,r){_newArrowCheck(this,_this$4),updateNotifiers(n,remove$1(i)),notify(i,"Abort",r)}.bind(void 0),onError=function(n,i,r){return _newArrowCheck(this,_this$4),abortRequest(n,i,new Error(r))}.bind(void 0),onSucceed=function(n,i,r){_newArrowCheck(this,_this$4),r.errors?onError(n,i,errorsToString(r.errors)):onResponse(n,i,r)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$4),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(n,i){_newArrowCheck(this,_this$4),"subscription"!==i.operationType&¬ifyStart(i),handlePush(n.channel.push("doc",i.request),createPushHandler(notifierPushHandler,n,i.request))}.bind(void 0),_this=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this),{onError:function(i){return _newArrowCheck(this,_this),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0);export default joinChannel; | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import"phoenix";import _extends from"babel-runtime/helpers/extends";import{errorsToString}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";import{remove,replace}from"@jumpn/utils-array";var _this$1=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$1),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$3=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$3),function(r){return _newArrowCheck(this,_this$3),r[n]&&r[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$3),"on"+String(n)}.bind(void 0),notify=function(n,i,r){return _newArrowCheck(this,_this$3),n.observers.forEach(getNotifier(getHandlerName(i),r))}.bind(void 0),_this$2=void 0,notifyall=function(n,i,r){return _newArrowCheck(this,_this$2),n.forEach(function(n){return _newArrowCheck(this,_this$2),notify(n,i,r)}.bind(this))}.bind(void 0),_this$6=void 0,find=function(n,i,r){return _newArrowCheck(this,_this$6),n.find(hasIn([i],r))}.bind(void 0),_this$5=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$5),function(r){return _newArrowCheck(this,_this$5),function(){for(var e=arguments.length,t=Array(e),o=0;o<e;o++)t[o]=arguments[o];_newArrowCheck(this,_this$5);var s=find(n.notifiers,"request",i);s&&r.apply(void 0,[n,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,r){return _newArrowCheck(this,_this$5),map(createEventHandler(i,r),n)}.bind(void 0),_this$8=void 0,findIndex=function(n,i,r){return _newArrowCheck(this,_this$8),n.findIndex(hasIn([i],r))}.bind(void 0),_this$7=void 0,remove$1=function(n){return _newArrowCheck(this,_this$7),function(i){return _newArrowCheck(this,_this$7),remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$9=void 0,refresh=function(n){return _newArrowCheck(this,_this$9),function(i){return _newArrowCheck(this,_this$9),replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$10=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$10),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$4=void 0,notifyStart=function(n){return _newArrowCheck(this,_this$4),notify(n,"Start",n)}.bind(void 0),onSubscriptionSucceed=function(n,i,r){var e=r.subscriptionId;_newArrowCheck(this,_this$4),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:e}))),notifyStart(i)}.bind(void 0),abortRequest=function(n,i,r){_newArrowCheck(this,_this$4),updateNotifiers(n,remove$1(i)),notify(i,"Abort",r)}.bind(void 0),onError=function(n,i,r){return _newArrowCheck(this,_this$4),abortRequest(n,i,new Error(r))}.bind(void 0),onSubscriptionResponse=function(n,i,r){_newArrowCheck(this,_this$4),r.errors?onError(n,i,errorsToString(r.errors)):onSubscriptionSucceed(n,i,r)}.bind(void 0),onQueryOrMutationResponse=function(n,i,r){_newArrowCheck(this,_this$4),updateNotifiers(n,remove$1(i)),notify(i,"Result",r.payload.result)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$4),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send=function(n,i,r){return _newArrowCheck(this,_this$4),handlePush(n.channel.push("doc",i),createPushHandler(r,n,i))}.bind(void 0),pushRequest=function(n,i){_newArrowCheck(this,_this$4),"subscription"===i.operationType?send(n,i.request,subcriptionHandler):(notifyStart(i),send(n,i.request,queryOrMutationHandler))}.bind(void 0),_this=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this),{onError:function(i){return _newArrowCheck(this,_this),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0);export default joinChannel; | ||
| //# sourceMappingURL=joinChannel.js.map |
@@ -1,2 +0,2 @@ | ||
| import _extends from"babel-runtime/helpers/extends";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{errorsToString}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";import"phoenix";import{remove,replace}from"@jumpn/utils-array";var _this$2=void 0,find=function(e,r,i){return _newArrowCheck(this,_this$2),e.find(hasIn([r],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(e,r){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var n=arguments.length,t=Array(n),o=0;o<n;o++)t[o]=arguments[o];_newArrowCheck(this,_this$1);var s=find(e.notifiers,"request",r);s&&i.apply(void 0,[e,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(e,r,i){return _newArrowCheck(this,_this$1),map(createEventHandler(r,i),e)}.bind(void 0),_this$3=void 0,handlePush=function(e,r){return _newArrowCheck(this,_this$3),e.receive("ok",r.onSucceed).receive("error",r.onError).receive("timeout",r.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(e,r){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[e]&&i[e](r)}.bind(this)}.bind(void 0),getHandlerName=function(e){return _newArrowCheck(this,_this$4),"on"+String(e)}.bind(void 0),notify=function(e,r,i){return _newArrowCheck(this,_this$4),e.observers.forEach(getNotifier(getHandlerName(r),i))}.bind(void 0),_this$6=void 0,findIndex=function(e,r,i){return _newArrowCheck(this,_this$6),e.findIndex(hasIn([r],i))}.bind(void 0),_this$5=void 0,remove$1=function(e){return _newArrowCheck(this,_this$5),function(r){return _newArrowCheck(this,_this$5),remove(findIndex(r,"request",e),1,r)}.bind(this)}.bind(void 0),_this$7=void 0,refresh=function(e){return _newArrowCheck(this,_this$7),function(r){return _newArrowCheck(this,_this$7),replace(findIndex(r,"request",e),[e],r)}.bind(this)}.bind(void 0),_this$8=void 0,updateNotifiers=function(e,r){return _newArrowCheck(this,_this$8),e.notifiers=r(e.notifiers),e}.bind(void 0),_this=void 0,onQueryOrMutationResponse=function(e,r,i){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(r)),notify(r,"Result",i.payload.result)}.bind(void 0),notifyStart=function(e){return _newArrowCheck(this,_this),notify(e,"Start",e)}.bind(void 0),onSubscriptionResponse=function(e,r,i){var n=i.subscriptionId;_newArrowCheck(this,_this),updateNotifiers(e,refresh(_extends({},r,{subscriptionId:n}))),notifyStart(r)}.bind(void 0),onResponse=function(e,r,i){_newArrowCheck(this,_this),i.subscriptionId?onSubscriptionResponse(e,r,i):i.payload&&onQueryOrMutationResponse(e,r,i)}.bind(void 0),abortRequest=function(e,r,i){_newArrowCheck(this,_this),updateNotifiers(e,remove$1(r)),notify(r,"Abort",i)}.bind(void 0),onError=function(e,r,i){return _newArrowCheck(this,_this),abortRequest(e,r,new Error(i))}.bind(void 0),onSucceed=function(e,r,i){_newArrowCheck(this,_this),i.errors?onError(e,r,errorsToString(i.errors)):onResponse(e,r,i)}.bind(void 0),onTimeout=function(e,r){return _newArrowCheck(this,_this),notify(r,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(e,r){_newArrowCheck(this,_this),"subscription"!==r.operationType&¬ifyStart(r),handlePush(e.channel.push("doc",r.request),createPushHandler(notifierPushHandler,e,r.request))}.bind(void 0);export default pushRequest; | ||
| import _extends from"babel-runtime/helpers/extends";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{errorsToString}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";import"phoenix";import{remove,replace}from"@jumpn/utils-array";var _this$2=void 0,find=function(r,e,i){return _newArrowCheck(this,_this$2),r.find(hasIn([e],i))}.bind(void 0),_this$1=void 0,createEventHandler=function(r,e){return _newArrowCheck(this,_this$1),function(i){return _newArrowCheck(this,_this$1),function(){for(var n=arguments.length,t=Array(n),o=0;o<n;o++)t[o]=arguments[o];_newArrowCheck(this,_this$1);var s=find(r.notifiers,"request",e);s&&i.apply(void 0,[r,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(r,e,i){return _newArrowCheck(this,_this$1),map(createEventHandler(e,i),r)}.bind(void 0),_this$3=void 0,handlePush=function(r,e){return _newArrowCheck(this,_this$3),r.receive("ok",e.onSucceed).receive("error",e.onError).receive("timeout",e.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(r,e){return _newArrowCheck(this,_this$4),function(i){return _newArrowCheck(this,_this$4),i[r]&&i[r](e)}.bind(this)}.bind(void 0),getHandlerName=function(r){return _newArrowCheck(this,_this$4),"on"+String(r)}.bind(void 0),notify=function(r,e,i){return _newArrowCheck(this,_this$4),r.observers.forEach(getNotifier(getHandlerName(e),i))}.bind(void 0),_this$6=void 0,findIndex=function(r,e,i){return _newArrowCheck(this,_this$6),r.findIndex(hasIn([e],i))}.bind(void 0),_this$5=void 0,remove$1=function(r){return _newArrowCheck(this,_this$5),function(e){return _newArrowCheck(this,_this$5),remove(findIndex(e,"request",r),1,e)}.bind(this)}.bind(void 0),_this$7=void 0,refresh=function(r){return _newArrowCheck(this,_this$7),function(e){return _newArrowCheck(this,_this$7),replace(findIndex(e,"request",r),[r],e)}.bind(this)}.bind(void 0),_this$8=void 0,updateNotifiers=function(r,e){return _newArrowCheck(this,_this$8),r.notifiers=e(r.notifiers),r}.bind(void 0),_this=void 0,notifyStart=function(r){return _newArrowCheck(this,_this),notify(r,"Start",r)}.bind(void 0),onSubscriptionSucceed=function(r,e,i){var n=i.subscriptionId;_newArrowCheck(this,_this),updateNotifiers(r,refresh(_extends({},e,{subscriptionId:n}))),notifyStart(e)}.bind(void 0),abortRequest=function(r,e,i){_newArrowCheck(this,_this),updateNotifiers(r,remove$1(e)),notify(e,"Abort",i)}.bind(void 0),onError=function(r,e,i){return _newArrowCheck(this,_this),abortRequest(r,e,new Error(i))}.bind(void 0),onSubscriptionResponse=function(r,e,i){_newArrowCheck(this,_this),i.errors?onError(r,e,errorsToString(i.errors)):onSubscriptionSucceed(r,e,i)}.bind(void 0),onQueryOrMutationResponse=function(r,e,i){_newArrowCheck(this,_this),updateNotifiers(r,remove$1(e)),notify(e,"Result",i.payload.result)}.bind(void 0),onTimeout=function(r,e){return _newArrowCheck(this,_this),notify(e,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send=function(r,e,i){return _newArrowCheck(this,_this),handlePush(r.channel.push("doc",e),createPushHandler(i,r,e))}.bind(void 0),pushRequest=function(r,e){_newArrowCheck(this,_this),"subscription"===e.operationType?send(r,e.request,subcriptionHandler):(notifyStart(e),send(r,e.request,queryOrMutationHandler))}.bind(void 0);export default pushRequest; | ||
| //# sourceMappingURL=pushRequest.js.map |
@@ -1,2 +0,2 @@ | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{append,remove,replace}from"@jumpn/utils-array";import"phoenix";import _extends from"babel-runtime/helpers/extends";import{errorsToString,getOperationType}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";var _this$2=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$2),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[n]&&e[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,i,e){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(i),e))}.bind(void 0),_this$3=void 0,notifyall=function(n,i,e){return _newArrowCheck(this,_this$3),n.forEach(function(n){return _newArrowCheck(this,_this$3),notify(n,i,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(n,i,e){return _newArrowCheck(this,_this$7),n.find(hasIn([i],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(n.notifiers,"request",i);s&&e.apply(void 0,[n,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,e){return _newArrowCheck(this,_this$6),map(createEventHandler(i,e),n)}.bind(void 0),_this$9=void 0,findIndex=function(n,i,e){return _newArrowCheck(this,_this$9),n.findIndex(hasIn([i],e))}.bind(void 0),_this$8=void 0,remove$1=function(n){return _newArrowCheck(this,_this$8),function(i){return _newArrowCheck(this,_this$8),remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(n){return _newArrowCheck(this,_this$10),function(i){return _newArrowCheck(this,_this$10),replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$11),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$5=void 0,onQueryOrMutationResponse=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Result",e.payload.result)}.bind(void 0),notifyStart=function(n){return _newArrowCheck(this,_this$5),notify(n,"Start",n)}.bind(void 0),onSubscriptionResponse=function(n,i,e){var r=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:r}))),notifyStart(i)}.bind(void 0),onResponse=function(n,i,e){_newArrowCheck(this,_this$5),e.subscriptionId?onSubscriptionResponse(n,i,e):e.payload&&onQueryOrMutationResponse(n,i,e)}.bind(void 0),abortRequest=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Abort",e)}.bind(void 0),onError=function(n,i,e){return _newArrowCheck(this,_this$5),abortRequest(n,i,new Error(e))}.bind(void 0),onSucceed=function(n,i,e){_newArrowCheck(this,_this$5),e.errors?onError(n,i,errorsToString(e.errors)):onResponse(n,i,e)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$5),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),notifierPushHandler={onError:onError,onSucceed:onSucceed,onTimeout:onTimeout},pushRequest=function(n,i){_newArrowCheck(this,_this$5),"subscription"!==i.operationType&¬ifyStart(i),handlePush(n.channel.push("doc",i.request),createPushHandler(notifierPushHandler,n,i.request))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$1),{onError:function(i){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this$1),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$1),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this$12=void 0,create=function(n){return _newArrowCheck(this,_this$12),{request:n,observers:[],operationType:getOperationType(n.operation),subscriptionId:void 0}}.bind(void 0),_this=void 0,connectOrJoin=function(n){_newArrowCheck(this,_this),n.isJoining=!0,n.phoenixSocket.isConnected()?joinChannel(n):n.phoenixSocket.connect()}.bind(void 0),isJoined=function(n){return _newArrowCheck(this,_this),n.phoenixSocket.isConnected()&&!n.isJoining}.bind(void 0),send=function(n,i){_newArrowCheck(this,_this);var e=create(i);return updateNotifiers(n,append([e])),isJoined(n)?pushRequest(n,e):connectOrJoin(n),e}.bind(void 0);export default send; | ||
| import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{append,remove,replace}from"@jumpn/utils-array";import"phoenix";import _extends from"babel-runtime/helpers/extends";import{errorsToString,getOperationType}from"@jumpn/utils-graphql";import{hasIn,map}from"@jumpn/utils-composite";var _this$2=void 0,handlePush=function(n,i){return _newArrowCheck(this,_this$2),n.receive("ok",i.onSucceed).receive("error",i.onError).receive("timeout",i.onTimeout)}.bind(void 0),_this$4=void 0,getNotifier=function(n,i){return _newArrowCheck(this,_this$4),function(e){return _newArrowCheck(this,_this$4),e[n]&&e[n](i)}.bind(this)}.bind(void 0),getHandlerName=function(n){return _newArrowCheck(this,_this$4),"on"+String(n)}.bind(void 0),notify=function(n,i,e){return _newArrowCheck(this,_this$4),n.observers.forEach(getNotifier(getHandlerName(i),e))}.bind(void 0),_this$3=void 0,notifyall=function(n,i,e){return _newArrowCheck(this,_this$3),n.forEach(function(n){return _newArrowCheck(this,_this$3),notify(n,i,e)}.bind(this))}.bind(void 0),_this$7=void 0,find=function(n,i,e){return _newArrowCheck(this,_this$7),n.find(hasIn([i],e))}.bind(void 0),_this$6=void 0,createEventHandler=function(n,i){return _newArrowCheck(this,_this$6),function(e){return _newArrowCheck(this,_this$6),function(){for(var r=arguments.length,t=Array(r),o=0;o<r;o++)t[o]=arguments[o];_newArrowCheck(this,_this$6);var s=find(n.notifiers,"request",i);s&&e.apply(void 0,[n,s].concat(t))}.bind(this)}.bind(this)}.bind(void 0),createPushHandler=function(n,i,e){return _newArrowCheck(this,_this$6),map(createEventHandler(i,e),n)}.bind(void 0),_this$9=void 0,findIndex=function(n,i,e){return _newArrowCheck(this,_this$9),n.findIndex(hasIn([i],e))}.bind(void 0),_this$8=void 0,remove$1=function(n){return _newArrowCheck(this,_this$8),function(i){return _newArrowCheck(this,_this$8),remove(findIndex(i,"request",n),1,i)}.bind(this)}.bind(void 0),_this$10=void 0,refresh=function(n){return _newArrowCheck(this,_this$10),function(i){return _newArrowCheck(this,_this$10),replace(findIndex(i,"request",n),[n],i)}.bind(this)}.bind(void 0),_this$11=void 0,updateNotifiers=function(n,i){return _newArrowCheck(this,_this$11),n.notifiers=i(n.notifiers),n}.bind(void 0),_this$5=void 0,notifyStart=function(n){return _newArrowCheck(this,_this$5),notify(n,"Start",n)}.bind(void 0),onSubscriptionSucceed=function(n,i,e){var r=e.subscriptionId;_newArrowCheck(this,_this$5),updateNotifiers(n,refresh(_extends({},i,{subscriptionId:r}))),notifyStart(i)}.bind(void 0),abortRequest=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Abort",e)}.bind(void 0),onError=function(n,i,e){return _newArrowCheck(this,_this$5),abortRequest(n,i,new Error(e))}.bind(void 0),onSubscriptionResponse=function(n,i,e){_newArrowCheck(this,_this$5),e.errors?onError(n,i,errorsToString(e.errors)):onSubscriptionSucceed(n,i,e)}.bind(void 0),onQueryOrMutationResponse=function(n,i,e){_newArrowCheck(this,_this$5),updateNotifiers(n,remove$1(i)),notify(i,"Result",e.payload.result)}.bind(void 0),onTimeout=function(n,i){return _newArrowCheck(this,_this$5),notify(i,"Error",new Error("request: timeout"))}.bind(void 0),queryOrMutationHandler={onError:onError,onTimeout:onTimeout,onSucceed:onQueryOrMutationResponse},subcriptionHandler={onError:onError,onTimeout:onTimeout,onSucceed:onSubscriptionResponse},send$2=function(n,i,e){return _newArrowCheck(this,_this$5),handlePush(n.channel.push("doc",i),createPushHandler(e,n,i))}.bind(void 0),pushRequest=function(n,i){_newArrowCheck(this,_this$5),"subscription"===i.operationType?send$2(n,i.request,subcriptionHandler):(notifyStart(i),send$2(n,i.request,queryOrMutationHandler))}.bind(void 0),_this$1=void 0,createChannelJoinHandler=function(n){return _newArrowCheck(this,_this$1),{onError:function(i){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: "+String(i)))}.bind(this),onSucceed:function(){_newArrowCheck(this,_this$1),n.isJoining=!1,n.notifiers.forEach(function(i){return _newArrowCheck(this,_this$1),pushRequest(n,i)}.bind(this))}.bind(this),onTimeout:function(){return _newArrowCheck(this,_this$1),notifyall(n.notifiers,"Error",new Error("channel join: timeout"))}.bind(this)}}.bind(void 0),joinChannel=function(n){return _newArrowCheck(this,_this$1),handlePush(n.channel.join(),createChannelJoinHandler(n))}.bind(void 0),_this$12=void 0,create=function(n){return _newArrowCheck(this,_this$12),{request:n,observers:[],operationType:getOperationType(n.operation),subscriptionId:void 0}}.bind(void 0),_this=void 0,connectOrJoin=function(n){_newArrowCheck(this,_this),n.isJoining=!0,n.phoenixSocket.isConnected()?joinChannel(n):n.phoenixSocket.connect()}.bind(void 0),isJoined=function(n){return _newArrowCheck(this,_this),n.phoenixSocket.isConnected()&&!n.isJoining}.bind(void 0),send=function(n,i){_newArrowCheck(this,_this);var e=create(i);return updateNotifiers(n,append([e])),isJoined(n)?pushRequest(n,e):connectOrJoin(n),e}.bind(void 0);export default send; | ||
| //# sourceMappingURL=send.js.map |
| { | ||
| "name": "@jumpn/absinthe-phoenix-socket", | ||
| "version": "0.4.0", | ||
| "version": "0.4.1", | ||
| "description": "Absinthe Phoenix Socket", | ||
@@ -5,0 +5,0 @@ "module": "dist/index.js", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
New alerts
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
Fixed alerts
License Policy Violation
LicenseThis 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
- increased by0.08%
603857
- Lines of code
- increased by0.93%
648
Worsened metrics
- Number of medium supply chain risk alerts
- increased byInfinity%
1
No dependency changes