AbstractWeb3Connector.js 7.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221
  1. "use strict";
  2. var _Reflect$construct = require("@babel/runtime-corejs3/core-js-stable/reflect/construct");
  3. var _Object$defineProperty = require("@babel/runtime-corejs3/core-js-stable/object/define-property");
  4. var _interopRequireDefault = require("@babel/runtime-corejs3/helpers/interopRequireDefault");
  5. _Object$defineProperty(exports, "__esModule", {
  6. value: true
  7. });
  8. exports.default = void 0;
  9. var _regenerator = _interopRequireDefault(require("@babel/runtime-corejs3/regenerator"));
  10. var _bind = _interopRequireDefault(require("@babel/runtime-corejs3/core-js-stable/instance/bind"));
  11. var _asyncToGenerator2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/asyncToGenerator"));
  12. var _classCallCheck2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/classCallCheck"));
  13. var _createClass2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/createClass"));
  14. var _assertThisInitialized2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/assertThisInitialized"));
  15. var _inherits2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/inherits"));
  16. var _possibleConstructorReturn2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/possibleConstructorReturn"));
  17. var _getPrototypeOf2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/getPrototypeOf"));
  18. var _defineProperty2 = _interopRequireDefault(require("@babel/runtime-corejs3/helpers/defineProperty"));
  19. var _events = _interopRequireDefault(require("events"));
  20. var _verifyChainId = _interopRequireDefault(require("../utils/verifyChainId"));
  21. var _events2 = require("./events");
  22. function _createSuper(Derived) {
  23. var hasNativeReflectConstruct = _isNativeReflectConstruct();
  24. return function () {
  25. var Super = (0, _getPrototypeOf2.default)(Derived),
  26. result;
  27. if (hasNativeReflectConstruct) {
  28. var NewTarget = (0, _getPrototypeOf2.default)(this).constructor;
  29. result = _Reflect$construct(Super, arguments, NewTarget);
  30. } else {
  31. result = Super.apply(this, arguments);
  32. }
  33. return (0, _possibleConstructorReturn2.default)(this, result);
  34. };
  35. }
  36. function _isNativeReflectConstruct() {
  37. if (typeof Reflect === "undefined" || !_Reflect$construct) return false;
  38. if (_Reflect$construct.sham) return false;
  39. if (typeof Proxy === "function") return true;
  40. try {
  41. Boolean.prototype.valueOf.call(_Reflect$construct(Boolean, [], function () {}));
  42. return true;
  43. } catch (e) {
  44. return false;
  45. }
  46. }
  47. /**
  48. * Abstract connector to connect EIP-1193 providers to Moralis
  49. *
  50. * It should implement at least:
  51. * - activate()
  52. * - Emit ConnectorEvent.CHAIN_CHANGED when the chain has changed (if possible)
  53. * - Emit ConnectorEvent.ACCOUNT_CHANGED when the account has changed (if possible)
  54. * - type: a name to identify
  55. * - network: the network type that is used (eg. 'evm')
  56. */
  57. var AbstractWeb3Connector = /*#__PURE__*/function (_EventEmitter) {
  58. (0, _inherits2.default)(AbstractWeb3Connector, _EventEmitter);
  59. var _super = _createSuper(AbstractWeb3Connector);
  60. function AbstractWeb3Connector() {
  61. var _context, _context2, _context3, _context4;
  62. var _this;
  63. (0, _classCallCheck2.default)(this, AbstractWeb3Connector);
  64. _this = _super.call(this);
  65. (0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "type", 'abstract');
  66. (0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "network", 'evm');
  67. (0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "account", null);
  68. (0, _defineProperty2.default)((0, _assertThisInitialized2.default)(_this), "chainId", null);
  69. _this.handleAccountsChanged = (0, _bind.default)(_context = _this.handleAccountsChanged).call(_context, (0, _assertThisInitialized2.default)(_this));
  70. _this.handleChainChanged = (0, _bind.default)(_context2 = _this.handleChainChanged).call(_context2, (0, _assertThisInitialized2.default)(_this));
  71. _this.handleConnect = (0, _bind.default)(_context3 = _this.handleConnect).call(_context3, (0, _assertThisInitialized2.default)(_this));
  72. _this.handleDisconnect = (0, _bind.default)(_context4 = _this.handleDisconnect).call(_context4, (0, _assertThisInitialized2.default)(_this));
  73. return _this;
  74. }
  75. (0, _createClass2.default)(AbstractWeb3Connector, [{
  76. key: "subscribeToEvents",
  77. value: function (provider) {
  78. if (provider && provider.on) {
  79. provider.on(_events2.EthereumEvents.CHAIN_CHANGED, this.handleChainChanged);
  80. provider.on(_events2.EthereumEvents.ACCOUNTS_CHANGED, this.handleAccountsChanged);
  81. provider.on(_events2.EthereumEvents.CONNECT, this.handleConnect);
  82. provider.on(_events2.EthereumEvents.DISCONNECT, this.handleDisconnect);
  83. }
  84. }
  85. }, {
  86. key: "unsubscribeToEvents",
  87. value: function (provider) {
  88. if (provider && provider.removeListener) {
  89. provider.removeListener(_events2.EthereumEvents.CHAIN_CHANGED, this.handleChainChanged);
  90. provider.removeListener(_events2.EthereumEvents.ACCOUNTS_CHANGED, this.handleAccountsChanged);
  91. provider.removeListener(_events2.EthereumEvents.CONNECT, this.handleConnect);
  92. provider.removeListener(_events2.EthereumEvents.DISCONNECT, this.handleDisconnect);
  93. }
  94. }
  95. /**
  96. * Activates the provider.
  97. * Should returns an object with:
  98. * - provider: A valid EIP-1193 provider
  99. * - chainId(optional): the chainId that has been connected to (in hex format)
  100. * - account(optional): the address that is connected to the provider
  101. */
  102. }, {
  103. key: "activate",
  104. value: function () {
  105. var _activate = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee() {
  106. return _regenerator.default.wrap(function (_context5) {
  107. while (1) {
  108. switch (_context5.prev = _context5.next) {
  109. case 0:
  110. throw new Error('Not implemented: activate()');
  111. case 1:
  112. case "end":
  113. return _context5.stop();
  114. }
  115. }
  116. }, _callee);
  117. }));
  118. return function () {
  119. return _activate.apply(this, arguments);
  120. };
  121. }()
  122. /**
  123. * Updates account and emit event, on EIP-1193 accountsChanged events
  124. */
  125. }, {
  126. key: "handleAccountsChanged",
  127. value: function (accounts) {
  128. var account = accounts && accounts[0] ? accounts[0].toLowerCase() : null;
  129. this.account = account;
  130. this.emit(_events2.ConnectorEvents.ACCOUNT_CHANGED, account);
  131. }
  132. /**
  133. * Updates chainId and emit event, on EIP-1193 accountsChanged events
  134. */
  135. }, {
  136. key: "handleChainChanged",
  137. value: function (chainId) {
  138. var newChainId = (0, _verifyChainId.default)(chainId);
  139. this.chainId = newChainId;
  140. this.emit(_events2.ConnectorEvents.CHAIN_CHANGED, newChainId);
  141. }
  142. }, {
  143. key: "handleConnect",
  144. value: function (connectInfo) {
  145. this.emit(_events2.ConnectorEvents.CONNECT, connectInfo);
  146. }
  147. }, {
  148. key: "handleDisconnect",
  149. value: function (error) {
  150. this.emit(_events2.ConnectorEvents.DISCONNECT, error);
  151. }
  152. /**
  153. * Cleans all active listners, connections and stale references
  154. */
  155. }, {
  156. key: "deactivate",
  157. value: function () {
  158. var _deactivate = (0, _asyncToGenerator2.default)( /*#__PURE__*/_regenerator.default.mark(function _callee2() {
  159. return _regenerator.default.wrap(function (_context6) {
  160. while (1) {
  161. switch (_context6.prev = _context6.next) {
  162. case 0:
  163. this.unsubscribeToEvents(this.provider);
  164. this.account = null;
  165. this.chainId = null;
  166. case 3:
  167. case "end":
  168. return _context6.stop();
  169. }
  170. }
  171. }, _callee2, this);
  172. }));
  173. return function () {
  174. return _deactivate.apply(this, arguments);
  175. };
  176. }()
  177. }]);
  178. return AbstractWeb3Connector;
  179. }(_events.default);
  180. var _default = AbstractWeb3Connector;
  181. exports.default = _default;