andreacavalli/tdlib-session-container
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Initialize client, print errors

Browse Source
This commit is contained in:
Andrea Cavalli 2022-03-19 01:36:24 +01:00
parent c92f0aa589
commit 5cf00542da
1 changed files with 13 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java
View File

@ -9,9 +9,11 @@ import com.google.common.primitives.Longs;
import io.atomix.cluster.messaging.ClusterEventService; import io.atomix.cluster.messaging.ClusterEventService;
import io.atomix.cluster.messaging.Subscription; import io.atomix.cluster.messaging.Subscription;
import io.atomix.core.Atomix; import io.atomix.core.Atomix;
import it.tdlight.common.Init;
import it.tdlight.common.ReactiveTelegramClient; import it.tdlight.common.ReactiveTelegramClient;
import it.tdlight.common.Response; import it.tdlight.common.Response;
import it.tdlight.common.Signal; import it.tdlight.common.Signal;
import it.tdlight.common.utils.CantLoadLibrary;
import it.tdlight.jni.TdApi; import it.tdlight.jni.TdApi;
import it.tdlight.jni.TdApi.AuthorizationStateClosed; import it.tdlight.jni.TdApi.AuthorizationStateClosed;
import it.tdlight.jni.TdApi.AuthorizationStateWaitOtherDeviceConfirmation; import it.tdlight.jni.TdApi.AuthorizationStateWaitOtherDeviceConfirmation;
@ -95,8 +97,18 @@ public abstract class ReactiveApiPublisher {
this.liveId = liveId; this.liveId = liveId;
this.dynamicIdResolveSubject = SubjectNaming.getDynamicIdResolveSubject(userId); this.dynamicIdResolveSubject = SubjectNaming.getDynamicIdResolveSubject(userId);
this.rawTelegramClient = ClientManager.createReactive(); this.rawTelegramClient = ClientManager.createReactive();
try {
Init.start();
} catch (CantLoadLibrary e) {
throw new RuntimeException("Can't load TDLight", e);
}
this.telegramClient = Flux.<Signal>create(sink -> this.registerTopics().thenAccept(subscription -> { this.telegramClient = Flux.<Signal>create(sink -> this.registerTopics().thenAccept(subscription -> {
rawTelegramClient.createAndRegisterClient(); try {
rawTelegramClient.createAndRegisterClient();
} catch (Throwable ex) {
LOG.error("Failed to initialize client {}", userId, ex);
sink.error(ex);
}
rawTelegramClient.setListener(sink::next); rawTelegramClient.setListener(sink::next);
sink.onCancel(rawTelegramClient::cancel); sink.onCancel(rawTelegramClient::cancel);
sink.onDispose(() -> { sink.onDispose(() -> {