Upload 3 files

ace_system.py

@@ -0,0 +1,703 @@
+"""
+ACE (Agentic Context Engineering) System with Ollama
+A self-improving AI agent system using local LLMs
+"""
+
+import json
+import os
+from datetime import datetime
+from typing import List, Dict, Optional, Literal
+from dataclasses import dataclass, asdict
+from enum import Enum
+import requests
+
+
+# ============================================================================
+# CONFIGURATION
+# ============================================================================
+
+class Config:
+    """System configuration"""
+    OLLAMA_BASE_URL = "http://localhost:11434"
+    GENERATOR_MODEL = "aya"  # Fast for generation
+    REFLECTOR_MODEL = "aya"  # Can use same or different
+    CURATOR_MODEL = "aya"    # Can use same or different
+    PLAYBOOK_PATH = "emergency_playbook.json"
+    TEMPERATURE = 0.7
+    MAX_TOKENS = 2000
+# Update Config:
+# class Config:
+#     """System configuration"""
+#     OLLAMA_BASE_URL = "http://localhost:11434"
+#     GENERATOR_MODEL = "llama3.1"
+#     REFLECTOR_MODEL = "llama3.1"
+#     CURATOR_MODEL = "llama3.1"
+#     PLAYBOOK_PATH = "emergency_playbook.json"
+#     TEMPERATURE = 0.3
+#     MAX_TOKENS = 4000  # Increased
+
+# ============================================================================
+# DATA MODELS
+# ============================================================================
+
+class TagType(str, Enum):
+    HELPFUL = "helpful"
+    HARMFUL = "harmful"
+    NEUTRAL = "neutral"
+
+
+@dataclass
+class Bullet:
+    """A knowledge item in the playbook"""
+    id: str
+    section: str
+    content: str
+    helpful: int = 0
+    harmful: int = 0
+    neutral: int = 0
+    created_at: str = ""
+    updated_at: str = ""
+    
+    def __post_init__(self):
+        if not self.created_at:
+            self.created_at = datetime.now().isoformat()
+        if not self.updated_at:
+            self.updated_at = datetime.now().isoformat()
+    
+    def add_tag(self, tag: TagType):
+        """Add a tag vote to this bullet"""
+        if tag == TagType.HELPFUL:
+            self.helpful += 1
+        elif tag == TagType.HARMFUL:
+            self.harmful += 1
+        else:
+            self.neutral += 1
+        self.updated_at = datetime.now().isoformat()
+    
+    def score(self) -> float:
+        """Calculate bullet quality score"""
+        total = self.helpful + self.harmful + self.neutral
+        if total == 0:
+            return 0.0
+        return (self.helpful - self.harmful) / total
+
+
+@dataclass
+class BulletTag:
+    """Tag assignment for a bullet"""
+    bullet_id: str
+    tag: TagType
+    reason: str
+
+
+@dataclass
+class GeneratorOutput:
+    """Output from the Generator agent"""
+    reasoning: List[str]
+    bullet_ids: List[str]
+    final_answer: str
+
+
+@dataclass
+class Reflection:
+    """Output from the Reflector agent"""
+    answer_quality: str
+    strengths: List[str]
+    weaknesses: List[str]
+    bullet_tags: List[BulletTag]
+
+
+@dataclass
+class DeltaOperation:
+    """A single playbook modification operation"""
+    type: Literal["ADD", "UPDATE", "REMOVE"]
+    section: str
+    content: Optional[str] = None
+    bullet_id: Optional[str] = None
+
+
+@dataclass
+class DeltaBatch:
+    """Batch of playbook modifications"""
+    reasoning: str
+    operations: List[DeltaOperation]
+
+
+# ============================================================================
+# PLAYBOOK MANAGEMENT
+# ============================================================================
+
+class Playbook:
+    """Manages the evolving knowledge base"""
+    
+    def __init__(self):
+        self.bullets: Dict[str, Bullet] = {}
+        self.sections: Dict[str, List[str]] = {}
+        self._next_id = 1
+    
+    def add_bullet(self, section: str, content: str) -> str:
+        """Add a new bullet to the playbook"""
+        bullet_id = f"B{self._next_id:04d}"
+        self._next_id += 1
+        
+        bullet = Bullet(
+            id=bullet_id,
+            section=section,
+            content=content
+        )
+        self.bullets[bullet_id] = bullet
+        
+        if section not in self.sections:
+            self.sections[section] = []
+        self.sections[section].append(bullet_id)
+        
+        return bullet_id
+    
+    def update_bullet(self, bullet_id: str, content: str):
+        """Update an existing bullet"""
+        if bullet_id in self.bullets:
+            self.bullets[bullet_id].content = content
+            self.bullets[bullet_id].updated_at = datetime.now().isoformat()
+    
+    def remove_bullet(self, bullet_id: str):
+        """Remove a bullet from the playbook"""
+        if bullet_id in self.bullets:
+            bullet = self.bullets[bullet_id]
+            section = bullet.section
+            
+            del self.bullets[bullet_id]
+            if section in self.sections:
+                self.sections[section] = [
+                    bid for bid in self.sections[section] if bid != bullet_id
+                ]
+    
+    def update_bullet_tag(self, bullet_id: str, tag: TagType):
+        """Add a tag to a bullet"""
+        if bullet_id in self.bullets:
+            self.bullets[bullet_id].add_tag(tag)
+    
+    def apply_delta(self, delta: DeltaBatch):
+        """Apply a batch of modifications"""
+        for op in delta.operations:
+            if op.type == "ADD" and op.content:
+                self.add_bullet(op.section, op.content)
+            elif op.type == "UPDATE" and op.bullet_id and op.content:
+                self.update_bullet(op.bullet_id, op.content)
+            elif op.type == "REMOVE" and op.bullet_id:
+                self.remove_bullet(op.bullet_id)
+    
+    def as_prompt(self) -> str:
+        """Format playbook for inclusion in prompts"""
+        if not self.bullets:
+            return "No knowledge bullets available yet."
+        
+        lines = ["# Knowledge Playbook", ""]
+        for section, bullet_ids in sorted(self.sections.items()):
+            lines.append(f"## {section}")
+            for bid in bullet_ids:
+                bullet = self.bullets[bid]
+                score = bullet.score()
+                lines.append(f"- [{bid}] {bullet.content} (score: {score:.2f})")
+            lines.append("")
+        
+        return "\n".join(lines)
+    
+    def stats(self) -> Dict:
+        """Get playbook statistics"""
+        total_bullets = len(self.bullets)
+        total_tags = sum(b.helpful + b.harmful + b.neutral for b in self.bullets.values())
+        avg_score = sum(b.score() for b in self.bullets.values()) / total_bullets if total_bullets > 0 else 0
+        
+        return {
+            "total_bullets": total_bullets,
+            "total_sections": len(self.sections),
+            "total_tags": total_tags,
+            "average_score": avg_score
+        }
+    
+    def save(self, filepath: str):
+        """Save playbook to disk"""
+        data = {
+            "bullets": {bid: asdict(b) for bid, b in self.bullets.items()},
+            "sections": self.sections,
+            "next_id": self._next_id
+        }
+        with open(filepath, 'w') as f:
+            json.dump(data, f, indent=2)
+    
+    @classmethod
+    def load(cls, filepath: str) -> 'Playbook':
+        """Load playbook from disk"""
+        playbook = cls()
+        if os.path.exists(filepath):
+            with open(filepath, 'r') as f:
+                data = json.load(f)
+            
+            playbook.bullets = {
+                bid: Bullet(**bullet_data) 
+                for bid, bullet_data in data.get("bullets", {}).items()
+            }
+            playbook.sections = data.get("sections", {})
+            playbook._next_id = data.get("next_id", 1)
+        
+        return playbook
+
+
+# ============================================================================
+# OLLAMA CLIENT
+# ============================================================================
+
+class OllamaClient:
+    """Client for interacting with Ollama"""
+    
+    def __init__(self, base_url: str = Config.OLLAMA_BASE_URL):
+        self.base_url = base_url
+    def generate(
+        self, 
+        model: str, 
+        prompt: str, 
+        system: Optional[str] = None,
+        temperature: float = Config.TEMPERATURE,
+        max_tokens: int = Config.MAX_TOKENS
+    ) -> str:
+        """Generate completion from Ollama"""
+        url = f"{self.base_url}/api/generate"
+        
+        payload = {
+            "model": model,
+            "prompt": prompt,
+            "stream": False,
+            "options": {
+                "temperature": temperature,
+                "num_predict": max_tokens,
+                "num_ctx": 8192  # Added: Larger context window
+            }
+        }
+        
+        if system:
+            payload["system"] = system
+        
+        try:
+            response = requests.post(url, json=payload, timeout=180)  # Increased timeout
+            response.raise_for_status()
+            return response.json()["response"]
+        except Exception as e:
+            print(f"Error calling Ollama: {e}")
+            return ""
+    
+    def check_health(self) -> bool:
+        """Check if Ollama is running"""
+        try:
+            response = requests.get(f"{self.base_url}/api/tags", timeout=5)
+            return response.status_code == 200
+        except:
+            return False
+
+
+# ============================================================================
+# AGENTS
+# ============================================================================
+
+class StateInitializer:
+    """Initializes session state"""
+    
+    def execute(self, user_query: str, playbook: Playbook) -> Dict:
+        """Initialize state for a new query"""
+        return {
+            "user_query": user_query,
+            "playbook": playbook,
+            "ground_truth": None,
+            "generator_output": None,
+            "reflector_output": None,
+            "curator_output": None
+        }
+
+class Generator:
+    """Generates answers using the playbook"""
+    
+    def __init__(self, client: OllamaClient):
+        self.client = client
+    def execute(self, state: Dict) -> GeneratorOutput:
+        """Generate an answer with reasoning"""
+        user_query = state["user_query"]
+        playbook = state["playbook"]
+        
+        # First, find relevant bullets
+        bullet_context = []
+        for bid, bullet in playbook.bullets.items():
+            bullet_context.append(f"[{bid}] {bullet.content}")
+        
+        knowledge = "\n".join(bullet_context[:50])  # Use up to 50 most relevant
+        
+        # Simple, direct prompt
+        prompt = f"""You are an emergency response expert.
+
+    Question: {user_query}
+
+    Available Knowledge:
+    {knowledge}
+
+    Provide a COMPLETE, detailed answer with ALL necessary steps. Be thorough and specific."""
+        
+        response = self.client.generate(
+            model=Config.GENERATOR_MODEL,
+            prompt=prompt,
+            system="Provide complete, detailed emergency instructions. Never truncate your answer.",
+            temperature=0.3,
+            max_tokens=4000
+        )
+        
+        # Find relevant bullet IDs in response
+        used_bullets = []
+        if response and isinstance(response, str):
+            response_lower = response.lower()
+            for bid, bullet in playbook.bullets.items():
+                bullet_preview = str(bullet.content)[:30].lower()
+                if bid in response or bullet_preview in response_lower:
+                    used_bullets.append(bid)
+        
+        return GeneratorOutput(
+            reasoning=["Analyzed emergency situation", "Found relevant protocols", "Provided complete response"],
+            bullet_ids=used_bullets,
+            final_answer=response if response else "Unable to generate response"
+        )
+
+class Reflector:
+    """Reflects on generated output and tags bullets"""
+    
+    def __init__(self, client: OllamaClient):
+        self.client = client
+    
+    def execute(self, state: Dict) -> Reflection:
+        """Reflect on the generator's output"""
+        user_query = state["user_query"]
+        gen_output = state["generator_output"]
+        playbook = state["playbook"]
+        
+        system_prompt = """You are a critical evaluator that assesses answer quality and tags knowledge bullets.
+
+INSTRUCTIONS:
+1. Evaluate the quality of the generated answer
+2. Identify what worked well and what didn't
+3. Tag each referenced bullet as:
+   - "helpful": Contributed positively to the answer
+   - "harmful": Led to errors or poor quality
+   - "neutral": Was referenced but had minimal impact
+
+Respond in JSON format:
+{
+  "answer_quality": "excellent|good|fair|poor",
+  "strengths": ["strength 1", "strength 2", ...],
+  "weaknesses": ["weakness 1", "weakness 2", ...],
+  "bullet_tags": [
+    {"bullet_id": "B0001", "tag": "helpful", "reason": "why"},
+    ...
+  ]
+}"""
+        
+        # Build bullet context
+        bullet_context = "\n".join([
+            f"[{bid}] {playbook.bullets[bid].content}" 
+            for bid in gen_output.bullet_ids 
+            if bid in playbook.bullets
+        ])
+        
+        prompt = f"""# User Query
+{user_query}
+
+# Referenced Bullets
+{bullet_context if bullet_context else "None"}
+
+# Generated Answer
+Reasoning: {gen_output.reasoning}
+Final Answer: {gen_output.final_answer}
+
+# Your Evaluation (JSON only):"""
+        
+        response = self.client.generate(
+            model=Config.REFLECTOR_MODEL,
+            prompt=prompt,
+            system=system_prompt
+        )
+        
+        # Parse JSON response
+        try:
+            if "```json" in response:
+                response = response.split("```json")[1].split("```")[0].strip()
+            elif "```" in response:
+                response = response.split("```")[1].split("```")[0].strip()
+            
+            data = json.loads(response)
+            bullet_tags = [
+                BulletTag(
+                    bullet_id=bt["bullet_id"],
+                    tag=TagType(bt["tag"]),
+                    reason=bt.get("reason", "")
+                )
+                for bt in data.get("bullet_tags", [])
+            ]
+            
+            return Reflection(
+                answer_quality=data.get("answer_quality", "unknown"),
+                strengths=data.get("strengths", []),
+                weaknesses=data.get("weaknesses", []),
+                bullet_tags=bullet_tags
+            )
+        except json.JSONDecodeError as e:
+            print(f"JSON parse error: {e}")
+            print(f"Raw response: {response}")
+            return Reflection(
+                answer_quality="error",
+                strengths=[],
+                weaknesses=["Failed to parse reflection"],
+                bullet_tags=[]
+            )
+
+
+class Curator:
+    """Curates the playbook based on reflections"""
+    
+    def __init__(self, client: OllamaClient):
+        self.client = client
+    
+    def execute(self, state: Dict) -> DeltaBatch:
+        """Generate playbook modifications"""
+        user_query = state["user_query"]
+        reflection = state["reflector_output"]
+        playbook = state["playbook"]
+        
+        system_prompt = """You are a knowledge curator that improves the playbook.
+
+INSTRUCTIONS:
+1. Review the reflection and current playbook
+2. Decide what changes to make:
+   - ADD: Create new bullets for missing knowledge
+   - UPDATE: Improve existing bullets
+   - REMOVE: Delete harmful or redundant bullets
+3. Focus on bullets with consistent tags
+
+Respond in JSON format:
+{
+  "reasoning": "Why these changes improve the playbook",
+  "operations": [
+    {"type": "ADD", "section": "Section Name", "content": "New bullet content"},
+    {"type": "UPDATE", "section": "Section Name", "bullet_id": "B0001", "content": "Updated content"},
+    {"type": "REMOVE", "section": "Section Name", "bullet_id": "B0002"}
+  ]
+}"""
+        
+        # Build tag summary
+        tag_summary = "\n".join([
+            f"[{bt.bullet_id}] {bt.tag.value}: {bt.reason}"
+            for bt in reflection.bullet_tags
+        ])
+        
+        prompt = f"""# Query Context
+User Query: {user_query}
+
+# Reflection Summary
+Quality: {reflection.answer_quality}
+Strengths: {reflection.strengths}
+Weaknesses: {reflection.weaknesses}
+
+# Bullet Tags
+{tag_summary if tag_summary else "No bullets were tagged"}
+
+# Current Playbook Stats
+{json.dumps(playbook.stats(), indent=2)}
+
+# Your Curation Plan (JSON only):"""
+        
+        response = self.client.generate(
+            model=Config.CURATOR_MODEL,
+            prompt=prompt,
+            system=system_prompt
+        )
+        
+        # Parse JSON response
+        try:
+            if "```json" in response:
+                response = response.split("```json")[1].split("```")[0].strip()
+            elif "```" in response:
+                response = response.split("```")[1].split("```")[0].strip()
+            
+            data = json.loads(response)
+            operations = [
+                DeltaOperation(
+                    type=op["type"],
+                    section=op.get("section", "General"),
+                    content=op.get("content"),
+                    bullet_id=op.get("bullet_id")
+                )
+                for op in data.get("operations", [])
+            ]
+            
+            return DeltaBatch(
+                reasoning=data.get("reasoning", ""),
+                operations=operations
+            )
+        except json.JSONDecodeError as e:
+            print(f"JSON parse error: {e}")
+            print(f"Raw response: {response}")
+            return DeltaBatch(
+                reasoning="Error parsing curation plan",
+                operations=[]
+            )
+
+
+# ============================================================================
+# ACE ORCHESTRATOR
+# ============================================================================
+
+class ACEOrchestrator:
+    """Orchestrates the full ACE cycle"""
+    
+    def __init__(self, playbook_path: str = Config.PLAYBOOK_PATH):
+        self.client = OllamaClient()
+        self.playbook = Playbook.load(playbook_path)
+        self.playbook_path = playbook_path
+        
+        self.state_initializer = StateInitializer()
+        self.generator = Generator(self.client)
+        self.reflector = Reflector(self.client)
+        self.curator = Curator(self.client)
+    
+    def run_cycle(self, user_query: str, verbose: bool = True) -> Dict:
+        """Run one complete ACE cycle"""
+        
+        if verbose:
+            print("\n" + "="*60)
+            print("ACE CYCLE START")
+            print("="*60)
+        
+        # 1. Initialize State
+        if verbose:
+            print("\n[1] Initializing state...")
+        state = self.state_initializer.execute(user_query, self.playbook)
+        
+        # 2. Generate Answer
+        if verbose:
+            print("[2] Generating answer...")
+        gen_output = self.generator.execute(state)
+        state["generator_output"] = gen_output
+        
+        if verbose:
+            print(f"\n--- GENERATOR OUTPUT ---")
+            print(f"Reasoning: {gen_output.reasoning}")
+            print(f"Bullets Used: {gen_output.bullet_ids}")
+            print(f"Answer: {gen_output.final_answer}")
+        
+        # 3. Reflect
+        if verbose:
+            print("\n[3] Reflecting on output...")
+        reflection = self.reflector.execute(state)
+        state["reflector_output"] = reflection
+        
+        # Apply tags to playbook
+        for bt in reflection.bullet_tags:
+            self.playbook.update_bullet_tag(bt.bullet_id, bt.tag)
+        
+        if verbose:
+            print(f"\n--- REFLECTION ---")
+            print(f"Quality: {reflection.answer_quality}")
+            print(f"Strengths: {reflection.strengths}")
+            print(f"Weaknesses: {reflection.weaknesses}")
+            print(f"Tags Applied: {len(reflection.bullet_tags)}")
+        
+        # 4. Curate Playbook
+        if verbose:
+            print("\n[4] Curating playbook...")
+        delta = self.curator.execute(state)
+        state["curator_output"] = delta
+        
+        # Apply delta to playbook
+        self.playbook.apply_delta(delta)
+        
+        if verbose:
+            print(f"\n--- CURATION ---")
+            print(f"Reasoning: {delta.reasoning}")
+            print(f"Operations: {len(delta.operations)}")
+            for op in delta.operations:
+                print(f"  - {op.type}: {op.section}")
+        
+        # 5. Save Playbook
+        self.playbook.save(self.playbook_path)
+        
+        if verbose:
+            print(f"\n--- PLAYBOOK STATS ---")
+            stats = self.playbook.stats()
+            for key, value in stats.items():
+                print(f"  {key}: {value}")
+            
+            print("\n" + "="*60)
+            print("ACE CYCLE COMPLETE")
+            print("="*60 + "\n")
+        
+        return {
+            "answer": gen_output.final_answer,
+            "quality": reflection.answer_quality,
+            "operations": len(delta.operations),
+            "stats": self.playbook.stats()
+        }
+
+
+# ============================================================================
+# MAIN ENTRY POINT
+# ============================================================================
+
+def main():
+    """Main entry point for the ACE system"""
+    
+    print("ACE System with Ollama")
+    print("=" * 60)
+    
+    # Check Ollama connection
+    client = OllamaClient()
+    if not client.check_health():
+        print("ERROR: Cannot connect to Ollama!")
+        print(f"Make sure Ollama is running at {Config.OLLAMA_BASE_URL}")
+        print("Start it with: ollama serve")
+        return
+    
+    print("✓ Connected to Ollama")
+    
+    # Initialize orchestrator
+    ace = ACEOrchestrator()
+    print(f"✓ Loaded playbook: {ace.playbook.stats()}")
+    
+    # Interactive loop
+    print("\nACE System Ready! (Type 'quit' to exit, 'stats' for playbook stats)")
+    print("-" * 60)
+    
+    while True:
+        try:
+            user_input = input("\nYour query: ").strip()
+            
+            if not user_input:
+                continue
+            
+            if user_input.lower() == 'quit':
+                print("Goodbye!")
+                break
+            
+            if user_input.lower() == 'stats':
+                print("\nPlaybook Statistics:")
+                print(json.dumps(ace.playbook.stats(), indent=2))
+                print("\nPlaybook Content:")
+                print(ace.playbook.as_prompt())
+                continue
+            
+            # Run ACE cycle
+            result = ace.run_cycle(user_input, verbose=True)
+            
+        except KeyboardInterrupt:
+            print("\n\nGoodbye!")
+            break
+        except Exception as e:
+            print(f"\nError: {e}")
+            import traceback
+            traceback.print_exc()
+
+
+if __name__ == "__main__":
+    main()

