148 lines
3.7 KiB
JavaScript
148 lines
3.7 KiB
JavaScript
// Copyright 2015, 2016 Ethcore (UK) Ltd.
|
|
// This file is part of Parity.
|
|
|
|
// Parity is free software: you can redistribute it and/or modify
|
|
// it under the terms of the GNU General Public License as published by
|
|
// the Free Software Foundation, either version 3 of the License, or
|
|
// (at your option) any later version.
|
|
|
|
// Parity 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 General Public License for more details.
|
|
|
|
// You should have received a copy of the GNU General Public License
|
|
// along with Parity. If not, see <http://www.gnu.org/licenses/>.
|
|
|
|
import Api from './api';
|
|
|
|
const sysuiToken = window.localStorage.getItem('sysuiToken');
|
|
|
|
export default class SecureApi extends Api {
|
|
constructor (url) {
|
|
super(new Api.Transport.Ws(url, sysuiToken));
|
|
|
|
this._isConnecting = true;
|
|
this._connectState = 0;
|
|
this._needsToken = false;
|
|
this._dappsPort = 8080;
|
|
this._signerPort = 8180;
|
|
|
|
console.log('SecureApi:constructor', sysuiToken);
|
|
|
|
this._followConnection();
|
|
}
|
|
|
|
setToken = () => {
|
|
window.localStorage.setItem('sysuiToken', this._transport.token);
|
|
console.log('SecureApi:setToken', this._transport.token);
|
|
}
|
|
|
|
_followConnection = () => {
|
|
const nextTick = () => {
|
|
setTimeout(() => this._followConnection(), 250);
|
|
};
|
|
const setManual = () => {
|
|
this._connectState = 100;
|
|
this._needsToken = true;
|
|
this._isConnecting = false;
|
|
};
|
|
const lastError = this._transport.lastError;
|
|
const isConnected = this._transport.isConnected;
|
|
|
|
switch (this._connectState) {
|
|
// token = <passed via constructor>
|
|
case 0:
|
|
if (isConnected) {
|
|
return this.connectSuccess();
|
|
} else if (lastError) {
|
|
this.updateToken('initial', 1);
|
|
}
|
|
break;
|
|
|
|
// token = 'initial'
|
|
case 1:
|
|
if (isConnected) {
|
|
this.signer
|
|
.generateAuthorizationToken()
|
|
.then((token) => {
|
|
this.updateToken(token, 2);
|
|
})
|
|
.catch((error) => {
|
|
console.error('SecureApi:generateAuthorizationToken', error);
|
|
setManual();
|
|
});
|
|
return;
|
|
} else if (lastError) {
|
|
return setManual();
|
|
}
|
|
break;
|
|
|
|
// token = <personal_generateAuthorizationToken>
|
|
case 2:
|
|
if (isConnected) {
|
|
return this.connectSuccess();
|
|
} else if (lastError) {
|
|
return setManual();
|
|
}
|
|
break;
|
|
}
|
|
|
|
nextTick();
|
|
}
|
|
|
|
connectSuccess () {
|
|
this._isConnecting = false;
|
|
this._needsToken = false;
|
|
|
|
this.setToken();
|
|
|
|
Promise
|
|
.all([
|
|
this.parity.dappsPort(),
|
|
this.parity.signerPort()
|
|
])
|
|
.then(([dappsPort, signerPort]) => {
|
|
this._dappsPort = dappsPort.toNumber();
|
|
this._signerPort = signerPort.toNumber();
|
|
});
|
|
|
|
console.log('SecureApi:connectSuccess', this._transport.token);
|
|
}
|
|
|
|
updateToken (token, connectState) {
|
|
this._connectState = connectState;
|
|
this._transport.updateToken(token.replace(/[^a-zA-Z0-9]/g, ''));
|
|
this._followConnection();
|
|
console.log('SecureApi:updateToken', this._transport.token, connectState);
|
|
}
|
|
|
|
get dappsPort () {
|
|
return this._dappsPort;
|
|
}
|
|
|
|
get dappsUrl () {
|
|
return `http://${window.location.hostname}:${this._dappsPort}`;
|
|
}
|
|
|
|
get signerPort () {
|
|
return this._signerPort;
|
|
}
|
|
|
|
get isConnecting () {
|
|
return this._isConnecting;
|
|
}
|
|
|
|
get isConnected () {
|
|
return this._transport.isConnected;
|
|
}
|
|
|
|
get needsToken () {
|
|
return this._needsToken;
|
|
}
|
|
|
|
get secureToken () {
|
|
return this._transport.token;
|
|
}
|
|
}
|