Connect on probe presence (for clients that do not send online presence first)

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()
 

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()