diff options
| author | bodqhrohro <bodqhrohro@gmail.com> | 2019-12-15 22:30:54 +0300 |
|---|---|---|
| committer | bodqhrohro <bodqhrohro@gmail.com> | 2019-12-15 22:30:54 +0300 |
| commit | 3918686f211a3eac60916a81423c64240ad1988a (patch) | |
| tree | 726c1d92ee1044a8bda0760a42963088b745740a | |
| parent | e43a0c314461b5e5b107a723e2cc3f9abe38b1f0 (diff) | |
Connect on probe presence (for clients that do not send online presence first)
| -rw-r--r-- | telegram/connect.go | 5 | ||||
| -rw-r--r-- | xmpp/handlers.go | 4 |
2 files changed, 6 insertions, 3 deletions
diff --git a/telegram/connect.go b/telegram/connect.go index b19e4ed..8988528 100644 --- a/telegram/connect.go +++ b/telegram/connect.go @@ -87,6 +87,9 @@ func (stateHandler *clientAuthorizer) Close() { // Connect starts TDlib connection func (c *Client) Connect() error { + // avoid conflict if another authorization is pending already + c.locks.authorizationReady.Wait() + if c.Online() { return nil } @@ -113,8 +116,8 @@ func (c *Client) Connect() error { } c.client = tdlibClient - c.locks.authorizationReady.Done() c.listener = tdlibClient.GetListener() + c.locks.authorizationReady.Done() go c.updateHandler() diff --git a/xmpp/handlers.go b/xmpp/handlers.go index 31c2b27..971ac86 100644 --- a/xmpp/handlers.go +++ b/xmpp/handlers.go @@ -236,8 +236,8 @@ func handlePresence(s xmpp.Sender, p stanza.Presence) { delete(sessions, bareFromJid) case "unavailable", "error": session.Disconnect() - case "", "online": - // due to the weird implentation of go-tdlib wrapper, it won't + case "probe", "", "online": + // due to the weird implementation of go-tdlib wrapper, it won't // return the client instance until successful authorization go func() { err = session.Connect() |