System Monitor Bot

def devops_logs_errors_tool(log_text: str) -> Dict[str, Any]:
    """
    Aggregate errors by pattern from logs(stack, ERROR, Exception, CRITICAL).
    Returns: {"top_errors":[{"pattern","count"}]}
    """
    if not log_text:
        return {"top_errors": []}
    patterns = [
        r"ERROR[: ]+([^\n]+)",
        r"Exception[: ]+([^\n]+)",
        r"CRITICAL[: ]+([^\n]+)",
    ]
    counts: Dict[str, int] = {}
    for pat in patterns:
        for m in re.finditer(pat, log_text):
            msg = m.group(1).strip()
            counts[msg] = counts.get(msg, 0) + 1
    top: List[Dict[str, Any]] = [
        {"pattern": k, "count": v} for k, v in sorted(counts.items(), key=lambda x: -x[1])
    ][:20]
    return {"top_errors": top}

def devops_latency_parse_tool(text: str) -> Dict[str, Any]:
    """
    Extract p50/p95/p99 latencies from lines like 'latency=123ms' or 'p95=250ms'.
    Returns: {"p50":..., "p95":..., "p99":..., "latency":...}
    """
    vals: Dict[str, int] = {}
    for key in ["p50", "p95", "p99", "latency"]:
        m = re.search(rf"{key}\s*=\s*(\d+)\s*ms", text or "", re.IGNORECASE)
        if m:
            vals[key.upper()] = int(m.group(1))
    return {
        "p50": vals.get("P50"),
        "p95": vals.get("P95"),
        "p99": vals.get("P99"),
        "latency": vals.get("LATENCY"),
    }