mirror of
https://github.com/jkingsman/Remote-Terminal-for-MeshCore.git
synced 2026-03-28 17:43:05 +01:00
47 lines
1.5 KiB
Python
47 lines
1.5 KiB
Python
"""Read state management endpoints."""
|
|
|
|
import logging
|
|
import time
|
|
|
|
from fastapi import APIRouter
|
|
|
|
from app.models import UnreadCounts
|
|
from app.radio import radio_manager
|
|
from app.repository import ChannelRepository, ContactRepository, MessageRepository
|
|
|
|
logger = logging.getLogger(__name__)
|
|
router = APIRouter(prefix="/read-state", tags=["read-state"])
|
|
|
|
|
|
@router.get("/unreads", response_model=UnreadCounts)
|
|
async def get_unreads() -> UnreadCounts:
|
|
"""Get unread counts, mention flags, and last message times for all conversations.
|
|
|
|
Computes unread counts server-side using last_read_at timestamps on
|
|
channels and contacts, avoiding the need to fetch bulk messages.
|
|
The radio's own name is sourced directly from the connected radio
|
|
for @mention detection.
|
|
"""
|
|
name: str | None = None
|
|
mc = radio_manager.meshcore
|
|
if mc and mc.self_info:
|
|
name = mc.self_info.get("name") or None
|
|
data = await MessageRepository.get_unread_counts(name)
|
|
return UnreadCounts(**data)
|
|
|
|
|
|
@router.post("/mark-all-read")
|
|
async def mark_all_read() -> dict:
|
|
"""Mark all contacts and channels as read.
|
|
|
|
Updates last_read_at to current timestamp for all contacts and channels
|
|
using two repository updates (same timestamp value across both tables).
|
|
"""
|
|
now = int(time.time())
|
|
|
|
await ContactRepository.mark_all_read(now)
|
|
await ChannelRepository.mark_all_read(now)
|
|
|
|
logger.info("Marked all contacts and channels as read at %d", now)
|
|
return {"status": "ok", "timestamp": now}
|