defined-realtime-websocket - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1

dist/defined-realtime-websocket.cjs.development.js

@@ -68,4 +68,8 @@ 'use strict';
   }
-  filterParams.map(generateSubClause);
-  return "\n  subscription CreateEvents {\n    onCreateEvents(id: $id) {\n      events {\n        address\n        baseTokenPrice\n        blockHash\n        blockNumber\n        eventDisplayType\n        eventType\n        logIndex\n        id\n        liquidityToken\n        maker\n        networkId\n        timestamp\n        token0SwapValueUsd\n        token0ValueBase\n        token1SwapValueUsd\n        token1ValueBase\n        transactionHash\n        transactionIndex\n        data {\n          ... on MintEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on BurnEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on SwapEventData {\n            amount0\n            amount0In\n            amount0Out\n            amount1\n            amount1In\n            amount1Out\n            amountNonLiquidityToken\n            priceBaseToken\n            priceBaseTokenTotal\n            priceUsd\n            priceUsdTotal\n            tick\n            type\n          }\n        }\n      }\n      address\n      id\n      networkId\n    }\n  }\n";
+  var whereClause = "";
+  var subclauses = filterParams.map(generateSubClause);
+  if (subclauses.length > 0) {
+    whereClause = "(" + subclauses.join(',') + ")";
+  }
+  return "\n  subscription CreateEvents {\n    onCreateEvents" + whereClause + " {\n      events {\n        address\n        baseTokenPrice\n        blockHash\n        blockNumber\n        eventDisplayType\n        eventType\n        logIndex\n        id\n        liquidityToken\n        maker\n        networkId\n        timestamp\n        token0SwapValueUsd\n        token0ValueBase\n        token1SwapValueUsd\n        token1ValueBase\n        transactionHash\n        transactionIndex\n        data {\n          ... on MintEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on BurnEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on SwapEventData {\n            amount0\n            amount0In\n            amount0Out\n            amount1\n            amount1In\n            amount1Out\n            amountNonLiquidityToken\n            priceBaseToken\n            priceBaseTokenTotal\n            priceUsd\n            priceUsdTotal\n            tick\n            type\n          }\n        }\n      }\n      address\n      id\n      networkId\n    }\n  }\n";
 };
@@ -107,4 +111,2 @@
     ws = window.WebSocket || window.MozWebSocket;
-  } else if (typeof self !== 'undefined') {
-    ws = self.WebSocket || self.MozWebSocket;
   }
@@ -111,0 +113,0 @@ return ws;

dist/defined-realtime-websocket.cjs.production.min.js

