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