2 Copyright (C) 2015-2022 AsamK and contributors
4 This program is free software: you can redistribute it and/or modify
5 it under the terms of the GNU General Public License as published by
6 the Free Software Foundation, either version 3 of the License, or
7 (at your option) any later version.
9 This program is distributed in the hope that it will be useful,
10 but WITHOUT ANY WARRANTY; without even the implied warranty of
11 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
12 GNU General Public License for more details.
14 You should have received a copy of the GNU General Public License
15 along with this program. If not, see <http://www.gnu.org/licenses/>.
17 package org
.asamk
.signal
.manager
.internal
;
19 import org
.asamk
.signal
.manager
.Manager
;
20 import org
.asamk
.signal
.manager
.api
.AlreadyReceivingException
;
21 import org
.asamk
.signal
.manager
.api
.AttachmentInvalidException
;
22 import org
.asamk
.signal
.manager
.api
.CaptchaRequiredException
;
23 import org
.asamk
.signal
.manager
.api
.Configuration
;
24 import org
.asamk
.signal
.manager
.api
.Device
;
25 import org
.asamk
.signal
.manager
.api
.DeviceLinkUrl
;
26 import org
.asamk
.signal
.manager
.api
.Group
;
27 import org
.asamk
.signal
.manager
.api
.GroupId
;
28 import org
.asamk
.signal
.manager
.api
.GroupInviteLinkUrl
;
29 import org
.asamk
.signal
.manager
.api
.GroupNotFoundException
;
30 import org
.asamk
.signal
.manager
.api
.GroupSendingNotAllowedException
;
31 import org
.asamk
.signal
.manager
.api
.Identity
;
32 import org
.asamk
.signal
.manager
.api
.IdentityVerificationCode
;
33 import org
.asamk
.signal
.manager
.api
.InactiveGroupLinkException
;
34 import org
.asamk
.signal
.manager
.api
.IncorrectPinException
;
35 import org
.asamk
.signal
.manager
.api
.InvalidDeviceLinkException
;
36 import org
.asamk
.signal
.manager
.api
.InvalidStickerException
;
37 import org
.asamk
.signal
.manager
.api
.InvalidUsernameException
;
38 import org
.asamk
.signal
.manager
.api
.LastGroupAdminException
;
39 import org
.asamk
.signal
.manager
.api
.Message
;
40 import org
.asamk
.signal
.manager
.api
.MessageEnvelope
;
41 import org
.asamk
.signal
.manager
.api
.NonNormalizedPhoneNumberException
;
42 import org
.asamk
.signal
.manager
.api
.NotAGroupMemberException
;
43 import org
.asamk
.signal
.manager
.api
.NotPrimaryDeviceException
;
44 import org
.asamk
.signal
.manager
.api
.Pair
;
45 import org
.asamk
.signal
.manager
.api
.PendingAdminApprovalException
;
46 import org
.asamk
.signal
.manager
.api
.PhoneNumberSharingMode
;
47 import org
.asamk
.signal
.manager
.api
.PinLockedException
;
48 import org
.asamk
.signal
.manager
.api
.Profile
;
49 import org
.asamk
.signal
.manager
.api
.RateLimitException
;
50 import org
.asamk
.signal
.manager
.api
.ReceiveConfig
;
51 import org
.asamk
.signal
.manager
.api
.Recipient
;
52 import org
.asamk
.signal
.manager
.api
.RecipientIdentifier
;
53 import org
.asamk
.signal
.manager
.api
.SendGroupMessageResults
;
54 import org
.asamk
.signal
.manager
.api
.SendMessageResult
;
55 import org
.asamk
.signal
.manager
.api
.SendMessageResults
;
56 import org
.asamk
.signal
.manager
.api
.StickerPackId
;
57 import org
.asamk
.signal
.manager
.api
.StickerPackInvalidException
;
58 import org
.asamk
.signal
.manager
.api
.StickerPackUrl
;
59 import org
.asamk
.signal
.manager
.api
.TextStyle
;
60 import org
.asamk
.signal
.manager
.api
.TypingAction
;
61 import org
.asamk
.signal
.manager
.api
.UnregisteredRecipientException
;
62 import org
.asamk
.signal
.manager
.api
.UpdateGroup
;
63 import org
.asamk
.signal
.manager
.api
.UpdateProfile
;
64 import org
.asamk
.signal
.manager
.api
.UserStatus
;
65 import org
.asamk
.signal
.manager
.api
.UsernameLinkUrl
;
66 import org
.asamk
.signal
.manager
.config
.ServiceEnvironmentConfig
;
67 import org
.asamk
.signal
.manager
.helper
.AccountFileUpdater
;
68 import org
.asamk
.signal
.manager
.helper
.Context
;
69 import org
.asamk
.signal
.manager
.helper
.RecipientHelper
.RegisteredUser
;
70 import org
.asamk
.signal
.manager
.jobs
.RefreshRecipientsJob
;
71 import org
.asamk
.signal
.manager
.jobs
.SyncStorageJob
;
72 import org
.asamk
.signal
.manager
.storage
.AttachmentStore
;
73 import org
.asamk
.signal
.manager
.storage
.AvatarStore
;
74 import org
.asamk
.signal
.manager
.storage
.SignalAccount
;
75 import org
.asamk
.signal
.manager
.storage
.groups
.GroupInfo
;
76 import org
.asamk
.signal
.manager
.storage
.identities
.IdentityInfo
;
77 import org
.asamk
.signal
.manager
.storage
.recipients
.RecipientAddress
;
78 import org
.asamk
.signal
.manager
.storage
.recipients
.RecipientId
;
79 import org
.asamk
.signal
.manager
.storage
.stickerPacks
.JsonStickerPack
;
80 import org
.asamk
.signal
.manager
.storage
.stickerPacks
.StickerPackStore
;
81 import org
.asamk
.signal
.manager
.storage
.stickers
.StickerPack
;
82 import org
.asamk
.signal
.manager
.util
.AttachmentUtils
;
83 import org
.asamk
.signal
.manager
.util
.KeyUtils
;
84 import org
.asamk
.signal
.manager
.util
.MimeUtils
;
85 import org
.asamk
.signal
.manager
.util
.StickerUtils
;
86 import org
.signal
.libsignal
.protocol
.InvalidMessageException
;
87 import org
.signal
.libsignal
.usernames
.BaseUsernameException
;
88 import org
.slf4j
.Logger
;
89 import org
.slf4j
.LoggerFactory
;
90 import org
.whispersystems
.signalservice
.api
.SignalSessionLock
;
91 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceDataMessage
;
92 import org
.whispersystems
.signalservice
.api
.messages
.SignalServicePreview
;
93 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceReceiptMessage
;
94 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceTypingMessage
;
95 import org
.whispersystems
.signalservice
.api
.push
.ServiceId
;
96 import org
.whispersystems
.signalservice
.api
.push
.ServiceId
.ACI
;
97 import org
.whispersystems
.signalservice
.api
.push
.ServiceIdType
;
98 import org
.whispersystems
.signalservice
.api
.push
.exceptions
.CdsiResourceExhaustedException
;
99 import org
.whispersystems
.signalservice
.api
.util
.DeviceNameUtil
;
100 import org
.whispersystems
.signalservice
.api
.util
.InvalidNumberException
;
101 import org
.whispersystems
.signalservice
.api
.util
.PhoneNumberFormatter
;
102 import org
.whispersystems
.signalservice
.api
.util
.StreamDetails
;
103 import org
.whispersystems
.signalservice
.internal
.util
.Hex
;
104 import org
.whispersystems
.signalservice
.internal
.util
.Util
;
106 import java
.io
.ByteArrayInputStream
;
108 import java
.io
.FileNotFoundException
;
109 import java
.io
.IOException
;
110 import java
.io
.InputStream
;
111 import java
.nio
.charset
.StandardCharsets
;
112 import java
.time
.Duration
;
113 import java
.util
.ArrayList
;
114 import java
.util
.Collection
;
115 import java
.util
.HashMap
;
116 import java
.util
.HashSet
;
117 import java
.util
.List
;
118 import java
.util
.Map
;
119 import java
.util
.Objects
;
120 import java
.util
.Optional
;
121 import java
.util
.Set
;
122 import java
.util
.concurrent
.ExecutorService
;
123 import java
.util
.concurrent
.Executors
;
124 import java
.util
.concurrent
.TimeUnit
;
125 import java
.util
.concurrent
.atomic
.AtomicInteger
;
126 import java
.util
.concurrent
.locks
.ReentrantLock
;
127 import java
.util
.function
.Function
;
128 import java
.util
.stream
.Collectors
;
129 import java
.util
.stream
.Stream
;
131 import io
.reactivex
.rxjava3
.disposables
.CompositeDisposable
;
132 import io
.reactivex
.rxjava3
.schedulers
.Schedulers
;
134 public class ManagerImpl
implements Manager
{
136 private static final Logger logger
= LoggerFactory
.getLogger(ManagerImpl
.class);
138 private SignalAccount account
;
139 private final SignalDependencies dependencies
;
140 private final Context context
;
142 private final ExecutorService executor
= Executors
.newCachedThreadPool();
144 private Thread receiveThread
;
145 private boolean isReceivingSynchronous
;
146 private final Set
<ReceiveMessageHandler
> weakHandlers
= new HashSet
<>();
147 private final Set
<ReceiveMessageHandler
> messageHandlers
= new HashSet
<>();
148 private final List
<Runnable
> closedListeners
= new ArrayList
<>();
149 private final List
<Runnable
> addressChangedListeners
= new ArrayList
<>();
150 private final CompositeDisposable disposable
= new CompositeDisposable();
153 SignalAccount account
,
154 PathConfig pathConfig
,
155 AccountFileUpdater accountFileUpdater
,
156 ServiceEnvironmentConfig serviceEnvironmentConfig
,
159 this.account
= account
;
161 final var sessionLock
= new SignalSessionLock() {
162 private final ReentrantLock LEGACY_LOCK
= new ReentrantLock();
165 public Lock
acquire() {
167 return LEGACY_LOCK
::unlock
;
170 this.dependencies
= new SignalDependencies(serviceEnvironmentConfig
,
172 account
.getCredentialsProvider(),
173 account
.getSignalServiceDataStore(),
176 final var avatarStore
= new AvatarStore(pathConfig
.avatarsPath());
177 final var attachmentStore
= new AttachmentStore(pathConfig
.attachmentsPath());
178 final var stickerPackStore
= new StickerPackStore(pathConfig
.stickerPacksPath());
180 this.context
= new Context(account
, new AccountFileUpdater() {
182 public void updateAccountIdentifiers(final String number
, final ACI aci
) {
183 accountFileUpdater
.updateAccountIdentifiers(number
, aci
);
184 synchronized (addressChangedListeners
) {
185 addressChangedListeners
.forEach(Runnable
::run
);
190 public void removeAccount() {
191 accountFileUpdater
.removeAccount();
193 }, dependencies
, avatarStore
, attachmentStore
, stickerPackStore
);
194 this.context
.getAccountHelper().setUnregisteredListener(this::close
);
195 this.context
.getReceiveHelper().setAuthenticationFailureListener(this::close
);
196 this.context
.getReceiveHelper().setCaughtUpWithOldMessagesListener(() -> {
197 synchronized (this) {
201 disposable
.add(account
.getIdentityKeyStore()
202 .getIdentityChanges()
203 .observeOn(Schedulers
.from(executor
))
204 .subscribe(serviceId
-> {
205 logger
.trace("Archiving old sessions for {}", serviceId
);
206 account
.getAccountData(ServiceIdType
.ACI
).getSessionStore().archiveSessions(serviceId
);
207 account
.getAccountData(ServiceIdType
.PNI
).getSessionStore().archiveSessions(serviceId
);
208 account
.getSenderKeyStore().deleteSharedWith(serviceId
);
209 final var recipientId
= account
.getRecipientResolver().resolveRecipient(serviceId
);
210 final var profile
= account
.getProfileStore().getProfile(recipientId
);
211 if (profile
!= null) {
212 account
.getProfileStore()
213 .storeProfile(recipientId
,
214 Profile
.newBuilder(profile
)
215 .withUnidentifiedAccessMode(Profile
.UnidentifiedAccessMode
.UNKNOWN
)
216 .withLastUpdateTimestamp(0)
223 public String
getSelfNumber() {
224 return account
.getNumber();
227 public void checkAccountState() throws IOException
{
228 context
.getAccountHelper().checkAccountState();
229 final var lastRecipientsRefresh
= account
.getLastRecipientsRefresh();
230 if (lastRecipientsRefresh
== null
231 || lastRecipientsRefresh
< System
.currentTimeMillis() - TimeUnit
.DAYS
.toMillis(1)) {
232 context
.getJobExecutor().enqueueJob(new RefreshRecipientsJob());
233 context
.getAccountHelper().checkWhoAmiI();
238 public Map
<String
, UserStatus
> getUserStatus(Set
<String
> numbers
) throws IOException
, RateLimitException
{
239 final var canonicalizedNumbers
= numbers
.stream().collect(Collectors
.toMap(n
-> n
, n
-> {
241 final var canonicalizedNumber
= PhoneNumberFormatter
.formatNumber(n
, account
.getNumber());
242 if (!canonicalizedNumber
.equals(n
)) {
243 logger
.debug("Normalized number {} to {}.", n
, canonicalizedNumber
);
245 return canonicalizedNumber
;
246 } catch (InvalidNumberException e
) {
251 // Note "registeredUsers" has no optionals. It only gives us info on users who are registered
252 final var canonicalizedNumbersSet
= canonicalizedNumbers
.values()
254 .filter(s
-> !s
.isEmpty())
255 .collect(Collectors
.toSet());
257 final Map
<String
, RegisteredUser
> registeredUsers
;
259 registeredUsers
= context
.getRecipientHelper().getRegisteredUsers(canonicalizedNumbersSet
);
260 } catch (CdsiResourceExhaustedException e
) {
261 logger
.debug("CDSI resource exhausted: {}", e
.getMessage());
262 throw new RateLimitException(System
.currentTimeMillis() + e
.getRetryAfterSeconds() * 1000L);
265 return numbers
.stream().collect(Collectors
.toMap(n
-> n
, n
-> {
266 final var number
= canonicalizedNumbers
.get(n
);
267 final var user
= registeredUsers
.get(number
);
268 final var serviceId
= user
== null ?
null : user
.getServiceId();
269 final var profile
= serviceId
== null
271 : context
.getProfileHelper()
272 .getRecipientProfile(account
.getRecipientResolver().resolveRecipient(serviceId
));
273 return new UserStatus(number
.isEmpty() ?
null : number
,
274 serviceId
== null ?
null : serviceId
.getRawUuid(),
276 && profile
.getUnidentifiedAccessMode() == Profile
.UnidentifiedAccessMode
.UNRESTRICTED
);
281 public void updateAccountAttributes(
283 Boolean unrestrictedUnidentifiedSender
,
284 final Boolean discoverableByNumber
,
285 final Boolean numberSharing
286 ) throws IOException
{
287 if (deviceName
!= null) {
288 context
.getAccountHelper().setDeviceName(deviceName
);
290 if (unrestrictedUnidentifiedSender
!= null) {
291 account
.setUnrestrictedUnidentifiedAccess(unrestrictedUnidentifiedSender
);
293 if (discoverableByNumber
!= null) {
294 account
.getConfigurationStore().setPhoneNumberUnlisted(!discoverableByNumber
);
296 if (numberSharing
!= null) {
297 account
.getConfigurationStore()
298 .setPhoneNumberSharingMode(numberSharing
299 ? PhoneNumberSharingMode
.EVERYBODY
300 : PhoneNumberSharingMode
.NOBODY
);
302 context
.getAccountHelper().updateAccountAttributes();
303 context
.getAccountHelper().checkWhoAmiI();
307 public Configuration
getConfiguration() {
308 final var configurationStore
= account
.getConfigurationStore();
309 return Configuration
.from(configurationStore
);
313 public void updateConfiguration(Configuration configuration
) {
314 final var configurationStore
= account
.getConfigurationStore();
315 if (configuration
.readReceipts().isPresent()) {
316 configurationStore
.setReadReceipts(configuration
.readReceipts().get());
318 if (configuration
.unidentifiedDeliveryIndicators().isPresent()) {
319 configurationStore
.setUnidentifiedDeliveryIndicators(configuration
.unidentifiedDeliveryIndicators().get());
321 if (configuration
.typingIndicators().isPresent()) {
322 configurationStore
.setTypingIndicators(configuration
.typingIndicators().get());
324 if (configuration
.linkPreviews().isPresent()) {
325 configurationStore
.setLinkPreviews(configuration
.linkPreviews().get());
327 context
.getSyncHelper().sendConfigurationMessage();
332 public void updateProfile(UpdateProfile updateProfile
) throws IOException
{
333 context
.getProfileHelper()
334 .setProfile(updateProfile
.getGivenName(),
335 updateProfile
.getFamilyName(),
336 updateProfile
.getAbout(),
337 updateProfile
.getAboutEmoji(),
338 updateProfile
.isDeleteAvatar()
340 : updateProfile
.getAvatar() == null ?
null : Optional
.of(updateProfile
.getAvatar()),
341 updateProfile
.getMobileCoinAddress());
342 context
.getSyncHelper().sendSyncFetchProfileMessage();
345 void refreshCurrentUsername() throws IOException
, BaseUsernameException
{
346 context
.getAccountHelper().refreshCurrentUsername();
350 public String
getUsername() {
351 return account
.getUsername();
355 public UsernameLinkUrl
getUsernameLink() {
356 return new UsernameLinkUrl(account
.getUsernameLink());
360 public void setUsername(final String username
) throws IOException
, InvalidUsernameException
{
362 context
.getAccountHelper().reserveUsername(username
);
363 } catch (BaseUsernameException e
) {
364 throw new InvalidUsernameException(e
.getMessage() + " (" + e
.getClass().getSimpleName() + ")", e
);
369 public void deleteUsername() throws IOException
{
370 context
.getAccountHelper().deleteUsername();
374 public void startChangeNumber(
375 String newNumber
, boolean voiceVerification
, String captcha
376 ) throws RateLimitException
, IOException
, CaptchaRequiredException
, NonNormalizedPhoneNumberException
, NotPrimaryDeviceException
{
377 if (!account
.isPrimaryDevice()) {
378 throw new NotPrimaryDeviceException();
380 context
.getAccountHelper().startChangeNumber(newNumber
, voiceVerification
, captcha
);
384 public void finishChangeNumber(
385 String newNumber
, String verificationCode
, String pin
386 ) throws IncorrectPinException
, PinLockedException
, IOException
, NotPrimaryDeviceException
{
387 if (!account
.isPrimaryDevice()) {
388 throw new NotPrimaryDeviceException();
390 context
.getAccountHelper().finishChangeNumber(newNumber
, verificationCode
, pin
);
394 public void unregister() throws IOException
{
395 context
.getAccountHelper().unregister();
399 public void deleteAccount() throws IOException
{
400 context
.getAccountHelper().deleteAccount();
404 public void submitRateLimitRecaptchaChallenge(String challenge
, String captcha
) throws IOException
{
405 captcha
= captcha
== null ?
null : captcha
.replace("signalcaptcha://", "");
407 dependencies
.getAccountManager().submitRateLimitRecaptchaChallenge(challenge
, captcha
);
411 public List
<Device
> getLinkedDevices() throws IOException
{
412 var devices
= dependencies
.getAccountManager().getDevices();
413 account
.setMultiDevice(devices
.size() > 1);
414 var identityKey
= account
.getAciIdentityKeyPair().getPrivateKey();
415 return devices
.stream().map(d
-> {
416 String deviceName
= d
.getName();
417 if (deviceName
!= null) {
419 deviceName
= DeviceNameUtil
.decryptDeviceName(deviceName
, identityKey
);
420 } catch (IOException e
) {
421 logger
.debug("Failed to decrypt device name, maybe plain text?", e
);
424 return new Device(d
.getId(),
428 d
.getId() == account
.getDeviceId());
433 public void removeLinkedDevices(int deviceId
) throws IOException
{
434 context
.getAccountHelper().removeLinkedDevices(deviceId
);
438 public void addDeviceLink(DeviceLinkUrl linkUrl
) throws IOException
, InvalidDeviceLinkException
, NotPrimaryDeviceException
{
439 if (!account
.isPrimaryDevice()) {
440 throw new NotPrimaryDeviceException();
442 context
.getAccountHelper().addDevice(linkUrl
);
446 public void setRegistrationLockPin(Optional
<String
> pin
) throws IOException
, NotPrimaryDeviceException
{
447 if (!account
.isPrimaryDevice()) {
448 throw new NotPrimaryDeviceException();
450 if (pin
.isPresent()) {
451 context
.getAccountHelper().setRegistrationPin(pin
.get());
453 context
.getAccountHelper().removeRegistrationPin();
457 void refreshPreKeys() throws IOException
{
458 context
.getPreKeyHelper().refreshPreKeysIfNecessary();
462 public List
<Group
> getGroups() {
463 return account
.getGroupStore().getGroups().stream().map(this::toGroup
).toList();
466 private Group
toGroup(final GroupInfo groupInfo
) {
467 if (groupInfo
== null) {
471 return Group
.from(groupInfo
, account
.getRecipientAddressResolver(), account
.getSelfRecipientId());
475 public SendGroupMessageResults
quitGroup(
476 GroupId groupId
, Set
<RecipientIdentifier
.Single
> groupAdmins
477 ) throws GroupNotFoundException
, IOException
, NotAGroupMemberException
, LastGroupAdminException
, UnregisteredRecipientException
{
478 final var newAdmins
= context
.getRecipientHelper().resolveRecipients(groupAdmins
);
479 return context
.getGroupHelper().quitGroup(groupId
, newAdmins
);
483 public void deleteGroup(GroupId groupId
) throws IOException
{
484 final var group
= context
.getGroupHelper().getGroup(groupId
);
485 if (group
.isMember(account
.getSelfRecipientId())) {
486 throw new IOException(
487 "The local group information cannot be removed, as the user is still a member of the group");
489 context
.getGroupHelper().deleteGroup(groupId
);
493 public Pair
<GroupId
, SendGroupMessageResults
> createGroup(
494 String name
, Set
<RecipientIdentifier
.Single
> members
, String avatarFile
495 ) throws IOException
, AttachmentInvalidException
, UnregisteredRecipientException
{
496 return context
.getGroupHelper()
498 members
== null ?
null : context
.getRecipientHelper().resolveRecipients(members
),
503 public SendGroupMessageResults
updateGroup(
504 final GroupId groupId
, final UpdateGroup updateGroup
505 ) throws IOException
, GroupNotFoundException
, AttachmentInvalidException
, NotAGroupMemberException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
{
506 return context
.getGroupHelper()
507 .updateGroup(groupId
,
508 updateGroup
.getName(),
509 updateGroup
.getDescription(),
510 updateGroup
.getMembers() == null
512 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getMembers()),
513 updateGroup
.getRemoveMembers() == null
515 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getRemoveMembers()),
516 updateGroup
.getAdmins() == null
518 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getAdmins()),
519 updateGroup
.getRemoveAdmins() == null
521 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getRemoveAdmins()),
522 updateGroup
.getBanMembers() == null
524 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getBanMembers()),
525 updateGroup
.getUnbanMembers() == null
527 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getUnbanMembers()),
528 updateGroup
.isResetGroupLink(),
529 updateGroup
.getGroupLinkState(),
530 updateGroup
.getAddMemberPermission(),
531 updateGroup
.getEditDetailsPermission(),
532 updateGroup
.getAvatarFile(),
533 updateGroup
.getExpirationTimer(),
534 updateGroup
.getIsAnnouncementGroup());
538 public Pair
<GroupId
, SendGroupMessageResults
> joinGroup(
539 GroupInviteLinkUrl inviteLinkUrl
540 ) throws IOException
, InactiveGroupLinkException
, PendingAdminApprovalException
{
541 return context
.getGroupHelper().joinGroup(inviteLinkUrl
);
544 private SendMessageResults
sendMessage(
545 SignalServiceDataMessage
.Builder messageBuilder
, Set
<RecipientIdentifier
> recipients
, boolean notifySelf
546 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
547 return sendMessage(messageBuilder
, recipients
, notifySelf
, Optional
.empty());
550 private SendMessageResults
sendMessage(
551 SignalServiceDataMessage
.Builder messageBuilder
,
552 Set
<RecipientIdentifier
> recipients
,
554 Optional
<Long
> editTargetTimestamp
555 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
556 var results
= new HashMap
<RecipientIdentifier
, List
<SendMessageResult
>>();
557 long timestamp
= System
.currentTimeMillis();
558 messageBuilder
.withTimestamp(timestamp
);
559 for (final var recipient
: recipients
) {
560 if (recipient
instanceof RecipientIdentifier
.NoteToSelf
|| (
561 recipient
instanceof RecipientIdentifier
.Single single
562 && new RecipientAddress(single
.toPartialRecipientAddress()).matches(account
.getSelfRecipientAddress())
564 final var result
= notifySelf
565 ? context
.getSendHelper()
566 .sendMessage(messageBuilder
, account
.getSelfRecipientId(), editTargetTimestamp
)
567 : context
.getSendHelper().sendSelfMessage(messageBuilder
, editTargetTimestamp
);
568 results
.put(recipient
, List
.of(toSendMessageResult(result
)));
569 } else if (recipient
instanceof RecipientIdentifier
.Single single
) {
571 final var recipientId
= context
.getRecipientHelper().resolveRecipient(single
);
572 final var result
= context
.getSendHelper()
573 .sendMessage(messageBuilder
, recipientId
, editTargetTimestamp
);
574 results
.put(recipient
, List
.of(toSendMessageResult(result
)));
575 } catch (UnregisteredRecipientException e
) {
576 results
.put(recipient
,
577 List
.of(SendMessageResult
.unregisteredFailure(single
.toPartialRecipientAddress())));
579 } else if (recipient
instanceof RecipientIdentifier
.Group group
) {
580 final var result
= context
.getSendHelper()
581 .sendAsGroupMessage(messageBuilder
, group
.groupId(), notifySelf
, editTargetTimestamp
);
582 results
.put(recipient
, result
.stream().map(this::toSendMessageResult
).toList());
585 return new SendMessageResults(timestamp
, results
);
588 private SendMessageResult
toSendMessageResult(final org
.whispersystems
.signalservice
.api
.messages
.SendMessageResult result
) {
589 return SendMessageResult
.from(result
, account
.getRecipientResolver(), account
.getRecipientAddressResolver());
592 private SendMessageResults
sendTypingMessage(
593 SignalServiceTypingMessage
.Action action
, Set
<RecipientIdentifier
> recipients
594 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
595 var results
= new HashMap
<RecipientIdentifier
, List
<SendMessageResult
>>();
596 final var timestamp
= System
.currentTimeMillis();
597 for (var recipient
: recipients
) {
598 if (recipient
instanceof RecipientIdentifier
.Single single
) {
599 final var message
= new SignalServiceTypingMessage(action
, timestamp
, Optional
.empty());
601 final var recipientId
= context
.getRecipientHelper().resolveRecipient(single
);
602 final var result
= context
.getSendHelper().sendTypingMessage(message
, recipientId
);
603 results
.put(recipient
, List
.of(toSendMessageResult(result
)));
604 } catch (UnregisteredRecipientException e
) {
605 results
.put(recipient
,
606 List
.of(SendMessageResult
.unregisteredFailure(single
.toPartialRecipientAddress())));
608 } else if (recipient
instanceof RecipientIdentifier
.Group
) {
609 final var groupId
= ((RecipientIdentifier
.Group
) recipient
).groupId();
610 final var message
= new SignalServiceTypingMessage(action
, timestamp
, Optional
.of(groupId
.serialize()));
611 final var result
= context
.getSendHelper().sendGroupTypingMessage(message
, groupId
);
612 results
.put(recipient
, result
.stream().map(this::toSendMessageResult
).toList());
615 return new SendMessageResults(timestamp
, results
);
619 public SendMessageResults
sendTypingMessage(
620 TypingAction action
, Set
<RecipientIdentifier
> recipients
621 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
622 return sendTypingMessage(action
.toSignalService(), recipients
);
626 public SendMessageResults
sendReadReceipt(
627 RecipientIdentifier
.Single sender
, List
<Long
> messageIds
629 final var timestamp
= System
.currentTimeMillis();
630 var receiptMessage
= new SignalServiceReceiptMessage(SignalServiceReceiptMessage
.Type
.READ
,
634 return sendReceiptMessage(sender
, timestamp
, receiptMessage
);
638 public SendMessageResults
sendViewedReceipt(
639 RecipientIdentifier
.Single sender
, List
<Long
> messageIds
641 final var timestamp
= System
.currentTimeMillis();
642 var receiptMessage
= new SignalServiceReceiptMessage(SignalServiceReceiptMessage
.Type
.VIEWED
,
646 return sendReceiptMessage(sender
, timestamp
, receiptMessage
);
649 private SendMessageResults
sendReceiptMessage(
650 final RecipientIdentifier
.Single sender
,
651 final long timestamp
,
652 final SignalServiceReceiptMessage receiptMessage
655 final var result
= context
.getSendHelper()
656 .sendReceiptMessage(receiptMessage
, context
.getRecipientHelper().resolveRecipient(sender
));
657 return new SendMessageResults(timestamp
, Map
.of(sender
, List
.of(toSendMessageResult(result
))));
658 } catch (UnregisteredRecipientException e
) {
659 return new SendMessageResults(timestamp
,
660 Map
.of(sender
, List
.of(SendMessageResult
.unregisteredFailure(sender
.toPartialRecipientAddress()))));
665 public SendMessageResults
sendMessage(
666 Message message
, Set
<RecipientIdentifier
> recipients
, boolean notifySelf
667 ) throws IOException
, AttachmentInvalidException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
, InvalidStickerException
{
668 final var selfProfile
= context
.getProfileHelper().getSelfProfile();
669 if (selfProfile
== null || selfProfile
.getDisplayName().isEmpty()) {
671 "No profile name set. When sending a message it's recommended to set a profile name with the updateProfile command. This may become mandatory in the future.");
673 final var messageBuilder
= SignalServiceDataMessage
.newBuilder();
674 applyMessage(messageBuilder
, message
);
675 return sendMessage(messageBuilder
, recipients
, notifySelf
);
679 public SendMessageResults
sendEditMessage(
680 Message message
, Set
<RecipientIdentifier
> recipients
, long editTargetTimestamp
681 ) throws IOException
, AttachmentInvalidException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
, InvalidStickerException
{
682 final var messageBuilder
= SignalServiceDataMessage
.newBuilder();
683 applyMessage(messageBuilder
, message
);
684 return sendMessage(messageBuilder
, recipients
, false, Optional
.of(editTargetTimestamp
));
687 private void applyMessage(
688 final SignalServiceDataMessage
.Builder messageBuilder
, final Message message
689 ) throws AttachmentInvalidException
, IOException
, UnregisteredRecipientException
, InvalidStickerException
{
690 if (message
.messageText().length() > 2000) {
691 final var messageBytes
= message
.messageText().getBytes(StandardCharsets
.UTF_8
);
692 final var textAttachment
= AttachmentUtils
.createAttachmentStream(new StreamDetails(new ByteArrayInputStream(
693 messageBytes
), MimeUtils
.LONG_TEXT
, messageBytes
.length
), Optional
.empty());
694 messageBuilder
.withBody(message
.messageText().substring(0, 2000));
695 messageBuilder
.withAttachment(context
.getAttachmentHelper().uploadAttachment(textAttachment
));
697 messageBuilder
.withBody(message
.messageText());
699 if (!message
.attachments().isEmpty()) {
700 messageBuilder
.withAttachments(context
.getAttachmentHelper().uploadAttachments(message
.attachments()));
702 if (!message
.mentions().isEmpty()) {
703 messageBuilder
.withMentions(resolveMentions(message
.mentions()));
705 if (!message
.textStyles().isEmpty()) {
706 messageBuilder
.withBodyRanges(message
.textStyles().stream().map(TextStyle
::toBodyRange
).toList());
708 if (message
.quote().isPresent()) {
709 final var quote
= message
.quote().get();
710 final var quotedAttachments
= new ArrayList
<SignalServiceDataMessage
.Quote
.QuotedAttachment
>();
711 for (final var a
: quote
.attachments()) {
712 final var quotedAttachment
= new SignalServiceDataMessage
.Quote
.QuotedAttachment(a
.contentType(),
714 a
.preview() == null ?
null : context
.getAttachmentHelper().uploadAttachment(a
.preview()));
715 quotedAttachments
.add(quotedAttachment
);
717 messageBuilder
.withQuote(new SignalServiceDataMessage
.Quote(quote
.timestamp(),
718 context
.getRecipientHelper()
719 .resolveSignalServiceAddress(context
.getRecipientHelper().resolveRecipient(quote
.author()))
723 resolveMentions(quote
.mentions()),
724 SignalServiceDataMessage
.Quote
.Type
.NORMAL
,
725 quote
.textStyles().stream().map(TextStyle
::toBodyRange
).toList()));
727 if (message
.sticker().isPresent()) {
728 final var sticker
= message
.sticker().get();
729 final var packId
= StickerPackId
.deserialize(sticker
.packId());
730 final var stickerId
= sticker
.stickerId();
732 final var stickerPack
= context
.getAccount().getStickerStore().getStickerPack(packId
);
733 if (stickerPack
== null) {
734 throw new InvalidStickerException("Sticker pack not found");
736 final var manifest
= context
.getStickerHelper().getOrRetrieveStickerPack(packId
, stickerPack
.packKey());
737 if (manifest
.stickers().size() <= stickerId
) {
738 throw new InvalidStickerException("Sticker id not part of this pack");
740 final var manifestSticker
= manifest
.stickers().get(stickerId
);
741 final var streamDetails
= context
.getStickerPackStore().retrieveSticker(packId
, stickerId
);
742 if (streamDetails
== null) {
743 throw new InvalidStickerException("Missing local sticker file");
745 messageBuilder
.withSticker(new SignalServiceDataMessage
.Sticker(packId
.serialize(),
746 stickerPack
.packKey(),
748 manifestSticker
.emoji(),
749 AttachmentUtils
.createAttachmentStream(streamDetails
, Optional
.empty())));
751 if (!message
.previews().isEmpty()) {
752 final var previews
= new ArrayList
<SignalServicePreview
>(message
.previews().size());
753 for (final var p
: message
.previews()) {
754 final var image
= p
.image().isPresent() ? context
.getAttachmentHelper()
755 .uploadAttachment(p
.image().get()) : null;
756 previews
.add(new SignalServicePreview(p
.url(),
760 Optional
.ofNullable(image
)));
762 messageBuilder
.withPreviews(previews
);
764 if (message
.storyReply().isPresent()) {
765 final var storyReply
= message
.storyReply().get();
766 final var authorServiceId
= context
.getRecipientHelper()
767 .resolveSignalServiceAddress(context
.getRecipientHelper().resolveRecipient(storyReply
.author()))
769 messageBuilder
.withStoryContext(new SignalServiceDataMessage
.StoryContext(authorServiceId
,
770 storyReply
.timestamp()));
774 private ArrayList
<SignalServiceDataMessage
.Mention
> resolveMentions(final List
<Message
.Mention
> mentionList
) throws UnregisteredRecipientException
{
775 final var mentions
= new ArrayList
<SignalServiceDataMessage
.Mention
>();
776 for (final var m
: mentionList
) {
777 final var recipientId
= context
.getRecipientHelper().resolveRecipient(m
.recipient());
778 mentions
.add(new SignalServiceDataMessage
.Mention(context
.getRecipientHelper()
779 .resolveSignalServiceAddress(recipientId
)
780 .getServiceId(), m
.start(), m
.length()));
786 public SendMessageResults
sendRemoteDeleteMessage(
787 long targetSentTimestamp
, Set
<RecipientIdentifier
> recipients
788 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
789 var delete
= new SignalServiceDataMessage
.RemoteDelete(targetSentTimestamp
);
790 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().withRemoteDelete(delete
);
791 for (final var recipient
: recipients
) {
792 if (recipient
instanceof RecipientIdentifier
.Uuid u
) {
793 account
.getMessageSendLogStore()
794 .deleteEntryForRecipientNonGroup(targetSentTimestamp
, ACI
.from(u
.uuid()));
795 } else if (recipient
instanceof RecipientIdentifier
.Single r
) {
797 final var recipientId
= context
.getRecipientHelper().resolveRecipient(r
);
798 final var address
= account
.getRecipientAddressResolver().resolveRecipientAddress(recipientId
);
799 if (address
.serviceId().isPresent()) {
800 account
.getMessageSendLogStore()
801 .deleteEntryForRecipientNonGroup(targetSentTimestamp
, address
.serviceId().get());
803 } catch (UnregisteredRecipientException ignored
) {
805 } else if (recipient
instanceof RecipientIdentifier
.Group r
) {
806 account
.getMessageSendLogStore().deleteEntryForGroup(targetSentTimestamp
, r
.groupId());
809 return sendMessage(messageBuilder
, recipients
, false);
813 public SendMessageResults
sendMessageReaction(
816 RecipientIdentifier
.Single targetAuthor
,
817 long targetSentTimestamp
,
818 Set
<RecipientIdentifier
> recipients
,
819 final boolean isStory
820 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
{
821 var targetAuthorRecipientId
= context
.getRecipientHelper().resolveRecipient(targetAuthor
);
822 final var authorServiceId
= context
.getRecipientHelper()
823 .resolveSignalServiceAddress(targetAuthorRecipientId
)
825 var reaction
= new SignalServiceDataMessage
.Reaction(emoji
, remove
, authorServiceId
, targetSentTimestamp
);
826 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().withReaction(reaction
);
828 messageBuilder
.withStoryContext(new SignalServiceDataMessage
.StoryContext(authorServiceId
,
829 targetSentTimestamp
));
831 return sendMessage(messageBuilder
, recipients
, false);
835 public SendMessageResults
sendPaymentNotificationMessage(
836 byte[] receipt
, String note
, RecipientIdentifier
.Single recipient
837 ) throws IOException
{
838 final var paymentNotification
= new SignalServiceDataMessage
.PaymentNotification(receipt
, note
);
839 final var payment
= new SignalServiceDataMessage
.Payment(paymentNotification
, null);
840 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().withPayment(payment
);
842 return sendMessage(messageBuilder
, Set
.of(recipient
), false);
843 } catch (NotAGroupMemberException
| GroupNotFoundException
| GroupSendingNotAllowedException e
) {
844 throw new AssertionError(e
);
849 public SendMessageResults
sendEndSessionMessage(Set
<RecipientIdentifier
.Single
> recipients
) throws IOException
{
850 var messageBuilder
= SignalServiceDataMessage
.newBuilder().asEndSessionMessage();
853 return sendMessage(messageBuilder
,
854 recipients
.stream().map(RecipientIdentifier
.class::cast
).collect(Collectors
.toSet()),
856 } catch (GroupNotFoundException
| NotAGroupMemberException
| GroupSendingNotAllowedException e
) {
857 throw new AssertionError(e
);
859 for (var recipient
: recipients
) {
860 final RecipientId recipientId
;
862 recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
863 } catch (UnregisteredRecipientException e
) {
866 final var serviceId
= context
.getAccount()
867 .getRecipientAddressResolver()
868 .resolveRecipientAddress(recipientId
)
870 if (serviceId
.isPresent()) {
871 account
.getAccountData(ServiceIdType
.ACI
).getSessionStore().deleteAllSessions(serviceId
.get());
878 public void hideRecipient(final RecipientIdentifier
.Single recipient
) {
879 final var recipientIdOptional
= context
.getRecipientHelper().resolveRecipientOptional(recipient
);
880 if (recipientIdOptional
.isPresent()) {
881 context
.getContactHelper().setContactHidden(recipientIdOptional
.get(), true);
882 account
.removeRecipient(recipientIdOptional
.get());
888 public void deleteRecipient(final RecipientIdentifier
.Single recipient
) {
889 final var recipientIdOptional
= context
.getRecipientHelper().resolveRecipientOptional(recipient
);
890 if (recipientIdOptional
.isPresent()) {
891 account
.removeRecipient(recipientIdOptional
.get());
897 public void deleteContact(final RecipientIdentifier
.Single recipient
) {
898 final var recipientIdOptional
= context
.getRecipientHelper().resolveRecipientOptional(recipient
);
899 if (recipientIdOptional
.isPresent()) {
900 account
.getContactStore().deleteContact(recipientIdOptional
.get());
906 public void setContactName(
907 RecipientIdentifier
.Single recipient
, String givenName
, final String familyName
908 ) throws NotPrimaryDeviceException
, UnregisteredRecipientException
{
909 if (!account
.isPrimaryDevice()) {
910 throw new NotPrimaryDeviceException();
912 context
.getContactHelper()
913 .setContactName(context
.getRecipientHelper().resolveRecipient(recipient
), givenName
, familyName
);
918 public void setContactsBlocked(
919 Collection
<RecipientIdentifier
.Single
> recipients
, boolean blocked
920 ) throws IOException
, UnregisteredRecipientException
{
921 if (recipients
.isEmpty()) {
924 final var recipientIds
= context
.getRecipientHelper().resolveRecipients(recipients
);
925 final var selfRecipientId
= account
.getSelfRecipientId();
926 boolean shouldRotateProfileKey
= false;
927 for (final var recipientId
: recipientIds
) {
928 if (context
.getContactHelper().isContactBlocked(recipientId
) == blocked
) {
931 context
.getContactHelper().setContactBlocked(recipientId
, blocked
);
932 // if we don't have a common group with the blocked contact we need to rotate the profile key
933 shouldRotateProfileKey
= blocked
&& (
934 shouldRotateProfileKey
|| account
.getGroupStore()
937 .noneMatch(g
-> g
.isMember(selfRecipientId
) && g
.isMember(recipientId
))
940 if (shouldRotateProfileKey
) {
941 context
.getProfileHelper().rotateProfileKey();
943 context
.getSyncHelper().sendBlockedList();
948 public void setGroupsBlocked(
949 final Collection
<GroupId
> groupIds
, final boolean blocked
950 ) throws GroupNotFoundException
, IOException
{
951 if (groupIds
.isEmpty()) {
954 boolean shouldRotateProfileKey
= false;
955 for (final var groupId
: groupIds
) {
956 if (context
.getGroupHelper().isGroupBlocked(groupId
) == blocked
) {
959 context
.getGroupHelper().setGroupBlocked(groupId
, blocked
);
960 shouldRotateProfileKey
= blocked
;
962 if (shouldRotateProfileKey
) {
963 context
.getProfileHelper().rotateProfileKey();
965 context
.getSyncHelper().sendBlockedList();
970 public void setExpirationTimer(
971 RecipientIdentifier
.Single recipient
, int messageExpirationTimer
972 ) throws IOException
, UnregisteredRecipientException
{
973 var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
974 context
.getContactHelper().setExpirationTimer(recipientId
, messageExpirationTimer
);
975 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().asExpirationUpdate();
977 sendMessage(messageBuilder
, Set
.of(recipient
), false);
978 } catch (NotAGroupMemberException
| GroupNotFoundException
| GroupSendingNotAllowedException e
) {
979 throw new AssertionError(e
);
985 public StickerPackUrl
uploadStickerPack(File path
) throws IOException
, StickerPackInvalidException
{
986 var manifest
= StickerUtils
.getSignalServiceStickerManifestUpload(path
);
988 var messageSender
= dependencies
.getMessageSender();
990 var packKey
= KeyUtils
.createStickerUploadKey();
991 var packIdString
= messageSender
.uploadStickerManifest(manifest
, packKey
);
992 var packId
= StickerPackId
.deserialize(Hex
.fromStringCondensed(packIdString
));
994 var sticker
= new StickerPack(packId
, packKey
);
995 account
.getStickerStore().addStickerPack(sticker
);
996 context
.getSyncHelper().sendStickerOperationsMessage(List
.of(sticker
), List
.of());
998 return new StickerPackUrl(packId
, packKey
);
1002 public void installStickerPack(StickerPackUrl url
) throws IOException
{
1003 final var packId
= url
.packId();
1004 final var packKey
= url
.packKey();
1006 context
.getStickerHelper().retrieveStickerPack(packId
, packKey
);
1007 } catch (InvalidMessageException e
) {
1008 throw new IOException(e
);
1011 final var sticker
= context
.getStickerHelper().addOrUpdateStickerPack(packId
, packKey
, true);
1012 context
.getSyncHelper().sendStickerOperationsMessage(List
.of(sticker
), List
.of());
1016 public List
<org
.asamk
.signal
.manager
.api
.StickerPack
> getStickerPacks() {
1017 final var stickerPackStore
= context
.getStickerPackStore();
1018 return account
.getStickerStore().getStickerPacks().stream().map(pack
-> {
1019 if (stickerPackStore
.existsStickerPack(pack
.packId())) {
1021 final var manifest
= stickerPackStore
.retrieveManifest(pack
.packId());
1022 return new org
.asamk
.signal
.manager
.api
.StickerPack(pack
.packId(),
1023 new StickerPackUrl(pack
.packId(), pack
.packKey()),
1027 Optional
.ofNullable(manifest
.cover() == null ?
null : manifest
.cover().toApi()),
1028 manifest
.stickers().stream().map(JsonStickerPack
.JsonSticker
::toApi
).toList());
1029 } catch (Exception e
) {
1030 logger
.warn("Failed to read local sticker pack manifest: {}", e
.getMessage(), e
);
1034 return new org
.asamk
.signal
.manager
.api
.StickerPack(pack
.packId(), pack
.packKey(), pack
.isInstalled());
1039 public void requestAllSyncData() {
1040 context
.getSyncHelper().requestAllSyncData();
1041 syncRemoteStorage();
1044 void syncRemoteStorage() {
1045 context
.getJobExecutor().enqueueJob(new SyncStorageJob());
1049 public void addReceiveHandler(final ReceiveMessageHandler handler
, final boolean isWeakListener
) {
1050 synchronized (messageHandlers
) {
1051 if (isWeakListener
) {
1052 weakHandlers
.add(handler
);
1054 messageHandlers
.add(handler
);
1055 startReceiveThreadIfRequired();
1060 private static final AtomicInteger threadNumber
= new AtomicInteger(0);
1062 private void startReceiveThreadIfRequired() {
1063 if (receiveThread
!= null || isReceivingSynchronous
) {
1066 receiveThread
= Thread
.ofPlatform().name("receive-" + threadNumber
.getAndIncrement()).start(() -> {
1067 logger
.debug("Starting receiving messages");
1068 context
.getReceiveHelper().receiveMessagesContinuously(this::passReceivedMessageToHandlers
);
1069 logger
.debug("Finished receiving messages");
1070 synchronized (messageHandlers
) {
1071 receiveThread
= null;
1073 // Check if in the meantime another handler has been registered
1074 if (!messageHandlers
.isEmpty()) {
1075 logger
.debug("Another handler has been registered, starting receive thread again");
1076 startReceiveThreadIfRequired();
1082 private void passReceivedMessageToHandlers(MessageEnvelope envelope
, Throwable e
) {
1083 synchronized (messageHandlers
) {
1084 Stream
.concat(messageHandlers
.stream(), weakHandlers
.stream()).forEach(h
-> {
1086 h
.handleMessage(envelope
, e
);
1087 } catch (Throwable ex
) {
1088 logger
.warn("Message handler failed, ignoring", ex
);
1095 public void removeReceiveHandler(final ReceiveMessageHandler handler
) {
1096 final Thread thread
;
1097 synchronized (messageHandlers
) {
1098 weakHandlers
.remove(handler
);
1099 messageHandlers
.remove(handler
);
1100 if (!messageHandlers
.isEmpty() || receiveThread
== null || isReceivingSynchronous
) {
1103 thread
= receiveThread
;
1104 receiveThread
= null;
1107 stopReceiveThread(thread
);
1110 private void stopReceiveThread(final Thread thread
) {
1111 if (context
.getReceiveHelper().requestStopReceiveMessages()) {
1112 logger
.debug("Receive stop requested, interrupting read from server.");
1117 } catch (InterruptedException ignored
) {
1122 public boolean isReceiving() {
1123 if (isReceivingSynchronous
) {
1126 synchronized (messageHandlers
) {
1127 return !messageHandlers
.isEmpty();
1132 public void receiveMessages(
1133 Optional
<Duration
> timeout
, Optional
<Integer
> maxMessages
, ReceiveMessageHandler handler
1134 ) throws IOException
, AlreadyReceivingException
{
1135 receiveMessages(timeout
.orElse(Duration
.ofMinutes(1)), timeout
.isPresent(), maxMessages
.orElse(null), handler
);
1139 public void stopReceiveMessages() {
1140 Thread thread
= null;
1141 synchronized (messageHandlers
) {
1142 if (isReceivingSynchronous
) {
1143 thread
= receiveThread
;
1144 receiveThread
= null;
1147 if (thread
!= null) {
1148 stopReceiveThread(thread
);
1152 private void receiveMessages(
1153 Duration timeout
, boolean returnOnTimeout
, Integer maxMessages
, ReceiveMessageHandler handler
1154 ) throws IOException
, AlreadyReceivingException
{
1155 synchronized (messageHandlers
) {
1156 if (isReceiving()) {
1157 throw new AlreadyReceivingException("Already receiving message.");
1159 isReceivingSynchronous
= true;
1160 receiveThread
= Thread
.currentThread();
1163 context
.getReceiveHelper().receiveMessages(timeout
, returnOnTimeout
, maxMessages
, (envelope
, e
) -> {
1164 passReceivedMessageToHandlers(envelope
, e
);
1165 handler
.handleMessage(envelope
, e
);
1168 synchronized (messageHandlers
) {
1169 receiveThread
= null;
1170 isReceivingSynchronous
= false;
1171 if (!messageHandlers
.isEmpty()) {
1172 startReceiveThreadIfRequired();
1179 public void setReceiveConfig(final ReceiveConfig receiveConfig
) {
1180 context
.getReceiveHelper().setReceiveConfig(receiveConfig
);
1184 public boolean isContactBlocked(final RecipientIdentifier
.Single recipient
) {
1185 final RecipientId recipientId
;
1187 recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1188 } catch (UnregisteredRecipientException e
) {
1191 return context
.getContactHelper().isContactBlocked(recipientId
);
1195 public void sendContacts() throws IOException
{
1196 context
.getSyncHelper().sendContacts();
1200 public List
<Recipient
> getRecipients(
1201 boolean onlyContacts
,
1202 Optional
<Boolean
> blocked
,
1203 Collection
<RecipientIdentifier
.Single
> recipients
,
1204 Optional
<String
> name
1206 final var recipientIds
= recipients
.stream().map(a
-> {
1208 return context
.getRecipientHelper().resolveRecipient(a
);
1209 } catch (UnregisteredRecipientException e
) {
1212 }).filter(Objects
::nonNull
).collect(Collectors
.toSet());
1213 if (!recipients
.isEmpty() && recipientIds
.isEmpty()) {
1216 // refresh profiles of explicitly given recipients
1217 context
.getProfileHelper().refreshRecipientProfiles(recipientIds
);
1218 return account
.getRecipientStore()
1219 .getRecipients(onlyContacts
, blocked
, recipientIds
, name
)
1221 .map(s
-> new Recipient(s
.getRecipientId(),
1222 s
.getAddress().toApiRecipientAddress(),
1225 s
.getExpiringProfileKeyCredential(),
1231 public String
getContactOrProfileName(RecipientIdentifier
.Single recipient
) {
1232 final RecipientId recipientId
;
1234 recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1235 } catch (UnregisteredRecipientException e
) {
1239 final var contact
= account
.getContactStore().getContact(recipientId
);
1240 if (contact
!= null && !Util
.isEmpty(contact
.getName())) {
1241 return contact
.getName();
1244 final var profile
= context
.getProfileHelper().getRecipientProfile(recipientId
);
1245 if (profile
!= null) {
1246 return profile
.getDisplayName();
1253 public Group
getGroup(GroupId groupId
) {
1254 return toGroup(context
.getGroupHelper().getGroup(groupId
));
1258 public List
<Identity
> getIdentities() {
1259 return account
.getIdentityKeyStore()
1262 .map(this::toIdentity
)
1263 .filter(Objects
::nonNull
)
1267 private Identity
toIdentity(final IdentityInfo identityInfo
) {
1268 if (identityInfo
== null) {
1272 final var address
= account
.getRecipientAddressResolver()
1273 .resolveRecipientAddress(account
.getRecipientResolver().resolveRecipient(identityInfo
.getServiceId()));
1274 if (address
.serviceId().isPresent() && !Objects
.equals(address
.serviceId().get(),
1275 identityInfo
.getServiceId())) {
1278 final var scannableFingerprint
= context
.getIdentityHelper()
1279 .computeSafetyNumberForScanning(identityInfo
.getServiceId(), identityInfo
.getIdentityKey());
1280 return new Identity(address
.toApiRecipientAddress(),
1281 identityInfo
.getIdentityKey(),
1282 context
.getIdentityHelper()
1283 .computeSafetyNumber(identityInfo
.getServiceId(), identityInfo
.getIdentityKey()),
1284 scannableFingerprint
== null ?
null : scannableFingerprint
.getSerialized(),
1285 identityInfo
.getTrustLevel(),
1286 identityInfo
.getDateAddedTimestamp());
1290 public List
<Identity
> getIdentities(RecipientIdentifier
.Single recipient
) {
1291 ServiceId serviceId
;
1293 final var address
= account
.getRecipientAddressResolver()
1294 .resolveRecipientAddress(context
.getRecipientHelper().resolveRecipient(recipient
));
1295 if (address
.serviceId().isEmpty()) {
1298 serviceId
= address
.serviceId().get();
1299 } catch (UnregisteredRecipientException e
) {
1302 final var identity
= account
.getIdentityKeyStore().getIdentityInfo(serviceId
);
1303 return identity
== null ? List
.of() : List
.of(toIdentity(identity
));
1307 public boolean trustIdentityVerified(
1308 RecipientIdentifier
.Single recipient
, IdentityVerificationCode verificationCode
1309 ) throws UnregisteredRecipientException
{
1310 return switch (verificationCode
) {
1311 case IdentityVerificationCode
.Fingerprint fingerprint
-> trustIdentity(recipient
,
1312 r
-> context
.getIdentityHelper().trustIdentityVerified(r
, fingerprint
.fingerprint()));
1313 case IdentityVerificationCode
.SafetyNumber safetyNumber
-> trustIdentity(recipient
,
1314 r
-> context
.getIdentityHelper().trustIdentityVerifiedSafetyNumber(r
, safetyNumber
.safetyNumber()));
1315 case IdentityVerificationCode
.ScannableSafetyNumber safetyNumber
-> trustIdentity(recipient
,
1316 r
-> context
.getIdentityHelper().trustIdentityVerifiedSafetyNumber(r
, safetyNumber
.safetyNumber()));
1317 case null -> throw new AssertionError("Invalid verification code type");
1322 public boolean trustIdentityAllKeys(RecipientIdentifier
.Single recipient
) throws UnregisteredRecipientException
{
1323 return trustIdentity(recipient
, r
-> context
.getIdentityHelper().trustIdentityAllKeys(r
));
1326 private boolean trustIdentity(
1327 RecipientIdentifier
.Single recipient
, Function
<RecipientId
, Boolean
> trustMethod
1328 ) throws UnregisteredRecipientException
{
1329 final var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1330 final var updated
= trustMethod
.apply(recipientId
);
1331 if (updated
&& this.isReceiving()) {
1332 context
.getReceiveHelper().setNeedsToRetryFailedMessages(true);
1338 public void addAddressChangedListener(final Runnable listener
) {
1339 synchronized (addressChangedListeners
) {
1340 addressChangedListeners
.add(listener
);
1345 public void addClosedListener(final Runnable listener
) {
1346 synchronized (closedListeners
) {
1347 closedListeners
.add(listener
);
1352 public InputStream
retrieveAttachment(final String id
) throws IOException
{
1353 return context
.getAttachmentHelper().retrieveAttachment(id
).getStream();
1357 public InputStream
retrieveContactAvatar(final RecipientIdentifier
.Single recipient
) throws IOException
, UnregisteredRecipientException
{
1358 final var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1359 final var address
= account
.getRecipientStore().resolveRecipientAddress(recipientId
);
1360 final var streamDetails
= context
.getAvatarStore().retrieveContactAvatar(address
);
1361 if (streamDetails
== null) {
1362 throw new FileNotFoundException();
1364 return streamDetails
.getStream();
1368 public InputStream
retrieveProfileAvatar(final RecipientIdentifier
.Single recipient
) throws IOException
, UnregisteredRecipientException
{
1369 final var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1370 context
.getProfileHelper().getRecipientProfile(recipientId
);
1371 final var address
= account
.getRecipientStore().resolveRecipientAddress(recipientId
);
1372 final var streamDetails
= context
.getAvatarStore().retrieveProfileAvatar(address
);
1373 if (streamDetails
== null) {
1374 throw new FileNotFoundException();
1376 return streamDetails
.getStream();
1380 public InputStream
retrieveGroupAvatar(final GroupId groupId
) throws IOException
{
1381 final var streamDetails
= context
.getAvatarStore().retrieveGroupAvatar(groupId
);
1382 context
.getGroupHelper().getGroup(groupId
);
1383 if (streamDetails
== null) {
1384 throw new FileNotFoundException();
1386 return streamDetails
.getStream();
1390 public InputStream
retrieveSticker(final StickerPackId stickerPackId
, final int stickerId
) throws IOException
{
1391 var streamDetails
= context
.getStickerPackStore().retrieveSticker(stickerPackId
, stickerId
);
1392 if (streamDetails
== null) {
1393 final var pack
= account
.getStickerStore().getStickerPack(stickerPackId
);
1396 context
.getStickerHelper().retrieveStickerPack(stickerPackId
, pack
.packKey());
1397 } catch (InvalidMessageException e
) {
1398 logger
.warn("Failed to download sticker pack");
1402 if (streamDetails
== null) {
1403 throw new FileNotFoundException();
1405 return streamDetails
.getStream();
1409 public void close() {
1411 synchronized (messageHandlers
) {
1412 weakHandlers
.clear();
1413 messageHandlers
.clear();
1414 thread
= receiveThread
;
1415 receiveThread
= null;
1417 if (thread
!= null) {
1418 stopReceiveThread(thread
);
1423 dependencies
.getSignalWebSocket().disconnect();
1424 dependencies
.getPushServiceSocket().close();
1425 disposable
.dispose();
1427 if (account
!= null) {
1431 synchronized (closedListeners
) {
1432 closedListeners
.forEach(Runnable
::run
);
1433 closedListeners
.clear();