Async session for telethon

Installation

pip install telethon_asyncpg
# Or with poetry
poetry add telethon_asyncpg

Usage

import ssl  # optional

from telethon import events, TelegramClient

from telethon_asyncpg import AsyncpgSession, install
install()

URI = ???  # URI-string
# dialect+driver://username:password@host:port/database

pgconf = dict(dsn=URI, min_size=5, max_size=5)
# to overcome problem with TLS connection to db pass
# ssl=ssl.SSLContext(protocol=ssl.PROTOCOL_TLS) to pgconf
session = AsyncpgSession(pgconf, session_id_factory=???)
# session_id_factory is any callable with "() -> str" signature
# default factory is uuid4 str generator. why factory? (it's not really factory ik)
bot = TelegramClient(session=session, api_id=???, api_hash=???)

@bot.on(events.NewMessage())
async def message_handler(message):
    await message.reply("Hi!")

async def start():
    await bot.start()
    print(await bot.get_entity("martin_winks"))
    await bot.run_until_disconnected()

if __name__ == '__main__':
    import asyncio
    asyncio.get_event_loop().run_until_complete(start())

• AsyncpgSession can also use shared pool by AsyncpgSession.with_pool initializer-method

my_pool = asyncpg.create_pool(...)
session = AsyncpgSession.with_pool(my_pool, lambda: "session-id", True)

Check out the examples/ folder for more realistic examples.

Contribution

Currently we have only asyncpg session available, if you want to contribute with your wrapper - welcome. Take AsyncpgSession as an example.

For contributors

# install poetry dependency manager
# Fork/Fork+Clone && cd {{cloned}}
poetry install
# happy hacking!

References

Telethon: here asyncpg pg-driver: asyncpg