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