Merge pull request #93 from Bugagazavr/proxy-support

Add proxy support

lib/webpush/request.rb

@@ -1,5 +1,6 @@
 # frozen_string_literal: true
 
+require 'uri'
 require 'jwt'
 require 'base64'
 
@@ -20,21 +21,30 @@ def initialize(message: '', subscription:, vapid:, **options)
 
     # rubocop:disable Metrics/AbcSize
     def perform
-      http = Net::HTTP.new(uri.host, uri.port)
+      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
     # rubocop:enable Metrics/AbcSize
 
+    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
+
     # rubocop:disable Metrics/MethodLength
     def headers
       headers = {}

spec/webpush/request_spec.rb

@@ -131,6 +131,20 @@ def build_request_with_api_key(endpoint, options = {})
     end
   end
 
+  describe '#proxy_options' do
+    it 'returns an array of proxy options' do
+      request = build_request(proxy: 'http://user:password@proxy_addr:8080')
+
+      expect(request.proxy_options).to eq(['proxy_addr', 8080, 'user', 'password'])
+    end
+
+    it 'returns empty array' do
+      request = build_request
+
+      expect(request.proxy_options).to be_empty
+    end
+  end
+
   def build_request(options = {})
     subscription = {
       endpoint: endpoint,