class AllQ::Peek

Public Instance Methods

base_send(tube, buried) click to toggle source
# File lib/allq/actions/peek.rb, line 26
def base_send(tube, buried)
  out = {
    'action' => 'peek',
    'params' => {
      'tube' => tube
    }
  }

  out['params']['buried'] = 'true' if buried
  out
end
rcv(data) click to toggle source
# File lib/allq/actions/peek.rb, line 14
def rcv(data)
  return nil if data.to_s == '' || data.to_s.strip == '{}'

  result = JSON.parse(data)
  if result['job']
    return nil if result['job'].empty?
    job = Job.new_from_hash(result['job'], @client)
    return job
  end
  nil
end
snd(data) click to toggle source
# File lib/allq/actions/peek.rb, line 4
def snd(data)
  result = nil
  tube = data.delete(:tube)
  buried = data.delete(:buried)

  send_data = base_send(tube, buried)
  response = send_hash_as_json(send_data)
  rcv(response)
end