Sha256: d6e80e79d46a57689e4ddebabad6e85b6bc719d84e6b6ecd6c3707af46080387
Contents?: true
Size: 1.93 KB
Versions: 1
Compression:
Stored size: 1.93 KB
Contents
require 'openssl' require 'socket' module ApnsSimple class Client attr_reader :certificate, :ssl_context, :host, :port COMMAND = 8 CODES = { 0 => 'No errors encountered', 1 => 'Processing error', 2 => 'Missing device token', 3 => 'Missing topic', 4 => 'Missing payload', 5 => 'Invalid token size', 6 => 'Invalid topic size', 7 => 'Invalid payload size', 8 => 'Invalid token', 10 => 'Shutdown', 255 => 'Unknown error' } def initialize(options) @certificate = options.fetch(:certificate) passphrase = options[:passphrase] || '' @ssl_context = OpenSSL::SSL::SSLContext.new @ssl_context.key = OpenSSL::PKey::RSA.new(certificate, passphrase) gateway_uri = options[:gateway_uri] || 'apn://gateway.push.apple.com:2195' @host, @port = parse_gateway_uri(gateway_uri) end def push(notification) begin current_time = Time.now.utc cert = OpenSSL::X509::Certificate.new(certificate) if current_time < cert.not_before || current_time > cert.not_after raise CertificateActivenessTimeError, "CURRENT_TIME: #{current_time}, NOT_BEFORE: #{cert.not_before}, NOT_AFTER: #{cert.not_after}" end ssl_context.cert = cert sock = TCPSocket.new(host, port) ssl = OpenSSL::SSL::SSLSocket.new(sock, ssl_context) ssl.connect ssl.write(notification.payload) ssl.flush if IO.select([ssl], nil, nil, 1) && error = ssl.read(6) command, status, _index = error.unpack("ccN") notification.error = command == COMMAND ? "#{status}: #{CODES[status]}" : "Unknown command received from APNS server: #{command}" end ensure ssl.close if ssl sock.close if sock end end private def parse_gateway_uri(uri) first, last = uri.sub('apn://', '').split(':') [first, last.to_i] end end end
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
apns_simple-0.7.0 | lib/apns_simple/client.rb |