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