mirror of https://github.com/BTCPrivate/copay.git
358 lines
10 KiB
JavaScript
358 lines
10 KiB
JavaScript
'use strict';
|
|
var bitcore = require('bitcore');
|
|
|
|
angular.module('copayApp.services')
|
|
.factory('controllerUtils', function($rootScope, $sce, $location, $filter, notification, $timeout, uriHandler, rateService) {
|
|
var root = {};
|
|
|
|
|
|
root.redirIfNotComplete = function() {
|
|
var w = $rootScope.wallet;
|
|
if (w) {
|
|
if (!w.isReady()) {
|
|
$location.path('/copayers');
|
|
}
|
|
} else {
|
|
$location.path('/');
|
|
}
|
|
};
|
|
|
|
|
|
root.redirIfLogged = function() {
|
|
var w = $rootScope.wallet;
|
|
if (w) {
|
|
if (!w.isReady()) {
|
|
$location.path('/copayers');
|
|
} else {
|
|
$location.path('receive');
|
|
}
|
|
}
|
|
};
|
|
|
|
root.logout = function() {
|
|
if ($rootScope.iden)
|
|
$rootScope.iden.close();
|
|
|
|
delete $rootScope['wallet'];
|
|
delete $rootScope['iden'];
|
|
|
|
// Clear rootScope
|
|
for (var i in $rootScope) {
|
|
if (i.charAt(0) != '$') {
|
|
delete $rootScope[i];
|
|
}
|
|
}
|
|
|
|
$location.path('/');
|
|
};
|
|
|
|
root.onError = function(scope) {
|
|
if (scope) scope.loading = false;
|
|
root.logout();
|
|
}
|
|
|
|
root.onErrorDigest = function(scope, msg) {
|
|
root.onError(scope);
|
|
if (msg) {
|
|
notification.error('Error', msg);
|
|
}
|
|
};
|
|
|
|
|
|
root.isFocusedWallet = function(wid) {
|
|
return wid === $rootScope.wallet.getId();
|
|
};
|
|
|
|
root.installWalletHandlers = function($scope, w) {
|
|
w.removeAllListeners();
|
|
|
|
var wid = w.getId();
|
|
w.on('connectionError', function() {
|
|
if (root.isFocusedWallet(wid)) {
|
|
var message = "Could not connect to the Insight server. Check your settings and network configuration";
|
|
notification.error('Networking Error', message);
|
|
root.onErrorDigest($scope);
|
|
}
|
|
});
|
|
|
|
w.on('corrupt', function(peerId) {
|
|
if (root.isFocusedWallet(wid)) {
|
|
notification.error('Error', $filter('translate')('Received corrupt message from ') + peerId);
|
|
}
|
|
});
|
|
w.on('ready', function(myPeerID) {
|
|
$scope.loading = false;
|
|
$rootScope.wallet = w;
|
|
if ($rootScope.initialConnection) {
|
|
$rootScope.initialConnection = false;
|
|
if ($rootScope.pendingPayment) {
|
|
$location.path('send');
|
|
} else {
|
|
root.redirIfLogged();
|
|
}
|
|
}
|
|
});
|
|
|
|
w.on('newAddresses', function(dontDigest) {
|
|
if (root.isFocusedWallet(wid)) {
|
|
root.updateAddressList();
|
|
if (!dontDigest) {
|
|
$rootScope.$digest();
|
|
}
|
|
}
|
|
});
|
|
|
|
w.on('tx', function(address, isChange) {
|
|
if (root.isFocusedWallet(wid)) {
|
|
if (!isChange) {
|
|
notification.funds('Funds received!', address);
|
|
}
|
|
root.updateBalance(function() {
|
|
$rootScope.$digest();
|
|
});
|
|
}
|
|
});
|
|
|
|
w.on('balanceUpdated', function() {
|
|
if (root.isFocusedWallet(wid)) {
|
|
root.updateBalance(function() {
|
|
$rootScope.$digest();
|
|
});
|
|
}
|
|
});
|
|
|
|
w.on('insightReconnected', function() {
|
|
if (root.isFocusedWallet(wid)) {
|
|
$rootScope.reconnecting = false;
|
|
root.updateAddressList();
|
|
root.updateBalance(function() {
|
|
$rootScope.$digest();
|
|
});
|
|
}
|
|
});
|
|
|
|
w.on('insightError', function() {
|
|
if (root.isFocusedWallet(wid)) {
|
|
$rootScope.reconnecting = true;
|
|
$rootScope.$digest();
|
|
}
|
|
});
|
|
|
|
var updateTxsAndBalance = _.debounce(function() {
|
|
root.updateTxs();
|
|
root.updateBalance(function() {
|
|
$rootScope.$digest();
|
|
})
|
|
}, 3000);
|
|
|
|
w.on('txProposalsUpdated', function(dontDigest) {
|
|
if (root.isFocusedWallet(wid)) {
|
|
updateTxsAndBalance();
|
|
}
|
|
});
|
|
|
|
w.on('txProposalEvent', function(e) {
|
|
|
|
// TODO: add wallet name notification
|
|
var user = w.publicKeyRing.nicknameForCopayer(e.cId);
|
|
switch (e.type) {
|
|
case 'signed':
|
|
notification.info('Transaction Update', $filter('translate')('A transaction was signed by') + ' ' + user);
|
|
break;
|
|
case 'rejected':
|
|
notification.info('Transaction Update', $filter('translate')('A transaction was rejected by') + ' ' + user);
|
|
break;
|
|
case 'corrupt':
|
|
notification.error('Transaction Error', $filter('translate')('Received corrupt transaction from') + ' ' + user);
|
|
break;
|
|
}
|
|
});
|
|
w.on('addressBookUpdated', function(dontDigest) {
|
|
if (root.isFocusedWallet(wid)) {
|
|
if (!dontDigest) {
|
|
$rootScope.$digest();
|
|
}
|
|
}
|
|
});
|
|
w.on('connect', function(peerID) {
|
|
$rootScope.$digest();
|
|
});
|
|
w.on('close', root.onErrorDigest);
|
|
w.on('locked', root.onErrorDigest.bind(this));
|
|
|
|
};
|
|
|
|
root.setupGlobalVariables = function(iden) {
|
|
notification.enableHtml5Mode(); // for chrome: if support, enable it
|
|
uriHandler.register();
|
|
$rootScope.unitName = config.unitName;
|
|
$rootScope.txAlertCount = 0;
|
|
$rootScope.initialConnection = true;
|
|
$rootScope.reconnecting = false;
|
|
$rootScope.isCollapsed = true;
|
|
|
|
$rootScope.iden = iden;
|
|
|
|
// TODO
|
|
// $rootScope.$watch('txAlertCount', function(txAlertCount) {
|
|
// if (txAlertCount && txAlertCount > 0) {
|
|
//
|
|
// notification.info('New Transaction', ($rootScope.txAlertCount == 1) ? 'You have a pending transaction proposal' : $filter('translate')('You have') + ' ' + $rootScope.txAlertCount + ' ' + $filter('translate')('pending transaction proposals'), txAlertCount);
|
|
// }
|
|
// });
|
|
};
|
|
|
|
|
|
root.rebindWallets = function($scope, iden) {
|
|
_.each(iden.listWallets(), function(winfo) {
|
|
var w = iden.getOpenWallet(winfo.id);
|
|
preconditions.checkState(w);
|
|
root.installWalletHandlers($scope, w);
|
|
});
|
|
};
|
|
|
|
root.setFocusedWallet = function(w) {
|
|
if (!_.isObject(w) )
|
|
w = $rootScope.iden.getOpenWallet(w);
|
|
preconditions.checkState(w && _.isObject(w));
|
|
|
|
$rootScope.wallet = w;
|
|
root.updateAddressList();
|
|
root.redirIfLogged();
|
|
};
|
|
|
|
root.bindProfile = function($scope, iden, w) {
|
|
|
|
root.setupGlobalVariables(iden);
|
|
root.rebindWallets($scope, iden);
|
|
root.setFocusedWallet(w);
|
|
};
|
|
|
|
|
|
// On the focused wallet
|
|
root.updateAddressList = function(wid) {
|
|
|
|
if (!wid || root.isFocusedWallet(wid)) {
|
|
var w = $rootScope.wallet;
|
|
|
|
if (w && w.isReady()) {
|
|
$rootScope.addrInfos = w.getAddressesInfo();
|
|
}
|
|
}
|
|
};
|
|
|
|
root.updateBalance = function(cb) {
|
|
var w = $rootScope.wallet;
|
|
if (!w) return root.onErrorDigest();
|
|
if (!w.isReady()) return;
|
|
|
|
$rootScope.balanceByAddr = {};
|
|
$rootScope.updatingBalance = true;
|
|
|
|
w.getBalance(function(err, balanceSat, balanceByAddrSat, safeBalanceSat) {
|
|
if (err) throw err;
|
|
|
|
var satToUnit = 1 / w.settings.unitToSatoshi;
|
|
var COIN = bitcore.util.COIN;
|
|
|
|
$rootScope.totalBalance = balanceSat * satToUnit;
|
|
$rootScope.totalBalanceBTC = (balanceSat / COIN);
|
|
$rootScope.availableBalance = safeBalanceSat * satToUnit;
|
|
$rootScope.availableBalanceBTC = (safeBalanceSat / COIN);
|
|
|
|
$rootScope.lockedBalance = (balanceSat - safeBalanceSat) * satToUnit;
|
|
$rootScope.lockedBalanceBTC = (balanceSat - safeBalanceSat) / COIN;
|
|
|
|
var balanceByAddr = {};
|
|
for (var ii in balanceByAddrSat) {
|
|
balanceByAddr[ii] = balanceByAddrSat[ii] * satToUnit;
|
|
}
|
|
$rootScope.balanceByAddr = balanceByAddr;
|
|
root.updateAddressList();
|
|
$rootScope.updatingBalance = false;
|
|
|
|
rateService.whenAvailable(function() {
|
|
$rootScope.totalBalanceAlternative = rateService.toFiat(balanceSat, w.settings.alternativeIsoCode);
|
|
$rootScope.alternativeIsoCode = w.settings.alternativeIsoCode;
|
|
$rootScope.lockedBalanceAlternative = rateService.toFiat(balanceSat - safeBalanceSat, w.settings.alternativeIsoCode);
|
|
$rootScope.alternativeConversionRate = rateService.toFiat(100000000, w.settings.alternativeIsoCode);
|
|
return cb ? cb() : null;
|
|
});
|
|
});
|
|
};
|
|
|
|
root.updateTxs = function(opts) {
|
|
var w = $rootScope.wallet;
|
|
if (!w) return;
|
|
opts = opts || $rootScope.txsOpts || {};
|
|
|
|
var satToUnit = 1 / w.settings.unitToSatoshi;
|
|
var myCopayerId = w.getMyCopayerId();
|
|
var pendingForUs = 0;
|
|
var inT = w.getTxProposals().sort(function(t1, t2) {
|
|
return t2.createdTs - t1.createdTs
|
|
});
|
|
var txs = [];
|
|
|
|
inT.forEach(function(i, index) {
|
|
if (opts.skip && (index < opts.skip[0] || index >= opts.skip[1])) {
|
|
return txs.push(null);
|
|
}
|
|
|
|
if (i.isPending && myCopayerId != i.creator && !i.rejectedByUs && !i.signedByUs) {
|
|
pendingForUs++;
|
|
}
|
|
|
|
if (!!opts.pending == !!i.isPending) {
|
|
var tx = i.builder.build();
|
|
var outs = [];
|
|
tx.outs.forEach(function(o) {
|
|
var addr = bitcore.Address.fromScriptPubKey(o.getScript(), w.getNetworkName())[0].toString();
|
|
if (!w.addressIsOwn(addr, {
|
|
excludeMain: true
|
|
})) {
|
|
outs.push({
|
|
address: addr,
|
|
value: bitcore.util.valueToBigInt(o.getValue()) * satToUnit,
|
|
});
|
|
}
|
|
});
|
|
// extra fields
|
|
i.outs = outs;
|
|
i.fee = i.builder.feeSat * satToUnit;
|
|
i.missingSignatures = tx.countInputMissingSignatures(0);
|
|
i.actionList = getActionList(i.peerActions);
|
|
txs.push(i);
|
|
}
|
|
});
|
|
|
|
// Disabling this as discrepancies in local time on copayer machines is causing
|
|
// valid TXPs to get removed
|
|
//w.removeTxWithSpentInputs();
|
|
|
|
$rootScope.txs = txs;
|
|
$rootScope.txsOpts = opts;
|
|
if ($rootScope.pendingTxCount < pendingForUs) {
|
|
$rootScope.txAlertCount = pendingForUs;
|
|
}
|
|
$rootScope.pendingTxCount = pendingForUs;
|
|
};
|
|
|
|
function getActionList(actions) {
|
|
var peers = Object.keys(actions).map(function(i) {
|
|
return {
|
|
cId: i,
|
|
actions: actions[i]
|
|
}
|
|
});
|
|
|
|
return peers.sort(function(a, b) {
|
|
return !!b.actions.create - !!a.actions.create;
|
|
});
|
|
}
|
|
|
|
|
|
|
|
return root;
|
|
});
|