From: AsamK Date: Thu, 30 Dec 2021 12:30:05 +0000 (+0100) Subject: Adapt log levels X-Git-Tag: v0.10.1~27 X-Git-Url: https://git.nmode.ca/signal-cli/commitdiff_plain/a738fb725b81ebf7801efe62d98e32c49857a327 Adapt log levels --- diff --git a/lib/src/main/java/org/asamk/signal/manager/helper/UnidentifiedAccessHelper.java b/lib/src/main/java/org/asamk/signal/manager/helper/UnidentifiedAccessHelper.java index bda24c7c..a9aff6eb 100644 --- a/lib/src/main/java/org/asamk/signal/manager/helper/UnidentifiedAccessHelper.java +++ b/lib/src/main/java/org/asamk/signal/manager/helper/UnidentifiedAccessHelper.java @@ -44,16 +44,68 @@ public class UnidentifiedAccessHelper { this.profileProvider = profileProvider; } + public List> getAccessFor(List recipients) { + return recipients.stream().map(this::getAccessFor).toList(); + } + + public Optional getAccessFor(RecipientId recipient) { + return getAccessFor(recipient, false); + } + + public Optional getAccessFor(RecipientId recipientId, boolean noRefresh) { + var recipientUnidentifiedAccessKey = getTargetUnidentifiedAccessKey(recipientId, noRefresh); + if (recipientUnidentifiedAccessKey == null) { + logger.trace("Unidentified access not available for {}", recipientId); + return Optional.absent(); + } + + var selfUnidentifiedAccessKey = getSelfUnidentifiedAccessKey(noRefresh); + if (selfUnidentifiedAccessKey == null) { + logger.trace("Unidentified access not available for self"); + return Optional.absent(); + } + + var senderCertificate = getSenderCertificateFor(recipientId); + if (senderCertificate == null) { + logger.trace("Unidentified access not available due to missing sender certificate"); + return Optional.absent(); + } + + try { + return Optional.of(new UnidentifiedAccessPair(new UnidentifiedAccess(recipientUnidentifiedAccessKey, + senderCertificate), new UnidentifiedAccess(selfUnidentifiedAccessKey, senderCertificate))); + } catch (InvalidCertificateException e) { + return Optional.absent(); + } + } + + public Optional getAccessForSync() { + var selfUnidentifiedAccessKey = getSelfUnidentifiedAccessKey(false); + var selfUnidentifiedAccessCertificate = getSenderCertificate(); + + if (selfUnidentifiedAccessKey == null || selfUnidentifiedAccessCertificate == null) { + return Optional.absent(); + } + + try { + return Optional.of(new UnidentifiedAccessPair(new UnidentifiedAccess(selfUnidentifiedAccessKey, + selfUnidentifiedAccessCertificate), + new UnidentifiedAccess(selfUnidentifiedAccessKey, selfUnidentifiedAccessCertificate))); + } catch (InvalidCertificateException e) { + return Optional.absent(); + } + } + private byte[] getSenderCertificateFor(final RecipientId recipientId) { final var sharingMode = account.getConfigurationStore().getPhoneNumberSharingMode(); if (sharingMode == PhoneNumberSharingMode.EVERYBODY || ( sharingMode == PhoneNumberSharingMode.CONTACTS && account.getContactStore().getContact(recipientId) != null )) { - logger.debug("Using normal sender certificate for message to {}", recipientId); + logger.trace("Using normal sender certificate for message to {}", recipientId); return getSenderCertificate(); } else { - logger.debug("Using phone number privacy sender certificate for message to {}", recipientId); + logger.trace("Using phone number privacy sender certificate for message to {}", recipientId); return getSenderCertificateForPhoneNumberPrivacy(); } } @@ -130,52 +182,6 @@ public class UnidentifiedAccessHelper { } } - public Optional getAccessForSync() { - var selfUnidentifiedAccessKey = getSelfUnidentifiedAccessKey(false); - var selfUnidentifiedAccessCertificate = getSenderCertificate(); - - if (selfUnidentifiedAccessKey == null || selfUnidentifiedAccessCertificate == null) { - return Optional.absent(); - } - - try { - return Optional.of(new UnidentifiedAccessPair(new UnidentifiedAccess(selfUnidentifiedAccessKey, - selfUnidentifiedAccessCertificate), - new UnidentifiedAccess(selfUnidentifiedAccessKey, selfUnidentifiedAccessCertificate))); - } catch (InvalidCertificateException e) { - return Optional.absent(); - } - } - - public List> getAccessFor(List recipients) { - return recipients.stream().map(this::getAccessFor).toList(); - } - - public Optional getAccessFor(RecipientId recipient) { - return getAccessFor(recipient, false); - } - - public Optional getAccessFor(RecipientId recipient, boolean noRefresh) { - var recipientUnidentifiedAccessKey = getTargetUnidentifiedAccessKey(recipient, noRefresh); - if (recipientUnidentifiedAccessKey == null) { - return Optional.absent(); - } - - var selfUnidentifiedAccessKey = getSelfUnidentifiedAccessKey(noRefresh); - var selfUnidentifiedAccessCertificate = getSenderCertificateFor(recipient); - if (selfUnidentifiedAccessKey == null || selfUnidentifiedAccessCertificate == null) { - return Optional.absent(); - } - - try { - return Optional.of(new UnidentifiedAccessPair(new UnidentifiedAccess(recipientUnidentifiedAccessKey, - selfUnidentifiedAccessCertificate), - new UnidentifiedAccess(selfUnidentifiedAccessKey, selfUnidentifiedAccessCertificate))); - } catch (InvalidCertificateException e) { - return Optional.absent(); - } - } - private static byte[] createUnrestrictedUnidentifiedAccess() { return UNRESTRICTED_KEY; } diff --git a/lib/src/main/java/org/asamk/signal/manager/storage/identities/IdentityKeyStore.java b/lib/src/main/java/org/asamk/signal/manager/storage/identities/IdentityKeyStore.java index bb4627a2..31b717cd 100644 --- a/lib/src/main/java/org/asamk/signal/manager/storage/identities/IdentityKeyStore.java +++ b/lib/src/main/java/org/asamk/signal/manager/storage/identities/IdentityKeyStore.java @@ -114,7 +114,7 @@ public class IdentityKeyStore implements org.whispersystems.libsignal.state.Iden return false; } if (identityInfo.getTrustLevel() == trustLevel) { - logger.debug("Not updating trust level for recipient {}, trust level already matches", recipientId); + logger.trace("Not updating trust level for recipient {}, trust level already matches", recipientId); return false; }