diff options
Diffstat (limited to 'toolkit/modules/AsanReporter.sys.mjs')
-rw-r--r-- | toolkit/modules/AsanReporter.sys.mjs | 166 |
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)); + }); +} |