This repository has been archived by the owner on Sep 5, 2020. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 2.1k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
14 changed files
with
1,495 additions
and
683 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,170 @@ | ||
|
|
||
| (function () { | ||
| var EventEmitter = window.EventEmitter; | ||
|
|
||
| var postMessage = function(payload) { | ||
| if(typeof payload === 'object') { | ||
| payload = JSON.stringify(payload); | ||
| } | ||
|
|
||
| window.postMessage(payload, (!location.origin || location.origin === "null" ) ? '*' : location.origin); | ||
| }; | ||
|
|
||
| // on events are: "connect", "data", "error", "end", "timeout" | ||
| // "data" will get notifications | ||
|
|
||
| function EthereumProvider() { | ||
| var _this = this; | ||
| // Call constructor of superclass to initialize superclass-derived members. | ||
| EventEmitter.call(this); | ||
|
|
||
| this.responseCallbacks = {}; | ||
|
|
||
| // fire the connect | ||
| this.connect(); | ||
| this._reconnectCheck(); | ||
|
|
||
|
|
||
|
|
||
| // Wait for response messages | ||
| window.addEventListener('message', function(event) { | ||
| var data; | ||
| try { | ||
| data = JSON.parse(event.data); | ||
| } catch(e){ | ||
| data = event.data; | ||
| } | ||
|
|
||
|
|
||
| if(typeof data !== 'object' || (data.message && !Object.prototype.hasOwnProperty.call(data.message, 'jsonrpc'))) { | ||
| return; | ||
| } | ||
|
|
||
| if (data.type === 'data') { | ||
|
|
||
| var id = null; | ||
| var result = data.message; | ||
|
|
||
| // get the id which matches the returned id | ||
| if(typeof result === 'object' && result.forEach && isFinite(result.length)) { | ||
| result.forEach(function(load){ | ||
| if(_this.responseCallbacks[load.id]) | ||
| id = load.id; | ||
| }); | ||
| } else { | ||
| id = result.id; | ||
| } | ||
|
|
||
| // notification | ||
| if(!id && result.method && result.method.indexOf('_subscription') !== -1) { | ||
| _this.listeners('data').forEach(function(callback){ | ||
| if(typeof callback === 'function') | ||
| callback(null, result); | ||
| }); | ||
|
|
||
| // fire the callback | ||
| } else if(_this.responseCallbacks[id]) { | ||
| _this.responseCallbacks[id](null, result); | ||
| delete _this.responseCallbacks[id]; | ||
| } | ||
|
|
||
| // make all other events listenable | ||
| } else if(data.type) { | ||
| _this.listeners(data.type).forEach(function(callback){ | ||
| if(typeof callback === 'function') | ||
| callback(null, data.message); | ||
| }); | ||
| } | ||
| }); | ||
| } | ||
|
|
||
| EthereumProvider.prototype = Object.create(EventEmitter.prototype); | ||
| EthereumProvider.prototype.constructor = EthereumProvider; | ||
|
|
||
| /** | ||
| Get the adds a callback to the responseCallbacks object, | ||
| which will be called if a response matching the response Id will arrive. | ||
| @method _addResponseCallback | ||
| */ | ||
| EthereumProvider.prototype._addResponseCallback = function(payload, callback) { | ||
| var id = payload.id || payload[0].id; | ||
| var method = payload.method || payload[0].method; | ||
|
|
||
| if (typeof callback !== 'function') { | ||
| throw new Error('No callback given, sync calls are not possible anymore in Mist. Please use only async calls.'); | ||
| } | ||
|
|
||
| this.responseCallbacks[id] = callback; | ||
| this.responseCallbacks[id].method = method; | ||
| }; | ||
|
|
||
|
|
||
| /** | ||
| Will watch for connection drops and tries to reconnect. | ||
| @method _reconnectCheck | ||
| */ | ||
| EthereumProvider.prototype._reconnectCheck = function() { | ||
| var _this = this; | ||
| var reconnectIntervalId; | ||
|
|
||
| this.on('end', function () { | ||
| reconnectIntervalId = setInterval(function () { | ||
| _this.connect(); | ||
| }, 500); | ||
| }); | ||
|
|
||
| this.on('connect', function () { | ||
| clearInterval(reconnectIntervalId); | ||
| }); | ||
| }; | ||
|
|
||
|
|
||
|
|
||
| /** | ||
| Will try to make a connection | ||
| @method connect | ||
| */ | ||
| EthereumProvider.prototype.connect = function(payload, callback) { | ||
| postMessage({ | ||
| type: 'create' | ||
| }); | ||
| }; | ||
|
|
||
| /** | ||
| Sends the request | ||
| @method send | ||
| @param {Object} payload example: {id: 1, jsonrpc: '2.0', 'method': 'eth_someMethod', params: []} | ||
| @param {Function} callback the callback to call | ||
| */ | ||
| EthereumProvider.prototype.send = function send(payload, callback) { | ||
|
|
||
| this._addResponseCallback(payload, callback); | ||
| postMessage({ | ||
| type: 'write', | ||
| message: payload | ||
| }, this.origin); | ||
| }; | ||
|
|
||
|
|
||
|
|
||
|
|
||
| delete window.EventEmitter; | ||
| window.ethereumProvider = new EthereumProvider(); | ||
|
|
||
|
|
||
| // For backwards compatibility of web3.currentProvider; | ||
| EthereumProvider.prototype.sendSync = function () { | ||
| return {jsonrpc: '2.0', error: {"code": -32603, message: 'Sync calls are not supported in Mist.'}}; | ||
| }; | ||
| EthereumProvider.prototype.sendAsync = EthereumProvider.prototype.send; | ||
| EthereumProvider.prototype.isConnected = function () { | ||
| return true; | ||
| }; | ||
| window.web3 = { | ||
| currentProvider: new EthereumProvider() | ||
| }; | ||
| })(); |
Oops, something went wrong.