aboutsummaryrefslogtreecommitdiff
path: root/ext/js/language/dictionary-importer-threaded.js
diff options
context:
space:
mode:
authortoasted-nutbread <toasted-nutbread@users.noreply.github.com>2021-07-31 14:46:09 -0400
committerGitHub <noreply@github.com>2021-07-31 14:46:09 -0400
commit8c4a50f68c9543c14cfe76abd2f6f42135b0e13d (patch)
tree9c7f252952a37b117f298b9b08a6c07418049c7f /ext/js/language/dictionary-importer-threaded.js
parent992c8bcf75b9477e1652cf2a458418e375903cc0 (diff)
DictionaryImporterThreaded (#1865)
* Create new classes for importing dictionaries from a separate thread * Use threaded importer * Update worker tests
Diffstat (limited to 'ext/js/language/dictionary-importer-threaded.js')
-rw-r--r--ext/js/language/dictionary-importer-threaded.js85
1 files changed, 85 insertions, 0 deletions
diff --git a/ext/js/language/dictionary-importer-threaded.js b/ext/js/language/dictionary-importer-threaded.js
new file mode 100644
index 00000000..a251906b
--- /dev/null
+++ b/ext/js/language/dictionary-importer-threaded.js
@@ -0,0 +1,85 @@
+/*
+ * Copyright (C) 2021 Yomichan Authors
+ *
+ * This program 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.
+ *
+ * This program 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 this program. If not, see <https://www.gnu.org/licenses/>.
+ */
+
+/* global
+ * DictionaryImporterMediaLoader
+ */
+
+class DictionaryImporterThreaded {
+ importDictionary(archiveContent, details, onProgress) {
+ return new Promise((resolve, reject) => {
+ const dictionaryImporterMediaLoader = new DictionaryImporterMediaLoader();
+ const worker = new Worker('/js/language/dictionary-importer-worker-main.js', {});
+ const onMessage = (e) => {
+ const {action, params} = e.data;
+ switch (action) {
+ case 'complete':
+ worker.removeEventListener('message', onMessage);
+ worker.terminate();
+ this._onComplete(params, resolve, reject);
+ break;
+ case 'progress':
+ this._onProgress(params, onProgress);
+ break;
+ case 'getImageResolution':
+ this._onGetImageResolution(params, worker, dictionaryImporterMediaLoader);
+ break;
+ }
+ };
+ worker.addEventListener('message', onMessage);
+ worker.postMessage({
+ action: 'import',
+ params: {details, archiveContent}
+ }, [archiveContent]);
+ });
+ }
+
+ // Private
+
+ _onComplete(params, resolve, reject) {
+ const {error} = params;
+ if (typeof error !== 'undefined') {
+ reject(deserializeError(error));
+ } else {
+ resolve(this._formatResult(params.result));
+ }
+ }
+
+ _formatResult(data) {
+ const {result, errors} = data;
+ const errors2 = errors.map((error) => deserializeError(error));
+ return {result, errors: errors2};
+ }
+
+ _onProgress(params, onProgress) {
+ if (typeof onProgress !== 'function') { return; }
+ const {args} = params;
+ onProgress(...args);
+ }
+
+ async _onGetImageResolution(params, worker, dictionaryImporterMediaLoader) {
+ const {id, mediaType, content} = params;
+ let response;
+ try {
+ const result = await dictionaryImporterMediaLoader.getImageResolution(mediaType, content);
+ response = {id, result};
+ } catch (e) {
+ response = {id, error: serializeError(e)};
+ }
+ worker.postMessage({action: 'getImageResolution.response', params: response});
+ }
+}