feat: add Inbucket mail provider integration and UI support

services/register/mail_provider.py

@@ -446,6 +446,109 @@ class MoEmailProvider(BaseMailProvider):
         self.session.close()
 
 
+class InbucketMailProvider(BaseMailProvider):
+    name = "inbucket"
+
+    def __init__(self, entry: dict, conf: dict):
+        super().__init__(conf, str(entry.get("provider_ref") or ""))
+        self.api_base = str(entry["api_base"]).rstrip("/")
+        raw_domains = entry.get("domain") or []
+        if isinstance(raw_domains, list):
+            self.domain = [str(item).strip() for item in raw_domains if str(item).strip()]
+        else:
+            self.domain = [str(raw_domains).strip()] if str(raw_domains).strip() else []
+        self.random_subdomain = bool(entry.get("random_subdomain", True))
+        self.session = requests.Session()
+        self.session.trust_env = False
+        self.session.headers.update({
+            "User-Agent": conf["user_agent"],
+            "Accept": "application/json",
+        })
+
+    def _request(self, method: str, path: str, expected: tuple[int, ...] = (200,)):
+        resp = self.session.request(
+            method.upper(),
+            f"{self.api_base}{path}",
+            timeout=self.conf["request_timeout"],
+            verify=False,
+        )
+        if resp.status_code not in expected:
+            raise RuntimeError(f"Inbucket 请求失败: {method} {path}, HTTP {resp.status_code}, body={resp.text[:300]}")
+        if resp.status_code == 204:
+            return {}
+        content_type = str(resp.headers.get("content-type") or "").lower()
+        if "application/json" in content_type:
+            return resp.json()
+        return resp.text
+
+    def _resolve_domain(self) -> str:
+        if self.domain:
+            return _next_domain(self.domain)
+        raise RuntimeError("Inbucket 需要至少配置一个 domain")
+
+    def _mailbox_name(self, address: str) -> str:
+        local_part, _, _ = str(address or "").partition("@")
+        return local_part.strip()
+
+    def create_mailbox(self, username: str | None = None) -> dict[str, Any]:
+        local_part = username or _random_mailbox_name()
+        base_domain = self._resolve_domain()
+        domain = f"{_random_subdomain_label()}.{base_domain}" if self.random_subdomain else base_domain
+        address = f"{local_part}@{domain}"
+        mailbox_name = self._mailbox_name(address)
+        return {
+            "provider": self.name,
+            "provider_ref": self.provider_ref,
+            "address": address,
+            "base_domain": base_domain,
+            "mailbox_name": mailbox_name,
+        }
+
+    def fetch_latest_message(self, mailbox: dict[str, Any]) -> dict[str, Any] | None:
+        mailbox_name = str(mailbox.get("mailbox_name") or self._mailbox_name(str(mailbox.get("address") or ""))).strip()
+        if not mailbox_name:
+            raise RuntimeError("Inbucket 缺少 mailbox_name")
+        data = self._request("GET", f"/api/v1/mailbox/{mailbox_name}")
+        items = [item for item in data if isinstance(item, dict)] if isinstance(data, list) else []
+        if not items:
+            return None
+        items.sort(
+            key=lambda value: (
+                (_parse_received_at(value.get("date")) or datetime.fromtimestamp(0, tz=timezone.utc)).timestamp(),
+                str(value.get("id") or ""),
+            ),
+            reverse=True,
+        )
+        address = str(mailbox.get("address") or "").strip()
+        for item in items:
+            message_id = str(item.get("id") or "").strip()
+            if not message_id:
+                continue
+            detail = self._request("GET", f"/api/v1/mailbox/{mailbox_name}/{message_id}")
+            if not isinstance(detail, dict):
+                continue
+            header = detail.get("header") if isinstance(detail.get("header"), dict) else {}
+            body = detail.get("body") if isinstance(detail.get("body"), dict) else {}
+            normalized = {
+                "provider": self.name,
+                "mailbox": mailbox_name,
+                "message_id": message_id,
+                "subject": str(detail.get("subject") or item.get("subject") or ""),
+                "sender": str(detail.get("from") or item.get("from") or ""),
+                "text_content": str(body.get("text") or ""),
+                "html_content": str(body.get("html") or ""),
+                "received_at": _parse_received_at(detail.get("date") or item.get("date")),
+                "to": header.get("To") if isinstance(header, dict) else None,
+                "raw": detail,
+            }
+            if _message_matches_email(normalized, address):
+                return normalized
+        return None
+
+    def close(self) -> None:
+        self.session.close()
+
+
 class YydsMailProvider(BaseMailProvider):
     name = "yyds_mail"
 
