feat(market): mirror speedtest + plugin detail, source empty when unavailable

Author: QtineNiko

config.yml

@@ -29,9 +29,8 @@ logging:
 plugins:
   autoload: []
   dir: ./plugins
-  marketplace_mirrors:
-  - https://mirror.qtine.dev/api
-  marketplace_url: https://qtine-market.example.com/api
+  marketplace_mirrors: []
+  marketplace_url: http://xingruo.chat:2456/api
 security:
   blacklist:
     enabled: true

plugins/pu-sr/README.md

@@ -0,0 +1,43 @@
+# PU-SR
+
+PU-CN-Wiki 搜索与反馈插件，基于 Qtine 平台。
+
+## 功能
+
+通过 Wikit GraphQL API 搜索 pu-cn-wiki 页面信息，并提供反馈/建议系统。
+
+## 命令
+
+### /sr - 搜索
+
+- `/sr` — 显示帮助
+- `/sr <页面名>` — 按页面名搜索，返回首个匹配（标题/评分/作者/标签/讨论/链接）
+- `/sr <页面名> #tag <标签> [标签...]` — 页面名 + 标签检索（全包含）
+- `/sr <页面名> <作者名>` — 页面名 + 作者组合检索
+- `/sr #au <作者名>` — 查看作者在本站所有页面（QQ 合并转发消息）
+
+### /au - 作者
+
+- `/au <作者名>` — 显示作者排行与总分，格式 `#排名 作者名 总分：值`
+
+### /putc - 反馈
+
+- `/putc` — 反馈/建议菜单
+- `/putc <内容>` — 提交反馈
+- `/putc me` — 查看自己的反馈受理状态
+- `/putc <编号>` — 查看指定编号反馈
+- `/putc list` — 列出所有反馈（管理员）
+- `/putc add <编号>` — 受理反馈（管理员）
+- `/putc kill <编号>` — 拒绝反馈（管理员）
+
+## 配置
+
+管理员 QQ 通过插件配置项 `admins` 设置（WebUI 可改），控制 `/putc list/add/kill` 权限。
+
+## 数据来源
+
+Wikit GraphQL API: `https://wikit.unitreaty.org/apiv1/graphql`
+
+## 版本
+
+1.0.1

qtine/core/app.py

@@ -34,6 +34,20 @@
 MAX_UPLOAD_MB = 50
 ALLOWED_EXTENSIONS = {"zip"}
 
+# 默认 GitHub 加速镜像（10 个）
+DEFAULT_GITHUB_MIRRORS = [
+    {"name": "GitHub 官方", "url": "https://github.com"},
+    {"name": "ghproxy", "url": "https://ghproxy.com"},
+    {"name": "99988866", "url": "https://gh.api.99988866.xyz"},
+    {"name": "mirror.ghproxy", "url": "https://mirror.ghproxy.com"},
+    {"name": "gh-proxy", "url": "https://gh-proxy.com"},
+    {"name": "xcxgw", "url": "https://gh.xcxgw.com"},
+    {"name": "ghps", "url": "https://ghps.cc"},
+    {"name": "d-ai workers", "url": "https://gh.d-ai.workers.dev"},
+    {"name": "llkk", "url": "https://gh.llkk.cc"},
+    {"name": "gitmirror", "url": "https://hub.gitmirror.com"},
+]
+
 # Built-in marketplace demo entries. Used as fallback when no remote
 # marketplace source is configured (or the configured source is unreachable),
 # so the WebUI can still render the plugin market page out of the box.
@@ -1144,9 +1158,7 @@ def api_market_plugins():
                     continue
 
             if using_fallback:
-                # Deep copy the built-in demo list so callers can't mutate
-                # the module-level constant via the response.
-                plugins = [dict(p) for p in BUILTIN_MARKET_PLUGINS]
+                plugins = []
 
             # Annotate installed state.
             for p in plugins:
@@ -1241,6 +1253,17 @@ def api_market_install(name):
                     "name": name,
                 }), 400
 
+            # Apply mirror if configured and download_url is from GitHub
+            mirror_url = self.storage.get("market_mirror", "") or ""
+            if (
+                mirror_url
+                and "github.com" in download_url
+                and mirror_url != "https://github.com"
+            ):
+                download_url = download_url.replace(
+                    "https://github.com", mirror_url.rstrip("/")
+                )
+
             # Download to data/uploads/<name>.zip
             try:
                 import urllib.request
@@ -1264,6 +1287,167 @@ def api_market_install(name):
                 {"success": False, "error": "Plugin import failed"}
             ), 400
 
