1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
|
package se.leap.bitmaskclient.pluggableTransports;
import static se.leap.bitmaskclient.base.models.Constants.KCP;
import android.util.Log;
import java.beans.PropertyChangeEvent;
import java.beans.PropertyChangeListener;
import java.util.Observable;
import java.util.Observer;
import java.util.concurrent.atomic.AtomicBoolean;
import java.util.concurrent.atomic.AtomicInteger;
import client.Client;
import de.blinkt.openvpn.core.ConnectionStatus;
import de.blinkt.openvpn.core.VpnStatus;
import se.leap.bitmaskclient.eip.EipStatus;
public class ObfsVpnClient implements PropertyChangeListener, PtClientInterface {
public static final AtomicInteger SOCKS_PORT = new AtomicInteger(4430);
public static final String SOCKS_IP = "127.0.0.1";
private static final String ERR_BIND = "bind: address already in use";
private static final String TAG = ObfsVpnClient.class.getSimpleName();
private volatile boolean noNetwork;
private final AtomicBoolean pendingNetworkErrorHandling = new AtomicBoolean(false);
private final AtomicInteger reconnectRetry = new AtomicInteger(0);
private static final int MAX_RETRY = 5;
private final client.Client_ obfsVpnClient;
private final Object LOCK = new Object();
public ObfsVpnClient(Obfs4Options options) throws IllegalStateException{
//FIXME: use a different strategy here
//Basically we would want to track if the more performant transport protocol (KCP?/TCP?) usage was successful
//if so, we stick to it, otherwise we flip the flag
boolean kcp = KCP.equals(options.transport.getProtocols()[0]);
if (options.transport.getOptions().getCert() == null) {
throw new IllegalStateException("No cert found to establish a obfs4 connection");
}
obfsVpnClient = Client.newClient(kcp, SOCKS_IP+":"+SOCKS_PORT.get(), options.transport.getOptions().getCert());
}
/**
* starts the client
* @return the port ObfsVpn is running on
*/
public int start() {
synchronized (LOCK) {
obfsVpnClient.setEventLogger(this);
Log.d(TAG, "aquired LOCK");
new Thread(this::startSync).start();
waitUntilStarted();
Log.d(TAG, "returning LOCK after " + (reconnectRetry.get() + 1) * 200 +" ms");
}
return SOCKS_PORT.get();
}
// We're waiting here until the obfsvpn client has found a unbound port and started
private void waitUntilStarted() {
int count = -1;
try {
while (count < reconnectRetry.get() && reconnectRetry.get() < MAX_RETRY) {
Thread.sleep(200);
count++;
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
private void startSync() {
try {
obfsVpnClient.start();
} catch (Exception e) {
Log.e(TAG, "[obfsvpn] exception: " + e.getLocalizedMessage());
VpnStatus.logError("[obfsvpn] " + e.getLocalizedMessage());
if (e.getLocalizedMessage() != null && e.getLocalizedMessage().contains(ERR_BIND) && reconnectRetry.get() < MAX_RETRY) {
reconnectRetry.addAndGet(1);
SOCKS_PORT.addAndGet(1);
obfsVpnClient.setSocksAddr(SOCKS_IP+":"+SOCKS_PORT.get());
Log.d(TAG, "[obfsvpn] reconnecting on different port... " + SOCKS_PORT.get());
VpnStatus.logDebug("[obfsvpn] reconnecting on different port... " + SOCKS_PORT.get());
startSync();
} else if (noNetwork) {
pendingNetworkErrorHandling.set(true);
}
}
}
public void stop() {
synchronized (LOCK) {
Log.d(TAG, "stopping obfsVpnClient...");
try {
obfsVpnClient.stop();
reconnectRetry.set(0);
SOCKS_PORT.set(4430);
Thread.sleep(100);
} catch (Exception e) {
e.printStackTrace();
VpnStatus.logError("[obfsvpn] " + e.getLocalizedMessage());
} finally {
obfsVpnClient.setEventLogger(null);
}
pendingNetworkErrorHandling.set(false);
Log.d(TAG, "stopping obfsVpnClient releasing LOCK ...");
}
}
public boolean isStarted() {
return obfsVpnClient.isStarted();
}
// TODO: register observer!
@Override
public void propertyChange(PropertyChangeEvent evt) {
if (EipStatus.PROPERTY_CHANGE.equals(evt.getPropertyName())) {
EipStatus status = (EipStatus) evt.getNewValue();
if (status.getLevel() == ConnectionStatus.LEVEL_NONETWORK) {
noNetwork = true;
} else {
noNetwork = false;
if (pendingNetworkErrorHandling.getAndSet(false)) {
stop();
start();
}
}
}
}
@Override
public void error(String s) {
VpnStatus.logError("[obfsvpn] " + s);
}
@Override
public void log(String state, String message) {
VpnStatus.logDebug("[obfsvpn] " + state + " " + message);
}
}
|
