1 | 'use strict';
|
2 |
|
3 | Object.defineProperty(exports, "__esModule", {
|
4 | value: true
|
5 | });
|
6 | exports.CryptoWorker = undefined;
|
7 |
|
8 | var _ramda = require('ramda');
|
9 |
|
10 | var _detectNode = require('detect-node');
|
11 |
|
12 | var _detectNode2 = _interopRequireDefault(_detectNode);
|
13 |
|
14 | var _defer = require('./util/defer');
|
15 |
|
16 | var _defer2 = _interopRequireDefault(_defer);
|
17 |
|
18 | var _smartTimeout = require('./util/smart-timeout');
|
19 |
|
20 | var _smartTimeout2 = _interopRequireDefault(_smartTimeout);
|
21 |
|
22 | var _bin = require('./bin');
|
23 |
|
24 | function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
|
25 |
|
26 | const convertIfArray = (0, _ramda.when)((0, _ramda.is)(Array), _bin.convertToUint8Array);
|
27 | let webWorker = !_detectNode2.default;
|
28 | let taskID = 0;
|
29 | const awaiting = {};
|
30 | const webCrypto = _detectNode2.default ? false
|
31 |
|
32 | : window.crypto.subtle || window.crypto.webkitSubtle
|
33 |
|
34 | || window.msCrypto && window.msCrypto.subtle;
|
35 | const useWebCrypto = webCrypto && !!webCrypto.digest;
|
36 | let useSha1Crypto = useWebCrypto;
|
37 | let useSha256Crypto = useWebCrypto;
|
38 | const finalizeTask = (taskID, result) => {
|
39 | const deferred = awaiting[taskID];
|
40 | if (deferred) {
|
41 |
|
42 | deferred.resolve(result);
|
43 | delete awaiting[taskID];
|
44 | }
|
45 | };
|
46 |
|
47 | const isCryptoTask = (0, _ramda.both)((0, _ramda.has)('taskID'), (0, _ramda.has)('result'));
|
48 |
|
49 |
|
50 | const workerEnable = !_detectNode2.default && window.Worker;
|
51 | if (workerEnable) {
|
52 | require('worker-loader!./worker.js');
|
53 | const tmpWorker = new Worker('./bundle/hash.worker.js');
|
54 |
|
55 |
|
56 |
|
57 | tmpWorker.onmessage = e => {
|
58 | if (e.data === 'ready') {
|
59 | console.info('CW ready');
|
60 | } else if (!isCryptoTask(e.data)) {
|
61 | console.info('Not crypto task', e, e.data);
|
62 | return e;
|
63 | } else return webWorker ? finalizeTask(e.data.taskID, e.data.result) : webWorker = tmpWorker;
|
64 | };
|
65 |
|
66 | tmpWorker.onerror = function (error) {
|
67 | console.error('CW error', error, error.stack);
|
68 | webWorker = false;
|
69 | };
|
70 | tmpWorker.postMessage('b');
|
71 | webWorker = tmpWorker;
|
72 | }
|
73 |
|
74 | const performTaskWorker = (task, params, embed) => {
|
75 |
|
76 | const deferred = (0, _defer2.default)();
|
77 |
|
78 | awaiting[taskID] = deferred;
|
79 |
|
80 | params.task = task;
|
81 | params.taskID = taskID;(embed || webWorker).postMessage(params);
|
82 |
|
83 | taskID++;
|
84 |
|
85 | return deferred.promise;
|
86 | };
|
87 |
|
88 | const sha1Hash = bytes => {
|
89 | if (useSha1Crypto) {
|
90 |
|
91 |
|
92 | const bytesTyped = convertIfArray(bytes);
|
93 |
|
94 | return webCrypto.digest({ name: 'SHA-1' }, bytesTyped).then(digest =>
|
95 |
|
96 | digest, e => {
|
97 | console.error('Crypto digest error', e);
|
98 | useSha1Crypto = false;
|
99 | return (0, _bin.sha1HashSync)(bytes);
|
100 | });
|
101 | }
|
102 | return _smartTimeout2.default.immediate(_bin.sha1HashSync, bytes);
|
103 | };
|
104 |
|
105 | const sha256Hash = bytes => {
|
106 | if (useSha256Crypto) {
|
107 | const bytesTyped = convertIfArray(bytes);
|
108 |
|
109 | return webCrypto.digest({ name: 'SHA-256' }, bytesTyped).then(_ramda.identity
|
110 |
|
111 | , e => {
|
112 | console.error('Crypto digest error', e);
|
113 | useSha256Crypto = false;
|
114 | return (0, _bin.sha256HashSync)(bytes);
|
115 | });
|
116 | }
|
117 | return _smartTimeout2.default.immediate(_bin.sha256HashSync, bytes);
|
118 | };
|
119 |
|
120 | const aesEncrypt = (bytes, keyBytes, ivBytes) => _smartTimeout2.default.immediate(() => (0, _bin.convertToArrayBuffer)((0, _bin.aesEncryptSync)(bytes, keyBytes, ivBytes)));
|
121 |
|
122 | const aesDecrypt = (encryptedBytes, keyBytes, ivBytes) => _smartTimeout2.default.immediate(() => (0, _bin.convertToArrayBuffer)((0, _bin.aesDecryptSync)(encryptedBytes, keyBytes, ivBytes)));
|
123 |
|
124 | const factorize = bytes => {
|
125 | bytes = (0, _bin.convertToByteArray)(bytes);
|
126 | return webWorker ? performTaskWorker('factorize', { bytes }) : _smartTimeout2.default.immediate(_bin.pqPrimeFactorization, bytes);
|
127 | };
|
128 |
|
129 | const modPow = (x, y, m) => webWorker ? performTaskWorker('mod-pow', {
|
130 | x,
|
131 | y,
|
132 | m
|
133 | }) : _smartTimeout2.default.immediate(_bin.bytesModPow, x, y, m);
|
134 |
|
135 | const CryptoWorker = exports.CryptoWorker = {
|
136 | sha1Hash,
|
137 | sha256Hash,
|
138 | aesEncrypt,
|
139 | aesDecrypt,
|
140 | factorize,
|
141 | modPow
|
142 | };
|
143 |
|
144 | exports.default = CryptoWorker;
|
145 |
|
\ | No newline at end of file |