1package eu.siacs.conversations.ui;
2
3import android.app.AlertDialog;
4import android.content.Context;
5import android.content.Intent;
6import android.content.SharedPreferences;
7import android.net.Uri;
8import android.os.Bundle;
9import android.preference.PreferenceManager;
10import android.text.Html;
11import android.text.method.LinkMovementMethod;
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;
19import android.widget.Toast;
20
21import androidx.annotation.NonNull;
22import androidx.core.content.ContextCompat;
23import androidx.databinding.DataBindingUtil;
24
25import com.google.android.material.color.MaterialColors;
26import com.google.android.material.dialog.MaterialAlertDialogBuilder;
27import com.google.common.base.Strings;
28
29import java.util.Collections;
30import java.util.List;
31import java.util.concurrent.atomic.AtomicReference;
32
33import eu.siacs.conversations.Config;
34import eu.siacs.conversations.R;
35import eu.siacs.conversations.databinding.ActivityChannelDiscoveryBinding;
36import eu.siacs.conversations.entities.Account;
37import eu.siacs.conversations.entities.Bookmark;
38import eu.siacs.conversations.entities.Conversation;
39import eu.siacs.conversations.entities.Room;
40import eu.siacs.conversations.services.ChannelDiscoveryService;
41import eu.siacs.conversations.services.QuickConversationsService;
42import eu.siacs.conversations.ui.adapter.ChannelSearchResultAdapter;
43import eu.siacs.conversations.ui.util.PendingItem;
44import eu.siacs.conversations.ui.util.SoftKeyboardUtils;
45import eu.siacs.conversations.utils.AccountUtils;
46import eu.siacs.conversations.xmpp.Jid;
47
48public class ChannelDiscoveryActivity extends XmppActivity implements MenuItem.OnActionExpandListener, TextView.OnEditorActionListener, ChannelDiscoveryService.OnChannelSearchResultsFound, ChannelSearchResultAdapter.OnChannelSearchResultSelected {
49
50 private static final String CHANNEL_DISCOVERY_OPT_IN = "channel_discovery_opt_in";
51
52 private final ChannelSearchResultAdapter adapter = new ChannelSearchResultAdapter();
53 private final PendingItem<String> mInitialSearchValue = new PendingItem<>();
54 private ActivityChannelDiscoveryBinding binding;
55 private MenuItem mMenuSearchView;
56 private EditText mSearchEditText;
57
58 private ChannelDiscoveryService.Method method = ChannelDiscoveryService.Method.LOCAL_SERVER;
59
60 private boolean optedIn = false;
61
62 @Override
63 protected void refreshUiReal() {
64
65 }
66
67 @Override
68 protected void onBackendConnected() {
69 if (optedIn || method == ChannelDiscoveryService.Method.LOCAL_SERVER) {
70 final String query;
71 if (mMenuSearchView != null && mMenuSearchView.isActionViewExpanded()) {
72 query = mSearchEditText.getText().toString();
73 } else {
74 query = mInitialSearchValue.peek();
75 }
76 toggleLoadingScreen();
77 xmppConnectionService.discoverChannels(query, this.method, this);
78 }
79 }
80
81 @Override
82 protected void onCreate(final Bundle savedInstanceState) {
83 super.onCreate(savedInstanceState);
84 binding = DataBindingUtil.setContentView(this, R.layout.activity_channel_discovery);
85 setSupportActionBar(binding.toolbar);
86 Activities.setStatusAndNavigationBarColors(this, binding.getRoot());
87 configureActionBar(getSupportActionBar(), true);
88 binding.list.setAdapter(this.adapter);
89 this.adapter.setOnChannelSearchResultSelectedListener(this);
90 this.optedIn = getPreferences().getBoolean(CHANNEL_DISCOVERY_OPT_IN, false);
91
92 final String search = savedInstanceState == null ? null : savedInstanceState.getString("search");
93 if (search != null) {
94 mInitialSearchValue.push(search);
95 }
96 }
97
98 private static ChannelDiscoveryService.Method getMethod(final Context c) {
99 if ( Strings.isNullOrEmpty(Config.CHANNEL_DISCOVERY)) {
100 return ChannelDiscoveryService.Method.LOCAL_SERVER;
101 }
102 if (QuickConversationsService.isQuicksy()) {
103 return ChannelDiscoveryService.Method.JABBER_NETWORK;
104 }
105 final SharedPreferences p = PreferenceManager.getDefaultSharedPreferences(c);
106 final String m = p.getString("channel_discovery_method", c.getString(R.string.default_channel_discovery));
107 try {
108 return ChannelDiscoveryService.Method.valueOf(m);
109 } catch (IllegalArgumentException e) {
110 return ChannelDiscoveryService.Method.JABBER_NETWORK;
111 }
112 }
113
114 @Override
115 public boolean onCreateOptionsMenu(final Menu menu) {
116 getMenuInflater().inflate(R.menu.channel_discovery_activity, menu);
117 AccountUtils.showHideMenuItems(menu);
118 mMenuSearchView = menu.findItem(R.id.action_search);
119 final View mSearchView = mMenuSearchView.getActionView();
120 mSearchEditText = mSearchView.findViewById(R.id.search_field);
121 mSearchEditText.setHint(R.string.search_channels);
122 final String initialSearchValue = mInitialSearchValue.pop();
123 if (initialSearchValue != null) {
124 mMenuSearchView.expandActionView();
125 mSearchEditText.append(initialSearchValue);
126 mSearchEditText.requestFocus();
127 if ((optedIn || method == ChannelDiscoveryService.Method.LOCAL_SERVER) && xmppConnectionService != null) {
128 xmppConnectionService.discoverChannels(initialSearchValue, this.method, this);
129 }
130 }
131 mSearchEditText.setOnEditorActionListener(this);
132 mMenuSearchView.setOnActionExpandListener(this);
133 return true;
134 }
135
136 @Override
137 public boolean onMenuItemActionExpand(@NonNull MenuItem item) {
138 mSearchEditText.post(() -> {
139 mSearchEditText.requestFocus();
140 final InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
141 imm.showSoftInput(mSearchEditText, InputMethodManager.SHOW_IMPLICIT);
142 });
143 return true;
144 }
145
146 @Override
147 public boolean onMenuItemActionCollapse(@NonNull MenuItem item) {
148 final InputMethodManager imm = (InputMethodManager) getSystemService(Context.INPUT_METHOD_SERVICE);
149 imm.hideSoftInputFromWindow(mSearchEditText.getWindowToken(), InputMethodManager.HIDE_IMPLICIT_ONLY);
150 mSearchEditText.setText("");
151 toggleLoadingScreen();
152 if (optedIn || method == ChannelDiscoveryService.Method.LOCAL_SERVER) {
153 xmppConnectionService.discoverChannels(null, this.method, this);
154 }
155 return true;
156 }
157
158 private void toggleLoadingScreen() {
159 adapter.submitList(Collections.emptyList());
160 binding.progressBar.setVisibility(View.VISIBLE);
161 binding.list.setBackgroundColor(MaterialColors.getColor(binding.list, com.google.android.material.R.attr.colorSurface));
162 }
163
164 @Override
165 public void onStart() {
166 super.onStart();
167 this.method = getMethod(this);
168 if (!optedIn && method == ChannelDiscoveryService.Method.JABBER_NETWORK) {
169 final MaterialAlertDialogBuilder builder = new MaterialAlertDialogBuilder(this);
170 builder.setTitle(R.string.channel_discovery_opt_in_title);
171 builder.setMessage(Html.fromHtml(getString(R.string.channel_discover_opt_in_message)));
172 builder.setNegativeButton(R.string.cancel, (dialog, which) -> finish());
173 builder.setPositiveButton(R.string.confirm, (dialog, which) -> optIn());
174 builder.setOnCancelListener(dialog -> finish());
175 final androidx.appcompat.app.AlertDialog dialog = builder.create();
176 dialog.setOnShowListener(d -> {
177 final TextView textView = dialog.findViewById(android.R.id.message);
178 if (textView == null) {
179 return;
180 }
181 textView.setMovementMethod(LinkMovementMethod.getInstance());
182 });
183 dialog.setCanceledOnTouchOutside(false);
184 dialog.show();
185 holdLoading();
186 }
187 }
188
189 private void holdLoading() {
190 adapter.submitList(Collections.emptyList());
191 binding.progressBar.setVisibility(View.GONE);
192 binding.list.setBackgroundColor(MaterialColors.getColor(binding.list, com.google.android.material.R.attr.colorSurface));
193 }
194
195 @Override
196 public void onSaveInstanceState(@NonNull Bundle savedInstanceState) {
197 if (mMenuSearchView != null && mMenuSearchView.isActionViewExpanded()) {
198 savedInstanceState.putString("search", mSearchEditText != null ? mSearchEditText.getText().toString() : null);
199 }
200 super.onSaveInstanceState(savedInstanceState);
201 }
202
203 private void optIn() {
204 SharedPreferences preferences = getPreferences();
205 preferences.edit().putBoolean(CHANNEL_DISCOVERY_OPT_IN, true).apply();
206 optedIn = true;
207 toggleLoadingScreen();
208 xmppConnectionService.discoverChannels(null, this.method, this);
209 }
210
211 @Override
212 public boolean onEditorAction(TextView v, int actionId, KeyEvent event) {
213 if (optedIn || method == ChannelDiscoveryService.Method.LOCAL_SERVER) {
214 toggleLoadingScreen();
215 SoftKeyboardUtils.hideSoftKeyboard(this);
216 xmppConnectionService.discoverChannels(v.getText().toString(), this.method, this);
217 }
218 return true;
219 }
220
221 @Override
222 public void onChannelSearchResultsFound(final List<Room> results) {
223 runOnUiThread(() -> {
224 adapter.submitList(results);
225 binding.progressBar.setVisibility(View.GONE);
226 if (results.isEmpty()) {
227 binding.list.setBackground(ContextCompat.getDrawable(this,R.drawable.background_no_results));
228 } else {
229 binding.list.setBackgroundColor(MaterialColors.getColor(binding.list, com.google.android.material.R.attr.colorSurface));
230 }
231 });
232
233 }
234
235 @Override
236 public void onChannelSearchResult(final Room result) {
237 final List<String> accounts = AccountUtils.getEnabledAccounts(xmppConnectionService);
238 if (accounts.size() == 1) {
239 joinChannelSearchResult(accounts.get(0), result);
240 } else if (accounts.isEmpty()) {
241 Toast.makeText(this, R.string.please_enable_an_account, Toast.LENGTH_LONG).show();
242 } else {
243 final AtomicReference<String> account = new AtomicReference<>(accounts.get(0));
244 final MaterialAlertDialogBuilder builder = new MaterialAlertDialogBuilder(this);
245 builder.setTitle(R.string.choose_account);
246 builder.setSingleChoiceItems(accounts.toArray(new CharSequence[0]), 0, (dialog, which) -> account.set(accounts.get(which)));
247 builder.setPositiveButton(R.string.join, (dialog, which) -> joinChannelSearchResult(account.get(), result));
248 builder.setNegativeButton(R.string.cancel, null);
249 builder.create().show();
250 }
251
252 }
253
254 @Override
255 public boolean onContextItemSelected(@NonNull MenuItem item) {
256 final Room room = adapter.getCurrent();
257 if (room == null) {
258 return false;
259 }
260 final int itemId = item.getItemId();
261 if (itemId == R.id.share_with) {
262 StartConversationActivity.shareAsChannel(this, room.address);
263 return true;
264 } else if (itemId == R.id.open_join_dialog) {
265 final Intent intent = new Intent(this, StartConversationActivity.class);
266 intent.setAction(Intent.ACTION_VIEW);
267 intent.putExtra("force_dialog", true);
268 intent.setData(Uri.parse(String.format("xmpp:%s?join", room.address)));
269 startActivity(intent);
270 return true;
271 } else {
272 return false;
273 }
274 }
275
276 public void joinChannelSearchResult(final String selectedAccount, final Room result) {
277 final Jid jid = Jid.ofEscaped(selectedAccount);
278 final Account account = xmppConnectionService.findAccountByJid(jid);
279 final Conversation conversation =
280 xmppConnectionService.findOrCreateConversation(
281 account, result.getRoom(), true, true, true);
282 final var existingBookmark = conversation.getBookmark();
283 if (existingBookmark == null) {
284 final var bookmark = new Bookmark(account, conversation.getJid().asBareJid());
285 bookmark.setAutojoin(true);
286 xmppConnectionService.createBookmark(account, bookmark);
287 } else {
288 if (!existingBookmark.autojoin()) {
289 existingBookmark.setAutojoin(true);
290 xmppConnectionService.createBookmark(account, existingBookmark);
291 }
292 }
293 switchToConversation(conversation);
294 }
295}