1 files changed, 96 insertions, 0 deletions
diff --git a/toolkit/components/satchel/FormHistoryStartup.sys.mjs b/toolkit/components/satchel/FormHistoryStartup.sys.mjs
new file mode 100644
index 0000000000..05bfdf3cee
--- /dev/null
+++ b/toolkit/components/satchel/FormHistoryStartup.sys.mjs
@@ -0,0 +1,96 @@
+/* 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/. */
+
+const lazy = {};
+
+ChromeUtils.defineESModuleGetters(lazy, {
+  FormHistory: "resource://gre/modules/FormHistory.sys.mjs",
+});
+
+export function FormHistoryStartup() {}
+
+FormHistoryStartup.prototype = {
+  classID: Components.ID("{3A0012EB-007F-4BB8-AA81-A07385F77A25}"),
+
+  QueryInterface: ChromeUtils.generateQI([
+    "nsIObserver",
+    "nsISupportsWeakReference",
+  ]),
+
+  observe(subject, topic, data) {
+    switch (topic) {
+      case "idle-daily":
+      case "formhistory-expire-now":
+        lazy.FormHistory.expireOldEntries().catch(Cu.reportError);
+        break;
+      case "profile-after-change":
+        this.init();
+        break;
+    }
+  },
+
+  inited: false,
+
+  init() {
+    if (this.inited) {
+      return;
+    }
+    this.inited = true;
+
+    // triggers needed service cleanup and db shutdown
+    Services.obs.addObserver(this, "idle-daily", true);
+    Services.obs.addObserver(this, "formhistory-expire-now", true);
+
+    Services.ppmm.addMessageListener(
+      "FormHistory:AutoCompleteSearchAsync",
+      this
+    );
+    Services.ppmm.addMessageListener("FormHistory:RemoveEntry", this);
+  },
+
+  receiveMessage(message) {
+    switch (message.name) {
+      case "FormHistory:AutoCompleteSearchAsync": {
+        // This case is only used for the search field. There is a
+        // similar algorithm in FormHistoryParent.jsm that uses
+        // sendQuery for other form fields.
+
+        let { id, searchString, params } = message.data;
+
+        let instance = (this._queryInstance = {});
+        lazy.FormHistory.getAutoCompleteResults(
+          searchString,
+          params,
+          (row, cancel) => {
+            if (this._queryInstance != instance) {
+              cancel();
+            }
+          }
+        ).then(results => {
+          if (this._queryInstance == instance) {
+            message.target.sendAsyncMessage(
+              "FormHistory:AutoCompleteSearchResults",
+              {
+                id,
+                results,
+              }
+            );
+          }
+        });
+        break;
+      }
+
+      case "FormHistory:RemoveEntry": {
+        let { inputName, value, guid } = message.data;
+        lazy.FormHistory.update({
+          op: "remove",
+          fieldname: inputName,
+          value,
+          guid,
+        });
+        break;
+      }
+    }
+  },
+};