Merge pull request

Author: GaabDevWeb

.env

@@ -0,0 +1,8 @@
+.env
+
+**/__pycache__/
+*.py[cod]
+*$py.class
+*.so
+
+cursor/

.gitignore

@@ -0,0 +1,2 @@
+# Para criar o banco:
+mysql -u root -p -e "CREATE DATABASE IF NOT EXISTS pybot CHARACTER SET utf8mb4;"

SQL/instructions_for_creation.md

@@ -0,0 +1,10 @@
+CREATE TABLE IF NOT EXISTS knowledge (
+    id         INT UNSIGNED AUTO_INCREMENT PRIMARY KEY,
+    title      VARCHAR(255) NOT NULL,
+    content    TEXT         NOT NULL,
+    category   VARCHAR(100) NOT NULL DEFAULT 'geral',
+    active     TINYINT(1)   NOT NULL DEFAULT 1,
+    created_at DATETIME     NOT NULL DEFAULT CURRENT_TIMESTAMP,
+    updated_at DATETIME     NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+    INDEX idx_active_category (active, category)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;

SQL/schema.sql

@@ -8,6 +8,8 @@
 from fastapi import APIRouter, HTTPException, Request
 from fastapi.responses import HTMLResponse, StreamingResponse
 
+from collections.abc import AsyncGenerator
+
 log = logging.getLogger("kernelbots.api.chat")
 
 router = APIRouter()
@@ -75,6 +77,28 @@ async def chat(request: Request) -> StreamingResponse:
             detail="Campo 'session_id' deve ser string ou omitido.",
         )
 
+    if user_message.strip().lower() == "/reload":
+        log.info("🔄 Comando /reload recebido — reconstruindo índice BM25...")
+        services.search_engine.rebuild()
+        chunk_count = len(services.search_engine.chunks)
+        db_count = sum(1 for c in services.search_engine.chunks if c.get("source", "").startswith("db:"))
+        md_count = chunk_count - db_count
+        status = (
+            f"Índice reconstruído: {chunk_count} chunk(s) total "
+            f"({md_count} de arquivos .md + {db_count} do MySQL)."
+        )
+        log.info("✅ /reload concluído — %s", status)
+
+        async def _reload_stream() -> AsyncGenerator[str, None]:
+            yield f"data: {status}\n\n"
+            yield "data: [DONE]\n\n"
+
+        return StreamingResponse(
+            _reload_stream(),
+            media_type="text/event-stream",
+            headers={"Cache-Control": "no-cache", "X-Accel-Buffering": "no", "Connection": "keep-alive"},
+        )
+
     built = services.context_manager.build_messages(
         user_message,
         discipline_filter=discipline,