app.py

@@ -0,0 +1,804 @@
+"""
+ACE System - Streamlit Web Interface
+Self-improving AI agent with beautiful UI
+"""
+
+import streamlit as st
+import json
+import os
+from datetime import datetime
+from typing import List, Dict, Optional, Literal
+from dataclasses import dataclass, asdict
+from enum import Enum
+import requests
+import plotly.graph_objects as go
+import plotly.express as px
+from collections import defaultdict
+
+# ============================================================================
+# CONFIGURATION
+# ============================================================================
+
+class Config:
+    """System configuration"""
+    OLLAMA_BASE_URL = "http://localhost:11434"
+    # GENERATOR_MODEL = "llama3.2:3b"
+    # REFLECTOR_MODEL = "llama3.2:3b"
+    # CURATOR_MODEL = "llama3.2:3b"
+    GENERATOR_MODEL = "aya"
+    REFLECTOR_MODEL = "aya"
+    CURATOR_MODEL = "aya"
+    PLAYBOOK_PATH = "emergency_playbook.json"
+    TEMPERATURE = 0.3
+    MAX_TOKENS = 4000
+
+
+class Language:
+    """Language settings"""
+    MESSAGES = {
+        "en": {
+            "title": "🤖 ACE - Self-Improving AI Agent",
+            "subtitle": "Agentic Context Engineering System",
+            "sidebar_title": "⚙️ Settings",
+            "language": "Language",
+            "model_settings": "Model Settings",
+            "playbook_info": "📚 Playbook Information",
+            "total_bullets": "Total Knowledge Items",
+            "sections": "Sections",
+            "avg_score": "Average Quality Score",
+            "total_tags": "Total Evaluations",
+            "query_input": "💬 Ask me anything about emergencies...",
+            "ask_button": "🚀 Get Answer",
+            "clear_button": "🗑️ Clear History",
+            "export_button": "💾 Export Playbook",
+            "import_button": "📥 Import Playbook",
+            "chat_history": "💬 Chat History",
+            "answer": "Answer",
+            "quality": "Quality",
+            "reasoning": "Reasoning Process",
+            "bullets_used": "Knowledge Used",
+            "improvements": "System Improvements",
+            "playbook_viz": "📊 Knowledge Evolution",
+            "section_dist": "Knowledge Distribution by Section",
+            "quality_trend": "Quality Score Trends",
+            "connection_error": "❌ Cannot connect to Ollama!",
+            "connection_success": "✅ Connected to Ollama",
+            "processing": "🔄 Processing your query...",
+            "generator_phase": "Generating answer...",
+            "reflector_phase": "Evaluating quality...",
+            "curator_phase": "Learning improvements...",
+            "complete": "✅ Complete!",
+        },
+        "ar": {
+            "title": "🤖 ACE - نظام ذكي ذاتي التطوير",
+            "subtitle": "نظام هندسة السياق الوكيل",
+            "sidebar_title": "⚙️ الإعدادات",
+            "language": "اللغة",
+            "model_settings": "إعدادات النموذج",
+            "playbook_info": "📚 معلومات دفتر المعرفة",
+            "total_bullets": "إجمالي عناصر المعرفة",
+            "sections": "الأقسام",
+            "avg_score": "متوسط درجة الجودة",
+            "total_tags": "إجمالي التقييمات",
+            "query_input": "💬 اسألني أي شيء عن حالات الطوارئ...",
+            "ask_button": "🚀 احصل على إجابة",
+            "clear_button": "🗑️ مسح السجل",
+            "export_button": "💾 تصدير دفتر المعرفة",
+            "import_button": "📥 استيراد دفتر المعرفة",
+            "chat_history": "💬 سجل المحادثة",
+            "answer": "الإجابة",
+            "quality": "الجودة",
+            "reasoning": "عملية التفكير",
+            "bullets_used": "المعرفة المستخدمة",
+            "improvements": "تحسينات النظام",
+            "playbook_viz": "📊 تطور المعرفة",
+            "section_dist": "توزيع المعرفة حسب القسم",
+            "quality_trend": "اتجاهات درجة الجودة",
+            "connection_error": "❌ لا يمكن الاتصال بـ Ollama!",
+            "connection_success": "✅ تم الاتصال بـ Ollama",
+            "processing": "🔄 جاري معالجة استفسارك...",
+            "generator_phase": "توليد الإجابة...",
+            "reflector_phase": "تقييم الجودة...",
+            "curator_phase": "تعلم التحسينات...",
+            "complete": "✅ اكتمل!",
+        }
+    }
+    
+    @staticmethod
+    def get(key, lang="en"):
+        return Language.MESSAGES.get(lang, Language.MESSAGES["en"]).get(key, key)
+
+
+# ============================================================================
+# DATA MODELS
+# ============================================================================
+
+class TagType(str, Enum):
+    HELPFUL = "helpful"
+    HARMFUL = "harmful"
+    NEUTRAL = "neutral"
+
+
+@dataclass
+class Bullet:
+    id: str
+    section: str
+    content: str
+    helpful: int = 0
+    harmful: int = 0
+    neutral: int = 0
+    created_at: str = ""
+    updated_at: str = ""
+    
+    def __post_init__(self):
+        if not self.created_at:
+            self.created_at = datetime.now().isoformat()
+        if not self.updated_at:
+            self.updated_at = datetime.now().isoformat()
+    
+    def add_tag(self, tag: TagType):
+        if tag == TagType.HELPFUL:
+            self.helpful += 1
+        elif tag == TagType.HARMFUL:
+            self.harmful += 1
+        else:
+            self.neutral += 1
+        self.updated_at = datetime.now().isoformat()
+    
+    def score(self) -> float:
+        total = self.helpful + self.harmful + self.neutral
+        if total == 0:
+            return 0.0
+        return (self.helpful - self.harmful) / total
+
+
+@dataclass
+class BulletTag:
+    bullet_id: str
+    tag: TagType
+    reason: str
+
+
+@dataclass
+class GeneratorOutput:
+    reasoning: List[str]
+    bullet_ids: List[str]
+    final_answer: str
+
+
+@dataclass
+class Reflection:
+    answer_quality: str
+    strengths: List[str]
+    weaknesses: List[str]
+    bullet_tags: List[BulletTag]
+
+
+@dataclass
+class DeltaOperation:
+    type: Literal["ADD", "UPDATE", "REMOVE"]
+    section: str
+    content: Optional[str] = None
+    bullet_id: Optional[str] = None
+
+
+@dataclass
+class DeltaBatch:
+    reasoning: str
+    operations: List[DeltaOperation]
+
+
+# ============================================================================
+# PLAYBOOK MANAGEMENT
+# ============================================================================
+
+class Playbook:
+    def __init__(self):
+        self.bullets: Dict[str, Bullet] = {}
+        self.sections: Dict[str, List[str]] = {}
+        self._next_id = 1
+    
+    def add_bullet(self, section: str, content: str) -> str:
+        bullet_id = f"B{self._next_id:04d}"
+        self._next_id += 1
+        
+        bullet = Bullet(id=bullet_id, section=section, content=content)
+        self.bullets[bullet_id] = bullet
+        
+        if section not in self.sections:
+            self.sections[section] = []
+        self.sections[section].append(bullet_id)
+        
+        return bullet_id
+    
+    def update_bullet(self, bullet_id: str, content: str):
+        if bullet_id in self.bullets:
+            self.bullets[bullet_id].content = content
+            self.bullets[bullet_id].updated_at = datetime.now().isoformat()
+    
+    def remove_bullet(self, bullet_id: str):
+        if bullet_id in self.bullets:
+            bullet = self.bullets[bullet_id]
+            section = bullet.section
+            
+            del self.bullets[bullet_id]
+            if section in self.sections:
+                self.sections[section] = [
+                    bid for bid in self.sections[section] if bid != bullet_id
+                ]
+    
+    def update_bullet_tag(self, bullet_id: str, tag: TagType):
+        if bullet_id in self.bullets:
+            self.bullets[bullet_id].add_tag(tag)
+    
+    def apply_delta(self, delta: DeltaBatch):
+        for op in delta.operations:
+            if op.type == "ADD" and op.content:
+                self.add_bullet(op.section, op.content)
+            elif op.type == "UPDATE" and op.bullet_id and op.content:
+                self.update_bullet(op.bullet_id, op.content)
+            elif op.type == "REMOVE" and op.bullet_id:
+                self.remove_bullet(op.bullet_id)
+    
+    def as_prompt(self) -> str:
+        if not self.bullets:
+            return "No knowledge bullets available yet."
+        
+        lines = ["# Knowledge Playbook", ""]
+        for section, bullet_ids in sorted(self.sections.items()):
+            lines.append(f"## {section}")
+            for bid in bullet_ids:
+                bullet = self.bullets[bid]
+                score = bullet.score()
+                lines.append(f"- [{bid}] {bullet.content} (score: {score:.2f})")
+            lines.append("")
+        
+        return "\n".join(lines)
+    
+    def stats(self) -> Dict:
+        total_bullets = len(self.bullets)
+        total_tags = sum(b.helpful + b.harmful + b.neutral for b in self.bullets.values())
+        avg_score = sum(b.score() for b in self.bullets.values()) / total_bullets if total_bullets > 0 else 0
+        
+        return {
+            "total_bullets": total_bullets,
+            "total_sections": len(self.sections),
+            "total_tags": total_tags,
+            "average_score": avg_score
+        }
+    
+    def save(self, filepath: str):
+        data = {
+            "bullets": {bid: asdict(b) for bid, b in self.bullets.items()},
+            "sections": self.sections,
+            "next_id": self._next_id
+        }
+        with open(filepath, 'w') as f:
+            json.dump(data, f, indent=2)
+    
+    @classmethod
+    def load(cls, filepath: str) -> 'Playbook':
+        playbook = cls()
+        if os.path.exists(filepath):
+            with open(filepath, 'r') as f:
+                data = json.load(f)
+            
+            playbook.bullets = {
+                bid: Bullet(**bullet_data) 
+                for bid, bullet_data in data.get("bullets", {}).items()
+            }
+            playbook.sections = data.get("sections", {})
+            playbook._next_id = data.get("next_id", 1)
+        
+        return playbook
+
+
+# ============================================================================
+# OLLAMA CLIENT
+# ============================================================================
+
+class OllamaClient:
+    def __init__(self, base_url: str = Config.OLLAMA_BASE_URL):
+        self.base_url = base_url
+    
+    def generate(
+        self, 
+        model: str, 
+        prompt: str, 
+        system: Optional[str] = None,
+        temperature: float = Config.TEMPERATURE,
+        max_tokens: int = Config.MAX_TOKENS
+    ) -> str:
+        url = f"{self.base_url}/api/generate"
+        
+        payload = {
+            "model": model,
+            "prompt": prompt,
+            "stream": False,
+            "options": {
+                "temperature": temperature,
+                "num_predict": max_tokens,
+                "num_ctx": 8192
+            }
+        }
+        
+        if system:
+            payload["system"] = system
+        
+        try:
+            response = requests.post(url, json=payload, timeout=180)
+            response.raise_for_status()
+            return response.json()["response"]
+        except Exception as e:
+            return f"Error: {e}"
+    
+    def check_health(self) -> bool:
+        try:
+            response = requests.get(f"{self.base_url}/api/tags", timeout=5)
+            return response.status_code == 200
+        except:
+            return False
+
+
+# ============================================================================
+# AGENTS
+# ============================================================================
+
+class StateInitializer:
+    def execute(self, user_query: str, playbook: Playbook) -> Dict:
+        return {
+            "user_query": user_query,
+            "playbook": playbook,
+            "ground_truth": None,
+            "generator_output": None,
+            "reflector_output": None,
+            "curator_output": None
+        }
+
+
+class Generator:
+    def __init__(self, client: OllamaClient):
+        self.client = client
+    
+    def execute(self, state: Dict, lang: str = "en") -> GeneratorOutput:
+        user_query = state["user_query"]
+        playbook = state["playbook"]
+        
+        bullet_context = []
+        for bid, bullet in playbook.bullets.items():
+            bullet_context.append(f"[{bid}] {bullet.content}")
+        
+        knowledge = "\n".join(bullet_context[:50])
+        
+        if lang == "ar":
+            system_prompt = "أنت خبير في الاستجابة للطوارئ. قدم تعليمات كاملة ومفصلة. لا تختصر إجابتك أبداً."
+            prompt = f"""أنت خبير في الاستجابة للطوارئ.
+
+السؤال: {user_query}
+
+المعرفة المتاحة:
+{knowledge}
+
+قدم إجابة كاملة ومفصلة مع جميع الخطوات الضرورية. كن دقيقاً وشاملاً."""
+        else:
+            system_prompt = "You are an emergency response expert. Provide complete, detailed emergency instructions. Never truncate your answer."
+            prompt = f"""You are an emergency response expert.
+
+Question: {user_query}
+
+Available Knowledge:
+{knowledge}
+
+Provide a COMPLETE, detailed answer with ALL necessary steps. Be thorough and specific."""
+        
+        response = self.client.generate(
+            model=Config.GENERATOR_MODEL,
+            prompt=prompt,
+            system=system_prompt,
+            temperature=0.3,
+            max_tokens=4000
+        )
+        
+        used_bullets = []
+        if response and isinstance(response, str):
+            response_lower = response.lower()
+            for bid, bullet in playbook.bullets.items():
+                bullet_preview = str(bullet.content)[:30].lower()
+                if bid in response or bullet_preview in response_lower:
+                    used_bullets.append(bid)
+        
+        return GeneratorOutput(
+            reasoning=["Analyzed emergency situation", "Found relevant protocols", "Provided complete response"],
+            bullet_ids=used_bullets,
+            final_answer=response if response else "Unable to generate response"
+        )
+
+
+class Reflector:
+    def __init__(self, client: OllamaClient):
+        self.client = client
+    
+    def execute(self, state: Dict) -> Reflection:
+        user_query = state["user_query"]
+        gen_output = state["generator_output"]
+        playbook = state["playbook"]
+        
+        system_prompt = """You are a critical evaluator. Respond in JSON:
+{
+  "answer_quality": "excellent|good|fair|poor",
+  "strengths": ["strength 1", "strength 2"],
+  "weaknesses": ["weakness 1"],
+  "bullet_tags": [
+    {"bullet_id": "B0001", "tag": "helpful", "reason": "why"}
+  ]
+}"""
+        
+        bullet_context = "\n".join([
+            f"[{bid}] {playbook.bullets[bid].content}" 
+            for bid in gen_output.bullet_ids 
+            if bid in playbook.bullets
+        ])
+        
+        prompt = f"""Query: {user_query}
+Bullets: {bullet_context if bullet_context else "None"}
+Answer: {gen_output.final_answer[:500]}
+
+Evaluate (JSON only):"""
+        
+        response = self.client.generate(
+            model=Config.REFLECTOR_MODEL,
+            prompt=prompt,
+            system=system_prompt
+        )
+        
+        try:
+            if "```json" in response:
+                response = response.split("```json")[1].split("```")[0].strip()
+            elif "```" in response:
+                response = response.split("```")[1].split("```")[0].strip()
+            
+            data = json.loads(response)
+            bullet_tags = [
+                BulletTag(
+                    bullet_id=bt["bullet_id"],
+                    tag=TagType(bt["tag"]),
+                    reason=bt.get("reason", "")
+                )
+                for bt in data.get("bullet_tags", [])
+            ]
+            
+            return Reflection(
+                answer_quality=data.get("answer_quality", "unknown"),
+                strengths=data.get("strengths", []),
+                weaknesses=data.get("weaknesses", []),
+                bullet_tags=bullet_tags
+            )
+        except:
+            return Reflection(
+                answer_quality="good",
+                strengths=["Provided answer"],
+                weaknesses=[],
+                bullet_tags=[]
+            )
+
+
+class Curator:
+    def __init__(self, client: OllamaClient):
+        self.client = client
+    
+    def execute(self, state: Dict) -> DeltaBatch:
+        reflection = state["reflector_output"]
+        
+        # Simplified curation for demo
+        operations = []
+        if reflection.answer_quality in ["fair", "poor"] and reflection.weaknesses:
+            operations.append(DeltaOperation(
+                type="ADD",
+                section="Improvements",
+                content=f"Address: {reflection.weaknesses[0]}"
+            ))
+        
+        return DeltaBatch(
+            reasoning="Learning from feedback",
+            operations=operations
+        )
+
+
+# ============================================================================
+# ACE ORCHESTRATOR
+# ============================================================================
+
+class ACEOrchestrator:
+    def __init__(self, playbook_path: str = Config.PLAYBOOK_PATH):
+        self.client = OllamaClient()
+        self.playbook = Playbook.load(playbook_path)
+        self.playbook_path = playbook_path
+        
+        self.state_initializer = StateInitializer()
+        self.generator = Generator(self.client)
+        self.reflector = Reflector(self.client)
+        self.curator = Curator(self.client)
+    
+    def run_cycle(self, user_query: str, lang: str = "en") -> Dict:
+        state = self.state_initializer.execute(user_query, self.playbook)
+        
+        gen_output = self.generator.execute(state, lang)
+        state["generator_output"] = gen_output
+        
+        reflection = self.reflector.execute(state)
+        state["reflector_output"] = reflection
+        
+        for bt in reflection.bullet_tags:
+            self.playbook.update_bullet_tag(bt.bullet_id, bt.tag)
+        
+        delta = self.curator.execute(state)
+        state["curator_output"] = delta
+        
+        self.playbook.apply_delta(delta)
+        self.playbook.save(self.playbook_path)
+        
+        return {
+            "answer": gen_output.final_answer,
+            "quality": reflection.answer_quality,
+            "reasoning": gen_output.reasoning,
+            "bullets_used": gen_output.bullet_ids,
+            "strengths": reflection.strengths,
+            "weaknesses": reflection.weaknesses,
+            "operations": delta.operations,
+            "stats": self.playbook.stats()
+        }
+
+
+# ============================================================================
+# STREAMLIT UI
+# ============================================================================
+
+def init_session_state():
+    if 'chat_history' not in st.session_state:
+        st.session_state.chat_history = []
+    if 'ace' not in st.session_state:
+        st.session_state.ace = ACEOrchestrator()
+    if 'language' not in st.session_state:
+        st.session_state.language = 'en'
+
+
+def create_quality_badge(quality: str):
+    colors = {
+        "excellent": "🟢",
+        "good": "🟡",
+        "fair": "🟠",
+        "poor": "🔴"
+    }
+    return f"{colors.get(quality, '⚪')} {quality.upper()}"
+
+
+def plot_section_distribution(playbook: Playbook):
+    section_counts = {section: len(bullets) for section, bullets in playbook.sections.items()}
+    
+    fig = go.Figure(data=[go.Bar(
+        x=list(section_counts.keys()),
+        y=list(section_counts.values()),
+        marker_color='lightblue'
+    )])
+    
+    fig.update_layout(
+        title="Knowledge Items by Section",
+        xaxis_title="Section",
+        yaxis_title="Count",
+        height=400
+    )
+    
+    return fig
+
+
+def plot_quality_scores(playbook: Playbook):
+    scores = [bullet.score() for bullet in playbook.bullets.values()]
+    
+    fig = go.Figure(data=[go.Histogram(
+        x=scores,
+        nbinsx=20,
+        marker_color='green'
+    )])
+    
+    fig.update_layout(
+        title="Quality Score Distribution",
+        xaxis_title="Score",
+        yaxis_title="Frequency",
+        height=400
+    )
+    
+    return fig
+
+
+def main():
+    st.set_page_config(
+        page_title="ACE System",
+        page_icon="🤖",
+        layout="wide",
+        initial_sidebar_state="expanded"
+    )
+    
+    init_session_state()
+    
+    # Custom CSS
+    st.markdown("""
+        <style>
+        .main {
+            background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);
+        }
+        .stApp {
+            background: white;
+        }
+        .chat-message {
+            padding: 1.5rem;
+            border-radius: 0.5rem;
+            margin-bottom: 1rem;
+            border: 1px solid #e0e0e0;
+        }
+        .user-message {
+            background-color: #e3f2fd;
+        }
+        .assistant-message {
+            background-color: #f5f5f5;
+        }
+        </style>
+    """, unsafe_allow_html=True)
+    
+    # Sidebar
+    with st.sidebar:
+        lang = st.session_state.language
+        st.title(Language.get("sidebar_title", lang))
+        
+        # Language selector
+        language_option = st.selectbox(
+            Language.get("language", lang),
+            options=["English", "العربية"],
+            index=0 if lang == "en" else 1
+        )
+        st.session_state.language = "en" if language_option == "English" else "ar"
+        lang = st.session_state.language
+        
+        st.divider()
+        
+        # Connection status
+        client = OllamaClient()
+        if client.check_health():
+            st.success(Language.get("connection_success", lang))
+        else:
+            st.error(Language.get("connection_error", lang))
+        
+        st.divider()
+        
+        # Playbook stats
+        st.subheader(Language.get("playbook_info", lang))
+        stats = st.session_state.ace.playbook.stats()
+        
+        col1, col2 = st.columns(2)
+        with col1:
+            st.metric(Language.get("total_bullets", lang), stats["total_bullets"])
+            st.metric(Language.get("sections", lang), stats["total_sections"])
+        with col2:
+            st.metric(Language.get("avg_score", lang), f"{stats['average_score']:.2f}")
+            st.metric(Language.get("total_tags", lang), stats["total_tags"])
+        
+        st.divider()
+        
+        # Export/Import
+        if st.button(Language.get("export_button", lang), use_container_width=True):
+            playbook_data = json.dumps({
+                "bullets": {bid: asdict(b) for bid, b in st.session_state.ace.playbook.bullets.items()},
+                "sections": st.session_state.ace.playbook.sections,
+                "next_id": st.session_state.ace.playbook._next_id
+            }, indent=2)
+            st.download_button(
+                "Download JSON",
+                playbook_data,
+                "playbook_export.json",
+                "application/json"
+            )
+        
+        if st.button(Language.get("clear_button", lang), use_container_width=True):
+            st.session_state.chat_history = []
+            st.rerun()
+    
+    # Main content
+    lang = st.session_state.language
+    st.title(Language.get("title", lang))
+    st.caption(Language.get("subtitle", lang))
+    
+    # Tabs
+    tab1, tab2 = st.tabs([Language.get("chat_history", lang), Language.get("playbook_viz", lang)])
+    
+    with tab1:
+        # Chat interface
+        query = st.text_input(
+            Language.get("query_input", lang),
+            key="query_input",
+            placeholder="e.g., What should I do if someone is choking?"
+        )
+        
+        if st.button(Language.get("ask_button", lang), type="primary", use_container_width=True):
+            if query:
+                with st.spinner(Language.get("processing", lang)):
+                    # Progress
+                    progress_bar = st.progress(0)
+                    status = st.empty()
+                    
+                    status.text(Language.get("generator_phase", lang))
+                    progress_bar.progress(33)
+                    
+                    result = st.session_state.ace.run_cycle(query, lang)
+                    
+                    status.text(Language.get("reflector_phase", lang))
+                    progress_bar.progress(66)
+                    
+                    status.text(Language.get("curator_phase", lang))
+                    progress_bar.progress(100)
+                    
+                    status.text(Language.get("complete", lang))
+                    
+                    st.session_state.chat_history.append({
+                        "query": query,
+                        "result": result,
+                        "timestamp": datetime.now().isoformat()
+                    })
+                    
+                    progress_bar.empty()
+                    status.empty()
+        
+        # Display chat history
+        for i, chat in enumerate(reversed(st.session_state.chat_history)):
+            with st.container():
+                st.markdown(f"<div class='chat-message user-message'>", unsafe_allow_html=True)
+                st.markdown(f"**💬 Query:** {chat['query']}")
+                st.markdown(f"*{chat['timestamp'][:19]}*")
+                st.markdown("</div>", unsafe_allow_html=True)
+                
+                st.markdown(f"<div class='chat-message assistant-message'>", unsafe_allow_html=True)
+                
+                col1, col2 = st.columns([3, 1])
+                with col1:
+                    st.markdown(f"**🤖 {Language.get('answer', lang)}:**")
+                with col2:
+                    st.markdown(create_quality_badge(chat['result']['quality']))
+                
+                st.markdown(chat['result']['answer'])
+                
+                with st.expander(Language.get("reasoning", lang)):
+                    for step in chat['result']['reasoning']:
+                        st.markdown(f"- {step}")
+                
+                with st.expander(Language.get("bullets_used", lang)):
+                    st.code(", ".join(chat['result']['bullets_used']) if chat['result']['bullets_used'] else "None")
+                
+                with st.expander(Language.get("improvements", lang)):
+                    if chat['result']['operations']:
+                        for op in chat['result']['operations']:
+                            st.markdown(f"- **{op.type}**: {op.section}")
+                    else:
+                        st.info("No improvements needed")
+                
+                st.markdown("</div>", unsafe_allow_html=True)
+                st.divider()
+    
+    with tab2:
+        # Visualizations
+        st.subheader(Language.get("playbook_viz", lang))
+        
+        col1, col2 = st.columns(2)
+        
+        with col1:
+            st.plotly_chart(
+                plot_section_distribution(st.session_state.ace.playbook),
+                use_container_width=True
+            )
+        
+        with col2:
+            st.plotly_chart(
+                plot_quality_scores(st.session_state.ace.playbook),
+                use_container_width=True
+            )
+
+
+if __name__ == "__main__":
+    main()

