Program_SecretChats.cs

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

namespace WTelegramClientTest
{
	static class Program_SecretChats
	{
		static WTelegram.Client Client;
		static WTelegram.SecretChats Secrets;
		static InputEncryptedChat ActiveChat; // the secret chat currently selected
		static readonly Dictionary<long, User> Users = new();
		static readonly Dictionary<long, ChatBase> Chats = new();

		// go to Project Properties > Debug > Environment variables and add at least these: api_id, api_hash, phone_number
		static async Task Main()
		{
			WTelegram.Helpers.Log = (l, s) => System.Diagnostics.Debug.WriteLine(s);
			Client = new WTelegram.Client(Environment.GetEnvironmentVariable);
			Secrets = new WTelegram.SecretChats(Client, "Secrets.bin");
			AppDomain.CurrentDomain.ProcessExit += (s, e) => { Secrets.Dispose(); Client.Dispose(); };
			SelectActiveChat();

			Client.OnUpdate += Client_OnUpdate;
			var myself = await Client.LoginUserIfNeeded();
			Users[myself.id] = myself;
			Console.WriteLine($"We are logged-in as {myself}");
				
			var dialogs = await Client.Messages_GetAllDialogs(); // load the list of users/chats
			dialogs.CollectUsersChats(Users, Chats);
			Console.WriteLine(@"Available commands:
/request <UserID>   Initiate Secret Chat with user (see /users)
/discard [delete]   Terminate active secret chat [and delete history]
/select <ChatID>    Select another Secret Chat
/photo filename.jpg Send a JPEG photo
/read               Mark active discussion as read
/users              List collected users and their IDs
Type a command, or a message to send to the active secret chat:");
			do
			{
				try
				{
					var line = Console.ReadLine();
					if (line.StartsWith('/'))
					{
						if (line == "/discard delete") { await Secrets.Discard(ActiveChat, true); SelectActiveChat(); }
						else if (line == "/discard") { await Secrets.Discard(ActiveChat, false); SelectActiveChat(); }
						else if (line == "/read") await Client.Messages_ReadEncryptedHistory(ActiveChat, DateTime.UtcNow);
						else if (line == "/users") foreach (var user in Users.Values) Console.WriteLine($"{user.id,-10} {user}");
						else if (line.StartsWith("/select ")) SelectActiveChat(int.Parse(line[8..]));
						else if (line.StartsWith("/request "))
							if (Users.TryGetValue(long.Parse(line[9..]), out var user))
								SelectActiveChat(await Secrets.Request(user));
							else
								Console.WriteLine("User not found");
						else if (line.StartsWith("/photo "))
						{
							var media = new TL.Layer45.DecryptedMessageMediaPhoto { caption = line[7..] };
							var file = await Secrets.UploadFile(File.OpenRead(line[7..]), media);
							var sent = await Secrets.SendMessage(ActiveChat, new TL.Layer73.DecryptedMessage { random_id = WTelegram.Helpers.RandomLong(),
								media = media, flags = TL.Layer73.DecryptedMessage.Flags.has_media }, file: file);
						}
						else Console.WriteLine("Unrecognized command");
					}
					else if (ActiveChat == null) Console.WriteLine("No active secret chat");
					else await Secrets.SendMessage(ActiveChat, new TL.Layer73.DecryptedMessage { message = line, random_id = WTelegram.Helpers.RandomLong() });
				}
				catch (Exception ex)
				{
					Console.WriteLine(ex);
				}
			} while (true);
		}

		private static async Task Client_OnUpdate(IObject arg)
		{
			if (arg is not UpdatesBase updates) return;
			updates.CollectUsersChats(Users, Chats);
			foreach (var update in updates.UpdateList)
				switch (update)
				{
					case UpdateEncryption ue: // Change in Secret Chat status
						await Secrets.HandleUpdate(ue);
						break;
					case UpdateNewEncryptedMessage unem: // Encrypted message or service message:
						if (unem.message.ChatId != ActiveChat?.chat_id) SelectActiveChat(unem.message.ChatId);
						foreach (var msg in Secrets.DecryptMessage(unem.message))
						{
							if (msg.Media != null && unem.message is EncryptedMessage { file: EncryptedFile ef })
							{
								Console.WriteLine($"{unem.message.ChatId}> {msg.Message} [file being downloaded to media.jpg]");
								using var output = File.Create("media.jpg"); // not necessarily a JPG, check the msg.Media mime_type
								using var decryptStream = new WTelegram.AES_IGE_Stream(output, msg.Media);
								await Client.DownloadFileAsync(ef, decryptStream, ef.dc_id, ef.size);
							}
							else if (msg.Action == null) Console.WriteLine($"{unem.message.ChatId}> {msg.Message}");
							else Console.WriteLine($"{unem.message.ChatId}> Service Message {msg.Action.GetType().Name[22..]}");
						}
						break;
					case UpdateEncryptedChatTyping:
					case UpdateEncryptedMessagesRead:
						//Console.WriteLine(update.GetType().Name);
						break;
				}
		}

		private static void SelectActiveChat(int newActiveChat = 0)
		{
			ActiveChat = Secrets.Peers.FirstOrDefault(sc => newActiveChat == 0 || sc.chat_id == newActiveChat);
			Console.WriteLine("Active secret chat ID: " + ActiveChat?.chat_id);
		}
	}
}