CaesarAI Telegram Message

CaesarAIMusicLoad/caesaraimusicload.py

@@ -0,0 +1,13 @@
+import requests
+
+class CaesarAITelegramBOT:
+    def __init__(self) -> None:
+        self.TOKEN = "6186492282:AAEOrXHlfhKZDnOo8ekQqu2glfmF9v4UEWE"
+    def get_chatids(self):
+        url = f"https://api.telegram.org/bot{self.TOKEN}/getUpdates"
+        response = requests.get(url).json()
+        return response
+    def send_message(self,chat_id,message):
+        url = f"https://api.telegram.org/bot{self.TOKEN}/sendMessage?chat_id={chat_id}&text={message}"
+        response = requests.get(url).json()
+        return response

RequestModels.py

@@ -30,7 +30,9 @@ class CaesarStockInfoModel(BaseModel):
     stock: str
     start_date: str
     end_date: str
-
+class CaesarTelegramMessageModel(BaseModel):
+    chat_id: str
+    message: str
 
 class CaesarVoiceModel(BaseModel):
     filename: Union[str,None]

main.py

@@ -28,10 +28,11 @@ from CaesarVoice import CaesarVoice
 from csv_to_db import ImportCSV
 from RequestModels import *
 from CaesarFaceRecognition.caesardeepface import CaesarDeepFace
-
+from CaesarAIMusicLoad.caesaraimusicload import CaesarAITelegramBOT
 importcsv  = ImportCSV("CaesarAI")
 caesaryolo = CaesarYolo()
 caesarfacedetectmodel = CaesarFaceDetection()
+caesartelgegrambot = CaesarAITelegramBOT()
 app = FastAPI()
 
 CURRENT_DIR = os.path.realpath(__file__).replace(f"/main.py","")
@@ -88,6 +89,23 @@ async def caesarfacedetect(websocket: WebSocket):
 
     except WebSocketDisconnect:
         print("Client disconnected")
+@app.get("/getcaesartelegramchatids")
+def getcaesartelegramchatid():
+    try:
+        chatids = caesartelgegrambot.get_chatids()
+        return chatids
+    except Exception as ex:
+        return {"error":f"{type(ex)},{ex}"}
+@app.get("/caesartelegramsendmessage")
+def caesartelegramsendmessage(messageinfo: CaesarAITelegramBOT):
+    try:
+        messageinfo = dict(messageinfo)
+        chat_id = messageinfo["chat_id"]
+        message = messageinfo["message"]
+        chatids = caesartelgegrambot.send_message(chat_id,message)
+        return chatids
+    except Exception as ex:
+        return {"error":f"{type(ex)},{ex}"}
 
 @app.post("/caesarfacesnap")
 def caesarfacesnap(frames: CaesarOCRHTTPModel):