1 files changed, 105 insertions, 0 deletions
diff --git a/comm/mailnews/local/src/Pop3Channel.jsm b/comm/mailnews/local/src/Pop3Channel.jsm
new file mode 100644
index 0000000000..4fae72894b
--- /dev/null
+++ b/comm/mailnews/local/src/Pop3Channel.jsm
@@ -0,0 +1,105 @@
+/* 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 EXPORTED_SYMBOLS = ["Pop3Channel"];
+
+const { XPCOMUtils } = ChromeUtils.importESModule(
+  "resource://gre/modules/XPCOMUtils.sys.mjs"
+);
+const { MailServices } = ChromeUtils.import(
+  "resource:///modules/MailServices.jsm"
+);
+
+const lazy = {};
+
+XPCOMUtils.defineLazyModuleGetters(lazy, {
+  Pop3Client: "resource:///modules/Pop3Client.jsm",
+});
+
+/**
+ * A channel to interact with POP3 server.
+ *
+ * @implements {nsIChannel}
+ * @implements {nsIRequest}
+ */
+class Pop3Channel {
+  QueryInterface = ChromeUtils.generateQI(["nsIChannel", "nsIRequest"]);
+
+  _logger = console.createInstance({
+    prefix: "mailnews.pop3",
+    maxLogLevel: "Warn",
+    maxLogLevelPref: "mailnews.pop3.loglevel",
+  });
+
+  /**
+   * @param {nsIURI} uri - The uri to construct the channel from.
+   * @param {nsILoadInfo} loadInfo - The loadInfo associated with the channel.
+   */
+  constructor(uri, loadInfo) {
+    this._server = MailServices.accounts
+      .findServerByURI(uri)
+      .QueryInterface(Ci.nsIPop3IncomingServer);
+
+    // nsIChannel attributes.
+    this.originalURI = uri;
+    this.URI = uri;
+    this.loadInfo = loadInfo;
+    this.contentLength = 0;
+  }
+
+  /**
+   * @see nsIRequest
+   */
+  get status() {
+    return Cr.NS_OK;
+  }
+
+  /**
+   * @see nsIChannel
+   */
+  get contentType() {
+    return this._contentType || "message/rfc822";
+  }
+
+  set contentType(value) {
+    this._contentType = value;
+  }
+
+  get isDocument() {
+    return true;
+  }
+
+  open() {
+    throw Components.Exception(
+      "Pop3Channel.open() not implemented",
+      Cr.NS_ERROR_NOT_IMPLEMENTED
+    );
+  }
+
+  asyncOpen(listener) {
+    this._logger.debug(`asyncOpen ${this.URI.spec}`);
+    let match = this.URI.spec.match(/pop3?:\/\/.+\/(?:\?|&)uidl=([^&]+)/);
+    let uidl = decodeURIComponent(match?.[1] || "");
+    if (!uidl) {
+      throw Components.Exception(
+        `Unrecognized url=${this.URI.spec}`,
+        Cr.NS_ERROR_ILLEGAL_VALUE
+      );
+    }
+
+    let client = new lazy.Pop3Client(this._server);
+    client.runningUri = this.URI;
+    client.connect();
+    client.onOpen = () => {
+      listener.onStartRequest(this);
+      client.fetchBodyForUidl(
+        this.URI.QueryInterface(Ci.nsIPop3URL).pop3Sink,
+        uidl
+      );
+    };
+    client.onDone = status => {
+      listener.onStopRequest(this, status);
+    };
+  }
+}