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

More requests added

Browse source 
More requests added:
- GetDialogsRequest
- GetFileRequest
- GetHistoryRequest
- GetNearestDcRequest
- GetUsersRequest
This commit is contained in:
Lonami 2015-10-14 18:16:27 +02:00
parent 4bd4680fd6
commit dcdb2405b5
7 changed files with 338 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

90
TLSharp.Core/Requests/GetDialogsRequest.cs Normal file
View file

@ -0,0 +1,90 @@
using System;
using System.Collections.Generic;
using System.IO;
using TLSharp.Core.MTProto;
namespace TLSharp.Core.Requests
{
public class GetDialogsRequest : MTProtoRequest
{
int _offset;
int _max_id;
int _limit;
public List<Dialog> dialogs;
public List<Message> messages;
public List<Chat> chats;
public List<User> users;
public GetDialogsRequest(int offset, int max_id, int limit)
{
_offset = offset;
_max_id = max_id;
_limit = limit;
}
public override void OnSend(BinaryWriter writer)
{
writer.Write(0xeccf1df6);
writer.Write(_offset);
writer.Write(_max_id);
writer.Write(_limit);
}
public override void OnResponse(BinaryReader reader)
{
bool dialogsSlice = reader.ReadUInt32() == 0x71e094f3; // else dialogs#15ba6c40
if (dialogsSlice) reader.ReadInt32(); // count
// dialogs
var result = reader.ReadUInt32(); // vector#1cb5c415
int dialogs_len = reader.ReadInt32();
dialogs = new List<Dialog>(dialogs_len);
for (int dialogs_index = 0; dialogs_index < dialogs_len; dialogs_index++)
{
Dialog dialog_element;
dialog_element = TL.Parse<Dialog>(reader);
dialogs.Add(dialog_element);
}
// messages
var count = reader.ReadInt32();
int messages_len = reader.ReadInt32();
messages = new List<Message>(messages_len);
for (int message_index = 0; message_index < messages_len; message_index++)
{
Message messages_element;
messages_element = TL.Parse<Message>(reader);
messages.Add(messages_element);
}
// chats
count = reader.ReadInt32();
int chats_len = reader.ReadInt32();
chats = new List<Chat>(chats_len);
for (int chat_index = 0; chat_index < chats_len; chat_index++)
{
Chat chats_element;
chats_element = TL.Parse<Chat>(reader);
chats.Add(chats_element);
}
// users
count = reader.ReadInt32();
int users_len = reader.ReadInt32();
users = new List<User>(users_len);
for (int users_index = 0; users_index < users_len; users_index++)
{
User users_element;
users_element = TL.Parse<User>(reader);
users.Add(users_element);
}
}
public override void OnException(Exception exception)
{
throw new NotImplementedException();
}
public override bool Confirmed => true;
public override bool Responded { get; }
}
}

49
TLSharp.Core/Requests/GetFileRequest.cs Normal file
View file

@ -0,0 +1,49 @@
using System;
using System.IO;
using TLSharp.Core.MTProto;
namespace TLSharp.Core.Requests
{
class GetFileRequest : MTProtoRequest
{
InputFileLocation _location;
int _offset;
int _limit;
public storage_FileType type;
public int mtime;
public byte[] bytes;
public GetFileRequest(InputFileLocation location, int offset, int limit)
{
_location = location;
_offset = offset;
_limit = limit;
}
public override void OnSend(BinaryWriter writer)
{
writer.Write(0xe3a6cfb5);
_location.Write(writer);
writer.Write(_offset);
writer.Write(_limit);
}
public override void OnResponse(BinaryReader reader)
{
var code = reader.ReadUInt32(); // upload.file#96a18d5
type = TL.Parse<storage_FileType>(reader);
mtime = reader.ReadInt32();
bytes = reader.ReadBytes(_limit);
}
public override void OnException(Exception exception)
{
throw new NotImplementedException();
}
public override bool Confirmed => true;
public override bool Responded { get; }
}
}

72
TLSharp.Core/Requests/GetHistoryRequest.cs Normal file
View file

@ -0,0 +1,72 @@
using System;
using System.Collections.Generic;
using System.IO;
using TLSharp.Core.MTProto;
namespace TLSharp.Core.Requests
{
class GetHistoryRequest : MTProtoRequest
{
InputPeer _peer;
int _offset;
int _max_id;
int _limit;
public List<Message> messages;
public List<Chat> chats;
public List<User> users;
public GetHistoryRequest(InputPeer peer, int offset, int max_id, int limit)
{
_peer = peer;
_offset = offset;
_max_id = max_id;
_limit = limit;
}
public override void OnSend(BinaryWriter writer)
{
writer.Write(0x92a1df2f);
_peer.Write(writer);
writer.Write(_offset);
writer.Write(_max_id);
writer.Write(_limit);
}
public override void OnResponse(BinaryReader reader)
{
bool messagesSlice = reader.ReadUInt32() == 0xb446ae3; // else messages#8c718e87
if (messagesSlice) reader.ReadInt32(); // count
// messages
var result = reader.ReadUInt32(); // vector#1cb5c415
int messages_len = reader.ReadInt32();
messages = new List<Message>(messages_len);
for (int i = 0; i < messages_len; i++)
messages.Add(TL.Parse<Message>(reader));
// chats
reader.ReadUInt32();
int chats_len = reader.ReadInt32();
chats = new List<Chat>(chats_len);
for (int i = 0; i < chats_len; i++)
chats.Add(TL.Parse<Chat>(reader));
// users
reader.ReadUInt32();
int users_len = reader.ReadInt32();
users = new List<User>(users_len);
for (int i = 0; i < users_len; i++)
users.Add(TL.Parse<User>(reader));
}
public override void OnException(Exception exception)
{
throw new NotImplementedException();
}
public override bool Confirmed => true;
public override bool Responded { get; }
}
}

