refactor: replace print with logging and document production deploy

Author: PPPPanda

README.md

@@ -255,6 +255,55 @@ curl http://localhost:8765/api/health
 curl http://localhost:8765/api/info
 ```
 
+### 6.5 生产部署 / 反向代理 / HTTPS
+
+如果你要把它部署给别人使用，推荐的最小方案是：
+
+1. ContentPipe 只监听内网或 Docker 网络
+2. 用 Nginx / Caddy 做反向代理
+3. 打开 `CONTENTPIPE_AUTH_TOKEN`
+4. 通过 HTTPS 暴露外部访问
+5. 把 `CONTENTPIPE_PUBLIC_BASE_URL` 设成最终对外域名
+
+示例（Nginx）：
+
+```nginx
+server {
+    listen 80;
+    server_name contentpipe.example.com;
+    return 301 https://$host$request_uri;
+}
+
+server {
+    listen 443 ssl http2;
+    server_name contentpipe.example.com;
+
+    ssl_certificate     /path/to/fullchain.pem;
+    ssl_certificate_key /path/to/privkey.pem;
+
+    client_max_body_size 25m;
+
+    location / {
+        proxy_pass http://127.0.0.1:8765;
+        proxy_set_header Host $host;
+        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
+        proxy_set_header X-Forwarded-Proto $scheme;
+        proxy_set_header Upgrade $http_upgrade;
+        proxy_set_header Connection "upgrade";
+    }
+}
+```
+
+对应 `.env` 建议：
+
+```bash
+CONTENTPIPE_AUTH_TOKEN=change-me
+CONTENTPIPE_PUBLIC_BASE_URL=https://contentpipe.example.com
+OPENCLAW_GATEWAY_URL=http://host.docker.internal:18789
+```
+
+如果只在本机使用，可以不配反代和 HTTPS；但**只要要给别人访问，就建议必须开 HTTPS + 鉴权**。
+
 ---
 
 ## 7. Web UI

scripts/env_loader.py

@@ -11,6 +11,10 @@
 import os
 from pathlib import Path
 
+from logutil import get_logger
+
+
+logger = get_logger(__name__)
 
 OPENCLAW_CONFIG_PATHS = [
     Path.home() / ".clawdbot" / "openclaw.json",
@@ -82,8 +86,8 @@ def load_keys_from_openclaw() -> dict[str, str]:
 if __name__ == "__main__":
     keys = load_keys_from_openclaw()
     if keys:
-        print(f"✅ 从 OpenClaw 加载了 {len(keys)} 个 API keys:")
+        logger.info("从 OpenClaw 加载了 %s 个 API keys", len(keys))
         for k, v in keys.items():
-            print(f"  {k} = {v}")
+            logger.info("%s = %s", k, v)
     else:
-        print("❌ 未找到 OpenClaw 配置或无可用 keys")
+        logger.warning("未找到 OpenClaw 配置或无可用 keys")

scripts/formatter.py

@@ -22,6 +22,10 @@
 import jinja2
 import yaml
 
+from logutil import get_logger
+
+logger = get_logger(__name__)
+
 
 SKILL_DIR = Path(__file__).parent.parent
 CONFIG_DIR = SKILL_DIR / "config"
@@ -417,7 +421,7 @@ def format_article(run_id: str, output_dir: Path, platform: str = "wechat") -> s
     (output_dir / "formatted.html").write_text(html, encoding="utf-8")
     (output_dir / "content_body.html").write_text(content_html, encoding="utf-8")
 
-    print(f"📐 Formatted: {len(html)} chars, {len(image_map)} images, template={template_name}")
+    logger.info("Formatted: %s chars, %s images, template=%s", len(html), len(image_map), template_name)
     return html
 
 
@@ -434,7 +438,7 @@ def format_article(run_id: str, output_dir: Path, platform: str = "wechat") -> s
         output_dir = DEFAULT_OUTPUT_BASE / args.run_id
 
     if not output_dir.exists():
-        print(f"❌ Output dir not found: {output_dir}", file=sys.stderr)
+        logger.error("Output dir not found: %s", output_dir)
         sys.exit(1)
 
     format_article(args.run_id, output_dir, args.platform)

scripts/hot_news.py

@@ -24,6 +24,10 @@
 import sys
 from typing import Any
 
+from logutil import get_logger
+
+logger = get_logger(__name__)
+
 import httpx
 
 HEADERS = {
@@ -54,7 +58,7 @@ def fetch_baidu(top: int = 30) -> list[dict]:
                 for i, it in enumerate(items[:top]) if isinstance(it, dict) and it.get("word")
             ]
     except Exception as e:
-        print(f"⚠️ 百度: {e}", file=sys.stderr)
+        logger.warning("百度: %s", e)
         return []
 
 
@@ -98,12 +102,12 @@ def fetch_twitter(top: int = 15, keywords: list[str] | None = None) -> list[dict
                     "retweets": tweet.get("retweet_count", 0),
                 })
         except FileNotFoundError:
-            print("⚠️ xreach 未安装，跳过 Twitter", file=sys.stderr)
+            logger.warning("xreach 未安装，跳过 Twitter")
             return results
         except subprocess.TimeoutExpired:
-            print(f"⚠️ xreach 超时: {query}", file=sys.stderr)
+            logger.warning("xreach 超时: %s", query)
         except Exception as e:
-            print(f"⚠️ Twitter ({query}): {e}", file=sys.stderr)
+            logger.warning("Twitter (%s): %s", query, e)
 
     # 去重
     seen = set()
@@ -137,7 +141,7 @@ def fetch_weibo(top: int = 20) -> list[dict]:
                 if it.get("word")
             ]
     except Exception as e:
-        print(f"⚠️ 微博: {e}", file=sys.stderr)
+        logger.warning("微博: %s", e)
         return []
 
 
@@ -168,7 +172,7 @@ def fetch_zhihu(top: int = 20) -> list[dict]:
                 })
             return results
     except Exception as e:
-        print(f"⚠️ 知乎: {e}", file=sys.stderr)
+        logger.warning("知乎: %s", e)
         return []
 
 
@@ -198,7 +202,7 @@ def fetch_via_jina(url: str, platform: str = "jina") -> list[dict]:
                     })
             return results
     except Exception as e:
-        print(f"⚠️ Jina ({url}): {e}", file=sys.stderr)
+        logger.warning("Jina (%s): %s", url, e)
         return []
 
 
@@ -242,7 +246,7 @@ def fetch_tophub(board_id: str, platform_name: str, top: int = 30) -> list[dict]
                     results[-1]["heat"] = int(hm.group(1)) * 10000
             return results
     except Exception as e:
-        print(f"⚠️ tophub ({platform_name}): {e}", file=sys.stderr)
+        logger.warning("tophub (%s): %s", platform_name, e)
         return []
 
 
@@ -282,7 +286,7 @@ def fetch_all(
 
     total = sum(len(v) for v in results.values())
     parts = [f"{k} {len(v)}" for k, v in results.items() if v]
-    print(f"🔥 热搜: {total} 条 ({', '.join(parts) or '全部失败'})", file=sys.stderr)
+    logger.info("热搜: %s 条 (%s)", total, ", ".join(parts) or "全部失败")
     return results
 
 

scripts/image_engines/api_pollinations.py

@@ -23,6 +23,9 @@
 import httpx
 
 from .base import ImageEngine, ImageResult
+from logutil import get_logger
+
+logger = get_logger(__name__)
 
 
 class PollinationsEngine(ImageEngine):
@@ -187,7 +190,7 @@ def _translate_prompt(chinese_prompt: str) -> str:
         if translated and len(translated) > 10:
             return translated
     except Exception as e:
-        print(f"  ⚠️ Prompt translation failed: {e}")
+        logger.warning("Prompt translation failed: %s", e)
 
     # Fallback: 原样返回（Pollinations 也能处理部分中文）
     return chinese_prompt

scripts/jimeng.py

@@ -16,9 +16,13 @@
 
 import httpx
 
+from logutil import get_logger
+
 GATEWAY_URL = "http://localhost:18789"
 JIMENG_TAB_ID = "633824CAA4F7CEFB0C523AFB972A9E08"  # 默认即梦 tab
 
+logger = get_logger(__name__)
+
 
 def _browser_action(action: str, **kwargs) -> dict:
     """调用 OpenClaw Gateway 的 browser tool"""
@@ -139,11 +143,11 @@ def get_highres_url(thumbnail_url: str, size: int = 2048) -> str:
 if __name__ == "__main__":
     import sys
     prompt = sys.argv[1] if len(sys.argv) > 1 else "一只可爱的卡通猫咪在花园里玩耍"
-    print(f"Prompt: {prompt}")
+    logger.info("Prompt: %s", prompt)
     try:
         urls = generate_images(prompt)
-        print(f"✅ 生成 {len(urls)} 张图片:")
+        logger.info("生成 %s 张图片", len(urls))
         for i, url in enumerate(urls):
-            print(f"  [{i+1}] {url[:100]}...")
+            logger.info("[%s] %s...", i+1, url[:100])
     except Exception as e:
-        print(f"❌ {e}")
+        logger.error("%s", e)