Skip to content

Commit

Permalink
Temporarily remove new Tor binary
Browse files Browse the repository at this point in the history
  • Loading branch information
@kaloudis
kaloudis committed Jan 18, 2024
1 parent c52c441 commit df2cb49
Show file tree
Hide file tree
Showing 8 changed files with 69 additions and 369 deletions.
4 changes: 2 additions & 2 deletions android/app/build.gradle
View file
Original file line number Diff line number Diff line change
Expand Up @@ -210,8 +210,8 @@ dependencies {
// Tor + Persistent LND
implementation "com.jakewharton:process-phoenix:2.0.0"

implementation 'info.guardianproject:tor-android:0.4.7.8'
implementation 'info.guardianproject:jtorctl:0.4.5.7'
// implementation 'info.guardianproject:tor-android:0.4.7.8'
// implementation 'info.guardianproject:jtorctl:0.4.5.7'

implementation('dev.doubledot.doki:library:0.0.1@aar') {
transitive = true
Expand Down
89 changes: 0 additions & 89 deletions android/app/src/main/java/com/msopentech/thali/android/installer/AndroidTorInstaller.java
View file

This file was deleted.

8 changes: 4 additions & 4 deletions android/app/src/main/java/com/zeus/LndMobile.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -348,10 +348,10 @@ public void startLnd(String args, Boolean isTorEnabled, Boolean isTestnet, Promi

String params = "--lnddir=" + getReactApplicationContext().getFilesDir().getPath();
if (isTorEnabled) {
int listenPort = ZeusTorUtils.getListenPort(isTestnet);
String controlSocket = "unix://" + getReactApplicationContext().getDir(TorService.class.getSimpleName(), Context.MODE_PRIVATE).getAbsolutePath() + "/data/ControlSocket";
params += " --tor.active --tor.control=" + controlSocket;
params += " --tor.v3 --listen=localhost:" + listenPort;
// int listenPort = ZeusTorUtils.getListenPort(isTestnet);
// String controlSocket = "unix://" + getReactApplicationContext().getDir(TorService.class.getSimpleName(), Context.MODE_PRIVATE).getAbsolutePath() + "/data/ControlSocket";
// params += " --tor.active --tor.control=" + controlSocket;
// params += " --tor.v3 --listen=localhost:" + listenPort;
} else {
// If Tor isn't active, make sure we aren't
// listening at all
Expand Down
132 changes: 62 additions & 70 deletions android/app/src/main/java/com/zeus/LndMobileScheduledSyncWorker.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,7 @@ public class LndMobileScheduledSyncWorker extends ListenableWorker {
// we'll close down lnd and the worker
private int numGetInfoCalls = 0;

ZeusTor zeusTor;
// ZeusTor zeusTor;

// private enum WorkState {
// NOT_STARTED, BOUND, WALLET_UNLOCKED, WAITING_FOR_SYNC, DONE;
Expand All @@ -72,7 +72,7 @@ public class LndMobileScheduledSyncWorker extends ListenableWorker {
public LndMobileScheduledSyncWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
super(context, workerParams);
dbSupplier = ReactDatabaseSupplier.getInstance(getApplicationContext());
zeusTor = new ZeusTor(new ReactApplicationContext(getApplicationContext()));
// zeusTor = new ZeusTor(new ReactApplicationContext(getApplicationContext()));
}

@Override
Expand Down Expand Up @@ -116,38 +116,32 @@ public void onSuccess(@Nullable Object value) {
// Hyperlog.d(TAG, "Password retrieved");

if (torEnabled) {
// boolean startTorResult = startTor();
// if (!startTorResult) {
// Log.e(TAG, "Could not start Tor");
// future.set(Result.failure());
// return;
// }
zeusTor.startTor(new PromiseWrapper() {
@Override
void onSuccess(@Nullable Object value) {
// Hyperlog.i(TAG, "Tor started");
// Hyperlog.i(TAG, "torSocksPort: " + (int) value);
torStarted = true;
torSocksPort = (int) value;

startLndWorkThread(completer, password);
}

@Override
void onFail(Throwable throwable) {
// Hyperlog.e(TAG, "Failed to start Tor", throwable);
zeusTor.stopTor(new PromiseWrapper() {
@Override
void onSuccess(@Nullable Object value) {
}

@Override
void onFail(Throwable throwable) {
}
});
completer.set(Result.failure());
}
});
// zeusTor.startTor(new PromiseWrapper() {
// @Override
// void onSuccess(@Nullable Object value) {
// // Hyperlog.i(TAG, "Tor started");
// // Hyperlog.i(TAG, "torSocksPort: " + (int) value);
// torStarted = true;
// torSocksPort = (int) value;

// startLndWorkThread(completer, password);
// }

// @Override
// void onFail(Throwable throwable) {
// // Hyperlog.e(TAG, "Failed to start Tor", throwable);
// zeusTor.stopTor(new PromiseWrapper() {
// @Override
// void onSuccess(@Nullable Object value) {
// }

// @Override
// void onFail(Throwable throwable) {
// }
// });
// completer.set(Result.failure());
// }
// });
} else {
startLndWorkThread(completer, password);
}
Expand Down Expand Up @@ -322,19 +316,17 @@ private void stopWorker(boolean success, CallbackToFutureAdapter.Completer<Resul
unbindLndMobileService();

if (torStarted) {
// if (!MainActivity.started) {
// Hyperlog.i(TAG, "Stopping Tor");
zeusTor.stopTor(new PromiseWrapper() {
@Override
void onSuccess(@Nullable Object value) {
// Hyperlog.i(TAG,"Tor stopped");
}

@Override
void onFail(Throwable throwable) {
// Hyperlog.e(TAG, "Fail while stopping Tor", throwable);
}
});
// zeusTor.stopTor(new PromiseWrapper() {
// @Override
// void onSuccess(@Nullable Object value) {
// // Hyperlog.i(TAG,"Tor stopped");
// }

// @Override
// void onFail(Throwable throwable) {
// // Hyperlog.e(TAG, "Fail while stopping Tor", throwable);
// }
// });
// } else {
// // Hyperlog.w(TAG, "MainActivity was started when shutting down sync work. I will not stop Tor");
// }
Expand All @@ -350,29 +342,29 @@ public void run() {
}

private boolean startTor(CallbackToFutureAdapter.Completer<Result> completer) {
// Hyperlog.i(TAG, "Starting Tor");
zeusTor.startTor(new PromiseWrapper() {
@Override
void onSuccess(@Nullable Object value) {
// Hyperlog.i(TAG, "Tor started");
// Hyperlog.i(TAG, "torSocksPort: " + (int) value);
torStarted = true;
torSocksPort = (int) value;
}

@Override
void onFail(Throwable throwable) {
// Hyperlog.e(TAG, "Failed to start Tor", throwable);
zeusTor.stopTor(new PromiseWrapper() {
@Override
void onSuccess(@Nullable Object value) {}

@Override
void onFail(Throwable throwable) {}
});
completer.set(Result.failure());
}
});
Hyperlog.i(TAG, "Starting Tor");
// zeusTor.startTor(new PromiseWrapper() {
// @Override
// void onSuccess(@Nullable Object value) {
// // Hyperlog.i(TAG, "Tor started");
// // Hyperlog.i(TAG, "torSocksPort: " + (int) value);
// torStarted = true;
// torSocksPort = (int) value;
// }

// @Override
// void onFail(Throwable throwable) {
// // Hyperlog.e(TAG, "Failed to start Tor", throwable);
// zeusTor.stopTor(new PromiseWrapper() {
// @Override
// void onSuccess(@Nullable Object value) {}

// @Override
// void onFail(Throwable throwable) {}
// });
// completer.set(Result.failure());
// }
// });
int torTries = 0;
while (!torStarted) {
if (torTries++ > 40) {
Expand Down
2 changes: 1 addition & 1 deletion android/app/src/main/java/com/zeus/MainApplication.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -49,7 +49,7 @@ protected List<ReactPackage> getPackages() {
packages.add(new LndMobileToolsPackage());
packages.add(new LndMobileScheduledSyncPackage());
packages.add(new LncPackage());
packages.add(new ZeusTorPackage());
// packages.add(new ZeusTorPackage());

return packages;
}
Expand Down
Loading

0 comments on commit df2cb49

Please sign in to comment.