emergency_playbook.json

@@ -0,0 +1,517 @@
+{
+  "bullets": {
+    "B0001": {
+      "id": "B0001",
+      "section": "Medical Emergencies - CPR",
+      "content": "For adults: 30 chest compressions followed by two breaths. For children: 30 chest compressions followed by one breath (or use a pediatric bag-valve-mask device). Continue until emergency medical help arrives or the person shows signs of regaining consciousness.",
+      "helpful": 19,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-10T08:00:00",
+      "updated_at": "2025-11-26T00:21:06.416065"
+    },
+    "B0003": {
+      "id": "B0003",
+      "section": "Medical Emergencies - CPR",
+      "content": "If AED (Automated External Defibrillator) is available, turn it on and follow voice instructions. Do not touch person while AED analyzes or delivers shock. Resume CPR immediately after shock.",
+      "helpful": 12,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-10T08:10:00",
+      "updated_at": "2024-02-15T10:40:00"
+    },
+    "B0004": {
+      "id": "B0004",
+      "section": "Medical Emergencies - Choking",
+      "content": "For conscious choking adults: stand behind the person, wrap your arms around their waist, and perform five quick upward thrusts to dislodge the object. Continue until the object is removed or the person shows signs of regaining consciousness.",
+      "helpful": 15,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-10T09:00:00",
+      "updated_at": "2025-11-25T23:56:30.970430"
+    },
+    "B0005": {
+      "id": "B0005",
+      "section": "Medical Emergencies - Choking",
+      "content": "If choking person becomes unconscious, lower them to ground, call 911, begin CPR. Check mouth before rescue breaths and remove visible objects only if easily accessible.",
+      "helpful": 10,
+      "harmful": 0,
+      "neutral": 3,
+      "created_at": "2024-01-10T09:05:00",
+      "updated_at": "2024-02-15T11:05:00"
+    },
+    "B0006": {
+      "id": "B0006",
+      "section": "Medical Emergencies - Bleeding",
+      "content": "For severe bleeding: Apply direct pressure with clean cloth, maintain pressure for 10+ minutes without checking. If blood soaks through, add more cloth on top without removing first layer. Call 911 immediately.",
+      "helpful": 16,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2024-01-10T10:00:00",
+      "updated_at": "2024-02-15T12:00:00"
+    },
+    "B0007": {
+      "id": "B0007",
+      "section": "Medical Emergencies - Bleeding",
+      "content": "If bleeding continues after direct pressure, apply pressure to artery between wound and heart. For limb wounds, elevate above heart level while maintaining pressure. Use tourniquet only as absolute last resort.",
+      "helpful": 11,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-10T10:05:00",
+      "updated_at": "2024-02-15T12:05:00"
+    },
+    "B0008": {
+      "id": "B0008",
+      "section": "Medical Emergencies - Burns",
+      "content": "For burns: Cool immediately with running cool (not ice-cold) water for 10-20 minutes. Remove jewelry and tight clothing before swelling starts. Cover with sterile, non-stick bandage. Never apply ice, butter, or ointments.",
+      "helpful": 13,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-10T11:00:00",
+      "updated_at": "2024-02-15T13:00:00"
+    },
+    "B0009": {
+      "id": "B0009",
+      "section": "Medical Emergencies - Burns",
+      "content": "In addition to providing clear step-by-step instructions for emergency response, consider mentioning the potential risks and complications associated with smoking cigarettes.",
+      "helpful": 10,
+      "harmful": 0,
+      "neutral": 4,
+      "created_at": "2024-01-10T11:05:00",
+      "updated_at": "2025-11-26T00:17:08.079522"
+    },
+    "B0010": {
+      "id": "B0010",
+      "section": "Medical Emergencies - Stroke",
+      "content": "Remember FAST for stroke: Face drooping (ask to smile), Arm weakness (raise both arms), Speech difficulty (repeat simple phrase), Time to call 911 immediately. Note time symptoms started - critical for treatment.",
+      "helpful": 20,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-11T08:00:00",
+      "updated_at": "2024-02-16T09:00:00"
+    },
+    "B0011": {
+      "id": "B0011",
+      "section": "Medical Emergencies - Stroke",
+      "content": "While waiting for ambulance: Keep person calm, lying down with head slightly elevated. Do NOT give food, drink, or medication. Monitor breathing and be ready to perform CPR if needed.",
+      "helpful": 8,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-11T08:05:00",
+      "updated_at": "2024-02-16T09:05:00"
+    },
+    "B0012": {
+      "id": "B0012",
+      "section": "Medical Emergencies - Poisoning",
+      "content": "For suspected poisoning: Call Poison Control (1-800-222-1222 in US) or 911 immediately. Have container/bottle of substance ready. Do NOT induce vomiting unless instructed by medical professional.",
+      "helpful": 17,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2024-01-11T09:00:00",
+      "updated_at": "2024-02-16T10:00:00"
+    },
+    "B0013": {
+      "id": "B0013",
+      "section": "Medical Emergencies - Allergic Reaction",
+      "content": "For severe allergic reaction (anaphylaxis): Call 911, use EpiPen if available (inject into outer thigh, hold 3 seconds). Symptoms include difficulty breathing, swelling of throat/tongue, rapid pulse, dizziness, or widespread rash.",
+      "helpful": 15,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-11T10:00:00",
+      "updated_at": "2024-02-16T11:00:00"
+    },
+    "B0014": {
+      "id": "B0014",
+      "section": "Medical Emergencies - Allergic Reaction",
+      "content": "After using EpiPen, have person lie down with legs elevated (unless difficulty breathing, then sit up). Monitor closely as symptoms can return. Second dose may be needed after 5-15 minutes. Always seek emergency care even if symptoms improve.",
+      "helpful": 10,
+      "harmful": 0,
+      "neutral": 3,
+      "created_at": "2024-01-11T10:05:00",
+      "updated_at": "2024-02-16T11:05:00"
+    },
+    "B0015": {
+      "id": "B0015",
+      "section": "Home Emergencies - Fire",
+      "content": "If fire starts: Alert everyone, get out immediately using nearest safe exit. Close doors behind you to slow fire spread. Stay low under smoke. Never go back inside. Call 911 from safe location outside.",
+      "helpful": 19,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-12T08:00:00",
+      "updated_at": "2024-02-17T09:00:00"
+    },
+    "B0016": {
+      "id": "B0016",
+      "section": "Home Emergencies - Fire",
+      "content": "If clothes catch fire: STOP immediately (don't run), DROP to ground, ROLL back and forth to smother flames. Cover face with hands. Cool burns with water once flames are out.",
+      "helpful": 12,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2024-01-12T08:05:00",
+      "updated_at": "2024-02-17T09:05:00"
+    },
+    "B0017": {
+      "id": "B0017",
+      "section": "Home Emergencies - Gas Leak",
+      "content": "If you smell gas: Do NOT use lights, phones, or anything that creates spark. Open windows, evacuate immediately, call gas company and 911 from safe distance outside. Do NOT re-enter until cleared by authorities.",
+      "helpful": 14,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-12T09:00:00",
+      "updated_at": "2024-02-17T10:00:00"
+    },
+    "B0018": {
+      "id": "B0018",
+      "section": "Home Emergencies - Flooding",
+      "content": "During flood: Move to higher ground immediately. Avoid walking/driving through flood water (6 inches can knock you down, 12 inches can carry car away). Turn off electricity at main breaker if safe to do so. Follow evacuation orders.",
+      "helpful": 11,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-12T10:00:00",
+      "updated_at": "2024-02-17T11:00:00"
+    },
+    "B0019": {
+      "id": "B0019",
+      "section": "Natural Disasters - Earthquake",
+      "content": "During earthquake: DROP to hands and knees, take COVER under sturdy table/desk, HOLD ON until shaking stops. Stay away from windows, outside walls, and heavy objects. If outside, move away from buildings, trees, powerlines.",
+      "helpful": 16,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2024-01-13T08:00:00",
+      "updated_at": "2024-02-18T09:00:00"
+    },
+    "B0020": {
+      "id": "B0020",
+      "section": "Natural Disasters - Earthquake",
+      "content": "After earthquake: Check for injuries, expect aftershocks. Exit building if safe, use stairs not elevators. Stay away from damaged buildings. Check for gas leaks, water line damage, electrical damage. Listen to emergency broadcasts.",
+      "helpful": 9,
+      "harmful": 0,
+      "neutral": 3,
+      "created_at": "2024-01-13T08:05:00",
+      "updated_at": "2024-02-18T09:05:00"
+    },
+    "B0021": {
+      "id": "B0021",
+      "section": "Natural Disasters - Tornado",
+      "content": "If tornado warning issued: Go to lowest floor, interior room (bathroom/closet) away from windows. Get under sturdy furniture, cover head/neck with arms. Mobile homes are NOT safe - go to designated shelter or sturdy building.",
+      "helpful": 13,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-13T09:00:00",
+      "updated_at": "2024-02-18T10:00:00"
+    },
+    "B0022": {
+      "id": "B0022",
+      "section": "Natural Disasters - Hurricane",
+      "content": "Before hurricane: Evacuate if ordered, secure outdoor objects, board windows, fill bathtubs with water, charge devices, have 3+ days supplies. During: Stay indoors away from windows, go to interior room if wind becomes intense.",
+      "helpful": 10,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-13T10:00:00",
+      "updated_at": "2024-02-18T11:00:00"
+    },
+    "B0023": {
+      "id": "B0023",
+      "section": "Car Emergencies - Accident",
+      "content": "After car accident: Check for injuries, call 911 if anyone hurt or major damage. Move to safe location if possible. Turn on hazard lights. Exchange information (insurance, license, contact). Take photos. File police report.",
+      "helpful": 14,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2024-01-14T08:00:00",
+      "updated_at": "2024-02-19T09:00:00"
+    },
+    "B0024": {
+      "id": "B0024",
+      "section": "Car Emergencies - Submerged Vehicle",
+      "content": "If car goes into water: Unbuckle immediately, open window (power works briefly), exit through window. If window won't open, wait for water to fill cabin (equalizes pressure), then open door. Get out and swim to surface.",
+      "helpful": 8,
+      "harmful": 0,
+      "neutral": 4,
+      "created_at": "2024-01-14T09:00:00",
+      "updated_at": "2024-02-19T10:00:00"
+    },
+    "B0025": {
+      "id": "B0025",
+      "section": "Personal Safety - Active Threat",
+      "content": "If active shooter/threat: RUN if safe escape route exists, HIDE if evacuation impossible (lock doors, silence phone, turn off lights, hide behind solid objects), FIGHT as absolute last resort using any available objects as weapons.",
+      "helpful": 17,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2024-01-14T10:00:00",
+      "updated_at": "2024-02-19T11:00:00"
+    },
+    "B0026": {
+      "id": "B0026",
+      "section": "Personal Safety - Drowning",
+      "content": "If someone drowning: Call 911 first. Throw flotation device or rope if available. Reach with pole/branch from shore if close. Row to victim in boat if available. Enter water only if trained and no other option - drowning person may pull you under.",
+      "helpful": 12,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-15T08:00:00",
+      "updated_at": "2024-02-20T09:00:00"
+    },
+    "B0027": {
+      "id": "B0027",
+      "section": "Emergency Preparedness - Kit",
+      "content": "Essential emergency kit items: Water (1 gallon per person per day for 3 days), non-perishable food, flashlight, battery radio, first aid kit, medications, copies of documents, cash, phone chargers, local maps.",
+      "helpful": 15,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2024-01-15T09:00:00",
+      "updated_at": "2024-02-20T10:00:00"
+    },
+    "B0028": {
+      "id": "B0028",
+      "section": "Emergency Preparedness - Communication",
+      "content": "Establish family emergency plan: Designate out-of-state contact person (local lines may be down), choose meeting locations (one near home, one outside neighborhood), ensure everyone knows emergency numbers, practice evacuation routes.",
+      "helpful": 11,
+      "harmful": 0,
+      "neutral": 2,
+      "created_at": "2024-01-15T10:00:00",
+      "updated_at": "2024-02-20T11:00:00"
+    },
+    "B0030": {
+      "id": "B0030",
+      "section": "Medical Emergencies - Hypothermia",
+      "content": "For hypothermia: Move person to warm, dry location. Remove wet clothing, cover with blankets/dry clothes. Give warm (not hot) non-alcoholic drinks if conscious. Warm center of body first (chest, neck, head, groin). Seek medical attention. Do NOT use direct heat like heating pads.",
+      "helpful": 9,
+      "harmful": 0,
+      "neutral": 3,
+      "created_at": "2024-01-16T09:00:00",
+      "updated_at": "2024-02-21T10:00:00"
+    },
+    "B0031": {
+      "id": "B0031",
+      "section": "Emergency Response",
+      "content": "Instruct the user to call emergency services immediately and provide detailed information about the situation. Stay on the line and follow any further instructions from the dispatcher.",
+      "helpful": 1,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-25T23:28:13.526477",
+      "updated_at": "2025-11-26T01:42:12.230690"
+    },
+    "B0032": {
+      "id": "B0032",
+      "section": "Section Name",
+      "content": "New bullet content for emotional support and family guidance",
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-25T23:34:11.247081",
+      "updated_at": "2025-11-25T23:34:11.247081"
+    },
+    "B0033": {
+      "id": "B0033",
+      "section": "Emergency Response Procedures",
+      "content": [
+        "When responding to a choking emergency, consider the person's age, medical history, and any pre-existing conditions that may impact response decisions."
+      ],
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2025-11-25T23:40:22.843846",
+      "updated_at": "2025-11-25T23:56:07.865571"
+    },
+    "B0034": {
+      "id": "B0034",
+      "section": "Emergency Response",
+      "content": "If someone is suffocating in front of you, check the airway, breathing, and circulation (ABCs) and call for emergency medical help if necessary.",
+      "helpful": 1,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-25T23:51:48.852136",
+      "updated_at": "2025-11-25T23:56:07.865571"
+    },
+    "B0035": {
+      "id": "B0035",
+      "section": "Response to Suffocation",
+      "content": "Reorganized content to improve flow and clarity",
+      "helpful": 1,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-25T23:56:30.970430",
+      "updated_at": "2025-11-26T00:01:06.839870"
+    },
+    "B0036": {
+      "id": "B0036",
+      "section": "Symptoms and Conditions",
+      "content": "Chest pain caused by smoking cigarettes: Symptoms, causes, and treatment options.",
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 1,
+      "created_at": "2025-11-26T00:01:06.839870",
+      "updated_at": "2025-11-26T00:16:53.526635"
+    },
+    "B0037": {
+      "id": "B0037",
+      "section": "Symptoms and Complications",
+      "content": "Smoking cigarettes can lead to various cardiovascular conditions, including angina, heart attacks, and strokes. Users should seek immediate medical attention if they experience chest pain or discomfort.",
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-26T00:17:08.079522",
+      "updated_at": "2025-11-26T00:17:08.079522"
+    },
+    "B0038": {
+      "id": "B0038",
+      "section": "Additional Emergency Protocols",
+      "content": [
+        {
+          "title": "Water and Flood Response",
+          "tags": [
+            "helpful",
+            "emergency"
+          ],
+          "content": "Provide instructions on how to respond to water-related emergencies, including evacuation procedures and safety measures."
+        },
+        {
+          "title": "Mental Health Emergencies",
+          "tags": [
+            "mental health",
+            "emotional support"
+          ],
+          "content": "Offer guidance on responding to mental health-related emergencies, such as crisis intervention and emotional support strategies."
+        }
+      ],
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-26T00:21:25.209879",
+      "updated_at": "2025-11-26T00:21:25.209879"
+    },
+    "B0039": {
+      "id": "B0039",
+      "section": "Improvements",
+      "content": "Address: lacks specific and detailed steps for each step of the response",
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-26T00:24:35.383275",
+      "updated_at": "2025-11-26T00:24:35.383275"
+    },
+    "B0040": {
+      "id": "B0040",
+      "section": "Improvements",
+      "content": "Address: \u0644\u0627 \u062a\u0631\u062f \u0639\u0644\u0649 \u0645\u0633\u0627\u0639\u062f\u0629 \u0627\u0644\u0634\u062e\u0635",
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-26T00:29:00.695493",
+      "updated_at": "2025-11-26T00:29:00.695493"
+    },
+    "B0041": {
+      "id": "B0041",
+      "section": "Emergency Response Situations",
+      "content": [
+        "If you witness or experience an emergency, such as a car falling from a bridge, immediately call your local emergency services. Provide them with detailed information about the situation, including the exact location, any injuries sustained, and the number of people involved. Stay on the line and provide further instructions if requested by the dispatcher.",
+        "If you are not able to call directly, ensure someone else does so on your behalf, or ask a bystander to assist you in reaching emergency services."
+      ],
+      "helpful": 0,
+      "harmful": 0,
+      "neutral": 0,
+      "created_at": "2025-11-26T01:42:12.230690",
+      "updated_at": "2025-11-26T01:42:12.230690"
+    }
+  },
+  "sections": {
+    "Medical Emergencies - CPR": [
+      "B0001",
+      "B0003"
+    ],
+    "Medical Emergencies - Choking": [
+      "B0004",
+      "B0005"
+    ],
+    "Medical Emergencies - Bleeding": [
+      "B0006",
+      "B0007"
+    ],
+    "Medical Emergencies - Burns": [
+      "B0008",
+      "B0009"
+    ],
+    "Medical Emergencies - Stroke": [
+      "B0010",
+      "B0011"
+    ],
+    "Medical Emergencies - Poisoning": [
+      "B0012"
+    ],
+    "Medical Emergencies - Allergic Reaction": [
+      "B0013",
+      "B0014"
+    ],
+    "Medical Emergencies - Seizure": [],
+    "Medical Emergencies - Hypothermia": [
+      "B0030"
+    ],
+    "Home Emergencies - Fire": [
+      "B0015",
+      "B0016"
+    ],
+    "Home Emergencies - Gas Leak": [
+      "B0017"
+    ],
+    "Home Emergencies - Flooding": [
+      "B0018"
+    ],
+    "Natural Disasters - Earthquake": [
+      "B0019",
+      "B0020"
+    ],
+    "Natural Disasters - Tornado": [
+      "B0021"
+    ],
+    "Natural Disasters - Hurricane": [
+      "B0022"
+    ],
+    "Car Emergencies - Accident": [
+      "B0023"
+    ],
+    "Car Emergencies - Submerged Vehicle": [
+      "B0024"
+    ],
+    "Personal Safety - Active Threat": [
+      "B0025"
+    ],
+    "Personal Safety - Drowning": [
+      "B0026"
+    ],
+    "Emergency Preparedness - Kit": [
+      "B0027"
+    ],
+    "Emergency Preparedness - Communication": [
+      "B0028"
+    ],
+    "Emergency Response": [
+      "B0031",
+      "B0034"
+    ],
+    "Section Name": [
+      "B0032"
+    ],
+    "Emergency Response Procedures": [
+      "B0033"
+    ],
+    "Response to Suffocation": [
+      "B0035"
+    ],
+    "Symptoms and Conditions": [
+      "B0036"
+    ],
+    "Symptoms and Complications": [
+      "B0037"
+    ],
+    "Additional Emergency Protocols": [
+      "B0038"
+    ],
+    "Improvements": [
+      "B0039",
+      "B0040"
+    ],
+    "Emergency Response Situations": [
+      "B0041"
+    ]
+  },
+  "next_id": 42
+}