File size: 1,973 Bytes
f6cdf9d 8a2fdbf f6cdf9d 96f79c9 f6cdf9d 8a2fdbf f6cdf9d 4032184 f6cdf9d 4032184 f6cdf9d 4032184 f0cf2d8 4032184 |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
from .supabase_db import SupabaseClient
from .llm import create_llm_client
from .reranker import Reranker
from .embedding import EmbeddingClient
from .facebook import FacebookClient
from .config import get_settings
from .sheets import SheetsClient
from app.message_processor import MessageProcessor
from typing import Optional
class ChatChannel:
def __init__(self, page_id: str, channel_type: str = "facebook"):
self.channel_type = channel_type
self.page_id = page_id
self.page_token = None # cache token
settings = get_settings()
self.supabase = SupabaseClient(settings.supabase_url, settings.supabase_key)
self.sheets = SheetsClient(
settings.google_sheets_credentials_file,
settings.google_sheets_token_file,
settings.conversation_sheet_id
)
self.llm = create_llm_client(
provider="gemini",
base_url=settings.gemini_base_url,
model=settings.gemini_models_list[0] if settings.gemini_models_list else "gemini-2.5-flash"
)
self.reranker = Reranker()
self.embedder = EmbeddingClient()
self.conversations = {} # sender_id -> MessageProcessor
def get_page_token(self, force_refresh=False):
if self.page_token is None or force_refresh:
self.page_token = self.supabase.get_page_token(self.page_id)
return self.page_token
def invalidate_page_token(self):
self.page_token = None
def get_sheets_client(self):
settings = get_settings()
return SheetsClient(
settings.google_sheets_credentials_file,
settings.google_sheets_token_file,
settings.conversation_sheet_id
)
def get_or_create_conversation(self, sender_id: str):
if sender_id not in self.conversations:
self.conversations[sender_id] = MessageProcessor(self, sender_id)
return self.conversations[sender_id] |