GiftedHacker/tangem-app-android-audited
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Updated on 2026-08-14

Browse source
This commit is contained in:
Tangem 2018-10-11 22:15:27 +03:00
parent 7a4292f489
commit 4d5cc7255b
3 changed files with 35 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

17
app/src/main/java/com/tangem/data/network/ServerApiHelperElectrum.java
View file

@ -2,6 +2,7 @@ package com.tangem.data.network;
import android.util.Log;
import com.tangem.App;
import com.tangem.domain.BitcoinNode;
import com.tangem.domain.BitcoinNodeTestNet;
import com.tangem.domain.wallet.Blockchain;
@ -33,6 +34,7 @@ public class ServerApiHelperElectrum {
/**
* TCP
* Used in BTC
* https://sidstudio.com.ua/sidstudio-blog/%D0%BF%D0%B5%D1%80%D0%B5%D0%B4%D0%B0%D1%87%D0%B0-%D0%B4%D0%B0%D0%BD%D0%BD%D1%8B%D1%85-%D0%BF%D0%BE-%D1%81%D0%B5%D1%82%D0%B8-%D0%BF%D1%80%D0%B8-%D0%BF%D0%BE%D0%BC%D0%BE%D1%89%D0%B8-socket-%D0%BF%D1%80%D0%B8-%D1%80%D0%B0%D0%B7%D1%80%D0%B0%D0%B1%D0%BE%D1%82%D0%BA%D0%B5-android-%D0%BF%D1%80%D0%B8%D0%BB%D0%BE%D0%B6%D0%B5%D0%BD%D0%B8%D1%8F
*/
private String host;
private int port;
@ -65,13 +67,6 @@ public class ServerApiHelperElectrum {
.filter(throwable -> throwable instanceof NullPointerException)
.zipWith(Observable.range(1, 2), (n, i) -> i))
// .retryWhen(errors -> errors
// .filter(throwable -> throwable instanceof Exception)
// .zipWith(Observable.range(1, 2), (n, i) -> i))
//
// .retryWhen(errors -> errors
// .filter(throwable -> throwable instanceof ConnectException)
// .zipWith(Observable.range(1, 2), (n, i) -> i))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
@ -117,12 +112,14 @@ public class ServerApiHelperElectrum {
Collections.addAll(result, electrumRequest);
try {
InetAddress serverAddress = InetAddress.getByName(host);
// Socket socket = App.getComponent().getSocket();
Socket socket = new Socket();
socket.setSoTimeout(5000);
socket.bind(new InetSocketAddress(0));
// TODO java.net.ConnectException: Connection refused
socket.connect(new InetSocketAddress(serverAddress, port));
socket.connect(new InetSocketAddress(InetAddress.getByName(host), port));
try {
OutputStream os = socket.getOutputStream();
OutputStreamWriter out = new OutputStreamWriter(os, "UTF-8");

5
app/src/main/java/com/tangem/di/AppComponent.java
View file

@ -2,6 +2,8 @@ package com.tangem.di;
import com.tangem.data.network.Server;
import java.net.Socket;
import javax.inject.Named;
import javax.inject.Singleton;
@ -27,4 +29,7 @@ public interface AppComponent {
@Named(Server.ApiUpdateVersion.URL_UPDATE_VERSION)
Retrofit getRetrofitGithubusercontent();
@Named("socket")
Socket getSocket();
}

23
app/src/main/java/com/tangem/di/NetworkModule.java
View file

@ -3,6 +3,11 @@ package com.tangem.di;
import com.jakewharton.retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import com.tangem.data.network.Server;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketException;
import javax.inject.Named;
import javax.inject.Singleton;
@ -81,4 +86,22 @@ class NetworkModule {
return logging;
}
@Provides
@Named("socket")
Socket provideSocket() {
Socket socket = new Socket();
try {
socket.setSoTimeout(5000);
try {
socket.bind(new InetSocketAddress(0));
} catch (IOException e) {
e.printStackTrace();
}
} catch (SocketException e) {
e.printStackTrace();
}
return socket;
}
}