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
.PinLockedException
;
47 import org
.asamk
.signal
.manager
.api
.Profile
;
48 import org
.asamk
.signal
.manager
.api
.RateLimitException
;
49 import org
.asamk
.signal
.manager
.api
.ReceiveConfig
;
50 import org
.asamk
.signal
.manager
.api
.Recipient
;
51 import org
.asamk
.signal
.manager
.api
.RecipientIdentifier
;
52 import org
.asamk
.signal
.manager
.api
.SendGroupMessageResults
;
53 import org
.asamk
.signal
.manager
.api
.SendMessageResult
;
54 import org
.asamk
.signal
.manager
.api
.SendMessageResults
;
55 import org
.asamk
.signal
.manager
.api
.StickerPackId
;
56 import org
.asamk
.signal
.manager
.api
.StickerPackInvalidException
;
57 import org
.asamk
.signal
.manager
.api
.StickerPackUrl
;
58 import org
.asamk
.signal
.manager
.api
.TextStyle
;
59 import org
.asamk
.signal
.manager
.api
.TypingAction
;
60 import org
.asamk
.signal
.manager
.api
.UnregisteredRecipientException
;
61 import org
.asamk
.signal
.manager
.api
.UpdateGroup
;
62 import org
.asamk
.signal
.manager
.api
.UpdateProfile
;
63 import org
.asamk
.signal
.manager
.api
.UserStatus
;
64 import org
.asamk
.signal
.manager
.api
.UsernameLinkUrl
;
65 import org
.asamk
.signal
.manager
.config
.ServiceEnvironmentConfig
;
66 import org
.asamk
.signal
.manager
.helper
.AccountFileUpdater
;
67 import org
.asamk
.signal
.manager
.helper
.Context
;
68 import org
.asamk
.signal
.manager
.helper
.RecipientHelper
.RegisteredUser
;
69 import org
.asamk
.signal
.manager
.jobs
.RefreshRecipientsJob
;
70 import org
.asamk
.signal
.manager
.jobs
.SyncStorageJob
;
71 import org
.asamk
.signal
.manager
.storage
.AttachmentStore
;
72 import org
.asamk
.signal
.manager
.storage
.AvatarStore
;
73 import org
.asamk
.signal
.manager
.storage
.SignalAccount
;
74 import org
.asamk
.signal
.manager
.storage
.groups
.GroupInfo
;
75 import org
.asamk
.signal
.manager
.storage
.identities
.IdentityInfo
;
76 import org
.asamk
.signal
.manager
.storage
.recipients
.RecipientAddress
;
77 import org
.asamk
.signal
.manager
.storage
.recipients
.RecipientId
;
78 import org
.asamk
.signal
.manager
.storage
.stickerPacks
.JsonStickerPack
;
79 import org
.asamk
.signal
.manager
.storage
.stickerPacks
.StickerPackStore
;
80 import org
.asamk
.signal
.manager
.storage
.stickers
.StickerPack
;
81 import org
.asamk
.signal
.manager
.util
.AttachmentUtils
;
82 import org
.asamk
.signal
.manager
.util
.KeyUtils
;
83 import org
.asamk
.signal
.manager
.util
.MimeUtils
;
84 import org
.asamk
.signal
.manager
.util
.StickerUtils
;
85 import org
.signal
.libsignal
.protocol
.InvalidMessageException
;
86 import org
.signal
.libsignal
.usernames
.BaseUsernameException
;
87 import org
.slf4j
.Logger
;
88 import org
.slf4j
.LoggerFactory
;
89 import org
.whispersystems
.signalservice
.api
.SignalSessionLock
;
90 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceDataMessage
;
91 import org
.whispersystems
.signalservice
.api
.messages
.SignalServicePreview
;
92 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceReceiptMessage
;
93 import org
.whispersystems
.signalservice
.api
.messages
.SignalServiceTypingMessage
;
94 import org
.whispersystems
.signalservice
.api
.push
.ServiceId
;
95 import org
.whispersystems
.signalservice
.api
.push
.ServiceId
.ACI
;
96 import org
.whispersystems
.signalservice
.api
.push
.ServiceIdType
;
97 import org
.whispersystems
.signalservice
.api
.push
.exceptions
.CdsiResourceExhaustedException
;
98 import org
.whispersystems
.signalservice
.api
.util
.DeviceNameUtil
;
99 import org
.whispersystems
.signalservice
.api
.util
.InvalidNumberException
;
100 import org
.whispersystems
.signalservice
.api
.util
.PhoneNumberFormatter
;
101 import org
.whispersystems
.signalservice
.api
.util
.StreamDetails
;
102 import org
.whispersystems
.signalservice
.internal
.util
.Hex
;
103 import org
.whispersystems
.signalservice
.internal
.util
.Util
;
105 import java
.io
.ByteArrayInputStream
;
107 import java
.io
.FileNotFoundException
;
108 import java
.io
.IOException
;
109 import java
.io
.InputStream
;
110 import java
.nio
.charset
.StandardCharsets
;
111 import java
.time
.Duration
;
112 import java
.util
.ArrayList
;
113 import java
.util
.Collection
;
114 import java
.util
.HashMap
;
115 import java
.util
.HashSet
;
116 import java
.util
.List
;
117 import java
.util
.Map
;
118 import java
.util
.Objects
;
119 import java
.util
.Optional
;
120 import java
.util
.Set
;
121 import java
.util
.concurrent
.ExecutorService
;
122 import java
.util
.concurrent
.Executors
;
123 import java
.util
.concurrent
.TimeUnit
;
124 import java
.util
.concurrent
.atomic
.AtomicInteger
;
125 import java
.util
.concurrent
.locks
.ReentrantLock
;
126 import java
.util
.function
.Function
;
127 import java
.util
.stream
.Collectors
;
128 import java
.util
.stream
.Stream
;
130 import io
.reactivex
.rxjava3
.disposables
.CompositeDisposable
;
131 import io
.reactivex
.rxjava3
.schedulers
.Schedulers
;
133 public class ManagerImpl
implements Manager
{
135 private static final Logger logger
= LoggerFactory
.getLogger(ManagerImpl
.class);
137 private SignalAccount account
;
138 private final SignalDependencies dependencies
;
139 private final Context context
;
141 private final ExecutorService executor
= Executors
.newCachedThreadPool();
143 private Thread receiveThread
;
144 private boolean isReceivingSynchronous
;
145 private final Set
<ReceiveMessageHandler
> weakHandlers
= new HashSet
<>();
146 private final Set
<ReceiveMessageHandler
> messageHandlers
= new HashSet
<>();
147 private final List
<Runnable
> closedListeners
= new ArrayList
<>();
148 private final List
<Runnable
> addressChangedListeners
= new ArrayList
<>();
149 private final CompositeDisposable disposable
= new CompositeDisposable();
152 SignalAccount account
,
153 PathConfig pathConfig
,
154 AccountFileUpdater accountFileUpdater
,
155 ServiceEnvironmentConfig serviceEnvironmentConfig
,
158 this.account
= account
;
160 final var sessionLock
= new SignalSessionLock() {
161 private final ReentrantLock LEGACY_LOCK
= new ReentrantLock();
164 public Lock
acquire() {
166 return LEGACY_LOCK
::unlock
;
169 this.dependencies
= new SignalDependencies(serviceEnvironmentConfig
,
171 account
.getCredentialsProvider(),
172 account
.getSignalServiceDataStore(),
175 final var avatarStore
= new AvatarStore(pathConfig
.avatarsPath());
176 final var attachmentStore
= new AttachmentStore(pathConfig
.attachmentsPath());
177 final var stickerPackStore
= new StickerPackStore(pathConfig
.stickerPacksPath());
179 this.context
= new Context(account
, new AccountFileUpdater() {
181 public void updateAccountIdentifiers(final String number
, final ACI aci
) {
182 accountFileUpdater
.updateAccountIdentifiers(number
, aci
);
183 synchronized (addressChangedListeners
) {
184 addressChangedListeners
.forEach(Runnable
::run
);
189 public void removeAccount() {
190 accountFileUpdater
.removeAccount();
192 }, dependencies
, avatarStore
, attachmentStore
, stickerPackStore
);
193 this.context
.getAccountHelper().setUnregisteredListener(this::close
);
194 this.context
.getReceiveHelper().setAuthenticationFailureListener(this::close
);
195 this.context
.getReceiveHelper().setCaughtUpWithOldMessagesListener(() -> {
196 synchronized (this) {
200 disposable
.add(account
.getIdentityKeyStore()
201 .getIdentityChanges()
202 .observeOn(Schedulers
.from(executor
))
203 .subscribe(serviceId
-> {
204 logger
.trace("Archiving old sessions for {}", serviceId
);
205 account
.getAccountData(ServiceIdType
.ACI
).getSessionStore().archiveSessions(serviceId
);
206 account
.getAccountData(ServiceIdType
.PNI
).getSessionStore().archiveSessions(serviceId
);
207 account
.getSenderKeyStore().deleteSharedWith(serviceId
);
208 final var recipientId
= account
.getRecipientResolver().resolveRecipient(serviceId
);
209 final var profile
= account
.getProfileStore().getProfile(recipientId
);
210 if (profile
!= null) {
211 account
.getProfileStore()
212 .storeProfile(recipientId
,
213 Profile
.newBuilder(profile
)
214 .withUnidentifiedAccessMode(Profile
.UnidentifiedAccessMode
.UNKNOWN
)
215 .withLastUpdateTimestamp(0)
222 public String
getSelfNumber() {
223 return account
.getNumber();
226 public void checkAccountState() throws IOException
{
227 context
.getAccountHelper().checkAccountState();
228 final var lastRecipientsRefresh
= account
.getLastRecipientsRefresh();
229 if (lastRecipientsRefresh
== null
230 || lastRecipientsRefresh
< System
.currentTimeMillis() - TimeUnit
.DAYS
.toMillis(1)) {
231 context
.getJobExecutor().enqueueJob(new RefreshRecipientsJob());
232 context
.getAccountHelper().checkWhoAmiI();
237 public Map
<String
, UserStatus
> getUserStatus(Set
<String
> numbers
) throws IOException
, RateLimitException
{
238 final var canonicalizedNumbers
= numbers
.stream().collect(Collectors
.toMap(n
-> n
, n
-> {
240 final var canonicalizedNumber
= PhoneNumberFormatter
.formatNumber(n
, account
.getNumber());
241 if (!canonicalizedNumber
.equals(n
)) {
242 logger
.debug("Normalized number {} to {}.", n
, canonicalizedNumber
);
244 return canonicalizedNumber
;
245 } catch (InvalidNumberException e
) {
250 // Note "registeredUsers" has no optionals. It only gives us info on users who are registered
251 final var canonicalizedNumbersSet
= canonicalizedNumbers
.values()
253 .filter(s
-> !s
.isEmpty())
254 .collect(Collectors
.toSet());
256 final Map
<String
, RegisteredUser
> registeredUsers
;
258 registeredUsers
= context
.getRecipientHelper().getRegisteredUsers(canonicalizedNumbersSet
);
259 } catch (CdsiResourceExhaustedException e
) {
260 logger
.debug("CDSI resource exhausted: {}", e
.getMessage());
261 throw new RateLimitException(System
.currentTimeMillis() + e
.getRetryAfterSeconds() * 1000L);
264 return numbers
.stream().collect(Collectors
.toMap(n
-> n
, n
-> {
265 final var number
= canonicalizedNumbers
.get(n
);
266 final var user
= registeredUsers
.get(number
);
267 final var serviceId
= user
== null ?
null : user
.getServiceId();
268 final var profile
= serviceId
== null
270 : context
.getProfileHelper()
271 .getRecipientProfile(account
.getRecipientResolver().resolveRecipient(serviceId
));
272 return new UserStatus(number
.isEmpty() ?
null : number
,
273 serviceId
== null ?
null : serviceId
.getRawUuid(),
275 && profile
.getUnidentifiedAccessMode() == Profile
.UnidentifiedAccessMode
.UNRESTRICTED
);
280 public void updateAccountAttributes(String deviceName
, Boolean unrestrictedUnidentifiedSender
) throws IOException
{
281 if (deviceName
!= null) {
282 context
.getAccountHelper().setDeviceName(deviceName
);
284 if (unrestrictedUnidentifiedSender
!= null) {
285 account
.setUnrestrictedUnidentifiedAccess(unrestrictedUnidentifiedSender
);
287 context
.getAccountHelper().updateAccountAttributes();
288 context
.getAccountHelper().checkWhoAmiI();
292 public Configuration
getConfiguration() {
293 final var configurationStore
= account
.getConfigurationStore();
294 return Configuration
.from(configurationStore
);
298 public void updateConfiguration(Configuration configuration
) {
299 final var configurationStore
= account
.getConfigurationStore();
300 if (configuration
.readReceipts().isPresent()) {
301 configurationStore
.setReadReceipts(configuration
.readReceipts().get());
303 if (configuration
.unidentifiedDeliveryIndicators().isPresent()) {
304 configurationStore
.setUnidentifiedDeliveryIndicators(configuration
.unidentifiedDeliveryIndicators().get());
306 if (configuration
.typingIndicators().isPresent()) {
307 configurationStore
.setTypingIndicators(configuration
.typingIndicators().get());
309 if (configuration
.linkPreviews().isPresent()) {
310 configurationStore
.setLinkPreviews(configuration
.linkPreviews().get());
312 context
.getSyncHelper().sendConfigurationMessage();
317 public void updateProfile(UpdateProfile updateProfile
) throws IOException
{
318 context
.getProfileHelper()
319 .setProfile(updateProfile
.getGivenName(),
320 updateProfile
.getFamilyName(),
321 updateProfile
.getAbout(),
322 updateProfile
.getAboutEmoji(),
323 updateProfile
.isDeleteAvatar()
325 : updateProfile
.getAvatar() == null ?
null : Optional
.of(updateProfile
.getAvatar()),
326 updateProfile
.getMobileCoinAddress());
327 context
.getSyncHelper().sendSyncFetchProfileMessage();
330 void refreshCurrentUsername() throws IOException
, BaseUsernameException
{
331 context
.getAccountHelper().refreshCurrentUsername();
335 public String
getUsername() {
336 return account
.getUsername();
340 public UsernameLinkUrl
getUsernameLink() {
341 return new UsernameLinkUrl(account
.getUsernameLink());
345 public void setUsername(final String username
) throws IOException
, InvalidUsernameException
{
347 context
.getAccountHelper().reserveUsername(username
);
348 } catch (BaseUsernameException e
) {
349 throw new InvalidUsernameException(e
.getMessage() + " (" + e
.getClass().getSimpleName() + ")", e
);
354 public void deleteUsername() throws IOException
{
355 context
.getAccountHelper().deleteUsername();
359 public void startChangeNumber(
360 String newNumber
, boolean voiceVerification
, String captcha
361 ) throws RateLimitException
, IOException
, CaptchaRequiredException
, NonNormalizedPhoneNumberException
, NotPrimaryDeviceException
{
362 if (!account
.isPrimaryDevice()) {
363 throw new NotPrimaryDeviceException();
365 context
.getAccountHelper().startChangeNumber(newNumber
, voiceVerification
, captcha
);
369 public void finishChangeNumber(
370 String newNumber
, String verificationCode
, String pin
371 ) throws IncorrectPinException
, PinLockedException
, IOException
, NotPrimaryDeviceException
{
372 if (!account
.isPrimaryDevice()) {
373 throw new NotPrimaryDeviceException();
375 context
.getAccountHelper().finishChangeNumber(newNumber
, verificationCode
, pin
);
379 public void unregister() throws IOException
{
380 context
.getAccountHelper().unregister();
384 public void deleteAccount() throws IOException
{
385 context
.getAccountHelper().deleteAccount();
389 public void submitRateLimitRecaptchaChallenge(String challenge
, String captcha
) throws IOException
{
390 captcha
= captcha
== null ?
null : captcha
.replace("signalcaptcha://", "");
392 dependencies
.getAccountManager().submitRateLimitRecaptchaChallenge(challenge
, captcha
);
396 public List
<Device
> getLinkedDevices() throws IOException
{
397 var devices
= dependencies
.getAccountManager().getDevices();
398 account
.setMultiDevice(devices
.size() > 1);
399 var identityKey
= account
.getAciIdentityKeyPair().getPrivateKey();
400 return devices
.stream().map(d
-> {
401 String deviceName
= d
.getName();
402 if (deviceName
!= null) {
404 deviceName
= DeviceNameUtil
.decryptDeviceName(deviceName
, identityKey
);
405 } catch (IOException e
) {
406 logger
.debug("Failed to decrypt device name, maybe plain text?", e
);
409 return new Device(d
.getId(),
413 d
.getId() == account
.getDeviceId());
418 public void removeLinkedDevices(int deviceId
) throws IOException
{
419 context
.getAccountHelper().removeLinkedDevices(deviceId
);
423 public void addDeviceLink(DeviceLinkUrl linkUrl
) throws IOException
, InvalidDeviceLinkException
, NotPrimaryDeviceException
{
424 if (!account
.isPrimaryDevice()) {
425 throw new NotPrimaryDeviceException();
427 context
.getAccountHelper().addDevice(linkUrl
);
431 public void setRegistrationLockPin(Optional
<String
> pin
) throws IOException
, NotPrimaryDeviceException
{
432 if (!account
.isPrimaryDevice()) {
433 throw new NotPrimaryDeviceException();
435 if (pin
.isPresent()) {
436 context
.getAccountHelper().setRegistrationPin(pin
.get());
438 context
.getAccountHelper().removeRegistrationPin();
442 void refreshPreKeys() throws IOException
{
443 context
.getPreKeyHelper().refreshPreKeysIfNecessary();
447 public List
<Group
> getGroups() {
448 return account
.getGroupStore().getGroups().stream().map(this::toGroup
).toList();
451 private Group
toGroup(final GroupInfo groupInfo
) {
452 if (groupInfo
== null) {
456 return Group
.from(groupInfo
, account
.getRecipientAddressResolver(), account
.getSelfRecipientId());
460 public SendGroupMessageResults
quitGroup(
461 GroupId groupId
, Set
<RecipientIdentifier
.Single
> groupAdmins
462 ) throws GroupNotFoundException
, IOException
, NotAGroupMemberException
, LastGroupAdminException
, UnregisteredRecipientException
{
463 final var newAdmins
= context
.getRecipientHelper().resolveRecipients(groupAdmins
);
464 return context
.getGroupHelper().quitGroup(groupId
, newAdmins
);
468 public void deleteGroup(GroupId groupId
) throws IOException
{
469 final var group
= context
.getGroupHelper().getGroup(groupId
);
470 if (group
.isMember(account
.getSelfRecipientId())) {
471 throw new IOException(
472 "The local group information cannot be removed, as the user is still a member of the group");
474 context
.getGroupHelper().deleteGroup(groupId
);
478 public Pair
<GroupId
, SendGroupMessageResults
> createGroup(
479 String name
, Set
<RecipientIdentifier
.Single
> members
, String avatarFile
480 ) throws IOException
, AttachmentInvalidException
, UnregisteredRecipientException
{
481 return context
.getGroupHelper()
483 members
== null ?
null : context
.getRecipientHelper().resolveRecipients(members
),
488 public SendGroupMessageResults
updateGroup(
489 final GroupId groupId
, final UpdateGroup updateGroup
490 ) throws IOException
, GroupNotFoundException
, AttachmentInvalidException
, NotAGroupMemberException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
{
491 return context
.getGroupHelper()
492 .updateGroup(groupId
,
493 updateGroup
.getName(),
494 updateGroup
.getDescription(),
495 updateGroup
.getMembers() == null
497 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getMembers()),
498 updateGroup
.getRemoveMembers() == null
500 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getRemoveMembers()),
501 updateGroup
.getAdmins() == null
503 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getAdmins()),
504 updateGroup
.getRemoveAdmins() == null
506 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getRemoveAdmins()),
507 updateGroup
.getBanMembers() == null
509 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getBanMembers()),
510 updateGroup
.getUnbanMembers() == null
512 : context
.getRecipientHelper().resolveRecipients(updateGroup
.getUnbanMembers()),
513 updateGroup
.isResetGroupLink(),
514 updateGroup
.getGroupLinkState(),
515 updateGroup
.getAddMemberPermission(),
516 updateGroup
.getEditDetailsPermission(),
517 updateGroup
.getAvatarFile(),
518 updateGroup
.getExpirationTimer(),
519 updateGroup
.getIsAnnouncementGroup());
523 public Pair
<GroupId
, SendGroupMessageResults
> joinGroup(
524 GroupInviteLinkUrl inviteLinkUrl
525 ) throws IOException
, InactiveGroupLinkException
, PendingAdminApprovalException
{
526 return context
.getGroupHelper().joinGroup(inviteLinkUrl
);
529 private SendMessageResults
sendMessage(
530 SignalServiceDataMessage
.Builder messageBuilder
, Set
<RecipientIdentifier
> recipients
, boolean notifySelf
531 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
532 return sendMessage(messageBuilder
, recipients
, notifySelf
, Optional
.empty());
535 private SendMessageResults
sendMessage(
536 SignalServiceDataMessage
.Builder messageBuilder
,
537 Set
<RecipientIdentifier
> recipients
,
539 Optional
<Long
> editTargetTimestamp
540 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
541 var results
= new HashMap
<RecipientIdentifier
, List
<SendMessageResult
>>();
542 long timestamp
= System
.currentTimeMillis();
543 messageBuilder
.withTimestamp(timestamp
);
544 for (final var recipient
: recipients
) {
545 if (recipient
instanceof RecipientIdentifier
.NoteToSelf
|| (
546 recipient
instanceof RecipientIdentifier
.Single single
547 && new RecipientAddress(single
.toPartialRecipientAddress()).matches(account
.getSelfRecipientAddress())
549 final var result
= notifySelf
550 ? context
.getSendHelper()
551 .sendMessage(messageBuilder
, account
.getSelfRecipientId(), editTargetTimestamp
)
552 : context
.getSendHelper().sendSelfMessage(messageBuilder
, editTargetTimestamp
);
553 results
.put(recipient
, List
.of(toSendMessageResult(result
)));
554 } else if (recipient
instanceof RecipientIdentifier
.Single single
) {
556 final var recipientId
= context
.getRecipientHelper().resolveRecipient(single
);
557 final var result
= context
.getSendHelper()
558 .sendMessage(messageBuilder
, recipientId
, editTargetTimestamp
);
559 results
.put(recipient
, List
.of(toSendMessageResult(result
)));
560 } catch (UnregisteredRecipientException e
) {
561 results
.put(recipient
,
562 List
.of(SendMessageResult
.unregisteredFailure(single
.toPartialRecipientAddress())));
564 } else if (recipient
instanceof RecipientIdentifier
.Group group
) {
565 final var result
= context
.getSendHelper()
566 .sendAsGroupMessage(messageBuilder
, group
.groupId(), notifySelf
, editTargetTimestamp
);
567 results
.put(recipient
, result
.stream().map(this::toSendMessageResult
).toList());
570 return new SendMessageResults(timestamp
, results
);
573 private SendMessageResult
toSendMessageResult(final org
.whispersystems
.signalservice
.api
.messages
.SendMessageResult result
) {
574 return SendMessageResult
.from(result
, account
.getRecipientResolver(), account
.getRecipientAddressResolver());
577 private SendMessageResults
sendTypingMessage(
578 SignalServiceTypingMessage
.Action action
, Set
<RecipientIdentifier
> recipients
579 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
580 var results
= new HashMap
<RecipientIdentifier
, List
<SendMessageResult
>>();
581 final var timestamp
= System
.currentTimeMillis();
582 for (var recipient
: recipients
) {
583 if (recipient
instanceof RecipientIdentifier
.Single single
) {
584 final var message
= new SignalServiceTypingMessage(action
, timestamp
, Optional
.empty());
586 final var recipientId
= context
.getRecipientHelper().resolveRecipient(single
);
587 final var result
= context
.getSendHelper().sendTypingMessage(message
, recipientId
);
588 results
.put(recipient
, List
.of(toSendMessageResult(result
)));
589 } catch (UnregisteredRecipientException e
) {
590 results
.put(recipient
,
591 List
.of(SendMessageResult
.unregisteredFailure(single
.toPartialRecipientAddress())));
593 } else if (recipient
instanceof RecipientIdentifier
.Group
) {
594 final var groupId
= ((RecipientIdentifier
.Group
) recipient
).groupId();
595 final var message
= new SignalServiceTypingMessage(action
, timestamp
, Optional
.of(groupId
.serialize()));
596 final var result
= context
.getSendHelper().sendGroupTypingMessage(message
, groupId
);
597 results
.put(recipient
, result
.stream().map(this::toSendMessageResult
).toList());
600 return new SendMessageResults(timestamp
, results
);
604 public SendMessageResults
sendTypingMessage(
605 TypingAction action
, Set
<RecipientIdentifier
> recipients
606 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
607 return sendTypingMessage(action
.toSignalService(), recipients
);
611 public SendMessageResults
sendReadReceipt(
612 RecipientIdentifier
.Single sender
, List
<Long
> messageIds
614 final var timestamp
= System
.currentTimeMillis();
615 var receiptMessage
= new SignalServiceReceiptMessage(SignalServiceReceiptMessage
.Type
.READ
,
619 return sendReceiptMessage(sender
, timestamp
, receiptMessage
);
623 public SendMessageResults
sendViewedReceipt(
624 RecipientIdentifier
.Single sender
, List
<Long
> messageIds
626 final var timestamp
= System
.currentTimeMillis();
627 var receiptMessage
= new SignalServiceReceiptMessage(SignalServiceReceiptMessage
.Type
.VIEWED
,
631 return sendReceiptMessage(sender
, timestamp
, receiptMessage
);
634 private SendMessageResults
sendReceiptMessage(
635 final RecipientIdentifier
.Single sender
,
636 final long timestamp
,
637 final SignalServiceReceiptMessage receiptMessage
640 final var result
= context
.getSendHelper()
641 .sendReceiptMessage(receiptMessage
, context
.getRecipientHelper().resolveRecipient(sender
));
642 return new SendMessageResults(timestamp
, Map
.of(sender
, List
.of(toSendMessageResult(result
))));
643 } catch (UnregisteredRecipientException e
) {
644 return new SendMessageResults(timestamp
,
645 Map
.of(sender
, List
.of(SendMessageResult
.unregisteredFailure(sender
.toPartialRecipientAddress()))));
650 public SendMessageResults
sendMessage(
651 Message message
, Set
<RecipientIdentifier
> recipients
, boolean notifySelf
652 ) throws IOException
, AttachmentInvalidException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
, InvalidStickerException
{
653 final var selfProfile
= context
.getProfileHelper().getSelfProfile();
654 if (selfProfile
== null || selfProfile
.getDisplayName().isEmpty()) {
656 "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.");
658 final var messageBuilder
= SignalServiceDataMessage
.newBuilder();
659 applyMessage(messageBuilder
, message
);
660 return sendMessage(messageBuilder
, recipients
, notifySelf
);
664 public SendMessageResults
sendEditMessage(
665 Message message
, Set
<RecipientIdentifier
> recipients
, long editTargetTimestamp
666 ) throws IOException
, AttachmentInvalidException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
, InvalidStickerException
{
667 final var messageBuilder
= SignalServiceDataMessage
.newBuilder();
668 applyMessage(messageBuilder
, message
);
669 return sendMessage(messageBuilder
, recipients
, false, Optional
.of(editTargetTimestamp
));
672 private void applyMessage(
673 final SignalServiceDataMessage
.Builder messageBuilder
, final Message message
674 ) throws AttachmentInvalidException
, IOException
, UnregisteredRecipientException
, InvalidStickerException
{
675 if (message
.messageText().length() > 2000) {
676 final var messageBytes
= message
.messageText().getBytes(StandardCharsets
.UTF_8
);
677 final var textAttachment
= AttachmentUtils
.createAttachmentStream(new StreamDetails(new ByteArrayInputStream(
678 messageBytes
), MimeUtils
.LONG_TEXT
, messageBytes
.length
), Optional
.empty());
679 messageBuilder
.withBody(message
.messageText().substring(0, 2000));
680 messageBuilder
.withAttachment(context
.getAttachmentHelper().uploadAttachment(textAttachment
));
682 messageBuilder
.withBody(message
.messageText());
684 if (!message
.attachments().isEmpty()) {
685 messageBuilder
.withAttachments(context
.getAttachmentHelper().uploadAttachments(message
.attachments()));
687 if (!message
.mentions().isEmpty()) {
688 messageBuilder
.withMentions(resolveMentions(message
.mentions()));
690 if (!message
.textStyles().isEmpty()) {
691 messageBuilder
.withBodyRanges(message
.textStyles().stream().map(TextStyle
::toBodyRange
).toList());
693 if (message
.quote().isPresent()) {
694 final var quote
= message
.quote().get();
695 final var quotedAttachments
= new ArrayList
<SignalServiceDataMessage
.Quote
.QuotedAttachment
>();
696 for (final var a
: quote
.attachments()) {
697 final var quotedAttachment
= new SignalServiceDataMessage
.Quote
.QuotedAttachment(a
.contentType(),
699 a
.preview() == null ?
null : context
.getAttachmentHelper().uploadAttachment(a
.preview()));
700 quotedAttachments
.add(quotedAttachment
);
702 messageBuilder
.withQuote(new SignalServiceDataMessage
.Quote(quote
.timestamp(),
703 context
.getRecipientHelper()
704 .resolveSignalServiceAddress(context
.getRecipientHelper().resolveRecipient(quote
.author()))
708 resolveMentions(quote
.mentions()),
709 SignalServiceDataMessage
.Quote
.Type
.NORMAL
,
710 quote
.textStyles().stream().map(TextStyle
::toBodyRange
).toList()));
712 if (message
.sticker().isPresent()) {
713 final var sticker
= message
.sticker().get();
714 final var packId
= StickerPackId
.deserialize(sticker
.packId());
715 final var stickerId
= sticker
.stickerId();
717 final var stickerPack
= context
.getAccount().getStickerStore().getStickerPack(packId
);
718 if (stickerPack
== null) {
719 throw new InvalidStickerException("Sticker pack not found");
721 final var manifest
= context
.getStickerHelper().getOrRetrieveStickerPack(packId
, stickerPack
.packKey());
722 if (manifest
.stickers().size() <= stickerId
) {
723 throw new InvalidStickerException("Sticker id not part of this pack");
725 final var manifestSticker
= manifest
.stickers().get(stickerId
);
726 final var streamDetails
= context
.getStickerPackStore().retrieveSticker(packId
, stickerId
);
727 if (streamDetails
== null) {
728 throw new InvalidStickerException("Missing local sticker file");
730 messageBuilder
.withSticker(new SignalServiceDataMessage
.Sticker(packId
.serialize(),
731 stickerPack
.packKey(),
733 manifestSticker
.emoji(),
734 AttachmentUtils
.createAttachmentStream(streamDetails
, Optional
.empty())));
736 if (!message
.previews().isEmpty()) {
737 final var previews
= new ArrayList
<SignalServicePreview
>(message
.previews().size());
738 for (final var p
: message
.previews()) {
739 final var image
= p
.image().isPresent() ? context
.getAttachmentHelper()
740 .uploadAttachment(p
.image().get()) : null;
741 previews
.add(new SignalServicePreview(p
.url(),
745 Optional
.ofNullable(image
)));
747 messageBuilder
.withPreviews(previews
);
749 if (message
.storyReply().isPresent()) {
750 final var storyReply
= message
.storyReply().get();
751 final var authorServiceId
= context
.getRecipientHelper()
752 .resolveSignalServiceAddress(context
.getRecipientHelper().resolveRecipient(storyReply
.author()))
754 messageBuilder
.withStoryContext(new SignalServiceDataMessage
.StoryContext(authorServiceId
,
755 storyReply
.timestamp()));
759 private ArrayList
<SignalServiceDataMessage
.Mention
> resolveMentions(final List
<Message
.Mention
> mentionList
) throws UnregisteredRecipientException
{
760 final var mentions
= new ArrayList
<SignalServiceDataMessage
.Mention
>();
761 for (final var m
: mentionList
) {
762 final var recipientId
= context
.getRecipientHelper().resolveRecipient(m
.recipient());
763 mentions
.add(new SignalServiceDataMessage
.Mention(context
.getRecipientHelper()
764 .resolveSignalServiceAddress(recipientId
)
765 .getServiceId(), m
.start(), m
.length()));
771 public SendMessageResults
sendRemoteDeleteMessage(
772 long targetSentTimestamp
, Set
<RecipientIdentifier
> recipients
773 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
{
774 var delete
= new SignalServiceDataMessage
.RemoteDelete(targetSentTimestamp
);
775 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().withRemoteDelete(delete
);
776 for (final var recipient
: recipients
) {
777 if (recipient
instanceof RecipientIdentifier
.Uuid u
) {
778 account
.getMessageSendLogStore()
779 .deleteEntryForRecipientNonGroup(targetSentTimestamp
, ACI
.from(u
.uuid()));
780 } else if (recipient
instanceof RecipientIdentifier
.Single r
) {
782 final var recipientId
= context
.getRecipientHelper().resolveRecipient(r
);
783 final var address
= account
.getRecipientAddressResolver().resolveRecipientAddress(recipientId
);
784 if (address
.serviceId().isPresent()) {
785 account
.getMessageSendLogStore()
786 .deleteEntryForRecipientNonGroup(targetSentTimestamp
, address
.serviceId().get());
788 } catch (UnregisteredRecipientException ignored
) {
790 } else if (recipient
instanceof RecipientIdentifier
.Group r
) {
791 account
.getMessageSendLogStore().deleteEntryForGroup(targetSentTimestamp
, r
.groupId());
794 return sendMessage(messageBuilder
, recipients
, false);
798 public SendMessageResults
sendMessageReaction(
801 RecipientIdentifier
.Single targetAuthor
,
802 long targetSentTimestamp
,
803 Set
<RecipientIdentifier
> recipients
,
804 final boolean isStory
805 ) throws IOException
, NotAGroupMemberException
, GroupNotFoundException
, GroupSendingNotAllowedException
, UnregisteredRecipientException
{
806 var targetAuthorRecipientId
= context
.getRecipientHelper().resolveRecipient(targetAuthor
);
807 final var authorServiceId
= context
.getRecipientHelper()
808 .resolveSignalServiceAddress(targetAuthorRecipientId
)
810 var reaction
= new SignalServiceDataMessage
.Reaction(emoji
, remove
, authorServiceId
, targetSentTimestamp
);
811 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().withReaction(reaction
);
813 messageBuilder
.withStoryContext(new SignalServiceDataMessage
.StoryContext(authorServiceId
,
814 targetSentTimestamp
));
816 return sendMessage(messageBuilder
, recipients
, false);
820 public SendMessageResults
sendPaymentNotificationMessage(
821 byte[] receipt
, String note
, RecipientIdentifier
.Single recipient
822 ) throws IOException
{
823 final var paymentNotification
= new SignalServiceDataMessage
.PaymentNotification(receipt
, note
);
824 final var payment
= new SignalServiceDataMessage
.Payment(paymentNotification
, null);
825 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().withPayment(payment
);
827 return sendMessage(messageBuilder
, Set
.of(recipient
), false);
828 } catch (NotAGroupMemberException
| GroupNotFoundException
| GroupSendingNotAllowedException e
) {
829 throw new AssertionError(e
);
834 public SendMessageResults
sendEndSessionMessage(Set
<RecipientIdentifier
.Single
> recipients
) throws IOException
{
835 var messageBuilder
= SignalServiceDataMessage
.newBuilder().asEndSessionMessage();
838 return sendMessage(messageBuilder
,
839 recipients
.stream().map(RecipientIdentifier
.class::cast
).collect(Collectors
.toSet()),
841 } catch (GroupNotFoundException
| NotAGroupMemberException
| GroupSendingNotAllowedException e
) {
842 throw new AssertionError(e
);
844 for (var recipient
: recipients
) {
845 final RecipientId recipientId
;
847 recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
848 } catch (UnregisteredRecipientException e
) {
851 final var serviceId
= context
.getAccount()
852 .getRecipientAddressResolver()
853 .resolveRecipientAddress(recipientId
)
855 if (serviceId
.isPresent()) {
856 account
.getAccountData(ServiceIdType
.ACI
).getSessionStore().deleteAllSessions(serviceId
.get());
863 public void hideRecipient(final RecipientIdentifier
.Single recipient
) {
864 final var recipientIdOptional
= context
.getRecipientHelper().resolveRecipientOptional(recipient
);
865 if (recipientIdOptional
.isPresent()) {
866 context
.getContactHelper().setContactHidden(recipientIdOptional
.get(), true);
867 account
.removeRecipient(recipientIdOptional
.get());
873 public void deleteRecipient(final RecipientIdentifier
.Single recipient
) {
874 final var recipientIdOptional
= context
.getRecipientHelper().resolveRecipientOptional(recipient
);
875 if (recipientIdOptional
.isPresent()) {
876 account
.removeRecipient(recipientIdOptional
.get());
882 public void deleteContact(final RecipientIdentifier
.Single recipient
) {
883 final var recipientIdOptional
= context
.getRecipientHelper().resolveRecipientOptional(recipient
);
884 if (recipientIdOptional
.isPresent()) {
885 account
.getContactStore().deleteContact(recipientIdOptional
.get());
891 public void setContactName(
892 RecipientIdentifier
.Single recipient
, String givenName
, final String familyName
893 ) throws NotPrimaryDeviceException
, UnregisteredRecipientException
{
894 if (!account
.isPrimaryDevice()) {
895 throw new NotPrimaryDeviceException();
897 context
.getContactHelper()
898 .setContactName(context
.getRecipientHelper().resolveRecipient(recipient
), givenName
, familyName
);
903 public void setContactsBlocked(
904 Collection
<RecipientIdentifier
.Single
> recipients
, boolean blocked
905 ) throws IOException
, UnregisteredRecipientException
{
906 if (recipients
.isEmpty()) {
909 final var recipientIds
= context
.getRecipientHelper().resolveRecipients(recipients
);
910 final var selfRecipientId
= account
.getSelfRecipientId();
911 boolean shouldRotateProfileKey
= false;
912 for (final var recipientId
: recipientIds
) {
913 if (context
.getContactHelper().isContactBlocked(recipientId
) == blocked
) {
916 context
.getContactHelper().setContactBlocked(recipientId
, blocked
);
917 // if we don't have a common group with the blocked contact we need to rotate the profile key
918 shouldRotateProfileKey
= blocked
&& (
919 shouldRotateProfileKey
|| account
.getGroupStore()
922 .noneMatch(g
-> g
.isMember(selfRecipientId
) && g
.isMember(recipientId
))
925 if (shouldRotateProfileKey
) {
926 context
.getProfileHelper().rotateProfileKey();
928 context
.getSyncHelper().sendBlockedList();
933 public void setGroupsBlocked(
934 final Collection
<GroupId
> groupIds
, final boolean blocked
935 ) throws GroupNotFoundException
, IOException
{
936 if (groupIds
.isEmpty()) {
939 boolean shouldRotateProfileKey
= false;
940 for (final var groupId
: groupIds
) {
941 if (context
.getGroupHelper().isGroupBlocked(groupId
) == blocked
) {
944 context
.getGroupHelper().setGroupBlocked(groupId
, blocked
);
945 shouldRotateProfileKey
= blocked
;
947 if (shouldRotateProfileKey
) {
948 context
.getProfileHelper().rotateProfileKey();
950 context
.getSyncHelper().sendBlockedList();
955 public void setExpirationTimer(
956 RecipientIdentifier
.Single recipient
, int messageExpirationTimer
957 ) throws IOException
, UnregisteredRecipientException
{
958 var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
959 context
.getContactHelper().setExpirationTimer(recipientId
, messageExpirationTimer
);
960 final var messageBuilder
= SignalServiceDataMessage
.newBuilder().asExpirationUpdate();
962 sendMessage(messageBuilder
, Set
.of(recipient
), false);
963 } catch (NotAGroupMemberException
| GroupNotFoundException
| GroupSendingNotAllowedException e
) {
964 throw new AssertionError(e
);
970 public StickerPackUrl
uploadStickerPack(File path
) throws IOException
, StickerPackInvalidException
{
971 var manifest
= StickerUtils
.getSignalServiceStickerManifestUpload(path
);
973 var messageSender
= dependencies
.getMessageSender();
975 var packKey
= KeyUtils
.createStickerUploadKey();
976 var packIdString
= messageSender
.uploadStickerManifest(manifest
, packKey
);
977 var packId
= StickerPackId
.deserialize(Hex
.fromStringCondensed(packIdString
));
979 var sticker
= new StickerPack(packId
, packKey
);
980 account
.getStickerStore().addStickerPack(sticker
);
981 context
.getSyncHelper().sendStickerOperationsMessage(List
.of(sticker
), List
.of());
983 return new StickerPackUrl(packId
, packKey
);
987 public void installStickerPack(StickerPackUrl url
) throws IOException
{
988 final var packId
= url
.packId();
989 final var packKey
= url
.packKey();
991 context
.getStickerHelper().retrieveStickerPack(packId
, packKey
);
992 } catch (InvalidMessageException e
) {
993 throw new IOException(e
);
996 final var sticker
= context
.getStickerHelper().addOrUpdateStickerPack(packId
, packKey
, true);
997 context
.getSyncHelper().sendStickerOperationsMessage(List
.of(sticker
), List
.of());
1001 public List
<org
.asamk
.signal
.manager
.api
.StickerPack
> getStickerPacks() {
1002 final var stickerPackStore
= context
.getStickerPackStore();
1003 return account
.getStickerStore().getStickerPacks().stream().map(pack
-> {
1004 if (stickerPackStore
.existsStickerPack(pack
.packId())) {
1006 final var manifest
= stickerPackStore
.retrieveManifest(pack
.packId());
1007 return new org
.asamk
.signal
.manager
.api
.StickerPack(pack
.packId(),
1008 new StickerPackUrl(pack
.packId(), pack
.packKey()),
1012 Optional
.ofNullable(manifest
.cover() == null ?
null : manifest
.cover().toApi()),
1013 manifest
.stickers().stream().map(JsonStickerPack
.JsonSticker
::toApi
).toList());
1014 } catch (Exception e
) {
1015 logger
.warn("Failed to read local sticker pack manifest: {}", e
.getMessage(), e
);
1019 return new org
.asamk
.signal
.manager
.api
.StickerPack(pack
.packId(), pack
.packKey(), pack
.isInstalled());
1024 public void requestAllSyncData() {
1025 context
.getSyncHelper().requestAllSyncData();
1026 syncRemoteStorage();
1029 void syncRemoteStorage() {
1030 context
.getJobExecutor().enqueueJob(new SyncStorageJob());
1034 public void addReceiveHandler(final ReceiveMessageHandler handler
, final boolean isWeakListener
) {
1035 synchronized (messageHandlers
) {
1036 if (isWeakListener
) {
1037 weakHandlers
.add(handler
);
1039 messageHandlers
.add(handler
);
1040 startReceiveThreadIfRequired();
1045 private static final AtomicInteger threadNumber
= new AtomicInteger(0);
1047 private void startReceiveThreadIfRequired() {
1048 if (receiveThread
!= null || isReceivingSynchronous
) {
1051 receiveThread
= Thread
.ofPlatform().name("receive-" + threadNumber
.getAndIncrement()).start(() -> {
1052 logger
.debug("Starting receiving messages");
1053 context
.getReceiveHelper().receiveMessagesContinuously(this::passReceivedMessageToHandlers
);
1054 logger
.debug("Finished receiving messages");
1055 synchronized (messageHandlers
) {
1056 receiveThread
= null;
1058 // Check if in the meantime another handler has been registered
1059 if (!messageHandlers
.isEmpty()) {
1060 logger
.debug("Another handler has been registered, starting receive thread again");
1061 startReceiveThreadIfRequired();
1067 private void passReceivedMessageToHandlers(MessageEnvelope envelope
, Throwable e
) {
1068 synchronized (messageHandlers
) {
1069 Stream
.concat(messageHandlers
.stream(), weakHandlers
.stream()).forEach(h
-> {
1071 h
.handleMessage(envelope
, e
);
1072 } catch (Throwable ex
) {
1073 logger
.warn("Message handler failed, ignoring", ex
);
1080 public void removeReceiveHandler(final ReceiveMessageHandler handler
) {
1081 final Thread thread
;
1082 synchronized (messageHandlers
) {
1083 weakHandlers
.remove(handler
);
1084 messageHandlers
.remove(handler
);
1085 if (!messageHandlers
.isEmpty() || receiveThread
== null || isReceivingSynchronous
) {
1088 thread
= receiveThread
;
1089 receiveThread
= null;
1092 stopReceiveThread(thread
);
1095 private void stopReceiveThread(final Thread thread
) {
1096 if (context
.getReceiveHelper().requestStopReceiveMessages()) {
1097 logger
.debug("Receive stop requested, interrupting read from server.");
1102 } catch (InterruptedException ignored
) {
1107 public boolean isReceiving() {
1108 if (isReceivingSynchronous
) {
1111 synchronized (messageHandlers
) {
1112 return !messageHandlers
.isEmpty();
1117 public void receiveMessages(
1118 Optional
<Duration
> timeout
, Optional
<Integer
> maxMessages
, ReceiveMessageHandler handler
1119 ) throws IOException
, AlreadyReceivingException
{
1120 receiveMessages(timeout
.orElse(Duration
.ofMinutes(1)), timeout
.isPresent(), maxMessages
.orElse(null), handler
);
1124 public void stopReceiveMessages() {
1125 Thread thread
= null;
1126 synchronized (messageHandlers
) {
1127 if (isReceivingSynchronous
) {
1128 thread
= receiveThread
;
1129 receiveThread
= null;
1132 if (thread
!= null) {
1133 stopReceiveThread(thread
);
1137 private void receiveMessages(
1138 Duration timeout
, boolean returnOnTimeout
, Integer maxMessages
, ReceiveMessageHandler handler
1139 ) throws IOException
, AlreadyReceivingException
{
1140 synchronized (messageHandlers
) {
1141 if (isReceiving()) {
1142 throw new AlreadyReceivingException("Already receiving message.");
1144 isReceivingSynchronous
= true;
1145 receiveThread
= Thread
.currentThread();
1148 context
.getReceiveHelper().receiveMessages(timeout
, returnOnTimeout
, maxMessages
, (envelope
, e
) -> {
1149 passReceivedMessageToHandlers(envelope
, e
);
1150 handler
.handleMessage(envelope
, e
);
1153 synchronized (messageHandlers
) {
1154 receiveThread
= null;
1155 isReceivingSynchronous
= false;
1156 if (!messageHandlers
.isEmpty()) {
1157 startReceiveThreadIfRequired();
1164 public void setReceiveConfig(final ReceiveConfig receiveConfig
) {
1165 context
.getReceiveHelper().setReceiveConfig(receiveConfig
);
1169 public boolean isContactBlocked(final RecipientIdentifier
.Single recipient
) {
1170 final RecipientId recipientId
;
1172 recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1173 } catch (UnregisteredRecipientException e
) {
1176 return context
.getContactHelper().isContactBlocked(recipientId
);
1180 public void sendContacts() throws IOException
{
1181 context
.getSyncHelper().sendContacts();
1185 public List
<Recipient
> getRecipients(
1186 boolean onlyContacts
,
1187 Optional
<Boolean
> blocked
,
1188 Collection
<RecipientIdentifier
.Single
> recipients
,
1189 Optional
<String
> name
1191 final var recipientIds
= recipients
.stream().map(a
-> {
1193 return context
.getRecipientHelper().resolveRecipient(a
);
1194 } catch (UnregisteredRecipientException e
) {
1197 }).filter(Objects
::nonNull
).collect(Collectors
.toSet());
1198 if (!recipients
.isEmpty() && recipientIds
.isEmpty()) {
1201 // refresh profiles of explicitly given recipients
1202 context
.getProfileHelper().refreshRecipientProfiles(recipientIds
);
1203 return account
.getRecipientStore()
1204 .getRecipients(onlyContacts
, blocked
, recipientIds
, name
)
1206 .map(s
-> new Recipient(s
.getRecipientId(),
1207 s
.getAddress().toApiRecipientAddress(),
1210 s
.getExpiringProfileKeyCredential(),
1216 public String
getContactOrProfileName(RecipientIdentifier
.Single recipient
) {
1217 final RecipientId recipientId
;
1219 recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1220 } catch (UnregisteredRecipientException e
) {
1224 final var contact
= account
.getContactStore().getContact(recipientId
);
1225 if (contact
!= null && !Util
.isEmpty(contact
.getName())) {
1226 return contact
.getName();
1229 final var profile
= context
.getProfileHelper().getRecipientProfile(recipientId
);
1230 if (profile
!= null) {
1231 return profile
.getDisplayName();
1238 public Group
getGroup(GroupId groupId
) {
1239 return toGroup(context
.getGroupHelper().getGroup(groupId
));
1243 public List
<Identity
> getIdentities() {
1244 return account
.getIdentityKeyStore()
1247 .map(this::toIdentity
)
1248 .filter(Objects
::nonNull
)
1252 private Identity
toIdentity(final IdentityInfo identityInfo
) {
1253 if (identityInfo
== null) {
1257 final var address
= account
.getRecipientAddressResolver()
1258 .resolveRecipientAddress(account
.getRecipientResolver().resolveRecipient(identityInfo
.getServiceId()));
1259 if (address
.serviceId().isPresent() && !Objects
.equals(address
.serviceId().get(),
1260 identityInfo
.getServiceId())) {
1263 final var scannableFingerprint
= context
.getIdentityHelper()
1264 .computeSafetyNumberForScanning(identityInfo
.getServiceId(), identityInfo
.getIdentityKey());
1265 return new Identity(address
.toApiRecipientAddress(),
1266 identityInfo
.getIdentityKey(),
1267 context
.getIdentityHelper()
1268 .computeSafetyNumber(identityInfo
.getServiceId(), identityInfo
.getIdentityKey()),
1269 scannableFingerprint
== null ?
null : scannableFingerprint
.getSerialized(),
1270 identityInfo
.getTrustLevel(),
1271 identityInfo
.getDateAddedTimestamp());
1275 public List
<Identity
> getIdentities(RecipientIdentifier
.Single recipient
) {
1276 ServiceId serviceId
;
1278 final var address
= account
.getRecipientAddressResolver()
1279 .resolveRecipientAddress(context
.getRecipientHelper().resolveRecipient(recipient
));
1280 if (address
.serviceId().isEmpty()) {
1283 serviceId
= address
.serviceId().get();
1284 } catch (UnregisteredRecipientException e
) {
1287 final var identity
= account
.getIdentityKeyStore().getIdentityInfo(serviceId
);
1288 return identity
== null ? List
.of() : List
.of(toIdentity(identity
));
1292 public boolean trustIdentityVerified(
1293 RecipientIdentifier
.Single recipient
, IdentityVerificationCode verificationCode
1294 ) throws UnregisteredRecipientException
{
1295 return switch (verificationCode
) {
1296 case IdentityVerificationCode
.Fingerprint fingerprint
-> trustIdentity(recipient
,
1297 r
-> context
.getIdentityHelper().trustIdentityVerified(r
, fingerprint
.fingerprint()));
1298 case IdentityVerificationCode
.SafetyNumber safetyNumber
-> trustIdentity(recipient
,
1299 r
-> context
.getIdentityHelper().trustIdentityVerifiedSafetyNumber(r
, safetyNumber
.safetyNumber()));
1300 case IdentityVerificationCode
.ScannableSafetyNumber safetyNumber
-> trustIdentity(recipient
,
1301 r
-> context
.getIdentityHelper().trustIdentityVerifiedSafetyNumber(r
, safetyNumber
.safetyNumber()));
1302 case null -> throw new AssertionError("Invalid verification code type");
1307 public boolean trustIdentityAllKeys(RecipientIdentifier
.Single recipient
) throws UnregisteredRecipientException
{
1308 return trustIdentity(recipient
, r
-> context
.getIdentityHelper().trustIdentityAllKeys(r
));
1311 private boolean trustIdentity(
1312 RecipientIdentifier
.Single recipient
, Function
<RecipientId
, Boolean
> trustMethod
1313 ) throws UnregisteredRecipientException
{
1314 final var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1315 final var updated
= trustMethod
.apply(recipientId
);
1316 if (updated
&& this.isReceiving()) {
1317 context
.getReceiveHelper().setNeedsToRetryFailedMessages(true);
1323 public void addAddressChangedListener(final Runnable listener
) {
1324 synchronized (addressChangedListeners
) {
1325 addressChangedListeners
.add(listener
);
1330 public void addClosedListener(final Runnable listener
) {
1331 synchronized (closedListeners
) {
1332 closedListeners
.add(listener
);
1337 public InputStream
retrieveAttachment(final String id
) throws IOException
{
1338 return context
.getAttachmentHelper().retrieveAttachment(id
).getStream();
1342 public InputStream
retrieveContactAvatar(final RecipientIdentifier
.Single recipient
) throws IOException
, UnregisteredRecipientException
{
1343 final var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1344 final var address
= account
.getRecipientStore().resolveRecipientAddress(recipientId
);
1345 final var streamDetails
= context
.getAvatarStore().retrieveContactAvatar(address
);
1346 if (streamDetails
== null) {
1347 throw new FileNotFoundException();
1349 return streamDetails
.getStream();
1353 public InputStream
retrieveProfileAvatar(final RecipientIdentifier
.Single recipient
) throws IOException
, UnregisteredRecipientException
{
1354 final var recipientId
= context
.getRecipientHelper().resolveRecipient(recipient
);
1355 context
.getProfileHelper().getRecipientProfile(recipientId
);
1356 final var address
= account
.getRecipientStore().resolveRecipientAddress(recipientId
);
1357 final var streamDetails
= context
.getAvatarStore().retrieveProfileAvatar(address
);
1358 if (streamDetails
== null) {
1359 throw new FileNotFoundException();
1361 return streamDetails
.getStream();
1365 public InputStream
retrieveGroupAvatar(final GroupId groupId
) throws IOException
{
1366 final var streamDetails
= context
.getAvatarStore().retrieveGroupAvatar(groupId
);
1367 context
.getGroupHelper().getGroup(groupId
);
1368 if (streamDetails
== null) {
1369 throw new FileNotFoundException();
1371 return streamDetails
.getStream();
1375 public InputStream
retrieveSticker(final StickerPackId stickerPackId
, final int stickerId
) throws IOException
{
1376 var streamDetails
= context
.getStickerPackStore().retrieveSticker(stickerPackId
, stickerId
);
1377 if (streamDetails
== null) {
1378 final var pack
= account
.getStickerStore().getStickerPack(stickerPackId
);
1381 context
.getStickerHelper().retrieveStickerPack(stickerPackId
, pack
.packKey());
1382 } catch (InvalidMessageException e
) {
1383 logger
.warn("Failed to download sticker pack");
1387 if (streamDetails
== null) {
1388 throw new FileNotFoundException();
1390 return streamDetails
.getStream();
1394 public void close() {
1396 synchronized (messageHandlers
) {
1397 weakHandlers
.clear();
1398 messageHandlers
.clear();
1399 thread
= receiveThread
;
1400 receiveThread
= null;
1402 if (thread
!= null) {
1403 stopReceiveThread(thread
);
1408 dependencies
.getSignalWebSocket().disconnect();
1409 dependencies
.getPushServiceSocket().close();
1410 disposable
.dispose();
1412 if (account
!= null) {
1416 synchronized (closedListeners
) {
1417 closedListeners
.forEach(Runnable
::run
);
1418 closedListeners
.clear();