astra/gotdlib
1
0
Fork 0
mirror of https://github.com/c0re100/gotdlib.git synced 2026-02-21 20:20:17 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Make some delay to the UpdateMessageSendSucceeded listener

Browse source
This commit is contained in:
c0re100 2023-11-27 03:14:17 +08:00
parent ad108a3ee2
commit 563cd7d677
No known key found for this signature in database
GPG key ID: 7C3B3004FE745AAF
1 changed files with 12 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

13
client/client.go
View file

@ -134,7 +134,18 @@ func (client *Client) processResponse(response *Response) {
needGc := false needGc := false
for _, listener := range client.listenerStore.Listeners() { for _, listener := range client.listenerStore.Listeners() {
if listener.IsActive() && listener.Updates != nil && typ.GetType() == listener.Filter.GetType() { // All updates go to Updates channel if type == filter if listener.IsActive() && listener.Updates != nil && typ.GetType() == listener.Filter.GetType() { // All updates go to Updates channel if type == filter
listener.Updates <- typ // Make some delay to UpdateMessageSendSucceeded listener
// This can make UpdateMessageSendSucceeded response later than sendMessage response.
// This may help a bot developer to map temporary message id to actual message id easily.
// Cause an event listener slower than sendMessage response, so you have enough time to do mapping stuff.
if typ.GetType() == (&UpdateMessageSendSucceeded{}).GetType() {
go func(listener *Listener, typ Type) {
time.Sleep(5 * time.Millisecond)
listener.Updates <- typ
}(listener, typ)
} else {
listener.Updates <- typ
}
} else if listener.IsActive() && listener.RawUpdates != nil { // All updates go to RawUpdates channel if filter is empty } else if listener.IsActive() && listener.RawUpdates != nil { // All updates go to RawUpdates channel if filter is empty
listener.RawUpdates <- typ listener.RawUpdates <- typ
} else if !listener.IsActive() { // GC inactive listener } else if !listener.IsActive() { // GC inactive listener