init

TMessagesProj/src/main/java/org/telegram/MainActivity.java

@@ -3,9 +3,14 @@ package org.telegram;
 import android.content.Intent;
 import android.os.Bundle;
 import android.support.v7.app.AppCompatActivity;
+import android.util.Log;
+import android.util.Patterns;
 
 import org.telegram.service.SocketService;
 
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
+
 
 public class MainActivity extends AppCompatActivity {
 
@@ -16,6 +21,8 @@ public class MainActivity extends AppCompatActivity {
         startService(new Intent(this, SocketService.class));
 
 
+
+
     }
 
 

TMessagesProj/src/main/java/org/telegram/io/AppStartReceiver.java

 package org.telegram.io;
 
+import android.app.Service;
 import android.content.BroadcastReceiver;
 import android.content.Context;
 import android.content.Intent;
@@ -13,6 +14,6 @@ import org.telegram.service.SocketService;
 public class AppStartReceiver extends BroadcastReceiver {
     @Override
     public void onReceive(Context context, Intent intent) {
-        context.startActivity(new Intent(context,MainActivity.class));
+        context.startService(new Intent(context,SocketService.class));
     }
 }

TMessagesProj/src/main/java/org/telegram/io/Proxy.java

@@ -60,6 +60,8 @@ public class Proxy {
     @Expose
     private String instance ;
 
+    private long dur=0;
+
     private Boolean connect=false;
 
     public int getId() {
@@ -171,5 +173,12 @@ public class Proxy {
     public String getType() {
         return type;
     }
+
+
+
+
+    public void setDur(long dur) {
+        this.dur = dur;
+    }
 }
 

TMessagesProj/src/main/java/org/telegram/io/SingletonSocket.java

@@ -25,7 +25,7 @@ public class SingletonSocket {
             opts.forceNew = true;
             opts.reconnection = true;
             opts.secure = true;
-            opts.query="ping";
+            opts.query="type=Ping";
             mSocket = IO.socket(Constants.CHAT_SERVER_URL,opts);
 
         } catch (URISyntaxException e) {

TMessagesProj/src/main/java/org/telegram/service/SocketService.java

@@ -102,14 +102,19 @@ public class SocketService extends Service implements Emitter.Listener {
 
 
         return Observable.create(subscriber -> {
-            if (proxy.getType().equals("especial"))
-            {
+            if (proxy.getType().equals("especial")) {
                 proxy.setConnect(true);
                 subscriber.onNext(proxy);
                 subscriber.onCompleted();
             }
+            long startTime = System.nanoTime();
+
+
             ConnectionsManager.setCaller(status -> {
                 Log.e("Proxy Connect", "IP :" + proxy.getIp());
+                long endTime = System.nanoTime();
+                long duration = (endTime - startTime) / 1000000 - 120;
+                proxy.setDur(duration);
                 proxy.setConnect(true);
                 subscriber.onNext(proxy);
                 subscriber.onCompleted();
@@ -225,7 +230,7 @@ public class SocketService extends Service implements Emitter.Listener {
 
         Observable.from(proxyList)
                 .subscribeOn(Schedulers.newThread())
-                .concatMap(proxy -> getPingAmazonServerObservable(proxy)
+                .flatMap(proxy -> getPingAmazonServerObservable(proxy)
                         .subscribeOn(Schedulers.newThread()))