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…
	
	Add table
		Add a link
		
	
		Reference in a new issue