]> nmode's Git Repositories - signal-cli/blob - lib/src/main/java/org/asamk/signal/manager/internal/ManagerImpl.java
Add command to retrieve avatars and stickers
[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.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;
104
105 import java.io.ByteArrayInputStream;
106 import java.io.File;
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;
129
130 import io.reactivex.rxjava3.disposables.CompositeDisposable;
131 import io.reactivex.rxjava3.schedulers.Schedulers;
132
133 public class ManagerImpl implements Manager {
134
135 private static final Logger logger = LoggerFactory.getLogger(ManagerImpl.class);
136
137 private SignalAccount account;
138 private final SignalDependencies dependencies;
139 private final Context context;
140
141 private final ExecutorService executor = Executors.newCachedThreadPool();
142
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();
150
151 public ManagerImpl(
152 SignalAccount account,
153 PathConfig pathConfig,
154 AccountFileUpdater accountFileUpdater,
155 ServiceEnvironmentConfig serviceEnvironmentConfig,
156 String userAgent
157 ) {
158 this.account = account;
159
160 final var sessionLock = new SignalSessionLock() {
161 private final ReentrantLock LEGACY_LOCK = new ReentrantLock();
162
163 @Override
164 public Lock acquire() {
165 LEGACY_LOCK.lock();
166 return LEGACY_LOCK::unlock;
167 }
168 };
169 this.dependencies = new SignalDependencies(serviceEnvironmentConfig,
170 userAgent,
171 account.getCredentialsProvider(),
172 account.getSignalServiceDataStore(),
173 executor,
174 sessionLock);
175 final var avatarStore = new AvatarStore(pathConfig.avatarsPath());
176 final var attachmentStore = new AttachmentStore(pathConfig.attachmentsPath());
177 final var stickerPackStore = new StickerPackStore(pathConfig.stickerPacksPath());
178
179 this.context = new Context(account, new AccountFileUpdater() {
180 @Override
181 public void updateAccountIdentifiers(final String number, final ACI aci) {
182 accountFileUpdater.updateAccountIdentifiers(number, aci);
183 synchronized (addressChangedListeners) {
184 addressChangedListeners.forEach(Runnable::run);
185 }
186 }
187
188 @Override
189 public void removeAccount() {
190 accountFileUpdater.removeAccount();
191 }
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) {
197 this.notifyAll();
198 }
199 });
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)
216 .build());
217 }
218 }));
219 }
220
221 @Override
222 public String getSelfNumber() {
223 return account.getNumber();
224 }
225
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();
233 }
234 }
235
236 @Override
237 public Map<String, UserStatus> getUserStatus(Set<String> numbers) throws IOException, RateLimitException {
238 final var canonicalizedNumbers = numbers.stream().collect(Collectors.toMap(n -> n, n -> {
239 try {
240 final var canonicalizedNumber = PhoneNumberFormatter.formatNumber(n, account.getNumber());
241 if (!canonicalizedNumber.equals(n)) {
242 logger.debug("Normalized number {} to {}.", n, canonicalizedNumber);
243 }
244 return canonicalizedNumber;
245 } catch (InvalidNumberException e) {
246 return "";
247 }
248 }));
249
250 // Note "registeredUsers" has no optionals. It only gives us info on users who are registered
251 final var canonicalizedNumbersSet = canonicalizedNumbers.values()
252 .stream()
253 .filter(s -> !s.isEmpty())
254 .collect(Collectors.toSet());
255
256 final Map<String, RegisteredUser> registeredUsers;
257 try {
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);
262 }
263
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
269 ? null
270 : context.getProfileHelper()
271 .getRecipientProfile(account.getRecipientResolver().resolveRecipient(serviceId));
272 return new UserStatus(number.isEmpty() ? null : number,
273 serviceId == null ? null : serviceId.getRawUuid(),
274 profile != null
275 && profile.getUnidentifiedAccessMode() == Profile.UnidentifiedAccessMode.UNRESTRICTED);
276 }));
277 }
278
279 @Override
280 public void updateAccountAttributes(String deviceName, Boolean unrestrictedUnidentifiedSender) throws IOException {
281 if (deviceName != null) {
282 context.getAccountHelper().setDeviceName(deviceName);
283 }
284 if (unrestrictedUnidentifiedSender != null) {
285 account.setUnrestrictedUnidentifiedAccess(unrestrictedUnidentifiedSender);
286 }
287 context.getAccountHelper().updateAccountAttributes();
288 context.getAccountHelper().checkWhoAmiI();
289 }
290
291 @Override
292 public Configuration getConfiguration() {
293 final var configurationStore = account.getConfigurationStore();
294 return Configuration.from(configurationStore);
295 }
296
297 @Override
298 public void updateConfiguration(Configuration configuration) {
299 final var configurationStore = account.getConfigurationStore();
300 if (configuration.readReceipts().isPresent()) {
301 configurationStore.setReadReceipts(configuration.readReceipts().get());
302 }
303 if (configuration.unidentifiedDeliveryIndicators().isPresent()) {
304 configurationStore.setUnidentifiedDeliveryIndicators(configuration.unidentifiedDeliveryIndicators().get());
305 }
306 if (configuration.typingIndicators().isPresent()) {
307 configurationStore.setTypingIndicators(configuration.typingIndicators().get());
308 }
309 if (configuration.linkPreviews().isPresent()) {
310 configurationStore.setLinkPreviews(configuration.linkPreviews().get());
311 }
312 context.getSyncHelper().sendConfigurationMessage();
313 syncRemoteStorage();
314 }
315
316 @Override
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()
324 ? Optional.empty()
325 : updateProfile.getAvatar() == null ? null : Optional.of(updateProfile.getAvatar()),
326 updateProfile.getMobileCoinAddress());
327 context.getSyncHelper().sendSyncFetchProfileMessage();
328 }
329
330 void refreshCurrentUsername() throws IOException, BaseUsernameException {
331 context.getAccountHelper().refreshCurrentUsername();
332 }
333
334 @Override
335 public String getUsername() {
336 return account.getUsername();
337 }
338
339 @Override
340 public UsernameLinkUrl getUsernameLink() {
341 return new UsernameLinkUrl(account.getUsernameLink());
342 }
343
344 @Override
345 public void setUsername(final String username) throws IOException, InvalidUsernameException {
346 try {
347 context.getAccountHelper().reserveUsername(username);
348 } catch (BaseUsernameException e) {
349 throw new InvalidUsernameException(e.getMessage() + " (" + e.getClass().getSimpleName() + ")", e);
350 }
351 }
352
353 @Override
354 public void deleteUsername() throws IOException {
355 context.getAccountHelper().deleteUsername();
356 }
357
358 @Override
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();
364 }
365 context.getAccountHelper().startChangeNumber(newNumber, voiceVerification, captcha);
366 }
367
368 @Override
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();
374 }
375 context.getAccountHelper().finishChangeNumber(newNumber, verificationCode, pin);
376 }
377
378 @Override
379 public void unregister() throws IOException {
380 context.getAccountHelper().unregister();
381 }
382
383 @Override
384 public void deleteAccount() throws IOException {
385 context.getAccountHelper().deleteAccount();
386 }
387
388 @Override
389 public void submitRateLimitRecaptchaChallenge(String challenge, String captcha) throws IOException {
390 captcha = captcha == null ? null : captcha.replace("signalcaptcha://", "");
391
392 dependencies.getAccountManager().submitRateLimitRecaptchaChallenge(challenge, captcha);
393 }
394
395 @Override
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) {
403 try {
404 deviceName = DeviceNameUtil.decryptDeviceName(deviceName, identityKey);
405 } catch (IOException e) {
406 logger.debug("Failed to decrypt device name, maybe plain text?", e);
407 }
408 }
409 return new Device(d.getId(),
410 deviceName,
411 d.getCreated(),
412 d.getLastSeen(),
413 d.getId() == account.getDeviceId());
414 }).toList();
415 }
416
417 @Override
418 public void removeLinkedDevices(int deviceId) throws IOException {
419 context.getAccountHelper().removeLinkedDevices(deviceId);
420 }
421
422 @Override
423 public void addDeviceLink(DeviceLinkUrl linkUrl) throws IOException, InvalidDeviceLinkException, NotPrimaryDeviceException {
424 if (!account.isPrimaryDevice()) {
425 throw new NotPrimaryDeviceException();
426 }
427 context.getAccountHelper().addDevice(linkUrl);
428 }
429
430 @Override
431 public void setRegistrationLockPin(Optional<String> pin) throws IOException, NotPrimaryDeviceException {
432 if (!account.isPrimaryDevice()) {
433 throw new NotPrimaryDeviceException();
434 }
435 if (pin.isPresent()) {
436 context.getAccountHelper().setRegistrationPin(pin.get());
437 } else {
438 context.getAccountHelper().removeRegistrationPin();
439 }
440 }
441
442 void refreshPreKeys() throws IOException {
443 context.getPreKeyHelper().refreshPreKeysIfNecessary();
444 }
445
446 @Override
447 public List<Group> getGroups() {
448 return account.getGroupStore().getGroups().stream().map(this::toGroup).toList();
449 }
450
451 private Group toGroup(final GroupInfo groupInfo) {
452 if (groupInfo == null) {
453 return null;
454 }
455
456 return Group.from(groupInfo, account.getRecipientAddressResolver(), account.getSelfRecipientId());
457 }
458
459 @Override
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);
465 }
466
467 @Override
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");
473 }
474 context.getGroupHelper().deleteGroup(groupId);
475 }
476
477 @Override
478 public Pair<GroupId, SendGroupMessageResults> createGroup(
479 String name, Set<RecipientIdentifier.Single> members, String avatarFile
480 ) throws IOException, AttachmentInvalidException, UnregisteredRecipientException {
481 return context.getGroupHelper()
482 .createGroup(name,
483 members == null ? null : context.getRecipientHelper().resolveRecipients(members),
484 avatarFile);
485 }
486
487 @Override
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
496 ? null
497 : context.getRecipientHelper().resolveRecipients(updateGroup.getMembers()),
498 updateGroup.getRemoveMembers() == null
499 ? null
500 : context.getRecipientHelper().resolveRecipients(updateGroup.getRemoveMembers()),
501 updateGroup.getAdmins() == null
502 ? null
503 : context.getRecipientHelper().resolveRecipients(updateGroup.getAdmins()),
504 updateGroup.getRemoveAdmins() == null
505 ? null
506 : context.getRecipientHelper().resolveRecipients(updateGroup.getRemoveAdmins()),
507 updateGroup.getBanMembers() == null
508 ? null
509 : context.getRecipientHelper().resolveRecipients(updateGroup.getBanMembers()),
510 updateGroup.getUnbanMembers() == null
511 ? 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());
520 }
521
522 @Override
523 public Pair<GroupId, SendGroupMessageResults> joinGroup(
524 GroupInviteLinkUrl inviteLinkUrl
525 ) throws IOException, InactiveGroupLinkException, PendingAdminApprovalException {
526 return context.getGroupHelper().joinGroup(inviteLinkUrl);
527 }
528
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());
533 }
534
535 private SendMessageResults sendMessage(
536 SignalServiceDataMessage.Builder messageBuilder,
537 Set<RecipientIdentifier> recipients,
538 boolean notifySelf,
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())
548 )) {
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) {
555 try {
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())));
563 }
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());
568 }
569 }
570 return new SendMessageResults(timestamp, results);
571 }
572
573 private SendMessageResult toSendMessageResult(final org.whispersystems.signalservice.api.messages.SendMessageResult result) {
574 return SendMessageResult.from(result, account.getRecipientResolver(), account.getRecipientAddressResolver());
575 }
576
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());
585 try {
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())));
592 }
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());
598 }
599 }
600 return new SendMessageResults(timestamp, results);
601 }
602
603 @Override
604 public SendMessageResults sendTypingMessage(
605 TypingAction action, Set<RecipientIdentifier> recipients
606 ) throws IOException, NotAGroupMemberException, GroupNotFoundException, GroupSendingNotAllowedException {
607 return sendTypingMessage(action.toSignalService(), recipients);
608 }
609
610 @Override
611 public SendMessageResults sendReadReceipt(
612 RecipientIdentifier.Single sender, List<Long> messageIds
613 ) {
614 final var timestamp = System.currentTimeMillis();
615 var receiptMessage = new SignalServiceReceiptMessage(SignalServiceReceiptMessage.Type.READ,
616 messageIds,
617 timestamp);
618
619 return sendReceiptMessage(sender, timestamp, receiptMessage);
620 }
621
622 @Override
623 public SendMessageResults sendViewedReceipt(
624 RecipientIdentifier.Single sender, List<Long> messageIds
625 ) {
626 final var timestamp = System.currentTimeMillis();
627 var receiptMessage = new SignalServiceReceiptMessage(SignalServiceReceiptMessage.Type.VIEWED,
628 messageIds,
629 timestamp);
630
631 return sendReceiptMessage(sender, timestamp, receiptMessage);
632 }
633
634 private SendMessageResults sendReceiptMessage(
635 final RecipientIdentifier.Single sender,
636 final long timestamp,
637 final SignalServiceReceiptMessage receiptMessage
638 ) {
639 try {
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()))));
646 }
647 }
648
649 @Override
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()) {
655 logger.warn(
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.");
657 }
658 final var messageBuilder = SignalServiceDataMessage.newBuilder();
659 applyMessage(messageBuilder, message);
660 return sendMessage(messageBuilder, recipients, notifySelf);
661 }
662
663 @Override
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));
670 }
671
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));
681 } else {
682 messageBuilder.withBody(message.messageText());
683 }
684 if (!message.attachments().isEmpty()) {
685 messageBuilder.withAttachments(context.getAttachmentHelper().uploadAttachments(message.attachments()));
686 }
687 if (!message.mentions().isEmpty()) {
688 messageBuilder.withMentions(resolveMentions(message.mentions()));
689 }
690 if (!message.textStyles().isEmpty()) {
691 messageBuilder.withBodyRanges(message.textStyles().stream().map(TextStyle::toBodyRange).toList());
692 }
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(),
698 a.filename(),
699 a.preview() == null ? null : context.getAttachmentHelper().uploadAttachment(a.preview()));
700 quotedAttachments.add(quotedAttachment);
701 }
702 messageBuilder.withQuote(new SignalServiceDataMessage.Quote(quote.timestamp(),
703 context.getRecipientHelper()
704 .resolveSignalServiceAddress(context.getRecipientHelper().resolveRecipient(quote.author()))
705 .getServiceId(),
706 quote.message(),
707 quotedAttachments,
708 resolveMentions(quote.mentions()),
709 SignalServiceDataMessage.Quote.Type.NORMAL,
710 quote.textStyles().stream().map(TextStyle::toBodyRange).toList()));
711 }
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();
716
717 final var stickerPack = context.getAccount().getStickerStore().getStickerPack(packId);
718 if (stickerPack == null) {
719 throw new InvalidStickerException("Sticker pack not found");
720 }
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");
724 }
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");
729 }
730 messageBuilder.withSticker(new SignalServiceDataMessage.Sticker(packId.serialize(),
731 stickerPack.packKey(),
732 stickerId,
733 manifestSticker.emoji(),
734 AttachmentUtils.createAttachmentStream(streamDetails, Optional.empty())));
735 }
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(),
742 p.title(),
743 p.description(),
744 0,
745 Optional.ofNullable(image)));
746 }
747 messageBuilder.withPreviews(previews);
748 }
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()))
753 .getServiceId();
754 messageBuilder.withStoryContext(new SignalServiceDataMessage.StoryContext(authorServiceId,
755 storyReply.timestamp()));
756 }
757 }
758
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()));
766 }
767 return mentions;
768 }
769
770 @Override
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) {
781 try {
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());
787 }
788 } catch (UnregisteredRecipientException ignored) {
789 }
790 } else if (recipient instanceof RecipientIdentifier.Group r) {
791 account.getMessageSendLogStore().deleteEntryForGroup(targetSentTimestamp, r.groupId());
792 }
793 }
794 return sendMessage(messageBuilder, recipients, false);
795 }
796
797 @Override
798 public SendMessageResults sendMessageReaction(
799 String emoji,
800 boolean remove,
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)
809 .getServiceId();
810 var reaction = new SignalServiceDataMessage.Reaction(emoji, remove, authorServiceId, targetSentTimestamp);
811 final var messageBuilder = SignalServiceDataMessage.newBuilder().withReaction(reaction);
812 if (isStory) {
813 messageBuilder.withStoryContext(new SignalServiceDataMessage.StoryContext(authorServiceId,
814 targetSentTimestamp));
815 }
816 return sendMessage(messageBuilder, recipients, false);
817 }
818
819 @Override
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);
826 try {
827 return sendMessage(messageBuilder, Set.of(recipient), false);
828 } catch (NotAGroupMemberException | GroupNotFoundException | GroupSendingNotAllowedException e) {
829 throw new AssertionError(e);
830 }
831 }
832
833 @Override
834 public SendMessageResults sendEndSessionMessage(Set<RecipientIdentifier.Single> recipients) throws IOException {
835 var messageBuilder = SignalServiceDataMessage.newBuilder().asEndSessionMessage();
836
837 try {
838 return sendMessage(messageBuilder,
839 recipients.stream().map(RecipientIdentifier.class::cast).collect(Collectors.toSet()),
840 false);
841 } catch (GroupNotFoundException | NotAGroupMemberException | GroupSendingNotAllowedException e) {
842 throw new AssertionError(e);
843 } finally {
844 for (var recipient : recipients) {
845 final RecipientId recipientId;
846 try {
847 recipientId = context.getRecipientHelper().resolveRecipient(recipient);
848 } catch (UnregisteredRecipientException e) {
849 continue;
850 }
851 final var serviceId = context.getAccount()
852 .getRecipientAddressResolver()
853 .resolveRecipientAddress(recipientId)
854 .serviceId();
855 if (serviceId.isPresent()) {
856 account.getAccountData(ServiceIdType.ACI).getSessionStore().deleteAllSessions(serviceId.get());
857 }
858 }
859 }
860 }
861
862 @Override
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());
868 syncRemoteStorage();
869 }
870 }
871
872 @Override
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());
877 syncRemoteStorage();
878 }
879 }
880
881 @Override
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());
886 syncRemoteStorage();
887 }
888 }
889
890 @Override
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();
896 }
897 context.getContactHelper()
898 .setContactName(context.getRecipientHelper().resolveRecipient(recipient), givenName, familyName);
899 syncRemoteStorage();
900 }
901
902 @Override
903 public void setContactsBlocked(
904 Collection<RecipientIdentifier.Single> recipients, boolean blocked
905 ) throws IOException, UnregisteredRecipientException {
906 if (recipients.isEmpty()) {
907 return;
908 }
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) {
914 continue;
915 }
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()
920 .getGroups()
921 .stream()
922 .noneMatch(g -> g.isMember(selfRecipientId) && g.isMember(recipientId))
923 );
924 }
925 if (shouldRotateProfileKey) {
926 context.getProfileHelper().rotateProfileKey();
927 }
928 context.getSyncHelper().sendBlockedList();
929 syncRemoteStorage();
930 }
931
932 @Override
933 public void setGroupsBlocked(
934 final Collection<GroupId> groupIds, final boolean blocked
935 ) throws GroupNotFoundException, IOException {
936 if (groupIds.isEmpty()) {
937 return;
938 }
939 boolean shouldRotateProfileKey = false;
940 for (final var groupId : groupIds) {
941 if (context.getGroupHelper().isGroupBlocked(groupId) == blocked) {
942 continue;
943 }
944 context.getGroupHelper().setGroupBlocked(groupId, blocked);
945 shouldRotateProfileKey = blocked;
946 }
947 if (shouldRotateProfileKey) {
948 context.getProfileHelper().rotateProfileKey();
949 }
950 context.getSyncHelper().sendBlockedList();
951 syncRemoteStorage();
952 }
953
954 @Override
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();
961 try {
962 sendMessage(messageBuilder, Set.of(recipient), false);
963 } catch (NotAGroupMemberException | GroupNotFoundException | GroupSendingNotAllowedException e) {
964 throw new AssertionError(e);
965 }
966 syncRemoteStorage();
967 }
968
969 @Override
970 public StickerPackUrl uploadStickerPack(File path) throws IOException, StickerPackInvalidException {
971 var manifest = StickerUtils.getSignalServiceStickerManifestUpload(path);
972
973 var messageSender = dependencies.getMessageSender();
974
975 var packKey = KeyUtils.createStickerUploadKey();
976 var packIdString = messageSender.uploadStickerManifest(manifest, packKey);
977 var packId = StickerPackId.deserialize(Hex.fromStringCondensed(packIdString));
978
979 var sticker = new StickerPack(packId, packKey);
980 account.getStickerStore().addStickerPack(sticker);
981 context.getSyncHelper().sendStickerOperationsMessage(List.of(sticker), List.of());
982
983 return new StickerPackUrl(packId, packKey);
984 }
985
986 @Override
987 public void installStickerPack(StickerPackUrl url) throws IOException {
988 final var packId = url.packId();
989 final var packKey = url.packKey();
990 try {
991 context.getStickerHelper().retrieveStickerPack(packId, packKey);
992 } catch (InvalidMessageException e) {
993 throw new IOException(e);
994 }
995
996 final var sticker = context.getStickerHelper().addOrUpdateStickerPack(packId, packKey, true);
997 context.getSyncHelper().sendStickerOperationsMessage(List.of(sticker), List.of());
998 }
999
1000 @Override
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())) {
1005 try {
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()),
1009 pack.isInstalled(),
1010 manifest.title(),
1011 manifest.author(),
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);
1016 }
1017 }
1018
1019 return new org.asamk.signal.manager.api.StickerPack(pack.packId(), pack.packKey(), pack.isInstalled());
1020 }).toList();
1021 }
1022
1023 @Override
1024 public void requestAllSyncData() {
1025 context.getSyncHelper().requestAllSyncData();
1026 syncRemoteStorage();
1027 }
1028
1029 void syncRemoteStorage() {
1030 context.getJobExecutor().enqueueJob(new SyncStorageJob());
1031 }
1032
1033 @Override
1034 public void addReceiveHandler(final ReceiveMessageHandler handler, final boolean isWeakListener) {
1035 synchronized (messageHandlers) {
1036 if (isWeakListener) {
1037 weakHandlers.add(handler);
1038 } else {
1039 messageHandlers.add(handler);
1040 startReceiveThreadIfRequired();
1041 }
1042 }
1043 }
1044
1045 private static final AtomicInteger threadNumber = new AtomicInteger(0);
1046
1047 private void startReceiveThreadIfRequired() {
1048 if (receiveThread != null || isReceivingSynchronous) {
1049 return;
1050 }
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;
1057
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();
1062 }
1063 }
1064 });
1065 }
1066
1067 private void passReceivedMessageToHandlers(MessageEnvelope envelope, Throwable e) {
1068 synchronized (messageHandlers) {
1069 Stream.concat(messageHandlers.stream(), weakHandlers.stream()).forEach(h -> {
1070 try {
1071 h.handleMessage(envelope, e);
1072 } catch (Throwable ex) {
1073 logger.warn("Message handler failed, ignoring", ex);
1074 }
1075 });
1076 }
1077 }
1078
1079 @Override
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) {
1086 return;
1087 }
1088 thread = receiveThread;
1089 receiveThread = null;
1090 }
1091
1092 stopReceiveThread(thread);
1093 }
1094
1095 private void stopReceiveThread(final Thread thread) {
1096 if (context.getReceiveHelper().requestStopReceiveMessages()) {
1097 logger.debug("Receive stop requested, interrupting read from server.");
1098 thread.interrupt();
1099 }
1100 try {
1101 thread.join();
1102 } catch (InterruptedException ignored) {
1103 }
1104 }
1105
1106 @Override
1107 public boolean isReceiving() {
1108 if (isReceivingSynchronous) {
1109 return true;
1110 }
1111 synchronized (messageHandlers) {
1112 return !messageHandlers.isEmpty();
1113 }
1114 }
1115
1116 @Override
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);
1121 }
1122
1123 @Override
1124 public void stopReceiveMessages() {
1125 Thread thread = null;
1126 synchronized (messageHandlers) {
1127 if (isReceivingSynchronous) {
1128 thread = receiveThread;
1129 receiveThread = null;
1130 }
1131 }
1132 if (thread != null) {
1133 stopReceiveThread(thread);
1134 }
1135 }
1136
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.");
1143 }
1144 isReceivingSynchronous = true;
1145 receiveThread = Thread.currentThread();
1146 }
1147 try {
1148 context.getReceiveHelper().receiveMessages(timeout, returnOnTimeout, maxMessages, (envelope, e) -> {
1149 passReceivedMessageToHandlers(envelope, e);
1150 handler.handleMessage(envelope, e);
1151 });
1152 } finally {
1153 synchronized (messageHandlers) {
1154 receiveThread = null;
1155 isReceivingSynchronous = false;
1156 if (!messageHandlers.isEmpty()) {
1157 startReceiveThreadIfRequired();
1158 }
1159 }
1160 }
1161 }
1162
1163 @Override
1164 public void setReceiveConfig(final ReceiveConfig receiveConfig) {
1165 context.getReceiveHelper().setReceiveConfig(receiveConfig);
1166 }
1167
1168 @Override
1169 public boolean isContactBlocked(final RecipientIdentifier.Single recipient) {
1170 final RecipientId recipientId;
1171 try {
1172 recipientId = context.getRecipientHelper().resolveRecipient(recipient);
1173 } catch (UnregisteredRecipientException e) {
1174 return false;
1175 }
1176 return context.getContactHelper().isContactBlocked(recipientId);
1177 }
1178
1179 @Override
1180 public void sendContacts() throws IOException {
1181 context.getSyncHelper().sendContacts();
1182 }
1183
1184 @Override
1185 public List<Recipient> getRecipients(
1186 boolean onlyContacts,
1187 Optional<Boolean> blocked,
1188 Collection<RecipientIdentifier.Single> recipients,
1189 Optional<String> name
1190 ) {
1191 final var recipientIds = recipients.stream().map(a -> {
1192 try {
1193 return context.getRecipientHelper().resolveRecipient(a);
1194 } catch (UnregisteredRecipientException e) {
1195 return null;
1196 }
1197 }).filter(Objects::nonNull).collect(Collectors.toSet());
1198 if (!recipients.isEmpty() && recipientIds.isEmpty()) {
1199 return List.of();
1200 }
1201 // refresh profiles of explicitly given recipients
1202 context.getProfileHelper().refreshRecipientProfiles(recipientIds);
1203 return account.getRecipientStore()
1204 .getRecipients(onlyContacts, blocked, recipientIds, name)
1205 .stream()
1206 .map(s -> new Recipient(s.getRecipientId(),
1207 s.getAddress().toApiRecipientAddress(),
1208 s.getContact(),
1209 s.getProfileKey(),
1210 s.getExpiringProfileKeyCredential(),
1211 s.getProfile()))
1212 .toList();
1213 }
1214
1215 @Override
1216 public String getContactOrProfileName(RecipientIdentifier.Single recipient) {
1217 final RecipientId recipientId;
1218 try {
1219 recipientId = context.getRecipientHelper().resolveRecipient(recipient);
1220 } catch (UnregisteredRecipientException e) {
1221 return null;
1222 }
1223
1224 final var contact = account.getContactStore().getContact(recipientId);
1225 if (contact != null && !Util.isEmpty(contact.getName())) {
1226 return contact.getName();
1227 }
1228
1229 final var profile = context.getProfileHelper().getRecipientProfile(recipientId);
1230 if (profile != null) {
1231 return profile.getDisplayName();
1232 }
1233
1234 return null;
1235 }
1236
1237 @Override
1238 public Group getGroup(GroupId groupId) {
1239 return toGroup(context.getGroupHelper().getGroup(groupId));
1240 }
1241
1242 @Override
1243 public List<Identity> getIdentities() {
1244 return account.getIdentityKeyStore()
1245 .getIdentities()
1246 .stream()
1247 .map(this::toIdentity)
1248 .filter(Objects::nonNull)
1249 .toList();
1250 }
1251
1252 private Identity toIdentity(final IdentityInfo identityInfo) {
1253 if (identityInfo == null) {
1254 return null;
1255 }
1256
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())) {
1261 return null;
1262 }
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());
1272 }
1273
1274 @Override
1275 public List<Identity> getIdentities(RecipientIdentifier.Single recipient) {
1276 ServiceId serviceId;
1277 try {
1278 final var address = account.getRecipientAddressResolver()
1279 .resolveRecipientAddress(context.getRecipientHelper().resolveRecipient(recipient));
1280 if (address.serviceId().isEmpty()) {
1281 return List.of();
1282 }
1283 serviceId = address.serviceId().get();
1284 } catch (UnregisteredRecipientException e) {
1285 return List.of();
1286 }
1287 final var identity = account.getIdentityKeyStore().getIdentityInfo(serviceId);
1288 return identity == null ? List.of() : List.of(toIdentity(identity));
1289 }
1290
1291 @Override
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");
1303 };
1304 }
1305
1306 @Override
1307 public boolean trustIdentityAllKeys(RecipientIdentifier.Single recipient) throws UnregisteredRecipientException {
1308 return trustIdentity(recipient, r -> context.getIdentityHelper().trustIdentityAllKeys(r));
1309 }
1310
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);
1318 }
1319 return updated;
1320 }
1321
1322 @Override
1323 public void addAddressChangedListener(final Runnable listener) {
1324 synchronized (addressChangedListeners) {
1325 addressChangedListeners.add(listener);
1326 }
1327 }
1328
1329 @Override
1330 public void addClosedListener(final Runnable listener) {
1331 synchronized (closedListeners) {
1332 closedListeners.add(listener);
1333 }
1334 }
1335
1336 @Override
1337 public InputStream retrieveAttachment(final String id) throws IOException {
1338 return context.getAttachmentHelper().retrieveAttachment(id).getStream();
1339 }
1340
1341 @Override
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();
1348 }
1349 return streamDetails.getStream();
1350 }
1351
1352 @Override
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();
1360 }
1361 return streamDetails.getStream();
1362 }
1363
1364 @Override
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();
1370 }
1371 return streamDetails.getStream();
1372 }
1373
1374 @Override
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);
1379 if (pack != null) {
1380 try {
1381 context.getStickerHelper().retrieveStickerPack(stickerPackId, pack.packKey());
1382 } catch (InvalidMessageException e) {
1383 logger.warn("Failed to download sticker pack");
1384 }
1385 }
1386 }
1387 if (streamDetails == null) {
1388 throw new FileNotFoundException();
1389 }
1390 return streamDetails.getStream();
1391 }
1392
1393 @Override
1394 public void close() {
1395 Thread thread;
1396 synchronized (messageHandlers) {
1397 weakHandlers.clear();
1398 messageHandlers.clear();
1399 thread = receiveThread;
1400 receiveThread = null;
1401 }
1402 if (thread != null) {
1403 stopReceiveThread(thread);
1404 }
1405 context.close();
1406 executor.close();
1407
1408 dependencies.getSignalWebSocket().disconnect();
1409 dependencies.getPushServiceSocket().close();
1410 disposable.dispose();
1411
1412 if (account != null) {
1413 account.close();
1414 }
1415
1416 synchronized (closedListeners) {
1417 closedListeners.forEach(Runnable::run);
1418 closedListeners.clear();
1419 }
1420
1421 account = null;
1422 }
1423 }