From ed70a6560830b3c7fa7eabfe32f0897fd378d390 Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Tue, 20 Oct 2020 22:25:49 +0200 Subject: [PATCH] Update TransferServiceImpl.java and TransferUtils.java --- src/main/java/it/cavallium/TransferServiceImpl.java | 4 ++++ src/main/java/it/cavallium/TransferUtils.java | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/it/cavallium/TransferServiceImpl.java b/src/main/java/it/cavallium/TransferServiceImpl.java index f10548a..2516167 100644 --- a/src/main/java/it/cavallium/TransferServiceImpl.java +++ b/src/main/java/it/cavallium/TransferServiceImpl.java @@ -411,6 +411,10 @@ public class TransferServiceImpl implements TransferService { } ) .last() + .onErrorMap(error -> { + error.printStackTrace(); + return new Exception("Error while obtaining source group members: " + error.getLocalizedMessage(), error); + }) .subscribeOn(Schedulers.boundedElastic()) .map(members -> Tuple2.of(clients, members)); }) diff --git a/src/main/java/it/cavallium/TransferUtils.java b/src/main/java/it/cavallium/TransferUtils.java index afb7187..6e58a2f 100644 --- a/src/main/java/it/cavallium/TransferUtils.java +++ b/src/main/java/it/cavallium/TransferUtils.java @@ -210,7 +210,7 @@ public class TransferUtils { if (supergroupFullInfo.upgradedFromBasicGroupId == 0 && supergroupFullInfo.upgradedFromMaxMessageId == 0 && supergroupFullInfo.memberCount > 500) { TdApi.Chat info = client - .send(new TdApi.GetChat(supergroupId)) + .send(new TdApi.GetChat(chatEntityIdToChatId(supergroupId, TChatType.SUPERGROUP))) .flatMap(MonoUtils::orElseThrow) .timeout(Duration.ofMinutes(2)) .blockOptional()