]> nmode's Git Repositories - signal-cli/blob - lib/src/main/java/org/asamk/signal/manager/internal/ManagerImpl.java
Fix issues with receiving message to PNI address
[signal-cli] / lib / src / main / java / org / asamk / signal / manager / internal / ManagerImpl.java
1 /*
2 Copyright (C) 2015-2022 AsamK and contributors
3
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.
8
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.
13
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/>.
16 */
17 package org.asamk.signal.manager.internal;
18
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;
105
106 import java.io.ByteArrayInputStream;
107 import java.io.File;
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;
130
131 import io.reactivex.rxjava3.disposables.CompositeDisposable;
132 import io.reactivex.rxjava3.schedulers.Schedulers;
133
134 public class ManagerImpl implements Manager {
135
136 private static final Logger logger = LoggerFactory.getLogger(ManagerImpl.class);
137
138 private SignalAccount account;
139 private final SignalDependencies dependencies;
140 private final Context context;
141
142 private final ExecutorService executor = Executors.newCachedThreadPool();
143
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();
151
152 public ManagerImpl(
153 SignalAccount account,
154 PathConfig pathConfig,
155 AccountFileUpdater accountFileUpdater,
156 ServiceEnvironmentConfig serviceEnvironmentConfig,
157 String userAgent
158 ) {
159 this.account = account;
160
161 final var sessionLock = new SignalSessionLock() {
162 private final ReentrantLock LEGACY_LOCK = new ReentrantLock();
163
164 @Override
165 public Lock acquire() {
166 LEGACY_LOCK.lock();
167 return LEGACY_LOCK::unlock;
168 }
169 };
170 this.dependencies = new SignalDependencies(serviceEnvironmentConfig,
171 userAgent,
172 account.getCredentialsProvider(),
173 account.getSignalServiceDataStore(),
174 executor,
175 sessionLock);
176 final var avatarStore = new AvatarStore(pathConfig.avatarsPath());
177 final var attachmentStore = new AttachmentStore(pathConfig.attachmentsPath());
178 final var stickerPackStore = new StickerPackStore(pathConfig.stickerPacksPath());
179
180 this.context = new Context(account, new AccountFileUpdater() {
181 @Override
182 public void updateAccountIdentifiers(final String number, final ACI aci) {
183 accountFileUpdater.updateAccountIdentifiers(number, aci);
184 synchronized (addressChangedListeners) {
185 addressChangedListeners.forEach(Runnable::run);
186 }
187 }
188
189 @Override
190 public void removeAccount() {
191 accountFileUpdater.removeAccount();
192 }
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) {
198 this.notifyAll();
199 }
200 });
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)
217 .build());
218 }
219 }));
220 }
221
222 @Override
223 public String getSelfNumber() {
224 return account.getNumber();
225 }
226
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();
234 }
235 }
236
237 @Override
238 public Map<String, UserStatus> getUserStatus(Set<String> numbers) throws IOException, RateLimitException {
239 final var canonicalizedNumbers = numbers.stream().collect(Collectors.toMap(n -> n, n -> {
240 try {
241 final var canonicalizedNumber = PhoneNumberFormatter.formatNumber(n, account.getNumber());
242 if (!canonicalizedNumber.equals(n)) {
243 logger.debug("Normalized number {} to {}.", n, canonicalizedNumber);
244 }
245 return canonicalizedNumber;
246 } catch (InvalidNumberException e) {
247 return "";
248 }
249 }));
250
251 // Note "registeredUsers" has no optionals. It only gives us info on users who are registered
252 final var canonicalizedNumbersSet = canonicalizedNumbers.values()
253 .stream()
254 .filter(s -> !s.isEmpty())
255 .collect(Collectors.toSet());
256
257 final Map<String, RegisteredUser> registeredUsers;
258 try {
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);
263 }
264
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
270 ? null
271 : context.getProfileHelper()
272 .getRecipientProfile(account.getRecipientResolver().resolveRecipient(serviceId));
273 return new UserStatus(number.isEmpty() ? null : number,
274 serviceId == null ? null : serviceId.getRawUuid(),
275 profile != null
276 && profile.getUnidentifiedAccessMode() == Profile.UnidentifiedAccessMode.UNRESTRICTED);
277 }));
278 }
279
280 @Override
281 public void updateAccountAttributes(
282 String deviceName,
283 Boolean unrestrictedUnidentifiedSender,
284 final Boolean discoverableByNumber,
285 final Boolean numberSharing
286 ) throws IOException {
287 if (deviceName != null) {
288 context.getAccountHelper().setDeviceName(deviceName);
289 }
290 if (unrestrictedUnidentifiedSender != null) {
291 account.setUnrestrictedUnidentifiedAccess(unrestrictedUnidentifiedSender);
292 }
293 if (discoverableByNumber != null) {
294 account.getConfigurationStore().setPhoneNumberUnlisted(!discoverableByNumber);
295 }
296 if (numberSharing != null) {
297 account.getConfigurationStore()
298 .setPhoneNumberSharingMode(numberSharing
299 ? PhoneNumberSharingMode.EVERYBODY
300 : PhoneNumberSharingMode.NOBODY);
301 }
302 context.getAccountHelper().updateAccountAttributes();
303 context.getAccountHelper().checkWhoAmiI();
304 }
305
306 @Override
307 public Configuration getConfiguration() {
308 final var configurationStore = account.getConfigurationStore();
309 return Configuration.from(configurationStore);
310 }
311
312 @Override
313 public void updateConfiguration(Configuration configuration) {
314 final var configurationStore = account.getConfigurationStore();
315 if (configuration.readReceipts().isPresent()) {
316 configurationStore.setReadReceipts(configuration.readReceipts().get());
317 }
318 if (configuration.unidentifiedDeliveryIndicators().isPresent()) {
319 configurationStore.setUnidentifiedDeliveryIndicators(configuration.unidentifiedDeliveryIndicators().get());
320 }
321 if (configuration.typingIndicators().isPresent()) {
322 configurationStore.setTypingIndicators(configuration.typingIndicators().get());
323 }
324 if (configuration.linkPreviews().isPresent()) {
325 configurationStore.setLinkPreviews(configuration.linkPreviews().get());
326 }
327 context.getSyncHelper().sendConfigurationMessage();
328 syncRemoteStorage();
329 }
330
331 @Override
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()
339 ? Optional.empty()
340 : updateProfile.getAvatar() == null ? null : Optional.of(updateProfile.getAvatar()),
341 updateProfile.getMobileCoinAddress());
342 context.getSyncHelper().sendSyncFetchProfileMessage();
343 }
344
345 void refreshCurrentUsername() throws IOException, BaseUsernameException {
346 context.getAccountHelper().refreshCurrentUsername();
347 }
348
349 @Override
350 public String getUsername() {
351 return account.getUsername();
352 }
353
354 @Override
355 public UsernameLinkUrl getUsernameLink() {
356 return new UsernameLinkUrl(account.getUsernameLink());
357 }
358
359 @Override
360 public void setUsername(final String username) throws IOException, InvalidUsernameException {
361 try {
362 context.getAccountHelper().reserveUsername(username);
363 } catch (BaseUsernameException e) {
364 throw new InvalidUsernameException(e.getMessage() + " (" + e.getClass().getSimpleName() + ")", e);
365 }
366 }
367
368 @Override
369 public void deleteUsername() throws IOException {
370 context.getAccountHelper().deleteUsername();
371 }
372
373 @Override
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();
379 }
380 context.getAccountHelper().startChangeNumber(newNumber, voiceVerification, captcha);
381 }
382
383 @Override
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();
389 }
390 context.getAccountHelper().finishChangeNumber(newNumber, verificationCode, pin);
391 }
392
393 @Override
394 public void unregister() throws IOException {
395 context.getAccountHelper().unregister();
396 }
397
398 @Override
399 public void deleteAccount() throws IOException {
400 context.getAccountHelper().deleteAccount();
401 }
402
403 @Override
404 public void submitRateLimitRecaptchaChallenge(String challenge, String captcha) throws IOException {
405 captcha = captcha == null ? null : captcha.replace("signalcaptcha://", "");
406
407 dependencies.getAccountManager().submitRateLimitRecaptchaChallenge(challenge, captcha);
408 }
409
410 @Override
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) {
418 try {
419 deviceName = DeviceNameUtil.decryptDeviceName(deviceName, identityKey);
420 } catch (IOException e) {
421 logger.debug("Failed to decrypt device name, maybe plain text?", e);
422 }
423 }
424 return new Device(d.getId(),
425 deviceName,
426 d.getCreated(),
427 d.getLastSeen(),
428 d.getId() == account.getDeviceId());
429 }).toList();
430 }
431
432 @Override
433 public void removeLinkedDevices(int deviceId) throws IOException {
434 context.getAccountHelper().removeLinkedDevices(deviceId);
435 }
436
437 @Override
438 public void addDeviceLink(DeviceLinkUrl linkUrl) throws IOException, InvalidDeviceLinkException, NotPrimaryDeviceException {
439 if (!account.isPrimaryDevice()) {
440 throw new NotPrimaryDeviceException();
441 }
442 context.getAccountHelper().addDevice(linkUrl);
443 }
444
445 @Override
446 public void setRegistrationLockPin(Optional<String> pin) throws IOException, NotPrimaryDeviceException {
447 if (!account.isPrimaryDevice()) {
448 throw new NotPrimaryDeviceException();
449 }
450 if (pin.isPresent()) {
451 context.getAccountHelper().setRegistrationPin(pin.get());
452 } else {
453 context.getAccountHelper().removeRegistrationPin();
454 }
455 }
456
457 void refreshPreKeys() throws IOException {
458 context.getPreKeyHelper().refreshPreKeysIfNecessary();
459 }
460
461 @Override
462 public List<Group> getGroups() {
463 return account.getGroupStore().getGroups().stream().map(this::toGroup).toList();
464 }
465
466 private Group toGroup(final GroupInfo groupInfo) {
467 if (groupInfo == null) {
468 return null;
469 }
470
471 return Group.from(groupInfo, account.getRecipientAddressResolver(), account.getSelfRecipientId());
472 }
473
474 @Override
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);
480 }
481
482 @Override
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");
488 }
489 context.getGroupHelper().deleteGroup(groupId);
490 }
491
492 @Override
493 public Pair<GroupId, SendGroupMessageResults> createGroup(
494 String name, Set<RecipientIdentifier.Single> members, String avatarFile
495 ) throws IOException, AttachmentInvalidException, UnregisteredRecipientException {
496 return context.getGroupHelper()
497 .createGroup(name,
498 members == null ? null : context.getRecipientHelper().resolveRecipients(members),
499 avatarFile);
500 }
501
502 @Override
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
511 ? null
512 : context.getRecipientHelper().resolveRecipients(updateGroup.getMembers()),
513 updateGroup.getRemoveMembers() == null
514 ? null
515 : context.getRecipientHelper().resolveRecipients(updateGroup.getRemoveMembers()),
516 updateGroup.getAdmins() == null
517 ? null
518 : context.getRecipientHelper().resolveRecipients(updateGroup.getAdmins()),
519 updateGroup.getRemoveAdmins() == null
520 ? null
521 : context.getRecipientHelper().resolveRecipients(updateGroup.getRemoveAdmins()),
522 updateGroup.getBanMembers() == null
523 ? null
524 : context.getRecipientHelper().resolveRecipients(updateGroup.getBanMembers()),
525 updateGroup.getUnbanMembers() == null
526 ? 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());
535 }
536
537 @Override
538 public Pair<GroupId, SendGroupMessageResults> joinGroup(
539 GroupInviteLinkUrl inviteLinkUrl
540 ) throws IOException, InactiveGroupLinkException, PendingAdminApprovalException {
541 return context.getGroupHelper().joinGroup(inviteLinkUrl);
542 }
543
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());
548 }
549
550 private SendMessageResults sendMessage(
551 SignalServiceDataMessage.Builder messageBuilder,
552 Set<RecipientIdentifier> recipients,
553 boolean notifySelf,
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())
563 )) {
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) {
570 try {
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())));
578 }
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());
583 }
584 }
585 return new SendMessageResults(timestamp, results);
586 }
587
588 private SendMessageResult toSendMessageResult(final org.whispersystems.signalservice.api.messages.SendMessageResult result) {
589 return SendMessageResult.from(result, account.getRecipientResolver(), account.getRecipientAddressResolver());
590 }
591
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());
600 try {
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())));
607 }
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());
613 }
614 }
615 return new SendMessageResults(timestamp, results);
616 }
617
618 @Override
619 public SendMessageResults sendTypingMessage(
620 TypingAction action, Set<RecipientIdentifier> recipients
621 ) throws IOException, NotAGroupMemberException, GroupNotFoundException, GroupSendingNotAllowedException {
622 return sendTypingMessage(action.toSignalService(), recipients);
623 }
624
625 @Override
626 public SendMessageResults sendReadReceipt(
627 RecipientIdentifier.Single sender, List<Long> messageIds
628 ) {
629 final var timestamp = System.currentTimeMillis();
630 var receiptMessage = new SignalServiceReceiptMessage(SignalServiceReceiptMessage.Type.READ,
631 messageIds,
632 timestamp);
633
634 return sendReceiptMessage(sender, timestamp, receiptMessage);
635 }
636
637 @Override
638 public SendMessageResults sendViewedReceipt(
639 RecipientIdentifier.Single sender, List<Long> messageIds
640 ) {
641 final var timestamp = System.currentTimeMillis();
642 var receiptMessage = new SignalServiceReceiptMessage(SignalServiceReceiptMessage.Type.VIEWED,
643 messageIds,
644 timestamp);
645
646 return sendReceiptMessage(sender, timestamp, receiptMessage);
647 }
648
649 private SendMessageResults sendReceiptMessage(
650 final RecipientIdentifier.Single sender,
651 final long timestamp,
652 final SignalServiceReceiptMessage receiptMessage
653 ) {
654 try {
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()))));
661 }
662 }
663
664 @Override
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()) {
670 logger.warn(
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.");
672 }
673 final var messageBuilder = SignalServiceDataMessage.newBuilder();
674 applyMessage(messageBuilder, message);
675 return sendMessage(messageBuilder, recipients, notifySelf);
676 }
677
678 @Override
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));
685 }
686
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));
696 } else {
697 messageBuilder.withBody(message.messageText());
698 }
699 if (!message.attachments().isEmpty()) {
700 messageBuilder.withAttachments(context.getAttachmentHelper().uploadAttachments(message.attachments()));
701 }
702 if (!message.mentions().isEmpty()) {
703 messageBuilder.withMentions(resolveMentions(message.mentions()));
704 }
705 if (!message.textStyles().isEmpty()) {
706 messageBuilder.withBodyRanges(message.textStyles().stream().map(TextStyle::toBodyRange).toList());
707 }
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(),
713 a.filename(),
714 a.preview() == null ? null : context.getAttachmentHelper().uploadAttachment(a.preview()));
715 quotedAttachments.add(quotedAttachment);
716 }
717 messageBuilder.withQuote(new SignalServiceDataMessage.Quote(quote.timestamp(),
718 context.getRecipientHelper()
719 .resolveSignalServiceAddress(context.getRecipientHelper().resolveRecipient(quote.author()))
720 .getServiceId(),
721 quote.message(),
722 quotedAttachments,
723 resolveMentions(quote.mentions()),
724 SignalServiceDataMessage.Quote.Type.NORMAL,
725 quote.textStyles().stream().map(TextStyle::toBodyRange).toList()));
726 }
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();
731
732 final var stickerPack = context.getAccount().getStickerStore().getStickerPack(packId);
733 if (stickerPack == null) {
734 throw new InvalidStickerException("Sticker pack not found");
735 }
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");
739 }
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");
744 }
745 messageBuilder.withSticker(new SignalServiceDataMessage.Sticker(packId.serialize(),
746 stickerPack.packKey(),
747 stickerId,
748 manifestSticker.emoji(),
749 AttachmentUtils.createAttachmentStream(streamDetails, Optional.empty())));
750 }
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(),
757 p.title(),
758 p.description(),
759 0,
760 Optional.ofNullable(image)));
761 }
762 messageBuilder.withPreviews(previews);
763 }
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()))
768 .getServiceId();
769 messageBuilder.withStoryContext(new SignalServiceDataMessage.StoryContext(authorServiceId,
770 storyReply.timestamp()));
771 }
772 }
773
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()));
781 }
782 return mentions;
783 }
784
785 @Override
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) {
796 try {
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());
802 }
803 } catch (UnregisteredRecipientException ignored) {
804 }
805 } else if (recipient instanceof RecipientIdentifier.Group r) {
806 account.getMessageSendLogStore().deleteEntryForGroup(targetSentTimestamp, r.groupId());
807 }
808 }
809 return sendMessage(messageBuilder, recipients, false);
810 }
811
812 @Override
813 public SendMessageResults sendMessageReaction(
814 String emoji,
815 boolean remove,
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)
824 .getServiceId();
825 var reaction = new SignalServiceDataMessage.Reaction(emoji, remove, authorServiceId, targetSentTimestamp);
826 final var messageBuilder = SignalServiceDataMessage.newBuilder().withReaction(reaction);
827 if (isStory) {
828 messageBuilder.withStoryContext(new SignalServiceDataMessage.StoryContext(authorServiceId,
829 targetSentTimestamp));
830 }
831 return sendMessage(messageBuilder, recipients, false);
832 }
833
834 @Override
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);
841 try {
842 return sendMessage(messageBuilder, Set.of(recipient), false);
843 } catch (NotAGroupMemberException | GroupNotFoundException | GroupSendingNotAllowedException e) {
844 throw new AssertionError(e);
845 }
846 }
847
848 @Override
849 public SendMessageResults sendEndSessionMessage(Set<RecipientIdentifier.Single> recipients) throws IOException {
850 var messageBuilder = SignalServiceDataMessage.newBuilder().asEndSessionMessage();
851
852 try {
853 return sendMessage(messageBuilder,
854 recipients.stream().map(RecipientIdentifier.class::cast).collect(Collectors.toSet()),
855 false);
856 } catch (GroupNotFoundException | NotAGroupMemberException | GroupSendingNotAllowedException e) {
857 throw new AssertionError(e);
858 } finally {
859 for (var recipient : recipients) {
860 final RecipientId recipientId;
861 try {
862 recipientId = context.getRecipientHelper().resolveRecipient(recipient);
863 } catch (UnregisteredRecipientException e) {
864 continue;
865 }
866 final var serviceId = context.getAccount()
867 .getRecipientAddressResolver()
868 .resolveRecipientAddress(recipientId)
869 .serviceId();
870 if (serviceId.isPresent()) {
871 account.getAccountData(ServiceIdType.ACI).getSessionStore().deleteAllSessions(serviceId.get());
872 }
873 }
874 }
875 }
876
877 @Override
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());
883 syncRemoteStorage();
884 }
885 }
886
887 @Override
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());
892 syncRemoteStorage();
893 }
894 }
895
896 @Override
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());
901 syncRemoteStorage();
902 }
903 }
904
905 @Override
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();
911 }
912 context.getContactHelper()
913 .setContactName(context.getRecipientHelper().resolveRecipient(recipient), givenName, familyName);
914 syncRemoteStorage();
915 }
916
917 @Override
918 public void setContactsBlocked(
919 Collection<RecipientIdentifier.Single> recipients, boolean blocked
920 ) throws IOException, UnregisteredRecipientException {
921 if (recipients.isEmpty()) {
922 return;
923 }
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) {
929 continue;
930 }
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()
935 .getGroups()
936 .stream()
937 .noneMatch(g -> g.isMember(selfRecipientId) && g.isMember(recipientId))
938 );
939 }
940 if (shouldRotateProfileKey) {
941 context.getProfileHelper().rotateProfileKey();
942 }
943 context.getSyncHelper().sendBlockedList();
944 syncRemoteStorage();
945 }
946
947 @Override
948 public void setGroupsBlocked(
949 final Collection<GroupId> groupIds, final boolean blocked
950 ) throws GroupNotFoundException, IOException {
951 if (groupIds.isEmpty()) {
952 return;
953 }
954 boolean shouldRotateProfileKey = false;
955 for (final var groupId : groupIds) {
956 if (context.getGroupHelper().isGroupBlocked(groupId) == blocked) {
957 continue;
958 }
959 context.getGroupHelper().setGroupBlocked(groupId, blocked);
960 shouldRotateProfileKey = blocked;
961 }
962 if (shouldRotateProfileKey) {
963 context.getProfileHelper().rotateProfileKey();
964 }
965 context.getSyncHelper().sendBlockedList();
966 syncRemoteStorage();
967 }
968
969 @Override
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();
976 try {
977 sendMessage(messageBuilder, Set.of(recipient), false);
978 } catch (NotAGroupMemberException | GroupNotFoundException | GroupSendingNotAllowedException e) {
979 throw new AssertionError(e);
980 }
981 syncRemoteStorage();
982 }
983
984 @Override
985 public StickerPackUrl uploadStickerPack(File path) throws IOException, StickerPackInvalidException {
986 var manifest = StickerUtils.getSignalServiceStickerManifestUpload(path);
987
988 var messageSender = dependencies.getMessageSender();
989
990 var packKey = KeyUtils.createStickerUploadKey();
991 var packIdString = messageSender.uploadStickerManifest(manifest, packKey);
992 var packId = StickerPackId.deserialize(Hex.fromStringCondensed(packIdString));
993
994 var sticker = new StickerPack(packId, packKey);
995 account.getStickerStore().addStickerPack(sticker);
996 context.getSyncHelper().sendStickerOperationsMessage(List.of(sticker), List.of());
997
998 return new StickerPackUrl(packId, packKey);
999 }
1000
1001 @Override
1002 public void installStickerPack(StickerPackUrl url) throws IOException {
1003 final var packId = url.packId();
1004 final var packKey = url.packKey();
1005 try {
1006 context.getStickerHelper().retrieveStickerPack(packId, packKey);
1007 } catch (InvalidMessageException e) {
1008 throw new IOException(e);
1009 }
1010
1011 final var sticker = context.getStickerHelper().addOrUpdateStickerPack(packId, packKey, true);
1012 context.getSyncHelper().sendStickerOperationsMessage(List.of(sticker), List.of());
1013 }
1014
1015 @Override
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())) {
1020 try {
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()),
1024 pack.isInstalled(),
1025 manifest.title(),
1026 manifest.author(),
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);
1031 }
1032 }
1033
1034 return new org.asamk.signal.manager.api.StickerPack(pack.packId(), pack.packKey(), pack.isInstalled());
1035 }).toList();
1036 }
1037
1038 @Override
1039 public void requestAllSyncData() {
1040 context.getSyncHelper().requestAllSyncData();
1041 syncRemoteStorage();
1042 }
1043
1044 void syncRemoteStorage() {
1045 context.getJobExecutor().enqueueJob(new SyncStorageJob());
1046 }
1047
1048 @Override
1049 public void addReceiveHandler(final ReceiveMessageHandler handler, final boolean isWeakListener) {
1050 synchronized (messageHandlers) {
1051 if (isWeakListener) {
1052 weakHandlers.add(handler);
1053 } else {
1054 messageHandlers.add(handler);
1055 startReceiveThreadIfRequired();
1056 }
1057 }
1058 }
1059
1060 private static final AtomicInteger threadNumber = new AtomicInteger(0);
1061
1062 private void startReceiveThreadIfRequired() {
1063 if (receiveThread != null || isReceivingSynchronous) {
1064 return;
1065 }
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;
1072
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();
1077 }
1078 }
1079 });
1080 }
1081
1082 private void passReceivedMessageToHandlers(MessageEnvelope envelope, Throwable e) {
1083 synchronized (messageHandlers) {
1084 Stream.concat(messageHandlers.stream(), weakHandlers.stream()).forEach(h -> {
1085 try {
1086 h.handleMessage(envelope, e);
1087 } catch (Throwable ex) {
1088 logger.warn("Message handler failed, ignoring", ex);
1089 }
1090 });
1091 }
1092 }
1093
1094 @Override
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) {
1101 return;
1102 }
1103 thread = receiveThread;
1104 receiveThread = null;
1105 }
1106
1107 stopReceiveThread(thread);
1108 }
1109
1110 private void stopReceiveThread(final Thread thread) {
1111 if (context.getReceiveHelper().requestStopReceiveMessages()) {
1112 logger.debug("Receive stop requested, interrupting read from server.");
1113 thread.interrupt();
1114 }
1115 try {
1116 thread.join();
1117 } catch (InterruptedException ignored) {
1118 }
1119 }
1120
1121 @Override
1122 public boolean isReceiving() {
1123 if (isReceivingSynchronous) {
1124 return true;
1125 }
1126 synchronized (messageHandlers) {
1127 return !messageHandlers.isEmpty();
1128 }
1129 }
1130
1131 @Override
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);
1136 }
1137
1138 @Override
1139 public void stopReceiveMessages() {
1140 Thread thread = null;
1141 synchronized (messageHandlers) {
1142 if (isReceivingSynchronous) {
1143 thread = receiveThread;
1144 receiveThread = null;
1145 }
1146 }
1147 if (thread != null) {
1148 stopReceiveThread(thread);
1149 }
1150 }
1151
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.");
1158 }
1159 isReceivingSynchronous = true;
1160 receiveThread = Thread.currentThread();
1161 }
1162 try {
1163 context.getReceiveHelper().receiveMessages(timeout, returnOnTimeout, maxMessages, (envelope, e) -> {
1164 passReceivedMessageToHandlers(envelope, e);
1165 handler.handleMessage(envelope, e);
1166 });
1167 } finally {
1168 synchronized (messageHandlers) {
1169 receiveThread = null;
1170 isReceivingSynchronous = false;
1171 if (!messageHandlers.isEmpty()) {
1172 startReceiveThreadIfRequired();
1173 }
1174 }
1175 }
1176 }
1177
1178 @Override
1179 public void setReceiveConfig(final ReceiveConfig receiveConfig) {
1180 context.getReceiveHelper().setReceiveConfig(receiveConfig);
1181 }
1182
1183 @Override
1184 public boolean isContactBlocked(final RecipientIdentifier.Single recipient) {
1185 final RecipientId recipientId;
1186 try {
1187 recipientId = context.getRecipientHelper().resolveRecipient(recipient);
1188 } catch (UnregisteredRecipientException e) {
1189 return false;
1190 }
1191 return context.getContactHelper().isContactBlocked(recipientId);
1192 }
1193
1194 @Override
1195 public void sendContacts() throws IOException {
1196 context.getSyncHelper().sendContacts();
1197 }
1198
1199 @Override
1200 public List<Recipient> getRecipients(
1201 boolean onlyContacts,
1202 Optional<Boolean> blocked,
1203 Collection<RecipientIdentifier.Single> recipients,
1204 Optional<String> name
1205 ) {
1206 final var recipientIds = recipients.stream().map(a -> {
1207 try {
1208 return context.getRecipientHelper().resolveRecipient(a);
1209 } catch (UnregisteredRecipientException e) {
1210 return null;
1211 }
1212 }).filter(Objects::nonNull).collect(Collectors.toSet());
1213 if (!recipients.isEmpty() && recipientIds.isEmpty()) {
1214 return List.of();
1215 }
1216 // refresh profiles of explicitly given recipients
1217 context.getProfileHelper().refreshRecipientProfiles(recipientIds);
1218 return account.getRecipientStore()
1219 .getRecipients(onlyContacts, blocked, recipientIds, name)
1220 .stream()
1221 .map(s -> new Recipient(s.getRecipientId(),
1222 s.getAddress().toApiRecipientAddress(),
1223 s.getContact(),
1224 s.getProfileKey(),
1225 s.getExpiringProfileKeyCredential(),
1226 s.getProfile()))
1227 .toList();
1228 }
1229
1230 @Override
1231 public String getContactOrProfileName(RecipientIdentifier.Single recipient) {
1232 final RecipientId recipientId;
1233 try {
1234 recipientId = context.getRecipientHelper().resolveRecipient(recipient);
1235 } catch (UnregisteredRecipientException e) {
1236 return null;
1237 }
1238
1239 final var contact = account.getContactStore().getContact(recipientId);
1240 if (contact != null && !Util.isEmpty(contact.getName())) {
1241 return contact.getName();
1242 }
1243
1244 final var profile = context.getProfileHelper().getRecipientProfile(recipientId);
1245 if (profile != null) {
1246 return profile.getDisplayName();
1247 }
1248
1249 return null;
1250 }
1251
1252 @Override
1253 public Group getGroup(GroupId groupId) {
1254 return toGroup(context.getGroupHelper().getGroup(groupId));
1255 }
1256
1257 @Override
1258 public List<Identity> getIdentities() {
1259 return account.getIdentityKeyStore()
1260 .getIdentities()
1261 .stream()
1262 .map(this::toIdentity)
1263 .filter(Objects::nonNull)
1264 .toList();
1265 }
1266
1267 private Identity toIdentity(final IdentityInfo identityInfo) {
1268 if (identityInfo == null) {
1269 return null;
1270 }
1271
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())) {
1276 return null;
1277 }
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());
1287 }
1288
1289 @Override
1290 public List<Identity> getIdentities(RecipientIdentifier.Single recipient) {
1291 ServiceId serviceId;
1292 try {
1293 final var address = account.getRecipientAddressResolver()
1294 .resolveRecipientAddress(context.getRecipientHelper().resolveRecipient(recipient));
1295 if (address.serviceId().isEmpty()) {
1296 return List.of();
1297 }
1298 serviceId = address.serviceId().get();
1299 } catch (UnregisteredRecipientException e) {
1300 return List.of();
1301 }
1302 final var identity = account.getIdentityKeyStore().getIdentityInfo(serviceId);
1303 return identity == null ? List.of() : List.of(toIdentity(identity));
1304 }
1305
1306 @Override
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");
1318 };
1319 }
1320
1321 @Override
1322 public boolean trustIdentityAllKeys(RecipientIdentifier.Single recipient) throws UnregisteredRecipientException {
1323 return trustIdentity(recipient, r -> context.getIdentityHelper().trustIdentityAllKeys(r));
1324 }
1325
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);
1333 }
1334 return updated;
1335 }
1336
1337 @Override
1338 public void addAddressChangedListener(final Runnable listener) {
1339 synchronized (addressChangedListeners) {
1340 addressChangedListeners.add(listener);
1341 }
1342 }
1343
1344 @Override
1345 public void addClosedListener(final Runnable listener) {
1346 synchronized (closedListeners) {
1347 closedListeners.add(listener);
1348 }
1349 }
1350
1351 @Override
1352 public InputStream retrieveAttachment(final String id) throws IOException {
1353 return context.getAttachmentHelper().retrieveAttachment(id).getStream();
1354 }
1355
1356 @Override
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();
1363 }
1364 return streamDetails.getStream();
1365 }
1366
1367 @Override
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();
1375 }
1376 return streamDetails.getStream();
1377 }
1378
1379 @Override
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();
1385 }
1386 return streamDetails.getStream();
1387 }
1388
1389 @Override
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);
1394 if (pack != null) {
1395 try {
1396 context.getStickerHelper().retrieveStickerPack(stickerPackId, pack.packKey());
1397 } catch (InvalidMessageException e) {
1398 logger.warn("Failed to download sticker pack");
1399 }
1400 }
1401 }
1402 if (streamDetails == null) {
1403 throw new FileNotFoundException();
1404 }
1405 return streamDetails.getStream();
1406 }
1407
1408 @Override
1409 public void close() {
1410 Thread thread;
1411 synchronized (messageHandlers) {
1412 weakHandlers.clear();
1413 messageHandlers.clear();
1414 thread = receiveThread;
1415 receiveThread = null;
1416 }
1417 if (thread != null) {
1418 stopReceiveThread(thread);
1419 }
1420 context.close();
1421 executor.close();
1422
1423 dependencies.getSignalWebSocket().disconnect();
1424 dependencies.getPushServiceSocket().close();
1425 disposable.dispose();
1426
1427 if (account != null) {
1428 account.close();
1429 }
1430
1431 synchronized (closedListeners) {
1432 closedListeners.forEach(Runnable::run);
1433 closedListeners.clear();
1434 }
1435
1436 account = null;
1437 }
1438 }