Contents

module Rpush
  module Daemon
    module Dispatcher
      class ApnsHttp2

        URLS = {
          production: 'https://api.push.apple.com:443',
          development: 'https://api.development.push.apple.com:443'
        }

        DEFAULT_TIMEOUT = 60

        def initialize(app, delivery_class, _options = {})
          @app = app
          @delivery_class = delivery_class

          url = URLS[app.environment.to_sym]
          @client = NetHttp2::Client.new(url,
            ssl_context:     prepare_ssl_context,
            connect_timeout: DEFAULT_TIMEOUT)
        end

        def dispatch(payload)
          @delivery_class.new(@app, @client, payload.batch).perform
        end

        def cleanup
          @client.close
        end

        private

        def prepare_ssl_context
          @ssl_context ||= begin
            ctx = OpenSSL::SSL::SSLContext.new
            begin
              p12      = OpenSSL::PKCS12.new(@app.certificate, @app.password)
              ctx.key  = p12.key
              ctx.cert = p12.certificate
            rescue OpenSSL::PKCS12::PKCS12Error
              ctx.key  = OpenSSL::PKey::RSA.new(@app.certificate, @app.password)
              ctx.cert = OpenSSL::X509::Certificate.new(@app.certificate)
            end
            ctx
          end
        end
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rpush-3.0.2	lib/rpush/daemon/dispatcher/apns_http2.rb
rpush-3.0.1	lib/rpush/daemon/dispatcher/apns_http2.rb
rpush-3.0.0	lib/rpush/daemon/dispatcher/apns_http2.rb
rpush-3.0.0.rc1	lib/rpush/daemon/dispatcher/apns_http2.rb