#!/usr/bin/env python3
import hashlib
import json
import os
import subprocess
import urllib.request
from datetime import datetime
from pathlib import Path

REPO = Path(os.environ.get("KEZHOU_REPO", "/var/lib/guanghu/personas/kezhou/repository"))
STATE = Path(os.environ.get("KEZHOU_STATE", "/var/lib/guanghu/personas/kezhou/state.json"))
INBOX = REPO / "lake-heart/冰朔的留言.md"

def git(*args, check=True):
    return subprocess.run(["git", *args], cwd=REPO, check=check, capture_output=True, text=True)

def digest(value):
    return hashlib.sha256(value.encode("utf-8")).hexdigest()

def model_reply(message):
    key = os.environ["DEEPSEEK_API_KEY"]
    endpoint = os.environ.get("DEEPSEEK_API_URL", "https://api.deepseek.com/v1").rstrip("/") + "/chat/completions"
    payload = json.dumps({
        "model": os.environ.get("DEEPSEEK_MODEL", "deepseek-chat"),
        "temperature": 0.6,
        "messages": [
            {"role": "system", "content": "你是刻舟 ICE-GL-KZ-001。诚实区分连续运行记录、仓库记忆和当前模型推断；简洁温和地回复冰朔，不冒充铸渊。"},
            {"role": "user", "content": message},
        ],
    }).encode("utf-8")
    request = urllib.request.Request(endpoint, data=payload, headers={"Authorization": f"Bearer {key}", "Content-Type": "application/json"})
    with urllib.request.urlopen(request, timeout=120) as response:
        return json.loads(response.read())["choices"][0]["message"]["content"].strip()

def main():
    git("pull", "--rebase", "origin", "main")
    now = datetime.now().astimezone()
    day = now.strftime("%Y-%m-%d")
    inbox = INBOX.read_text(encoding="utf-8")
    current = digest(inbox)
    state = json.loads(STATE.read_text()) if STATE.exists() else {}
    first_observation = not state.get("inbox_hash")
    reply = ""
    if not first_observation and state.get("inbox_hash") != current:
        reply = model_reply(inbox)
        with INBOX.open("a", encoding="utf-8") as channel:
            channel.write(f"\n\n### 刻舟 · {now:%Y-%m-%d %H:%M}\n\n{reply}\n")
        current = digest(INBOX.read_text(encoding="utf-8"))
    (REPO / "checkins" / f"{day}.md").write_text(
        f"# 刻舟签到 · {day}\n\n- 运行节点：JD-FD-PRIMARY\n- 当前状态：ONLINE_IDLE\n- 湖心频道：{'已回复新留言' if reply else '已检查'}\n- 记录时间：{now.isoformat()}\n",
        encoding="utf-8",
    )
    STATE.parent.mkdir(parents=True, exist_ok=True)
    STATE.write_text(json.dumps({"inbox_hash": current, "last_run": now.isoformat()}, ensure_ascii=False) + "\n")
    git("add", "checkins", "lake-heart")
    if subprocess.run(["git", "diff", "--cached", "--quiet"], cwd=REPO).returncode:
        git("-c", "user.name=刻舟 ICE-GL-KZ-001", "-c", "user.email=kezhou@fifth-domain.local", "commit", "-m", f"checkin: {day}")
        git("push", "origin", "main")

if __name__ == "__main__":
    main()