Sha256: f36cf13a0f466a6985c1fbda03694cb4874436f6e6b6acf4179c0cef8a3f9109
Contents?: true
Size: 1.86 KB
Versions: 15
Compression:
Stored size: 1.86 KB
Contents
require 'rhoconnect/ping'
module Rhoconnect
module PingJob
@queue = :ping
# Perform a ping for all clients registered to a user
def self.perform(params)
device_pins = []
phone_ids = []
user_ids = params['user_id']
user_ids = [user_ids] unless user_ids.is_a? Array
user_ids.each do |user|
ping_by_user user, params, device_pins, phone_ids
end
end
def self.ping_by_user(user_id, params, device_pins, phone_ids)
user = User.load(user_id)
user.clients.members.each do |client_id|
client = Client.load(client_id,{:source_name => '*'})
params.merge!('device_port' => client.device_port, 'device_pin' => client.device_pin, 'phone_id' => client.phone_id)
send_push = false
if client.device_type and client.device_type.size > 0
if client.phone_id and client.phone_id.size > 0
unless phone_ids.include? client.phone_id
phone_ids << client.phone_id
send_push = true
end
elsif client.device_pin and client.device_pin.size > 0
unless device_pins.include? client.device_pin
device_pins << client.device_pin
send_push = true
end
else
log "Skipping ping for non-registered client_id '#{client_id}'..."
next
end
if send_push
klass = Object.const_get(camelize(client.device_type.downcase))
if klass
params['vibrate'] = params['vibrate'].to_s
klass.ping(params)
end
else
log "Dropping ping request for client_id '#{client_id}' because it's already in user's device pin or phone_id list."
end
else
log "Skipping ping for non-registered client_id '#{client_id}'..."
end
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems