sochix/TLSharp
1
0
Fork 0
mirror of https://github.com/sochix/TLSharp.git synced 2025-12-06 08:02:00 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Core: allow reconnecting same TelegramClient instance

Browse source 
Fixes https://github.com/sochix/TLSharp/issues/930
This commit is contained in:
solarin 2020-04-12 02:14:54 +08:00 committed by Andres G. Aragoneses
parent 874cfd07a2
commit 94775cebd8
1 changed files with 8 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/TgSharp.Core/TelegramClient.cs
View file

@ -28,6 +28,8 @@ namespace TgSharp.Core
private TcpTransport transport; private TcpTransport transport;
private string apiHash = String.Empty; private string apiHash = String.Empty;
private int apiId = 0; private int apiId = 0;
private string sessionUserId;
private ISessionStore store;
private Session session; private Session session;
private List<TLDcOption> dcOptions; private List<TLDcOption> dcOptions;
private TcpClientConnectionHandler handler; private TcpClientConnectionHandler handler;
@ -58,20 +60,23 @@ namespace TgSharp.Core
if (store == null) if (store == null)
store = new FileSessionStore(); store = new FileSessionStore();
this.store = store;
this.apiHash = apiHash; this.apiHash = apiHash;
this.apiId = apiId; this.apiId = apiId;
this.handler = handler; this.handler = handler;
this.dcIpVersion = dcIpVersion; this.dcIpVersion = dcIpVersion;
session = Session.TryLoadOrCreateNew(store, sessionUserId); this.sessionUserId = sessionUserId;
transport = new TcpTransport (session.DataCenter.Address, session.DataCenter.Port, this.handler);
} }
public async Task ConnectAsync(bool reconnect = false, CancellationToken token = default(CancellationToken)) public async Task ConnectAsync(bool reconnect = false, CancellationToken token = default(CancellationToken))
{ {
token.ThrowIfCancellationRequested(); token.ThrowIfCancellationRequested();
session = Session.TryLoadOrCreateNew (store, sessionUserId);
transport = new TcpTransport (session.DataCenter.Address, session.DataCenter.Port, this.handler);
if (session.AuthKey == null || reconnect) if (session.AuthKey == null || reconnect)
{ {
var result = await Authenticator.DoAuthentication(transport, token).ConfigureAwait(false); var result = await Authenticator.DoAuthentication(transport, token).ConfigureAwait(false);
@ -135,9 +140,8 @@ namespace TgSharp.Core
dc = dcs.First(); dc = dcs.First();
var dataCenter = new DataCenter (dcId, dc.IpAddress, dc.Port); var dataCenter = new DataCenter (dcId, dc.IpAddress, dc.Port);
transport = new TcpTransport(dc.IpAddress, dc.Port, handler);
session.DataCenter = dataCenter; session.DataCenter = dataCenter;
session.Save();
await ConnectAsync(true, token).ConfigureAwait(false); await ConnectAsync(true, token).ConfigureAwait(false);