Contents

require "base64"
require File.join File.dirname(File.expand_path(__FILE__)), "apn_connection.rb"
require File.join File.dirname(File.expand_path(__FILE__)), "gcm_connection.rb"

module Suj
  module Pusher
    class ConnectionPool
      include Suj::Pusher::Logger

      APN_SANDBOX = "gateway.sandbox.push.apple.com"
      APN_GATEWAY = "gateway.push.apple.com"
      APN_PORT = 2195

      def initialize(daemon)
        @pool = {}
        @daemon = daemon
      end

      def apn_connection(options = {})
        cert = Digest::SHA1.hexdigest options[:cert]
        info "APN connection #{cert}"
        @pool[cert] ||= EM.connect(APN_GATEWAY, APN_PORT, APNConnection, self, options)
      end

      def apn_sandbox_connection(options = {})
        cert = Digest::SHA1.hexdigest options[:cert]
        info "APN connection #{cert}"
        @pool[cert] ||= EM.connect(APN_SANDBOX, APN_PORT, APNConnection, self, options)
      end

      def gcm_connection(options = {})
        # All GCM connections are unique, even if they are to the same app.
        api_key = "#{options[:api_key]}#{rand * 100}"
        info "GCM connection #{api_key}"
        @pool[api_key] ||= Suj::Pusher::GCMConnection.new(self, api_key, options)
      end

      def remove_connection(key)
        info "Removing connection #{key}"
        @pool.delete(key)
      end

    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
suj-pusher-0.0.1	lib/suj/pusher/connection_pool.rb