diff --git a/go.mod b/go.mod
index e2d0eb78..69ee3dea 100644
--- a/go.mod
+++ b/go.mod
@@ -57,4 +57,4 @@ require (
 	rsc.io/qr v0.2.0 // indirect
 )
 
-replace github.com/gotd/td => github.com/beeper/td v0.107.1-0.20240910034630-041e169998aa
+replace github.com/gotd/td => github.com/beeper/td v0.107.1-0.20240910142745-d8981eddae3e
diff --git a/go.sum b/go.sum
index 9ea1720e..6e0a1479 100644
--- a/go.sum
+++ b/go.sum
@@ -2,8 +2,8 @@ filippo.io/edwards25519 v1.1.0 h1:FNf4tywRC1HmFuKW5xopWpigGjJKiJSV0Cqo0cJWDaA=
 filippo.io/edwards25519 v1.1.0/go.mod h1:BxyFTGdWcka3PhytdK4V28tE5sGfRvvvRV7EaN4VDT4=
 github.com/DATA-DOG/go-sqlmock v1.5.2 h1:OcvFkGmslmlZibjAjaHm3L//6LiuBgolP7OputlJIzU=
 github.com/DATA-DOG/go-sqlmock v1.5.2/go.mod h1:88MAG/4G7SMwSE3CeA0ZKzrT5CiOU3OJ+JlNzwDqpNU=
-github.com/beeper/td v0.107.1-0.20240910034630-041e169998aa h1:MrwT5FYp/1YAdApBM+2pQzekaVH9BZVVkK4+osYfHfU=
-github.com/beeper/td v0.107.1-0.20240910034630-041e169998aa/go.mod h1:rHtaG0hd4EY0ice4f9CVH/JxsA7ZICqkcH3aFSVZplg=
+github.com/beeper/td v0.107.1-0.20240910142745-d8981eddae3e h1:rGY9oRvWi/22wRqQrwiLo2I1EcI+4f1VZ2Q5xh3MLLs=
+github.com/beeper/td v0.107.1-0.20240910142745-d8981eddae3e/go.mod h1:rHtaG0hd4EY0ice4f9CVH/JxsA7ZICqkcH3aFSVZplg=
 github.com/cenkalti/backoff/v4 v4.3.0 h1:MyRJ/UdXutAwSAT+s3wNd7MfTIcy71VQueUuFK343L8=
 github.com/cenkalti/backoff/v4 v4.3.0/go.mod h1:Y3VNntkOUPxTVeUxJ/G5vcM//AlwfmyYozVcomhLiZE=
 github.com/coreos/go-systemd/v22 v22.5.0 h1:RrqgGjYQKalulkV8NGVIfkXQf6YYmOyiJKk8iXXhfZs=
diff --git a/pkg/connector/client.go b/pkg/connector/client.go
index 6ae31f2f..bbb5c9ba 100644
--- a/pkg/connector/client.go
+++ b/pkg/connector/client.go
@@ -195,7 +195,8 @@ func NewTelegramClient(ctx context.Context, tc *TelegramConnector, login *bridge
 		Logger:               zaplog,
 		UpdateHandler:        client.updatesManager,
 		OnDead:               client.onDead,
-		OnConnected:          client.onConnected,
+		OnSession:            client.onConnectionStateChange,
+		OnConnected:          client.onConnectionStateChange,
 		OnAuthError:          client.onAuthError,
 		PingTimeout:          time.Duration(tc.Config.Ping.TimeoutSeconds) * time.Second,
 		PingInterval:         time.Duration(tc.Config.Ping.IntervalSeconds) * time.Second,
@@ -349,7 +350,7 @@ func (t *TelegramClient) onDead() {
 	})
 }
 
-func (t *TelegramClient) onConnected() {
+func (t *TelegramClient) onConnectionStateChange() {
 	authStatus, err := t.client.Auth().Status(context.Background())
 	if err != nil {
 		t.userLogin.BridgeState.Send(status.BridgeState{