refactor code

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/MessageDeframer.java

@@ -16,10 +16,9 @@
 package com.taobao.arthas.grpcweb.proxy;
 
 import com.taobao.arthas.grpcweb.proxy.MessageUtils.ContentType;
-import com.taobao.arthas.grpcweb.proxy.util.IOUtils;
+import com.taobao.arthas.common.IOUtils;
 import com.alibaba.arthas.deps.org.slf4j.Logger;
 import com.alibaba.arthas.deps.org.slf4j.LoggerFactory;
-
 import java.io.IOException;
 import java.io.InputStream;
 import java.lang.invoke.MethodHandles;
@@ -63,7 +62,7 @@ public boolean processInput(InputStream in, MessageUtils.ContentType contentType
         byte[] inBytes;
         try {
             InputStream inStream = (contentType == ContentType.GRPC_WEB_TEXT) ? Base64.getDecoder().wrap(in) : in;
-            inBytes = IOUtils.toByteArray(inStream);
+            inBytes = IOUtils.getBytes(inStream);
         } catch (IOException e) {
             e.printStackTrace();
             logger.warn("invalid input");

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/MessageUtils.java

@@ -16,7 +16,6 @@
 package com.taobao.arthas.grpcweb.proxy;
 
 import com.google.common.annotations.VisibleForTesting;
-
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
 import java.util.HashMap;

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/MetadataUtil.java

@@ -17,7 +17,6 @@
 
 import io.grpc.Metadata;
 import io.netty.handler.codec.http.HttpHeaders;
-
 import java.util.*;
 
 class MetadataUtil {

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/SendGrpcWebResponse.java

@@ -23,7 +23,6 @@
 import io.netty.handler.stream.ChunkedStream;
 import com.alibaba.arthas.deps.org.slf4j.Logger;
 import com.alibaba.arthas.deps.org.slf4j.LoggerFactory;
-
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/server/GrpcWebProxyHandler.java

@@ -1,7 +1,5 @@
-
 package com.taobao.arthas.grpcweb.proxy.server;
 
-
 import com.taobao.arthas.grpcweb.proxy.GrpcServiceConnectionManager;
 import com.taobao.arthas.grpcweb.proxy.GrpcWebRequestHandler;
 import io.netty.buffer.Unpooled;

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/server/GrpcWebProxyServer.java

@@ -1,4 +1,3 @@
-
 package com.taobao.arthas.grpcweb.proxy.server;
 
 import io.netty.bootstrap.ServerBootstrap;

arthas-grpc-web-proxy/src/main/java/com/taobao/arthas/grpcweb/proxy/server/GrpcWebProxyServerInitializer.java

@@ -1,4 +1,3 @@
-
 package com.taobao.arthas.grpcweb.proxy.server;
 
 import io.netty.channel.ChannelInitializer;

arthas-grpc-web-proxy/src/test/java/com/taobao/arthas/grpcweb/proxy/server/GrpcWebProxyServerTest.java

@@ -32,16 +32,22 @@ public void startServer(){
         GRPC_PORT = SocketUtils.findAvailableTcpPort();
         // 启动grpc服务
         Thread grpcStart = new Thread(() -> {
-            startGrpcTest startGrpcTest = new startGrpcTest(GRPC_PORT);
+            StartGrpcTest startGrpcTest = new StartGrpcTest(GRPC_PORT);
             startGrpcTest.startGrpcService();
         });
         grpcStart.start();
         // 启动grpc-web-proxy服务
         Thread grpcWebProxyStart = new Thread(() -> {
-            startGrpcWebProxyTest startGrpcWebProxyTest = new startGrpcWebProxyTest(GRPC_WEB_PROXY_PORT,GRPC_PORT);
+            StartGrpcWebProxyTest startGrpcWebProxyTest = new StartGrpcWebProxyTest(GRPC_WEB_PROXY_PORT,GRPC_PORT);
             startGrpcWebProxyTest.startGrpcWebProxy();
         });
         grpcWebProxyStart.start();
+        try {
+            // waiting for the server to start
+            Thread.sleep(1000);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
         hostName = "http://127.0.0.1:" + GRPC_WEB_PROXY_PORT;
         httpClient = HttpClients.createDefault();
     }

arthas-grpc-web-proxy/src/test/java/com/taobao/arthas/grpcweb/proxy/server/startGrpcTest.java → arthas-grpc-web-proxy/src/test/java/com/taobao/arthas/grpcweb/proxy/server/StartGrpcTest.java

@@ -4,17 +4,16 @@
 import com.taobao.arthas.grpcweb.proxy.server.grpcService.GreeterService;
 import com.taobao.arthas.grpcweb.proxy.server.grpcService.HelloImpl;
 import io.grpc.BindableService;
-import io.grpc.Grpc;
 import io.grpc.Server;
 import io.grpc.ServerBuilder;
 
 import java.io.IOException;
 
-public class startGrpcTest {
+public class StartGrpcTest {
 
     private int GRPC_PORT;
 
-    public startGrpcTest(int grpcPort){
+    public StartGrpcTest(int grpcPort){
         this.GRPC_PORT = grpcPort;
     }
 

arthas-grpc-web-proxy/src/test/java/com/taobao/arthas/grpcweb/proxy/server/startGrpcWebProxyTest.java → arthas-grpc-web-proxy/src/test/java/com/taobao/arthas/grpcweb/proxy/server/StartGrpcWebProxyTest.java

@@ -1,13 +1,13 @@
 package com.taobao.arthas.grpcweb.proxy.server;
 
-public class startGrpcWebProxyTest {
+public class StartGrpcWebProxyTest {
 
     private int GRPC_WEB_PROXY_PORT;
 
     private int GRPC_PORT;
 
 
-    public startGrpcWebProxyTest(int grpcWebPort, int grpcPort){
+    public StartGrpcWebProxyTest(int grpcWebPort, int grpcPort){
         this.GRPC_WEB_PROXY_PORT = grpcWebPort;
         this.GRPC_PORT = grpcPort;
     }