-
Notifications
You must be signed in to change notification settings - Fork 4.9k
/
ProviderResolver.js
108 lines (92 loc) · 3.28 KB
/
ProviderResolver.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
/*
This file is part of web3.js.
web3.js is free software: you can redistribute it and/or modify
it under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.
web3.js is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
GNU Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public License
along with web3.js. If not, see <http://www.gnu.org/licenses/>.
*/
/**
* @file ProviderResolver.js
* @authors: Samuel Furter <samuel@ethereum.org>
* @date 2018
*/
import isFunction from 'lodash/isFunction';
import isObject from 'lodash/isObject';
const global =
(function() {
return this || (typeof self === 'object' && self);
// eslint-disable-next-line no-new-func
})() || new Function('return this')();
export default class ProviderResolver {
/**
* @param {ProvidersModuleFactory} providersModuleFactory
*
* @constructor
*/
constructor(providersModuleFactory) {
this.providersModuleFactory = providersModuleFactory;
}
/**
* Resolves the correct provider with his adapter
*
* @method resolve
*
* @param {AbstractSocketProvider|HttpProvider|CustomProvider} provider
* @param {Net} net
*
* @returns {AbstractSocketProvider|HttpProvider|CustomProvider}
*/
resolve(provider, net) {
if (!provider) {
return provider;
}
if (typeof provider === 'string') {
// HTTP
if (/^http(s)?:\/\//i.test(provider)) {
return this.providersModuleFactory.createHttpProvider(provider);
}
// WS
if (/^ws(s)?:\/\//i.test(provider)) {
return this.providersModuleFactory.createWebsocketProvider(provider);
}
// IPC
if (provider && isObject(net) && isFunction(net.connect)) {
return this.providersModuleFactory.createIpcProvider(provider, net);
}
}
if (provider.sendPayload && provider.subscribe) {
return provider;
}
if (provider.host === 'Web3EthereumProvider') {
return provider;
}
if (typeof global.mist !== 'undefined' && provider.constructor.name === 'EthereumProvider') {
return this.providersModuleFactory.createMistEthereumProvider(provider);
}
if (provider.isEIP1193) {
return this.providersModuleFactory.createWeb3EthereumProvider(provider);
}
if (this.isMetamaskInpageProvider(provider)) {
return this.providersModuleFactory.createMetamaskProvider(provider);
}
return this.providersModuleFactory.createCustomProvider(provider);
}
/**
* Checks if the given provider is the MetamaskInpageProvider
*
* @method isMetamaskInpageProvider
*
* @param {Object} provider
*
* @returns {Boolean}
*/
isMetamaskInpageProvider(provider) {
return provider.constructor.name === 'MetamaskInpageProvider';
}
}