mirror of
https://github.com/kremalicious/metamask-extension.git
synced 2024-12-23 09:52:26 +01:00
inpage-provider - remove createSyncProvider, just fail
This commit is contained in:
parent
c48b60d7a6
commit
3417c421c8
@ -1,9 +1,7 @@
|
|||||||
const HttpProvider = require('web3/lib/web3/httpprovider')
|
|
||||||
const Streams = require('mississippi')
|
const Streams = require('mississippi')
|
||||||
const ObjectMultiplex = require('./obj-multiplex')
|
const ObjectMultiplex = require('./obj-multiplex')
|
||||||
const StreamProvider = require('web3-stream-provider')
|
const StreamProvider = require('web3-stream-provider')
|
||||||
const RemoteStore = require('./remote-store.js').RemoteStore
|
const RemoteStore = require('./remote-store.js').RemoteStore
|
||||||
const MetamaskConfig = require('../config.js')
|
|
||||||
|
|
||||||
module.exports = MetamaskInpageProvider
|
module.exports = MetamaskInpageProvider
|
||||||
|
|
||||||
@ -27,13 +25,6 @@ function MetamaskInpageProvider (connectionStream) {
|
|||||||
})
|
})
|
||||||
self.publicConfigStore = publicConfigStore
|
self.publicConfigStore = publicConfigStore
|
||||||
|
|
||||||
// connect to sync provider
|
|
||||||
self.syncProvider = createSyncProvider(publicConfigStore.get('provider'))
|
|
||||||
// subscribe to publicConfig to update the syncProvider on change
|
|
||||||
publicConfigStore.subscribe(function (state) {
|
|
||||||
self.syncProvider = createSyncProvider(state.provider)
|
|
||||||
})
|
|
||||||
|
|
||||||
// connect to async provider
|
// connect to async provider
|
||||||
var asyncProvider = new StreamProvider()
|
var asyncProvider = new StreamProvider()
|
||||||
Streams.pipe(asyncProvider, multiStream.createStream('provider'), asyncProvider, function (err) {
|
Streams.pipe(asyncProvider, multiStream.createStream('provider'), asyncProvider, function (err) {
|
||||||
@ -65,9 +56,10 @@ MetamaskInpageProvider.prototype.send = function (payload) {
|
|||||||
result = selectedAddress || '0x0000000000000000000000000000000000000000'
|
result = selectedAddress || '0x0000000000000000000000000000000000000000'
|
||||||
break
|
break
|
||||||
|
|
||||||
// fallback to normal rpc
|
// throw not-supported Error
|
||||||
default:
|
default:
|
||||||
return self.syncProvider.send(payload)
|
var message = 'The MetaMask Web3 object does not support synchronous methods. See https://github.com/MetaMask/faq#all-async---think-of-metamask-as-a-light-client for details.'
|
||||||
|
throw new Error(message)
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -89,35 +81,6 @@ MetamaskInpageProvider.prototype.isConnected = function () {
|
|||||||
|
|
||||||
// util
|
// util
|
||||||
|
|
||||||
function createSyncProvider (providerConfig) {
|
|
||||||
providerConfig = providerConfig || {}
|
|
||||||
let syncProviderUrl
|
|
||||||
|
|
||||||
if (providerConfig.rpcTarget) {
|
|
||||||
syncProviderUrl = providerConfig.rpcTarget
|
|
||||||
} else {
|
|
||||||
switch (providerConfig.type) {
|
|
||||||
case 'testnet':
|
|
||||||
syncProviderUrl = MetamaskConfig.network.testnet
|
|
||||||
break
|
|
||||||
case 'mainnet':
|
|
||||||
syncProviderUrl = MetamaskConfig.network.mainnet
|
|
||||||
break
|
|
||||||
default:
|
|
||||||
syncProviderUrl = MetamaskConfig.network.default
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
const provider = new HttpProvider(syncProviderUrl)
|
|
||||||
// Stubbing out the send method to throw on sync methods:
|
|
||||||
provider.send = function() {
|
|
||||||
var message = 'The MetaMask Web3 object does not support synchronous methods. See https://github.com/MetaMask/faq#all-async---think-of-metamask-as-a-light-client for details.'
|
|
||||||
throw new Error(message)
|
|
||||||
}
|
|
||||||
|
|
||||||
return provider
|
|
||||||
}
|
|
||||||
|
|
||||||
function remoteStoreWithLocalStorageCache (storageKey) {
|
function remoteStoreWithLocalStorageCache (storageKey) {
|
||||||
// read local cache
|
// read local cache
|
||||||
var initState = JSON.parse(localStorage[storageKey] || '{}')
|
var initState = JSON.parse(localStorage[storageKey] || '{}')
|
||||||
|
Loading…
x
Reference in New Issue
Block a user