Update TDLib

- Introduced `sendAsync` in `TelegramClient` to support asynchronous queries with `CompletableFuture`.
- Updated TDLib native and API versions in BOM.
- Improved input handling in `ScannerUtils`.
- Minor adjustment in `SimpleTelegramClient.logOutAsync`.

Author: cavallium

bom/pom.xml

@@ -8,8 +8,8 @@
 	<name>TDLight Java BOM</name>
 	<properties>
 		<revision>3.0.0.0-SNAPSHOT</revision>
-		<tdlight.natives.version>4.0.558</tdlight.natives.version>
-		<tdlight.api.version>4.0.528</tdlight.api.version>
+		<tdlight.natives.version>4.0.585</tdlight.natives.version>
+		<tdlight.api.version>4.0.555</tdlight.api.version>
 		<maven.compiler.source>1.8</maven.compiler.source>
 		<maven.compiler.target>1.8</maven.compiler.target>
 	</properties>

tdlight-java/src/main/java/it/tdlight/TelegramClient.java

@@ -1,6 +1,8 @@
 package it.tdlight;
 
+import it.tdlight.client.TelegramError;
 import it.tdlight.jni.TdApi;
+import java.util.concurrent.CompletableFuture;
 
 public interface TelegramClient {
 
@@ -65,4 +67,31 @@ default <R extends TdApi.Object> void send(TdApi.Function<R> query, ResultHandle
 	 * @throws NullPointerException if query is null.
 	 */
 	<R extends TdApi.Object> TdApi.Object execute(TdApi.Function<R> query);
+
+	/**
+	 * Sends a request to the TDLib and returns a {@link CompletableFuture} that will be completed
+	 * with the result or completed exceptionally with a {@link TelegramError} if TDLib returns an error.
+	 *
+	 * <p>The returned future has no timeout by default. To avoid hanging indefinitely on a
+	 * non-responsive request, use {@link CompletableFuture#orTimeout(long, java.util.concurrent.TimeUnit)}
+	 * on the returned future.</p>
+	 *
+	 * @param query Object representing a query to the TDLib.
+	 * @param <R>   The expected result type.
+	 * @return a {@link CompletableFuture} that completes with the result or fails with {@link TelegramError}.
+	 * @throws NullPointerException if query is null.
+	 */
+	default <R extends TdApi.Object> CompletableFuture<R> sendAsync(TdApi.Function<R> query) {
+		CompletableFuture<R> future = new CompletableFuture<>();
+		send(query, result -> {
+			if (result.getConstructor() == TdApi.Error.CONSTRUCTOR) {
+				future.completeExceptionally(new TelegramError((TdApi.Error) result));
+			} else {
+				@SuppressWarnings("unchecked")
+				R r = (R) result;
+				future.complete(r);
+			}
+		});
+		return future;
+	}
 }

tdlight-java/src/main/java/it/tdlight/client/SimpleTelegramClient.java

@@ -270,7 +270,6 @@ private <R extends TdApi.Object> boolean shouldWaitForReadiness(Function<R> func
 			case TdApi.PingProxy.CONSTRUCTOR:
 			case TdApi.TestProxy.CONSTRUCTOR:
 			case TdApi.EnableProxy.CONSTRUCTOR:
-			case TdApi.GetProxyLink.CONSTRUCTOR:
 			case TdApi.GetProxies.CONSTRUCTOR:
 			case TdApi.LogOut.CONSTRUCTOR:
 			case TdApi.SetTdlibParameters.CONSTRUCTOR:
@@ -519,7 +518,7 @@ public CompletableFuture<Void> loadChatListMainAsync() {
 	 *
 	 **/
 	public CompletableFuture<Void> logOutAsync() {
-		return send(new LogOut()).thenAccept(ok -> {});
+		return send(new LogOut()).thenApply(ok -> null);
 	}
 
 	public boolean isMainChatsListLoaded() {

tdlight-java/src/main/java/it/tdlight/util/ScannerUtils.java

@@ -2,6 +2,7 @@
 
 import java.io.Console;
 import java.io.IOException;
+import java.io.InputStream;
 import java.io.InputStreamReader;
 import java.io.Reader;
 import java.util.regex.Matcher;
@@ -13,13 +14,17 @@ public final class ScannerUtils {
 	private static InputStreamReader scanner = null;
 
 	public static String askParameter(String displayName, String question) {
+		return askParameter(displayName, question, System.in);
+	}
+
+	public static String askParameter(String displayName, String question, InputStream inputStream) {
 		synchronized (LOCK) {
 			Console console = System.console();
 			if (console != null) {
 				return console.readLine("[%s] %s: ", displayName, question);
 			} else {
-				if (scanner == null) {
-					scanner = new InputStreamReader(System.in);
+				if (scanner == null || inputStream != System.in) {
+					scanner = new InputStreamReader(inputStream);
 				}
 				System.out.printf("[%s] %s: ", displayName, question);
 				try {