A conversation plugin class for pyrogram using inbuild Update Handlers

Complete list of handlers to be used without Handlers postfix :- https://docs.pyrogram.org/api/handlers#index

Use the package manager pip to install or simply copy the class file to your project.

pip install git+https://github.com/Ripeey/Conversation-Pyrogram

main.py Where the Client is initialized

from pyrogram import Client
from convopyro import Conversation

app = Client('MyApp')
Conversation(app) # That's it!

Then at any update handler

answer = client.listen.CallbackQuery(filters.user(update.from_user.id))

from convopyro import listen_message

@app.on_message(filters.command('start'))
async def start(client, message):
	await client.send_mesage(messsage.chat.id, "What's your name?")

	answer = await listen_message(client, messsage.chat.id, timeout=None)
	await answer.reply(f'hello {answer.text}')

The conversation class has 2 primary methods listen.Handler (Handlers like Message, CallbackQuery ...etc) and listen.Cancel for ending an ongoing listener.

The conversation listen.Message (or any other Handler) takes 3 parameters, default is None but either filter or id as parameter is required.

• filters : Single or Combined is required but this is optional if id is passed with a valid single user or chat filter (which will learn below).

• id : An unique id for each listen, this could be str, a single user filter or chat filter, this is mostly optional and only needed to Cancel() a conversation listen. If user/chat filter is passed then it combines itself with filters so you dont need to repeat again in filters using &, where as if str is used it's just used normally as id.

• timeout : Waiting time in seconds int for getting a response optional.

• Update : Based on handlers used could be one of received updates such as Message, CallbackQuery, etc.
• None : When listen gets cancel using listen.Cancel a None is return as response at listen callback.
• Exception : An asyncio.TimeoutError is raised if provided waiting time get's over.

The conversation listen.Cancel takes 1 required parameter. This method is used to cancel a specific conversation listen.

• id : An unique id provided during listen, this could be str, a single user filter or chat filter.

• Boolean : False if id provided already cancelled or invalid.

@app.on_callback_query(filters.regex(r'stop'))
async def _(client, query):
	# This will return response None at listen
	await client.listen.Cancel(filters.user(query.from_user.id))

@app.on_message(filters.regex(r'hi'))
async def _(client, message):
	button = InlineKeyboardMarkup([[InlineKeyboardButton('Cancel Question', callback_data = 'stop')]])
	question = await client.send_message(message.chat.id, 'Enter your name in 5s.', reply_markup = button)
	# A nice flow of conversation
	try:
		response = await client.listen.Message(filters.text, id = filters.user(message.from_user.id), timeout = 5)
	except asyncio.TimeoutError:
		await message.reply('Too late 5s gone.')
	else:
		if response:
			await response.reply(f'Hello {response.text}')
		else:
			await message.reply('Okay cancelled question!')
	finally:
		await question.delete()