ConversationsActivity.java

   1/*
   2 * Copyright (c) 2018, Daniel Gultsch All rights reserved.
   3 *
   4 * Redistribution and use in source and binary forms, with or without modification,
   5 * are permitted provided that the following conditions are met:
   6 *
   7 * 1. Redistributions of source code must retain the above copyright notice, this
   8 * list of conditions and the following disclaimer.
   9 *
  10 * 2. Redistributions in binary form must reproduce the above copyright notice,
  11 * this list of conditions and the following disclaimer in the documentation and/or
  12 * other materials provided with the distribution.
  13 *
  14 * 3. Neither the name of the copyright holder nor the names of its contributors
  15 * may be used to endorse or promote products derived from this software without
  16 * specific prior written permission.
  17 *
  18 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
  19 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  20 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  21 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR
  22 * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  23 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  24 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
  25 * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  26 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
  27 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  28 */
  29
  30package eu.siacs.conversations.ui;
  31
  32import static eu.siacs.conversations.ui.ConversationFragment.REQUEST_DECRYPT_PGP;
  33
  34import android.Manifest;
  35import android.annotation.SuppressLint;
  36import android.app.Activity;
  37import android.app.Fragment;
  38import android.app.FragmentManager;
  39import android.app.FragmentTransaction;
  40import android.content.ActivityNotFoundException;
  41import android.content.ComponentName;
  42import android.content.Context;
  43import android.content.Intent;
  44import android.content.pm.PackageManager;
  45import android.graphics.Bitmap;
  46import android.net.Uri;
  47import android.os.Build;
  48import android.os.Bundle;
  49import android.provider.Settings;
  50import android.util.Log;
  51import android.util.Pair;
  52import android.view.KeyEvent;
  53import android.view.Menu;
  54import android.view.MenuItem;
  55import android.widget.Toast;
  56
  57import androidx.annotation.IdRes;
  58import androidx.annotation.NonNull;
  59import androidx.appcompat.app.ActionBar;
  60import androidx.appcompat.app.AlertDialog;
  61import androidx.core.app.ActivityCompat;
  62import androidx.core.content.ContextCompat;
  63import androidx.databinding.DataBindingUtil;
  64
  65import com.cheogram.android.DownloadDefaultStickers;
  66import com.cheogram.android.FinishOnboarding;
  67
  68import com.google.common.collect.ImmutableList;
  69
  70import io.michaelrocks.libphonenumber.android.NumberParseException;
  71import com.google.android.material.dialog.MaterialAlertDialogBuilder;
  72import com.google.android.material.color.MaterialColors;
  73
  74import org.openintents.openpgp.util.OpenPgpApi;
  75
  76import java.util.Arrays;
  77import java.util.ArrayList;
  78import java.util.HashSet;
  79import java.util.HashMap;
  80import java.util.List;
  81import java.util.Objects;
  82import java.util.Set;
  83import java.util.TreeMap;
  84import java.util.concurrent.RejectedExecutionException;
  85import java.util.concurrent.atomic.AtomicBoolean;
  86import java.util.stream.Collectors;
  87import java.util.stream.Stream;
  88
  89import eu.siacs.conversations.Config;
  90import eu.siacs.conversations.R;
  91import eu.siacs.conversations.crypto.OmemoSetting;
  92import eu.siacs.conversations.databinding.ActivityConversationsBinding;
  93import eu.siacs.conversations.entities.Account;
  94import eu.siacs.conversations.entities.Contact;
  95import eu.siacs.conversations.entities.Conversation;
  96import eu.siacs.conversations.entities.Conversational;
  97import eu.siacs.conversations.entities.ListItem.Tag;
  98import eu.siacs.conversations.persistance.FileBackend;
  99import eu.siacs.conversations.services.XmppConnectionService;
 100import eu.siacs.conversations.ui.interfaces.OnBackendConnected;
 101import eu.siacs.conversations.ui.interfaces.OnConversationArchived;
 102import eu.siacs.conversations.ui.interfaces.OnConversationRead;
 103import eu.siacs.conversations.ui.interfaces.OnConversationSelected;
 104import eu.siacs.conversations.ui.interfaces.OnConversationsListItemUpdated;
 105import eu.siacs.conversations.ui.util.ActivityResult;
 106import eu.siacs.conversations.ui.util.AvatarWorkerTask;
 107import eu.siacs.conversations.ui.util.ConversationMenuConfigurator;
 108import eu.siacs.conversations.ui.util.MenuDoubleTabUtil;
 109import eu.siacs.conversations.ui.util.PendingItem;
 110import eu.siacs.conversations.ui.util.ToolbarUtils;
 111import eu.siacs.conversations.ui.util.SendButtonTool;
 112import eu.siacs.conversations.utils.AccountUtils;
 113import eu.siacs.conversations.utils.ExceptionHelper;
 114import eu.siacs.conversations.utils.PhoneNumberUtilWrapper;
 115import eu.siacs.conversations.utils.SignupUtils;
 116import eu.siacs.conversations.utils.ThemeHelper;
 117import eu.siacs.conversations.utils.XmppUri;
 118import eu.siacs.conversations.xmpp.Jid;
 119import eu.siacs.conversations.xmpp.OnUpdateBlocklist;
 120
 121public class ConversationsActivity extends XmppActivity implements OnConversationSelected, OnConversationArchived, OnConversationsListItemUpdated, OnConversationRead, XmppConnectionService.OnAccountUpdate, XmppConnectionService.OnConversationUpdate, XmppConnectionService.OnRosterUpdate, OnUpdateBlocklist, XmppConnectionService.OnShowErrorToast, XmppConnectionService.OnAffiliationChanged {
 122
 123    public static final String ACTION_VIEW_CONVERSATION = "eu.siacs.conversations.action.VIEW";
 124    public static final String EXTRA_CONVERSATION = "conversationUuid";
 125    public static final String EXTRA_DOWNLOAD_UUID = "eu.siacs.conversations.download_uuid";
 126    public static final String EXTRA_AS_QUOTE = "eu.siacs.conversations.as_quote";
 127    public static final String EXTRA_NICK = "nick";
 128    public static final String EXTRA_IS_PRIVATE_MESSAGE = "pm";
 129    public static final String EXTRA_DO_NOT_APPEND = "do_not_append";
 130    public static final String EXTRA_POST_INIT_ACTION = "post_init_action";
 131    public static final String POST_ACTION_RECORD_VOICE = "record_voice";
 132    public static final String EXTRA_THREAD = "threadId";
 133    public static final String EXTRA_TYPE = "type";
 134    public static final String EXTRA_NODE = "node";
 135    public static final String EXTRA_JID = "jid";
 136
 137    private static final List<String> VIEW_AND_SHARE_ACTIONS = Arrays.asList(
 138            ACTION_VIEW_CONVERSATION,
 139            Intent.ACTION_SEND,
 140            Intent.ACTION_SEND_MULTIPLE
 141    );
 142
 143    public static final int REQUEST_OPEN_MESSAGE = 0x9876;
 144    public static final int REQUEST_PLAY_PAUSE = 0x5432;
 145    public static final int REQUEST_MICROPHONE = 0x5432f;
 146    public static final int DIALLER_INTEGRATION = 0x5432ff;
 147    public static final int REQUEST_DOWNLOAD_STICKERS = 0xbf8702;
 148
 149    public static final long DRAWER_ALL_CHATS = 1;
 150    public static final long DRAWER_UNREAD_CHATS = 2;
 151    public static final long DRAWER_DIRECT_MESSAGES = 3;
 152    public static final long DRAWER_MANAGE_ACCOUNT = 4;
 153    public static final long DRAWER_MANAGE_PHONE_ACCOUNTS = 5;
 154    public static final long DRAWER_CHANNELS = 6;
 155    public static final long DRAWER_SETTINGS = 7;
 156    public static final long DRAWER_START_CHAT = 8;
 157    public static final long DRAWER_START_CHAT_CONTACT = 9;
 158    public static final long DRAWER_START_CHAT_NEW = 10;
 159    public static final long DRAWER_START_CHAT_GROUP = 11;
 160    public static final long DRAWER_START_CHAT_PUBLIC = 12;
 161    public static final long DRAWER_START_CHAT_DISCOVER = 13;
 162
 163    //secondary fragment (when holding the conversation, must be initialized before refreshing the overview fragment
 164    private static final @IdRes
 165    int[] FRAGMENT_ID_NOTIFICATION_ORDER = {R.id.secondary_fragment, R.id.main_fragment};
 166    private final PendingItem<Intent> pendingViewIntent = new PendingItem<>();
 167    private final PendingItem<ActivityResult> postponedActivityResult = new PendingItem<>();
 168    private ActivityConversationsBinding binding;
 169    private boolean mActivityPaused = true;
 170    private final AtomicBoolean mRedirectInProcess = new AtomicBoolean(false);
 171    private boolean refreshForNewCaps = false;
 172    private Set<Jid> newCapsJids = new HashSet<>();
 173    private int mRequestCode = -1;
 174    private com.mikepenz.materialdrawer.widget.AccountHeaderView accountHeader;
 175    private Bundle savedState = null;
 176    private Tag selectedTag = null;
 177    private long mainFilter = DRAWER_ALL_CHATS;
 178    private boolean refreshAccounts = true;
 179
 180    private static boolean isViewOrShareIntent(Intent i) {
 181        Log.d(Config.LOGTAG, "action: " + (i == null ? null : i.getAction()));
 182        return i != null && VIEW_AND_SHARE_ACTIONS.contains(i.getAction()) && i.hasExtra(EXTRA_CONVERSATION);
 183    }
 184
 185    private static Intent createLauncherIntent(Context context) {
 186        final Intent intent = new Intent(context, ConversationsActivity.class);
 187        intent.setAction(Intent.ACTION_MAIN);
 188        intent.addCategory(Intent.CATEGORY_LAUNCHER);
 189        return intent;
 190    }
 191
 192    @Override
 193    protected void refreshUiReal() {
 194        invalidateOptionsMenu();
 195        for (@IdRes int id : FRAGMENT_ID_NOTIFICATION_ORDER) {
 196            refreshFragment(id);
 197        }
 198        refreshForNewCaps = false;
 199        newCapsJids.clear();
 200
 201        if (accountHeader == null) return;
 202
 203        final var accountUnreads = new HashMap<Account, Integer>();
 204        binding.drawer.apply(dr -> {
 205            final var items = binding.drawer.getItemAdapter().getAdapterItems();
 206            final var tags = new TreeMap<Tag, Integer>();
 207            final var conversations = new ArrayList<Conversation>();
 208            var totalUnread = 0;
 209            var dmUnread = 0;
 210            var channelUnread = 0;
 211            populateWithOrderedConversations(conversations, false, false);
 212            for (final var c : conversations) {
 213                final var unread = c.unreadCount();
 214                totalUnread += unread;
 215                if (c.getMode() == Conversation.MODE_MULTI) {
 216                    channelUnread += unread;
 217                } else {
 218                    dmUnread += unread;
 219                }
 220                var accountUnread = accountUnreads.get(c.getAccount());
 221                if (accountUnread == null) accountUnread = 0;
 222                accountUnreads.put(c.getAccount(), accountUnread + unread);
 223                for (final var tag : c.getTags(this)) {
 224                    if ("Channel".equals(tag.getName())) continue;
 225                    var count = tags.get(tag);
 226                    if (count == null) count = 0;
 227                    tags.put(tag, count + unread);
 228                }
 229            }
 230
 231            com.mikepenz.materialdrawer.util.MaterialDrawerSliderViewExtensionsKt.updateBadge(
 232                binding.drawer,
 233                DRAWER_UNREAD_CHATS,
 234                new com.mikepenz.materialdrawer.holder.StringHolder(totalUnread > 0 ? new Integer(totalUnread).toString() : null)
 235            );
 236
 237            com.mikepenz.materialdrawer.util.MaterialDrawerSliderViewExtensionsKt.updateBadge(
 238                binding.drawer,
 239                DRAWER_DIRECT_MESSAGES,
 240                new com.mikepenz.materialdrawer.holder.StringHolder(dmUnread > 0 ? new Integer(dmUnread).toString() : null)
 241            );
 242
 243            com.mikepenz.materialdrawer.util.MaterialDrawerSliderViewExtensionsKt.updateBadge(
 244                binding.drawer,
 245                DRAWER_CHANNELS,
 246                new com.mikepenz.materialdrawer.holder.StringHolder(channelUnread > 0 ? new Integer(channelUnread).toString() : null)
 247            );
 248
 249            long id = 1000;
 250            final var inDrawer = new HashMap<Tag, Long>();
 251            for (final var item : ImmutableList.copyOf(items)) {
 252                if (item.getIdentifier() >= 1000 && !tags.containsKey(item.getTag())) {
 253                    com.mikepenz.materialdrawer.util.MaterialDrawerSliderViewExtensionsKt.removeItems(binding.drawer, item);
 254                } else if (item.getIdentifier() >= 1000) {
 255                    inDrawer.put((Tag)item.getTag(), item.getIdentifier());
 256                    id = item.getIdentifier() + 1;
 257                }
 258            }
 259
 260            for (final var entry : tags.entrySet()) {
 261                final var badge = entry.getValue() > 0 ? entry.getValue().toString() : null;
 262                if (inDrawer.containsKey(entry.getKey())) {
 263                    com.mikepenz.materialdrawer.util.MaterialDrawerSliderViewExtensionsKt.updateBadge(
 264                        binding.drawer,
 265                        inDrawer.get(entry.getKey()),
 266                        new com.mikepenz.materialdrawer.holder.StringHolder(badge)
 267                    );
 268                } else {
 269                    final var item = new com.mikepenz.materialdrawer.model.SecondaryDrawerItem();
 270                    item.setIdentifier(id++);
 271                    item.setTag(entry.getKey());
 272                    com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(item, entry.getKey().getName());
 273                    if (badge != null) com.mikepenz.materialdrawer.model.interfaces.BadgeableKt.setBadgeText(item, badge);
 274                    final var color = MaterialColors.getColor(binding.drawer, com.google.android.material.R.attr.colorPrimaryContainer);
 275                    final var textColor = MaterialColors.getColor(binding.drawer, com.google.android.material.R.attr.colorOnPrimaryContainer);
 276                    item.setBadgeStyle(new com.mikepenz.materialdrawer.holder.BadgeStyle(com.mikepenz.materialdrawer.R.drawable.material_drawer_badge, color, color, textColor));
 277                    binding.drawer.getItemAdapter().add(binding.drawer.getItemAdapter().getGlobalPosition(5), item);
 278                }
 279            }
 280
 281            items.subList(5, 5 + tags.size()).sort((x, y) -> x.getTag() == null ? -1 : ((Comparable) x.getTag()).compareTo(y.getTag()));
 282            binding.drawer.getItemAdapter().getFastAdapter().notifyDataSetChanged();
 283            return kotlin.Unit.INSTANCE;
 284        });
 285
 286
 287        accountHeader.apply(ah -> {
 288            // if (!refreshAccounts) return kotlin.Unit.INSTANCE;
 289            refreshAccounts = false;
 290            final var accounts = xmppConnectionService.getAccounts();
 291            final var inHeader = new HashSet<>();
 292            for (final var p : ImmutableList.copyOf(accountHeader.getProfiles())) {
 293                if (p instanceof com.mikepenz.materialdrawer.model.ProfileSettingDrawerItem) continue;
 294                if (accounts.contains(p.getTag()) || (accounts.size() > 1 && p.getTag() == null)) {
 295                    inHeader.add(p.getTag());
 296                } else {
 297                    accountHeader.removeProfile(p);
 298                }
 299            }
 300
 301            if (accounts.size() > 1 && !inHeader.contains(null)) {
 302                final var all = new com.mikepenz.materialdrawer.model.ProfileDrawerItem();
 303                all.setIdentifier(100);
 304                com.mikepenz.materialdrawer.model.interfaces.DescribableKt.setDescriptionText(all, "All Accounts");
 305                com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(all, R.drawable.main_logo);
 306                accountHeader.addProfile(all, 0);
 307            }
 308
 309            accountHeader.removeProfileByIdentifier(DRAWER_MANAGE_PHONE_ACCOUNTS);
 310            final var hasPhoneAccounts = accounts.stream().anyMatch(a -> a.getGateways("pstn").size() > 0);
 311            if (hasPhoneAccounts) {
 312                final var phoneAccounts = new com.mikepenz.materialdrawer.model.ProfileSettingDrawerItem();
 313                phoneAccounts.setIdentifier(DRAWER_MANAGE_PHONE_ACCOUNTS);
 314                com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(phoneAccounts, "Manage Phone Accounts");
 315                com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(phoneAccounts, R.drawable.ic_call_24dp);
 316                accountHeader.addProfile(phoneAccounts, accountHeader.getProfiles().size() - 1);
 317            }
 318
 319            long id = 101;
 320            final boolean nightMode = Activities.isNightMode(this);
 321            for (final var a : accounts) {
 322                final var size = (int) getResources().getDimension(R.dimen.avatar_on_drawer);
 323                final var avatar = xmppConnectionService.getAvatarService().get(a, size, true);
 324                if (avatar == null) {
 325                    final var task = new AvatarWorkerTask(this, R.dimen.avatar_on_drawer);
 326                    try { task.execute(a); } catch (final RejectedExecutionException ignored) { }
 327                    refreshAccounts = true;
 328                }
 329                final var p = new com.mikepenz.materialdrawer.model.ProfileDrawerItem();
 330                p.setIdentifier(id++);
 331                p.setTag(a);
 332                com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(p, a.getDisplayName() == null ? "" : a.getDisplayName());
 333                com.mikepenz.materialdrawer.model.interfaces.DescribableKt.setDescriptionText(p, a.getJid().asBareJid().toString());
 334                if (avatar != null) com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconBitmap(p, FileBackend.drawDrawable(avatar).copy(Bitmap.Config.ARGB_8888, false));
 335                var color = SendButtonTool.getSendButtonColor(binding.drawer, a.getPresenceStatus());
 336                if (!a.isOnlineAndConnected()) {
 337                    if (a.getStatus().isError()) {
 338                        color = MaterialColors.harmonizeWithPrimary(this, ContextCompat.getColor(this, nightMode ? R.color.red_300 : R.color.red_800));
 339                    } else {
 340                        color = MaterialColors.getColor(binding.drawer, com.google.android.material.R.attr.colorOnSurface);
 341                    }
 342                }
 343                final var textColor = MaterialColors.getColor(binding.drawer, com.google.android.material.R.attr.colorOnPrimaryContainer);
 344                p.setBadgeStyle(new com.mikepenz.materialdrawer.holder.BadgeStyle(com.mikepenz.materialdrawer.R.drawable.material_drawer_badge, color, color, textColor));
 345                final var badgeNumber = accountUnreads.get(a);
 346                p.setBadge(new com.mikepenz.materialdrawer.holder.StringHolder(badgeNumber == null ? " " : badgeNumber.toString()));
 347                if (inHeader.contains(a)) {
 348                    accountHeader.updateProfile(p);
 349                } else {
 350                    accountHeader.addProfile(p, accountHeader.getProfiles().size() - (hasPhoneAccounts ? 2 : 1));
 351                }
 352            }
 353            return kotlin.Unit.INSTANCE;
 354        });
 355    }
 356
 357    @Override
 358    protected void onBackendConnected() {
 359        final var useSavedState = savedState;
 360        savedState = null;
 361        if (performRedirectIfNecessary(true)) {
 362            return;
 363        }
 364        xmppConnectionService.getNotificationService().setIsInForeground(true);
 365        final Intent intent = pendingViewIntent.pop();
 366        if (intent != null) {
 367            if (processViewIntent(intent)) {
 368                if (binding.secondaryFragment != null) {
 369                    notifyFragmentOfBackendConnected(R.id.main_fragment);
 370                }
 371                invalidateActionBarTitle();
 372                return;
 373            }
 374        }
 375        for (@IdRes int id : FRAGMENT_ID_NOTIFICATION_ORDER) {
 376            notifyFragmentOfBackendConnected(id);
 377        }
 378
 379        final ActivityResult activityResult = postponedActivityResult.pop();
 380        if (activityResult != null) {
 381            handleActivityResult(activityResult);
 382        }
 383
 384        invalidateActionBarTitle();
 385        if (binding.secondaryFragment != null && ConversationFragment.getConversation(this) == null) {
 386            Conversation conversation = ConversationsOverviewFragment.getSuggestion(this);
 387            if (conversation != null) {
 388                openConversation(conversation, null);
 389            }
 390        }
 391        showDialogsIfMainIsOverview();
 392
 393        if (accountHeader != null || binding == null || binding.drawer == null) {
 394            refreshUiReal();
 395            return;
 396        }
 397
 398        accountHeader = new com.mikepenz.materialdrawer.widget.AccountHeaderView(this);
 399        final var manageAccount = new com.mikepenz.materialdrawer.model.ProfileSettingDrawerItem();
 400        manageAccount.setIdentifier(DRAWER_MANAGE_ACCOUNT);
 401        com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(manageAccount, xmppConnectionService.getAccounts().size() > 1 ? "Manage Accounts" : "Manage Account");
 402        com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(manageAccount, R.drawable.ic_settings_24dp);
 403        accountHeader.addProfiles(manageAccount);
 404
 405        final var color = MaterialColors.getColor(binding.drawer, com.google.android.material.R.attr.colorPrimaryContainer);
 406        final var textColor = MaterialColors.getColor(binding.drawer, com.google.android.material.R.attr.colorOnPrimaryContainer);
 407
 408        final var allChats = new com.mikepenz.materialdrawer.model.PrimaryDrawerItem();
 409        allChats.setIdentifier(DRAWER_ALL_CHATS);
 410        com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(allChats, "All Chats");
 411        com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(allChats, R.drawable.ic_chat_24dp);
 412
 413        final var unreadChats = new com.mikepenz.materialdrawer.model.PrimaryDrawerItem();
 414        unreadChats.setIdentifier(DRAWER_UNREAD_CHATS);
 415        com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(unreadChats, "Unread Chats");
 416        com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(unreadChats, R.drawable.chat_unread_24dp);
 417        unreadChats.setBadgeStyle(new com.mikepenz.materialdrawer.holder.BadgeStyle(com.mikepenz.materialdrawer.R.drawable.material_drawer_badge, color, color, textColor));
 418
 419        final var directMessages = new com.mikepenz.materialdrawer.model.PrimaryDrawerItem();
 420        directMessages.setIdentifier(DRAWER_DIRECT_MESSAGES);
 421        com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(directMessages, "Direct Messages");
 422        com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(directMessages, R.drawable.ic_person_24dp);
 423        directMessages.setBadgeStyle(new com.mikepenz.materialdrawer.holder.BadgeStyle(com.mikepenz.materialdrawer.R.drawable.material_drawer_badge, color, color, textColor));
 424
 425        final var channels = new com.mikepenz.materialdrawer.model.PrimaryDrawerItem();
 426        channels.setIdentifier(DRAWER_CHANNELS);
 427        com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(channels, "Channels");
 428        com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(channels, R.drawable.ic_group_24dp);
 429        channels.setBadgeStyle(new com.mikepenz.materialdrawer.holder.BadgeStyle(com.mikepenz.materialdrawer.R.drawable.material_drawer_badge, color, color, textColor));
 430
 431        binding.drawer.getItemAdapter().add(
 432            allChats,
 433            unreadChats,
 434            directMessages,
 435            channels,
 436            new com.mikepenz.materialdrawer.model.DividerDrawerItem()
 437        );
 438
 439        final var settings = new com.mikepenz.materialdrawer.model.PrimaryDrawerItem();
 440        settings.setIdentifier(DRAWER_SETTINGS);
 441        settings.setSelectable(false);
 442        com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(settings, "Settings");
 443        com.mikepenz.materialdrawer.model.interfaces.IconableKt.setIconRes(settings, R.drawable.ic_settings_24dp);
 444        com.mikepenz.materialdrawer.util.MaterialDrawerSliderViewExtensionsKt.addStickyDrawerItems(binding.drawer, settings);
 445
 446        if (useSavedState != null) {
 447            mainFilter = useSavedState.getLong("mainFilter", DRAWER_ALL_CHATS);
 448            selectedTag = (Tag) useSavedState.getSerializable("selectedTag");
 449        }
 450        refreshUiReal();
 451        if (useSavedState != null) binding.drawer.setSavedInstance(useSavedState);
 452        accountHeader.attachToSliderView(binding.drawer);
 453        if (useSavedState != null) accountHeader.withSavedInstance(useSavedState);
 454
 455        if (mainFilter == DRAWER_ALL_CHATS && selectedTag == null) {
 456            binding.drawer.setSelectedItemIdentifier(DRAWER_ALL_CHATS);
 457        }
 458
 459        binding.drawer.setOnDrawerItemClickListener((v, drawerItem, pos) -> {
 460            final var id = drawerItem.getIdentifier();
 461            if (id != DRAWER_START_CHAT) binding.drawer.getExpandableExtension().collapse(false);
 462            if (id == DRAWER_SETTINGS) {
 463                startActivity(new Intent(this, eu.siacs.conversations.ui.activity.SettingsActivity.class));
 464                return false;
 465            } else if (id == DRAWER_START_CHAT_CONTACT) {
 466                launchStartConversation();
 467            } else if (id == DRAWER_START_CHAT_NEW) {
 468                launchStartConversation(R.id.create_contact);
 469            } else if (id == DRAWER_START_CHAT_GROUP) {
 470                launchStartConversation(R.id.create_private_group_chat);
 471            } else if (id == DRAWER_START_CHAT_PUBLIC) {
 472                launchStartConversation(R.id.create_public_channel);
 473            } else if (id == DRAWER_START_CHAT_DISCOVER) {
 474                launchStartConversation(R.id.discover_public_channels);
 475            } else if (id == DRAWER_ALL_CHATS || id == DRAWER_UNREAD_CHATS || id == DRAWER_DIRECT_MESSAGES || id == DRAWER_CHANNELS) {
 476                selectedTag = null;
 477                mainFilter = id;
 478                binding.drawer.getSelectExtension().deselect();
 479            } else if (id >= 1000) {
 480                selectedTag = (Tag) drawerItem.getTag();
 481            }
 482            binding.drawer.getSelectExtension().selectByIdentifier(mainFilter, false, true);
 483
 484            final var fm = getFragmentManager();
 485            while (fm.getBackStackEntryCount() > 0) {
 486                try {
 487                    fm.popBackStackImmediate();
 488                } catch (IllegalStateException e) {
 489                    break;
 490                }
 491            }
 492
 493            refreshUi();
 494            return false;
 495        });
 496
 497         accountHeader.setOnAccountHeaderListener((v, profile, isCurrent) -> {
 498            final var id = profile.getIdentifier();
 499            if (isCurrent) return false; // Ignore switching to already selected profile
 500
 501            if (id == DRAWER_MANAGE_ACCOUNT) {
 502                final Account account = (Account) accountHeader.getActiveProfile().getTag();
 503                if (account == null) {
 504                    AccountUtils.launchManageAccounts(this);
 505                } else {
 506                    switchToAccount(account);
 507                }
 508                return false;
 509            }
 510
 511            if (id == DRAWER_MANAGE_PHONE_ACCOUNTS) {
 512                final String[] permissions;
 513                if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.S) {
 514                    permissions = new String[]{Manifest.permission.RECORD_AUDIO, Manifest.permission.BLUETOOTH_CONNECT};
 515                } else {
 516                    permissions = new String[]{Manifest.permission.RECORD_AUDIO};
 517                }
 518                requestPermissions(permissions, REQUEST_MICROPHONE);
 519                return false;
 520            }
 521
 522            // Clicked on an actual profile
 523            if (profile.getTag() == null) {
 524                com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(manageAccount, "Manage Accounts");
 525            } else {
 526                com.mikepenz.materialdrawer.model.interfaces.NameableKt.setNameText(manageAccount, "Manage Account");
 527            }
 528            accountHeader.updateProfile(manageAccount);
 529
 530            final var fm = getFragmentManager();
 531            while (fm.getBackStackEntryCount() > 0) {
 532                try {
 533                    fm.popBackStackImmediate();
 534                } catch (IllegalStateException e) {
 535                    break;
 536                }
 537            }
 538
 539            refreshUi();
 540
 541            return false;
 542        });
 543
 544         accountHeader.setOnAccountHeaderProfileImageListener((v, profile, isCurrent) -> {
 545            if (isCurrent) {
 546                final Account account = (Account) accountHeader.getActiveProfile().getTag();
 547                if (account == null) {
 548                    AccountUtils.launchManageAccounts(this);
 549                } else {
 550                    switchToAccount(account);
 551                }
 552            }
 553            return false;
 554         });
 555    }
 556
 557    @Override
 558    public boolean colorCodeAccounts() {
 559        if (accountHeader != null) {
 560            final var active = accountHeader.getActiveProfile();
 561            if (active != null && active.getTag() != null) return false;
 562        }
 563        return super.colorCodeAccounts();
 564    }
 565
 566    @Override
 567    public void populateWithOrderedConversations(List<Conversation> list) {
 568        populateWithOrderedConversations(list, true, true);
 569    }
 570
 571    public void populateWithOrderedConversations(List<Conversation> list, final boolean tagFilter, final boolean sort) {
 572        if (sort) {
 573            super.populateWithOrderedConversations(list);
 574        } else {
 575            list.addAll(xmppConnectionService.getConversations());
 576        }
 577        if (accountHeader == null || accountHeader.getActiveProfile() == null) return;
 578
 579        final var selectedAccount =
 580            accountHeader.getActiveProfile().getTag() != null ?
 581            ((Account) accountHeader.getActiveProfile().getTag()).getUuid() :
 582            null;
 583
 584        for (final var c : ImmutableList.copyOf(list)) {
 585            if (mainFilter == DRAWER_CHANNELS && c.getMode() != Conversation.MODE_MULTI) {
 586                list.remove(c);
 587            } else if (mainFilter == DRAWER_DIRECT_MESSAGES && c.getMode() == Conversation.MODE_MULTI) {
 588                list.remove(c);
 589            } else if (mainFilter == DRAWER_UNREAD_CHATS && c.unreadCount() < 1) {
 590                list.remove(c);
 591            } else if (selectedAccount != null && !selectedAccount.equals(c.getAccount().getUuid())) {
 592                list.remove(c);
 593            } else if (selectedTag != null && tagFilter && !c.getTags(this).contains(selectedTag)) {
 594                list.remove(c);
 595            }
 596        }
 597    }
 598
 599    @Override
 600    public void launchStartConversation() {
 601        launchStartConversation(0);
 602    }
 603
 604    public void launchStartConversation(int goTo) {
 605        StartConversationActivity.launch(this, (Account) accountHeader.getActiveProfile().getTag(), selectedTag == null ? null : selectedTag.getName(), goTo);
 606    }
 607
 608    private boolean performRedirectIfNecessary(boolean noAnimation) {
 609        return performRedirectIfNecessary(null, noAnimation);
 610    }
 611
 612    private boolean performRedirectIfNecessary(final Conversation ignore, final boolean noAnimation) {
 613        if (xmppConnectionService == null) {
 614            return false;
 615        }
 616
 617        boolean isConversationsListEmpty = xmppConnectionService.isConversationsListEmpty(ignore);
 618        if (isConversationsListEmpty && mRedirectInProcess.compareAndSet(false, true)) {
 619            final Intent intent = SignupUtils.getRedirectionIntent(this);
 620            if (noAnimation) {
 621                intent.addFlags(Intent.FLAG_ACTIVITY_NO_ANIMATION);
 622            }
 623            runOnUiThread(() -> {
 624                startActivity(intent);
 625                if (noAnimation) {
 626                    overridePendingTransition(0, 0);
 627                }
 628            });
 629        }
 630        return mRedirectInProcess.get();
 631    }
 632
 633    private void showDialogsIfMainIsOverview() {
 634        Pair<Account, Account> incomplete = null;
 635        if (xmppConnectionService != null && (incomplete = xmppConnectionService.onboardingIncomplete()) != null) {
 636            FinishOnboarding.finish(xmppConnectionService, this, incomplete.first, incomplete.second);
 637        }
 638        if (xmppConnectionService == null || xmppConnectionService.isOnboarding()) {
 639            return;
 640        }
 641        final Fragment fragment = getFragmentManager().findFragmentById(R.id.main_fragment);
 642        if (fragment instanceof ConversationsOverviewFragment) {
 643            if (ExceptionHelper.checkForCrash(this)) return;
 644            if (offerToSetupDiallerIntegration()) return;
 645            if (offerToDownloadStickers()) return;
 646            if (openBatteryOptimizationDialogIfNeeded()) return;
 647            requestNotificationPermissionIfNeeded();
 648            xmppConnectionService.rescanStickers();
 649        }
 650    }
 651
 652    private String getBatteryOptimizationPreferenceKey() {
 653        @SuppressLint("HardwareIds") String device = Settings.Secure.getString(getContentResolver(), Settings.Secure.ANDROID_ID);
 654        return "show_battery_optimization" + (device == null ? "" : device);
 655    }
 656
 657    private void setNeverAskForBatteryOptimizationsAgain() {
 658        getPreferences().edit().putBoolean(getBatteryOptimizationPreferenceKey(), false).apply();
 659    }
 660
 661    private boolean openBatteryOptimizationDialogIfNeeded() {
 662        if (isOptimizingBattery() && getPreferences().getBoolean(getBatteryOptimizationPreferenceKey(), true)) {
 663            final MaterialAlertDialogBuilder builder = new MaterialAlertDialogBuilder(this);
 664            builder.setTitle(R.string.battery_optimizations_enabled);
 665            builder.setMessage(getString(R.string.battery_optimizations_enabled_dialog, getString(R.string.app_name)));
 666            builder.setPositiveButton(R.string.next, (dialog, which) -> {
 667                final Intent intent = new Intent(Settings.ACTION_REQUEST_IGNORE_BATTERY_OPTIMIZATIONS);
 668                final Uri uri = Uri.parse("package:" + getPackageName());
 669                intent.setData(uri);
 670                try {
 671                    startActivityForResult(intent, REQUEST_BATTERY_OP);
 672                } catch (final ActivityNotFoundException e) {
 673                    Toast.makeText(this, R.string.device_does_not_support_battery_op, Toast.LENGTH_SHORT).show();
 674                }
 675            });
 676            builder.setOnDismissListener(dialog -> setNeverAskForBatteryOptimizationsAgain());
 677            final AlertDialog dialog = builder.create();
 678            dialog.setCanceledOnTouchOutside(false);
 679            dialog.show();
 680            return true;
 681        }
 682        return false;
 683    }
 684
 685    private void requestNotificationPermissionIfNeeded() {
 686        if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.TIRAMISU && ActivityCompat.checkSelfPermission(this, Manifest.permission.POST_NOTIFICATIONS) != PackageManager.PERMISSION_GRANTED) {
 687            requestPermissions(new String[]{Manifest.permission.POST_NOTIFICATIONS}, REQUEST_POST_NOTIFICATION);
 688        }
 689    }
 690
 691    private boolean offerToDownloadStickers() {
 692        int offered = getPreferences().getInt("default_stickers_offered", 0);
 693        if (offered > 0) return false;
 694        getPreferences().edit().putInt("default_stickers_offered", 1).apply();
 695
 696        AlertDialog.Builder builder = new AlertDialog.Builder(this);
 697        builder.setTitle("Download Stickers?");
 698        builder.setMessage("Would you like to download some default sticker packs?");
 699        builder.setPositiveButton(R.string.yes, (dialog, which) -> {
 700            if (hasStoragePermission(REQUEST_DOWNLOAD_STICKERS)) {
 701                downloadStickers();
 702            }
 703        });
 704        builder.setNegativeButton(R.string.no, (dialog, which) -> {
 705            showDialogsIfMainIsOverview();
 706        });
 707        final AlertDialog dialog = builder.create();
 708        dialog.setCanceledOnTouchOutside(false);
 709        dialog.show();
 710        return true;
 711    }
 712
 713    private boolean offerToSetupDiallerIntegration() {
 714        if (mRequestCode == DIALLER_INTEGRATION) {
 715            mRequestCode = -1;
 716            return true;
 717        }
 718        if (Build.VERSION.SDK_INT < 23) return false;
 719        if (Build.VERSION.SDK_INT >= 33) {
 720            if (!getPackageManager().hasSystemFeature(PackageManager.FEATURE_TELECOM) && !getPackageManager().hasSystemFeature(PackageManager.FEATURE_CONNECTION_SERVICE)) return false;
 721        } else {
 722            if (!getPackageManager().hasSystemFeature(PackageManager.FEATURE_CONNECTION_SERVICE)) return false;
 723        }
 724
 725        Set<String> pstnGateways = xmppConnectionService.getAccounts().stream()
 726            .flatMap(a -> a.getGateways("pstn").stream())
 727            .map(a -> a.getJid().asBareJid().toString()).collect(Collectors.toSet());
 728
 729        if (pstnGateways.size() < 1) return false;
 730        Set<String> fromPrefs = getPreferences().getStringSet("pstn_gateways", Set.of("UPGRADE"));
 731        getPreferences().edit().putStringSet("pstn_gateways", pstnGateways).apply();
 732        pstnGateways.removeAll(fromPrefs);
 733        if (pstnGateways.size() < 1) return false;
 734
 735        if (fromPrefs.contains("UPGRADE")) return false;
 736
 737        AlertDialog.Builder builder = new AlertDialog.Builder(this);
 738        builder.setTitle("Dialler Integration");
 739        builder.setMessage("Cheogram Android is able to integrate with your system's dialler app to allow dialling calls via your configured gateway " + String.join(", ", pstnGateways) + ".\n\nEnabling this integration will require granting microphone permission to the app.  Would you like to enable it now?");
 740        builder.setPositiveButton(R.string.yes, (dialog, which) -> {
 741            final String[] permissions;
 742            if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.S) {
 743                permissions = new String[]{Manifest.permission.RECORD_AUDIO, Manifest.permission.BLUETOOTH_CONNECT};
 744            } else {
 745                permissions = new String[]{Manifest.permission.RECORD_AUDIO};
 746            }
 747            requestPermissions(permissions, REQUEST_MICROPHONE);
 748        });
 749        builder.setNegativeButton(R.string.no, (dialog, which) -> {
 750            showDialogsIfMainIsOverview();
 751        });
 752        final AlertDialog dialog = builder.create();
 753        dialog.setCanceledOnTouchOutside(false);
 754        dialog.show();
 755        return true;
 756    }
 757
 758    private void notifyFragmentOfBackendConnected(@IdRes int id) {
 759        final Fragment fragment = getFragmentManager().findFragmentById(id);
 760        if (fragment instanceof OnBackendConnected callback) {
 761            callback.onBackendConnected();
 762        }
 763    }
 764
 765    private void refreshFragment(@IdRes int id) {
 766        final Fragment fragment = getFragmentManager().findFragmentById(id);
 767        if (fragment instanceof XmppFragment xmppFragment) {
 768            xmppFragment.refresh();
 769            if (refreshForNewCaps) xmppFragment.refreshForNewCaps(newCapsJids);
 770        }
 771    }
 772
 773    private boolean processViewIntent(Intent intent) {
 774        final String uuid = intent.getStringExtra(EXTRA_CONVERSATION);
 775        final Conversation conversation = uuid != null ? xmppConnectionService.findConversationByUuid(uuid) : null;
 776        if (conversation == null) {
 777            Log.d(Config.LOGTAG, "unable to view conversation with uuid:" + uuid);
 778            return false;
 779        }
 780        openConversation(conversation, intent.getExtras());
 781        return true;
 782    }
 783
 784    @Override
 785    public void onRequestPermissionsResult(int requestCode, @NonNull String[] permissions, @NonNull int[] grantResults) {
 786        super.onRequestPermissionsResult(requestCode, permissions, grantResults);
 787        UriHandlerActivity.onRequestPermissionResult(this, requestCode, grantResults);
 788        if (grantResults.length > 0) {
 789            if (grantResults[0] == PackageManager.PERMISSION_GRANTED) {
 790                switch (requestCode) {
 791                    case REQUEST_OPEN_MESSAGE:
 792                        refreshUiReal();
 793                        ConversationFragment.openPendingMessage(this);
 794                        break;
 795                    case REQUEST_PLAY_PAUSE:
 796                        ConversationFragment.startStopPending(this);
 797                        break;
 798                    case REQUEST_MICROPHONE:
 799                        Intent intent = new Intent();
 800                        intent.setComponent(new ComponentName("com.android.server.telecom",
 801                            "com.android.server.telecom.settings.EnableAccountPreferenceActivity"));
 802                        try {
 803                            startActivityForResult(intent, DIALLER_INTEGRATION);
 804                        } catch (ActivityNotFoundException e) {
 805                            displayToast("Dialler integration not available on your OS");
 806                        }
 807                        break;
 808                    case REQUEST_DOWNLOAD_STICKERS:
 809                        downloadStickers();
 810                        break;
 811                }
 812            } else {
 813                showDialogsIfMainIsOverview();
 814            }
 815        } else {
 816            showDialogsIfMainIsOverview();
 817        }
 818    }
 819
 820    private void downloadStickers() {
 821        Intent intent = new Intent(this, DownloadDefaultStickers.class);
 822        intent.putExtra("tor", xmppConnectionService.useTorToConnect());
 823        ContextCompat.startForegroundService(this, intent);
 824        displayToast("Sticker download started");
 825        showDialogsIfMainIsOverview();
 826    }
 827
 828    @Override
 829    public void onActivityResult(int requestCode, int resultCode, final Intent data) {
 830        super.onActivityResult(requestCode, resultCode, data);
 831
 832        if (requestCode == DIALLER_INTEGRATION) {
 833            mRequestCode = requestCode;
 834            try {
 835                startActivity(new Intent(android.telecom.TelecomManager.ACTION_CHANGE_PHONE_ACCOUNTS));
 836            } catch (ActivityNotFoundException e) {
 837                displayToast("Dialler integration not available on your OS");
 838            }
 839            return;
 840        }
 841
 842        ActivityResult activityResult = ActivityResult.of(requestCode, resultCode, data);
 843        if (xmppConnectionService != null) {
 844            handleActivityResult(activityResult);
 845        } else {
 846            this.postponedActivityResult.push(activityResult);
 847        }
 848    }
 849
 850    private void handleActivityResult(final ActivityResult activityResult) {
 851        if (activityResult.resultCode == Activity.RESULT_OK) {
 852            handlePositiveActivityResult(activityResult.requestCode, activityResult.data);
 853        } else {
 854            handleNegativeActivityResult(activityResult.requestCode);
 855        }
 856        if (activityResult.requestCode == REQUEST_BATTERY_OP) {
 857            // the result code is always 0 even when battery permission were granted
 858            requestNotificationPermissionIfNeeded();
 859            XmppConnectionService.toggleForegroundService(xmppConnectionService);
 860        }
 861    }
 862
 863    private void handleNegativeActivityResult(int requestCode) {
 864        Conversation conversation = ConversationFragment.getConversationReliable(this);
 865        switch (requestCode) {
 866            case REQUEST_DECRYPT_PGP:
 867                if (conversation == null) {
 868                    break;
 869                }
 870                conversation.getAccount().getPgpDecryptionService().giveUpCurrentDecryption();
 871                break;
 872            case REQUEST_BATTERY_OP:
 873                setNeverAskForBatteryOptimizationsAgain();
 874                break;
 875        }
 876    }
 877
 878    private void handlePositiveActivityResult(int requestCode, final Intent data) {
 879        Conversation conversation = ConversationFragment.getConversationReliable(this);
 880        if (conversation == null) {
 881            Log.d(Config.LOGTAG, "conversation not found");
 882            return;
 883        }
 884        switch (requestCode) {
 885            case REQUEST_DECRYPT_PGP:
 886                conversation.getAccount().getPgpDecryptionService().continueDecryption(data);
 887                break;
 888            case REQUEST_CHOOSE_PGP_ID:
 889                long id = data.getLongExtra(OpenPgpApi.EXTRA_SIGN_KEY_ID, 0);
 890                if (id != 0) {
 891                    conversation.getAccount().setPgpSignId(id);
 892                    announcePgp(conversation.getAccount(), null, null, onOpenPGPKeyPublished);
 893                } else {
 894                    choosePgpSignId(conversation.getAccount());
 895                }
 896                break;
 897            case REQUEST_ANNOUNCE_PGP:
 898                announcePgp(conversation.getAccount(), conversation, data, onOpenPGPKeyPublished);
 899                break;
 900        }
 901    }
 902
 903    @Override
 904    protected void onCreate(final Bundle savedInstanceState) {
 905        super.onCreate(savedInstanceState);
 906        savedState = savedInstanceState;
 907        ConversationMenuConfigurator.reloadFeatures(this);
 908        OmemoSetting.load(this);
 909        this.binding = DataBindingUtil.setContentView(this, R.layout.activity_conversations);
 910        Activities.setStatusAndNavigationBarColors(this, binding.getRoot());
 911        setSupportActionBar(binding.toolbar);
 912        configureActionBar(getSupportActionBar());
 913        this.getFragmentManager().addOnBackStackChangedListener(this::invalidateActionBarTitle);
 914        this.getFragmentManager().addOnBackStackChangedListener(this::showDialogsIfMainIsOverview);
 915        this.initializeFragments();
 916        this.invalidateActionBarTitle();
 917        final Intent intent;
 918        if (savedInstanceState == null) {
 919            intent = getIntent();
 920        } else {
 921            intent = savedInstanceState.getParcelable("intent");
 922        }
 923        if (isViewOrShareIntent(intent)) {
 924            pendingViewIntent.push(intent);
 925            setIntent(createLauncherIntent(this));
 926        }
 927    }
 928
 929    @Override
 930    public boolean onCreateOptionsMenu(Menu menu) {
 931        getMenuInflater().inflate(R.menu.activity_conversations, menu);
 932        final MenuItem qrCodeScanMenuItem = menu.findItem(R.id.action_scan_qr_code);
 933        if (qrCodeScanMenuItem != null) {
 934            if (isCameraFeatureAvailable() && (xmppConnectionService == null || !xmppConnectionService.isOnboarding())) {
 935                Fragment fragment = getFragmentManager().findFragmentById(R.id.main_fragment);
 936                boolean visible = getResources().getBoolean(R.bool.show_qr_code_scan)
 937                        && fragment instanceof ConversationsOverviewFragment;
 938                qrCodeScanMenuItem.setVisible(visible);
 939            } else {
 940                qrCodeScanMenuItem.setVisible(false);
 941            }
 942        }
 943        return super.onCreateOptionsMenu(menu);
 944    }
 945
 946    @Override
 947    public void onConversationSelected(Conversation conversation) {
 948        clearPendingViewIntent();
 949        if (ConversationFragment.getConversation(this) == conversation) {
 950            Log.d(Config.LOGTAG, "ignore onConversationSelected() because conversation is already open");
 951            return;
 952        }
 953        openConversation(conversation, null);
 954    }
 955
 956    public void clearPendingViewIntent() {
 957        if (pendingViewIntent.clear()) {
 958            Log.e(Config.LOGTAG, "cleared pending view intent");
 959        }
 960    }
 961
 962    private void displayToast(final String msg) {
 963        runOnUiThread(() -> Toast.makeText(ConversationsActivity.this, msg, Toast.LENGTH_SHORT).show());
 964    }
 965
 966    @Override
 967    public void onAffiliationChangedSuccessful(Jid jid) {
 968
 969    }
 970
 971    @Override
 972    public void onAffiliationChangeFailed(Jid jid, int resId) {
 973        displayToast(getString(resId, jid.asBareJid().toString()));
 974    }
 975
 976    private void openConversation(Conversation conversation, Bundle extras) {
 977        final FragmentManager fragmentManager = getFragmentManager();
 978        executePendingTransactions(fragmentManager);
 979        ConversationFragment conversationFragment = (ConversationFragment) fragmentManager.findFragmentById(R.id.secondary_fragment);
 980        final boolean mainNeedsRefresh;
 981        if (conversationFragment == null) {
 982            mainNeedsRefresh = false;
 983            final Fragment mainFragment = fragmentManager.findFragmentById(R.id.main_fragment);
 984            if (mainFragment instanceof ConversationFragment) {
 985                conversationFragment = (ConversationFragment) mainFragment;
 986            } else {
 987                conversationFragment = new ConversationFragment();
 988                FragmentTransaction fragmentTransaction = fragmentManager.beginTransaction();
 989                fragmentTransaction.replace(R.id.main_fragment, conversationFragment);
 990                fragmentTransaction.addToBackStack(null);
 991                try {
 992                    fragmentTransaction.commit();
 993                } catch (IllegalStateException e) {
 994                    Log.w(Config.LOGTAG, "sate loss while opening conversation", e);
 995                    //allowing state loss is probably fine since view intents et all are already stored and a click can probably be 'ignored'
 996                    return;
 997                }
 998            }
 999        } else {
1000            mainNeedsRefresh = true;
1001        }
1002        conversationFragment.reInit(conversation, extras == null ? new Bundle() : extras);
1003        if (mainNeedsRefresh) {
1004            refreshFragment(R.id.main_fragment);
1005        }
1006        invalidateActionBarTitle();
1007    }
1008
1009    private static void executePendingTransactions(final FragmentManager fragmentManager) {
1010        try {
1011            fragmentManager.executePendingTransactions();
1012        } catch (final Exception e) {
1013            Log.e(Config.LOGTAG,"unable to execute pending fragment transactions");
1014        }
1015    }
1016
1017    public boolean onXmppUriClicked(Uri uri) {
1018        XmppUri xmppUri = new XmppUri(uri);
1019        if (xmppUri.isValidJid() && !xmppUri.hasFingerprints()) {
1020            final Conversation conversation = xmppConnectionService.findUniqueConversationByJid(xmppUri);
1021            if (conversation != null) {
1022                if (xmppUri.getParameter("password") != null) {
1023                    xmppConnectionService.providePasswordForMuc(conversation, xmppUri.getParameter("password"));
1024                }
1025                if (xmppUri.isAction("command")) {
1026                    startCommand(conversation.getAccount(), xmppUri.getJid(), xmppUri.getParameter("node"));
1027                } else {
1028                    Bundle extras = new Bundle();
1029                    extras.putString(Intent.EXTRA_TEXT, xmppUri.getBody());
1030                    if (xmppUri.isAction("message")) extras.putString(EXTRA_POST_INIT_ACTION, "message");
1031                    openConversation(conversation, extras);
1032                }
1033                return true;
1034            }
1035        }
1036        return false;
1037    }
1038
1039    public boolean onTelUriClicked(Uri uri, Account acct) {
1040        final String tel;
1041        try {
1042            tel = PhoneNumberUtilWrapper.normalize(this, uri.getSchemeSpecificPart());
1043        } catch (final IllegalArgumentException | NumberParseException | NullPointerException e) {
1044            return false;
1045        }
1046
1047        Set<String> gateways = (acct == null ? xmppConnectionService.getAccounts().stream() : List.of(acct).stream()).flatMap(account ->
1048            Stream.concat(
1049                account.getGateways("pstn").stream(),
1050                account.getGateways("sms").stream()
1051            )
1052        ).map(a -> a.getJid().asBareJid().toString()).collect(Collectors.toSet());
1053
1054        for (String gateway : gateways) {
1055            if (onXmppUriClicked(Uri.parse("xmpp:" + tel + "@" + gateway))) return true;
1056        }
1057
1058        if (gateways.size() == 1 && acct != null) {
1059            openConversation(xmppConnectionService.findOrCreateConversation(acct, Jid.ofLocalAndDomain(tel, gateways.iterator().next()), false, true), null);
1060            return true;
1061        }
1062
1063        return false;
1064    }
1065
1066    @Override
1067    public boolean onOptionsItemSelected(MenuItem item) {
1068        if (MenuDoubleTabUtil.shouldIgnoreTap()) {
1069            return false;
1070        }
1071        switch (item.getItemId()) {
1072            case android.R.id.home:
1073                FragmentManager fm = getFragmentManager();
1074                if (android.os.Build.VERSION.SDK_INT >= 26) {
1075                    Fragment f = fm.getFragments().get(fm.getFragments().size() - 1);
1076                    if (f != null && f instanceof ConversationFragment) {
1077                        if (((ConversationFragment) f).onBackPressed()) {
1078                            return true;
1079                        }
1080                    }
1081                }
1082                if (fm.getBackStackEntryCount() > 0) {
1083                    try {
1084                        fm.popBackStack();
1085                    } catch (IllegalStateException e) {
1086                        Log.w(Config.LOGTAG, "Unable to pop back stack after pressing home button");
1087                    }
1088                    return true;
1089                } else {
1090                    if (binding.drawer != null) binding.drawer.getDrawerLayout().openDrawer(binding.drawer);
1091                    return true;
1092                }
1093            case R.id.action_scan_qr_code:
1094                UriHandlerActivity.scan(this);
1095                return true;
1096            case R.id.action_search_all_conversations:
1097                startActivity(new Intent(this, SearchActivity.class));
1098                return true;
1099            case R.id.action_search_this_conversation:
1100                final Conversation conversation = ConversationFragment.getConversation(this);
1101                if (conversation == null) {
1102                    return true;
1103                }
1104                final Intent intent = new Intent(this, SearchActivity.class);
1105                intent.putExtra(SearchActivity.EXTRA_CONVERSATION_UUID, conversation.getUuid());
1106                startActivity(intent);
1107                return true;
1108        }
1109        return super.onOptionsItemSelected(item);
1110    }
1111
1112    @Override
1113    public boolean onKeyDown(final int keyCode, final KeyEvent keyEvent) {
1114        if (keyCode == KeyEvent.KEYCODE_DPAD_UP && keyEvent.isCtrlPressed()) {
1115            final ConversationFragment conversationFragment = ConversationFragment.get(this);
1116            if (conversationFragment != null && conversationFragment.onArrowUpCtrlPressed()) {
1117                return true;
1118            }
1119        }
1120        return super.onKeyDown(keyCode, keyEvent);
1121    }
1122
1123    @Override
1124    public void onSaveInstanceState(Bundle savedInstanceState) {
1125        final Intent pendingIntent = pendingViewIntent.peek();
1126        savedInstanceState.putParcelable("intent", pendingIntent != null ? pendingIntent : getIntent());
1127        savedInstanceState.putLong("mainFilter", mainFilter);
1128        savedInstanceState.putSerializable("selectedTag", selectedTag);
1129        if (binding.drawer != null) savedInstanceState = binding.drawer.saveInstanceState(savedInstanceState);
1130        if (accountHeader != null) savedInstanceState = accountHeader.saveInstanceState(savedInstanceState);
1131        super.onSaveInstanceState(savedInstanceState);
1132    }
1133
1134    @Override
1135    public void onStart() {
1136        super.onStart();
1137        mRedirectInProcess.set(false);
1138    }
1139
1140    @Override
1141    protected void onNewIntent(final Intent intent) {
1142        super.onNewIntent(intent);
1143        if (isViewOrShareIntent(intent)) {
1144            if (xmppConnectionService != null) {
1145                clearPendingViewIntent();
1146                processViewIntent(intent);
1147            } else {
1148                pendingViewIntent.push(intent);
1149            }
1150        }
1151        setIntent(createLauncherIntent(this));
1152    }
1153
1154    @Override
1155    public void onPause() {
1156        this.mActivityPaused = true;
1157        super.onPause();
1158    }
1159
1160    @Override
1161    public void onResume() {
1162        super.onResume();
1163        this.mActivityPaused = false;
1164    }
1165
1166    private void initializeFragments() {
1167        final FragmentManager fragmentManager = getFragmentManager();
1168        FragmentTransaction transaction = fragmentManager.beginTransaction();
1169        final Fragment mainFragment = fragmentManager.findFragmentById(R.id.main_fragment);
1170        final Fragment secondaryFragment = fragmentManager.findFragmentById(R.id.secondary_fragment);
1171        if (mainFragment != null) {
1172            if (binding.secondaryFragment != null) {
1173                if (mainFragment instanceof ConversationFragment) {
1174                    getFragmentManager().popBackStack();
1175                    transaction.remove(mainFragment);
1176                    transaction.commit();
1177                    fragmentManager.executePendingTransactions();
1178                    transaction = fragmentManager.beginTransaction();
1179                    transaction.replace(R.id.secondary_fragment, mainFragment);
1180                    transaction.replace(R.id.main_fragment, new ConversationsOverviewFragment());
1181                    transaction.commit();
1182                    return;
1183                }
1184            } else {
1185                if (secondaryFragment instanceof ConversationFragment) {
1186                    transaction.remove(secondaryFragment);
1187                    transaction.commit();
1188                    getFragmentManager().executePendingTransactions();
1189                    transaction = fragmentManager.beginTransaction();
1190                    transaction.replace(R.id.main_fragment, secondaryFragment);
1191                    transaction.addToBackStack(null);
1192                    transaction.commit();
1193                    return;
1194                }
1195            }
1196        } else {
1197            transaction.replace(R.id.main_fragment, new ConversationsOverviewFragment());
1198        }
1199        if (binding.secondaryFragment != null && secondaryFragment == null) {
1200            transaction.replace(R.id.secondary_fragment, new ConversationFragment());
1201        }
1202        transaction.commit();
1203    }
1204
1205    private void invalidateActionBarTitle() {
1206        final ActionBar actionBar = getSupportActionBar();
1207        if (actionBar == null) {
1208            return;
1209        }
1210        actionBar.setHomeAsUpIndicator(0);
1211        final FragmentManager fragmentManager = getFragmentManager();
1212        final Fragment mainFragment = fragmentManager.findFragmentById(R.id.main_fragment);
1213        if (mainFragment instanceof ConversationFragment conversationFragment) {
1214            final Conversation conversation = conversationFragment.getConversation();
1215            if (conversation != null) {
1216                actionBar.setTitle(conversation.getName());
1217                actionBar.setDisplayHomeAsUpEnabled(!xmppConnectionService.isOnboarding() || !conversation.getJid().equals(Jid.of("cheogram.com")));
1218                ToolbarUtils.setActionBarOnClickListener(
1219                        binding.toolbar,
1220                        (v) -> { if(!xmppConnectionService.isOnboarding()) openConversationDetails(conversation); }
1221                );
1222                return;
1223            }
1224        }
1225        final Fragment secondaryFragment = fragmentManager.findFragmentById(R.id.secondary_fragment);
1226        if (secondaryFragment instanceof ConversationFragment conversationFragment) {
1227            final Conversation conversation = conversationFragment.getConversation();
1228            if (conversation != null) {
1229                actionBar.setTitle(conversation.getName());
1230            } else {
1231                actionBar.setTitle(R.string.app_name);
1232            }
1233        } else {
1234            actionBar.setTitle(R.string.app_name);
1235        }
1236        actionBar.setDisplayHomeAsUpEnabled(true);
1237        actionBar.setHomeAsUpIndicator(R.drawable.menu_24dp);
1238        ToolbarUtils.resetActionBarOnClickListeners(binding.toolbar);
1239        ToolbarUtils.setActionBarOnClickListener(
1240                binding.toolbar,
1241                (v) -> { if (binding.drawer != null) binding.drawer.getDrawerLayout().openDrawer(binding.drawer); }
1242        );
1243    }
1244
1245    private void openConversationDetails(final Conversation conversation) {
1246        if (conversation.getMode() == Conversational.MODE_MULTI) {
1247            ConferenceDetailsActivity.open(this, conversation);
1248        } else {
1249            final Contact contact = conversation.getContact();
1250            if (contact.isSelf()) {
1251                switchToAccount(conversation.getAccount());
1252            } else {
1253                switchToContactDetails(contact);
1254            }
1255        }
1256    }
1257
1258    @Override
1259    public void onConversationArchived(Conversation conversation) {
1260        if (performRedirectIfNecessary(conversation, false)) {
1261            return;
1262        }
1263        final FragmentManager fragmentManager = getFragmentManager();
1264        final Fragment mainFragment = fragmentManager.findFragmentById(R.id.main_fragment);
1265        if (mainFragment instanceof ConversationFragment) {
1266            try {
1267                fragmentManager.popBackStack();
1268            } catch (final IllegalStateException e) {
1269                Log.w(Config.LOGTAG, "state loss while popping back state after archiving conversation", e);
1270                //this usually means activity is no longer active; meaning on the next open we will run through this again
1271            }
1272            return;
1273        }
1274        final Fragment secondaryFragment = fragmentManager.findFragmentById(R.id.secondary_fragment);
1275        if (secondaryFragment instanceof ConversationFragment) {
1276            if (((ConversationFragment) secondaryFragment).getConversation() == conversation) {
1277                Conversation suggestion = ConversationsOverviewFragment.getSuggestion(this, conversation);
1278                if (suggestion != null) {
1279                    openConversation(suggestion, null);
1280                }
1281            }
1282        }
1283    }
1284
1285    @Override
1286    public void onConversationsListItemUpdated() {
1287        Fragment fragment = getFragmentManager().findFragmentById(R.id.main_fragment);
1288        if (fragment instanceof ConversationsOverviewFragment) {
1289            ((ConversationsOverviewFragment) fragment).refresh();
1290        }
1291    }
1292
1293    @Override
1294    public void switchToConversation(Conversation conversation) {
1295        Log.d(Config.LOGTAG, "override");
1296        openConversation(conversation, null);
1297    }
1298
1299    @Override
1300    public void onConversationRead(Conversation conversation, String upToUuid) {
1301        if (!mActivityPaused && pendingViewIntent.peek() == null) {
1302            xmppConnectionService.sendReadMarker(conversation, upToUuid);
1303        } else {
1304            Log.d(Config.LOGTAG, "ignoring read callback. mActivityPaused=" + mActivityPaused);
1305        }
1306    }
1307
1308    @Override
1309    public void onAccountUpdate() {
1310        refreshAccounts = true;
1311        this.refreshUi();
1312    }
1313
1314    @Override
1315    public void onConversationUpdate(boolean newCaps) {
1316        if (performRedirectIfNecessary(false)) {
1317            return;
1318        }
1319        refreshForNewCaps = newCaps;
1320        this.refreshUi();
1321    }
1322
1323    @Override
1324    public void onRosterUpdate(final XmppConnectionService.UpdateRosterReason reason, final Contact contact) {
1325        if (reason != XmppConnectionService.UpdateRosterReason.AVATAR) {
1326            refreshForNewCaps = true;
1327            if (contact != null) newCapsJids.add(contact.getJid().asBareJid());
1328        }
1329        this.refreshUi();
1330    }
1331
1332    @Override
1333    public void OnUpdateBlocklist(OnUpdateBlocklist.Status status) {
1334        this.refreshUi();
1335    }
1336
1337    @Override
1338    public void onShowErrorToast(int resId) {
1339        runOnUiThread(() -> Toast.makeText(this, resId, Toast.LENGTH_SHORT).show());
1340    }
1341}