Jocaru/telewarder
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes

Browse Source
This commit is contained in:
Joan
2024-03-11 17:18:44 +01:00
parent fdab80e6f3
commit 5e6995afe5
1 changed files with 11 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
telewarder/app.py
View File

@@ -4,6 +4,7 @@ import os
import aiohttp import aiohttp
import asyncio import asyncio
import logging import logging
import json
API_ID = os.getenv('API_ID') API_ID = os.getenv('API_ID')
API_HASH = os.getenv('API_HASH') API_HASH = os.getenv('API_HASH')
@@ -30,7 +31,7 @@ async def fetch_messages(session, url):
async def forward_message(client, message_data): async def forward_message(client, message_data):
try: try:
async with aiohttp.ClientSession() as session: async with aiohttp.ClientSession() as session:
await session.post(SEND_ENDPOINT, data=message_data) await session.post(url=SEND_ENDPOINT, data=message_data, headers={"Content-Type": "application/json"})
except Exception as e: except Exception as e:
logging.error(f"Error forwarding message to HTTP server: {e}") logging.error(f"Error forwarding message to HTTP server: {e}")
@@ -41,10 +42,13 @@ async def check_and_reply(app):
messages = await fetch_messages(session, MESSAGES_ENDPOINT) messages = await fetch_messages(session, MESSAGES_ENDPOINT)
if messages: if messages:
for message_data in messages: for message_data in messages:
try:
chat_id = message_data.get('chat_id') chat_id = message_data.get('chat_id')
message_id = message_data.get('message_id') message_id = message_data.get('message_id')
message_text = message_data.get('message') message_text = message_data.get('message_text')
await app.send_message(chat_id, message_text, reply_to_message_id=message_id) await app.send_message(chat_id, message_text, reply_to_message_id=message_id)
except Exception as e:
logging.info(f"Something wrong occurred: {e}")
await asyncio.sleep(10) # Adjust the time interval for checking (in seconds) await asyncio.sleep(10) # Adjust the time interval for checking (in seconds)
#@app.on_message() #@app.on_message()
@@ -53,10 +57,10 @@ async def forward(client, message):
message_data = { message_data = {
"chat_id": message.chat.id, "chat_id": message.chat.id,
"message_id": message.id, "message_id": message.id,
"message": message.text "message_text": message.text
} }
logging.info(f"Sending {message_data} to {SEND_ENDPOINT}") logging.info(f"Sending {message_data} to {SEND_ENDPOINT}")
await forward_message(client, message_data) await forward_message(client, json.dumps(message_data))
async def main(): async def main():
app = Client(os.environ.get('SESSION_NAME', '/data/telewarder'), app = Client(os.environ.get('SESSION_NAME', '/data/telewarder'),