Module: Rpush

Defined in:: lib/rpush.rb,
lib/rpush/cli.rb,
lib/rpush/push.rb,
lib/rpush/embed.rb,
lib/rpush/daemon.rb,
lib/rpush/logger.rb,
lib/rpush/plugin.rb,
lib/rpush/version.rb,
lib/rpush/daemon/adm.rb,
lib/rpush/daemon/gcm.rb,
lib/rpush/daemon/rpc.rb,
lib/rpush/daemon/wns.rb,
lib/rpush/daemon/apns.rb,
lib/rpush/daemon/wpns.rb,
lib/rpush/deprecation.rb,
lib/rpush/reflectable.rb,
lib/rpush/daemon/apns2.rb,
lib/rpush/daemon/batch.rb,
lib/rpush/deprecatable.rb,
lib/rpush/apns_feedback.rb,
lib/rpush/configuration.rb,
lib/rpush/daemon/errors.rb,
lib/rpush/daemon/feeder.rb,
lib/rpush/daemon/delivery.rb,
lib/rpush/daemon/loggable.rb,
lib/rpush/client/redis/app.rb,
lib/rpush/daemon/constants.rb,
lib/rpush/daemon/app_runner.rb,
lib/rpush/daemon/proc_title.rb,
lib/rpush/daemon/rpc/client.rb,
lib/rpush/daemon/rpc/server.rb,
lib/rpush/multi_json_helper.rb,
lib/rpush/daemon/ring_buffer.rb,
lib/rpush/daemon/store/redis.rb,
lib/rpush/daemon/adm/delivery.rb,
lib/rpush/daemon/gcm/delivery.rb,
lib/rpush/daemon/synchronizer.rb,
lib/rpush/daemon/wns/delivery.rb,
lib/rpush/client/redis/adm/app.rb,
lib/rpush/client/redis/gcm/app.rb,
lib/rpush/client/redis/wns/app.rb,
lib/rpush/daemon/apns/delivery.rb,
lib/rpush/daemon/queue_payload.rb,
lib/rpush/daemon/wpns/delivery.rb,
lib/rpush/client/redis/apns/app.rb,
lib/rpush/client/redis/wpns/app.rb,
lib/rpush/daemon/apns2/delivery.rb,
lib/rpush/daemon/delivery_error.rb,
lib/rpush/daemon/dispatcher/tcp.rb,
lib/rpush/daemon/signal_handler.rb,
lib/rpush/daemon/string_helpers.rb,
lib/rpush/daemon/tcp_connection.rb,
lib/rpush/reflection_collection.rb,
lib/rpush/client/redis/apns2/app.rb,
lib/rpush/daemon/dispatcher/http.rb,
lib/rpush/daemon/dispatcher_loop.rb,
lib/rpush/daemon/retryable_error.rb,
lib/rpush/daemon/store/interface.rb,
lib/rpush/daemon/wns/raw_request.rb,
lib/rpush/daemon/wns/post_request.rb,
lib/rpush/client/active_record/app.rb,
lib/rpush/daemon/wns/badge_request.rb,
lib/rpush/daemon/wns/toast_request.rb,
lib/rpush/client/redis/notification.rb,
lib/rpush/reflection_public_methods.rb,
lib/rpush/client/redis/apns/feedback.rb,
lib/rpush/daemon/dispatcher/apns_tcp.rb,
lib/rpush/daemon/interruptible_sleep.rb,
lib/rpush/daemon/retry_header_parser.rb,
lib/rpush/daemon/store/active_record.rb,
lib/rpush/client/active_model/adm/app.rb,
lib/rpush/client/active_model/gcm/app.rb,
lib/rpush/client/active_model/wns/app.rb,
lib/rpush/client/active_model/apns/app.rb,
lib/rpush/client/active_model/wpns/app.rb,
lib/rpush/client/active_record/adm/app.rb,
lib/rpush/client/active_record/gcm/app.rb,
lib/rpush/client/active_record/wns/app.rb,
lib/rpush/daemon/dispatcher/apns_http2.rb,
lib/rpush/client/active_model/apns2/app.rb,
lib/rpush/client/active_record/apns/app.rb,
lib/rpush/client/active_record/wpns/app.rb,
lib/rpush/client/redis/adm/notification.rb,
lib/rpush/client/redis/gcm/notification.rb,
lib/rpush/client/redis/wns/notification.rb,
lib/rpush/daemon/apns/feedback_receiver.rb,
lib/rpush/daemon/service_config_methods.rb,
lib/rpush/client/active_record/apns2/app.rb,
lib/rpush/client/redis/apns/notification.rb,
lib/rpush/client/redis/wpns/notification.rb,
lib/rpush/client/redis/apns2/notification.rb,
lib/rpush/client/active_model/notification.rb,
lib/rpush/client/active_record/notification.rb,
lib/rpush/client/redis/wns/raw_notification.rb,
lib/rpush/client/active_record/apns/feedback.rb,
lib/rpush/client/redis/wns/badge_notification.rb,
lib/rpush/client/active_model/adm/notification.rb,
lib/rpush/client/active_model/gcm/notification.rb,
lib/rpush/client/active_model/wns/notification.rb,
lib/rpush/client/active_model/apns/notification.rb,
lib/rpush/client/active_model/wpns/notification.rb,
lib/rpush/client/active_record/adm/notification.rb,
lib/rpush/client/active_record/gcm/notification.rb,
lib/rpush/client/active_record/wns/notification.rb,
lib/rpush/client/active_model/adm/data_validator.rb,
lib/rpush/client/active_model/apns2/notification.rb,
lib/rpush/client/active_record/apns/notification.rb,
lib/rpush/client/active_record/wpns/notification.rb,
lib/rpush/client/active_record/apns2/notification.rb,
lib/rpush/daemon/store/active_record/reconnectable.rb,
lib/rpush/client/active_record/wns/raw_notification.rb,
lib/rpush/client/active_record/wns/badge_notification.rb,
lib/rpush/client/active_model/payload_data_size_validator.rb,
lib/rpush/client/active_model/registration_ids_count_validator.rb,
lib/rpush/client/active_model/apns/binary_notification_validator.rb,
lib/rpush/client/active_model/apns/device_token_format_validator.rb,
lib/rpush/client/active_model/gcm/expiry_collapse_key_mutual_inclusion_validator.rb

