Handle notify messagepack-rpc messages

Author: jebberjeb

src/neovim_client/message.clj

@@ -2,6 +2,7 @@
 
 (def +request+ 0)
 (def +response+ 1)
+(def +notify+ 2)
 
 (defn gen-msg-id
   "Get a unique message id."
@@ -18,7 +19,6 @@
   [id result]
   [1 id nil result])
 
-
 ;; TODO - find better way to get [B type.
 (def byte-array-type (type (.getBytes "foo")))
 
@@ -34,10 +34,13 @@
 
 ;; ***** Accessor fns *****
 (def msg-type first)
+
+;; Only true for request & response, notify has no id
 (def id second)
 
 (defn request? [msg] (= +request+ (msg-type msg)))
 (defn response? [msg] (= +response+ (msg-type msg)))
+(defn notify? [msg] (= +notify+ (msg-type msg)))
 
 (defn value
   [msg]
@@ -46,10 +49,10 @@
 
 (defn method
   [msg]
-  {:pre [(request? msg)]}
-  (bytes->str (nth msg 2)))
+  {:pre [(or (request? msg) (notify? msg))]}
+  (bytes->str (nth (reverse msg) 1)))
 
 (defn params
   [msg]
-  {:pre [(or (request? msg) (response? msg))]}
+  {:pre [(or (request? msg) (response? msg) (notify? msg))]}
   (last msg))

src/neovim_client/rpc.clj

@@ -17,6 +17,8 @@
   "Read messages from the input stream, put them on a channel."
   [input-stream]
   (let [chan (async/chan 1024)]
+    ;; TODO make these threads w/ loops, since they're handling IO
+    ;; might explain the wierd drlog blockages
     (async/go-loop
       []
       (when-let [msg (msgpack/unpack input-stream)]
@@ -101,6 +103,11 @@
           (let [f (get @method-table (method msg) method-not-found)
                 result (f msg)]
             (send-message-async!
-              component (->response-msg (id msg) result) nil)))
+              component (->response-msg (id msg) result) nil))
+
+          msg/+notify+
+          (let [f (get @method-table (method msg) method-not-found)
+                result (f msg)]))
+
         (recur))))
     component))