This repository was archived by the owner on Dec 5, 2021. It is now read-only.
GetFullChat + GetAllChats + MakeAuthBotAsync + Other methods #926
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -61,7 +61,7 @@ public TelegramClient(int apiId, string apiHash, | |
| this.handler = handler; | ||
|
|
||
| session = Session.TryLoadOrCreateNew(store, sessionUserId); | ||
| transport = new TcpTransport(session.DataCenter.Address, session.DataCenter.Port, this.handler); | ||
| } | ||
|
|
||
| public async Task ConnectAsync(bool reconnect = false, CancellationToken token = default(CancellationToken)) | ||
|
|
@@ -110,7 +110,7 @@ public TelegramClient(int apiId, string apiHash, | |
| } | ||
|
|
||
| var dc = dcOptions.First(d => d.Id == dcId); | ||
| var dataCenter = new DataCenter(dcId, dc.IpAddress, dc.Port); | ||
|
|
||
| transport = new TcpTransport(dc.IpAddress, dc.Port, handler); | ||
| session.DataCenter = dataCenter; | ||
|
|
@@ -131,15 +131,15 @@ public TelegramClient(int apiId, string apiHash, | |
| throw new InvalidOperationException("Not connected!"); | ||
|
|
||
| var completed = false; | ||
| while (!completed) | ||
| { | ||
| try | ||
| { | ||
| await sender.Send(request, token).ConfigureAwait(false); | ||
| await sender.Receive(request, token).ConfigureAwait(false); | ||
| completed = true; | ||
| } | ||
| catch (DataCenterMigrationException e) | ||
| { | ||
| if (session.DataCenter.DataCenterId.HasValue && | ||
| session.DataCenter.DataCenterId.Value == e.DC) | ||
|
|
@@ -193,7 +193,7 @@ public bool IsUserAuthorized() | |
|
|
||
| if (String.IsNullOrWhiteSpace(code)) | ||
| throw new ArgumentNullException(nameof(code)); | ||
|
|
||
| var request = new TLRequestSignIn() { PhoneNumber = phoneNumber, PhoneCodeHash = phoneCodeHash, PhoneCode = code }; | ||
|
|
||
| await RequestWithDcMigration(request, token).ConfigureAwait(false); | ||
|
|
@@ -202,7 +202,7 @@ public bool IsUserAuthorized() | |
|
|
||
| return ((TLUser)request.Response.User); | ||
| } | ||
|
|
||
| public async Task<TLPassword> GetPasswordSetting(CancellationToken token = default(CancellationToken)) | ||
| { | ||
| var request = new TLRequestGetPassword(); | ||
|
|
@@ -234,7 +234,7 @@ public bool IsUserAuthorized() | |
| public async Task<TLUser> SignUpAsync(string phoneNumber, string phoneCodeHash, string code, string firstName, string lastName, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| var request = new TLRequestSignUp() { PhoneNumber = phoneNumber, PhoneCode = code, PhoneCodeHash = phoneCodeHash, FirstName = firstName, LastName = lastName }; | ||
|
|
||
| await RequestWithDcMigration(request, token).ConfigureAwait(false); | ||
|
|
||
| OnUserAuthenticated((TLUser)request.Response.User); | ||
|
|
@@ -251,7 +251,7 @@ public bool IsUserAuthorized() | |
| return (T)result; | ||
| } | ||
|
|
||
| internal async Task<T> SendAuthenticatedRequestAsync<T>(TLMethod methodToExecute, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| if (!IsUserAuthorized()) | ||
| throw new InvalidOperationException("Authorize user first!"); | ||
|
|
@@ -278,23 +278,23 @@ public bool IsUserAuthorized() | |
|
|
||
| public async Task<TLImportedContacts> ImportContactsAsync(IReadOnlyList<TLInputPhoneContact> contacts, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| var req = new TLRequestImportContacts { Contacts = new TLVector<TLInputPhoneContact>(contacts) }; | ||
|
|
||
| return await SendAuthenticatedRequestAsync<TLImportedContacts>(req, token) | ||
| .ConfigureAwait(false); | ||
| } | ||
|
|
||
| public async Task<bool> DeleteContactsAsync(IReadOnlyList<TLAbsInputUser> users, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| var req = new TLRequestDeleteContacts { Id = new TLVector<TLAbsInputUser>(users) }; | ||
|
|
||
| return await SendAuthenticatedRequestAsync<bool>(req, token) | ||
| .ConfigureAwait(false); | ||
| } | ||
|
|
||
| public async Task<TLLink> DeleteContactAsync(TLAbsInputUser user, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| var req = new TLRequestDeleteContact { Id = user }; | ||
|
|
||
| return await SendAuthenticatedRequestAsync<TLLink>(req, token) | ||
| .ConfigureAwait(false); | ||
|
|
@@ -337,10 +337,10 @@ public bool IsUserAuthorized() | |
| offsetPeer = new TLInputPeerSelf(); | ||
|
|
||
| var req = new TLRequestGetDialogs() | ||
| { | ||
| OffsetDate = offsetDate, | ||
| OffsetId = offsetId, | ||
| OffsetPeer = offsetPeer, | ||
| Limit = limit | ||
| }; | ||
| return await SendAuthenticatedRequestAsync<TLAbsDialogs>(req, token) | ||
|
|
@@ -350,44 +350,44 @@ public bool IsUserAuthorized() | |
| public async Task<TLAbsUpdates> SendUploadedPhoto(TLAbsInputPeer peer, TLAbsInputFile file, string caption, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| return await SendAuthenticatedRequestAsync<TLAbsUpdates>(new TLRequestSendMedia() | ||
| { | ||
| RandomId = Helpers.GenerateRandomLong(), | ||
| Background = false, | ||
| ClearDraft = false, | ||
| Media = new TLInputMediaUploadedPhoto() { File = file, Caption = caption }, | ||
| Peer = peer | ||
| }, token) | ||
| .ConfigureAwait(false); | ||
| } | ||
|
|
||
| public async Task<TLAbsUpdates> SendUploadedDocument( | ||
| TLAbsInputPeer peer, TLAbsInputFile file, string caption, string mimeType, TLVector<TLAbsDocumentAttribute> attributes, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| return await SendAuthenticatedRequestAsync<TLAbsUpdates>(new TLRequestSendMedia() | ||
| { | ||
| RandomId = Helpers.GenerateRandomLong(), | ||
| Background = false, | ||
| ClearDraft = false, | ||
| Media = new TLInputMediaUploadedDocument() | ||
| { | ||
| File = file, | ||
| Caption = caption, | ||
| MimeType = mimeType, | ||
| Attributes = attributes | ||
| }, | ||
| Peer = peer | ||
| }, token) | ||
| .ConfigureAwait(false); | ||
| } | ||
|
|
||
| public async Task<TLFile> GetFile(TLAbsInputFileLocation location, int filePartSize, int offset = 0, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| TLFile result = await SendAuthenticatedRequestAsync<TLFile>(new TLRequestGetFile | ||
| { | ||
| Location = location, | ||
| Limit = filePartSize, | ||
| Offset = offset | ||
| }, token) | ||
| .ConfigureAwait(false); | ||
| return result; | ||
| } | ||
|
|
@@ -524,7 +524,7 @@ await sender.SendPingAsync(token) | |
| /// <param name="partType">The type of the participants to get. Choose Recents not to filter</param> | ||
| /// <param name="token"></param> | ||
| /// <returns></returns> | ||
| public async Task<TLChannelParticipants> GetParticipants(TLChannel channel, int stIdx = -1, int pageSize = -1, ParticipantFilterTypes partType = ParticipantFilterTypes.Recents, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| if (channel == null) return null; | ||
| return await GetParticipants(channel.Id, (long)channel.AccessHash, stIdx, pageSize, partType, token).ConfigureAwait(false); | ||
|
|
@@ -541,31 +541,31 @@ await sender.SendPingAsync(token) | |
| /// <param name="partType">The type of the participants to get. Choose Recents not to filter</param> | ||
| /// <param name="token"></param> | ||
| /// <returns></returns> | ||
| public async Task<TLChannelParticipants> GetParticipants(int channelId, long accessHash, int stIdx = -1, int pageSize = -1, ParticipantFilterTypes partType = ParticipantFilterTypes.Recents, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| TLAbsChannelParticipantsFilter filter; | ||
| switch (partType) | ||
| { | ||
| case ParticipantFilterTypes.Admins: | ||
| filter = new TLChannelParticipantsAdmins(); | ||
| break; | ||
|
|
||
| case ParticipantFilterTypes.Kicked: | ||
| filter = new TLChannelParticipantsKicked(); | ||
| break; | ||
|
|
||
| case ParticipantFilterTypes.Bots: | ||
| filter = new TLChannelParticipantsBots(); | ||
| break; | ||
|
|
||
| case ParticipantFilterTypes.Recents: | ||
| filter = new TLChannelParticipantsRecent(); | ||
| break; | ||
|
|
||
| case ParticipantFilterTypes.Banned: | ||
| case ParticipantFilterTypes.Restricted: | ||
| case ParticipantFilterTypes.Contacts: | ||
| case ParticipantFilterTypes.Search: | ||
| default: | ||
| throw new NotImplementedException($"{partType} not implemented yet"); | ||
|
There was a problem hiding this comment. If it's not gonna be implemented please remove them from your enum as the only purpose of enum is for this filter There was a problem hiding this comment. it's gonna be implemented as soon as the new Classes are added to the TL framework There was a problem hiding this comment. should i drop them anyways or leave them? There was a problem hiding this comment. are they present in the new layers? There was a problem hiding this comment. yes, see here: https://core.telegram.org/type/ChannelParticipantsFilter There was a problem hiding this comment. I vote, then, for only merging this PR after we have updated the layer |
||
| } | ||
|
|
@@ -588,7 +588,7 @@ await sender.SendPingAsync(token) | |
| ChannelId = channelId, | ||
| AccessHash = accessHash | ||
| }, | ||
| Filter = filter, | ||
| Offset = found, | ||
| Limit = pageSize | ||
| }; | ||
|
|
@@ -607,6 +607,16 @@ await sender.SendPingAsync(token) | |
| /// <summary> | ||
| /// Invites the passed users to the specified channel | ||
| /// </summary> | ||
| /// <param name="channel">The descriptor of the channel to invite the users to</param> | ||
| /// <param name="users"></param> | ||
| /// <returns></returns> | ||
| public async Task<TLUpdates> InviteToChannel(TLChannel channel, int[] users, CancellationToken token = default(CancellationToken)) | ||
| { | ||
| return await InviteToChannel(channel.Id, (long)channel.AccessHash, users, token); | ||
| } | ||
solarin marked this conversation as resolved.
Show resolved
Hide resolved
|
||
| /// <summary> | ||
| /// Invites the passed users to the specified channel | ||
| /// </summary> | ||
| /// <param name="channelId">The id of the channel to invite the users to</param> | ||
| /// <param name="accessHash">The access hash of the channel to invite the users to</param> | ||
| /// <param name="users"></param> | ||
|
|
||
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,6 +1,6 @@ | ||
| namespace TLSharp.Core.Types | ||
| { | ||
| public enum ParticipantFilterTypes | ||
| { | ||
| Recents, | ||
| Restricted, | ||
|
|
||
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you formatted the whole file again by mistake, can you create a separate PR just to format the file please?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
see the next commit