@absinthe/socket-graphiql - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

compat/cjs/createFetcher.js

@@ -1,2 +0,2 @@
-"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}var _JSON$stringify=_interopDefault(require("babel-runtime/core-js/json/stringify")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsGraphql=require("@jumpn/utils-graphql"),_Map=_interopDefault(require("babel-runtime/core-js/map")),_classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_slicedToArray=_interopDefault(require("babel-runtime/helpers/slicedToArray")),AbsintheSocket=require("@absinthe/socket"),phoenix=require("phoenix"),_this$1=void 0,observe$1=function(e,t,i){return _newArrowCheck(this,_this$1),AbsintheSocket.observe(e.absintheSocket,t,{onAbort:i,onResult:function(e){return _newArrowCheck(this,_this$1),i(null,e.data)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this$1),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this$1);var i=generateRequestKey(e);return e.requests.set(t,i),i}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this$1);var i=e.requests.get(t);return void 0!==i?i:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this$1),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this$1),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this$1);var i=!0,r=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(i=(s=o.next()).done);i=!0){var u=s.value,c=_slicedToArray(u,2),h=c[0];if(c[1]===t)return h}}catch(e){r=!0,n=e}finally{try{!i&&o.return&&o.return()}finally{if(r)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this$1),AbsintheSocket.cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,i){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=AbsintheSocket.create(new phoenix.Socket(t,i)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var i=AbsintheSocket.send(this.absintheSocket,utilsGraphql.requestFromCompat(e)),r=storeRequestIfNeeded(this,i.request);return observe$1(this,i,t),r}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var i=findNotifier(this,t);i&&cancel$1(this,i)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this=void 0,parseIfJson=function(e){_newArrowCheck(this,_this);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this),function(t,i){_newArrowCheck(this,_this),t?e.error(t):e.next(i)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,i,r){return _newArrowCheck(this,_this),{subscribe:function(n){_newArrowCheck(this,_this),n.next(i),e.activeSubscriptionId=t.subscribe(r,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,i){_newArrowCheck(this,_this);var r={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this),r.activeSubscriptionId&&t.unsubscribe(r.activeSubscriptionId),"subscription"!==utilsGraphql.getOperationType(n.query)?postJson(e,n):subscribeWithObservable(r,t,i,n)}.bind(this)}.bind(void 0);module.exports=createFetcher;
+"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}var _JSON$stringify=_interopDefault(require("babel-runtime/core-js/json/stringify")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),utilsGraphql=require("@jumpn/utils-graphql"),_Map=_interopDefault(require("babel-runtime/core-js/map")),_classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_slicedToArray=_interopDefault(require("babel-runtime/helpers/slicedToArray")),AbsintheSocket=require("@absinthe/socket"),phoenix=require("phoenix"),_this$1=void 0,observe$1=function(e,t,i){return _newArrowCheck(this,_this$1),AbsintheSocket.observe(e.absintheSocket,t,{onAbort:i,onResult:function(e){return _newArrowCheck(this,_this$1),i(null,e)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this$1),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this$1);var i=generateRequestKey(e);return e.requests.set(t,i),i}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this$1);var i=e.requests.get(t);return void 0!==i?i:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this$1),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this$1),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this$1);var i=!0,r=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(i=(s=o.next()).done);i=!0){var u=s.value,c=_slicedToArray(u,2),h=c[0];if(c[1]===t)return h}}catch(e){r=!0,n=e}finally{try{!i&&o.return&&o.return()}finally{if(r)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this$1),AbsintheSocket.cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,i){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=AbsintheSocket.create(new phoenix.Socket(t,i)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var i=AbsintheSocket.send(this.absintheSocket,utilsGraphql.requestFromCompat(e)),r=storeRequestIfNeeded(this,i.request);return observe$1(this,i,t),r}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var i=findNotifier(this,t);i&&cancel$1(this,i)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this=void 0,parseIfJson=function(e){_newArrowCheck(this,_this);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this),function(t,i){_newArrowCheck(this,_this),t?e.error(t):e.next(i)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,i,r){return _newArrowCheck(this,_this),{subscribe:function(n){_newArrowCheck(this,_this),n.next(i),e.activeSubscriptionId=t.subscribe(r,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,i){_newArrowCheck(this,_this);var r={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this),r.activeSubscriptionId&&t.unsubscribe(r.activeSubscriptionId),"subscription"!==utilsGraphql.getOperationType(n.query)?postJson(e,n):subscribeWithObservable(r,t,i,n)}.bind(this)}.bind(void 0);module.exports=createFetcher;
 //# sourceMappingURL=createFetcher.js.map

