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
	{
		// go to Project Properties > Debug > Environment variables and add at least these: api_id, api_hash, phone_number
		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(Environment.GetEnvironmentVariable);
			client.Update += Client_Update;
			var my = await client.LoginUserIfNeeded();
			_users[my.id] = my;
			// Note that on login 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})");
			// We collect all infos about the users/chats so that updates can be printed with their names
			var dialogsBase = await client.Messages_GetDialogs(default, 0, null, 0, 0); // dialogs = groups/channels/users
			if (dialogsBase is Messages_Dialogs dialogs)
				while (dialogs.dialogs.Length != 0)
				{
					foreach (var (id, user) in dialogs.users) _users[id] = user;
					foreach (var (id, chat) in dialogs.chats) _chats[id] = chat;
					var lastDialog = dialogs.dialogs[^1];
					var lastMsg = dialogs.messages.LastOrDefault(m => m.Peer.ID == lastDialog.Peer.ID && m.ID == lastDialog.TopMessage);
					var offsetPeer = dialogs.UserOrChat(lastDialog).ToInputPeer();
					dialogs = (Messages_Dialogs)await client.Messages_GetDialogs(lastMsg?.Date ?? default, lastDialog.TopMessage, offsetPeer, 500, 0);
				}
			Console.ReadKey();
		}


		private static readonly Dictionary<long, UserBase> _users = new();
		private static readonly Dictionary<long, ChatBase> _chats = new();
		private static string User(long id) => _users.TryGetValue(id, out var user) ? user.ToString() : $"User {id}";
		private static string Chat(long id) => _chats.TryGetValue(id, out var chat) ? chat.ToString() : $"Chat {id}";
		private static string Peer(Peer peer) => peer is null ? null : peer is PeerUser user ? User(user.user_id)
			: peer is PeerChat or PeerChannel ? Chat(peer.ID) : $"Peer {peer.ID}";

		private static void Client_Update(IObject arg)
		{
			if (arg is not UpdatesBase updates) return;
			foreach(var (id, user) in updates.Users) _users[id] = user;
			foreach(var (id, chat) in updates.Chats) _chats[id] = chat;
			foreach (var update in updates.UpdateList)
				switch (update)
				{
					case UpdateNewMessage unm: DisplayMessage(unm.message); break;
					case UpdateEditMessage uem: DisplayMessage(uem.message, true); break;
					case UpdateDeleteChannelMessages udcm: Console.WriteLine($"{udcm.messages.Length} message(s) deleted in {Chat(udcm.channel_id)}"); break;
					case UpdateDeleteMessages udm: Console.WriteLine($"{udm.messages.Length} message(s) deleted"); break;
					case UpdateUserTyping uut: Console.WriteLine($"{User(uut.user_id)} is {uut.action}"); break;
					case UpdateChatUserTyping ucut: Console.WriteLine($"{Peer(ucut.from_id)} is {ucut.action} in {Chat(ucut.chat_id)}"); break;
					case UpdateChannelUserTyping ucut2: Console.WriteLine($"{Peer(ucut2.from_id)} is {ucut2.action} in {Chat(ucut2.channel_id)}"); break;
					case UpdateChatParticipants { participants: ChatParticipants cp }: Console.WriteLine($"{cp.participants.Length} participants in {Chat(cp.chat_id)}"); break;
					case UpdateUserStatus uus: Console.WriteLine($"{User(uus.user_id)} is now {uus.status.GetType().Name[10..]}"); break;
					case UpdateUserName uun: Console.WriteLine($"{User(uun.user_id)} has changed profile name: @{uun.username} {uun.first_name} {uun.last_name}"); break;
					case UpdateUserPhoto uup: Console.WriteLine($"{User(uup.user_id)} has changed profile photo"); break;
					default: Console.WriteLine(update.GetType().Name); break;
				}
		}

		private static void DisplayMessage(MessageBase messageBase, bool edit = false)
		{
			if (edit) Console.Write("(Edit): ");
			switch (messageBase)
			{
				case Message m: Console.WriteLine($"{Peer(m.from_id) ?? m.post_author} in {Peer(m.peer_id)}> {m.message}"); break;
				case MessageService ms: Console.WriteLine($"{Peer(ms.from_id)} in {Peer(ms.peer_id)} [{ms.action.GetType().Name[13..]}]"); break;
			}
		}
	}
}