Send replies on the appropriate socket (Jupyter messaging protocol v5.4)

Author: halleysfifthinc

src/comm_manager.jl

@@ -59,7 +59,7 @@ function comm_info_request(sock, msg)
     end
     content = Dict(:comms => _comms)
 
-    send_ipython(IJulia.publish[],
+    send_ipython(sock,
                  msg_reply(msg, "comm_info_reply", content))
 end
 

src/handlers.jl

@@ -154,9 +154,9 @@ function complete_request(socket, msg)
 end
 
 function kernel_info_request(socket, msg)
-    send_ipython(requests[],
+    send_ipython(socket,
                  msg_reply(msg, "kernel_info_reply",
-                           Dict("protocol_version" => "5.0",
+                           Dict("protocol_version" => "5.4",
                                         "implementation" => "ijulia",
                                         "implementation_version" => pkgversion(@__MODULE__),
                                         "language_info" =>
@@ -189,7 +189,7 @@ function connect_request(socket, msg)
 end
 
 function shutdown_request(socket, msg)
-    send_ipython(requests[], msg_reply(msg, "shutdown_reply",
+    send_ipython(socket, msg_reply(msg, "shutdown_reply",
                                      msg.content))
     sleep(0.1) # short delay (like in ipykernel), to hopefully ensure shutdown_reply is sent
     exit()
@@ -271,7 +271,7 @@ end
 
 function interrupt_request(socket, msg)
     @async Base.throwto(requests_task[], InterruptException())
-    send_ipython(requests[], msg_reply(msg, "interrupt_reply", Dict()))
+    send_ipython(socket, msg_reply(msg, "interrupt_reply", Dict()))
 end
 
 function unknown_request(socket, msg)

src/msg.jl

@@ -20,7 +20,7 @@ msg_header(m::Msg, msg_type::String) = Dict("msg_id" => uuid4(),
                                             "session" => m.header["session"],
                                             "date" => now(),
                                             "msg_type" => msg_type,
-                                            "version" => "5.3")
+                                            "version" => "5.4")
 
 # PUB/broadcast messages use the msg_type as the ident, except for
 # stream messages which use the stream name (e.g. "stdout").