Conversation ​

A conversation is an object that represents some chat and all messages inside it since the start of the conversation until it is stopped.

Usage ​

Create a Conversation object and pass TelegramClient and the peer you want there:

const conv = new Conversation(tg, 'stickers')

const conv = new Conversation(tg, 'stickers')

Then, use .with(), and inside it you can interact with the other party:

await conv.with(async () => {
    await conv.sendText('Hello!')
    await conv.waitForResponse()
})

await conv.with(async () => {
    await conv.sendText('Hello!')
    await conv.waitForResponse()
})

await conv.start()
try {
    // ... code ...
} catch (e) {}
conv.stop()

await conv.start()
try {
    // ... code ...
} catch (e) {}
conv.stop()

Sending messages ​

To send messages, use conv.sendText, conv.sendMedia and conv.sendMediaGroup methods:

await conv.sendText('Hello!')
await conv.sendMedia('BQACAgEAAx...Z2mGB8E')
await conv.sendMediaGroup(['BQACAgEAAx...Z2mGB8E', 'BQACAgEAAx...Z2mGB8E'])

await conv.sendText('Hello!')
await conv.sendMedia('BQACAgEAAx...Z2mGB8E')
await conv.sendMediaGroup(['BQACAgEAAx...Z2mGB8E', 'BQACAgEAAx...Z2mGB8E'])

DO NOT use client methods like tg.sendText, because conversation state won't properly be updated.

Waiting for events ​

Currently, Conversation supports waiting for new messages, edits and read acknowledgments:

await conv.sendText('Hello!')
await conv.waitForNewMessage()

await conv.sendText('Hello!')
await conv.waitForRead()

await conv.sendText('Hello!')
await conv.waitForNewMessage()
await conv.sendText('Now edit that')
await conv.waitForEdit()

await conv.sendText('Hello!')
await conv.waitForNewMessage()

await conv.sendText('Hello!')
await conv.waitForRead()

await conv.sendText('Hello!')
await conv.waitForNewMessage()
await conv.sendText('Now edit that')
await conv.waitForEdit()

Smarter waiting ​

Instead of waitForNewMessage, you can use waitForResponse or waitForReply.

waitForResponse will wait for a message which was sent strictly after the given message (by default, the last one)

waitForReply will wait for a message which is a reply to the given message (by default, the last one)

Timeouts ​

By default, for every waitFor* method a timeout of 15 seconds is applied. If the event does not occur within those, MtTimeoutError is thrown.

This is a pretty generous default when interacting with bots. However, if you are interacting with other people (which you shouldn't, use scenes instead), you may want to raise the timeout or disable it altogether.

To do that, you can pass timeout parameter to the functions:

await conv.waitForNewMessage(filters.any, 60_000) // 60 sec timeout
await conv.waitForResponse(filters.any, { timeout: null }) // disable timeout

await conv.waitForNewMessage(filters.any, 60_000) // 60 sec timeout
await conv.waitForResponse(filters.any, { timeout: null }) // disable timeout

Filters ​

You can apply dispatcher filters to the waitFor* methods:

await conv.waitForNewMessage(filters.regex(/welcome/i))

await conv.waitForNewMessage(filters.regex(/welcome/i))

Since dispatcher filters are simple functions, you can also use custom filters:

await conv.waitForResponse((msg) => msg.id > 42)

await conv.waitForResponse((msg) => msg.id > 42)

If a newly received message (or other update) does not match the filter, it will be ignored.