/* * Nextcloud Talk application * * @author Mario Danic * Copyright (C) 2017-2018 Mario Danic * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ package com.nextcloud.talk.controllers; import android.content.ClipData; import android.content.ClipboardManager; import android.content.Context; import android.content.Intent; import android.graphics.Bitmap; import android.graphics.Color; import android.graphics.drawable.ColorDrawable; import android.graphics.drawable.Drawable; import android.os.Bundle; import android.os.Handler; import android.support.annotation.NonNull; import android.support.annotation.Nullable; import android.support.v7.widget.LinearLayoutManager; import android.support.v7.widget.RecyclerView; import android.text.TextUtils; import android.util.Log; import android.view.LayoutInflater; import android.view.Menu; import android.view.MenuInflater; import android.view.MenuItem; import android.view.View; import android.view.ViewGroup; import android.view.inputmethod.EditorInfo; import android.widget.AbsListView; import android.widget.ImageView; import com.bluelinelabs.conductor.RouterTransaction; import com.bluelinelabs.conductor.changehandler.HorizontalChangeHandler; import com.bumptech.glide.load.DataSource; import com.bumptech.glide.load.engine.DiskCacheStrategy; import com.bumptech.glide.load.engine.GlideException; import com.bumptech.glide.load.resource.bitmap.CircleCrop; import com.bumptech.glide.request.RequestListener; import com.bumptech.glide.request.RequestOptions; import com.bumptech.glide.request.target.Target; import com.nextcloud.talk.R; import com.nextcloud.talk.activities.CallActivity; import com.nextcloud.talk.adapters.messages.MagicIncomingTextMessageViewHolder; import com.nextcloud.talk.adapters.messages.MagicOutcomingTextMessageViewHolder; import com.nextcloud.talk.api.NcApi; import com.nextcloud.talk.application.NextcloudTalkApplication; import com.nextcloud.talk.callbacks.MentionAutocompleteCallback; import com.nextcloud.talk.controllers.base.BaseController; import com.nextcloud.talk.models.database.UserEntity; import com.nextcloud.talk.models.json.call.Call; import com.nextcloud.talk.models.json.call.CallOverall; import com.nextcloud.talk.models.json.chat.ChatMessage; import com.nextcloud.talk.models.json.chat.ChatOverall; import com.nextcloud.talk.models.json.generic.GenericOverall; import com.nextcloud.talk.models.json.mention.Mention; import com.nextcloud.talk.models.json.rooms.Room; import com.nextcloud.talk.models.json.rooms.RoomsOverall; import com.nextcloud.talk.presenters.MentionAutocompletePresenter; import com.nextcloud.talk.utils.ApiUtils; import com.nextcloud.talk.utils.KeyboardUtils; import com.nextcloud.talk.utils.bundle.BundleKeys; import com.nextcloud.talk.utils.database.user.UserUtils; import com.nextcloud.talk.utils.glide.GlideApp; import com.otaliastudios.autocomplete.Autocomplete; import com.otaliastudios.autocomplete.AutocompleteCallback; import com.otaliastudios.autocomplete.AutocompletePresenter; import com.otaliastudios.autocomplete.CharPolicy; import com.stfalcon.chatkit.commons.ImageLoader; import com.stfalcon.chatkit.commons.models.IMessage; import com.stfalcon.chatkit.messages.MessageInput; import com.stfalcon.chatkit.messages.MessagesList; import com.stfalcon.chatkit.messages.MessagesListAdapter; import com.stfalcon.chatkit.utils.DateFormatter; import com.webianks.library.PopupBubble; import org.parceler.Parcels; import java.io.IOException; import java.lang.reflect.Field; import java.util.ArrayList; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.concurrent.TimeUnit; import javax.inject.Inject; import autodagger.AutoInjector; import butterknife.BindView; import io.reactivex.Observer; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.disposables.Disposable; import io.reactivex.schedulers.Schedulers; import okhttp3.Cache; import retrofit2.Response; @AutoInjector(NextcloudTalkApplication.class) public class ChatController extends BaseController implements MessagesListAdapter.OnLoadMoreListener, MessagesListAdapter.Formatter, MessagesListAdapter.OnMessageLongClickListener { private static final String TAG = "ChatController"; @Inject NcApi ncApi; @Inject UserUtils userUtils; @Inject Cache cache; @BindView(R.id.input) MessageInput messageInput; @BindView(R.id.messagesList) MessagesList messagesList; @BindView(R.id.popupBubble) PopupBubble popupBubble; private List disposableList = new ArrayList<>(); private String conversationName; private String roomToken; private UserEntity conversationUser; private String roomPassword; private String credentials; private String baseUrl; private Call currentCall; private boolean inChat = false; private boolean historyRead = false; private int globalLastKnownFutureMessageId = -1; private int globalLastKnownPastMessageId = -1; private MessagesListAdapter adapter; private String myFirstMessage; private Autocomplete mentionAutocomplete; private LinearLayoutManager layoutManager; private boolean lookingIntoFuture = false; private int newMessagesCount = 0; private Boolean startCallFromNotification; /* TODO: - check push notifications */ public ChatController(Bundle args) { super(args); setHasOptionsMenu(true); NextcloudTalkApplication.getSharedApplication().getComponentApplication().inject(this); UserEntity currentUser = userUtils.getCurrentUser(); this.conversationName = args.getString(BundleKeys.KEY_CONVERSATION_NAME); if (args.containsKey(BundleKeys.KEY_USER_ENTITY)) { this.conversationUser = Parcels.unwrap(args.getParcelable(BundleKeys.KEY_USER_ENTITY)); } else { this.conversationUser = currentUser; } this.roomToken = args.getString(BundleKeys.KEY_ROOM_TOKEN, ""); if (args.containsKey(BundleKeys.KEY_ACTIVE_CONVERSATION)) { this.currentCall = Parcels.unwrap(args.getParcelable(BundleKeys.KEY_ACTIVE_CONVERSATION)); } this.baseUrl = args.getString(BundleKeys.KEY_MODIFIED_BASE_URL, ""); if (!TextUtils.isEmpty(baseUrl)) { conversationUser.setBaseUrl(baseUrl); conversationUser.setUserId("-1"); conversationUser.setDisplayName(currentUser.getDisplayName()); } else { baseUrl = conversationUser.getBaseUrl(); } this.roomPassword = args.getString(BundleKeys.KEY_CONVERSATION_PASSWORD, ""); this.startCallFromNotification = args.getBoolean(BundleKeys.KEY_FROM_NOTIFICATION_START_CALL); } private void handleFromNotification() { ncApi.getRooms(credentials, ApiUtils.getUrlForGetRooms(baseUrl)) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(new Observer() { @Override public void onSubscribe(Disposable d) { } @Override public void onNext(RoomsOverall roomsOverall) { for (Room room : roomsOverall.getOcs().getData()) { if (roomToken.equals(room.getRoomId())) { roomToken = room.getToken(); break; } } setupMentionAutocomplete(); joinRoomWithPassword(); } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }); } @Override protected View inflateView(@NonNull LayoutInflater inflater, @NonNull ViewGroup container) { return inflater.inflate(R.layout.controller_chat, container, false); } @Override protected void onViewBound(@NonNull View view) { super.onViewBound(view); boolean adapterWasNull = false; if (adapter == null) { try { cache.evictAll(); } catch (IOException e) { Log.e(TAG, "Failed to evict cache"); } adapterWasNull = true; MessagesListAdapter.HoldersConfig holdersConfig = new MessagesListAdapter.HoldersConfig(); holdersConfig.setIncoming(MagicIncomingTextMessageViewHolder.class, R.layout.item_custom_incoming_text_message); holdersConfig.setOutcoming(MagicOutcomingTextMessageViewHolder.class, R.layout.item_custom_outcoming_text_message); adapter = new MessagesListAdapter<>(conversationUser.getUserId(), holdersConfig, new ImageLoader() { @Override public void loadImage(ImageView imageView, String url) { GlideApp.with(NextcloudTalkApplication.getSharedApplication().getApplicationContext()) .asBitmap() .diskCacheStrategy(DiskCacheStrategy.NONE) .load(url) .centerInside() .override(imageView.getMeasuredWidth(), imageView.getMeasuredHeight()) .apply(RequestOptions.bitmapTransform(new CircleCrop())) .listener(new RequestListener() { @Override public boolean onLoadFailed(@Nullable GlideException e, Object model, Target target, boolean isFirstResource) { imageView.setVisibility(View.GONE); return true; } @Override public boolean onResourceReady(Bitmap resource, Object model, Target target, DataSource dataSource, boolean isFirstResource) { return false; } }) .into(imageView); } }); } messagesList.setAdapter(adapter); adapter.setLoadMoreListener(this); adapter.setDateHeadersFormatter(this::format); adapter.setOnMessageLongClickListener(this); layoutManager = (LinearLayoutManager) messagesList.getLayoutManager(); popupBubble.setRecyclerView(messagesList); popupBubble.setPopupBubbleListener(context -> { if (newMessagesCount != 0) { new Handler().postDelayed(() -> messagesList.smoothScrollToPosition(newMessagesCount - 1), 200); } }); messagesList.addOnScrollListener(new RecyclerView.OnScrollListener() { @Override public void onScrollStateChanged(RecyclerView recyclerView, int newState) { super.onScrollStateChanged(recyclerView, newState); if (newState == AbsListView.OnScrollListener.SCROLL_STATE_IDLE) { if (newMessagesCount != 0) { if (layoutManager.findFirstCompletelyVisibleItemPosition() < newMessagesCount) { newMessagesCount = 0; if (popupBubble.isShown()) { popupBubble.hide(); } } } } } }); messageInput.getInputEditText().setImeOptions(EditorInfo.IME_FLAG_NO_EXTRACT_UI); messageInput.setInputListener(input -> { sendMessage(input.toString()); return true; }); if (adapterWasNull && startCallFromNotification == null) { setupMentionAutocomplete(); joinRoomWithPassword(); } else if (adapterWasNull) { handleFromNotification(); } } private void setupMentionAutocomplete() { float elevation = 6f; Drawable backgroundDrawable = new ColorDrawable(Color.WHITE); AutocompletePresenter presenter = new MentionAutocompletePresenter(getApplicationContext(), roomToken); AutocompleteCallback callback = new MentionAutocompleteCallback(); mentionAutocomplete = Autocomplete.on(messageInput.getInputEditText()) .with(elevation) .with(backgroundDrawable) .with(new CharPolicy('@')) .with(presenter) .with(callback) .build(); } @Override protected void onAttach(@NonNull View view) { super.onAttach(view); if (getActionBar() != null) { getActionBar().setDisplayHomeAsUpEnabled(true); } if (mentionAutocomplete != null && mentionAutocomplete.isPopupShowing()) { mentionAutocomplete.dismissPopup(); } if (getActivity() != null) { new KeyboardUtils(getActivity(), getView()); } } @Override protected String getTitle() { return conversationName; } @Override public boolean handleBack() { if (getRouter().hasRootController()) { getRouter().popToRoot(new HorizontalChangeHandler()); } else { getRouter().setRoot(RouterTransaction.with(new MagicBottomNavigationController()) .pushChangeHandler(new HorizontalChangeHandler()) .popChangeHandler(new HorizontalChangeHandler())); } return true; } @Override public void onDestroy() { inChat = false; dispose(); super.onDestroy(); } private void dispose() { Disposable disposable; for (int i = 0; i < disposableList.size(); i++) { if ((disposable = disposableList.get(i)).isDisposed()) { disposable.dispose(); } } } private void joinRoomWithPassword() { String password = ""; if (!TextUtils.isEmpty(roomPassword)) { password = roomPassword; } if (conversationUser.getUserId().equals("-1")) { credentials = null; } else { credentials = ApiUtils.getCredentials(conversationUser.getUserId(), conversationUser.getToken()); } if (currentCall == null) { ncApi.joinRoom(credentials, ApiUtils.getUrlForRoomParticipants(baseUrl, roomToken), password) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .retry(3) .subscribe(new Observer() { @Override public void onSubscribe(Disposable d) { disposableList.add(d); } @Override public void onNext(CallOverall callOverall) { inChat = true; currentCall = callOverall.getOcs().getData(); startPing(); pullChatMessages(0); if (startCallFromNotification != null && startCallFromNotification) { startCallFromNotification = false; startACall(false); } } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }); } else { inChat = true; startPing(); pullChatMessages(0); } } private void setSenderId() { try { final Field senderId = adapter.getClass().getDeclaredField("senderId"); senderId.setAccessible(true); senderId.set(adapter, conversationUser.getUserId()); } catch (NoSuchFieldException e) { Log.e(TAG, "Failed to set sender id"); } catch (IllegalAccessException e) { Log.e(TAG, "Failed to access and set field"); } } private void sendMessage(String message) { Map fieldMap = new HashMap<>(); fieldMap.put("message", message); fieldMap.put("actorDisplayName", conversationUser.getDisplayName()); ncApi.sendChatMessage(credentials, ApiUtils.getUrlForChat(baseUrl, roomToken), fieldMap) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .retry(3, observable -> inChat) .subscribe(new Observer() { @Override public void onSubscribe(Disposable d) { } @Override public void onNext(GenericOverall genericOverall) { if (conversationUser.getUserId().equals("-1") && TextUtils.isEmpty(myFirstMessage)) { myFirstMessage = message; } if (popupBubble.isShown()) { popupBubble.hide(); } messagesList.smoothScrollToPosition(0); } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }); } private void startPing() { ncApi.pingCall(credentials, ApiUtils.getUrlForCallPing(baseUrl, roomToken)) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .repeatWhen(observable -> observable.delay(5000, TimeUnit.MILLISECONDS)) .takeWhile(observable -> inChat) .retry(3, observable -> inChat) .subscribe(new Observer() { @Override public void onSubscribe(Disposable d) { disposableList.add(d); } @Override public void onNext(GenericOverall genericOverall) { } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }); } private void pullChatMessages(int lookIntoFuture) { if (!lookingIntoFuture && lookIntoFuture == 1) { lookingIntoFuture = true; } Map fieldMap = new HashMap<>(); fieldMap.put("lookIntoFuture", lookIntoFuture); fieldMap.put("limit", 25); int lastKnown; if (lookIntoFuture == 1) { lastKnown = globalLastKnownFutureMessageId; } else { lastKnown = globalLastKnownPastMessageId; } if (lastKnown != -1) { fieldMap.put("lastKnownMessageId", lastKnown); } if (lookIntoFuture == 1) { ncApi.pullChatMessages(credentials, ApiUtils.getUrlForChat(baseUrl, roomToken), fieldMap) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .takeWhile(observable -> inChat) .retry(3, observable -> inChat) .subscribe(new Observer() { @Override public void onSubscribe(Disposable d) { disposableList.add(d); } @Override public void onNext(Response response) { processMessages(response, true); } @Override public void onError(Throwable e) { } @Override public void onComplete() { pullChatMessages(1); } }); } else { ncApi.pullChatMessages(credentials, ApiUtils.getUrlForChat(baseUrl, roomToken), fieldMap) .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .retry(3, observable -> inChat) .subscribe(new Observer() { @Override public void onSubscribe(Disposable d) { disposableList.add(d); } @Override public void onNext(Response response) { processMessages(response, false); } @Override public void onError(Throwable e) { } @Override public void onComplete() { } }); } } private void processMessages(Response response, boolean isFromTheFuture) { if (response.code() == 200) { ChatOverall chatOverall = (ChatOverall) response.body(); List chatMessageList = chatOverall.getOcs().getData(); if (!isFromTheFuture) { for (int i = 0; i < chatMessageList.size(); i++) { chatMessageList.get(i).setBaseUrl(conversationUser.getBaseUrl()); if (globalLastKnownPastMessageId == -1 || chatMessageList.get(i).getJsonMessageId() < globalLastKnownPastMessageId) { globalLastKnownPastMessageId = chatMessageList.get(i).getJsonMessageId(); } if (globalLastKnownFutureMessageId == -1) { if (chatMessageList.get(i).getJsonMessageId() > globalLastKnownFutureMessageId) { globalLastKnownFutureMessageId = chatMessageList.get(i).getJsonMessageId(); } } } adapter.addToEnd(chatMessageList, false); } else { for (int i = 0; i < chatMessageList.size(); i++) { chatMessageList.get(i).setBaseUrl(conversationUser.getBaseUrl()); if (conversationUser.getUserId().equals("-1") && !TextUtils.isEmpty(myFirstMessage)) { ChatMessage chatMessage = chatMessageList.get(i); if (chatMessage.getActorType().equals("guests") && chatMessage.getActorDisplayName().equals(conversationUser.getDisplayName())) { conversationUser.setUserId(chatMessage.getActorId()); setSenderId(); } } boolean shouldScroll = layoutManager.findFirstVisibleItemPosition() == 0 || adapter.getItemCount() == 0; if (!shouldScroll) { if (!popupBubble.isShown()) { newMessagesCount = 1; popupBubble.show(); } else if (popupBubble.isShown()) { newMessagesCount++; } } else { newMessagesCount = 0; } adapter.addToStart(chatMessageList.get(i), shouldScroll); } String xChatLastGivenHeader; if (response.headers().size() > 0 && !TextUtils.isEmpty((xChatLastGivenHeader = response.headers().get ("X-Chat-Last-Given")))) { globalLastKnownFutureMessageId = Integer.parseInt(xChatLastGivenHeader); } } if (!lookingIntoFuture) { pullChatMessages(1); } } else if (response.code() == 304 && !isFromTheFuture) { historyRead = true; if (!lookingIntoFuture) { pullChatMessages(1); } } } @Override public void onLoadMore(int page, int totalItemsCount) { if (!historyRead) { pullChatMessages(0); } } @Override public String format(Date date) { if (DateFormatter.isToday(date)) { return getResources().getString(R.string.nc_date_header_today); } else if (DateFormatter.isYesterday(date)) { return getResources().getString(R.string.nc_date_header_yesterday); } else { return DateFormatter.format(date, DateFormatter.Template.STRING_DAY_MONTH_YEAR); } } @Override public void onCreateOptionsMenu(Menu menu, MenuInflater inflater) { super.onCreateOptionsMenu(menu, inflater); inflater.inflate(R.menu.menu_conversation, menu); } @Override public boolean onOptionsItemSelected(@NonNull MenuItem item) { switch (item.getItemId()) { case android.R.id.home: inChat = false; if (getRouter().hasRootController()) { getRouter().popToRoot(new HorizontalChangeHandler()); } else { getRouter().setRoot(RouterTransaction.with(new MagicBottomNavigationController()) .pushChangeHandler(new HorizontalChangeHandler()) .popChangeHandler(new HorizontalChangeHandler())); } return true; case R.id.conversation_video_call: startACall(false); return true; case R.id.conversation_voice_call: startACall(true); return true; default: return super.onOptionsItemSelected(item); } } private void startACall(boolean isVoiceOnlyCall) { if (!isVoiceOnlyCall) { Intent videoCallIntent = getIntentForCall(false); if (videoCallIntent != null) { startActivity(videoCallIntent); } } else { Intent voiceCallIntent = getIntentForCall(true); if (voiceCallIntent != null) { startActivity(voiceCallIntent); } } } private Intent getIntentForCall(boolean isVoiceOnlyCall) { if (currentCall != null && !TextUtils.isEmpty(currentCall.getSessionId())) { Bundle bundle = new Bundle(); bundle.putString(BundleKeys.KEY_ROOM_TOKEN, roomToken); bundle.putParcelable(BundleKeys.KEY_USER_ENTITY, Parcels.wrap(conversationUser)); bundle.putString(BundleKeys.KEY_CONVERSATION_PASSWORD, roomPassword); bundle.putString(BundleKeys.KEY_CALL_SESSION, currentCall.getSessionId()); bundle.putString(BundleKeys.KEY_MODIFIED_BASE_URL, baseUrl); if (isVoiceOnlyCall) { bundle.putBoolean(BundleKeys.KEY_CALL_VOICE_ONLY, true); } Intent callIntent = new Intent(getActivity(), CallActivity.class); callIntent.putExtras(bundle); return callIntent; } else { return null; } } @Override public void onMessageLongClick(IMessage message) { if (getActivity() != null) { ClipboardManager clipboardManager = (android.content.ClipboardManager) getActivity().getSystemService(Context.CLIPBOARD_SERVICE); ClipData clipData = android.content.ClipData.newPlainText( getResources().getString(R.string.nc_app_name), message.getText()); if (clipboardManager != null) { clipboardManager.setPrimaryClip(clipData); } } } }