Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 1 | /* |
Adrien Béraud | e552f69 | 2020-11-03 14:30:52 -0500 | [diff] [blame] | 2 | * Copyright (C) 2004-2020 Savoir-faire Linux Inc. |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 3 | * |
| 4 | * Author: Hadrien De Sousa <hadrien.desousa@savoirfairelinux.com> |
Adrien Béraud | 6453872 | 2018-03-15 17:34:00 -0400 | [diff] [blame] | 5 | * Author: Adrien Béraud <adrien.beraud@savoirfairelinux.com> |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 6 | * |
| 7 | * This program is free software; you can redistribute it and/or modify |
| 8 | * it under the terms of the GNU General Public License as published by |
| 9 | * the Free Software Foundation; either version 3 of the License, or |
| 10 | * (at your option) any later version. |
| 11 | * |
| 12 | * This program is distributed in the hope that it will be useful, |
| 13 | * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 14 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| 15 | * GNU General Public License for more details. |
| 16 | * |
| 17 | * You should have received a copy of the GNU General Public License |
| 18 | * along with this program; if not, write to the Free Software |
| 19 | * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. |
| 20 | */ |
| 21 | package cx.ring.conversation; |
| 22 | |
Pierre Duchemin | e0c3a49 | 2018-02-01 16:22:45 -0500 | [diff] [blame] | 23 | import java.io.File; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 24 | |
| 25 | import javax.inject.Inject; |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 26 | import javax.inject.Named; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 27 | |
| 28 | import cx.ring.daemon.Blob; |
| 29 | import cx.ring.facades.ConversationFacade; |
Adrien Béraud | 20d4221 | 2018-03-02 14:40:38 -0500 | [diff] [blame] | 30 | import cx.ring.model.Account; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 31 | import cx.ring.model.CallContact; |
| 32 | import cx.ring.model.Conference; |
| 33 | import cx.ring.model.Conversation; |
Adrien Béraud | 7c50511 | 2018-03-20 16:03:28 -0400 | [diff] [blame] | 34 | import cx.ring.model.DataTransfer; |
Adrien Béraud | a0226ff | 2019-11-21 15:24:42 -0500 | [diff] [blame] | 35 | import cx.ring.model.Error; |
Adrien Béraud | 37fb52e | 2020-10-02 19:24:31 -0400 | [diff] [blame] | 36 | import cx.ring.model.Interaction; |
Aline Bonnet | 15fdf0a | 2017-04-26 17:02:58 -0400 | [diff] [blame] | 37 | import cx.ring.model.SipCall; |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 38 | import cx.ring.model.TrustRequest; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 39 | import cx.ring.model.Uri; |
| 40 | import cx.ring.mvp.RootPresenter; |
| 41 | import cx.ring.services.AccountService; |
| 42 | import cx.ring.services.ContactService; |
Pierre Duchemin | 4af6b39 | 2018-02-02 11:23:56 -0500 | [diff] [blame] | 43 | import cx.ring.services.DeviceRuntimeService; |
Hadrien De Sousa | 45fb21b | 2017-12-14 11:06:48 -0500 | [diff] [blame] | 44 | import cx.ring.services.HardwareService; |
Amirhossein | 4ae37ef | 2020-11-30 23:26:27 -0500 | [diff] [blame] | 45 | import cx.ring.services.PreferencesService; |
Hadrien De Sousa | 6cd2bd2 | 2018-01-02 16:11:32 -0500 | [diff] [blame] | 46 | import cx.ring.services.VCardService; |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 47 | import cx.ring.utils.Log; |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 48 | import cx.ring.utils.StringUtils; |
Adrien Béraud | 5477ce8 | 2020-02-24 11:13:54 -0500 | [diff] [blame] | 49 | import cx.ring.utils.Tuple; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 50 | import cx.ring.utils.VCardUtils; |
Amirhossein | 5ee9d41 | 2020-04-04 13:44:52 -0400 | [diff] [blame] | 51 | import io.reactivex.Observable; |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 52 | import io.reactivex.Scheduler; |
| 53 | import io.reactivex.disposables.CompositeDisposable; |
| 54 | import io.reactivex.schedulers.Schedulers; |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 55 | import io.reactivex.subjects.BehaviorSubject; |
| 56 | import io.reactivex.subjects.Subject; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 57 | |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 58 | public class ConversationPresenter extends RootPresenter<ConversationView> { |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 59 | |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 60 | private static final String TAG = ConversationPresenter.class.getSimpleName(); |
Adrien Béraud | 68f1adb | 2018-07-18 18:35:21 -0400 | [diff] [blame] | 61 | private final ContactService mContactService; |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 62 | private final AccountService mAccountService; |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 63 | private final HardwareService mHardwareService; |
| 64 | private final ConversationFacade mConversationFacade; |
| 65 | private final VCardService mVCardService; |
| 66 | private final DeviceRuntimeService mDeviceRuntimeService; |
Amirhossein | 4ae37ef | 2020-11-30 23:26:27 -0500 | [diff] [blame] | 67 | private final PreferencesService mPreferencesService; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 68 | |
| 69 | private Conversation mConversation; |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 70 | private Uri mContactUri; |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 71 | private String mAccountId; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 72 | |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 73 | private CompositeDisposable mConversationDisposable; |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 74 | private final CompositeDisposable mVisibilityDisposable = new CompositeDisposable(); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 75 | |
| 76 | @Inject |
| 77 | @Named("UiScheduler") |
| 78 | protected Scheduler mUiScheduler; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 79 | |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 80 | private final Subject<Conversation> mConversationSubject = BehaviorSubject.create(); |
| 81 | |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 82 | @Inject |
Adrien Béraud | 6453872 | 2018-03-15 17:34:00 -0400 | [diff] [blame] | 83 | public ConversationPresenter(ContactService contactService, |
| 84 | AccountService accountService, |
Hadrien De Sousa | 45fb21b | 2017-12-14 11:06:48 -0500 | [diff] [blame] | 85 | HardwareService hardwareService, |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 86 | ConversationFacade conversationFacade, |
Hadrien De Sousa | 6cd2bd2 | 2018-01-02 16:11:32 -0500 | [diff] [blame] | 87 | VCardService vCardService, |
Amirhossein | 7bb77aa | 2020-12-18 16:30:44 -0500 | [diff] [blame^] | 88 | DeviceRuntimeService deviceRuntimeService, |
| 89 | PreferencesService preferencesService) { |
Adrien Béraud | c35f7f4 | 2020-04-15 15:29:29 -0400 | [diff] [blame] | 90 | mContactService = contactService; |
| 91 | mAccountService = accountService; |
| 92 | mHardwareService = hardwareService; |
| 93 | mConversationFacade = conversationFacade; |
| 94 | mVCardService = vCardService; |
| 95 | mDeviceRuntimeService = deviceRuntimeService; |
Amirhossein | 4ae37ef | 2020-11-30 23:26:27 -0500 | [diff] [blame] | 96 | mPreferencesService = preferencesService; |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 97 | } |
| 98 | |
| 99 | @Override |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 100 | public void bindView(ConversationView view) { |
| 101 | super.bindView(view); |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 102 | mCompositeDisposable.add(mVisibilityDisposable); |
| 103 | if (mConversationDisposable == null && mConversation != null) |
| 104 | initView(mConversation, view); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 105 | } |
| 106 | |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 107 | public void init(Uri contactRingId, String accountId) { |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 108 | Log.w(TAG, "init " + contactRingId + " " + accountId); |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 109 | mContactUri = contactRingId; |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 110 | mAccountId = accountId; |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 111 | Account account = mAccountService.getAccount(accountId); |
Adrien Béraud | 9c16631 | 2019-10-25 14:24:15 -0400 | [diff] [blame] | 112 | if (account != null) { |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 113 | initContact(account, contactRingId, getView()); |
Adrien Béraud | 9c16631 | 2019-10-25 14:24:15 -0400 | [diff] [blame] | 114 | mCompositeDisposable.add(mConversationFacade.loadConversationHistory(account, contactRingId) |
| 115 | .observeOn(mUiScheduler) |
| 116 | .subscribe(this::setConversation, e -> getView().goToHome())); |
| 117 | } else { |
| 118 | getView().goToHome(); |
Adrien Béraud | dbb351f | 2020-12-04 18:20:04 -0500 | [diff] [blame] | 119 | return; |
Adrien Béraud | 9c16631 | 2019-10-25 14:24:15 -0400 | [diff] [blame] | 120 | } |
Amirhossein | 5ee9d41 | 2020-04-04 13:44:52 -0400 | [diff] [blame] | 121 | |
| 122 | mCompositeDisposable.add(Observable.combineLatest( |
| 123 | mHardwareService.getConnectivityState(), |
Adrien Béraud | dbb351f | 2020-12-04 18:20:04 -0500 | [diff] [blame] | 124 | mAccountService.getObservableAccount(account), |
Amirhossein | 5ee9d41 | 2020-04-04 13:44:52 -0400 | [diff] [blame] | 125 | (isConnected, a) -> isConnected || a.isRegistered()) |
| 126 | .observeOn(mUiScheduler) |
| 127 | .subscribe(isOk -> { |
| 128 | ConversationView view = getView(); |
| 129 | if (view != null) { |
| 130 | if (isOk) |
| 131 | view.hideErrorPanel(); |
| 132 | else |
| 133 | view.displayNetworkErrorPanel(); |
| 134 | } |
| 135 | })); |
Amirhossein | 85b3f2e | 2020-12-01 13:05:43 -0500 | [diff] [blame] | 136 | |
Amirhossein | 7bb77aa | 2020-12-18 16:30:44 -0500 | [diff] [blame^] | 137 | getView().setReadIndicatorStatus(showReadIndicator()); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 138 | } |
Pierre Duchemin | e0c3a49 | 2018-02-01 16:22:45 -0500 | [diff] [blame] | 139 | |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 140 | private void setConversation(final Conversation conversation) { |
| 141 | if (conversation == null || mConversation == conversation) |
| 142 | return; |
| 143 | mConversation = conversation; |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 144 | mConversationSubject.onNext(conversation); |
| 145 | ConversationView view = getView(); |
| 146 | if (view != null) |
| 147 | initView(conversation, view); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 148 | } |
| 149 | |
| 150 | public void pause() { |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 151 | mVisibilityDisposable.clear(); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 152 | if (mConversation != null) { |
Adrien Béraud | 6453872 | 2018-03-15 17:34:00 -0400 | [diff] [blame] | 153 | mConversation.setVisible(false); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 154 | } |
| 155 | } |
| 156 | |
Amirhossein | 6891638 | 2020-07-19 11:23:59 -0400 | [diff] [blame] | 157 | public void resume(boolean isBubble) { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 158 | Log.w(TAG, "resume " + mConversation + " " + mAccountId + " " + mContactUri); |
Adrien Béraud | 7aa7a9e | 2018-06-29 19:50:32 -0400 | [diff] [blame] | 159 | mVisibilityDisposable.clear(); |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 160 | mVisibilityDisposable.add(mConversationSubject |
| 161 | .firstOrError() |
| 162 | .subscribe(conversation -> { |
| 163 | conversation.setVisible(true); |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 164 | updateOngoingCallView(conversation); |
Amirhossein | 6891638 | 2020-07-19 11:23:59 -0400 | [diff] [blame] | 165 | mConversationFacade.readMessages(mAccountService.getAccount(mAccountId), conversation, !isBubble); |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 166 | }, e -> Log.e(TAG, "Error loading conversation", e))); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 167 | } |
| 168 | |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 169 | private CallContact initContact(final Account account, final Uri uri, |
| 170 | final ConversationView view) { |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 171 | CallContact contact; |
Adrien Béraud | f5d5ce9 | 2020-05-07 03:02:19 -0400 | [diff] [blame] | 172 | if (account.isJami()) { |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 173 | String rawId = uri.getRawRingId(); |
| 174 | contact = account.getContact(rawId); |
| 175 | if (contact == null) { |
| 176 | contact = account.getContactFromCache(uri); |
Adrien Béraud | bf81ead | 2019-06-29 00:16:43 -0400 | [diff] [blame] | 177 | TrustRequest req = account.getRequest(uri); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 178 | if (req == null) { |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 179 | view.switchToUnknownView(contact.getRingUsername()); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 180 | } else { |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 181 | view.switchToIncomingTrustRequestView(req.getDisplayname()); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 182 | } |
| 183 | } else { |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 184 | view.switchToConversationView(); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 185 | } |
| 186 | Log.w(TAG, "initContact " + contact.getUsername()); |
| 187 | if (contact.getUsername() == null) { |
| 188 | mAccountService.lookupAddress(mAccountId, "", rawId); |
| 189 | } |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 190 | } else { |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 191 | contact = mContactService.findContact(account, uri); |
Adrien Béraud | e5ec895 | 2018-07-11 15:14:44 -0400 | [diff] [blame] | 192 | view.switchToConversationView(); |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 193 | } |
Adrien Béraud | 78ae7b9 | 2018-08-25 19:04:17 -0400 | [diff] [blame] | 194 | view.displayContact(contact); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 195 | return contact; |
| 196 | } |
| 197 | |
| 198 | private void initView(final Conversation c, final ConversationView view) { |
| 199 | Log.w(TAG, "initView"); |
| 200 | if (mConversationDisposable == null) { |
| 201 | mConversationDisposable = new CompositeDisposable(); |
| 202 | mCompositeDisposable.add(mConversationDisposable); |
| 203 | } |
| 204 | mConversationDisposable.clear(); |
| 205 | view.hideNumberSpinner(); |
| 206 | |
| 207 | Account account = mAccountService.getAccount(mAccountId); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 208 | |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 209 | |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 210 | mConversationDisposable.add(c.getSortedHistory() |
Adrien Béraud | f2c76ed | 2019-05-25 03:36:48 -0400 | [diff] [blame] | 211 | .subscribe(view::refreshView, e -> Log.e(TAG, "Can't update element", e))); |
Adrien Béraud | a084cd1 | 2018-12-31 12:49:12 -0500 | [diff] [blame] | 212 | mConversationDisposable.add(c.getCleared() |
Adrien Béraud | 08eb45e | 2019-02-18 01:58:12 -0500 | [diff] [blame] | 213 | .observeOn(mUiScheduler) |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 214 | .subscribe(view::refreshView, e -> Log.e(TAG, "Can't update elements", e))); |
Adrien Béraud | 9ec8244 | 2019-02-18 01:55:16 -0500 | [diff] [blame] | 215 | mConversationDisposable.add(mContactService.getLoadedContact(c.getAccountId(), c.getContact()) |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 216 | .observeOn(mUiScheduler) |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 217 | .subscribe(contact -> initContact(account, mContactUri, view), e -> Log.e(TAG, "Can't get contact", e))); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 218 | mConversationDisposable.add(c.getUpdatedElements() |
| 219 | .observeOn(mUiScheduler) |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 220 | .subscribe(elementTuple -> { |
| 221 | switch(elementTuple.second) { |
| 222 | case ADD: |
| 223 | view.addElement(elementTuple.first); |
| 224 | break; |
| 225 | case UPDATE: |
| 226 | view.updateElement(elementTuple.first); |
| 227 | break; |
| 228 | case REMOVE: |
| 229 | view.removeElement(elementTuple.first); |
| 230 | break; |
| 231 | } |
| 232 | }, e -> Log.e(TAG, "Can't update element", e))); |
Amirhossein | 4ae37ef | 2020-11-30 23:26:27 -0500 | [diff] [blame] | 233 | if (showTypingIndicator()) { |
| 234 | mConversationDisposable.add(c.getComposingStatus() |
| 235 | .observeOn(mUiScheduler) |
| 236 | .subscribe(view::setComposingStatus)); |
| 237 | } |
Adrien Béraud | 263cd5c | 2020-03-13 13:36:57 -0400 | [diff] [blame] | 238 | mConversationDisposable.add(c.getLastDisplayed() |
| 239 | .observeOn(mUiScheduler) |
| 240 | .subscribe(view::setLastDisplayed)); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 241 | mConversationDisposable.add(c.getCalls() |
| 242 | .observeOn(mUiScheduler) |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 243 | .subscribe(calls -> updateOngoingCallView(mConversation), e -> Log.e(TAG, "Can't update call view", e))); |
Adrien Béraud | 0f3ee3d | 2018-12-08 22:03:54 -0500 | [diff] [blame] | 244 | mConversationDisposable.add(c.getColor() |
| 245 | .observeOn(mUiScheduler) |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 246 | .subscribe(view::setConversationColor, e -> Log.e(TAG, "Can't update conversation color", e))); |
Adrien Béraud | 5477ce8 | 2020-02-24 11:13:54 -0500 | [diff] [blame] | 247 | |
| 248 | Log.e(TAG, "getLocationUpdates subscribe"); |
| 249 | mConversationDisposable.add(account |
| 250 | .getLocationUpdates(c.getContact().getPrimaryUri()) |
| 251 | .observeOn(mUiScheduler) |
| 252 | .subscribe(u -> { |
| 253 | Log.e(TAG, "getLocationUpdates: update"); |
| 254 | getView().showMap(c.getAccountId(), c.getContact().getPrimaryUri().getUri(), false); |
| 255 | })); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 256 | } |
| 257 | |
Adrien Béraud | 0f3ee3d | 2018-12-08 22:03:54 -0500 | [diff] [blame] | 258 | public void openContact() { |
Adrien Béraud | 91f8874 | 2019-09-09 00:46:46 -0400 | [diff] [blame] | 259 | if (mConversation != null) |
| 260 | getView().goToContactActivity(mAccountId, mConversation.getContact().getPrimaryNumber()); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 261 | } |
| 262 | |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 263 | public void sendTextMessage(String message) { |
Adrien Béraud | 91f8874 | 2019-09-09 00:46:46 -0400 | [diff] [blame] | 264 | if (StringUtils.isEmpty(message) || mConversation == null) { |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 265 | return; |
| 266 | } |
| 267 | Conference conference = mConversation.getCurrentCall(); |
| 268 | if (conference == null || !conference.isOnGoing()) { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 269 | mConversationFacade.sendTextMessage(mAccountId, mConversation, mContactUri, message).subscribe(); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 270 | } else { |
| 271 | mConversationFacade.sendTextMessage(mConversation, conference, message); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 272 | } |
| 273 | } |
| 274 | |
Pierre Duchemin | e0c3a49 | 2018-02-01 16:22:45 -0500 | [diff] [blame] | 275 | public void selectFile() { |
| 276 | getView().openFilePicker(); |
| 277 | } |
| 278 | |
Adrien Béraud | 6453872 | 2018-03-15 17:34:00 -0400 | [diff] [blame] | 279 | public void sendFile(File file) { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 280 | mConversationFacade.sendFile(mAccountId, mContactUri, file).subscribe(); |
Pierre Duchemin | e0c3a49 | 2018-02-01 16:22:45 -0500 | [diff] [blame] | 281 | } |
| 282 | |
amine younes | 7c56f31 | 2019-06-10 11:34:25 -0400 | [diff] [blame] | 283 | /** |
| 284 | * Gets the absolute path of the file dataTransfer and sends both the DataTransfer and the |
| 285 | * found path to the ConversationView in order to start saving the file |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 286 | * |
| 287 | * @param interaction an interaction representing a datat transfer |
amine younes | 7c56f31 | 2019-06-10 11:34:25 -0400 | [diff] [blame] | 288 | */ |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 289 | public void saveFile(Interaction interaction) { |
| 290 | DataTransfer transfer = (DataTransfer) interaction; |
| 291 | String fileAbsolutePath = getDeviceRuntimeService(). |
amine younes | 7c56f31 | 2019-06-10 11:34:25 -0400 | [diff] [blame] | 292 | getConversationPath(transfer.getPeerId(), transfer.getStoragePath()) |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 293 | .getAbsolutePath(); |
| 294 | getView().startSaveFile(transfer, fileAbsolutePath); |
Adrien Béraud | 7c50511 | 2018-03-20 16:03:28 -0400 | [diff] [blame] | 295 | } |
| 296 | |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 297 | public void shareFile(Interaction interaction) { |
| 298 | DataTransfer file = (DataTransfer) interaction; |
Adrien Béraud | fcf457f | 2018-04-03 17:46:34 -0400 | [diff] [blame] | 299 | File path = getDeviceRuntimeService().getConversationPath(file.getPeerId(), file.getStoragePath()); |
| 300 | getView().shareFile(path); |
| 301 | } |
| 302 | |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 303 | public void openFile(Interaction interaction) { |
| 304 | DataTransfer file = (DataTransfer) interaction; |
Adrien Béraud | b2b3f44 | 2018-12-01 17:42:38 -0500 | [diff] [blame] | 305 | File path = getDeviceRuntimeService().getConversationPath(file.getPeerId(), file.getStoragePath()); |
| 306 | getView().openFile(path); |
| 307 | } |
| 308 | |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 309 | public void deleteConversationItem(Interaction element) { |
Rayan Osseiran | e634a56 | 2019-05-29 13:44:55 -0400 | [diff] [blame] | 310 | mConversationFacade.deleteConversationItem(element); |
| 311 | } |
| 312 | |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 313 | public void cancelMessage(Interaction message) { |
Rayan Osseiran | e634a56 | 2019-05-29 13:44:55 -0400 | [diff] [blame] | 314 | mConversationFacade.cancelMessage(message); |
Adrien Béraud | 7c50511 | 2018-03-20 16:03:28 -0400 | [diff] [blame] | 315 | } |
| 316 | |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 317 | private void sendTrustRequest() { |
Adrien Béraud | 0acf5a1 | 2018-08-02 13:40:40 -0400 | [diff] [blame] | 318 | final String accountId = mAccountId; |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 319 | final Uri contactId = mContactUri; |
Adrien Béraud | 1cab7d1 | 2020-08-06 12:38:58 -0400 | [diff] [blame] | 320 | CallContact contact = mContactService.findContact(mAccountService.getAccount(accountId), contactId); |
| 321 | if (contact != null) { |
| 322 | contact.setStatus(CallContact.Status.REQUEST_SENT); |
| 323 | } |
Adrien Béraud | bdfb5e1 | 2019-02-18 15:46:44 -0500 | [diff] [blame] | 324 | mVCardService.loadSmallVCard(accountId, VCardService.MAX_SIZE_REQUEST) |
| 325 | .subscribeOn(Schedulers.computation()) |
Adrien Béraud | 1cab7d1 | 2020-08-06 12:38:58 -0400 | [diff] [blame] | 326 | .subscribe(vCard -> mAccountService.sendTrustRequest(accountId, contactId.getRawRingId(), Blob.fromString(VCardUtils.vcardToString(vCard))), |
| 327 | e -> mAccountService.sendTrustRequest(accountId, contactId.getRawRingId(), null)); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 328 | } |
| 329 | |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 330 | public void clickOnGoingPane() { |
Amirhossein | 1cbc8df | 2020-08-14 11:48:30 -0400 | [diff] [blame] | 331 | Conference conf = mConversation == null ? null : mConversation.getCurrentCall(); |
Adrien Beraud | 4f64438 | 2017-07-21 17:01:51 -0400 | [diff] [blame] | 332 | if (conf != null) { |
| 333 | getView().goToCallActivity(conf.getId()); |
| 334 | } else { |
Hadrien De Sousa | 0dc8316 | 2017-11-10 16:15:18 -0500 | [diff] [blame] | 335 | getView().displayOnGoingCallPane(false); |
Adrien Beraud | 4f64438 | 2017-07-21 17:01:51 -0400 | [diff] [blame] | 336 | } |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 337 | } |
| 338 | |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 339 | public void goToCall(boolean audioOnly) { |
Adrien Béraud | d3bf4e4 | 2018-02-14 14:44:41 +0100 | [diff] [blame] | 340 | if (audioOnly && !mHardwareService.hasMicrophone()) { |
Adrien Béraud | a0226ff | 2019-11-21 15:24:42 -0500 | [diff] [blame] | 341 | getView().displayErrorToast(Error.NO_MICROPHONE); |
Hadrien De Sousa | 45fb21b | 2017-12-14 11:06:48 -0500 | [diff] [blame] | 342 | return; |
| 343 | } |
| 344 | |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 345 | mCompositeDisposable.add(mConversationSubject |
| 346 | .firstElement() |
| 347 | .subscribe(conversation -> { |
| 348 | ConversationView view = getView(); |
| 349 | if (view != null) { |
| 350 | Conference conf = mConversation.getCurrentCall(); |
| 351 | if (conf != null |
| 352 | && !conf.getParticipants().isEmpty() |
| 353 | && conf.getParticipants().get(0).getCallStatus() != SipCall.CallStatus.INACTIVE |
| 354 | && conf.getParticipants().get(0).getCallStatus() != SipCall.CallStatus.FAILURE) { |
| 355 | view.goToCallActivity(conf.getId()); |
| 356 | } else { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 357 | view.goToCallActivityWithResult(mAccountId, mContactUri.getRawUriString(), audioOnly); |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 358 | } |
| 359 | } |
| 360 | })); |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 361 | } |
| 362 | |
Adrien Béraud | 4a64305 | 2019-11-18 12:41:23 -0500 | [diff] [blame] | 363 | private void updateOngoingCallView(Conversation conversation) { |
| 364 | Conference conf = conversation == null ? null : conversation.getCurrentCall(); |
Rayan Osseiran | 6f41566 | 2019-10-25 14:23:25 -0400 | [diff] [blame] | 365 | if (conf != null && (conf.getState() == SipCall.CallStatus.CURRENT || conf.getState() == SipCall.CallStatus.HOLD || conf.getState() == SipCall.CallStatus.RINGING)) { |
Adrien Béraud | 20d4221 | 2018-03-02 14:40:38 -0500 | [diff] [blame] | 366 | getView().displayOnGoingCallPane(true); |
| 367 | } else { |
| 368 | getView().displayOnGoingCallPane(false); |
| 369 | } |
Hadrien De Sousa | ec95e5e | 2017-03-21 15:28:23 -0400 | [diff] [blame] | 370 | } |
| 371 | |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 372 | public void onBlockIncomingContactRequest() { |
| 373 | String accountId = mAccountId == null ? mAccountService.getCurrentAccount().getAccountID() : mAccountId; |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 374 | mConversationFacade.discardRequest(accountId, mContactUri); |
| 375 | mAccountService.removeContact(accountId, mContactUri.getHost(), true); |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 376 | |
| 377 | getView().goToHome(); |
| 378 | } |
| 379 | |
| 380 | public void onRefuseIncomingContactRequest() { |
| 381 | String accountId = mAccountId == null ? mAccountService.getCurrentAccount().getAccountID() : mAccountId; |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 382 | |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 383 | mConversationFacade.discardRequest(accountId, mContactUri); |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 384 | getView().goToHome(); |
| 385 | } |
| 386 | |
| 387 | public void onAcceptIncomingContactRequest() { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 388 | mConversationFacade.acceptRequest(mAccountId, mContactUri); |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 389 | getView().switchToConversationView(); |
| 390 | } |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 391 | |
Adrien Béraud | ace37a2 | 2018-06-22 14:58:36 -0400 | [diff] [blame] | 392 | public void onAddContact() { |
| 393 | sendTrustRequest(); |
Pierre Duchemin | 1fa6192 | 2018-01-18 10:09:02 -0500 | [diff] [blame] | 394 | getView().switchToConversationView(); |
| 395 | } |
| 396 | |
Pierre Duchemin | 4af6b39 | 2018-02-02 11:23:56 -0500 | [diff] [blame] | 397 | public DeviceRuntimeService getDeviceRuntimeService() { |
| 398 | return mDeviceRuntimeService; |
| 399 | } |
Pierre Duchemin | df6cb5a | 2018-02-09 18:05:21 -0500 | [diff] [blame] | 400 | |
| 401 | public void noSpaceLeft() { |
| 402 | Log.e(TAG, "configureForFileInfoTextMessage: no space left on device"); |
Adrien Béraud | a0226ff | 2019-11-21 15:24:42 -0500 | [diff] [blame] | 403 | getView().displayErrorToast(Error.NO_SPACE_LEFT); |
Pierre Duchemin | df6cb5a | 2018-02-09 18:05:21 -0500 | [diff] [blame] | 404 | } |
Adrien Béraud | 0f3ee3d | 2018-12-08 22:03:54 -0500 | [diff] [blame] | 405 | |
| 406 | public void setConversationColor(int color) { |
| 407 | mCompositeDisposable.add(mConversationSubject |
| 408 | .firstElement() |
| 409 | .subscribe(conversation -> conversation.setColor(color))); |
| 410 | } |
Rayan Osseiran | 38206c6 | 2019-05-15 14:49:03 -0400 | [diff] [blame] | 411 | |
| 412 | public void cameraPermissionChanged(boolean isGranted) { |
| 413 | if (isGranted && mHardwareService.isVideoAvailable()) { |
Adrien Béraud | 37fb52e | 2020-10-02 19:24:31 -0400 | [diff] [blame] | 414 | mHardwareService.initVideo() |
| 415 | .onErrorComplete() |
| 416 | .subscribe(); |
Rayan Osseiran | 38206c6 | 2019-05-15 14:49:03 -0400 | [diff] [blame] | 417 | } |
| 418 | } |
| 419 | |
Adrien Béraud | 5477ce8 | 2020-02-24 11:13:54 -0500 | [diff] [blame] | 420 | public void shareLocation() { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 421 | getView().startShareLocation(mAccountId, mContactUri.getUri()); |
Adrien Béraud | 5477ce8 | 2020-02-24 11:13:54 -0500 | [diff] [blame] | 422 | } |
| 423 | |
| 424 | public Tuple<String, String> getPath() { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 425 | return new Tuple<>(mAccountId, mContactUri.getUri()); |
| 426 | } |
| 427 | |
| 428 | public void onComposingChanged(boolean hasMessage) { |
Amirhossein | 4ae37ef | 2020-11-30 23:26:27 -0500 | [diff] [blame] | 429 | if (mConversation == null || !showTypingIndicator()) { |
Adrien Béraud | fd458ea | 2020-02-28 13:40:18 -0500 | [diff] [blame] | 430 | return; |
| 431 | } |
| 432 | mConversationFacade.setIsComposing(mAccountId, mContactUri, hasMessage); |
Adrien Béraud | 5477ce8 | 2020-02-24 11:13:54 -0500 | [diff] [blame] | 433 | } |
Amirhossein | 4ae37ef | 2020-11-30 23:26:27 -0500 | [diff] [blame] | 434 | |
| 435 | public boolean showTypingIndicator() { |
| 436 | return mPreferencesService.getSettings().isAllowTypingIndicator(); |
| 437 | } |
| 438 | |
Amirhossein | 7bb77aa | 2020-12-18 16:30:44 -0500 | [diff] [blame^] | 439 | private boolean showReadIndicator() { |
Amirhossein | 85b3f2e | 2020-12-01 13:05:43 -0500 | [diff] [blame] | 440 | return mPreferencesService.getSettings().isAllowReadIndicator(); |
| 441 | } |
| 442 | |
Amirhossein | 7bb77aa | 2020-12-18 16:30:44 -0500 | [diff] [blame^] | 443 | public boolean isRecordingBlocked(){ |
| 444 | return mPreferencesService.getSettings().isRecordingBlocked(); |
| 445 | } |
| 446 | |
Adrien Béraud | e32ab74 | 2018-08-25 21:15:08 -0400 | [diff] [blame] | 447 | } |