Contents

require 'socket'
require 'timeout'

class Eye::Client
  attr_reader :socket_path

  def initialize(socket_path)
    @socket_path = socket_path
  end
  
  def command(cmd, *args)
    attempt_command([cmd, *args] * '|')
  end
  
  def attempt_command(pack)
    Timeout.timeout(Eye::Settings.client_timeout) do
      return send_request(pack)
    end

  rescue Timeout::Error, EOFError
    :timeouted
  end

  def send_request(pack)
    UNIXSocket.open(@socket_path) do |socket|
      socket.puts(pack)
      data = socket.read
      res = Marshal.load(data) rescue :corrupred_marshal
    end
  end
  
end

Version data entries

11 entries across 11 versions & 2 rubygems

Version	Path
reel-eye-0.3.2	lib/eye/client.rb
eye-0.3.2	lib/eye/client.rb
reel-eye-0.3.1	lib/eye/client.rb
eye-0.3.1	lib/eye/client.rb
eye-0.3	lib/eye/client.rb
eye-0.2.4	lib/eye/client.rb
eye-0.2.3	lib/eye/client.rb
eye-0.2.2	lib/eye/client.rb
eye-0.2.1	lib/eye/client.rb
eye-0.2	lib/eye/client.rb
eye-0.1.11	lib/eye/client.rb