""" AUTHOR: Khushal P Soonderji DATE: Wednesday, 15th Jan., 2025. OBJECTIVE: To handle all chat-related behaviour from one place. The initially known clients are WhatsApp and Telegram. REFERENCES: N/A DOWNLOADS: N/A """ # ***************************************************************************************************************** # ***** **** # *** IMPORT *** # ***** **** # ***************************************************************************************************************** # To make sibling directories accessible for imports: import sys sys.path.append(".") sys.path.append("..") # My async utils: from utils_v2.database.async_mongo_v2 import AsyncMongo from utils_v2.cache.async_redis_cache_v2 import AsyncRedisCache # Controllers: from controllers_v2.core.message import CoreMessageController # Models: from models.core.auth_token import CoreAuthTokenModel from models.api.message.sms.send import ( NimbusSMSIndiaMessage, SavvyBulkSMSKenyaMessage, SMSSendOneResult, SMSSendManyResults ) # SMS clients: from utils_v2.sms.india.nimbus.controllers.async_nimbus import AsyncNimbusSMS from utils_v2.sms.kenya.savvy_bulk_sms.controllers.async_savvy_bulk_sms import AsyncSavvyBulkSMS # To work with datatypes: from typing import List, Any # To make HTTP requests: import httpx # To make abstract classes: from abc import ABC, abstractmethod # ***************************************************************************************************************** # ***** **** # *** MACROS / ONE-TIME INIT *** # ***** **** # ***************************************************************************************************************** # --- Nothing Yet # ***************************************************************************************************************** # ***** **** # *** VARIABLES *** # ***** **** # ***************************************************************************************************************** # --- Nothing Yet # ***************************************************************************************************************** # ***** **** # *** FUNCTIONS *** # ***** **** # ***************************************************************************************************************** # --- Nothing Yet # ***************************************************************************************************************** # ***** **** # *** CLASSES *** # ***** **** # ***************************************************************************************************************** class ChatController(CoreMessageController, ABC): # ┏┓ # ┃ ┏┓┏┓┏╋┏┓┓┏┏╋┏┓┏┓ # ┗┛┗┛┛┗┛┗┛ ┗┻┗┗┗┛┛ def __init__( self, cache: AsyncRedisCache = None, http_client: httpx.AsyncClient = None, alert_url: str = None, base_filter: dict = None, debug: bool = True, debug_prefix: str = "Chat (C) | ", debug_only_errors: bool = True ): """ This is the foundational controller for all chat services. This is built on top of the core message controller, and, in turn, all individual chat client controllers must be built on top of this. :param cache: The object to use for caching results from database calls. :param http_client: The HTTP client :param base_filter: The basic filter that will be applied to all fetching/updating queries. WARNING: THE BASE FILTER WILL ALWAYS BE APPLIED AUTOMATICALLY. SET THIS UP WISELY. :param debug: Whether, or not, you would like to print debugging messages: :param debug_prefix: The prefix to print with the debugging messages. :param debug_only_errors: Whether you would like to print only error messages or all messages. :return: None. """ # Prepare the combined base filter: sms_filter = {} for k, v in (base_filter or {}).items(): sms_filter[k] = v sms_filter["serviceType"] = "sms" # Invoke the parent's constructor: CoreMessageController.__init__( self, cache = cache, alert_url = alert_url, http_client = http_client, base_filter = sms_filter, debug = debug, debug_prefix = debug_prefix, debug_only_errors = debug_only_errors ) # ***************************************************************************************************************** # ***** **** # *** MAIN PROGRAM *** # ***** **** # ***************************************************************************************************************** if __name__ == "__main__": pass