commit c2f12afc2652f9351be2efbde3cf602df3fc26ca Author: Hashik Donthineni HashikDonthineni@gmail.com Date: Wed Jun 24 14:54:58 2020 +0530
Added web-socket boiler plate code --- .../torproject/snowflake/MyPersistentService.java | 48 ++++++++++++++++++++++ 1 file changed, 48 insertions(+)
diff --git a/app/src/main/java/org/torproject/snowflake/MyPersistentService.java b/app/src/main/java/org/torproject/snowflake/MyPersistentService.java index 5fd3b6c..1bcee7e 100644 --- a/app/src/main/java/org/torproject/snowflake/MyPersistentService.java +++ b/app/src/main/java/org/torproject/snowflake/MyPersistentService.java @@ -14,6 +14,7 @@ import android.util.Log;
import androidx.annotation.Nullable;
+import org.jetbrains.annotations.NotNull; import org.json.JSONException; import org.torproject.snowflake.constants.BrokerConstants; import org.torproject.snowflake.constants.ForegroundServiceConstants; @@ -43,6 +44,12 @@ import io.reactivex.rxjava3.android.schedulers.AndroidSchedulers; import io.reactivex.rxjava3.core.Observable; import io.reactivex.rxjava3.disposables.CompositeDisposable; import io.reactivex.rxjava3.schedulers.Schedulers; +import okhttp3.OkHttpClient; +import okhttp3.Request; +import okhttp3.Response; +import okhttp3.WebSocket; +import okhttp3.WebSocketListener; +import okio.ByteString;
/** * Main Snowflake implementation of foreground service to relay data in the background. @@ -60,6 +67,7 @@ public class MyPersistentService extends Service { private NotificationManager mNotificationManager; private boolean isConnectionAlive; private SIDHelper sidHelper; + private WebSocket webSocket;
@Nullable @Override @@ -448,4 +456,44 @@ public class MyPersistentService extends Service { mainPeerConnection.close(); isConnectionAlive = false; } + + /////////////// Web Socket //////////////////////// + + private void startWebSocket() { + OkHttpClient client = new OkHttpClient(); + webSocket = client.newWebSocket(new Request.Builder().url(GlobalApplication.getBrokerUrl()).build() + , new WebSocketListener() { + @Override + public void onClosed(@NotNull WebSocket webSocket, int code, @NotNull String reason) { + Log.d(TAG, "WebSocketListener: onClosed: "); + } + + @Override + public void onClosing(@NotNull WebSocket webSocket, int code, @NotNull String reason) { + Log.d(TAG, "WebSocketListener: onClosing: "); + } + + @Override + public void onFailure(@NotNull WebSocket webSocket, @NotNull Throwable t, @org.jetbrains.annotations.Nullable Response response) { + Log.d(TAG, "WebSocketListener: onFailure: "); + } + + @Override + public void onMessage(@NotNull WebSocket webSocket, @NotNull String text) { + Log.d(TAG, "WebSocketListener: onMessage: "); + } + + @Override + public void onMessage(@NotNull WebSocket webSocket, @NotNull ByteString bytes) { + Log.d(TAG, "WebSocketListener: onMessage: "); + } + + @Override + public void onOpen(@NotNull WebSocket webSocket, @NotNull Response response) { + Log.d(TAG, "WebSocketListener: onOpen: "); + } + }); + + client.dispatcher().executorService().shutdown(); + } }