1 files changed, 72 insertions, 0 deletions
diff --git a/toolkit/components/telemetry/pings/UntrustedModulesPing.sys.mjs b/toolkit/components/telemetry/pings/UntrustedModulesPing.sys.mjs
new file mode 100644
index 0000000000..85f565775d
--- /dev/null
+++ b/toolkit/components/telemetry/pings/UntrustedModulesPing.sys.mjs
@@ -0,0 +1,72 @@
+/* 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/. */
+
+/*
+ * This module periodically sends a Telemetry ping containing information
+ * about untrusted module loads on Windows.
+ *
+ * https://firefox-source-docs.mozilla.org/toolkit/components/telemetry/telemetry/data/third-party-modules-ping.html
+ */
+
+import { Log } from "resource://gre/modules/Log.sys.mjs";
+import { XPCOMUtils } from "resource://gre/modules/XPCOMUtils.sys.mjs";
+
+const lazy = {};
+
+ChromeUtils.defineESModuleGetters(lazy, {
+  TelemetryController: "resource://gre/modules/TelemetryController.sys.mjs",
+  TelemetryUtils: "resource://gre/modules/TelemetryUtils.sys.mjs",
+});
+
+XPCOMUtils.defineLazyServiceGetters(lazy, {
+  UpdateTimerManager: [
+    "@mozilla.org/updates/timer-manager;1",
+    "nsIUpdateTimerManager",
+  ],
+});
+
+const DEFAULT_INTERVAL_SECONDS = 24 * 60 * 60; // 1 day
+
+const LOGGER_NAME = "Toolkit.Telemetry";
+const LOGGER_PREFIX = "TelemetryUntrustedModulesPing::";
+const TIMER_NAME = "telemetry_untrustedmodules_ping";
+const PING_SUBMISSION_NAME = "third-party-modules";
+
+export var TelemetryUntrustedModulesPing = Object.freeze({
+  _log: Log.repository.getLoggerWithMessagePrefix(LOGGER_NAME, LOGGER_PREFIX),
+
+  start() {
+    lazy.UpdateTimerManager.registerTimer(
+      TIMER_NAME,
+      this,
+      Services.prefs.getIntPref(
+        lazy.TelemetryUtils.Preferences.UntrustedModulesPingFrequency,
+        DEFAULT_INTERVAL_SECONDS
+      )
+    );
+  },
+
+  notify() {
+    try {
+      Services.telemetry.getUntrustedModuleLoadEvents().then(payload => {
+        try {
+          if (payload) {
+            lazy.TelemetryController.submitExternalPing(
+              PING_SUBMISSION_NAME,
+              payload,
+              {
+                addClientId: true,
+                addEnvironment: true,
+              }
+            );
+          }
+        } catch (ex) {
+          this._log.error("payload handler caught an exception", ex);
+        }
+      });
+    } catch (ex) {
+      this._log.error("notify() caught an exception", ex);
+    }
+  },
+});