summaryrefslogtreecommitdiffstats
path: root/toolkit/modules/AsanReporter.sys.mjs
diff options
context:
space:
mode:
Diffstat (limited to 'toolkit/modules/AsanReporter.sys.mjs')
-rw-r--r--toolkit/modules/AsanReporter.sys.mjs166
1 files changed, 166 insertions, 0 deletions
diff --git a/toolkit/modules/AsanReporter.sys.mjs b/toolkit/modules/AsanReporter.sys.mjs
new file mode 100644
index 0000000000..367fee9f49
--- /dev/null
+++ b/toolkit/modules/AsanReporter.sys.mjs
@@ -0,0 +1,166 @@
+/* -*- indent-tabs-mode: nil; js-indent-level: 2 -*- */
+/* This Source Code Form is subject to the terms of the Mozilla Public
+ * License, v. 2.0. If a copy of the MPL was not distributed with this
+ * file, You can obtain one at http://mozilla.org/MPL/2.0/. */
+
+import { AppConstants } from "resource://gre/modules/AppConstants.sys.mjs";
+
+const lazy = {};
+
+ChromeUtils.defineESModuleGetters(lazy, {
+ Log: "resource://gre/modules/Log.sys.mjs",
+});
+
+// Define our prefs
+const PREF_CLIENT_ID = "asanreporter.clientid";
+const PREF_API_URL = "asanreporter.apiurl";
+const PREF_AUTH_TOKEN = "asanreporter.authtoken";
+const PREF_LOG_LEVEL = "asanreporter.loglevel";
+
+// Reporter product map
+const REPORTER_PRODUCT = {
+ firefox: "mozilla-central-asan-nightly",
+ thunderbird: "comm-central-asan-daily",
+};
+
+const LOGGER_NAME = "asanreporter";
+
+let logger;
+
+export const AsanReporter = {
+ init() {
+ if (this.initialized) {
+ return;
+ }
+ this.initialized = true;
+
+ // Setup logging
+ logger = lazy.Log.repository.getLogger(LOGGER_NAME);
+ logger.addAppender(
+ new lazy.Log.ConsoleAppender(new lazy.Log.BasicFormatter())
+ );
+ logger.addAppender(
+ new lazy.Log.DumpAppender(new lazy.Log.BasicFormatter())
+ );
+ logger.level = Services.prefs.getIntPref(
+ PREF_LOG_LEVEL,
+ lazy.Log.Level.Info
+ );
+
+ logger.info("Starting up...");
+
+ // Install a handler to observe tab crashes, so we can report those right
+ // after they happen instead of relying on the user to restart the browser.
+ Services.obs.addObserver(this, "ipc:content-shutdown");
+
+ processDirectory();
+ },
+
+ observe(aSubject, aTopic, aData) {
+ if (aTopic == "ipc:content-shutdown") {
+ aSubject.QueryInterface(Ci.nsIPropertyBag2);
+ if (!aSubject.get("abnormal")) {
+ return;
+ }
+ processDirectory();
+ }
+ },
+};
+
+async function processDirectory() {
+ const asanDumpDir = PathUtils.join(PathUtils.profileDir, "asan");
+ const children = await IOUtils.getChildren(asanDumpDir);
+
+ const results = children.filter(function(path) {
+ const name = PathUtils.filename(path);
+ return name.startsWith("ff_asan_log.") && !name.includes("submitted");
+ });
+
+ logger.info(`Processing ${results.length} reports...`);
+ for (const result of results) {
+ try {
+ await submitReport(result);
+ logger.info(`Successfully submitted ${result.path}`);
+ } catch (e) {
+ logger.error(`Failed to submit ${result.path}. Reason: ${e}`);
+ }
+ }
+
+ logger.info("Done processing reports.");
+}
+
+async function submitReport(reportFile) {
+ logger.info("Processing " + reportFile);
+ const data = await IOUtils.read(reportFile);
+ await submitToServer(data);
+ // Mark as submitted only if we successfully submitted it to the server.
+ await IOUtils.move(reportFile, `${reportFile}.submitted`);
+}
+
+function submitToServer(data) {
+ return new Promise(function(resolve, reject) {
+ logger.debug("Setting up XHR request");
+ let client = Services.prefs.getStringPref(PREF_CLIENT_ID);
+ let api_url = Services.prefs.getStringPref(PREF_API_URL);
+ let auth_token = Services.prefs.getStringPref(PREF_AUTH_TOKEN, null);
+
+ let decoder = new TextDecoder();
+
+ if (!client) {
+ client = "unknown";
+ }
+
+ let versionArr = [
+ Services.appinfo.version,
+ Services.appinfo.appBuildID,
+ AppConstants.SOURCE_REVISION_URL || "unknown",
+ ];
+
+ // Concatenate all relevant information as our server only
+ // has one field available for version information.
+ let product_version = versionArr.join("-");
+ let os = AppConstants.platform;
+ let reporter_product = REPORTER_PRODUCT[AppConstants.MOZ_APP_NAME];
+
+ let reportObj = {
+ rawStdout: "",
+ rawStderr: "",
+ rawCrashData: decoder.decode(data),
+ // Hardcode platform as there is no other reasonable platform for ASan
+ platform: "x86-64",
+ product: reporter_product,
+ product_version,
+ os,
+ client,
+ tool: "asan-nightly-program",
+ };
+
+ var xhr = new XMLHttpRequest();
+ xhr.open("POST", api_url, true);
+ xhr.setRequestHeader("Content-Type", "application/json");
+
+ // For internal testing purposes, an auth_token can be specified
+ if (auth_token) {
+ xhr.setRequestHeader("Authorization", "Token " + auth_token);
+ } else {
+ // Prevent privacy leaks
+ xhr.channel.loadFlags |= Ci.nsIRequest.LOAD_ANONYMOUS;
+ }
+
+ xhr.onreadystatechange = function() {
+ if (xhr.readyState == 4) {
+ if (xhr.status == "201") {
+ logger.debug("XHR: OK");
+ resolve(xhr);
+ } else {
+ logger.debug(
+ "XHR: Status: " + xhr.status + " Response: " + xhr.responseText
+ );
+ reject(xhr);
+ }
+ }
+ };
+
+ xhr.send(JSON.stringify(reportObj));
+ });
+}