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()