Sha256: 2f1b078fa6069aa835b706324edd52637c909274794612e0957404de0a9b2b4c
Contents?: true
Size: 1.71 KB
Versions: 7
Compression:
Stored size: 1.71 KB
Contents
module Pusher
module NativeNotification
class Client
attr_reader :app_id, :host
API_PREFIX = "server_api"
API_VERSION = "v1"
def initialize(app_id, host, scheme, pusher_client)
@app_id = app_id
@host = host
@scheme = scheme
@pusher_client = pusher_client
end
# Send a notification via the native notifications API
def notify(interests, data = {})
Request.new(
@pusher_client,
:post,
url("/notifications"),
{},
payload(interests, data)
).send_sync
end
private
# {
# interests: [Array of interests],
# apns: {
# See https://pusher.com/docs/push_notifications/ios/server
# },
# gcm: {
# See https://pusher.com/docs/push_notifications/android/server
# }
# }
#
# @raise [Pusher::Error] if the interests array is empty
# @return [String]
def payload(interests, data)
interests = Array(interests).map(&:to_s)
raise Pusher::Error, "Interests array must not be empty" if interests.length == 0
data = deep_symbolize_keys!(data)
data.merge!(interests: interests)
MultiJson.encode(data)
end
def url(path = nil)
URI.parse("#{@scheme}://#{@host}/#{API_PREFIX}/#{API_VERSION}/apps/#{@app_id}#{path}")
end
# Symbolize all keys in the hash recursively
def deep_symbolize_keys!(hash)
hash.keys.each do |k|
ks = k.respond_to?(:to_sym) ? k.to_sym : k
hash[ks] = hash.delete(k)
deep_symbolize_keys!(hash[ks]) if hash[ks].kind_of?(Hash)
end
hash
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems