working communication across Chrome and v8 inspector

Author: blagoev

…g/java/com/tns/AndroidJsV8Inspector.java …n/java/com/tns/AndroidJsV8Inspector.javatest-app/app/src/debug/java/com/tns/AndroidJsV8Inspector.java renamed to runtime/src/main/java/com/tns/AndroidJsV8Inspector.java test-app/app/src/debug/java/com/tns/AndroidJsV8Inspector.java renamed to runtime/src/main/java/com/tns/AndroidJsV8Inspector.java

@@ -1,27 +1,9 @@
 package com.tns;
 
-import android.content.BroadcastReceiver;
 import android.content.Context;
-import android.content.Intent;
-import android.content.IntentFilter;
-import android.content.pm.ApplicationInfo;
-import android.content.pm.PackageManager.NameNotFoundException;
-import android.net.LocalServerSocket;
-import android.net.LocalSocket;
-import android.os.Bundle;
-import android.os.Handler;
-import android.os.HandlerThread;
-
-import java.io.BufferedReader;
-import java.io.Closeable;
-import java.io.File;
+import android.util.Log;
+
 import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.OutputStream;
-import java.io.UnsupportedEncodingException;
-import java.util.ArrayList;
-import java.util.NoSuchElementException;
-import java.util.Scanner;
 
 import fi.iki.elonen.NanoHTTPD;
 import fi.iki.elonen.NanoWSD;
@@ -32,6 +14,11 @@ public class AndroidJsV8Inspector
     private Logger logger;
 	private Context context;
 
+    protected native final void init();
+    protected native final void connect(Object connection);
+    protected native final void disconnect();
+    protected native final void dispatchMessage(String message);
+
 
 	public AndroidJsV8Inspector(Context context, Logger logger)
 	{
@@ -44,21 +31,35 @@ public void start() throws IOException
         if (this.server == null)
         {
             this.server = new JsV8InspectorServer(context.getPackageName() + "-inspectorServer");
-            this.server.start();
+            this.server.start(-1);
+
+            init();
         }
     }
 
+    private static void send(Object connection, String payload) throws IOException
+    {
+        ((JsV8InspectorWebSocket)connection).send(payload);
+    }
+
     class JsV8InspectorServer extends NanoWSD
     {
         public JsV8InspectorServer(String name)
         {
             super(name);
         }
 
+        @Override
+        protected Response serveHttp(IHTTPSession session)
+        {
+            Log.d("{N}.v8-inspector", "http request for " + session.getUri());
+            return super.serveHttp(session);
+        }
+
         @Override
         protected WebSocket openWebSocket(IHTTPSession handshake)
         {
-            return null;
+            return new JsV8InspectorWebSocket(handshake);
         }
     }
 
@@ -73,33 +74,43 @@ public JsV8InspectorWebSocket(NanoHTTPD.IHTTPSession handshakeRequest)
         @Override
         protected void onOpen()
         {
-
+            Log.d("V8Inspector", "onOpen");
+            connect(this);
         }
 
         @Override
         protected void onClose(NanoWSD.WebSocketFrame.CloseCode code, String reason, boolean initiatedByRemote)
         {
-
+            Log.d("V8Inspector", "onClose");
+            disconnect();
         }
 
         @Override
         protected void onMessage(NanoWSD.WebSocketFrame message)
         {
+            Log.d("V8Inspector", "onMessage");
+            Log.d("V8Inspector", "onMessage TextPayload" + message.getTextPayload());
+            dispatchMessage(message.getTextPayload());
+        }
 
+        @Override
+        public void send(String payload) throws IOException
+        {
+            Log.d("V8Inspector", "send " + payload);
+            super.send(payload);
         }
 
         @Override
         protected void onPong(NanoWSD.WebSocketFrame pong)
         {
-
+            Log.d("V8Inspector", "onPong");
         }
 
         @Override
         protected void onException(IOException exception)
         {
-
+            exception.printStackTrace();
+            disconnect();
         }
     }
-
-
 }