Skip to content

Commit 1e685c7

Browse files
committed
Extend merge/split logging
1 parent ce813e4 commit 1e685c7

File tree

2 files changed

+10
-4
lines changed

2 files changed

+10
-4
lines changed

lib/src/main/java/org/asamk/signal/manager/storage/recipients/MergeRecipientHelper.java

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,10 +83,11 @@ static Pair<RecipientId, List<RecipientId>> resolveRecipientTrustedLocked(
8383
recipientsToBeStripped.add(recipient);
8484
}
8585

86-
logger.debug("Got separate recipients for high trust identifiers {}, need to merge ({}) and strip ({})",
86+
logger.debug("Got separate recipients for high trust identifiers {}, need to merge ({}, {}) and strip ({})",
8787
address,
88-
recipientsToBeMerged.stream().map(r -> r.id().toString()).collect(Collectors.joining(", ")),
89-
recipientsToBeStripped.stream().map(r -> r.id().toString()).collect(Collectors.joining(", ")));
88+
resultingRecipient.map(RecipientWithAddress::address),
89+
recipientsToBeMerged.stream().map(r -> r.address().toString()).collect(Collectors.joining(", ")),
90+
recipientsToBeStripped.stream().map(r -> r.address().toString()).collect(Collectors.joining(", ")));
9091

9192
RecipientAddress finalAddress = resultingRecipient.map(RecipientWithAddress::address).orElse(null);
9293
for (final var recipient : recipientsToBeMerged) {

lib/src/main/java/org/asamk/signal/manager/storage/recipients/RecipientStore.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -994,7 +994,12 @@ private void markUnregisteredAndSplitIfNecessary(
994994
) throws SQLException {
995995
markUnregistered(connection, recipientId);
996996
final var address = resolveRecipientAddress(connection, recipientId);
997-
if (address.aci().isPresent() && address.pni().isPresent()) {
997+
final var needSplit = address.aci().isPresent() && address.pni().isPresent();
998+
logger.trace("Marking unregistered recipient {} as unregistered (and split={}): {}",
999+
recipientId,
1000+
needSplit,
1001+
address);
1002+
if (needSplit) {
9981003
final var numberAddress = new RecipientAddress(address.pni().get(), address.number().orElse(null));
9991004
updateRecipientAddress(connection, recipientId, address.removeIdentifiersFrom(numberAddress));
10001005
addNewRecipient(connection, numberAddress);

0 commit comments

Comments
 (0)