Class: WebPush::Request

Inherits:
Object
  • Object
show all
Defined in:
lib/web_push/request.rb

Instance Method Summary collapse

Constructor Details

#initialize(message: '', subscription:, vapid:, **options) ⇒ Request

Returns a new instance of Request.



6
7
8
9
10
11
12
 
# File 'lib/web_push/request.rb', line 6

def initialize(message: '', subscription:, vapid:, **options)
  endpoint = subscription.fetch(:endpoint)
  @endpoint = endpoint
  @payload = build_payload(message, subscription)
  @vapid_options = vapid
  @options = default_options.merge(options)
end

Instance Method Details

#body ⇒ Object 



63
64
65
 
# File 'lib/web_push/request.rb', line 63

def body
  @payload || ''
end

#build_vapid_header ⇒ Object 



56
57
58
59
60
61
 
# File 'lib/web_push/request.rb', line 56

def build_vapid_header
  vapid_key = vapid_pem ? VapidKey.from_pem(vapid_pem) : VapidKey.from_keys(vapid_public_key, vapid_private_key)
  jwt = JWT.encode(jwt_payload, vapid_key.curve, 'ES256', jwt_header_fields)
  p256ecdsa = vapid_key.public_key_for_push_header
  "vapid t=#{jwt},k=#{p256ecdsa}"
end

#headers ⇒ Object 



38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/web_push/request.rb', line 38

def headers
  headers = {}
  headers['Content-Type'] = 'application/octet-stream'
  headers['Ttl']          = ttl
  headers['Urgency']      = urgency

  if @payload
    headers['Content-Encoding'] = 'aes128gcm'
    headers["Content-Length"] = @payload.length.to_s
  end

  if vapid?
    headers["Authorization"] = build_vapid_header
  end

  headers
end

#perform ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/web_push/request.rb', line 14

def perform
  http = Net::HTTP.new(uri.host, uri.port, *proxy_options)
  http.use_ssl = true
  http.ssl_timeout = @options[:ssl_timeout] unless @options[:ssl_timeout].nil?
  http.open_timeout = @options[:open_timeout] unless @options[:open_timeout].nil?
  http.read_timeout = @options[:read_timeout] unless @options[:read_timeout].nil?

  req = Net::HTTP::Post.new(uri.request_uri, headers)
  req.body = body

  resp = http.request(req)
  verify_response(resp)

  resp
end

#proxy_options ⇒ Object 



30
31
32
33
34
35
36
 
# File 'lib/web_push/request.rb', line 30

def proxy_options
  return [] unless @options[:proxy]

  proxy_uri = URI.parse(@options[:proxy])

  [proxy_uri.host, proxy_uri.port, proxy_uri.user, proxy_uri.password]
end