WTelegramClient/Examples/Program_ListenUpdates.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using TL;

namespace WTelegramClientTest
{
	class Program_ListenUpdates
	{
		static string Config(string what)
		{
			// go to Project Properties > Debug > Environment variables and add at least these: api_id, api_hash, phone_number
			if (what == "verification_code") { Console.Write("Code: "); return Console.ReadLine(); }
			return Environment.GetEnvironmentVariable(what);
		}

		static async Task Main(string[] _)
		{
			Console.WriteLine("The program will display updates received for the logged-in user. Press any key to terminate");
			WTelegram.Helpers.Log += (l, s) => System.Diagnostics.Debug.WriteLine(s);
			using var client = new WTelegram.Client(Config) { CollectAccessHash = true };
			client.Update += Client_Update;
			await client.ConnectAsync();
			var my = await client.LoginUserIfNeeded();
			users[my.id] = my;
			// note that on logging, Telegram may sends a bunch of updates/messages that happened in the past and were not acknowledged
			Console.WriteLine($"We are logged-in as {my.username ?? my.first_name + " " + my.last_name} (id {my.id})");
			var dialogsBase = await client.Messages_GetDialogs(default, 0, InputPeer.Empty, 0, 0);
			if (dialogsBase is Messages_Dialogs dialogs)
				while (dialogs.dialogs.Length != 0)
				{
					foreach (var user in dialogs.users) users[user.ID] = user;
					foreach (var chat in dialogs.chats) chats[chat.ID] = chat;
					var lastDialog = (Dialog)dialogs.dialogs[^1];
					var lastMsg = dialogs.messages.LastOrDefault(m => m.Peer.ID == lastDialog.peer.ID && m.ID == lastDialog.top_message);
					InputPeer offsetPeer = lastDialog.peer is PeerUser pu ? dialogs.users.First(u => u.ID == pu.ID)
						 : dialogs.chats.First(u => u.ID == lastDialog.peer.ID);
					dialogs = (Messages_Dialogs)await client.Messages_GetDialogs(lastMsg?.Date ?? default, lastDialog.top_message, offsetPeer, 500, 0);
				}
			Console.ReadKey();
			await client.Ping(43); // dummy API call.. this is used to force an acknowledge on this session's updates
		}


		private static readonly Dictionary<long, UserBase> users = new();
		private static readonly Dictionary<long, ChatBase> chats = new();
		private static string AUser(long user_id) => users.TryGetValue(user_id, out var user) ? user.DisplayName : $"User {user_id}";
		private static string AChat(long chat_id) => chats.TryGetValue(chat_id, out var chat) ? chat.Title : $"Chat {chat_id}";
		private static string APeer(Peer peer) => peer is null ? null : peer is PeerUser user ? AUser(user.user_id)
			: peer is PeerChat chat ? AChat(chat.chat_id) : peer is PeerChannel channel ? AChat(channel.channel_id) : $"Peer {peer.ID}";

		private static void Client_Update(ITLObject arg)
		{
			switch (arg)
			{
				case UpdateShortMessage usm: Console.WriteLine($"{AUser(usm.user_id)}> {usm.message}"); break;
				case UpdateShortChatMessage uscm: Console.WriteLine($"{AUser(uscm.from_id)} in {AChat(uscm.chat_id)}> {uscm.message}"); break;
				case UpdateShortSentMessage: Console.WriteLine($"You sent a message"); break;
				case UpdateShort updateShort: DisplayUpdate(updateShort.update); break;
				case Updates u:
					foreach (var user in u.users) users[user.ID] = user;
					foreach (var chat in u.chats) chats[chat.ID] = chat;
					foreach (var update in u.updates) DisplayUpdate(update);
					break;
				case UpdatesCombined uc:
					foreach (var user in uc.users) users[user.ID] = user;
					foreach (var chat in uc.chats) chats[chat.ID] = chat;
					foreach (var update in uc.updates) DisplayUpdate(update);
					break;
				default: Console.WriteLine(arg.GetType().Name); break;
			}
		}

		private static void DisplayUpdate(Update update)
		{
			switch (update)
			{
				case UpdateNewMessage unm: DisplayMessage(unm.message); break;
				case UpdateEditMessage uem: Console.Write("(Edit): "); DisplayMessage(uem.message); break;
				case UpdateDeleteChannelMessages udcm: Console.WriteLine($"{udcm.messages.Length} message(s) deleted in {AChat(udcm.channel_id)}"); break;
				case UpdateDeleteMessages udm: Console.WriteLine($"{udm.messages.Length} message(s) deleted"); break;
				case UpdateUserTyping uut: Console.WriteLine($"{AUser(uut.user_id)} is {uut.action.GetType().Name[11..^6]}"); break;
				case UpdateChatUserTyping ucut: Console.WriteLine($"{APeer(ucut.from_id)} is {ucut.action.GetType().Name[11..^6]} in {AChat(ucut.chat_id)}"); break;
				case UpdateChannelUserTyping ucut2: Console.WriteLine($"{APeer(ucut2.from_id)} is {ucut2.action.GetType().Name[11..^6]} in {AChat(ucut2.channel_id)}"); break;
				case UpdateChatParticipants { participants: ChatParticipants cp }: Console.WriteLine($"{cp.participants.Length} participants in {AChat(cp.chat_id)}"); break;
				case UpdateUserStatus uus: Console.WriteLine($"{AUser(uus.user_id)} is now {uus.status.GetType().Name[10..]}"); break;
				case UpdateUserName uun: Console.WriteLine($"{AUser(uun.user_id)} has changed profile name: @{uun.username} {uun.first_name} {uun.last_name}"); break;
				case UpdateUserPhoto uup: Console.WriteLine($"{AUser(uup.user_id)} has changed profile photo"); break;
				default: Console.WriteLine(update.GetType().Name); break;
			}
		}

		private static void DisplayMessage(MessageBase messageBase)
		{
			switch (messageBase)
			{
				case Message m: Console.WriteLine($"{APeer(m.from_id) ?? m.post_author} in {APeer(m.peer_id)}> {m.message}"); break;
				case MessageService ms: Console.WriteLine($"{APeer(ms.from_id)} in {APeer(ms.peer_id)} [{ms.action.GetType().Name[13..]}]"); break;
			}
		}
	}
}