+        # ── marketplace: mirrors / speedtest / readme ──────────────
+
+        @app.route("/api/market/mirrors")
+        def api_market_mirrors():
+            """返回 GitHub 加速镜像列表，含用户自定义的。"""
+            custom = self.storage.get("market_custom_mirrors", []) or []
+            current = self.storage.get(
+                "market_mirror", "https://github.com"
+            ) or "https://github.com"
+            all_mirrors = list(DEFAULT_GITHUB_MIRRORS) + [
+                {"name": m.get("name", "自定义"), "url": m.get("url", "")}
+                for m in custom
+                if m.get("url")
+            ]
+            return jsonify({
+                "mirrors": all_mirrors,
+                "current": current,
+            })
+
+        @app.route("/api/market/mirrors/set", methods=["POST"])
+        def api_market_mirrors_set():
+            """设置当前使用的加速源。"""
+            data = request.get_json(silent=True) or {}
+            url = (data.get("url") or "").strip()
+            if not url:
+                return jsonify(
+                    {"success": False, "error": "url is required"}
+                ), 400
+            self.storage.set("market_mirror", url)
+            return jsonify({"success": True, "current": url})
+
+        @app.route("/api/market/mirrors/speedtest")
+        def api_market_mirrors_speedtest():
+            """对所有镜像进行测速，返回最快的。"""
+            import urllib.request
+
+            mirrors = DEFAULT_GITHUB_MIRRORS[:]
+            custom = self.storage.get("market_custom_mirrors", []) or []
+            for m in custom:
+                if m.get("url"):
+                    mirrors.append(
+                        {"name": m.get("name", "自定义"), "url": m["url"]}
+                    )
+
+            results = []
+            test_path = "/QtineNiko/Qtine"
+            for m in mirrors:
+                url = m["url"].rstrip("/") + test_path
+                start = time.time()
+                try:
+                    req = urllib.request.Request(url, method="HEAD")
+                    with urllib.request.urlopen(req, timeout=5) as r:
+                        latency = (time.time() - start) * 1000
+                        results.append({
+                            "name": m["name"],
+                            "url": m["url"],
+                            "latency": round(latency, 0),
+                        })
+                except Exception:
+                    results.append({
+                        "name": m["name"],
+                        "url": m["url"],
+                        "latency": 99999,
+                    })
+
+            results.sort(key=lambda x: x["latency"])
+            fastest = (
+                results[0]["url"]
+                if results and results[0]["latency"] < 99999
+                else None
+            )
+            return jsonify({"results": results, "fastest": fastest})
+
+        @app.route("/api/market/mirrors/custom", methods=["POST"])
+        def api_market_mirrors_custom_add():
+            """添加自定义加速源。"""
+            data = request.get_json(silent=True) or {}
+            name = (data.get("name") or "").strip()
+            url = (data.get("url") or "").strip()
+            if not url:
+                return jsonify(
+                    {"success": False, "error": "url is required"}
+                ), 400
+            if not name:
+                name = url[:20]
+            custom = self.storage.get("market_custom_mirrors", []) or []
+            custom.append({"name": name, "url": url})
+            self.storage.set("market_custom_mirrors", custom)
+            return jsonify({"success": True, "mirrors": custom})
+
+        @app.route(
+            "/api/market/mirrors/custom/<int:idx>", methods=["DELETE"]
+        )
+        def api_market_mirrors_custom_remove(idx):
+            """删除自定义加速源。"""
+            custom = self.storage.get("market_custom_mirrors", []) or []
+            if idx < 0 or idx >= len(custom):
+                return jsonify(
+                    {"success": False, "error": "index out of range"}
+                ), 400
+            removed = custom.pop(idx)
+            self.storage.set("market_custom_mirrors", custom)
+            return jsonify({"success": True, "removed": removed})
+
+        @app.route("/api/market/plugins/<name>/readme")
+        def api_market_plugin_readme(name):
+            """获取插件 README。
+
+            优先从市场源拉取；源不可用时返回空字符串。
+            """
+            source_url = (
+                self.config.get("plugins.marketplace_url", "") or ""
+            ).strip()
+            readme = ""
+            if source_url:
+                try:
+                    import urllib.request
+                    import json as _json
+
+                    url = (
+                        source_url.rstrip("/")
+                        + f"/plugins/{name}/readme"
+                    )
+                    with urllib.request.urlopen(
+                        url, timeout=10
+                    ) as r:
+                        d = _json.loads(
+                            r.read().decode("utf-8", "ignore")
+                        )
+                        readme = d.get("readme", "") or ""
+                except Exception as e:
+                    self.logger.warning(
+                        f"Fetch readme for {name} failed: {e}"
+                    )
+            return jsonify({"name": name, "readme": readme})
+
+        @app.route("/api/market/plugins/<name>/detail")
+        def api_market_plugin_detail(name):
+            """获取插件详情（含 readme）。"""
+            source_url = (
+                self.config.get("plugins.marketplace_url", "") or ""
+            ).strip()
+            if source_url:
+                try:
+                    import urllib.request
+                    import json as _json
+
+                    url = source_url.rstrip("/") + f"/plugins/{name}"
+                    with urllib.request.urlopen(
+                        url, timeout=10
+                    ) as r:
+                        d = _json.loads(
+                            r.read().decode("utf-8", "ignore")
+                        )
+                        return jsonify(d)
+                except Exception as e:
+                    self.logger.warning(
+                        f"Fetch detail for {name} failed: {e}"
+                    )
+            return jsonify({"error": "not found"}), 404
+
         # ── adapters CRUD ──────────────────────────────────────────
 
         @app.route("/api/adapters")