[tor-commits] [orbot/master] Check OrbotService status, start Tor, if down, switch to Meek, when started, fetch CAPTCHA, as soon as done with that.
n8fr8 at torproject.org
n8fr8 at torproject.org
Tue Apr 28 21:05:02 UTC 2020
commit c026e2064389725a4c5b66ee801e667ff5400ca3
Author: Benjamin Erhart <berhart at netzarchitekten.com>
Date: Fri Apr 17 17:16:36 2020 +0200
Check OrbotService status, start Tor, if down, switch to Meek, when started, fetch CAPTCHA, as soon as done with that.
Proxy Volley correctly.
Improved option menu handling.
Not working, yet: Tor doesn't come up. Why?
---
.../org/torproject/android/OrbotMainActivity.java | 5 +-
.../android/ui/onboarding/MoatActivity.java | 120 ++++++++++++++++++---
.../android/ui/onboarding/ProxiedHurlStack.java | 33 ++++++
3 files changed, 141 insertions(+), 17 deletions(-)
diff --git a/app/src/main/java/org/torproject/android/OrbotMainActivity.java b/app/src/main/java/org/torproject/android/OrbotMainActivity.java
index ff23beed..d21e1d05 100644
--- a/app/src/main/java/org/torproject/android/OrbotMainActivity.java
+++ b/app/src/main/java/org/torproject/android/OrbotMainActivity.java
@@ -209,11 +209,9 @@ public class OrbotMainActivity extends AppCompatActivity
}
private void sendIntentToService(final String action) {
-
Intent intent = new Intent(OrbotMainActivity.this, OrbotService.class);
intent.setAction(action);
startService(intent);
-
}
private void stopTor() {
@@ -930,6 +928,7 @@ public class OrbotMainActivity extends AppCompatActivity
if (mBtnBridges.isChecked()) {
Prefs.putBridgesEnabled(true);
+
startActivity(new Intent(this, BridgeWizardActivity.class));
} else {
enableBridges(false);
@@ -1200,8 +1199,8 @@ public class OrbotMainActivity extends AppCompatActivity
@Override
protected void onDestroy() {
super.onDestroy();
- LocalBroadcastManager.getInstance(this).unregisterReceiver(mLocalBroadcastReceiver);
+ LocalBroadcastManager.getInstance(this).unregisterReceiver(mLocalBroadcastReceiver);
}
public static class DataCount {
diff --git a/app/src/main/java/org/torproject/android/ui/onboarding/MoatActivity.java b/app/src/main/java/org/torproject/android/ui/onboarding/MoatActivity.java
index e5ea5459..e2f642fd 100644
--- a/app/src/main/java/org/torproject/android/ui/onboarding/MoatActivity.java
+++ b/app/src/main/java/org/torproject/android/ui/onboarding/MoatActivity.java
@@ -1,9 +1,16 @@
+/* Copyright (c) 2020, Benjamin Erhart, Orbot / The Guardian Project - https://guardianproject.info */
+/* See LICENSE for licensing information */
package org.torproject.android.ui.onboarding;
import android.app.Dialog;
+import android.content.BroadcastReceiver;
+import android.content.Context;
import android.content.DialogInterface;
+import android.content.Intent;
+import android.content.IntentFilter;
import android.graphics.BitmapFactory;
import android.os.Bundle;
+import android.text.TextUtils;
import android.util.Base64;
import android.util.Log;
import android.view.Menu;
@@ -16,6 +23,7 @@ import androidx.appcompat.app.ActionBar;
import androidx.appcompat.app.AlertDialog;
import androidx.appcompat.app.AppCompatActivity;
import androidx.appcompat.widget.Toolbar;
+import androidx.localbroadcastmanager.content.LocalBroadcastManager;
import com.android.volley.Request;
import com.android.volley.RequestQueue;
@@ -28,6 +36,8 @@ import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;
import org.torproject.android.R;
+import org.torproject.android.service.OrbotService;
+import org.torproject.android.service.TorServiceConstants;
import org.torproject.android.service.util.Prefs;
/**
@@ -51,6 +61,31 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
private RequestQueue mQueue;
+ private String mTorStatus;
+
+ private BroadcastReceiver mBroadcastReceiver = new BroadcastReceiver() {
+ @Override
+ public void onReceive(Context context, Intent intent) {
+ String host = intent.getStringExtra(OrbotService.EXTRA_SOCKS_PROXY_HOST);
+ int port = intent.getIntExtra(OrbotService.EXTRA_SOCKS_PROXY_PORT,-1);
+ String status = intent.getStringExtra(TorServiceConstants.EXTRA_STATUS);
+
+ if (TextUtils.isEmpty(host)) {
+ host = TorServiceConstants.IP_LOCALHOST;
+ }
+
+ if (port < 1) {
+ port = Integer.parseInt(TorServiceConstants.SOCKS_PROXY_PORT_DEFAULT);
+ }
+
+ if (TextUtils.isEmpty(status)) {
+ status = TorServiceConstants.STATUS_OFF;
+ }
+
+ setUp(host, port, status);
+ }
+ };
+
@Override
protected void onCreate(Bundle savedInstanceState) {
@@ -72,7 +107,8 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
findViewById(R.id.requestBt).setOnClickListener(this);
- mQueue = Volley.newRequestQueue(this);
+ LocalBroadcastManager.getInstance(this).registerReceiver(mBroadcastReceiver,
+ new IntentFilter(TorServiceConstants.ACTION_STATUS));
}
@Override
@@ -85,32 +121,51 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
}
@Override
+ public boolean onPrepareOptionsMenu(Menu menu) {
+ menu.findItem(R.id.menu_refresh)
+ .setEnabled(TorServiceConstants.STATUS_ON.equals(mTorStatus));
+
+ return super.onPrepareOptionsMenu(menu);
+ }
+
+ @Override
protected void onResume() {
super.onResume();
- // Set to Meek bridge.
- Prefs.setBridgesList("meek");
- Prefs.putBridgesEnabled(true);
-
- fetchCaptcha();
+ sendIntentToService(TorServiceConstants.ACTION_STATUS);
}
@Override
public void onClick(View view) {
- Log.d(MoatActivity.class.toString(), "Request Bridge!");
+ Log.d(MoatActivity.class.getSimpleName(), "Request Bridge!");
requestBridges(mSolutionEt.getText().toString());
}
@Override
public boolean onOptionsItemSelected(MenuItem item) {
- if (item.getItemId() == R.id.menu_refresh) {
- fetchCaptcha();
+ switch (item.getItemId()) {
+ case R.id.menu_refresh:
+ fetchCaptcha();
+
+ return true;
+
+ case android.R.id.home:
+ finish();
+
+ return true;
}
return super.onOptionsItemSelected(item);
}
+ @Override
+ protected void onDestroy() {
+ super.onDestroy();
+
+ LocalBroadcastManager.getInstance(this).unregisterReceiver(mBroadcastReceiver);
+ }
+
private void fetchCaptcha() {
JsonObjectRequest request = buildRequest("fetch",
"\"type\": \"client-transports\", \"supported\": [\"obfs4\"]",
@@ -125,7 +180,7 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
mCaptchaIv.setImageBitmap(BitmapFactory.decodeByteArray(image, 0, image.length));
} catch (JSONException e) {
- Log.d(MoatActivity.class.toString(), "Error decoding answer.");
+ Log.d(MoatActivity.class.getSimpleName(), "Error decoding answer.");
new AlertDialog.Builder(MoatActivity.this)
.setTitle(R.string.error)
@@ -156,7 +211,7 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
try {
JSONArray bridges = response.getJSONArray("data").getJSONObject(0).getJSONArray("bridges");
- Log.d(MoatActivity.class.toString(), "Bridges: " + bridges.toString());
+ Log.d(MoatActivity.class.getSimpleName(), "Bridges: " + bridges.toString());
StringBuilder sb = new StringBuilder();
@@ -170,7 +225,7 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
MoatActivity.this.finish();
} catch (JSONException e) {
- Log.d(MoatActivity.class.toString(), "Error decoding answer: " + response.toString());
+ Log.d(MoatActivity.class.getSimpleName(), "Error decoding answer: " + response.toString());
new AlertDialog.Builder(MoatActivity.this)
.setTitle(R.string.error)
@@ -200,7 +255,7 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
return null;
}
- Log.d(MoatActivity.class.toString(), "Request: " + requestBody.toString());
+ Log.d(MoatActivity.class.getSimpleName(), "Request: " + requestBody.toString());
return new JsonObjectRequest(
Request.Method.POST,
@@ -210,7 +265,7 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
new Response.ErrorListener() {
@Override
public void onErrorResponse(VolleyError error) {
- Log.d(MoatActivity.class.toString(), "Error response.");
+ Log.d(MoatActivity.class.getSimpleName(), "Error response.");
new AlertDialog.Builder(MoatActivity.this)
.setTitle(R.string.error)
@@ -230,4 +285,41 @@ public class MoatActivity extends AppCompatActivity implements View.OnClickListe
}
};
}
+
+ private void sendIntentToService(final String action) {
+ Intent intent = new Intent(this, OrbotService.class);
+ intent.setAction(action);
+ startService(intent);
+ }
+
+ private void setUp(String host, int port, String status) {
+ Log.d(MoatActivity.class.getSimpleName(), "Tor status=" + status);
+
+ mTorStatus = status;
+ invalidateOptionsMenu();
+
+ switch (status) {
+ case TorServiceConstants.STATUS_OFF:
+ sendIntentToService(TorServiceConstants.ACTION_START);
+
+ break;
+
+ case TorServiceConstants.STATUS_ON:
+ Prefs.setBridgesList("moat");
+ Prefs.putBridgesEnabled(true);
+
+ Log.d(MoatActivity.class.getSimpleName(), "Set up Volley queue. host=" + host + ", port=" + port);
+
+ mQueue = Volley.newRequestQueue(MoatActivity.this, new ProxiedHurlStack(host, port));
+
+ sendIntentToService(TorServiceConstants.CMD_SIGNAL_HUP);
+
+ fetchCaptcha();
+
+ break;
+
+ default:
+ sendIntentToService(TorServiceConstants.ACTION_STATUS);
+ }
+ }
}
diff --git a/app/src/main/java/org/torproject/android/ui/onboarding/ProxiedHurlStack.java b/app/src/main/java/org/torproject/android/ui/onboarding/ProxiedHurlStack.java
new file mode 100644
index 00000000..e3bdb86a
--- /dev/null
+++ b/app/src/main/java/org/torproject/android/ui/onboarding/ProxiedHurlStack.java
@@ -0,0 +1,33 @@
+/* Copyright (c) 2020, Benjamin Erhart, Orbot / The Guardian Project - https://guardianproject.info */
+/* See LICENSE for licensing information */
+package org.torproject.android.ui.onboarding;
+
+import com.android.volley.toolbox.HurlStack;
+
+import java.io.IOException;
+import java.net.HttpURLConnection;
+import java.net.InetSocketAddress;
+import java.net.Proxy;
+import java.net.URL;
+
+ at SuppressWarnings("WeakerAccess")
+public class ProxiedHurlStack extends HurlStack {
+
+ private final String mHost;
+ private final int mPort;
+
+ public ProxiedHurlStack(String host, int port) {
+ super();
+
+ mHost = host;
+ mPort = port;
+ }
+
+ @Override
+ protected HttpURLConnection createConnection(URL url) throws IOException {
+ Proxy proxy = new Proxy(Proxy.Type.SOCKS,
+ InetSocketAddress.createUnresolved(mHost, mPort));
+
+ return (HttpURLConnection) url.openConnection(proxy);
+ }
+}
More information about the tor-commits
mailing list