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

API modified to receive events instead of relying on polling to update chats.

Browse source
This commit is contained in:
Paulo Rogerio Panhoto 2018-01-02 18:04:21 -02:00
parent 017f5ddc1b
commit f871597de7
1 changed files with 19 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -18,6 +18,8 @@ namespace TLSharp.Core.Network
{ {
//private ulong sessionId = GenerateRandomUlong(); //private ulong sessionId = GenerateRandomUlong();
private readonly uint UpdatesTooLongID = (uint) new TeleSharp.TL.TLUpdatesTooLong ().Constructor;
private TcpTransport _transport; private TcpTransport _transport;
private Session _session; private Session _session;
@ -190,7 +192,6 @@ namespace TLSharp.Core.Network
uint code = messageReader.ReadUInt32(); uint code = messageReader.ReadUInt32();
messageReader.BaseStream.Position -= 4; messageReader.BaseStream.Position -= 4;
Console.WriteLine ("Msg code: {0:x8}", code);
switch (code) switch (code)
{ {
case 0x73f1f8dc: // container case 0x73f1f8dc: // container
@ -227,14 +228,15 @@ namespace TLSharp.Core.Network
//logger.debug("MSG gzip_packed"); //logger.debug("MSG gzip_packed");
return HandleGzipPacked(messageId, sequence, messageReader, request); return HandleGzipPacked(messageId, sequence, messageReader, request);
case 0xe317af7e: case 0xe317af7e:
case 0xd3f45784: case 0x914fbf11:
case 0x2b2fbd4e: case 0x16812688:
case 0x78d4dec1: case 0x78d4dec1:
case 0x725b04c3: case 0x725b04c3:
case 0x74ae4240: case 0x74ae4240:
case 0x11f1331c:
return HandleUpdate(code, sequence, messageReader, request); return HandleUpdate(code, sequence, messageReader, request);
default: default:
//logger.debug("unknown message: {0}", code); Console.WriteLine ("Msg code: {0:x8}", code);
return false; return false;
} }
} }
@ -244,11 +246,14 @@ namespace TLSharp.Core.Network
try try
{ {
var update = ParseUpdate (code, messageReader); var update = ParseUpdate (code, messageReader);
if (update != null && UpdatesEvent != null) if (update != null && UpdatesEvent != null)
UpdatesEvent(update); {
UpdatesEvent (update);
}
} }
catch catch (Exception ex)
{ {
Console.WriteLine (ex);
} }
return false; return false;
} }
@ -259,9 +264,9 @@ namespace TLSharp.Core.Network
{ {
case 0xe317af7e: case 0xe317af7e:
return DecodeUpdate<TeleSharp.TL.TLUpdatesTooLong>(messageReader); return DecodeUpdate<TeleSharp.TL.TLUpdatesTooLong>(messageReader);
case 0xd3f45784: case 0x914fbf11:
return DecodeUpdate<TeleSharp.TL.TLUpdateShortMessage> (messageReader); return DecodeUpdate<TeleSharp.TL.TLUpdateShortMessage> (messageReader);
case 0x2b2fbd4e: case 0x16812688:
return DecodeUpdate<TeleSharp.TL.TLUpdateShortChatMessage> (messageReader); return DecodeUpdate<TeleSharp.TL.TLUpdateShortChatMessage> (messageReader);
case 0x78d4dec1: case 0x78d4dec1:
return DecodeUpdate<TeleSharp.TL.TLUpdateShort> (messageReader); return DecodeUpdate<TeleSharp.TL.TLUpdateShort> (messageReader);
@ -269,15 +274,17 @@ namespace TLSharp.Core.Network
return DecodeUpdate<TeleSharp.TL.TLUpdatesCombined> (messageReader); return DecodeUpdate<TeleSharp.TL.TLUpdatesCombined> (messageReader);
case 0x74ae4240: case 0x74ae4240:
return DecodeUpdate<TeleSharp.TL.TLUpdates> (messageReader); return DecodeUpdate<TeleSharp.TL.TLUpdates> (messageReader);
case 0x11f1331c:
return DecodeUpdate<TeleSharp.TL.TLUpdateShortSentMessage> (messageReader);
default: default:
return null; return null;
} }
} }
private TeleSharp.TL.TLAbsUpdates DecodeUpdate<T>(BinaryReader messageReader) where T: TeleSharp.TL.TLAbsUpdates, new() private TeleSharp.TL.TLAbsUpdates DecodeUpdate<T>(BinaryReader messageReader) where T: TeleSharp.TL.TLAbsUpdates
{ {
var update = new T (); var ms = messageReader.BaseStream as MemoryStream;
update.DeserializeBody (messageReader); var update = (T) TeleSharp.TL.ObjectUtils.DeserializeObject (messageReader);
return update; return update;
} }