mirror of
https://github.com/oxen-io/session-desktop.git
synced 2023-12-14 02:12:57 +01:00
remove unused worker
This commit is contained in:
parent
1d5d098b06
commit
874e3f863b
4 changed files with 1 additions and 78 deletions
|
@ -106,8 +106,6 @@
|
|||
|
||||
window.document.title = window.getTitle();
|
||||
|
||||
// start a background worker for ecc
|
||||
textsecure.startWorker('js/libsignal-protocol-worker.js');
|
||||
let messageReceiver;
|
||||
Whisper.events = _.clone(Backbone.Events);
|
||||
Whisper.events.isListenedTo = eventName =>
|
||||
|
|
|
@ -25316,77 +25316,6 @@
|
|||
|
||||
})();
|
||||
|
||||
; (function () {
|
||||
|
||||
'use strict';
|
||||
|
||||
// I am the...workee?
|
||||
var origCurve25519 = Internal.curve25519_async;
|
||||
|
||||
Internal.startWorker = function (url) {
|
||||
Internal.stopWorker(); // there can be only one
|
||||
|
||||
Internal.curve25519_async = new Curve25519Worker(url);
|
||||
Internal.Curve.async = Internal.wrapCurve25519(Internal.curve25519_async);
|
||||
libsignal.Curve.async = Internal.wrapCurve(Internal.Curve.async);
|
||||
};
|
||||
|
||||
Internal.stopWorker = function () {
|
||||
if (Internal.curve25519_async instanceof Curve25519Worker) {
|
||||
var worker = Internal.curve25519_async.worker;
|
||||
|
||||
Internal.curve25519_async = origCurve25519;
|
||||
Internal.Curve.async = Internal.wrapCurve25519(Internal.curve25519_async);
|
||||
libsignal.Curve.async = Internal.wrapCurve(Internal.Curve.async);
|
||||
|
||||
worker.terminate();
|
||||
}
|
||||
};
|
||||
|
||||
libsignal.worker = {
|
||||
startWorker: Internal.startWorker,
|
||||
stopWorker: Internal.stopWorker,
|
||||
};
|
||||
|
||||
function Curve25519Worker(url) {
|
||||
this.jobs = {};
|
||||
this.jobId = 0;
|
||||
this.worker = new Worker(url);
|
||||
this.worker.onmessage = function (e) {
|
||||
var job = this.jobs[e.data.id];
|
||||
if (e.data.error && typeof job.onerror === 'function') {
|
||||
job.onerror(new Error(e.data.error));
|
||||
} else if (typeof job.onsuccess === 'function') {
|
||||
job.onsuccess(e.data.result);
|
||||
}
|
||||
delete this.jobs[e.data.id];
|
||||
}.bind(this);
|
||||
}
|
||||
|
||||
Curve25519Worker.prototype = {
|
||||
constructor: Curve25519Worker,
|
||||
postMessage: function (methodName, args, onsuccess, onerror) {
|
||||
return new Promise(function (resolve, reject) {
|
||||
this.jobs[this.jobId] = { onsuccess: resolve, onerror: reject };
|
||||
this.worker.postMessage({ id: this.jobId, methodName: methodName, args: args });
|
||||
this.jobId++;
|
||||
}.bind(this));
|
||||
},
|
||||
keyPair: function (privKey) {
|
||||
return this.postMessage('keyPair', [privKey]);
|
||||
},
|
||||
sharedSecret: function (pubKey, privKey) {
|
||||
return this.postMessage('sharedSecret', [pubKey, privKey]);
|
||||
},
|
||||
sign: function (privKey, message) {
|
||||
return this.postMessage('sign', [privKey, message]);
|
||||
},
|
||||
verify: function (pubKey, message, sig) {
|
||||
return this.postMessage('verify', [pubKey, message, sig]);
|
||||
}
|
||||
};
|
||||
|
||||
})();
|
||||
|
||||
/*
|
||||
Copyright 2013 Daniel Wirtz <dcode@dcode.io>
|
||||
|
|
|
@ -1,11 +1,8 @@
|
|||
/* global window, textsecure, SignalProtocolStore, libsignal */
|
||||
/* global window, textsecure, SignalProtocolStore */
|
||||
|
||||
// eslint-disable-next-line func-names
|
||||
(function() {
|
||||
window.textsecure = window.textsecure || {};
|
||||
window.textsecure.storage = window.textsecure.storage || {};
|
||||
textsecure.storage.protocol = new SignalProtocolStore();
|
||||
|
||||
textsecure.startWorker = libsignal.worker.startWorker;
|
||||
textsecure.stopWorker = libsignal.worker.stopWorker;
|
||||
})();
|
||||
|
|
|
@ -63,7 +63,6 @@ const excludedFiles = [
|
|||
'^test/test.js',
|
||||
|
||||
// From libsignal-protocol-javascript project
|
||||
'^js/libsignal-protocol-worker.js',
|
||||
'^libtextsecure/libsignal-protocol.js',
|
||||
|
||||
// Test files
|
||||
|
|
Loading…
Reference in a new issue