test: SocketTest

Author: codeestX

app/build.gradle

@@ -21,6 +21,11 @@ android {
             proguardFiles getDefaultProguardFile('proguard-android.txt'), 'proguard-rules.pro'
         }
     }
+    testOptions {
+        unitTests {
+            includeAndroidResources = true
+        }
+    }
 }
 
 dependencies {
@@ -31,11 +36,8 @@ dependencies {
     implementation "org.jetbrains.kotlin:kotlin-stdlib-jre7:$kotlin_version"
     implementation 'com.android.support:appcompat-v7:25.4.0'
     testImplementation 'junit:junit:4.12'
+    testCompile "org.robolectric:robolectric:3.3.2"
     implementation 'com.android.support.constraint:constraint-layout:1.0.2'
     compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
-//    compile 'io.reactivex.rxjava2:rxjava:2.1.1' {
-//        exclude group: "io.reactivex", module: "rxjava"
-//    }
-
     implementation project(':RxSocketClient')
 }

app/src/main/java/moe/codeest/rxsocketclientdemo/JavaActivity.java

@@ -58,9 +58,7 @@ protected void onCreate(Bundle savedInstanceState) {
         btnSend.setOnClickListener(this);
         btnConnect.setOnClickListener(this);
         btnDisConnect.setOnClickListener(this);
-    }
 
-    private void connect() {
         //init
         mClient = RxSocketClient
                 .create(new SocketConfig.Builder()
@@ -75,7 +73,9 @@ private void connect() {
                         .setHead(HEAD)
                         .setTail(TAIL)
                         .build());
+    }
 
+    private void connect() {
         //connect
         ref = mClient.connect()
                 .observeOn(AndroidSchedulers.mainThread())
@@ -109,6 +109,12 @@ public void accept(Throwable throwable) throws Exception {
                 });
     }
 
+    public void connect(SocketSubscriber subscriber) {
+        ref = mClient.connect()
+                .observeOn(AndroidSchedulers.mainThread())
+                .subscribe(subscriber);
+    }
+
     @Override
     public void onClick(View v) {
         switch (v.getId()) {

app/src/test/java/moe/codeest/rxsocketclientdemo/ExampleUnitTest.kt

@@ -0,0 +1,94 @@
+package moe.codeest.rxsocketclientdemo;
+
+import android.widget.Button;
+import android.widget.TextView;
+import android.widget.Toast;
+
+import org.jetbrains.annotations.NotNull;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.robolectric.Robolectric;
+import org.robolectric.RobolectricTestRunner;
+import org.robolectric.annotation.Config;
+import org.robolectric.shadows.ShadowLog;
+import org.robolectric.shadows.ShadowToast;
+
+import java.net.URISyntaxException;
+import java.util.Arrays;
+
+import moe.codeest.rxsocketclient.SocketSubscriber;
+
+import static junit.framework.Assert.assertEquals;
+import static junit.framework.Assert.assertNotNull;
+
+/**
+ * @author: Est <codeest.dev@gmail.com>
+ * @date: 2017/7/12
+ * @description:
+ */
+
+@RunWith(RobolectricTestRunner.class)
+@Config(constants = BuildConfig.class)
+public class SocketTest {
+
+    private JavaActivity activity;
+    private Button btnConnect, btnDisConnect, btnSend;
+    private TextView tvReceive;
+
+    @Before
+    public void setUp() throws URISyntaxException {
+        ShadowLog.stream = System.out;
+        activity = Robolectric.setupActivity(JavaActivity.class);
+        btnConnect = (Button) activity.findViewById(R.id.btn_connect);
+        btnDisConnect = (Button) activity.findViewById(R.id.btn_disconnect);
+        btnSend = (Button) activity.findViewById(R.id.btn_send);
+        tvReceive = (TextView) activity.findViewById(R.id.tv_receive);
+    }
+
+    @Test
+    public void testActivity() {
+        assertNotNull(activity);
+        assertEquals("RxSocketClientDemo", activity.getTitle());
+    }
+
+    @Test
+    public void testCallback(){
+        assertNotNull(activity);
+        TestSocketSubscriber subscriber = new TestSocketSubscriber();
+        activity.connect(subscriber);
+        subscriber.onConnected();
+        assertEquals("onConnected", ShadowToast.getTextOfLatestToast());
+        subscriber.onResponse(new byte[]{1, 2, 3});
+        assertEquals("[1, 2, 3]", tvReceive.getText());
+        subscriber.onDisconnected();
+        assertEquals("onDisConnected", ShadowToast.getTextOfLatestToast());
+    }
+
+    @Test
+    public void testUI(){
+        assertNotNull(btnConnect);
+        assertNotNull(btnDisConnect);
+        btnConnect.performClick();
+        btnDisConnect.performClick();
+    }
+
+    public class TestSocketSubscriber extends SocketSubscriber {
+
+        @Override
+        public void onConnected() {
+            Toast.makeText(activity, "onConnected", Toast.LENGTH_SHORT).show();
+        }
+
+        @Override
+        public void onDisconnected() {
+            Toast.makeText(activity, "onDisConnected", Toast.LENGTH_SHORT).show();
+        }
+
+        @Override
+        public void onResponse(@NotNull byte[] data) {
+            tvReceive.setText(Arrays.toString(data));
+        }
+    }
+
+}

app/src/test/java/moe/codeest/rxsocketclientdemo/SocketTest.java

@@ -10,6 +10,7 @@
 # Specifies the JVM arguments used for the daemon process.
 # The setting is particularly useful for tweaking memory settings.
 org.gradle.jvmargs=-Xmx1536m
+android.enableAapt2=false
 
 # When configured, Gradle will run in incubating parallel mode.
 # This option should only be used with decoupled projects. More details, visit