module LibZMQ
  extend FFI::Library
  LINUX = ["libzmq.so", "/usr/local/lib/libzmq.so", "/opt/local/lib/libzmq.so"]
  OSX = ["libzmq.dylib", "/usr/local/lib/libzmq.dylib", "/opt/local/lib/libzmq.dylib"]
  WINDOWS = []
  ffi_lib(LINUX + OSX + WINDOWS)

  # Message api
  class Msg_t < FFI::Struct
    layout :content,  :pointer,
    :flags,    :uint8,
    :vsm_size, :uint8,
    :vsm_data, [:uint8, 30]

  end # class Msg_t

  attach_function :zmq_msg_init, [:pointer], :int
  attach_function :zmq_msg_init_size, [:pointer, :size_t], :int
  callback :message_deallocator, [:pointer, :pointer], :void
  attach_function :zmq_msg_init_data, [:pointer, :pointer, :size_t, :message_deallocator, :pointer], :int
  attach_function :zmq_msg_close, [:pointer], :int
  attach_function :zmq_msg_data, [:pointer], :pointer
  attach_function :zmq_msg_size, [:pointer], :size_t
  attach_function :zmq_msg_copy, [:pointer, :pointer], :int
  attach_function :zmq_msg_move, [:pointer, :pointer], :int

  # Called by zmq_close
  MessageDeallocator = Proc.new do |data_ptr, hint_ptr|
    #puts "msg_callback: freed data [#{data_ptr}]"
    data_ptr.free
  end
end