infocatcher / console_logger Goto Github PK

var file = "D:\\test";
appendAsync(file, "1: " + ts() + " Qwerty Йцукен\n", function() {
    appendAsync(file, "2: " + ts() + "\n", function() {
        appendAsync(file, "3: " + ts() + "\n");
    });
});

function appendAsync(file, data, callback) {
    function onFailure(err) {
        Components.utils.reportError(err);
        callback && callback("");
    }
    OS.File.open(file, { write: true, append: true }).then(
        function onSuccess(osFile) {
            var arr = new TextEncoder().encode(data); //~ todo: reuse TextEncoder
            osFile.write(arr).then(
                function onSuccess(bytesCount) {
                    osFile.close().then(
                        function onSuccess() {
                            callback && callback(data);
                        },
                        onFailure
                    ).then(null, onFailure);
                },
                onFailure
            ).then(null, onFailure);
        },
        onFailure
    ).then(null, onFailure);
}
function ts() {
    var d = new Date();
    var ms = d.getMilliseconds();
    return d.toLocaleFormat("%M:%S:") + "000".substr(String(ms).length) + ms;
}

var halt = 0;
var t = [0, 0, 0, 0];
var o1 = {
    observe: function(msg) {
        Services.tm.mainThread.dispatch({run: function() {
            t[2] = performance.now();
            stats();
        }}, Components.interfaces.nsIThread.DISPATCH_NORMAL);
        t[0] = performance.now();
        if(halt) {
            var stop = performance.now() + halt;
            while(performance.now() < stop);
        }
        Services.console.unregisterListener(this);
        stats();
    }
};
var o2 = {
    observe: function(msg) {
        Services.tm.mainThread.dispatch({run: function() {
            t[3] = performance.now();
            stats();
        }}, Components.interfaces.nsIThread.DISPATCH_NORMAL);
        t[1] = performance.now();
        var stop = performance.now() + 50;
        if(halt) {
            var stop = performance.now() + halt;
            while(performance.now() < stop);
        }
        Services.console.unregisterListener(this);
        stats();
    }
};
Services.console.registerListener(o1);
Services.console.registerListener(o2);
function stats() {
    if(t[0] && t[1] && t[2] && t[3]) {
        var listeners = Math.max(t[0], t[1]);
        alert([
            "Listener #1: " + t[0].toFixed(2),
            "Listener #2: " + t[1].toFixed(2),
            "Delayed #1: " + t[2].toFixed(2) + (t[2] > listeners ? " after listeners!" : ""),
            "Delayed #2: " + t[3].toFixed(2) + (t[3] > listeners ? " after listeners!" : "")
        ].join("\n"));
    }
}
Services.console.logStringMessage("test");

/**
 * Send a Console API message. This function will send a console-api-log-event
 * notification through the nsIObserverService.
 *
 * @param {string} aLevel
 *        Message severity level. This is usually the name of the console method
 *        that was called.
 * @param {object} aFrame
 *        The youngest stack frame coming from Components.stack, as formatted by
 *        getStack().
 * @param {array} aArgs
 *        The arguments given to the console method.
 * @param {object} aOptions
 *        Object properties depend on the console method that was invoked:
 *        - timer: for time() and timeEnd(). Holds the timer information.
 *        - groupName: for group(), groupCollapsed() and groupEnd().
 *        - stacktrace: for trace(). Holds the array of stack frames as given by
 *        getStack().
 */
function sendConsoleAPIMessage(aLevel, aFrame, aArgs, aOptions = {})
{
  let consoleEvent = {
    ID: "jsm",
    innerID: aFrame.filename,
    level: aLevel,
    filename: aFrame.filename,
    lineNumber: aFrame.lineNumber,
    functionName: aFrame.functionName,
    timeStamp: Date.now(),
    arguments: aArgs,
  };

  consoleEvent.wrappedJSObject = consoleEvent;

  switch (aLevel) {
    case "trace":
      consoleEvent.stacktrace = aOptions.stacktrace;
      break;
    case "time":
    case "timeEnd":
      consoleEvent.timer = aOptions.timer;
      break;
    case "group":
    case "groupCollapsed":
    case "groupEnd":
      try {
        consoleEvent.groupName = Array.prototype.join.call(aArgs, " ");
      }
      catch (ex) {
        Cu.reportError(ex);
        Cu.reportError(ex.stack);
        return;
      }
      break;
  }

  Services.obs.notifyObservers(consoleEvent, "console-api-log-event", null);
  let ConsoleAPIStorage = Cc["@mozilla.org/consoleAPI-storage;1"]
                            .getService(Ci.nsIConsoleAPIStorage);
  ConsoleAPIStorage.recordEvent("jsm", consoleEvent);
}