feat: card-forge 模块 + 三体融合配套 + 对话掉落卡片闭环 & 社区登录 (M1/M2/M5)

app/main_server.py

@@ -1578,6 +1578,49 @@ async def health():
     return build_health_response("main", instance_id=INSTANCE_ID)
 
 
+# ── Card-Forge 跨进程当前猫娘同步端点 ────────────────────────────
+# 奇遇铸造机 (card-forge) 前端会轮询本端点，拿到当前猫娘名作为
+# /arena/forge-facts 的 runtime_character_hint；不要求 card-forge 后端
+# 知道 NEKO 内部状态，只通过此端点把"当前 NEKO 在前台展示的猫娘"广播给它。
+_card_forge_active_character: dict = {}  # {dataUrl, name}
+
+
+@app.post('/card-forge/active-character')
+async def set_card_forge_active_character(payload: dict):
+    """由 app-chat-avatar.js 在捕获头像后调用，存储当前猫娘名（与头像 dataUrl）供 card-forge 获取。
+
+    用 in-payload 语义区分"省略字段（不动）" vs "显式空串（清空）"：
+    - POST {"dataUrl": "x"}        只更新 dataUrl，保留已存 name
+    - POST {"name": ""}            显式清空 name
+    - POST {"dataUrl": "", "name": ""}  显式清空全部
+    前端调用方因此应该 *只在字段有意义时* 把它放进 body，避免误擦。
+    """
+    if not isinstance(payload, dict):
+        return {"ok": True}
+    if 'dataUrl' in payload:
+        _card_forge_active_character['dataUrl'] = str(payload.get('dataUrl') or '')
+    if 'name' in payload:
+        _card_forge_active_character['name'] = str(payload.get('name') or '')
+    return {"ok": True}
+
+
+@app.get('/card-forge/active-character')
+async def get_card_forge_active_character(include_avatar: bool = False):
+    """card-forge 前端轮询此端点获取最新猫娘名。
+
+    默认不返回 avatar dataUrl —— card-forge 前端目前每 5 秒轮询一次,只读 `name`,
+    把几十 KB 的 base64 dataUrl 一起回包纯属浪费。需要 avatar 的调用方
+    (例如未来的卡仓预览面板) 显式传 `?include_avatar=true`。
+    """
+    from fastapi.responses import JSONResponse
+    payload: dict[str, str] = {
+        'name': _card_forge_active_character.get('name', ''),
+    }
+    if include_avatar:
+        payload['dataUrl'] = _card_forge_active_character.get('dataUrl', '')
+    return JSONResponse(payload)
+
+
 @app.post('/api/beacon/shutdown')
 async def beacon_shutdown():
     """Beacon 接口：用于优雅关闭服务器"""
@@ -2055,6 +2098,24 @@ async def _event_loop_heartbeat():
         except Exception as _e:
             logger.debug(f"[debug_health] start watchdog failed: {_e}")
 
+        # N.E.K.O.Servers 社交平台 facts_sync worker。默认禁用
+        # （NEKO_FACTS_SYNC_ENABLED=0）；启用后 5 分钟 sweep 一次，把高 importance
+        # facts 推到云端铸造池。完整契约见 N.E.K.O.Servers/.claude/contracts/facts-sync-schema.md。
+        try:
+            from main_logic.facts_sync import start_facts_sync_worker  # noqa: WPS433  (lazy import 避免循环)
+            asyncio.create_task(start_facts_sync_worker())
+        except Exception as _e:
+            logger.debug(f"[facts_sync] start worker failed: {_e}")
+
+        # N.E.K.O.Servers 卡片本地缓存 puller。默认禁用
+        # （NEKO_CARD_CACHE_ENABLED=0）；启用后 5 分钟拉 Servers /api/cards/mine
+        # 自己的卡片到 memory/<lanlan>/cards/<id>.json。
+        try:
+            from main_logic.card_cache import start_card_cache_puller  # noqa: WPS433
+            asyncio.create_task(start_card_cache_puller())
+        except Exception as _e:
+            logger.debug(f"[card_cache] start puller failed: {_e}")
+
         blocking_reason = get_storage_startup_blocking_reason(_config_manager)
         if blocking_reason:
             _enable_main_storage_limited_mode(blocking_reason)

app/runtime_bindings.py

@@ -35,6 +35,7 @@
 _INSTALLED: dict[str, bool] = {
     "config_runtime": False,
     "user_directives_sink": False,
+    "quota_hooks": False,
 }
 
 
@@ -149,3 +150,41 @@ def install_runtime_bindings() -> None:
                     # config_runtime block 的策略——咽掉避免 startup 二次崩，
                     # caller (app/__init__) 已经印过 stderr 面包屑。
                     pass
+
+    # ---- main_logic.agent_event_bus ← main_logic.quota dropper -----------
+    # N.E.K.O.Servers 社交平台配额掉落 hooks（M2-j）。挂载本身不依赖环境变量，
+    # 是否真触发取决于 dropper._enabled()（要求 NEKO_QUOTA_DROPPER_ENABLED=1
+    # + NEKO_SOCIAL_BASE_URL 已配）。默认 noop，挂着也无害。
+    if not _INSTALLED["quota_hooks"]:
+        try:
+            from main_logic.agent_event_bus import (
+                register_text_user_message_hook,
+                register_user_utterance_sink,
+            )
+            from main_logic.quota import on_text_message, on_utterance
+
+            # text-message hook 是 first-hit-wins，dropper 已确保返回 None
+            register_text_user_message_hook(on_text_message)
+            register_user_utterance_sink(on_utterance)
+            _INSTALLED["quota_hooks"] = True
+        except Exception as exc:
+            _expected_absent = {
+                "main_logic",
+                "main_logic.agent_event_bus",
+                "main_logic.quota",
+                "main_logic.quota.dropper",
+                "yaml",  # PyYAML 缺失也算预期场景（memory-only worker）
+            }
+            _is_expected_absent = (
+                isinstance(exc, ModuleNotFoundError)
+                and getattr(exc, "name", None) in _expected_absent
+            )
+            if not _is_expected_absent:
+                try:
+                    from utils.logger_config import get_module_logger
+                    get_module_logger(__name__, "App").warning(
+                        "install_runtime_bindings(quota_hooks) failed unexpectedly",
+                        exc_info=True,
+                    )
+                except Exception:
+                    pass

card-forge/index.html

@@ -0,0 +1,12 @@
+<!doctype html>
+<html lang="zh-CN">
+  <head>
+    <meta charset="UTF-8" />
+    <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+    <title>奇遇铸造机 · NEKO</title>
+  </head>
+  <body>
+    <div id="root"></div>
+    <script type="module" src="/src/main.jsx"></script>
+  </body>
+</html>