@@ -544,6 +647,8 @@ def _create_provider(mail_config: dict, provider: str = "", provider_ref: str =
         return GptMailProvider(entry, conf)
     if entry["type"] == "moemail":
         return MoEmailProvider(entry, conf)
+    if entry["type"] == "inbucket":
+        return InbucketMailProvider(entry, conf)
     if entry["type"] == "yyds_mail":
         return YydsMailProvider(entry, conf)
     raise RuntimeError(f"不支持的 mail.provider: {entry['type']}")

web/src/app/register/components/register-card.tsx

@@ -50,6 +50,7 @@ export function RegisterCard() {
       ...(type === "cloudflare_temp_email" ? { api_base: "", admin_password: "", domain: [] } : {}),
       ...(type === "tempmail_lol" ? { api_key: "", domain: [] } : {}),
       ...(type === "moemail" ? { api_base: "", api_key: "", domain: [] } : {}),
+      ...(type === "inbucket" ? { api_base: "", domain: [], random_subdomain: true } : {}),
       ...(type === "duckmail" ? { api_key: "", default_domain: "duckmail.sbs" } : {}),
       ...(type === "gptmail" ? { api_key: "", default_domain: "" } : {}),
       ...(type === "yyds_mail" ? { api_base: "https://maliapi.215.im/v1", api_key: "", domain: [], subdomain: "", wildcard: false } : {}),
@@ -168,13 +169,14 @@ export function RegisterCard() {
                             <SelectItem value="cloudflare_temp_email">cloudflare_temp_email</SelectItem>
                             <SelectItem value="tempmail_lol">tempmail_lol</SelectItem>
                             <SelectItem value="moemail">moemail</SelectItem>
+                            <SelectItem value="inbucket">inbucket</SelectItem>
                             <SelectItem value="duckmail">duckmail</SelectItem>
                             <SelectItem value="gptmail">gptmail(未测试)</SelectItem>
                             <SelectItem value="yyds_mail">yyds_mail</SelectItem>
                           </SelectContent>
                         </Select>
                       </div>
-                      {type === "cloudflare_temp_email" || type === "moemail" || type === "yyds_mail" ? (
+                      {type === "cloudflare_temp_email" || type === "moemail" || type === "inbucket" || type === "yyds_mail" ? (
                         <>
                           <div className="space-y-2">
                             <label className="text-sm text-stone-700">API Base</label>
@@ -188,6 +190,12 @@ export function RegisterCard() {
                           ) : null}
                         </>
                       ) : null}
+                      {type === "inbucket" ? (
+                        <label className="flex items-center gap-3 pt-8 text-sm text-stone-700">
+                          <Checkbox checked={Boolean(provider.random_subdomain ?? true)} onCheckedChange={(checked) => updateProvider(index, { random_subdomain: Boolean(checked) })} disabled={config.enabled} />
+                          启用随机子域名
+                        </label>
+                      ) : null}
                       {type === "tempmail_lol" || type === "moemail" || type === "duckmail" || type === "gptmail" || type === "yyds_mail" ? (
                         <div className="space-y-2">
                           <label className="text-sm text-stone-700">API Key</label>
@@ -214,10 +222,10 @@ export function RegisterCard() {
                       ) : null}
                     </div>
 
-                    {type === "tempmail_lol" || type === "cloudflare_temp_email" || type === "moemail" || type === "yyds_mail" ? (
+                    {type === "tempmail_lol" || type === "cloudflare_temp_email" || type === "moemail" || type === "inbucket" || type === "yyds_mail" ? (
                       <div className="space-y-2">
-                        <label className="text-sm text-stone-700">Domain</label>
-                        <Textarea value={domains} onChange={(event) => updateProvider(index, { domain: event.target.value.split(/[\n,]/).map((item) => item.trim()).filter(Boolean) })} placeholder={type === "moemail" ? "每行一个域名" : "每行一个域名，留空则使用服务默认域名"} className="min-h-20 rounded-xl border-stone-200 bg-white font-mono text-xs" disabled={config.enabled} />
+                        <label className="text-sm text-stone-700">{type === "inbucket" ? "基础域名列表" : "Domain"}</label>
+                        <Textarea value={domains} onChange={(event) => updateProvider(index, { domain: event.target.value.split(/[\n,]/).map((item) => item.trim()).filter(Boolean) })} placeholder={type === "inbucket" ? "每行一个基础域名，系统会自动生成随机子域名" : type === "moemail" ? "每行一个域名" : "每行一个域名，留空则使用服务默认域名"} className="min-h-20 rounded-xl border-stone-200 bg-white font-mono text-xs" disabled={config.enabled} />
                       </div>
                     ) : null}
                   </div>