class Terminalwire::Transport::Unix

def self.connect(url)
  uri = URI(url)
  new(UNIXSocket.new(uri.path))
end

def self.listen(url)
  uri = URI(url)
  new(UNIXServer.new(uri.path))
end

def close
  @socket.close
end

def initialize(socket)
  @socket = socket
end

def read
  length = @socket.read(4)
  return nil if length.nil?
  length = length.unpack('L>')[0]
  @socket.read(length)
end

def write(data)
  length = [data.bytesize].pack('L>')
  @socket.write(length + data)
end