Defined Under Namespace

Modules: Client, Daemon, Deprecatable, MultiJsonHelper, Reflectable, VERSION Classes: ApnsConfiguration, ApnsFeedbackReceiverConfiguration, CLI, CertificateExpiredError, Configuration, ConfigurationError, ConfigurationWithoutDefaults, DeliveryError, Deprecation, Logger, Plugin, RateLimitError, ReflectionCollection, RetryableError

Constant Summary collapse

CURRENT_ATTRS =

[:push_poll, :embedded, :pid_file, :batch_size, :push, :client, :logger, :log_file, :foreground, :log_level, :plugin, :apns]

DEPRECATED_ATTRS =

[]

CONFIG_ATTRS =

CURRENT_ATTRS + DEPRECATED_ATTRS

Class Attribute Summary collapse

.config ⇒ Object
.logger ⇒ Object
.reflection_stack ⇒ Object readonly

Returns the value of attribute reflection_stack.

Class Method Summary collapse

Class Attribute Details

.config ⇒ `Object`



8
9
10

# File 'lib/rpush/configuration.rb', line 8

def config
  @config ||= Rpush::Configuration.new
end

.logger ⇒ `Object`



28
29
30

# File 'lib/rpush.rb', line 28

def self.logger
  @logger ||= Logger.new
end

.reflection_stack ⇒ `Object` (readonly)

Returns the value of attribute reflection_stack.



5
6
7

# File 'lib/rpush/reflection_public_methods.rb', line 5

def reflection_stack
  @reflection_stack
end

Class Method Details

.apns_feedback ⇒ `Object`

# File 'lib/rpush/apns_feedback.rb', line 2

def self.apns_feedback
  require 'rpush/daemon'
  Rpush::Daemon.common_init

  Rpush::Apns::App.all.each do |app|
    # Redis stores every App type on the same namespace, hence the
    # additional filtering
    next unless app.service_name == 'apns'

    receiver = Rpush::Daemon::Apns::FeedbackReceiver.new(app)
    receiver.check_for_feedback
  end

  nil
