browser/components/translation/LanguageDetector.jsm

changeset 0
6474c204b198
     1.1 --- /dev/null	Thu Jan 01 00:00:00 1970 +0000
     1.2 +++ b/browser/components/translation/LanguageDetector.jsm	Wed Dec 31 06:09:35 2014 +0100
     1.3 @@ -0,0 +1,55 @@
     1.4 +/* This Source Code Form is subject to the terms of the Mozilla Public
     1.5 + * License, v. 2.0. If a copy of the MPL was not distributed with this file,
     1.6 + * You can obtain one at http://mozilla.org/MPL/2.0/. */
     1.7 +
     1.8 +"use strict";
     1.9 +
    1.10 +this.EXPORTED_SYMBOLS = ["LanguageDetector"];
    1.11 +
    1.12 +Components.utils.import("resource://gre/modules/XPCOMUtils.jsm");
    1.13 +
    1.14 +XPCOMUtils.defineLazyModuleGetter(this, "Promise",
    1.15 +                                  "resource://gre/modules/Promise.jsm");
    1.16 +
    1.17 +const WORKER_URL = "resource:///modules/translation/cld-worker.js";
    1.18 +
    1.19 +let detectionQueue = [];
    1.20 +
    1.21 +let workerReady = false;
    1.22 +let pendingStrings = [];
    1.23 +
    1.24 +XPCOMUtils.defineLazyGetter(this, "worker", () => {
    1.25 +  let worker = new Worker(WORKER_URL);
    1.26 +  worker.onmessage = function(aMsg) {
    1.27 +    if (aMsg.data == "ready") {
    1.28 +      workerReady = true;
    1.29 +      for (let string of pendingStrings)
    1.30 +        worker.postMessage(string);
    1.31 +      pendingStrings = [];
    1.32 +    }
    1.33 +    else
    1.34 +      detectionQueue.shift().resolve(aMsg.data);
    1.35 +  }
    1.36 +  return worker;
    1.37 +});
    1.38 +
    1.39 +this.LanguageDetector = {
    1.40 +  /**
    1.41 +   * Detect the language of a given string
    1.42 +   *
    1.43 +   * @returns {Promise}
    1.44 +   * @resolves When detection is finished, with a object containing
    1.45 +   * these fields:
    1.46 +   *  - 'language' (string with a language code)
    1.47 +   *  - 'confident' (boolean).
    1.48 +   */
    1.49 +  detectLanguage: function(aString) {
    1.50 +    let deferred = Promise.defer();
    1.51 +    detectionQueue.push(deferred);
    1.52 +    if (worker && workerReady)
    1.53 +      worker.postMessage(aString);
    1.54 +    else
    1.55 +      pendingStrings.push(aString);
    1.56 +    return deferred.promise;
    1.57 +  }
    1.58 +};

mercurial