ContactsController.java 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875
  1. /*
  2. * Nextcloud Talk application
  3. *
  4. * @author Mario Danic
  5. * Copyright (C) 2017 Mario Danic (mario@lovelyhq.com)
  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, see <http://www.gnu.org/licenses/>.
  19. */
  20. package com.nextcloud.talk.controllers;
  21. import android.app.SearchManager;
  22. import android.content.Context;
  23. import android.content.Intent;
  24. import android.os.Bundle;
  25. import android.os.Handler;
  26. import androidx.annotation.NonNull;
  27. import androidx.annotation.Nullable;
  28. import com.google.android.material.bottomnavigation.BottomNavigationView;
  29. import androidx.core.view.MenuItemCompat;
  30. import androidx.swiperefreshlayout.widget.SwipeRefreshLayout;
  31. import androidx.recyclerview.widget.RecyclerView;
  32. import androidx.appcompat.widget.SearchView;
  33. import android.text.InputType;
  34. import android.text.TextUtils;
  35. import android.view.LayoutInflater;
  36. import android.view.Menu;
  37. import android.view.MenuInflater;
  38. import android.view.MenuItem;
  39. import android.view.View;
  40. import android.view.ViewGroup;
  41. import android.view.ViewTreeObserver;
  42. import android.view.inputmethod.EditorInfo;
  43. import android.widget.RelativeLayout;
  44. import com.bluelinelabs.conductor.RouterTransaction;
  45. import com.bluelinelabs.conductor.changehandler.HorizontalChangeHandler;
  46. import com.bluelinelabs.conductor.changehandler.VerticalChangeHandler;
  47. import com.kennyc.bottomsheet.BottomSheet;
  48. import com.nextcloud.talk.R;
  49. import com.nextcloud.talk.activities.MagicCallActivity;
  50. import com.nextcloud.talk.adapters.items.ProgressItem;
  51. import com.nextcloud.talk.adapters.items.UserHeaderItem;
  52. import com.nextcloud.talk.adapters.items.UserItem;
  53. import com.nextcloud.talk.api.NcApi;
  54. import com.nextcloud.talk.application.NextcloudTalkApplication;
  55. import com.nextcloud.talk.controllers.base.BaseController;
  56. import com.nextcloud.talk.controllers.bottomsheet.OperationsMenuController;
  57. import com.nextcloud.talk.events.BottomSheetLockEvent;
  58. import com.nextcloud.talk.models.RetrofitBucket;
  59. import com.nextcloud.talk.models.database.UserEntity;
  60. import com.nextcloud.talk.models.json.participants.Participant;
  61. import com.nextcloud.talk.models.json.rooms.Conversation;
  62. import com.nextcloud.talk.models.json.rooms.RoomOverall;
  63. import com.nextcloud.talk.models.json.sharees.Sharee;
  64. import com.nextcloud.talk.models.json.sharees.ShareesOverall;
  65. import com.nextcloud.talk.utils.ApiUtils;
  66. import com.nextcloud.talk.utils.bundle.BundleKeys;
  67. import com.nextcloud.talk.utils.database.user.UserUtils;
  68. import org.greenrobot.eventbus.EventBus;
  69. import org.greenrobot.eventbus.Subscribe;
  70. import org.greenrobot.eventbus.ThreadMode;
  71. import org.parceler.Parcels;
  72. import java.util.ArrayList;
  73. import java.util.Collections;
  74. import java.util.HashMap;
  75. import java.util.HashSet;
  76. import java.util.List;
  77. import java.util.Map;
  78. import java.util.Set;
  79. import javax.inject.Inject;
  80. import autodagger.AutoInjector;
  81. import butterknife.BindView;
  82. import butterknife.OnClick;
  83. import butterknife.Optional;
  84. import eu.davidea.fastscroller.FastScroller;
  85. import eu.davidea.flexibleadapter.FlexibleAdapter;
  86. import eu.davidea.flexibleadapter.SelectableAdapter;
  87. import eu.davidea.flexibleadapter.common.SmoothScrollLinearLayoutManager;
  88. import eu.davidea.flexibleadapter.items.AbstractFlexibleItem;
  89. import eu.davidea.flexibleadapter.items.IFlexible;
  90. import eu.davidea.flipview.FlipView;
  91. import io.reactivex.Observer;
  92. import io.reactivex.android.schedulers.AndroidSchedulers;
  93. import io.reactivex.disposables.Disposable;
  94. import io.reactivex.schedulers.Schedulers;
  95. import retrofit2.HttpException;
  96. import retrofit2.Response;
  97. @AutoInjector(NextcloudTalkApplication.class)
  98. public class ContactsController extends BaseController implements SearchView.OnQueryTextListener,
  99. FlexibleAdapter.OnItemClickListener, FastScroller.OnScrollStateChangeListener, FlexibleAdapter.EndlessScrollListener {
  100. public static final String TAG = "ContactsController";
  101. private static final String KEY_SEARCH_QUERY = "ContactsController.searchQuery";
  102. @Nullable
  103. @BindView(R.id.initial_relative_layout)
  104. public RelativeLayout initialRelativeLayout;
  105. @Nullable
  106. @BindView(R.id.secondary_relative_layout)
  107. public RelativeLayout secondaryRelativeLayout;
  108. @Inject
  109. UserUtils userUtils;
  110. @Inject
  111. EventBus eventBus;
  112. @BindView(R.id.recycler_view)
  113. RecyclerView recyclerView;
  114. @BindView(R.id.swipe_refresh_layout)
  115. SwipeRefreshLayout swipeRefreshLayout;
  116. @BindView(R.id.fast_scroller)
  117. FastScroller fastScroller;
  118. @Inject
  119. NcApi ncApi;
  120. private String credentials;
  121. private UserEntity currentUser;
  122. private Disposable contactsQueryDisposable;
  123. private Disposable cacheQueryDisposable;
  124. private FlexibleAdapter adapter;
  125. private List<AbstractFlexibleItem> contactItems = new ArrayList<>();
  126. private BottomSheet bottomSheet;
  127. private View view;
  128. private int currentPage;
  129. private int currentSearchPage;
  130. private SmoothScrollLinearLayoutManager layoutManager;
  131. private MenuItem searchItem;
  132. private SearchView searchView;
  133. private String searchQuery;
  134. private boolean isNewConversationView;
  135. private boolean isPublicCall;
  136. private HashMap<String, UserHeaderItem> userHeaderItems = new HashMap<>();
  137. private boolean alreadyFetching = false;
  138. private boolean canFetchFurther = true;
  139. private boolean canFetchSearchFurther = true;
  140. private MenuItem doneMenuItem;
  141. public ContactsController() {
  142. super();
  143. setHasOptionsMenu(true);
  144. }
  145. public ContactsController(Bundle args) {
  146. super(args);
  147. setHasOptionsMenu(true);
  148. if (args.containsKey(BundleKeys.KEY_NEW_CONVERSATION)) {
  149. isNewConversationView = true;
  150. }
  151. }
  152. @Override
  153. protected View inflateView(@NonNull LayoutInflater inflater, @NonNull ViewGroup container) {
  154. if (isNewConversationView) {
  155. return inflater.inflate(R.layout.controller_contacts_rv, container, false);
  156. } else {
  157. return inflater.inflate(R.layout.controller_generic_rv, container, false);
  158. }
  159. }
  160. @Override
  161. protected void onAttach(@NonNull View view) {
  162. super.onAttach(view);
  163. eventBus.register(this);
  164. if (isNewConversationView) {
  165. toggleNewCallHeaderVisibility(!isPublicCall);
  166. checkAndHandleDoneMenuItem();
  167. if (getActionBar() != null) {
  168. getActionBar().setDisplayHomeAsUpEnabled(true);
  169. }
  170. }
  171. }
  172. @Override
  173. protected void onViewBound(@NonNull View view) {
  174. super.onViewBound(view);
  175. NextcloudTalkApplication.getSharedApplication().getComponentApplication().inject(this);
  176. FlipView.resetLayoutAnimationDelay(true, 1000L);
  177. FlipView.stopLayoutAnimation();
  178. currentUser = userUtils.getCurrentUser();
  179. if (currentUser != null) {
  180. credentials = ApiUtils.getCredentials(currentUser.getUsername(), currentUser.getToken());
  181. }
  182. if (adapter == null) {
  183. adapter = new FlexibleAdapter<>(contactItems, getActivity(), false);
  184. if (currentUser != null) {
  185. fetchData(true);
  186. }
  187. }
  188. setupAdapter();
  189. prepareViews();
  190. }
  191. private void setupAdapter() {
  192. adapter.setNotifyChangeOfUnfilteredItems(true)
  193. .setMode(SelectableAdapter.Mode.MULTI);
  194. adapter.setEndlessScrollListener(this, new ProgressItem());
  195. adapter.registerAdapterDataObserver(new androidx.recyclerview.widget.RecyclerView.AdapterDataObserver() {
  196. @Override
  197. public void onChanged() {
  198. super.onChanged();
  199. adapter.filterItems();
  200. adapter.onLoadMoreComplete(null);
  201. }
  202. });
  203. adapter.setStickyHeaderElevation(5)
  204. .setUnlinkAllItemsOnRemoveHeaders(true)
  205. .setDisplayHeadersAtStartUp(true)
  206. .setStickyHeaders(true);
  207. adapter.addListener(this);
  208. }
  209. private void selectionDone() {
  210. if (!isPublicCall && adapter.getSelectedPositions().size() == 1) {
  211. RetrofitBucket retrofitBucket = ApiUtils.getRetrofitBucketForCreateRoom(currentUser.getBaseUrl(), "1",
  212. ((UserItem) adapter.getItem(adapter.getSelectedPositions().get(0))).getModel().getUserId(), null);
  213. ncApi.createRoom(credentials,
  214. retrofitBucket.getUrl(), retrofitBucket.getQueryMap())
  215. .subscribeOn(Schedulers.newThread())
  216. .observeOn(AndroidSchedulers.mainThread())
  217. .subscribe(new Observer<RoomOverall>() {
  218. @Override
  219. public void onSubscribe(Disposable d) {
  220. }
  221. @Override
  222. public void onNext(RoomOverall roomOverall) {
  223. Intent conversationIntent = new Intent(getActivity(), MagicCallActivity.class);
  224. Bundle bundle = new Bundle();
  225. bundle.putString(BundleKeys.KEY_ROOM_TOKEN, roomOverall.getOcs().getData().getToken());
  226. bundle.putString(BundleKeys.KEY_ROOM_ID, roomOverall.getOcs().getData().getRoomId());
  227. if (currentUser.hasSpreedCapabilityWithName("chat-v2")) {
  228. bundle.putString(BundleKeys.KEY_CONVERSATION_NAME,
  229. roomOverall.getOcs().getData().getDisplayName());
  230. conversationIntent.putExtras(bundle);
  231. getRouter().pushController((RouterTransaction.with(new ChatController(bundle))
  232. .pushChangeHandler(new HorizontalChangeHandler())
  233. .popChangeHandler(new HorizontalChangeHandler())));
  234. } else {
  235. conversationIntent.putExtras(bundle);
  236. startActivity(conversationIntent);
  237. new Handler().postDelayed(() -> getRouter().popCurrentController(), 100);
  238. }
  239. }
  240. @Override
  241. public void onError(Throwable e) {
  242. }
  243. @Override
  244. public void onComplete() {
  245. }
  246. });
  247. } else {
  248. Bundle bundle = new Bundle();
  249. Conversation.RoomType roomType;
  250. if (isPublicCall) {
  251. roomType = Conversation.RoomType.ROOM_PUBLIC_CALL;
  252. } else {
  253. roomType = Conversation.RoomType.ROOM_GROUP_CALL;
  254. }
  255. bundle.putParcelable(BundleKeys.KEY_CONVERSATION_TYPE, Parcels.wrap(roomType));
  256. ArrayList<String> userIds = new ArrayList<>();
  257. Set<Integer> selectedPositions = adapter.getSelectedPositionsAsSet();
  258. for (int selectedPosition : selectedPositions) {
  259. if (adapter.getItem(selectedPosition) instanceof UserItem) {
  260. UserItem userItem = (UserItem) adapter.getItem(selectedPosition);
  261. userIds.add(userItem.getModel().getUserId());
  262. }
  263. }
  264. bundle.putStringArrayList(BundleKeys.KEY_INVITED_PARTICIPANTS, userIds);
  265. bundle.putInt(BundleKeys.KEY_OPERATION_CODE, 11);
  266. prepareAndShowBottomSheetWithBundle(bundle);
  267. }
  268. }
  269. private void initSearchView() {
  270. if (getActivity() != null) {
  271. SearchManager searchManager = (SearchManager) getActivity().getSystemService(Context.SEARCH_SERVICE);
  272. if (searchItem != null) {
  273. searchView = (SearchView) MenuItemCompat.getActionView(searchItem);
  274. searchView.setMaxWidth(Integer.MAX_VALUE);
  275. searchView.setInputType(InputType.TYPE_TEXT_VARIATION_FILTER);
  276. searchView.setImeOptions(EditorInfo.IME_ACTION_DONE | EditorInfo.IME_FLAG_NO_FULLSCREEN);
  277. searchView.setQueryHint(getResources().getString(R.string.nc_search));
  278. if (searchManager != null) {
  279. searchView.setSearchableInfo(searchManager.getSearchableInfo(getActivity().getComponentName()));
  280. }
  281. searchView.setOnQueryTextListener(this);
  282. }
  283. }
  284. final View mSearchEditFrame = searchView
  285. .findViewById(androidx.appcompat.R.id.search_edit_frame);
  286. BottomNavigationView bottomNavigationView = null;
  287. if (getParentController() != null && getParentController().getView() != null) {
  288. bottomNavigationView = getParentController().getView().findViewById(R.id.navigation);
  289. }
  290. Handler handler = new Handler();
  291. ViewTreeObserver vto = mSearchEditFrame.getViewTreeObserver();
  292. BottomNavigationView finalBottomNavigationView = bottomNavigationView;
  293. vto.addOnGlobalLayoutListener(new ViewTreeObserver.OnGlobalLayoutListener() {
  294. int oldVisibility = -1;
  295. @Override
  296. public void onGlobalLayout() {
  297. int currentVisibility = mSearchEditFrame.getVisibility();
  298. if (currentVisibility != oldVisibility) {
  299. if (currentVisibility == View.VISIBLE) {
  300. if (finalBottomNavigationView != null) {
  301. handler.postDelayed(() -> finalBottomNavigationView.setVisibility(View.GONE), 100);
  302. }
  303. } else {
  304. handler.postDelayed(() -> {
  305. if (finalBottomNavigationView != null) {
  306. finalBottomNavigationView.setVisibility(View.VISIBLE);
  307. }
  308. searchItem.setVisible(contactItems.size() > 0);
  309. }, 500);
  310. }
  311. oldVisibility = currentVisibility;
  312. }
  313. }
  314. });
  315. }
  316. @Override
  317. public boolean onOptionsItemSelected(@NonNull MenuItem item) {
  318. switch (item.getItemId()) {
  319. case android.R.id.home:
  320. getRouter().popCurrentController();
  321. return true;
  322. case R.id.contacts_selection_done:
  323. selectionDone();
  324. return true;
  325. default:
  326. return super.onOptionsItemSelected(item);
  327. }
  328. }
  329. @Override
  330. public void onCreateOptionsMenu(Menu menu, MenuInflater inflater) {
  331. super.onCreateOptionsMenu(menu, inflater);
  332. inflater.inflate(R.menu.menu_conversation_plus_filter, menu);
  333. searchItem = menu.findItem(R.id.action_search);
  334. doneMenuItem = menu.findItem(R.id.contacts_selection_done);
  335. menu.findItem(R.id.action_new_conversation).setVisible(false);
  336. initSearchView();
  337. }
  338. @Override
  339. public void onPrepareOptionsMenu(Menu menu) {
  340. super.onPrepareOptionsMenu(menu);
  341. searchItem.setVisible(contactItems.size() > 0);
  342. if (adapter.hasFilter()) {
  343. searchItem.expandActionView();
  344. searchView.setQuery((CharSequence) adapter.getFilter(String.class), false);
  345. }
  346. }
  347. private void fetchData(boolean startFromScratch) {
  348. dispose(null);
  349. alreadyFetching = true;
  350. Set<Sharee> shareeHashSet = new HashSet<>();
  351. userHeaderItems = new HashMap<>();
  352. String query = "";
  353. if (searchView != null && !TextUtils.isEmpty(searchView.getQuery())) {
  354. query = searchView.getQuery().toString();
  355. } else if (startFromScratch) {
  356. contactItems = new ArrayList<>();
  357. }
  358. RetrofitBucket retrofitBucket = ApiUtils.getRetrofitBucketForContactsSearch(currentUser.getBaseUrl(),
  359. query);
  360. int page = 1;
  361. if (!startFromScratch) {
  362. if (TextUtils.isEmpty(query)) {
  363. page = currentPage + 1;
  364. } else {
  365. page = currentSearchPage + 1;
  366. }
  367. }
  368. Map<String, Object> modifiedQueryMap = new HashMap<>(retrofitBucket.getQueryMap());
  369. modifiedQueryMap.put("page", page);
  370. modifiedQueryMap.put("perPage", 100);
  371. ncApi.getContactsWithSearchParam(
  372. credentials,
  373. retrofitBucket.getUrl(), modifiedQueryMap)
  374. .subscribeOn(Schedulers.newThread())
  375. .observeOn(AndroidSchedulers.mainThread())
  376. .retry(3)
  377. .subscribe(new Observer<Response>() {
  378. @Override
  379. public void onSubscribe(Disposable d) {
  380. contactsQueryDisposable = d;
  381. }
  382. @Override
  383. public void onNext(Response response) {
  384. if (response.body() != null) {
  385. ShareesOverall shareesOverall = (ShareesOverall) response.body();
  386. if (shareesOverall.getOcs().getData().getUsers() != null) {
  387. shareeHashSet.addAll(shareesOverall.getOcs().getData().getUsers());
  388. }
  389. if (shareesOverall.getOcs().getData().getExactUsers() != null &&
  390. shareesOverall.getOcs().getData().getExactUsers().getExactSharees() != null) {
  391. shareeHashSet.addAll(shareesOverall.getOcs().getData().
  392. getExactUsers().getExactSharees());
  393. }
  394. if (TextUtils.isEmpty((CharSequence) modifiedQueryMap.get("search"))) {
  395. canFetchFurther = !shareeHashSet.isEmpty();
  396. currentPage = (int) modifiedQueryMap.get("page");
  397. } else {
  398. canFetchSearchFurther = !shareeHashSet.isEmpty();
  399. currentSearchPage = (int) modifiedQueryMap.get("page");
  400. }
  401. Participant participant;
  402. List<AbstractFlexibleItem> newUserItemList = new ArrayList<>();
  403. newUserItemList.addAll(contactItems);
  404. for (Sharee sharee : shareeHashSet) {
  405. if (!sharee.getValue().getShareWith().equals(currentUser.getUsername())) {
  406. participant = new Participant();
  407. participant.setName(sharee.getLabel());
  408. String headerTitle;
  409. headerTitle = sharee.getLabel().substring(0, 1).toUpperCase();
  410. UserHeaderItem userHeaderItem;
  411. if (!userHeaderItems.containsKey(headerTitle)) {
  412. userHeaderItem = new UserHeaderItem(headerTitle);
  413. userHeaderItems.put(headerTitle, userHeaderItem);
  414. }
  415. participant.setUserId(sharee.getValue().getShareWith());
  416. UserItem newContactItem = new UserItem(participant, currentUser,
  417. userHeaderItems.get(headerTitle));
  418. if (!contactItems.contains(newContactItem)) {
  419. newUserItemList.add(newContactItem);
  420. }
  421. }
  422. }
  423. boolean shouldFilterManually = false;
  424. if (newUserItemList.size() == contactItems.size()) {
  425. shouldFilterManually = true;
  426. }
  427. contactItems = newUserItemList;
  428. userHeaderItems = new HashMap<>();
  429. Collections.sort(newUserItemList, (o1, o2) -> {
  430. String firstName;
  431. String secondName;
  432. if (o1 instanceof UserItem) {
  433. firstName = ((UserItem) o1).getModel().getName();
  434. } else {
  435. firstName = ((UserHeaderItem) o1).getModel();
  436. }
  437. if (o2 instanceof UserItem) {
  438. secondName = ((UserItem) o2).getModel().getName();
  439. } else {
  440. secondName = ((UserHeaderItem) o2).getModel();
  441. }
  442. return firstName.compareToIgnoreCase(secondName);
  443. });
  444. if (!shouldFilterManually) {
  445. adapter.updateDataSet(newUserItemList, false);
  446. } else {
  447. adapter.filterItems();
  448. adapter.onLoadMoreComplete(null);
  449. }
  450. searchItem.setVisible(newUserItemList.size() > 0);
  451. if (swipeRefreshLayout != null) {
  452. swipeRefreshLayout.setRefreshing(false);
  453. }
  454. if (isNewConversationView) {
  455. checkAndHandleDoneMenuItem();
  456. }
  457. }
  458. ;
  459. }
  460. @Override
  461. public void onError(Throwable e) {
  462. if (searchItem != null) {
  463. searchItem.setVisible(false);
  464. }
  465. if (e instanceof HttpException) {
  466. HttpException exception = (HttpException) e;
  467. switch (exception.code()) {
  468. case 401:
  469. if (getParentController() != null &&
  470. getParentController().getRouter() != null) {
  471. getParentController().getRouter().pushController((RouterTransaction.with
  472. (new WebViewLoginController(currentUser.getBaseUrl(),
  473. true))
  474. .pushChangeHandler(new VerticalChangeHandler())
  475. .popChangeHandler(new VerticalChangeHandler())));
  476. }
  477. break;
  478. default:
  479. break;
  480. }
  481. if (swipeRefreshLayout != null) {
  482. swipeRefreshLayout.setRefreshing(false);
  483. }
  484. }
  485. dispose(contactsQueryDisposable);
  486. }
  487. @Override
  488. public void onComplete() {
  489. if (swipeRefreshLayout != null) {
  490. swipeRefreshLayout.setRefreshing(false);
  491. }
  492. dispose(contactsQueryDisposable);
  493. alreadyFetching = false;
  494. }
  495. });
  496. }
  497. private void prepareViews() {
  498. layoutManager = new SmoothScrollLinearLayoutManager(getActivity());
  499. recyclerView.setLayoutManager(new SmoothScrollLinearLayoutManager(getActivity()));
  500. recyclerView.setHasFixedSize(true);
  501. recyclerView.setAdapter(adapter);
  502. swipeRefreshLayout.setOnRefreshListener(() -> fetchData(true));
  503. swipeRefreshLayout.setColorSchemeResources(R.color.colorPrimary);
  504. fastScroller.addOnScrollStateChangeListener(this);
  505. adapter.setFastScroller(fastScroller);
  506. fastScroller.setBubbleTextCreator(position -> {
  507. IFlexible abstractFlexibleItem = adapter.getItem(position);
  508. if (abstractFlexibleItem instanceof UserItem) {
  509. return ((UserItem) adapter.getItem(position)).getHeader().getModel();
  510. } else if (abstractFlexibleItem instanceof UserHeaderItem) {
  511. return ((UserHeaderItem) adapter.getItem(position)).getModel();
  512. } else {
  513. return "";
  514. }
  515. });
  516. }
  517. private void dispose(@Nullable Disposable disposable) {
  518. if (disposable != null && !disposable.isDisposed()) {
  519. disposable.dispose();
  520. } else if (disposable == null) {
  521. if (contactsQueryDisposable != null && !contactsQueryDisposable.isDisposed()) {
  522. contactsQueryDisposable.dispose();
  523. contactsQueryDisposable = null;
  524. }
  525. if (cacheQueryDisposable != null && !cacheQueryDisposable.isDisposed()) {
  526. cacheQueryDisposable.dispose();
  527. cacheQueryDisposable = null;
  528. }
  529. }
  530. }
  531. @Override
  532. public void onSaveViewState(@NonNull View view, @NonNull Bundle outState) {
  533. adapter.onSaveInstanceState(outState);
  534. super.onSaveViewState(view, outState);
  535. if (searchView != null && !TextUtils.isEmpty(searchView.getQuery())) {
  536. outState.putString(KEY_SEARCH_QUERY, searchView.getQuery().toString());
  537. }
  538. }
  539. @Override
  540. public void onRestoreViewState(@NonNull View view, @NonNull Bundle savedViewState) {
  541. super.onRestoreViewState(view, savedViewState);
  542. searchQuery = savedViewState.getString(KEY_SEARCH_QUERY, "");
  543. if (adapter != null) {
  544. adapter.onRestoreInstanceState(savedViewState);
  545. }
  546. }
  547. @Override
  548. public void onDestroy() {
  549. super.onDestroy();
  550. dispose(null);
  551. }
  552. @Override
  553. public boolean onQueryTextChange(String newText) {
  554. if (adapter.hasNewFilter(newText) || !TextUtils.isEmpty(searchQuery)) {
  555. if (!TextUtils.isEmpty(searchQuery)) {
  556. adapter.setFilter(searchQuery);
  557. adapter.filterItems();
  558. searchQuery = "";
  559. } else {
  560. adapter.setFilter(newText);
  561. if (TextUtils.isEmpty(newText)) {
  562. adapter.filterItems();
  563. } else {
  564. fetchData(true);
  565. }
  566. }
  567. }
  568. if (swipeRefreshLayout != null) {
  569. swipeRefreshLayout.setEnabled(!adapter.hasFilter());
  570. }
  571. return true;
  572. }
  573. @Override
  574. public boolean onQueryTextSubmit(String query) {
  575. return onQueryTextChange(query);
  576. }
  577. private void checkAndHandleDoneMenuItem() {
  578. if (adapter != null && doneMenuItem != null) {
  579. if (adapter.getSelectedItemCount() > 0 || isPublicCall) {
  580. if (!doneMenuItem.isVisible()) {
  581. doneMenuItem.setVisible(true);
  582. }
  583. } else {
  584. doneMenuItem.setVisible(false);
  585. }
  586. } else if (doneMenuItem != null) {
  587. doneMenuItem.setVisible(false);
  588. }
  589. }
  590. @Override
  591. protected String getTitle() {
  592. if (!isNewConversationView) {
  593. return getResources().getString(R.string.nc_app_name);
  594. } else {
  595. return getResources().getString(R.string.nc_select_contacts);
  596. }
  597. }
  598. @Override
  599. public void onFastScrollerStateChange(boolean scrolling) {
  600. swipeRefreshLayout.setEnabled(!scrolling);
  601. }
  602. private void prepareAndShowBottomSheetWithBundle(Bundle bundle) {
  603. if (view == null) {
  604. view = getActivity().getLayoutInflater().inflate(R.layout.bottom_sheet, null, false);
  605. }
  606. getChildRouter((ViewGroup) view).setRoot(
  607. RouterTransaction.with(new OperationsMenuController(bundle))
  608. .popChangeHandler(new VerticalChangeHandler())
  609. .pushChangeHandler(new VerticalChangeHandler()));
  610. if (bottomSheet == null) {
  611. bottomSheet = new BottomSheet.Builder(getActivity()).setView(view).create();
  612. }
  613. bottomSheet.setOnCancelListener(dialog -> {
  614. if (getActionBar() != null) {
  615. getActionBar().setDisplayHomeAsUpEnabled(true);
  616. }
  617. });
  618. bottomSheet.setOnShowListener(dialog -> eventBus.post(new BottomSheetLockEvent(false, 0,
  619. false, false)));
  620. bottomSheet.show();
  621. }
  622. @Subscribe(threadMode = ThreadMode.MAIN)
  623. public void onMessageEvent(BottomSheetLockEvent bottomSheetLockEvent) {
  624. if (bottomSheet != null) {
  625. if (!bottomSheetLockEvent.isCancelable()) {
  626. bottomSheet.setCancelable(bottomSheetLockEvent.isCancelable());
  627. } else {
  628. bottomSheet.setCancelable(bottomSheetLockEvent.isCancelable());
  629. if (bottomSheet.isShowing() && bottomSheetLockEvent.isCancel()) {
  630. new Handler().postDelayed(() -> {
  631. bottomSheet.setOnCancelListener(null);
  632. bottomSheet.cancel();
  633. }, bottomSheetLockEvent.getDelay());
  634. }
  635. }
  636. }
  637. }
  638. @Override
  639. protected void onDetach(@NonNull View view) {
  640. super.onDetach(view);
  641. eventBus.unregister(this);
  642. }
  643. @Override
  644. public boolean onItemClick(View view, int position) {
  645. if (adapter.getItem(position) instanceof UserItem) {
  646. if (!isNewConversationView) {
  647. UserItem userItem = (UserItem) adapter.getItem(position);
  648. RetrofitBucket retrofitBucket = ApiUtils.getRetrofitBucketForCreateRoom(currentUser.getBaseUrl(), "1",
  649. userItem.getModel().getUserId(), null);
  650. ncApi.createRoom(credentials,
  651. retrofitBucket.getUrl(), retrofitBucket.getQueryMap())
  652. .subscribeOn(Schedulers.newThread())
  653. .observeOn(AndroidSchedulers.mainThread())
  654. .subscribe(new Observer<RoomOverall>() {
  655. @Override
  656. public void onSubscribe(Disposable d) {
  657. }
  658. @Override
  659. public void onNext(RoomOverall roomOverall) {
  660. if (getActivity() != null) {
  661. Intent conversationIntent = new Intent(getActivity(), MagicCallActivity.class);
  662. Bundle bundle = new Bundle();
  663. bundle.putString(BundleKeys.KEY_ROOM_TOKEN, roomOverall.getOcs().getData().getToken());
  664. bundle.putString(BundleKeys.KEY_ROOM_ID, roomOverall.getOcs().getData().getRoomId());
  665. conversationIntent.putExtras(bundle);
  666. if (currentUser.hasSpreedCapabilityWithName("chat-v2")) {
  667. bundle.putString(BundleKeys.KEY_CONVERSATION_NAME,
  668. roomOverall.getOcs().getData().getDisplayName());
  669. if (getParentController() != null) {
  670. getParentController().getRouter().pushController((RouterTransaction.with(new ChatController(bundle))
  671. .pushChangeHandler(new HorizontalChangeHandler())
  672. .popChangeHandler(new HorizontalChangeHandler())));
  673. }
  674. } else {
  675. startActivity(conversationIntent);
  676. }
  677. }
  678. }
  679. @Override
  680. public void onError(Throwable e) {
  681. }
  682. @Override
  683. public void onComplete() {
  684. }
  685. });
  686. } else {
  687. ((UserItem) adapter.getItem(position)).flipItemSelection();
  688. adapter.toggleSelection(position);
  689. checkAndHandleDoneMenuItem();
  690. }
  691. }
  692. return true;
  693. }
  694. @Optional
  695. @OnClick(R.id.call_header_layout)
  696. void toggleCallHeader() {
  697. toggleNewCallHeaderVisibility(isPublicCall);
  698. isPublicCall = !isPublicCall;
  699. checkAndHandleDoneMenuItem();
  700. }
  701. private void toggleNewCallHeaderVisibility(boolean showInitialLayout) {
  702. if (showInitialLayout) {
  703. initialRelativeLayout.setVisibility(View.VISIBLE);
  704. secondaryRelativeLayout.setVisibility(View.GONE);
  705. } else {
  706. initialRelativeLayout.setVisibility(View.GONE);
  707. secondaryRelativeLayout.setVisibility(View.VISIBLE);
  708. }
  709. }
  710. @Override
  711. public void noMoreLoad(int newItemsSize) {
  712. }
  713. @Override
  714. public void onLoadMore(int lastPosition, int currentPage) {
  715. String query = "";
  716. if (searchView != null && !TextUtils.isEmpty(searchView.getQuery())) {
  717. query = searchView.getQuery().toString();
  718. }
  719. if (!alreadyFetching && ((searchView != null && searchView.isIconified() && canFetchFurther)
  720. || (!TextUtils.isEmpty(query) && canFetchSearchFurther))) {
  721. fetchData(false);
  722. } else {
  723. adapter.onLoadMoreComplete(null);
  724. }
  725. }
  726. }