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

Merge pull request #7 from nblockchain/allowReconnecting

Browse source 
Core: allow reconnecting same TelegramClient instance
This commit is contained in:
Andres G. Aragoneses 2020-04-12 23:06:54 +08:00 committed by GitHub
parent 10632fed22 6ff40930c1
commit 4d09ac711d
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
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,28 @@ 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 (CancellationToken token = default (CancellationToken))
{
await ConnectInternalAsync(false, token);
}
private async Task ConnectInternalAsync (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,11 +145,10 @@ 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 ConnectInternalAsync(true, token).ConfigureAwait(false);
if (session.TLUser != null) if (session.TLUser != null)
{ {