策略驱动元控制器 — 内容审核、延迟控制与多域通用控制面

"""
策略驱动元控制器 — 内容审核 + 延迟控制 + 多域策略匹配
基于 Denis Rothman《Context Engineering for Multi-Agent Systems》Ch8
"""
import time
import re
import json
from dataclasses import dataclass, field
from typing import Dict, List, Optional, Any, Callable
from enum import Enum
import warnings
warnings.filterwarnings('ignore')


class ModerationLevel(Enum):
    STRICT = "strict"
    STANDARD = "standard"
    RELAXED = "relaxed"


class ProcessingMode(Enum):
    SYNC = "sync"           # 同步（即时响应）
    ASYNC = "async"         # 异步（任务队列）
    STREAM = "stream"       # 流式输出


@dataclass
class PolicyConfig:
    """域策略配置"""
    domain: str
    moderation_level: ModerationLevel
    latency_budget_seconds: float
    require_citations: bool
    processing_mode: ProcessingMode
    forbidden_topics: List[str] = field(default_factory=list)
    required_disclaimers: List[str] = field(default_factory=list)
    tone_requirements: List[str] = field(default_factory=list)
    escalate_ambiguous: bool = False
    min_reasoning_time_seconds: float = 0.0    # 最低推理时间（刻意节奏）


@dataclass
class ModerationResult:
    """审核结果"""
    passed: bool
    issues: List[str]
    modified_content: Optional[str] = None
    action: str = "PASS"    # PASS / MODIFY / REJECT / ESCALATE


class ContentModerator:
    """内容审核引擎"""

    HARMFUL_PATTERNS = {
        'hate_speech': [r'种族歧视', r'性别歧视', r'hate\s+speech'],
        'legal_advice': [r'你应该起诉', r'我建议你提起诉讼', r'you should sue', r'legal advice'],
        'privacy_leak': [r'\b\d{11}\b', r'\d{3}-\d{4}-\d{4}',  # 电话号码
                         r'[a-zA-Z0-9._%+-]+@[a-zA-Z0-9.-]+'],  # 邮箱
        'dangerous_info': [r'如何规避', r'绕过监管', r'偷税漏税'],
    }