 fs = require 'fs'
-zmq = require 'zmq'
 _ = require 'lodash'
+jmp = require 'jmp'
+zmq = jmp.zmq
 
 shell_socket = zmq.socket 'dealer'
 io_socket    = zmq.socket 'sub'

shell_socket.on 'message', (msg...) ->
    console.log "new shell message"
    _.forEach(msg,(item) ->
            console.log "shell received:", item.toString('utf8'))

io_socket.on 'message', (msg...) ->
    console.log "new IO message"


# console.log io_socket

header = JSON.stringify
    msg_id: 0,
    username: "will",
    session: "00000000-0000-0000-0000-000000000000",
    msg_type: "execute_request",
    version: "5.0"

message = [
    '<IDS|MSG>',
    '',
    header,
    '{}',
    '{}',
    JSON.stringify
        code: "a - 4"
        silent: false
        store_history: true
        user_expressions: {}
        allow_stdin: false
]

shell_socket.send message
