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