compat/cjs/index.js

@@ -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 _Map=_interopDefault(require("babel-runtime/core-js/map")),_classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_slicedToArray=_interopDefault(require("babel-runtime/helpers/slicedToArray")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),AbsintheSocket=require("@absinthe/socket"),utilsGraphql=require("@jumpn/utils-graphql"),phoenix=require("phoenix"),_JSON$stringify=_interopDefault(require("babel-runtime/core-js/json/stringify")),_this=void 0,observe$1=function(e,t,i){return _newArrowCheck(this,_this),AbsintheSocket.observe(e.absintheSocket,t,{onAbort:i,onResult:function(e){return _newArrowCheck(this,_this),i(null,e.data)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var i=generateRequestKey(e);return e.requests.set(t,i),i}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var i=e.requests.get(t);return void 0!==i?i:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var i=!0,r=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(i=(s=o.next()).done);i=!0){var u=s.value,c=_slicedToArray(u,2),h=c[0];if(c[1]===t)return h}}catch(e){r=!0,n=e}finally{try{!i&&o.return&&o.return()}finally{if(r)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),AbsintheSocket.cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,i){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=AbsintheSocket.create(new phoenix.Socket(t,i)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var i=AbsintheSocket.send(this.absintheSocket,utilsGraphql.requestFromCompat(e)),r=storeRequestIfNeeded(this,i.request);return observe$1(this,i,t),r}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var i=findNotifier(this,t);i&&cancel$1(this,i)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this$1=void 0,parseIfJson=function(e){_newArrowCheck(this,_this$1);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this$1),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this$1),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this$1),function(t,i){_newArrowCheck(this,_this$1),t?e.error(t):e.next(i)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,i,r){return _newArrowCheck(this,_this$1),{subscribe:function(n){_newArrowCheck(this,_this$1),n.next(i),e.activeSubscriptionId=t.subscribe(r,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,i){_newArrowCheck(this,_this$1);var r={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this$1),r.activeSubscriptionId&&t.unsubscribe(r.activeSubscriptionId),"subscription"!==utilsGraphql.getOperationType(n.query)?postJson(e,n):subscribeWithObservable(r,t,i,n)}.bind(this)}.bind(void 0);exports.SubscriptionsClient=SubscriptionsClient,exports.createFetcher=createFetcher;
+"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}Object.defineProperty(exports,"__esModule",{value:!0});var _Map=_interopDefault(require("babel-runtime/core-js/map")),_classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_slicedToArray=_interopDefault(require("babel-runtime/helpers/slicedToArray")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),AbsintheSocket=require("@absinthe/socket"),utilsGraphql=require("@jumpn/utils-graphql"),phoenix=require("phoenix"),_JSON$stringify=_interopDefault(require("babel-runtime/core-js/json/stringify")),_this=void 0,observe$1=function(e,t,i){return _newArrowCheck(this,_this),AbsintheSocket.observe(e.absintheSocket,t,{onAbort:i,onResult:function(e){return _newArrowCheck(this,_this),i(null,e)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var i=generateRequestKey(e);return e.requests.set(t,i),i}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var i=e.requests.get(t);return void 0!==i?i:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var i=!0,r=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(i=(s=o.next()).done);i=!0){var u=s.value,c=_slicedToArray(u,2),h=c[0];if(c[1]===t)return h}}catch(e){r=!0,n=e}finally{try{!i&&o.return&&o.return()}finally{if(r)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),AbsintheSocket.cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,i){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=AbsintheSocket.create(new phoenix.Socket(t,i)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var i=AbsintheSocket.send(this.absintheSocket,utilsGraphql.requestFromCompat(e)),r=storeRequestIfNeeded(this,i.request);return observe$1(this,i,t),r}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var i=findNotifier(this,t);i&&cancel$1(this,i)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this$1=void 0,parseIfJson=function(e){_newArrowCheck(this,_this$1);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this$1),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this$1),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this$1),function(t,i){_newArrowCheck(this,_this$1),t?e.error(t):e.next(i)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,i,r){return _newArrowCheck(this,_this$1),{subscribe:function(n){_newArrowCheck(this,_this$1),n.next(i),e.activeSubscriptionId=t.subscribe(r,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,i){_newArrowCheck(this,_this$1);var r={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this$1),r.activeSubscriptionId&&t.unsubscribe(r.activeSubscriptionId),"subscription"!==utilsGraphql.getOperationType(n.query)?postJson(e,n):subscribeWithObservable(r,t,i,n)}.bind(this)}.bind(void 0);exports.SubscriptionsClient=SubscriptionsClient,exports.createFetcher=createFetcher;
 //# sourceMappingURL=index.js.map

compat/cjs/SubscriptionsClient.js

@@ -1,2 +0,2 @@
-"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}var _Map=_interopDefault(require("babel-runtime/core-js/map")),_classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_slicedToArray=_interopDefault(require("babel-runtime/helpers/slicedToArray")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),AbsintheSocket=require("@absinthe/socket"),utilsGraphql=require("@jumpn/utils-graphql"),phoenix=require("phoenix"),_this=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this),AbsintheSocket.observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this),r(null,e.data)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var r=!0,i=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(r=(s=o.next()).done);r=!0){var u=s.value,c=_slicedToArray(u,2),h=c[0];if(c[1]===t)return h}}catch(e){i=!0,n=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),AbsintheSocket.cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=AbsintheSocket.create(new phoenix.Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=AbsintheSocket.send(this.absintheSocket,utilsGraphql.requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}();module.exports=SubscriptionsClient;
+"use strict";function _interopDefault(e){return e&&"object"==typeof e&&"default"in e?e.default:e}var _Map=_interopDefault(require("babel-runtime/core-js/map")),_classCallCheck=_interopDefault(require("babel-runtime/helpers/classCallCheck")),_createClass=_interopDefault(require("babel-runtime/helpers/createClass")),_getIterator=_interopDefault(require("babel-runtime/core-js/get-iterator")),_slicedToArray=_interopDefault(require("babel-runtime/helpers/slicedToArray")),_newArrowCheck=_interopDefault(require("babel-runtime/helpers/newArrowCheck")),AbsintheSocket=require("@absinthe/socket"),utilsGraphql=require("@jumpn/utils-graphql"),phoenix=require("phoenix"),_this=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this),AbsintheSocket.observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this),r(null,e)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var r=!0,i=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(r=(s=o.next()).done);r=!0){var u=s.value,c=_slicedToArray(u,2),h=c[0];if(c[1]===t)return h}}catch(e){i=!0,n=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),AbsintheSocket.cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=AbsintheSocket.create(new phoenix.Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=AbsintheSocket.send(this.absintheSocket,utilsGraphql.requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}();module.exports=SubscriptionsClient;
 //# sourceMappingURL=SubscriptionsClient.js.map

dist/createFetcher.js

@@ -1,2 +0,2 @@
-import _JSON$stringify from"babel-runtime/core-js/json/stringify";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{getOperationType,requestFromCompat}from"@jumpn/utils-graphql";import _Map from"babel-runtime/core-js/map";import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import _getIterator from"babel-runtime/core-js/get-iterator";import _slicedToArray from"babel-runtime/helpers/slicedToArray";import{cancel,create,observe,send}from"@absinthe/socket";import{Socket}from"phoenix";var _this$1=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this$1),observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this$1),r(null,e.data)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this$1),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this$1);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this$1);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this$1),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this$1),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this$1);var r=!0,i=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(r=(s=o.next()).done);r=!0){var c=s.value,h=_slicedToArray(c,2),u=h[0];if(h[1]===t)return u}}catch(e){i=!0,n=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this$1),cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=create(new Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=send(this.absintheSocket,requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this=void 0,parseIfJson=function(e){_newArrowCheck(this,_this);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this),function(t,r){_newArrowCheck(this,_this),t?e.error(t):e.next(r)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,r,i){return _newArrowCheck(this,_this),{subscribe:function(n){_newArrowCheck(this,_this),n.next(r),e.activeSubscriptionId=t.subscribe(i,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,r){_newArrowCheck(this,_this);var i={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this),i.activeSubscriptionId&&t.unsubscribe(i.activeSubscriptionId),"subscription"!==getOperationType(n.query)?postJson(e,n):subscribeWithObservable(i,t,r,n)}.bind(this)}.bind(void 0);export default createFetcher;
+import _JSON$stringify from"babel-runtime/core-js/json/stringify";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{getOperationType,requestFromCompat}from"@jumpn/utils-graphql";import _Map from"babel-runtime/core-js/map";import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import _getIterator from"babel-runtime/core-js/get-iterator";import _slicedToArray from"babel-runtime/helpers/slicedToArray";import{cancel,create,observe,send}from"@absinthe/socket";import{Socket}from"phoenix";var _this$1=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this$1),observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this$1),r(null,e)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this$1),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this$1);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this$1);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this$1),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this$1),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this$1);var r=!0,i=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(r=(s=o.next()).done);r=!0){var c=s.value,h=_slicedToArray(c,2),u=h[0];if(h[1]===t)return u}}catch(e){i=!0,n=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this$1),cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=create(new Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=send(this.absintheSocket,requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this=void 0,parseIfJson=function(e){_newArrowCheck(this,_this);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this),function(t,r){_newArrowCheck(this,_this),t?e.error(t):e.next(r)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,r,i){return _newArrowCheck(this,_this),{subscribe:function(n){_newArrowCheck(this,_this),n.next(r),e.activeSubscriptionId=t.subscribe(i,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,r){_newArrowCheck(this,_this);var i={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this),i.activeSubscriptionId&&t.unsubscribe(i.activeSubscriptionId),"subscription"!==getOperationType(n.query)?postJson(e,n):subscribeWithObservable(i,t,r,n)}.bind(this)}.bind(void 0);export default createFetcher;
 //# sourceMappingURL=createFetcher.js.map

dist/index.js

@@ -1,2 +0,2 @@
-import _Map from"babel-runtime/core-js/map";import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import _getIterator from"babel-runtime/core-js/get-iterator";import _slicedToArray from"babel-runtime/helpers/slicedToArray";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{cancel,create,observe,send}from"@absinthe/socket";import{getOperationType,requestFromCompat}from"@jumpn/utils-graphql";import{Socket}from"phoenix";import _JSON$stringify from"babel-runtime/core-js/json/stringify";var _this=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this),observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this),r(null,e.data)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var r=!0,i=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(r=(s=o.next()).done);r=!0){var c=s.value,h=_slicedToArray(c,2),u=h[0];if(h[1]===t)return u}}catch(e){i=!0,n=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=create(new Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=send(this.absintheSocket,requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this$1=void 0,parseIfJson=function(e){_newArrowCheck(this,_this$1);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this$1),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this$1),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this$1),function(t,r){_newArrowCheck(this,_this$1),t?e.error(t):e.next(r)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,r,i){return _newArrowCheck(this,_this$1),{subscribe:function(n){_newArrowCheck(this,_this$1),n.next(r),e.activeSubscriptionId=t.subscribe(i,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,r){_newArrowCheck(this,_this$1);var i={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this$1),i.activeSubscriptionId&&t.unsubscribe(i.activeSubscriptionId),"subscription"!==getOperationType(n.query)?postJson(e,n):subscribeWithObservable(i,t,r,n)}.bind(this)}.bind(void 0);export{SubscriptionsClient,createFetcher};
+import _Map from"babel-runtime/core-js/map";import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import _getIterator from"babel-runtime/core-js/get-iterator";import _slicedToArray from"babel-runtime/helpers/slicedToArray";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{cancel,create,observe,send}from"@absinthe/socket";import{getOperationType,requestFromCompat}from"@jumpn/utils-graphql";import{Socket}from"phoenix";import _JSON$stringify from"babel-runtime/core-js/json/stringify";var _this=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this),observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this),r(null,e)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var r=!0,i=!1,n=void 0;try{for(var s,o=_getIterator(e.requests.entries());!(r=(s=o.next()).done);r=!0){var c=s.value,h=_slicedToArray(c,2),u=h[0];if(h[1]===t)return u}}catch(e){i=!0,n=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw n}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=create(new Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=send(this.absintheSocket,requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}(),_this$1=void 0,parseIfJson=function(e){_newArrowCheck(this,_this$1);try{return JSON.parse(e)}catch(t){return e}}.bind(void 0),responseToText=function(e){return _newArrowCheck(this,_this$1),e.text()}.bind(void 0),postJson=function(e,t){return _newArrowCheck(this,_this$1),fetch(e,{method:"post",headers:{Accept:"application/json","Content-Type":"application/json"},body:_JSON$stringify(t),credentials:"include"}).then(responseToText).then(parseIfJson)}.bind(void 0),getSubscribeCallback=function(e){return _newArrowCheck(this,_this$1),function(t,r){_newArrowCheck(this,_this$1),t?e.error(t):e.next(r)}.bind(this)}.bind(void 0),subscribeWithObservable=function(e,t,r,i){return _newArrowCheck(this,_this$1),{subscribe:function(n){_newArrowCheck(this,_this$1),n.next(r),e.activeSubscriptionId=t.subscribe(i,getSubscribeCallback(n))}.bind(this)}}.bind(void 0),createFetcher=function(e,t,r){_newArrowCheck(this,_this$1);var i={activeSubscriptionId:void 0};return function(n){return _newArrowCheck(this,_this$1),i.activeSubscriptionId&&t.unsubscribe(i.activeSubscriptionId),"subscription"!==getOperationType(n.query)?postJson(e,n):subscribeWithObservable(i,t,r,n)}.bind(this)}.bind(void 0);export{SubscriptionsClient,createFetcher};
 //# sourceMappingURL=index.js.map

dist/SubscriptionsClient.js

@@ -1,2 +0,2 @@
-import _Map from"babel-runtime/core-js/map";import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import _getIterator from"babel-runtime/core-js/get-iterator";import _slicedToArray from"babel-runtime/helpers/slicedToArray";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{cancel,create,observe,send}from"@absinthe/socket";import{requestFromCompat}from"@jumpn/utils-graphql";import{Socket}from"phoenix";var _this=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this),observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this),r(null,e.data)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var r=!0,i=!1,s=void 0;try{for(var n,o=_getIterator(e.requests.entries());!(r=(n=o.next()).done);r=!0){var c=n.value,u=_slicedToArray(c,2),h=u[0];if(u[1]===t)return h}}catch(e){i=!0,s=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw s}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=create(new Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=send(this.absintheSocket,requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}();export default SubscriptionsClient;
+import _Map from"babel-runtime/core-js/map";import _classCallCheck from"babel-runtime/helpers/classCallCheck";import _createClass from"babel-runtime/helpers/createClass";import _getIterator from"babel-runtime/core-js/get-iterator";import _slicedToArray from"babel-runtime/helpers/slicedToArray";import _newArrowCheck from"babel-runtime/helpers/newArrowCheck";import{cancel,create,observe,send}from"@absinthe/socket";import{requestFromCompat}from"@jumpn/utils-graphql";import{Socket}from"phoenix";var _this=void 0,observe$1=function(e,t,r){return _newArrowCheck(this,_this),observe(e.absintheSocket,t,{onAbort:r,onResult:function(e){return _newArrowCheck(this,_this),r(null,e)}.bind(this)})}.bind(void 0),generateRequestKey=function(e){return _newArrowCheck(this,_this),e.requestsCount+=1,String(e.requestsCount)}.bind(void 0),storeRequest=function(e,t){_newArrowCheck(this,_this);var r=generateRequestKey(e);return e.requests.set(t,r),r}.bind(void 0),storeRequestIfNeeded=function(e,t){_newArrowCheck(this,_this);var r=e.requests.get(t);return void 0!==r?r:storeRequest(e,t)}.bind(void 0),findNotifier=function(e,t){return _newArrowCheck(this,_this),e.absintheSocket.notifiers.find(function(e){return _newArrowCheck(this,_this),e.request===t}.bind(this))}.bind(void 0),findRequest=function(e,t){_newArrowCheck(this,_this);var r=!0,i=!1,s=void 0;try{for(var n,o=_getIterator(e.requests.entries());!(r=(n=o.next()).done);r=!0){var c=n.value,u=_slicedToArray(c,2),h=u[0];if(u[1]===t)return h}}catch(e){i=!0,s=e}finally{try{!r&&o.return&&o.return()}finally{if(i)throw s}}}.bind(void 0),cancel$1=function(e,t){_newArrowCheck(this,_this),cancel(e.absintheSocket,t),e.requests.delete(t.request)}.bind(void 0),SubscriptionsClient=function(){function e(t,r){_classCallCheck(this,e),this.requestsCount=0,this.absintheSocket=create(new Socket(t,r)),this.requests=new _Map}return _createClass(e,[{key:"close",value:function(){this.absintheSocket.phoenixSocket.disconnect()}},{key:"subscribe",value:function(e,t){var r=send(this.absintheSocket,requestFromCompat(e)),i=storeRequestIfNeeded(this,r.request);return observe$1(this,r,t),i}},{key:"unsubscribe",value:function(e){var t=findRequest(this,e);if(t){var r=findNotifier(this,t);r&&cancel$1(this,r)}}},{key:"unsubscribeAll",value:function(){var e=this;this.absintheSocket.notifiers.forEach(function(t){return _newArrowCheck(this,e),cancel$1(this,t)}.bind(this))}}]),e}();export default SubscriptionsClient;
 //# sourceMappingURL=SubscriptionsClient.js.map

LICENSE.txt

 MIT License
 
-Copyright (c) 2017  Mauro Titimoli
+Copyright (c) 2017 Jumpn Limited.
 
@@ -5,0 +5,0 @@ Permission is hereby granted, free of charge, to any person obtaining a copy

package.json

 {
   "name": "@absinthe/socket-graphiql",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "description": "Socket GraphiQL Utilities",
@@ -36,3 +36,3 @@ "module": "dist/index.js",
   "dependencies": {
-    "@absinthe/socket": "0.1.7",
+    "@absinthe/socket": "^0.1.8",
     "@jumpn/utils-graphql": "0.5.3",
@@ -39,0 +39,0 @@ "babel-runtime": "6.26.0",

README.md

@@ -44,2 +44,2 @@ # @absinthe/socket-graphiql
 
-[MIT](LICENSE.txt) :copyright: Mauro Titimoli ([e-mail])
+[MIT](LICENSE.txt) :copyright: Jumpn Limited.

src/SubscriptionsClient.js

@@ -23,3 +23,3 @@ // @flow
     onAbort: callback,
-    onResult: result => callback(null, result.data)
+    onResult: result => callback(null, result)
   });
@@ -26,0 +26,0 @@

New alerts

License Policy Violation

License

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

Found 1 instance in 1 package

Major refactor

Supply chain risk

Package 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

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

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

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

381813

increased by384.28%

Lines of code

479

increased by93.93%

Worsened metrics

Number of package files

20

decreased by-16.67%

Number of medium supply chain risk alerts

8

increased by60%

Dependency changes

• + Added@absinthe/socket@0.1.10(transitive)

• - Removed@absinthe/socket@0.1.7(transitive)

• Updated@absinthe/socket@^0.1.8