You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
92 lines
2.6 KiB
92 lines
2.6 KiB
class StandardProvider {
|
|
_isConnected
|
|
_provider
|
|
|
|
constructor (provider) {
|
|
this._provider = provider
|
|
this._onMessage('ethereumpingerror', this._onClose.bind(this))
|
|
this._onMessage('ethereumpingsuccess', this._onConnect.bind(this))
|
|
window.addEventListener('load', () => {
|
|
this._subscribe()
|
|
this._ping()
|
|
})
|
|
}
|
|
|
|
_onMessage (type, handler) {
|
|
window.addEventListener('message', function ({ data }) {
|
|
if (!data || data.type !== type) return
|
|
handler.apply(this, arguments)
|
|
})
|
|
}
|
|
|
|
_onClose () {
|
|
if (this._isConnected === undefined || this._isConnected) {
|
|
this._provider.emit('close', {
|
|
code: 1011,
|
|
reason: 'Network connection error',
|
|
})
|
|
}
|
|
this._isConnected = false
|
|
}
|
|
|
|
_onConnect () {
|
|
!this._isConnected && this._provider.emit('connect')
|
|
this._isConnected = true
|
|
}
|
|
|
|
async _ping () {
|
|
try {
|
|
await this.send('net_version')
|
|
window.postMessage({ type: 'ethereumpingsuccess' }, '*')
|
|
} catch (error) {
|
|
window.postMessage({ type: 'ethereumpingerror' }, '*')
|
|
}
|
|
}
|
|
|
|
_subscribe () {
|
|
this._provider.on('data', (error, { method, params }) => {
|
|
if (!error && method === 'eth_subscription') {
|
|
this._provider.emit('notification', params.result)
|
|
}
|
|
})
|
|
}
|
|
|
|
/**
|
|
* Initiate an RPC method call
|
|
*
|
|
* @param {string} method - RPC method name to call
|
|
* @param {string[]} params - Array of RPC method parameters
|
|
* @returns {Promise<*>} Promise resolving to the result if successful
|
|
*/
|
|
send (method, params = []) {
|
|
if (method === 'eth_requestAccounts') return this._provider.enable()
|
|
|
|
return new Promise((resolve, reject) => {
|
|
try {
|
|
this._provider.sendAsync({ method, params, beta: true }, (error, response) => {
|
|
error = error || response.error
|
|
error ? reject(error) : resolve(response)
|
|
})
|
|
} catch (error) {
|
|
reject(error)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Converts a legacy provider into an EIP-1193-compliant standard provider
|
|
* @param {Object} provider - Legacy provider to convert
|
|
* @returns {Object} Standard provider
|
|
*/
|
|
export default function createStandardProvider (provider) {
|
|
const standardProvider = new StandardProvider(provider)
|
|
const sendLegacy = provider.send
|
|
provider.send = (methodOrPayload, callbackOrArgs) => {
|
|
if (typeof methodOrPayload === 'string' && !callbackOrArgs || Array.isArray(callbackOrArgs)) {
|
|
return standardProvider.send(methodOrPayload, callbackOrArgs)
|
|
}
|
|
return sendLegacy.call(provider, methodOrPayload, callbackOrArgs)
|
|
}
|
|
return provider
|
|
}
|
|
|