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