Compare commits
2 commits
4e32665882
...
2972cca582
Author | SHA1 | Date | |
---|---|---|---|
2972cca582 | |||
8b57552944 |
1 changed files with 12 additions and 4 deletions
16
mirrortea
16
mirrortea
|
@ -1,6 +1,7 @@
|
||||||
#!/usr/bin/env python3
|
#!/usr/bin/env python3
|
||||||
|
|
||||||
import asyncio
|
import asyncio
|
||||||
|
import sys
|
||||||
|
|
||||||
import aiogram as telegram
|
import aiogram as telegram
|
||||||
import nio as matrix
|
import nio as matrix
|
||||||
|
@ -14,20 +15,27 @@ async def main():
|
||||||
try:
|
try:
|
||||||
matrix_client = \
|
matrix_client = \
|
||||||
matrix.AsyncClient(MATRIX_HOMESERVER_URL, MATRIX_FULL_USER_ID)
|
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)
|
await matrix_client.login(MATRIX_PASSWORD)
|
||||||
|
|
||||||
telegram_client = telegram.Bot(token=TELEGRAM_BOT_TOKEN)
|
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:
|
finally:
|
||||||
if matrix_client:
|
if matrix_client:
|
||||||
await matrix_client.close()
|
await matrix_client.close()
|
||||||
|
|
||||||
async def matrix_loop():
|
async def matrix_loop(client):
|
||||||
print(123)
|
await client.sync_forever(timeout=30000)
|
||||||
|
|
||||||
async def telegram_loop():
|
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__':
|
if __name__ == '__main__':
|
||||||
asyncio.run(main())
|
asyncio.run(main())
|
||||||
|
|
Loading…
Reference in a new issue