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