Reconnect provisioning socket

If the provisioning socket closes, reconnect and generate a new qr code.
Fixes #371

// FREEBIE
pull/749/head
lilia 10 years ago
parent 47befdbf61
commit 9b12d8a978

@ -39073,10 +39073,11 @@ var TextSecureServer = (function() {
var registerKeys = this.server.registerKeys.bind(this.server); var registerKeys = this.server.registerKeys.bind(this.server);
var getSocket = this.server.getProvisioningSocket.bind(this.server); var getSocket = this.server.getProvisioningSocket.bind(this.server);
return textsecure.protocol_wrapper.createIdentityKeyRecvSocket().then(function(cryptoInfo) { return textsecure.protocol_wrapper.createIdentityKeyRecvSocket().then(function(cryptoInfo) {
return new Promise(function(resolve) { return new Promise(function(resolve, reject) {
var socket = getSocket(); var socket = getSocket();
socket.onclose = function(e) { socket.onclose = function(e) {
console.log('websocket closed', e.code); console.log('websocket closed', e.code);
reject(new Error('websocket closed'));
}; };
var wsr = new WebSocketResource(socket, { var wsr = new WebSocketResource(socket, {
keepalive: { path: '/v1/keepalive/provisioning' }, keepalive: { path: '/v1/keepalive/provisioning' },

@ -61,34 +61,40 @@
}); });
$(function() { $(function() {
$('#init-setup').show().addClass('in');
$('#status').text("Connecting...");
var accountManager = new bg.getAccountManager(); var accountManager = new bg.getAccountManager();
accountManager.registerSecondDevice(setProvisioningUrl, confirmNumber, incrementCounter).then(function() {
var launch = function() {
bg.openInbox();
bg.removeEventListener('textsecure:contactsync', launch);
clearTimeout(timeout);
window.close();
};
var timeout = setTimeout(launch, 60000);
bg.addEventListener('textsecure:contactsync', launch);
$('.progress-dialog .status').text('Syncing groups and contacts');
$('.progress-dialog .bar').addClass('progress-bar-striped active');
}).catch(function(e) { var init = function() {
if (e.name === 'HTTPError' && e.code == 411) { $('#init-setup').show().addClass('in');
$('.progress-dialog').hide(); $('#qr').html('');
$('.error-dialog').show(); $('#status').text("Connecting...");
$('.error-dialog .ok').click(function(e) {
chrome.runtime.reload(); accountManager.registerSecondDevice(setProvisioningUrl, confirmNumber, incrementCounter).then(function() {
}); var launch = function() {
} bg.openInbox();
else { bg.removeEventListener('textsecure:contactsync', launch);
throw e; clearTimeout(timeout);
} window.close();
}); };
var timeout = setTimeout(launch, 60000);
bg.addEventListener('textsecure:contactsync', launch);
$('.progress-dialog .status').text('Syncing groups and contacts');
$('.progress-dialog .bar').addClass('progress-bar-striped active');
}).catch(function(e) {
if (e.message === 'websocket closed') {
init();
} else if (e.name === 'HTTPError' && e.code == 411) {
$('.progress-dialog').hide();
$('.error-dialog').show();
$('.error-dialog .ok').click(function(e) {
chrome.runtime.reload();
});
}
else {
throw e;
}
});
};
init();
}); });
}); });
})(); })();

@ -36,10 +36,11 @@
var registerKeys = this.server.registerKeys.bind(this.server); var registerKeys = this.server.registerKeys.bind(this.server);
var getSocket = this.server.getProvisioningSocket.bind(this.server); var getSocket = this.server.getProvisioningSocket.bind(this.server);
return textsecure.protocol_wrapper.createIdentityKeyRecvSocket().then(function(cryptoInfo) { return textsecure.protocol_wrapper.createIdentityKeyRecvSocket().then(function(cryptoInfo) {
return new Promise(function(resolve) { return new Promise(function(resolve, reject) {
var socket = getSocket(); var socket = getSocket();
socket.onclose = function(e) { socket.onclose = function(e) {
console.log('websocket closed', e.code); console.log('websocket closed', e.code);
reject(new Error('websocket closed'));
}; };
var wsr = new WebSocketResource(socket, { var wsr = new WebSocketResource(socket, {
keepalive: { path: '/v1/keepalive/provisioning' }, keepalive: { path: '/v1/keepalive/provisioning' },

Loading…
Cancel
Save