aboutsummaryrefslogtreecommitdiffstats
path: root/app/scripts/controllers
diff options
context:
space:
mode:
authorkumavis <kumavis@users.noreply.github.com>2017-09-28 06:56:23 +0800
committerGitHub <noreply@github.com>2017-09-28 06:56:23 +0800
commitecf909e140b2fc99afbd15f6f0882dd17e3ecb88 (patch)
tree7bcbb40e5d99c1ba3fd72916fdbfe5f61881958c /app/scripts/controllers
parentfc17d4511d195c1f18e4f84d8eb77c666fe13c70 (diff)
parent06b5dd2096b6bfcdf7d9ebf7c9bb1e40c8aed2e0 (diff)
downloadtangerine-wallet-browser-ecf909e140b2fc99afbd15f6f0882dd17e3ecb88.tar.gz
tangerine-wallet-browser-ecf909e140b2fc99afbd15f6f0882dd17e3ecb88.tar.zst
tangerine-wallet-browser-ecf909e140b2fc99afbd15f6f0882dd17e3ecb88.zip
Merge pull request #2194 from MetaMask/network-controller-refactor
Network controller refactor
Diffstat (limited to 'app/scripts/controllers')
-rw-r--r--app/scripts/controllers/network.js64
1 files changed, 33 insertions, 31 deletions
diff --git a/app/scripts/controllers/network.js b/app/scripts/controllers/network.js
index dc9978043..2a17cdae8 100644
--- a/app/scripts/controllers/network.js
+++ b/app/scripts/controllers/network.js
@@ -11,52 +11,36 @@ const DEFAULT_RPC = RPC_ADDRESS_LIST['rinkeby']
module.exports = class NetworkController extends EventEmitter {
constructor (config) {
super()
- this.networkStore = new ObservableStore('loading')
config.provider.rpcTarget = this.getRpcAddressForType(config.provider.type, config.provider)
+ this.networkStore = new ObservableStore('loading')
this.providerStore = new ObservableStore(config.provider)
this.store = new ComposedStore({ provider: this.providerStore, network: this.networkStore })
- this._providerListeners = {}
+ this._proxy = createEventEmitterProxy()
this.on('networkDidChange', this.lookupNetwork)
- this.providerStore.subscribe((state) => this.switchNetwork({rpcUrl: state.rpcTarget}))
- }
-
- get provider () {
- return this._proxy
- }
-
- set provider (provider) {
- this._provider = provider
+ this.providerStore.subscribe((state) => this.switchNetwork({ rpcUrl: state.rpcTarget }))
}
initializeProvider (opts, providerContructor = MetaMaskProvider) {
- this.providerInit = opts
- this._provider = providerContructor(opts)
- this._proxy = createEventEmitterProxy(this._provider)
- this.provider._blockTracker = createEventEmitterProxy(this._provider._blockTracker)
- this.provider.on('block', this._logBlock.bind(this))
- this.provider.on('error', this.verifyNetwork.bind(this))
- this.ethQuery = new EthQuery(this.provider)
+ this._baseProviderParams = opts
+ const provider = providerContructor(opts)
+ this._setProvider(provider)
+ this._proxy.on('block', this._logBlock.bind(this))
+ this._proxy.on('error', this.verifyNetwork.bind(this))
+ this.ethQuery = new EthQuery(this._proxy)
this.lookupNetwork()
- return this.provider
+ return this._proxy
}
- switchNetwork (providerInit) {
+ switchNetwork (opts) {
this.setNetworkState('loading')
- const newInit = extend(this.providerInit, providerInit)
- this.providerInit = newInit
-
- this._provider.removeAllListeners()
- this._provider.stop()
- this._provider = MetaMaskProvider(newInit)
- // apply the listners created by other controllers
- const blockTrackerHandlers = this.provider._blockTracker.proxyEventHandlers
- this.provider.setTarget(this._provider)
- this.provider._blockTracker = createEventEmitterProxy(this._provider._blockTracker, blockTrackerHandlers)
+ const providerParams = extend(this._baseProviderParams, opts)
+ this._baseProviderParams = providerParams
+ const provider = MetaMaskProvider(providerParams)
+ this._setProvider(provider)
this.emit('networkDidChange')
}
-
verifyNetwork () {
// Check network when restoring connectivity:
if (this.isNetworkLoading()) this.lookupNetwork()
@@ -110,6 +94,24 @@ module.exports = class NetworkController extends EventEmitter {
return provider && provider.rpcTarget ? provider.rpcTarget : DEFAULT_RPC
}
+ _setProvider (provider) {
+ // collect old block tracker events
+ const oldProvider = this._provider
+ let blockTrackerHandlers
+ if (oldProvider) {
+ // capture old block handlers
+ blockTrackerHandlers = oldProvider._blockTracker.proxyEventHandlers
+ // tear down
+ oldProvider.removeAllListeners()
+ oldProvider.stop()
+ }
+ // override block tracler
+ provider._blockTracker = createEventEmitterProxy(provider._blockTracker, blockTrackerHandlers)
+ // set as new provider
+ this._provider = provider
+ this._proxy.setTarget(provider)
+ }
+
_logBlock (block) {
log.info(`BLOCK CHANGED: #${block.number.toString('hex')} 0x${block.hash.toString('hex')}`)
this.verifyNetwork()