45
TLSharp.Core/Requests/GetNearestDcRequest.cs Normal file
View file

@ -0,0 +1,45 @@
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using TLSharp.Core.MTProto;
namespace TLSharp.Core.Requests
{
public class GetNearestDcRequest : MTProtoRequest
{
public string country;
public int this_dc;
public int nearest_dc;
public GetNearestDcRequest() { }
public override void OnSend(BinaryWriter writer)
{
writer.Write(0x1fb33026);
}
public override void OnResponse(BinaryReader reader)
{
var code = reader.ReadUInt32();
country = Serializers.String.read(reader);
this_dc = reader.ReadInt32();
nearest_dc = reader.ReadInt32();
System.Diagnostics.Debug.WriteLine("country: " + country);
System.Diagnostics.Debug.WriteLine("this_dc: " + this_dc);
System.Diagnostics.Debug.WriteLine("nearest: " + nearest_dc);
}
public override void OnException(Exception exception)
{
throw new NotImplementedException();
}
public override bool Confirmed => true;
public override bool Responded { get; }
}
}

49
TLSharp.Core/Requests/GetUsersRequest.cs Normal file
View file

@ -0,0 +1,49 @@
using System;
using System.Collections.Generic;
using System.IO;
using TLSharp.Core.MTProto;
namespace TLSharp.Core.Requests
{
class GetUsersRequest : MTProtoRequest
{
List<InputUser> _id;
public List<User> users;
public GetUsersRequest(List<InputUser> id)
{
_id = id;
}
public override void OnSend(BinaryWriter writer)
{
writer.Write(0xd91a548);
writer.Write(0x1cb5c415); // vector#1cb5c415
writer.Write(_id.Count); // vector length
foreach (var id in _id)
id.Write(writer);
}
public override void OnResponse(BinaryReader reader)
{
var code = reader.ReadUInt32();
var result = reader.ReadInt32(); // vector#1cb5c415
if (result != 0)
{
int users_len = reader.ReadInt32(); // vector length
users = new List<User>(users_len);
for (int i = 0; i < users_len; i++)
users.Add(TL.Parse<User>(reader));
}
}
public override void OnException(Exception exception)
{
throw new NotImplementedException();
}
public override bool Confirmed => true;
public override bool Responded { get; }
}
}

5
TLSharp.Core/TLSharp.Core.csproj
View file

@ -67,6 +67,11 @@
<Compile Include="Requests\AuthCheckPhoneRequest.cs" />
<Compile Include="Requests\AuthSendCodeRequest.cs" />
<Compile Include="Requests\AuthSignInRequest.cs" />
<Compile Include="Requests\GetDialogsRequest.cs" />
<Compile Include="Requests\GetFileRequest.cs" />
<Compile Include="Requests\GetHistoryRequest.cs" />
<Compile Include="Requests\GetNearestDcRequest.cs" />
<Compile Include="Requests\GetUsersRequest.cs" />
<Compile Include="Requests\ImportContactRequest.cs" />
<Compile Include="Requests\InitConnectionRequest.cs" />
<Compile Include="Requests\MTProtoRequest.cs" />

25
TLSharp.Core/TelegramClient.cs
View file

@ -1,4 +1,5 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TLSharp.Core.Auth;
@ -18,6 +19,11 @@ namespace TLSharp.Core
private int _apiId = 19474;
private Session _session;
public User loggedUser { get { return _session.User; } }
public List<Chat> chats;
public List<User> users;
public TelegramClient(ISessionStore store, string sessionUserId)
{
if (_apiId == 0)
@ -107,7 +113,26 @@ namespace TLSharp.Core
await _sender.Send(request);
await _sender.Recieve(request);
}
public async Task LoadChatsAndUsers(int offset, int max_id, int limit)
{
// GetDialogs
var request = new GetDialogsRequest(offset, max_id, limit);
await _sender.Send(request);
await _sender.Recieve(request);
chats = request.chats;
users = request.users;
}
public async Task<List<Message>> GetHistory(int user_id, int offset, int max_id, int limit)
{
var request = new GetHistoryRequest(new InputPeerContactConstructor(user_id), offset, max_id, limit);
await _sender.Send(request);
await _sender.Recieve(request);
return request.messages;
}
}
}