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