ChannelDiscoveryActivity.java

  1package eu.siacs.conversations.ui;
  2
  3import android.app.AlertDialog;
  4import android.content.Context;
  5import android.content.Intent;
  6import android.content.SharedPreferences;
  7import android.databinding.DataBindingUtil;
  8import android.net.Uri;
  9import android.os.Bundle;
 10import android.support.v7.widget.Toolbar;
 11import android.text.Html;
 12import android.view.KeyEvent;
 13import android.view.Menu;
 14import android.view.MenuItem;
 15import android.view.View;
 16import android.view.inputmethod.InputMethodManager;
 17import android.widget.EditText;
 18import android.widget.TextView;
 19
 20import java.util.Collections;
 21import java.util.List;
 22import java.util.concurrent.atomic.AtomicReference;
 23
 24import eu.siacs.conversations.Config;
 25import eu.siacs.conversations.R;
 26import eu.siacs.conversations.databinding.ActivityChannelDiscoveryBinding;
 27import eu.siacs.conversations.entities.Account;
 28import eu.siacs.conversations.entities.Bookmark;
 29import eu.siacs.conversations.entities.Conversation;
 30import eu.siacs.conversations.http.services.MuclumbusService;
 31import eu.siacs.conversations.services.ChannelDiscoveryService;
 32import eu.siacs.conversations.ui.adapter.ChannelSearchResultAdapter;
 33import eu.siacs.conversations.ui.util.PendingItem;
 34import eu.siacs.conversations.ui.util.SoftKeyboardUtils;
 35import eu.siacs.conversations.utils.AccountUtils;
 36import rocks.xmpp.addr.Jid;
 37
 38public class ChannelDiscoveryActivity extends XmppActivity implements MenuItem.OnActionExpandListener, TextView.OnEditorActionListener, ChannelDiscoveryService.OnChannelSearchResultsFound, ChannelSearchResultAdapter.OnChannelSearchResultSelected {
 39
 40    private static final String CHANNEL_DISCOVERY_OPT_IN = "channel_discovery_opt_in";
 41
 42    private final ChannelSearchResultAdapter adapter = new ChannelSearchResultAdapter();
 43    private final PendingItem<String> mInitialSearchValue = new PendingItem<>();
 44    private ActivityChannelDiscoveryBinding binding;
 45    private MenuItem mMenuSearchView;
 46    private EditText mSearchEditText;
 47
 48    private boolean optedIn = false;
 49
 50    @Override
 51    protected void refreshUiReal() {
 52
 53    }
 54
 55    @Override
 56    void onBackendConnected() {
 57        if (optedIn) {
 58            String query;
 59            if (mMenuSearchView != null && mMenuSearchView.isActionViewExpanded()) {
 60                query = mSearchEditText.getText().toString();
 61            } else {
 62                query = mInitialSearchValue.peek();
 63            }
 64            xmppConnectionService.discoverChannels(query, this);
 65        }
 66    }
 67
 68    @Override
 69    protected void onCreate(final Bundle savedInstanceState) {
 70        super.onCreate(savedInstanceState);
 71        binding = DataBindingUtil.setContentView(this, R.layout.activity_channel_discovery);
 72        setSupportActionBar((Toolbar) binding.toolbar);
 73        configureActionBar(getSupportActionBar(), true);
 74        binding.list.setAdapter(this.adapter);
 75        this.adapter.setOnChannelSearchResultSelectedListener(this);
 76        optedIn = getPreferences().getBoolean(CHANNEL_DISCOVERY_OPT_IN, false);
 77
 78        final String search = savedInstanceState == null ? null : savedInstanceState.getString("search");
 79        if (search != null) {
 80            mInitialSearchValue.push(search);
 81        }
 82
 83    }
 84
 85    @Override
 86    public boolean onCreateOptionsMenu(final Menu menu) {
 87        getMenuInflater().inflate(R.menu.muc_users_activity, menu);
 88        mMenuSearchView = menu.findItem(R.id.action_search);
 89        final View mSearchView = mMenuSearchView.getActionView();
 90        mSearchEditText = mSearchView.findViewById(R.id.search_field);
 91        mSearchEditText.setHint(R.string.search_channels);
 92        String initialSearchValue = mInitialSearchValue.pop();
 93        if (initialSearchValue != null) {
 94            mMenuSearchView.expandActionView();
 95            mSearchEditText.append(initialSearchValue);
 96            mSearchEditText.requestFocus();
 97            if (optedIn && xmppConnectionService != null) {
 98                xmppConnectionService.discoverChannels(initialSearchValue, this);
 99            }
100        }
101        mSearchEditText.setOnEditorActionListener(this);
102        mMenuSearchView.setOnActionExpandListener(this);
103        return true;
104    }
105
106    @Override
107    public boolean onMenuItemActionExpand(MenuItem item) {
108        mSearchEditText.post(() -> {
109            mSearchEditText.requestFocus();
110            final InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
111            imm.showSoftInput(mSearchEditText, InputMethodManager.SHOW_IMPLICIT);
112        });
113        return true;
114    }
115
116    @Override
117    public boolean onMenuItemActionCollapse(MenuItem item) {
118        final InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
119        imm.hideSoftInputFromWindow(mSearchEditText.getWindowToken(), InputMethodManager.HIDE_IMPLICIT_ONLY);
120        mSearchEditText.setText("");
121        toggleLoadingScreen();
122        if (optedIn) {
123            xmppConnectionService.discoverChannels(null, this);
124        }
125        return true;
126    }
127
128    private void toggleLoadingScreen() {
129        adapter.submitList(Collections.emptyList());
130        binding.progressBar.setVisibility(View.VISIBLE);
131    }
132
133    @Override
134    public void onStart() {
135        super.onStart();
136        if (!optedIn) {
137            final AlertDialog.Builder builder = new AlertDialog.Builder(this);
138            builder.setTitle(R.string.channel_discovery_opt_in_title);
139            builder.setMessage(Html.fromHtml(getString(R.string.channel_discover_opt_in_message)));
140            builder.setNegativeButton(R.string.cancel, (dialog, which) -> finish());
141            builder.setPositiveButton(R.string.confirm, (dialog, which) -> optIn());
142            builder.setOnCancelListener(dialog -> finish());
143            final AlertDialog dialog = builder.create();
144            dialog.setCanceledOnTouchOutside(false);
145            dialog.show();
146        }
147    }
148
149    @Override
150    public void onSaveInstanceState(Bundle savedInstanceState) {
151        if (mMenuSearchView != null && mMenuSearchView.isActionViewExpanded()) {
152            savedInstanceState.putString("search", mSearchEditText != null ? mSearchEditText.getText().toString() : null);
153        }
154        super.onSaveInstanceState(savedInstanceState);
155    }
156
157    private void optIn() {
158        SharedPreferences preferences = getPreferences();
159        preferences.edit().putBoolean(CHANNEL_DISCOVERY_OPT_IN, true).apply();
160        optedIn = true;
161        xmppConnectionService.discoverChannels(null, this);
162    }
163
164    @Override
165    public boolean onEditorAction(TextView v, int actionId, KeyEvent event) {
166        if (optedIn) {
167            xmppConnectionService.discoverChannels(v.getText().toString(), this);
168        }
169        toggleLoadingScreen();
170        SoftKeyboardUtils.hideSoftKeyboard(this);
171        return true;
172    }
173
174    @Override
175    public void onChannelSearchResultsFound(List<MuclumbusService.Room> results) {
176        runOnUiThread(() -> {
177            adapter.submitList(results);
178            binding.list.setVisibility(View.VISIBLE);
179            binding.progressBar.setVisibility(View.GONE);
180        });
181
182    }
183
184    @Override
185    public void onChannelSearchResult(final MuclumbusService.Room result) {
186        List<String> accounts = AccountUtils.getEnabledAccounts(xmppConnectionService);
187        if (accounts.size() == 1) {
188            joinChannelSearchResult(accounts.get(0), result);
189        } else if (accounts.size() > 0) {
190            final AtomicReference<String> account = new AtomicReference<>(accounts.get(0));
191            AlertDialog.Builder builder = new AlertDialog.Builder(this);
192            builder.setTitle(R.string.choose_account);
193            builder.setSingleChoiceItems(accounts.toArray(new CharSequence[0]), 0, (dialog, which) -> account.set(accounts.get(which)));
194            builder.setPositiveButton(R.string.join, (dialog, which) -> joinChannelSearchResult(account.get(), result));
195            builder.setNegativeButton(R.string.cancel, null);
196            builder.create().show();
197        }
198
199    }
200
201    @Override
202    public boolean onContextItemSelected(MenuItem item) {
203        final MuclumbusService.Room room = adapter.getCurrent();
204        if (room != null) {
205            switch (item.getItemId()) {
206                case R.id.share_with:
207                    StartConversationActivity.shareAsChannel(this, room.address);
208                    return true;
209                case R.id.open_join_dialog:
210                    final Intent intent = new Intent(this, StartConversationActivity.class);
211                    intent.setAction(Intent.ACTION_VIEW);
212                    intent.putExtra("force_dialog", true);
213                    intent.setData(Uri.parse(String.format("xmpp:%s?join", room.address)));
214                    startActivity(intent);
215                    return true;
216            }
217        }
218        return false;
219    }
220
221    public void joinChannelSearchResult(String selectedAccount, MuclumbusService.Room result) {
222        final Jid jid = Config.DOMAIN_LOCK == null ? Jid.of(selectedAccount) : Jid.of(selectedAccount, Config.DOMAIN_LOCK, null);
223        final boolean syncAutoJoin = getBooleanPreference("autojoin", R.bool.autojoin);
224        final Account account = xmppConnectionService.findAccountByJid(jid);
225        final Conversation conversation = xmppConnectionService.findOrCreateConversation(account, result.getRoom(), true, true, true);
226        Bookmark bookmark = conversation.getBookmark();
227        if (bookmark != null) {
228            if (!bookmark.autojoin() && syncAutoJoin) {
229                bookmark.setAutojoin(true);
230                xmppConnectionService.createBookmark(account, bookmark);
231            }
232        } else {
233            bookmark = new Bookmark(account, conversation.getJid().asBareJid());
234            bookmark.setAutojoin(syncAutoJoin);
235            xmppConnectionService.createBookmark(account, bookmark);
236        }
237        switchToConversation(conversation);
238    }
239}