feat: Facebook channel (#183)

* add integrations backend apis

* add integrations frontend

* completed integrations admin ui

* add facebook channel implementation

* fix typo in ci

* fix ui issues

Author: alfredfrancis

.github/workflows/evaluate-frontend.yml

@@ -8,7 +8,7 @@ on:
     branches:
       - master
     paths:
-      'frontend/*'
+      - 'frontend/*'
 
 jobs:     
   test-nextjs:

README.md

@@ -13,6 +13,7 @@ You don’t need to be an expert at artificial intelligence to create an awesome
 
 ## Features
 - Fully Self Hosted
+- Low Code, DIY, Admin Dashboard
 - Multi-turn Conversations
 - Advanced Natural Language Understanding (NLU)
   - Spacy Word Embeddings
@@ -23,20 +24,30 @@ You don’t need to be an expert at artificial intelligence to create an awesome
 - API request fulfilment
 - Channel Integrations
   - Web using rest api/chat snippet
-  - Facebook Messenger (coming soon)
-  - WhatsApp via Twilio (coming soon)
+  - Facebook Messenger
   - Slack (coming soon)
-- Low Code Admin Dashboard
+  - WhatsApp via Twilio (coming soon)
+
 
 ## Index
 
+* [Tech Stack](#tech-stack)
 * [Installation](#installation)
   * [Docker Compose](#using-docker-compose)
   * [Helm](#using-helm)
 * [Development](#development)
 * [Tutorial](#tutorial)
 * [Dependencies](#dependencies-documentations)
 
+### Tech Stack
+
+ - Python / FastAPI / Pydantic
+ - MongoDB / Motor
+ - React / NextJS
+ - scikit-learn / Tensorflow / Keras
+ - Spacy / python-crfsuite
+ - Docker / docker-compose / Kubernetes / Helm
+
 ### Installation
 
 ### Using docker-compose (recommended)

app/admin/bots/routes.py

@@ -5,7 +5,7 @@
 
 from app.admin.bots import store
 
-router = APIRouter(prefix="/bots")
+router = APIRouter(prefix="/bots", tags=["bots"])
 
 
 @router.put("/{name}/config")

app/admin/entities/routes.py

@@ -2,7 +2,7 @@
 from app.admin.entities import store
 from app.admin.entities.schemas import Entity
 
-router = APIRouter(prefix="/entities")
+router = APIRouter(prefix="/entities", tags=["entities"])
 
 
 @router.post("/")

app/admin/integrations/routes.py

@@ -0,0 +1,30 @@
+from typing import List
+from fastapi import APIRouter, HTTPException
+from . import store
+from .schemas import Integration, IntegrationUpdate
+
+router = APIRouter(prefix="/integrations", tags=["integrations"])
+
+
+@router.get("/", response_model=List[Integration])
+async def list_integrations():
+    """List all available integrations."""
+    return await store.list_integrations()
+
+
+@router.get("/{id}", response_model=Integration)
+async def get_integration(id: str):
+    """Get a specific integration by ID."""
+    integration = await store.get_integration(id)
+    if not integration:
+        raise HTTPException(status_code=404, detail="Integration not found")
+    return integration
+
+
+@router.put("/{id}", response_model=Integration)
+async def update_integration(id: str, integration: IntegrationUpdate):
+    """Update an integration's status and settings."""
+    updated_integration = await store.update_integration(id, integration)
+    if not updated_integration:
+        raise HTTPException(status_code=404, detail="Integration not found")
+    return updated_integration

app/admin/integrations/schemas.py

@@ -0,0 +1,23 @@
+from typing import Dict, Optional
+from pydantic import BaseModel
+
+
+class IntegrationBase(BaseModel):
+    id: str
+    name: str
+    description: str
+    status: bool = False
+    settings: Optional[Dict] = {}
+
+
+class IntegrationCreate(IntegrationBase):
+    pass
+
+
+class IntegrationUpdate(IntegrationBase):
+    pass
+
+
+class Integration(IntegrationBase):
+    class Config:
+        from_attributes = True

app/admin/integrations/store.py

@@ -0,0 +1,68 @@
+from typing import List, Optional
+from app.database import database
+from .schemas import Integration, IntegrationUpdate
+
+collection_name = "integrations"
+
+
+async def list_integrations() -> List[Integration]:
+    """Get all integrations."""
+    cursor = database[collection_name].find()
+    integrations = await cursor.to_list(length=None)
+    return [Integration(**integration) for integration in integrations]
+
+
+async def get_integration(id: str) -> Optional[Integration]:
+    """Get a specific integration by ID."""
+    integration = await database[collection_name].find_one({"id": id})
+    if integration:
+        return Integration(**integration)
+    return None
+
+
+async def update_integration(
+    id: str, integration: IntegrationUpdate
+) -> Optional[Integration]:
+    """Update an integration's status and settings."""
+    update_data = integration.model_dump(exclude_unset=True)
+
+    result = await database[collection_name].find_one_and_update(
+        {"id": id},
+        {"$set": update_data},
+        return_document=True,
+    )
+
+    if result:
+        return Integration(**result)
+    return None
+
+
+async def ensure_default_integrations():
+    """Ensure default integrations exist in the database."""
+    default_integrations = [
+        {
+            "id": "facebook",
+            "name": "Facebook Messenger",
+            "description": "Connect with Facebook Messenger",
+            "status": False,
+            "settings": {
+                "verify": "ai-chatbot-framework",
+                "secret": "",
+                "page_access_token": "",
+            },
+        },
+        {
+            "id": "chat_widget",
+            "name": "Chat Widget",
+            "description": "Add a chat widget to your website",
+            "status": True,
+            "settings": {},
+        },
+    ]
+
+    for integration in default_integrations:
+        await database[collection_name].update_one(
+            {"id": integration["id"]},
+            {"$setOnInsert": integration},
+            upsert=True,
+        )

app/admin/intents/routes.py

@@ -2,7 +2,7 @@
 from app.admin.intents import store
 from app.admin.intents.schemas import Intent
 
-router = APIRouter(prefix="/intents")
+router = APIRouter(prefix="/intents", tags=["intents"])
 
 
 @router.post("/")

app/admin/train/routes.py

@@ -3,7 +3,7 @@
 from app.dependencies import reload_dialogue_manager
 from app.bot.nlu.training import train_pipeline
 
-router = APIRouter(prefix="/train")
+router = APIRouter(prefix="/train", tags=["train"])
 
 
 @router.post("/{intent_id}/data")