1
0
Fork 0

Compare commits

...

2 Commits

Author SHA1 Message Date
Alex Kotov 2972cca582
Print to stderr 2023-01-08 16:55:14 +04:00
Alex Kotov 8b57552944
Add Matrix callback 2023-01-08 16:46:08 +04:00
1 changed files with 12 additions and 4 deletions

View File

@ -1,6 +1,7 @@
#!/usr/bin/env python3
import asyncio
import sys
import aiogram as telegram
import nio as matrix
@ -14,20 +15,27 @@ async def main():
try:
matrix_client = \
matrix.AsyncClient(MATRIX_HOMESERVER_URL, MATRIX_FULL_USER_ID)
matrix_client.add_event_callback(matrix_on_message,
matrix.RoomMessage)
await matrix_client.login(MATRIX_PASSWORD)
telegram_client = telegram.Bot(token=TELEGRAM_BOT_TOKEN)
await asyncio.gather(matrix_loop(), telegram_loop())
await asyncio.gather(matrix_loop(matrix_client), telegram_loop())
finally:
if matrix_client:
await matrix_client.close()
async def matrix_loop():
print(123)
async def matrix_loop(client):
await client.sync_forever(timeout=30000)
async def telegram_loop():
print(456)
print(456, file=sys.stderr)
async def matrix_on_message(room, event):
print(room, event, file=sys.stderr)
if __name__ == '__main__':
asyncio.run(main())