end

.configure {|config| ... } ⇒ `Object`

Yields:

(config)

# File 'lib/rpush/configuration.rb', line 12

def configure
  return unless block_given?
  yield config
  config.initialize_client
end

.debug ⇒ `Object`



38
39
40

# File 'lib/rpush/embed.rb', line 38

def self.debug
  status
end

.embed ⇒ `Object`

# File 'lib/rpush/embed.rb', line 2

def self.embed
  require 'rpush/daemon'

  if @embed_thread
    STDERR.puts 'Rpush.embed can only be run once inside this process.'
  end

  Rpush.config.embedded = true
  Rpush.config.foreground = true
  Kernel.at_exit { shutdown }
  @embed_thread = Thread.new { Rpush::Daemon.start }
end

.jruby? ⇒ `Boolean`

Returns:

(Boolean)



24
25
26

# File 'lib/rpush.rb', line 24

def self.jruby?
  defined? JRUBY_VERSION
end

.plugin(name) ⇒ `Object`

# File 'lib/rpush/plugin.rb', line 2

def self.plugin(name)
  plugins[name] ||= Rpush::Plugin.new(name)
  plugins[name]
end

.plugins ⇒ `Object`



7
8
9

# File 'lib/rpush/plugin.rb', line 7

def self.plugins
  @plugins ||= {}
end

.push ⇒ `Object`

# File 'lib/rpush/push.rb', line 2

def self.push
  require 'rpush/daemon'

  Rpush.config.push = true
  Rpush::Daemon.common_init
  Rpush::Daemon::Synchronizer.sync
  Rpush::Daemon::Feeder.start(true) # non-blocking
  Rpush::Daemon::AppRunner.stop
end

.reflect {|| ... } ⇒ `Object`

Yields:

()



8
9
10

# File 'lib/rpush/reflection_public_methods.rb', line 8

def self.reflect
  yield reflection_stack[0] if block_given?
end

.root ⇒ `Object`

# File 'lib/rpush.rb', line 32

def self.root
  require 'rails'
  Rails.root || Dir.pwd
rescue LoadError
  Dir.pwd
end

.shutdown ⇒ `Object`

# File 'lib/rpush/embed.rb', line 15

def self.shutdown
  return unless Rpush.config.embedded
  Rpush::Daemon.shutdown
  @embed_thread.join if @embed_thread
rescue StandardError => e
  STDERR.puts(e.message)
  STDERR.puts(e.backtrace.join("\n"))
ensure
  @embed_thread = nil
end

.status ⇒ `Object`

# File 'lib/rpush/embed.rb', line 31

def self.status
  return unless Rpush.config.embedded
  status = Rpush::Daemon::AppRunner.status
  Rpush.logger.info(JSON.pretty_generate(status))
  status
end

.sync ⇒ `Object`

# File 'lib/rpush/embed.rb', line 26

def self.sync
  return unless Rpush.config.embedded
  Rpush::Daemon::Synchronizer.sync
end

Module: Rpush

Defined Under Namespace

Constant Summary collapse

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

.config ⇒ Object

.logger ⇒ Object

.reflection_stack ⇒ Object (readonly)

Class Method Details

.apns_feedback ⇒ Object

.configure {|config| ... } ⇒ Object

.debug ⇒ Object

.embed ⇒ Object

.jruby? ⇒ Boolean

.plugin(name) ⇒ Object

.plugins ⇒ Object

.push ⇒ Object

.reflect {|| ... } ⇒ Object

.root ⇒ Object

.shutdown ⇒ Object

.status ⇒ Object

.sync ⇒ Object

.config ⇒ `Object`

.logger ⇒ `Object`

.reflection_stack ⇒ `Object` (readonly)

.apns_feedback ⇒ `Object`

.configure {|config| ... } ⇒ `Object`

.debug ⇒ `Object`

.embed ⇒ `Object`

.jruby? ⇒ `Boolean`

.plugin(name) ⇒ `Object`

.plugins ⇒ `Object`

.push ⇒ `Object`

.reflect {|| ... } ⇒ `Object`

.root ⇒ `Object`

.shutdown ⇒ `Object`

.status ⇒ `Object`

.sync ⇒ `Object`