Sha256: 9e7488c1bc4a78f91ee6b17e55ae6f8e73a7345bf101b13caf51da72b45e4373
Contents?: true
Size: 1.89 KB
Versions: 26
Compression:
Stored size: 1.89 KB
Contents
require 'ably/realtime/push/device_registrations'
require 'ably/realtime/push/channel_subscriptions'
module Ably::Realtime
class Push
# Class providing push notification administrative functionality
# for registering devices and attaching to channels etc.
class Admin
include Ably::Modules::AsyncWrapper
include Ably::Modules::Conversions
# @api private
attr_reader :client
# @api private
attr_reader :push
def initialize(push)
@push = push
@client = push.client
end
# (see Ably::Rest::Push#publish)
#
# @yield Block is invoked upon successful publish of the message
# @return [Ably::Util::SafeDeferrable]
#
def publish(recipient, data, &callback)
raise ArgumentError, "Expecting a Hash object for recipient, got #{recipient.class}" unless recipient.kind_of?(Hash)
raise ArgumentError, "Recipient data is empty. You must provide recipient details" if recipient.empty?
raise ArgumentError, "Expecting a Hash object for data, got #{data.class}" unless data.kind_of?(Hash)
raise ArgumentError, "Push data field is empty. You must provide attributes for the push notification" if data.empty?
async_wrap(callback) do
rest_push_admin.publish(recipient, data)
end
end
# Manage device registrations
# @return [Ably::Realtime::Push::DeviceRegistrations]
def device_registrations
@device_registrations ||= DeviceRegistrations.new(self)
end
# Manage channel subscriptions for devices or clients
# @return [Ably::Realtime::Push::ChannelSubscriptions]
def channel_subscriptions
@channel_subscriptions ||= ChannelSubscriptions.new(self)
end
private
def rest_push_admin
client.rest_client.push.admin
end
def logger
client.logger
end
end
end
end
Version data entries
26 entries across 26 versions & 2 rubygems