Update main.py

main.py

@@ -76,7 +76,7 @@ def generate_text(request: Request, input_data: InputData):
         history = []
         generated_response = generate(input_text, history, temperature, max_new_tokens, top_p, repetition_penalty)
         if input_data.telegramChatId != '' and input_data.telegramUrlBot != '' and input_data.telegramUrlPost != '': 
-            call_telegram_api(input_data, generated_response)
+            asyncio.run(call_telegram_api(input_data, generated_response))
         LoggaTesto("RISPOSTA", {"response": generated_response})
         return {"response": generated_response}
     else: 
@@ -100,7 +100,7 @@ def generate_text(request: Request, input_data: InputData):
             LoggaTesto("RISPOSTA ASINCRONA UNIFICATA", {"response": result_data})
         return {"response": result_data}
 
-def call_telegram_api(input_data, text): 
+def call_telegram_api_OLD(input_data, text): 
     payload = {
         "chat_id": input_data.telegramChatId,
         "text": text,
@@ -112,6 +112,16 @@ def call_telegram_api(input_data, text):
     else:    
         print("Errore nella richiesta POST. Codice di stato:", response.status_code)    
 
+async def call_telegram_api(input_data, text):
+    payload = {
+        "chat_id": input_data.telegramChatId,
+        "text": text,
+        "telegramUrl": input_data.telegramUrlBot
+    }
+    async with aiohttp.ClientSession() as session:
+        async with session.post(input_data.telegramUrlPost, json=payload) as response:
+            print(await response.text())        
+
 def generate_input_text(input_data):
     if input_data.instruction.startswith("http"):
         try: