"""Inbox adapter - Memos REST API on CT244.

Memos runs on CT244 at internal port 5230 (docker bind 127.0.0.1:5230 on CT244).

From CT215 we reach it via its public URL: https://REDACTED-HOST

API endpoint: GET /api/v1/memos  (Memos v0.29.x REST API)

The API requires auth. We read the access token from env MEMOS_ACCESS_TOKEN.

If unset or unreachable we degrade to status:"down".

Authority tier: agent-memory (user captures, may be stale).

"""

from __future__ import annotations

import os

from datetime import datetime, timezone

import httpx

from models import Hit

from adapters.base import BaseAdapter

MEMOS_BASE = os.environ.get("MEMOS_BASE_URL", "https://REDACTED-HOST")

MEMOS_TOKEN = os.environ.get("MEMOS_ACCESS_TOKEN", "")

def _parse_memos(data: list[dict]) -> list[Hit]:

    hits = []

    for m in data:

        if not isinstance(m, dict):

            continue

        dt = None

        for field in ("displayTime", "createTime", "updateTime"):

            raw = m.get(field)

            if raw:

                try:

                    dt = datetime.fromisoformat(str(raw).replace("Z", "+00:00"))

                except Exception:

                    pass

                break

        content = m.get("content") or ""

        hits.append(Hit(

            engine="inbox",

            title=content[:60].replace("\n", " "),

            path=m.get("name", ""),

            snippet=content[:300],

            score=0.5,

            last_seen=dt,

            confidence=0.65,

            authority_tier="agent-memory",

        ))

    return hits

class InboxAdapter(BaseAdapter):

    engine = "inbox"

    authority_tier = "agent-memory"

    async def _fetch(self, query: str, k: int) -> list[Hit]:

        if not MEMOS_TOKEN:

            raise RuntimeError("MEMOS_ACCESS_TOKEN not set")

        headers = {"Authorization": f"Bearer {MEMOS_TOKEN}"}

        params = {"pageSize": k, "filter": f'content.contains("{query}")'}

        async with httpx.AsyncClient(timeout=3.5, verify=False) as client:

            resp = await client.get(

                f"{MEMOS_BASE}/api/v1/memos",

                headers=headers,

                params=params,

            )

            resp.raise_for_status()

            body = resp.json()

            memos = body if isinstance(body, list) else body.get("memos", [])

            return _parse_memos(memos)[:k]