From 540a2aa3b4f796e37b87b1e3bb81f1b530f54419 Mon Sep 17 00:00:00 2001
From: pingao <pingao777@gmail.com>
Date: Mon, 27 Aug 2018 11:53:58 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E9=A2=84=E8=A7=88=E9=A1=B5?=
 =?UTF-8?q?=E9=9D=A2=E5=85=B3=E9=97=AD=E9=87=8D=E6=96=B0=E6=89=93=E5=BC=80?=
 =?UTF-8?q?=E4=B8=8D=E6=98=BE=E7=A4=BA=E5=86=85=E5=AE=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 autoload/mpsync.vim                                          | 5 +++++
 autoload/python/java_vim_bridge.py                           | 4 ++++
 src/main/java/com/pingao/server/SocketServer.java            | 4 ++++
 .../java/com/pingao/server/TextWebSocketFrameHandler.java    | 5 +----
 src/main/webapp/js/index.js                                  | 5 -----
 5 files changed, 14 insertions(+), 9 deletions(-)

diff --git a/autoload/mpsync.vim b/autoload/mpsync.vim
index 23e2310..5a34df2 100644
--- a/autoload/mpsync.vim
+++ b/autoload/mpsync.vim
@@ -70,6 +70,11 @@ function! s:open()
             execute "silent !\"" . g:markdown_preview_sync_firefox_path . "\" http://127.0.0.1:" . g:markdown_preview_sync_port . "/index"
         endif
     endif
+
+python <<EOF
+path = vim.eval('expand("%:p")')
+java_vim_bridge.open(path)
+EOF
 endfunction
 
 function! s:sync()
diff --git a/autoload/python/java_vim_bridge.py b/autoload/python/java_vim_bridge.py
index d40eff6..e674ac0 100644
--- a/autoload/python/java_vim_bridge.py
+++ b/autoload/python/java_vim_bridge.py
@@ -40,6 +40,10 @@ def _connect(port, theme):
     s.send('start' + SEP + str(port) + SEP + theme + EOF)
 
 
+def open(path):
+    s.send('open' + SEP + path + EOF)
+
+
 def sync(path, content, bottom):
     s.send('sync' + SEP + path + SEP + content + SEP + str(bottom) + EOF)
 
diff --git a/src/main/java/com/pingao/server/SocketServer.java b/src/main/java/com/pingao/server/SocketServer.java
index 0a063e8..4a9a7cb 100644
--- a/src/main/java/com/pingao/server/SocketServer.java
+++ b/src/main/java/com/pingao/server/SocketServer.java
@@ -1,6 +1,7 @@
 package com.pingao.server;
 
 import com.pingao.utils.FileUtils;
+import com.pingao.utils.JSoupUtils;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.buffer.ByteBuf;
 import io.netty.buffer.Unpooled;
@@ -63,6 +64,9 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
                     server.setTheme(data[2]);
                     server.start(Integer.parseInt(data[1]));
                     break;
+                case "open":
+                    JSoupUtils.removeCache(data[1]);
+                    break;
                 case "sync":
                     server.broadcast("sync", data[1], data[2], Integer.parseInt(data[3]));
                     break;
diff --git a/src/main/java/com/pingao/server/TextWebSocketFrameHandler.java b/src/main/java/com/pingao/server/TextWebSocketFrameHandler.java
index e8d7238..cb28864 100644
--- a/src/main/java/com/pingao/server/TextWebSocketFrameHandler.java
+++ b/src/main/java/com/pingao/server/TextWebSocketFrameHandler.java
@@ -1,6 +1,5 @@
 package com.pingao.server;
 
-import com.pingao.utils.JSoupUtils;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
 import io.netty.handler.codec.http.websocketx.TextWebSocketFrame;
@@ -28,8 +27,6 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exc
     @Override
     public void channelRead0(ChannelHandlerContext ctx, TextWebSocketFrame msg) {
         msg.retain();
-        if (msg.text().contains("close")) {
-            JSoupUtils.removeCache(msg.text().split(",")[1]);
-        }
+        Logger.info("Received msg {}", msg.text());
     }
 }
diff --git a/src/main/webapp/js/index.js b/src/main/webapp/js/index.js
index acee6c0..f6f4911 100644
--- a/src/main/webapp/js/index.js
+++ b/src/main/webapp/js/index.js
@@ -104,11 +104,6 @@ $(function () {
     }
 
 
-    $(window).bind('beforeunload', function () {
-        ws.send('close,' + $('#path').val());
-    });
-
-
     self.mark_line = function (line) {
         if (ws !== null) {
             ws.send(line);