@@ -1,2 +0,2 @@
-"use strict";Object.defineProperty(exports,"__esModule",{value:!0});var n=require("uuid"),t=function(n){var t=n[0],e=n[1],r=t+': "'+e+'"';return"number"==typeof e&&(r=t+": "+e),r},e=function(n,e){var r=[];n&&r.push(["address",n.toLowerCase()]),e&&r.push(["networkId",parseInt(e.toString(10),10)]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\nsubscription NftSaleEventSubscription {\n  onCreateNftEvents"+o+" {\n    address\n    id\n    networkId\n    events {\n      id\n      tokenId\n      aggregatorAddress\n      blockNumber\n      contractAddress\n      eventType\n      exchangeAddress\n      data {\n        buyHash\n        maker\n        metadata\n        price\n        sellHash\n        taker\n        type\n      }\n      taker\n      timestamp\n      numberOfTokens\n      transactionHash\n      logIndex\n      maker\n      networkId\n      totalPriceNetworkBaseToken\n      totalPriceUsd\n      transactionIndex\n      individualPrice\n      individualPriceUsd\n      individualPriceNetworkBaseToken\n      paymentTokenAddress\n      poolAddress\n      sortKey\n      totalPrice\n    }\n  }\n}\n"},r=function(n,e){var r=[];n&&r.push(["address",n.toLowerCase()]),e&&r.push(["networkId",parseInt(e.toString(10),10)]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\nsubscription UpdatePrice {\n    onUpdatePrice"+o+" {\n      address\n      networkId\n      priceUsd\n      timestamp\n    }\n  }\n"},o=function(n,e){var r=[];n&&e&&r.push(["pairId",n.toLowerCase()+":"+e]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\n  subscription UpdateAggregateBatch {\n    onUpdateAggregateBatch"+o+" {\n      eventSortKey\n      networkId\n      pairAddress\n      pairId\n      timestamp\n      aggregates {\n      r1 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r5 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r15 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r30 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r60 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r240 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r720 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r1D {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r7D {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n    }\n  }\n"},i=function(n,e){var r=[];return n&&e&&r.push(["pairId",n.toLowerCase()+":"+e]),r.map(t),"\n  subscription CreateEvents {\n    onCreateEvents(id: $id) {\n      events {\n        address\n        baseTokenPrice\n        blockHash\n        blockNumber\n        eventDisplayType\n        eventType\n        logIndex\n        id\n        liquidityToken\n        maker\n        networkId\n        timestamp\n        token0SwapValueUsd\n        token0ValueBase\n        token1SwapValueUsd\n        token1ValueBase\n        transactionHash\n        transactionIndex\n        data {\n          ... on MintEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on BurnEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on SwapEventData {\n            amount0\n            amount0In\n            amount0Out\n            amount1\n            amount1In\n            amount1Out\n            amountNonLiquidityToken\n            priceBaseToken\n            priceBaseTokenTotal\n            priceUsd\n            priceUsdTotal\n            tick\n            type\n          }\n        }\n      }\n      address\n      id\n      networkId\n    }\n  }\n"};function a(n,t){if(!n)throw new Error("Invariant failed")}var s="realtime.api.defined.fi",u=function(n){try{return btoa(n)}catch(t){return Buffer.from(n).toString("base64")}},c=function(n){if(n)return n;var t,e=(t=void 0,"undefined"!=typeof WebSocket?t=WebSocket:"undefined"!=typeof MozWebSocket?t=MozWebSocket:"undefined"!=typeof global?t=global.WebSocket||global.MozWebSocket:"undefined"!=typeof window?t=window.WebSocket||window.MozWebSocket:"undefined"!=typeof self&&(t=self.WebSocket||self.MozWebSocket),t);return e||("undefined"==typeof window?require("ws"):(e||a(!1),e))},l=function(n,t){return void 0===t&&(t="wss://realtime.api.defined.fi/graphql/realtime"),t+"?header="+n+"&payload=e30="},d=function(n,t){return void 0===t&&(t=s),u('{"host": "'+t+'", "Authorization": "'+n+'" }')};function h(){h=function(){return n};var n={},t=Object.prototype,e=t.hasOwnProperty,r=Object.defineProperty||function(n,t,e){n[t]=e.value},o="function"==typeof Symbol?Symbol:{},i=o.iterator||"@@iterator",a=o.asyncIterator||"@@asyncIterator",s=o.toStringTag||"@@toStringTag";function u(n,t,e){return Object.defineProperty(n,t,{value:e,enumerable:!0,configurable:!0,writable:!0}),n[t]}try{u({},"")}catch(n){u=function(n,t,e){return n[t]=e}}function c(n,t,e,o){var i=Object.create((t&&t.prototype instanceof f?t:f).prototype),a=new T(o||[]);return r(i,"_invoke",{value:S(n,e,a)}),i}function l(n,t,e){try{return{type:"normal",arg:n.call(t,e)}}catch(n){return{type:"throw",arg:n}}}n.wrap=c;var d={};function f(){}function p(){}function v(){}var y={};u(y,i,(function(){return this}));var g=Object.getPrototypeOf,m=g&&g(g(I([])));m&&m!==t&&e.call(m,i)&&(y=m);var w=v.prototype=f.prototype=Object.create(y);function b(n){["next","throw","return"].forEach((function(t){u(n,t,(function(n){return this._invoke(t,n)}))}))}function k(n,t){function o(r,i,a,s){var u=l(n[r],n,i);if("throw"!==u.type){var c=u.arg,d=c.value;return d&&"object"==typeof d&&e.call(d,"__await")?t.resolve(d.__await).then((function(n){o("next",n,a,s)}),(function(n){o("throw",n,a,s)})):t.resolve(d).then((function(n){c.value=n,a(c)}),(function(n){return o("throw",n,a,s)}))}s(u.arg)}var i;r(this,"_invoke",{value:function(n,e){function r(){return new t((function(t,r){o(n,e,t,r)}))}return i=i?i.then(r,r):r()}})}function S(n,t,e){var r="suspendedStart";return function(o,i){if("executing"===r)throw new Error("Generator is already running");if("completed"===r){if("throw"===o)throw i;return{value:void 0,done:!0}}for(e.method=o,e.arg=i;;){var a=e.delegate;if(a){var s=L(a,e);if(s){if(s===d)continue;return s}}if("next"===e.method)e.sent=e._sent=e.arg;else if("throw"===e.method){if("suspendedStart"===r)throw r="completed",e.arg;e.dispatchException(e.arg)}else"return"===e.method&&e.abrupt("return",e.arg);r="executing";var u=l(n,t,e);if("normal"===u.type){if(r=e.done?"completed":"suspendedYield",u.arg===d)continue;return{value:u.arg,done:e.done}}"throw"===u.type&&(r="completed",e.method="throw",e.arg=u.arg)}}}function L(n,t){var e=t.method,r=n.iterator[e];if(void 0===r)return t.delegate=null,"throw"===e&&n.iterator.return&&(t.method="return",t.arg=void 0,L(n,t),"throw"===t.method)||"return"!==e&&(t.method="throw",t.arg=new TypeError("The iterator does not provide a '"+e+"' method")),d;var o=l(r,n.iterator,t.arg);if("throw"===o.type)return t.method="throw",t.arg=o.arg,t.delegate=null,d;var i=o.arg;return i?i.done?(t[n.resultName]=i.value,t.next=n.nextLoc,"return"!==t.method&&(t.method="next",t.arg=void 0),t.delegate=null,d):i:(t.method="throw",t.arg=new TypeError("iterator result is not an object"),t.delegate=null,d)}function x(n){var t={tryLoc:n[0]};1 in n&&(t.catchLoc=n[1]),2 in n&&(t.finallyLoc=n[2],t.afterLoc=n[3]),this.tryEntries.push(t)}function E(n){var t=n.completion||{};t.type="normal",delete t.arg,n.completion=t}function T(n){this.tryEntries=[{tryLoc:"root"}],n.forEach(x,this),this.reset(!0)}function I(n){if(n){var t=n[i];if(t)return t.call(n);if("function"==typeof n.next)return n;if(!isNaN(n.length)){var r=-1,o=function t(){for(;++r<n.length;)if(e.call(n,r))return t.value=n[r],t.done=!1,t;return t.value=void 0,t.done=!0,t};return o.next=o}}return{next:z}}function z(){return{value:void 0,done:!0}}return p.prototype=v,r(w,"constructor",{value:v,configurable:!0}),r(v,"constructor",{value:p,configurable:!0}),p.displayName=u(v,s,"GeneratorFunction"),n.isGeneratorFunction=function(n){var t="function"==typeof n&&n.constructor;return!!t&&(t===p||"GeneratorFunction"===(t.displayName||t.name))},n.mark=function(n){return Object.setPrototypeOf?Object.setPrototypeOf(n,v):(n.__proto__=v,u(n,s,"GeneratorFunction")),n.prototype=Object.create(w),n},n.awrap=function(n){return{__await:n}},b(k.prototype),u(k.prototype,a,(function(){return this})),n.AsyncIterator=k,n.async=function(t,e,r,o,i){void 0===i&&(i=Promise);var a=new k(c(t,e,r,o),i);return n.isGeneratorFunction(e)?a:a.next().then((function(n){return n.done?n.value:a.next()}))},b(w),u(w,s,"Generator"),u(w,i,(function(){return this})),u(w,"toString",(function(){return"[object Generator]"})),n.keys=function(n){var t=Object(n),e=[];for(var r in t)e.push(r);return e.reverse(),function n(){for(;e.length;){var r=e.pop();if(r in t)return n.value=r,n.done=!1,n}return n.done=!0,n}},n.values=I,T.prototype={constructor:T,reset:function(n){if(this.prev=0,this.next=0,this.sent=this._sent=void 0,this.done=!1,this.delegate=null,this.method="next",this.arg=void 0,this.tryEntries.forEach(E),!n)for(var t in this)"t"===t.charAt(0)&&e.call(this,t)&&!isNaN(+t.slice(1))&&(this[t]=void 0)},stop:function(){this.done=!0;var n=this.tryEntries[0].completion;if("throw"===n.type)throw n.arg;return this.rval},dispatchException:function(n){if(this.done)throw n;var t=this;function r(e,r){return a.type="throw",a.arg=n,t.next=e,r&&(t.method="next",t.arg=void 0),!!r}for(var o=this.tryEntries.length-1;o>=0;--o){var i=this.tryEntries[o],a=i.completion;if("root"===i.tryLoc)return r("end");if(i.tryLoc<=this.prev){var s=e.call(i,"catchLoc"),u=e.call(i,"finallyLoc");if(s&&u){if(this.prev<i.catchLoc)return r(i.catchLoc,!0);if(this.prev<i.finallyLoc)return r(i.finallyLoc)}else if(s){if(this.prev<i.catchLoc)return r(i.catchLoc,!0)}else{if(!u)throw new Error("try statement without catch or finally");if(this.prev<i.finallyLoc)return r(i.finallyLoc)}}}},abrupt:function(n,t){for(var r=this.tryEntries.length-1;r>=0;--r){var o=this.tryEntries[r];if(o.tryLoc<=this.prev&&e.call(o,"finallyLoc")&&this.prev<o.finallyLoc){var i=o;break}}i&&("break"===n||"continue"===n)&&i.tryLoc<=t&&t<=i.finallyLoc&&(i=null);var a=i?i.completion:{};return a.type=n,a.arg=t,i?(this.method="next",this.next=i.finallyLoc,d):this.complete(a)},complete:function(n,t){if("throw"===n.type)throw n.arg;return"break"===n.type||"continue"===n.type?this.next=n.arg:"return"===n.type?(this.rval=this.arg=n.arg,this.method="return",this.next="end"):"normal"===n.type&&t&&(this.next=t),d},finish:function(n){for(var t=this.tryEntries.length-1;t>=0;--t){var e=this.tryEntries[t];if(e.finallyLoc===n)return this.complete(e.completion,e.afterLoc),E(e),d}},catch:function(n){for(var t=this.tryEntries.length-1;t>=0;--t){var e=this.tryEntries[t];if(e.tryLoc===n){var r=e.completion;if("throw"===r.type){var o=r.arg;E(e)}return o}}throw new Error("illegal catch attempt")},delegateYield:function(n,t,e){return this.delegate={iterator:I(n),resultName:t,nextLoc:e},"next"===this.method&&(this.arg=void 0),d}},n}function f(n,t,e,r,o,i,a){try{var s=n[i](a),u=s.value}catch(n){return void e(n)}s.done?t(u):Promise.resolve(u).then(r,o)}function p(n){return function(){var t=this,e=arguments;return new Promise((function(r,o){var i=n.apply(t,e);function a(n){f(i,r,o,a,s,"next",n)}function s(n){f(i,r,o,a,s,"throw",n)}a(void 0)}))}}exports.DefinedRealtimeClient=function(t,u){var f=this;this.apiKey=void 0,this.wsFactory=void 0,this.hostUrl=s,this.wsLazySingleton=void 0,this.getWebSocketUrl=function(){var n=d(f.apiKey);return l(n)},this.disconnect=p(h().mark((function n(){return h().wrap((function(n){for(;;)switch(n.prev=n.next){case 0:return n.abrupt("return",new Promise((function(n){var t,e,r;if(!f.wsLazySingleton)return n(!0);null==(t=f.wsLazySingleton)||t.close(),3!==(null==(e=f.wsLazySingleton)?void 0:e.readyState)?null==(r=f.wsLazySingleton)||r.addEventListener("close",(function(t){n(!0)})):n(!0)})));case 1:case"end":return n.stop()}}),n)}))),this.connect=p(h().mark((function n(){return h().wrap((function(n){for(;;)switch(n.prev=n.next){case 0:return n.abrupt("return",new Promise((function(n){var t,e,r;1===(null==(t=f.wsLazySingleton)?void 0:t.readyState)&&n(f.wsLazySingleton),f.wsLazySingleton||f._initDefinedFiWebSocket(),1!==(null==(e=f.wsLazySingleton)?void 0:e.readyState)?null==(r=f.wsLazySingleton)||r.addEventListener("open",(function(t){n(f.wsLazySingleton)})):n(f.wsLazySingleton)})));case 1:case"end":return n.stop()}}),n)}))),this.subscribe=function(){var t=p(h().mark((function t(e,r){var o,i,a,s,u;return h().wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return t.next=2,f.connect();case 2:return i=n.v4(),a=JSON.stringify({query:e,variables:null}),s={id:i,payload:{data:a,extensions:{authorization:{host:f.hostUrl,Authorization:f.apiKey}}},type:"start"},u=function(n){try{var t=JSON.parse(n.data);if(!t.id)return void console.warn("Unrecognized websocket message",t.payload.errors);if(t.id!==i)return;if("error"===t.type)return console.log("Error with subscription "+i,t.payload.errors),void(null==r.error||r.error(t));if("start_ack"===t.type)return;return void r.next(t.payload.data)}catch(n){throw n}},null==(o=f.wsLazySingleton)||o.addEventListener("message",u),f.wsLazySingleton.send(JSON.stringify(s)),t.abrupt("return",(function(){var n;null==(n=f.wsLazySingleton)||n.removeEventListener("message",u)}));case 10:case"end":return t.stop()}}),t)})));return function(n,e){return t.apply(this,arguments)}}(),this.subscribeToNftSales=function(n,t){var r=e(n.contractAddress,n.chainId);return f.subscribe(r,t)},this.subscribeToTokenPriceUpdates=function(n,t){var e=r(n.contractAddress,n.chainId);return f.subscribe(e,t)},this.subscribeToTokenChartUpdates=function(n,t){var e=i(n.contractAddressOrPaidAddress,n.chainId);return f.subscribe(e,t)},this.subscribeToTokenSwapUpdates=function(n,t){var e=o(n.contractAddressOrPaidAddress,n.chainId);return f.subscribe(e,t)},this.getWebSocketAuthenticatedConnectionString=function(){var n=d(f.apiKey,f.hostUrl);return l(n)},this._initDefinedFiWebSocket=function(){if(f.wsLazySingleton)return f.wsLazySingleton;var n=f.getWebSocketAuthenticatedConnectionString();return f.wsLazySingleton=new f.wsFactory(n,"graphql-ws"),f.wsLazySingleton},this.apiKey=t,this.apiKey||a(!1),this.wsFactory=c(),!1===(null==u?void 0:u.lazyLoadWebSocketConnection)&&this._initDefinedFiWebSocket(),null!=u&&u.hostUrl&&(this.hostUrl=u.hostUrl)},exports.btoaIsomorphic=u,exports.encodeApiKeyToWebsocketAuthHeader=d,exports.getDefinedErc20TokenChartUpdateGql=i,exports.getDefinedErc20TokenPriceUpdateGql=r,exports.getDefinedErc20TokenSwapUpdateGql=o,exports.getDefinedNftSaleSubscriptionGql=e,exports.getDefinedWsWebsocketUrl=l,exports.getIsomorphicWebSocket=c,exports.sleep=function(n){return new Promise((function(t,e){setTimeout((function(){t(null)}),n)}))};
+"use strict";Object.defineProperty(exports,"__esModule",{value:!0});var n=require("uuid"),t=function(n){var t=n[0],e=n[1],r=t+': "'+e+'"';return"number"==typeof e&&(r=t+": "+e),r},e=function(n,e){var r=[];n&&r.push(["address",n.toLowerCase()]),e&&r.push(["networkId",parseInt(e.toString(10),10)]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\nsubscription NftSaleEventSubscription {\n  onCreateNftEvents"+o+" {\n    address\n    id\n    networkId\n    events {\n      id\n      tokenId\n      aggregatorAddress\n      blockNumber\n      contractAddress\n      eventType\n      exchangeAddress\n      data {\n        buyHash\n        maker\n        metadata\n        price\n        sellHash\n        taker\n        type\n      }\n      taker\n      timestamp\n      numberOfTokens\n      transactionHash\n      logIndex\n      maker\n      networkId\n      totalPriceNetworkBaseToken\n      totalPriceUsd\n      transactionIndex\n      individualPrice\n      individualPriceUsd\n      individualPriceNetworkBaseToken\n      paymentTokenAddress\n      poolAddress\n      sortKey\n      totalPrice\n    }\n  }\n}\n"},r=function(n,e){var r=[];n&&r.push(["address",n.toLowerCase()]),e&&r.push(["networkId",parseInt(e.toString(10),10)]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\nsubscription UpdatePrice {\n    onUpdatePrice"+o+" {\n      address\n      networkId\n      priceUsd\n      timestamp\n    }\n  }\n"},o=function(n,e){var r=[];n&&e&&r.push(["pairId",n.toLowerCase()+":"+e]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\n  subscription UpdateAggregateBatch {\n    onUpdateAggregateBatch"+o+" {\n      eventSortKey\n      networkId\n      pairAddress\n      pairId\n      timestamp\n      aggregates {\n      r1 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r5 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r15 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r30 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r60 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r240 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r720 {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r1D {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n      r7D {\n        t\n        usd {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n        token {\n          t\n          o\n          h\n          l\n          c\n          volume\n        }\n      }\n    }\n  }\n"},i=function(n,e){var r=[];n&&e&&r.push(["pairId",n.toLowerCase()+":"+e]);var o="",i=r.map(t);return i.length>0&&(o="("+i.join(",")+")"),"\n  subscription CreateEvents {\n    onCreateEvents"+o+" {\n      events {\n        address\n        baseTokenPrice\n        blockHash\n        blockNumber\n        eventDisplayType\n        eventType\n        logIndex\n        id\n        liquidityToken\n        maker\n        networkId\n        timestamp\n        token0SwapValueUsd\n        token0ValueBase\n        token1SwapValueUsd\n        token1ValueBase\n        transactionHash\n        transactionIndex\n        data {\n          ... on MintEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on BurnEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on SwapEventData {\n            amount0\n            amount0In\n            amount0Out\n            amount1\n            amount1In\n            amount1Out\n            amountNonLiquidityToken\n            priceBaseToken\n            priceBaseTokenTotal\n            priceUsd\n            priceUsdTotal\n            tick\n            type\n          }\n        }\n      }\n      address\n      id\n      networkId\n    }\n  }\n"};function a(n,t){if(!n)throw new Error("Invariant failed")}var s="realtime.api.defined.fi",u=function(n){try{return btoa(n)}catch(t){return Buffer.from(n).toString("base64")}},c=function(n){if(n)return n;var t,e=(t=void 0,"undefined"!=typeof WebSocket?t=WebSocket:"undefined"!=typeof MozWebSocket?t=MozWebSocket:"undefined"!=typeof global?t=global.WebSocket||global.MozWebSocket:"undefined"!=typeof window&&(t=window.WebSocket||window.MozWebSocket),t);return e||("undefined"==typeof window?require("ws"):(e||a(!1),e))},l=function(n,t){return void 0===t&&(t="wss://realtime.api.defined.fi/graphql/realtime"),t+"?header="+n+"&payload=e30="},d=function(n,t){return void 0===t&&(t=s),u('{"host": "'+t+'", "Authorization": "'+n+'" }')};function h(){h=function(){return n};var n={},t=Object.prototype,e=t.hasOwnProperty,r=Object.defineProperty||function(n,t,e){n[t]=e.value},o="function"==typeof Symbol?Symbol:{},i=o.iterator||"@@iterator",a=o.asyncIterator||"@@asyncIterator",s=o.toStringTag||"@@toStringTag";function u(n,t,e){return Object.defineProperty(n,t,{value:e,enumerable:!0,configurable:!0,writable:!0}),n[t]}try{u({},"")}catch(n){u=function(n,t,e){return n[t]=e}}function c(n,t,e,o){var i=Object.create((t&&t.prototype instanceof f?t:f).prototype),a=new T(o||[]);return r(i,"_invoke",{value:S(n,e,a)}),i}function l(n,t,e){try{return{type:"normal",arg:n.call(t,e)}}catch(n){return{type:"throw",arg:n}}}n.wrap=c;var d={};function f(){}function p(){}function v(){}var y={};u(y,i,(function(){return this}));var g=Object.getPrototypeOf,m=g&&g(g(I([])));m&&m!==t&&e.call(m,i)&&(y=m);var w=v.prototype=f.prototype=Object.create(y);function b(n){["next","throw","return"].forEach((function(t){u(n,t,(function(n){return this._invoke(t,n)}))}))}function k(n,t){function o(r,i,a,s){var u=l(n[r],n,i);if("throw"!==u.type){var c=u.arg,d=c.value;return d&&"object"==typeof d&&e.call(d,"__await")?t.resolve(d.__await).then((function(n){o("next",n,a,s)}),(function(n){o("throw",n,a,s)})):t.resolve(d).then((function(n){c.value=n,a(c)}),(function(n){return o("throw",n,a,s)}))}s(u.arg)}var i;r(this,"_invoke",{value:function(n,e){function r(){return new t((function(t,r){o(n,e,t,r)}))}return i=i?i.then(r,r):r()}})}function S(n,t,e){var r="suspendedStart";return function(o,i){if("executing"===r)throw new Error("Generator is already running");if("completed"===r){if("throw"===o)throw i;return{value:void 0,done:!0}}for(e.method=o,e.arg=i;;){var a=e.delegate;if(a){var s=L(a,e);if(s){if(s===d)continue;return s}}if("next"===e.method)e.sent=e._sent=e.arg;else if("throw"===e.method){if("suspendedStart"===r)throw r="completed",e.arg;e.dispatchException(e.arg)}else"return"===e.method&&e.abrupt("return",e.arg);r="executing";var u=l(n,t,e);if("normal"===u.type){if(r=e.done?"completed":"suspendedYield",u.arg===d)continue;return{value:u.arg,done:e.done}}"throw"===u.type&&(r="completed",e.method="throw",e.arg=u.arg)}}}function L(n,t){var e=t.method,r=n.iterator[e];if(void 0===r)return t.delegate=null,"throw"===e&&n.iterator.return&&(t.method="return",t.arg=void 0,L(n,t),"throw"===t.method)||"return"!==e&&(t.method="throw",t.arg=new TypeError("The iterator does not provide a '"+e+"' method")),d;var o=l(r,n.iterator,t.arg);if("throw"===o.type)return t.method="throw",t.arg=o.arg,t.delegate=null,d;var i=o.arg;return i?i.done?(t[n.resultName]=i.value,t.next=n.nextLoc,"return"!==t.method&&(t.method="next",t.arg=void 0),t.delegate=null,d):i:(t.method="throw",t.arg=new TypeError("iterator result is not an object"),t.delegate=null,d)}function x(n){var t={tryLoc:n[0]};1 in n&&(t.catchLoc=n[1]),2 in n&&(t.finallyLoc=n[2],t.afterLoc=n[3]),this.tryEntries.push(t)}function E(n){var t=n.completion||{};t.type="normal",delete t.arg,n.completion=t}function T(n){this.tryEntries=[{tryLoc:"root"}],n.forEach(x,this),this.reset(!0)}function I(n){if(n){var t=n[i];if(t)return t.call(n);if("function"==typeof n.next)return n;if(!isNaN(n.length)){var r=-1,o=function t(){for(;++r<n.length;)if(e.call(n,r))return t.value=n[r],t.done=!1,t;return t.value=void 0,t.done=!0,t};return o.next=o}}return{next:z}}function z(){return{value:void 0,done:!0}}return p.prototype=v,r(w,"constructor",{value:v,configurable:!0}),r(v,"constructor",{value:p,configurable:!0}),p.displayName=u(v,s,"GeneratorFunction"),n.isGeneratorFunction=function(n){var t="function"==typeof n&&n.constructor;return!!t&&(t===p||"GeneratorFunction"===(t.displayName||t.name))},n.mark=function(n){return Object.setPrototypeOf?Object.setPrototypeOf(n,v):(n.__proto__=v,u(n,s,"GeneratorFunction")),n.prototype=Object.create(w),n},n.awrap=function(n){return{__await:n}},b(k.prototype),u(k.prototype,a,(function(){return this})),n.AsyncIterator=k,n.async=function(t,e,r,o,i){void 0===i&&(i=Promise);var a=new k(c(t,e,r,o),i);return n.isGeneratorFunction(e)?a:a.next().then((function(n){return n.done?n.value:a.next()}))},b(w),u(w,s,"Generator"),u(w,i,(function(){return this})),u(w,"toString",(function(){return"[object Generator]"})),n.keys=function(n){var t=Object(n),e=[];for(var r in t)e.push(r);return e.reverse(),function n(){for(;e.length;){var r=e.pop();if(r in t)return n.value=r,n.done=!1,n}return n.done=!0,n}},n.values=I,T.prototype={constructor:T,reset:function(n){if(this.prev=0,this.next=0,this.sent=this._sent=void 0,this.done=!1,this.delegate=null,this.method="next",this.arg=void 0,this.tryEntries.forEach(E),!n)for(var t in this)"t"===t.charAt(0)&&e.call(this,t)&&!isNaN(+t.slice(1))&&(this[t]=void 0)},stop:function(){this.done=!0;var n=this.tryEntries[0].completion;if("throw"===n.type)throw n.arg;return this.rval},dispatchException:function(n){if(this.done)throw n;var t=this;function r(e,r){return a.type="throw",a.arg=n,t.next=e,r&&(t.method="next",t.arg=void 0),!!r}for(var o=this.tryEntries.length-1;o>=0;--o){var i=this.tryEntries[o],a=i.completion;if("root"===i.tryLoc)return r("end");if(i.tryLoc<=this.prev){var s=e.call(i,"catchLoc"),u=e.call(i,"finallyLoc");if(s&&u){if(this.prev<i.catchLoc)return r(i.catchLoc,!0);if(this.prev<i.finallyLoc)return r(i.finallyLoc)}else if(s){if(this.prev<i.catchLoc)return r(i.catchLoc,!0)}else{if(!u)throw new Error("try statement without catch or finally");if(this.prev<i.finallyLoc)return r(i.finallyLoc)}}}},abrupt:function(n,t){for(var r=this.tryEntries.length-1;r>=0;--r){var o=this.tryEntries[r];if(o.tryLoc<=this.prev&&e.call(o,"finallyLoc")&&this.prev<o.finallyLoc){var i=o;break}}i&&("break"===n||"continue"===n)&&i.tryLoc<=t&&t<=i.finallyLoc&&(i=null);var a=i?i.completion:{};return a.type=n,a.arg=t,i?(this.method="next",this.next=i.finallyLoc,d):this.complete(a)},complete:function(n,t){if("throw"===n.type)throw n.arg;return"break"===n.type||"continue"===n.type?this.next=n.arg:"return"===n.type?(this.rval=this.arg=n.arg,this.method="return",this.next="end"):"normal"===n.type&&t&&(this.next=t),d},finish:function(n){for(var t=this.tryEntries.length-1;t>=0;--t){var e=this.tryEntries[t];if(e.finallyLoc===n)return this.complete(e.completion,e.afterLoc),E(e),d}},catch:function(n){for(var t=this.tryEntries.length-1;t>=0;--t){var e=this.tryEntries[t];if(e.tryLoc===n){var r=e.completion;if("throw"===r.type){var o=r.arg;E(e)}return o}}throw new Error("illegal catch attempt")},delegateYield:function(n,t,e){return this.delegate={iterator:I(n),resultName:t,nextLoc:e},"next"===this.method&&(this.arg=void 0),d}},n}function f(n,t,e,r,o,i,a){try{var s=n[i](a),u=s.value}catch(n){return void e(n)}s.done?t(u):Promise.resolve(u).then(r,o)}function p(n){return function(){var t=this,e=arguments;return new Promise((function(r,o){var i=n.apply(t,e);function a(n){f(i,r,o,a,s,"next",n)}function s(n){f(i,r,o,a,s,"throw",n)}a(void 0)}))}}exports.DefinedRealtimeClient=function(t,u){var f=this;this.apiKey=void 0,this.wsFactory=void 0,this.hostUrl=s,this.wsLazySingleton=void 0,this.getWebSocketUrl=function(){var n=d(f.apiKey);return l(n)},this.disconnect=p(h().mark((function n(){return h().wrap((function(n){for(;;)switch(n.prev=n.next){case 0:return n.abrupt("return",new Promise((function(n){var t,e,r;if(!f.wsLazySingleton)return n(!0);null==(t=f.wsLazySingleton)||t.close(),3!==(null==(e=f.wsLazySingleton)?void 0:e.readyState)?null==(r=f.wsLazySingleton)||r.addEventListener("close",(function(t){n(!0)})):n(!0)})));case 1:case"end":return n.stop()}}),n)}))),this.connect=p(h().mark((function n(){return h().wrap((function(n){for(;;)switch(n.prev=n.next){case 0:return n.abrupt("return",new Promise((function(n){var t,e,r;1===(null==(t=f.wsLazySingleton)?void 0:t.readyState)&&n(f.wsLazySingleton),f.wsLazySingleton||f._initDefinedFiWebSocket(),1!==(null==(e=f.wsLazySingleton)?void 0:e.readyState)?null==(r=f.wsLazySingleton)||r.addEventListener("open",(function(t){n(f.wsLazySingleton)})):n(f.wsLazySingleton)})));case 1:case"end":return n.stop()}}),n)}))),this.subscribe=function(){var t=p(h().mark((function t(e,r){var o,i,a,s,u;return h().wrap((function(t){for(;;)switch(t.prev=t.next){case 0:return t.next=2,f.connect();case 2:return i=n.v4(),a=JSON.stringify({query:e,variables:null}),s={id:i,payload:{data:a,extensions:{authorization:{host:f.hostUrl,Authorization:f.apiKey}}},type:"start"},u=function(n){try{var t=JSON.parse(n.data);if(!t.id)return void console.warn("Unrecognized websocket message",t.payload.errors);if(t.id!==i)return;if("error"===t.type)return console.log("Error with subscription "+i,t.payload.errors),void(null==r.error||r.error(t));if("start_ack"===t.type)return;return void r.next(t.payload.data)}catch(n){throw n}},null==(o=f.wsLazySingleton)||o.addEventListener("message",u),f.wsLazySingleton.send(JSON.stringify(s)),t.abrupt("return",(function(){var n;null==(n=f.wsLazySingleton)||n.removeEventListener("message",u)}));case 10:case"end":return t.stop()}}),t)})));return function(n,e){return t.apply(this,arguments)}}(),this.subscribeToNftSales=function(n,t){var r=e(n.contractAddress,n.chainId);return f.subscribe(r,t)},this.subscribeToTokenPriceUpdates=function(n,t){var e=r(n.contractAddress,n.chainId);return f.subscribe(e,t)},this.subscribeToTokenChartUpdates=function(n,t){var e=i(n.contractAddressOrPaidAddress,n.chainId);return f.subscribe(e,t)},this.subscribeToTokenSwapUpdates=function(n,t){var e=o(n.contractAddressOrPaidAddress,n.chainId);return f.subscribe(e,t)},this.getWebSocketAuthenticatedConnectionString=function(){var n=d(f.apiKey,f.hostUrl);return l(n)},this._initDefinedFiWebSocket=function(){if(f.wsLazySingleton)return f.wsLazySingleton;var n=f.getWebSocketAuthenticatedConnectionString();return f.wsLazySingleton=new f.wsFactory(n,"graphql-ws"),f.wsLazySingleton},this.apiKey=t,this.apiKey||a(!1),this.wsFactory=c(),!1===(null==u?void 0:u.lazyLoadWebSocketConnection)&&this._initDefinedFiWebSocket(),null!=u&&u.hostUrl&&(this.hostUrl=u.hostUrl)},exports.btoaIsomorphic=u,exports.encodeApiKeyToWebsocketAuthHeader=d,exports.getDefinedErc20TokenChartUpdateGql=i,exports.getDefinedErc20TokenPriceUpdateGql=r,exports.getDefinedErc20TokenSwapUpdateGql=o,exports.getDefinedNftSaleSubscriptionGql=e,exports.getDefinedWsWebsocketUrl=l,exports.getIsomorphicWebSocket=c,exports.sleep=function(n){return new Promise((function(t,e){setTimeout((function(){t(null)}),n)}))};
 //# sourceMappingURL=defined-realtime-websocket.cjs.production.min.js.map

dist/defined-realtime-websocket.esm.js

@@ -64,4 +64,8 @@ import { v4 } from 'uuid';
   }
-  filterParams.map(generateSubClause);
-  return "\n  subscription CreateEvents {\n    onCreateEvents(id: $id) {\n      events {\n        address\n        baseTokenPrice\n        blockHash\n        blockNumber\n        eventDisplayType\n        eventType\n        logIndex\n        id\n        liquidityToken\n        maker\n        networkId\n        timestamp\n        token0SwapValueUsd\n        token0ValueBase\n        token1SwapValueUsd\n        token1ValueBase\n        transactionHash\n        transactionIndex\n        data {\n          ... on MintEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on BurnEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on SwapEventData {\n            amount0\n            amount0In\n            amount0Out\n            amount1\n            amount1In\n            amount1Out\n            amountNonLiquidityToken\n            priceBaseToken\n            priceBaseTokenTotal\n            priceUsd\n            priceUsdTotal\n            tick\n            type\n          }\n        }\n      }\n      address\n      id\n      networkId\n    }\n  }\n";
+  var whereClause = "";
+  var subclauses = filterParams.map(generateSubClause);
+  if (subclauses.length > 0) {
+    whereClause = "(" + subclauses.join(',') + ")";
+  }
+  return "\n  subscription CreateEvents {\n    onCreateEvents" + whereClause + " {\n      events {\n        address\n        baseTokenPrice\n        blockHash\n        blockNumber\n        eventDisplayType\n        eventType\n        logIndex\n        id\n        liquidityToken\n        maker\n        networkId\n        timestamp\n        token0SwapValueUsd\n        token0ValueBase\n        token1SwapValueUsd\n        token1ValueBase\n        transactionHash\n        transactionIndex\n        data {\n          ... on MintEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on BurnEventData {\n            amount0\n            amount1\n            amount0Shifted\n            amount1Shifted\n            tickLower\n            tickUpper\n            type\n          }\n          ... on SwapEventData {\n            amount0\n            amount0In\n            amount0Out\n            amount1\n            amount1In\n            amount1Out\n            amountNonLiquidityToken\n            priceBaseToken\n            priceBaseTokenTotal\n            priceUsd\n            priceUsdTotal\n            tick\n            type\n          }\n        }\n      }\n      address\n      id\n      networkId\n    }\n  }\n";
 };
@@ -109,4 +113,2 @@
     ws = window.WebSocket || window.MozWebSocket;
-  } else if (typeof self !== 'undefined') {
-    ws = self.WebSocket || self.MozWebSocket;
   }
@@ -113,0 +115,0 @@ return ws;

package.json

 {
   "name": "defined-realtime-websocket",
-  "version": "0.1.0",
+  "version": "0.1.1",
   "license": "MIT",
@@ -5,0 +5,0 @@ "author": "johnrjj",

README.md

 # Defined.fi Realtime Websocket SDK
 
-TypeScript library for interacting with [Defined.fi](https://defined.fi)'s realtime websockets.
+TypeScript library for interacting with [Defined.fi](https://defined.fi)'s realtime websockets. Access **realtime** DEX trades, NFT trades, mints, burns, and pricing updates across every popular chain via Defined via WebSocket subscriptions in your app or backend.
 
@@ -5,0 +5,0 @@ ![Defined Banner](./banner.jpg)

src/browser.ts

@@ -17,4 +17,2 @@ // https://github.com/maxogden/websocket-stream/blob/48dc3ddf943e5ada668c31ccd94e9186f02fafbd/ws-fallback.js
     ws = window.WebSocket || (window as any).MozWebSocket;
-  } else if (typeof self !== 'undefined') {
-    ws = self.WebSocket || (self as any).MozWebSocket;
   }
@@ -21,0 +19,0 @@ return ws;

src/gql.ts

@@ -436,3 +436,3 @@ type FilterTuple = [string, string | number];
   subscription CreateEvents {
-    onCreateEvents(id: $id) {
+    onCreateEvents${whereClause} {
       events {
@@ -439,0 +439,0 @@ address

src/node.ts

@@ -1,3 +0,1 @@
-'use strict';
-
 module.exports = require('ws');

New alerts

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Fixed alerts

Long strings

Supply chain risk

Contains long string literals, which may be a sign of obfuscated or packed code.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

242577

increased by0.02%

Lines of code

2795

increased by0.04%

No dependency changes