# PluginContext 新增方法签名
def register_auxiliary_task(
    self,
    name: str,                          # 任务名称（用于日志和状态追踪）
    coro: Callable[[], Awaitable[None]], # 异步任务函数
    *,
    interval: float = 60.0,             # 执行间隔（秒）
    start_after: float = 0.0,           # 首次延迟（秒），0=立即
    max_failures: int = 3,              # 连续失败上限，超限后自动暂停
    timeout: float | None = None,       # 单次执行超时（秒）
) -> str:
    """注册一个辅助后台任务，返回 task_id"""

# plugins/github_watcher/__init__.py
import asyncio
import aiohttp
from datetime import datetime
from hermes.plugin import HermesPlugin, PluginContext

class GitHubWatcherPlugin(HermesPlugin):
    """监控指定 GitHub 仓库的最新 Release"""

    name = "github_watcher"
    version = "1.0.0"

    def __init__(self):
        self.repos = [
            "NousResearch/hermes-agent",
            "openclaw/openclaw",
        ]
        self.last_checked: dict[str, str] = {}  # repo -> last tag
        self._session: aiohttp.ClientSession | None = None

    async def activate(self, ctx: PluginContext):
        # 注册辅助任务：每 1800 秒（30分钟）检查一次
        ctx.register_auxiliary_task(
            name="gh-release-poll",
            coro=self._poll_releases,
            interval=1800.0,      # 30 分钟
            start_after=10.0,     # 给 Agent 10 秒初始化时间
            max_failures=5,       # GitHub API 偶尔 429，容忍 5 次
            timeout=45.0,         # 单次检查不超过 45 秒
        )
        self._session = aiohttp.ClientSession()

    async def _poll_releases(self):
        for repo in self.repos:
            try:
                async with self._session.get(
                    f"https://api.github.com/repos/{repo}/releases/latest",
                    headers={"Accept": "application/vnd.github+json"},
                    timeout=aiohttp.ClientTimeout(total=30)
                ) as resp:
                    if resp.status != 200:
                        continue
                    data = await resp.json()
                    tag = data.get("tag_name", "")
                    prev = self.last_checked.get(repo)

                    if prev and prev != tag:
                        # 发现新 Release！写入通知文件
                        self._notify_new_release(repo, tag, data)
                    self.last_checked[repo] = tag
            except Exception:
                continue  # max_failures 会自动处理

    def _notify_new_release(self, repo: str, tag: str, data: dict):
        body = data.get("body", "")[:500]
        msg = (
            f"🚀 {repo} 新版本 {tag}\n"
            f"发布时间: {data.get('published_at', 'unknown')}\n"
            f"更新内容: {body}..."
        )
        # 写入 Agent 通知通道（可以是文件、Webhook、或内存队列）
        with open("/tmp/hermes_release_alerts.log", "a") as f:
            f.write(f"[{datetime.now().isoformat()}] {msg}\n\n")

# plugins/session_warmer/__init__.py
class SessionWarmerPlugin(HermesPlugin):
    """在 Agent 空闲时预热模型缓存，降低首次响应延迟"""

    name = "session_warmer"
    version = "1.0.0"

    async def activate(self, ctx: PluginContext):
        # 每 5 分钟发送一次轻量级 keep-alive
        ctx.register_auxiliary_task(
            name="model-keepalive",
            coro=self._keepalive,
            interval=300.0,       # 5 分钟
            start_after=60.0,     # 1 分钟后开始
            max_failures=10,      # 预热失败不影响主流程，容忍度高
            timeout=15.0,
        )

    async def _keepalive(self):
        # 发送一个轻量推理请求保持模型热缓存
        # 实际实现取决于你的模型部署方式
        ...

# plugins/source_health/__init__.py
class SourceHealthPlugin(HermesPlugin):
    """监控关键数据源的健康状态"""

    name = "source_health"
    version = "1.0.0"

    # 定义监控端点
    ENDPOINTS = [
        ("HN API", "https://hacker-news.firebaseio.com/v0/topstories.json"),
        ("GitHub API", "https://api.github.com"),
    ]

    async def activate(self, ctx: PluginContext):
        ctx.register_auxiliary_task(
            name="health-check",
            coro=self._check_all,
            interval=600.0,       # 每 10 分钟
            start_after=0.0,      # 立即开始
            max_failures=3,
            timeout=20.0,
        )

    async def _check_all(self):
        for name, url in self.ENDPOINTS:
            try:
                async with self._session.get(url, timeout=aiohttp.ClientTimeout(total=10)) as r:
                    status = "✅" if r.status == 200 else f"⚠️ {r.status}"
            except Exception as e:
                status = f"❌ {type(e).__name__}"

            # 写入健康状态文件
            with open(f"/tmp/health_{name.lower().replace(' ', '_')}.txt", "w") as f:
                f.write(f"{status}\n")

async def activate(self, ctx: PluginContext):
    self._task_id = ctx.register_auxiliary_task(...)

async def deactivate(self, ctx: PluginContext):
    if self._task_id:
        ctx.unregister_auxiliary_task(self._task_id)