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

undone the 'async' changes.

Browse source
This commit is contained in:
Paulo Rogério Panhoto 2017-12-29 11:39:50 -02:00
parent cf983474b4
commit 017f5ddc1b
1 changed files with 11 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
TLSharp.Core/Network/MtProtoSender.cs
View file

@ -145,7 +145,7 @@ namespace TLSharp.Core.Network
using (var messageStream = new MemoryStream (result.Item1, false)) using (var messageStream = new MemoryStream (result.Item1, false))
using (var messageReader = new BinaryReader (messageStream)) using (var messageReader = new BinaryReader (messageStream))
{ {
await processMessage (result.Item2, result.Item3, messageReader, request); processMessage (result.Item2, result.Item3, messageReader, request);
} }
} }
@ -159,7 +159,7 @@ namespace TLSharp.Core.Network
using (var messageStream = new MemoryStream (result.Item1, false)) using (var messageStream = new MemoryStream (result.Item1, false))
using (var messageReader = new BinaryReader (messageStream)) using (var messageReader = new BinaryReader (messageStream))
{ {
await processMessage (result.Item2, result.Item3, messageReader, null); processMessage (result.Item2, result.Item3, messageReader, null);
} }
return null; return null;
@ -178,7 +178,7 @@ namespace TLSharp.Core.Network
await Receive(pingRequest); await Receive(pingRequest);
} }
private async Task<bool> processMessage(ulong messageId, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request) private bool processMessage(ulong messageId, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request)
{ {
// TODO: check salt // TODO: check salt
// TODO: check sessionid // TODO: check sessionid
@ -195,7 +195,7 @@ namespace TLSharp.Core.Network
{ {
case 0x73f1f8dc: // container case 0x73f1f8dc: // container
//logger.debug("MSG container"); //logger.debug("MSG container");
return await HandleContainer(messageId, sequence, messageReader, request); return HandleContainer(messageId, sequence, messageReader, request);
case 0x7abe77ec: // ping case 0x7abe77ec: // ping
//logger.debug("MSG ping"); //logger.debug("MSG ping");
return HandlePing(messageId, sequence, messageReader); return HandlePing(messageId, sequence, messageReader);
@ -225,21 +225,21 @@ namespace TLSharp.Core.Network
return HandleRpcResult(messageId, sequence, messageReader, request); return HandleRpcResult(messageId, sequence, messageReader, request);
case 0x3072cfa1: // gzip_packed case 0x3072cfa1: // gzip_packed
//logger.debug("MSG gzip_packed"); //logger.debug("MSG gzip_packed");
return await HandleGzipPacked(messageId, sequence, messageReader, request); return HandleGzipPacked(messageId, sequence, messageReader, request);
case 0xe317af7e: case 0xe317af7e:
case 0xd3f45784: case 0xd3f45784:
case 0x2b2fbd4e: case 0x2b2fbd4e:
case 0x78d4dec1: case 0x78d4dec1:
case 0x725b04c3: case 0x725b04c3:
case 0x74ae4240: case 0x74ae4240:
return await HandleUpdate(code, sequence, messageReader, request); return HandleUpdate(code, sequence, messageReader, request);
default: default:
//logger.debug("unknown message: {0}", code); //logger.debug("unknown message: {0}", code);
return false; return false;
} }
} }
private async Task<bool> HandleUpdate(uint code, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request) private bool HandleUpdate(uint code, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request)
{ {
try try
{ {
@ -281,14 +281,14 @@ namespace TLSharp.Core.Network
return update; return update;
} }
private async Task<bool> HandleGzipPacked(ulong messageId, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request) private bool HandleGzipPacked(ulong messageId, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request)
{ {
uint code = messageReader.ReadUInt32(); uint code = messageReader.ReadUInt32();
byte[] packedData = GZipStream.UncompressBuffer(Serializers.Bytes.read(messageReader)); byte[] packedData = GZipStream.UncompressBuffer(Serializers.Bytes.read(messageReader));
using (MemoryStream packedStream = new MemoryStream(packedData, false)) using (MemoryStream packedStream = new MemoryStream(packedData, false))
using (BinaryReader compressedReader = new BinaryReader(packedStream)) using (BinaryReader compressedReader = new BinaryReader(packedStream))
{ {
await processMessage(messageId, sequence, compressedReader, request); processMessage(messageId, sequence, compressedReader, request);
} }
return true; return true;
@ -539,7 +539,7 @@ namespace TLSharp.Core.Network
return false; return false;
} }
private async Task<bool> HandleContainer(ulong messageId, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request) private bool HandleContainer(ulong messageId, int sequence, BinaryReader messageReader, TeleSharp.TL.TLMethod request)
{ {
uint code = messageReader.ReadUInt32(); uint code = messageReader.ReadUInt32();
int size = messageReader.ReadInt32(); int size = messageReader.ReadInt32();
@ -551,7 +551,7 @@ namespace TLSharp.Core.Network
long beginPosition = messageReader.BaseStream.Position; long beginPosition = messageReader.BaseStream.Position;
try try
{ {
if (!await processMessage(innerMessageId, sequence, messageReader, request)) if (!processMessage(innerMessageId, sequence, messageReader, request))
{ {
messageReader.BaseStream.Position = beginPosition + innerLength; messageReader.BaseStream.Position = beginPosition + innerLength;
} }