From 8b57552944ebba732333d9a48ebd35738950baec Mon Sep 17 00:00:00 2001 From: Alex Kotov Date: Sun, 8 Jan 2023 16:46:08 +0400 Subject: [PATCH] Add Matrix callback --- mirrortea | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/mirrortea b/mirrortea index 81c4c7a..1ac046d 100755 --- a/mirrortea +++ b/mirrortea @@ -14,20 +14,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) +async def matrix_on_message(room, event): + print(room, event) + if __name__ == '__main__': asyncio.run(main())