Knowledge Base

def _extract_content(self, file_content: bytes, filename: str, mime_type: str) -> str:
    """Extract text content from file bytes."""
    file_extension = Path(filename).suffix.lower()
    
    # Handle text-based files
    if (file_extension in ['.txt', '.json', '.xml', '.csv'] 
        or mime_type.startswith('text/')):
        detected = chardet.detect(file_content)
        encoding = detected.get('encoding', 'utf-8')
        return file_content.decode(encoding)
    
    # Handle PDFs
    elif file_extension == '.pdf':
        pdf_reader = PyPDF2.PdfReader(io.BytesIO(file_content))
        return '\n\n'.join(page.extract_text() for page in pdf_reader.pages)
    
    # Handle Word documents
    elif file_extension == '.docx':
        doc = docx.Document(io.BytesIO(file_content))
        return '\n'.join(paragraph.text for paragraph in doc.paragraphs)

async def _generate_summary(self, content: str, filename: str) -> str:
    prompt = f"""Analyze this file and create a concise, actionable summary.

File: {filename}
Content: {content}

Generate a 2-3 sentence summary that captures:
1. What this file contains
2. Key information or purpose  
3. When this knowledge would be useful

Keep it under 200 words and make it actionable for context injection."""
    
    response = await make_llm_api_call(
        messages=[{"role": "user", "content": prompt}],
        model_name="openrouter/google/gemini-2.5-flash-lite",
        temperature=0.1,
        max_tokens=300,
        stream=False,
    )
    
    return response.choices[0].message.content.strip()

# Invalidate KB context cache for all agents
try:
    from core.cache.runtime_cache import invalidate_kb_context_cache
    assignments_result = await client.table('agent_knowledge_entry_assignments') \
        .select('agent_id').eq('entry_id', entry_id).execute()
    
    agent_ids = set(row['agent_id'] for row in assignments_result.data)
    for agent_id in agent_ids:
        await invalidate_kb_context_cache(agent_id)
    logger.debug(f"Invalidated KB cache for {len(agent_ids)} agents")
except Exception as e:
    logger.warning(f"Failed to invalidate KB cache: {e}")