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