Headers for download by url

lib/carrierwave/mount.rb

@@ -166,6 +166,10 @@ def remote_#{column}_url=(url)
           _mounter(:#{column}).remote_urls = [url]
         end
 
+        def remote_#{column}_request_header=(header)
+          _mounter(:#{column}).remote_request_headers = [header]
+        end
+
         def write_#{column}_identifier
           return if frozen?
           mounter = _mounter(:#{column})
@@ -316,6 +320,10 @@ def remote_#{column}_urls=(urls)
           _mounter(:#{column}).remote_urls = urls
         end
 
+        def remote_#{column}_request_headers=(headers)
+          _mounter(:#{column}).remote_request_headers = headers
+        end
+
         def write_#{column}_identifier
           return if frozen?
           mounter = _mounter(:#{column})

lib/carrierwave/mounter.rb

@@ -3,8 +3,9 @@ module CarrierWave
   # this is an internal class, used by CarrierWave::Mount so that
   # we don't pollute the model with a lot of methods.
   class Mounter #:nodoc:
-    attr_reader :column, :record, :remote_urls, :integrity_error, :processing_error, :download_error
-    attr_accessor :remove
+    attr_reader :column, :record, :remote_urls, :integrity_error,
+      :processing_error, :download_error
+    attr_accessor :remove, :remote_request_headers
 
     def initialize(record, column, options={})
       @record = record
@@ -75,9 +76,9 @@ def remote_urls=(urls)
       @download_error = nil
       @integrity_error = nil
 
-      @uploaders = urls.map do |url|
+      @uploaders = urls.zip(remote_request_headers || []).map do |url, header|
         uploader = blank_uploader
-        uploader.download!(url)
+        uploader.download!(url, header || {})
         uploader
       end
 

lib/carrierwave/uploader/download.rb

@@ -10,8 +10,9 @@ module Download
       include CarrierWave::Uploader::Cache
 
       class RemoteFile
-        def initialize(uri)
+        def initialize(uri, remote_headers = {})
           @uri = uri
+          @remote_headers = remote_headers
         end
 
         def original_filename
@@ -35,7 +36,10 @@ def http?
 
         def file
           if @file.blank?
-            @file = Kernel.open(@uri.to_s, "User-Agent" => "CarrierWave/#{CarrierWave::VERSION}")
+            headers = @remote_headers.
+              reverse_merge('User-Agent' => "CarrierWave/#{CarrierWave::VERSION}")
+
+            @file = Kernel.open(@uri.to_s, headers)
             @file = @file.is_a?(String) ? StringIO.new(@file) : @file
           end
           @file
@@ -62,10 +66,11 @@ def method_missing(*args, &block)
       # === Parameters
       #
       # [url (String)] The URL where the remote file is stored
+      # [remote_headers (Hash)] Request headers
       #
-      def download!(uri)
+      def download!(uri, remote_headers = {})
         processed_uri = process_uri(uri)
-        file = RemoteFile.new(processed_uri)
+        file = RemoteFile.new(processed_uri, remote_headers)
         raise CarrierWave::DownloadError, "trying to download a file which is not served over HTTP" unless file.http?
         cache!(file)
       end

spec/mount_multiple_spec.rb

@@ -863,7 +863,7 @@ def monkey
 
     before do
       uploader.class_eval do
-        def download! uri
+        def download! uri, headers = {}
           raise CarrierWave::DownloadError
         end
       end

spec/mount_single_spec.rb

@@ -740,7 +740,7 @@ def monkey
 
     it "should raise an error if the image fails to be processed" do
       @uploader.class_eval do
-        def download! uri
+        def download! uri, headers = {}
           raise CarrierWave::DownloadError
         end
       end

spec/orm/activerecord_spec.rb

@@ -488,7 +488,7 @@ def monkey
       context 'when validating download' do
         before do
           @uploader.class_eval do
-            def download! file
+            def download! file, headers = {}
               raise CarrierWave::DownloadError
             end
           end
@@ -1209,7 +1209,7 @@ def monkey
       context 'when validating download' do
         before do
           @uploader.class_eval do
-            def download! file
+            def download! file, headers = {}
               raise CarrierWave::DownloadError
             end
           end

spec/uploader/download_spec.rb

@@ -8,6 +8,14 @@
   let(:url) { base_url + "/test.jpg" }
   let(:test_file) { File.read(file_path(test_file_name)) }
   let(:test_file_name) { "test.jpg" }
+  let(:authentication_headers) do
+    {
+      'Accept'=>'*/*',
+      'Accept-Encoding'=>'gzip;q=1.0,deflate;q=0.6,identity;q=0.3',
+      'User-Agent'=>"CarrierWave/#{CarrierWave::VERSION}",
+      'Authorization'=>'Bearer QWE'
+    }
+  end
 
   after { FileUtils.rm_rf(public_path) }
 
@@ -32,6 +40,10 @@
 
       stub_request(:get, "www.example.com/missing.jpg").
         to_return(status: 404)
+
+      stub_request(:get, "www.example.com/authorization_required.jpg").
+        with(:headers => authentication_headers).
+        to_return(body: test_file)
     end
 
     context "when a file was downloaded" do
@@ -83,6 +95,14 @@
       end
     end
 
+    context 'with request headers' do
+      it 'pass custom headers to request' do
+        auth_required_url = 'http://www.example.com/authorization_required.jpg'
+        uploader.download!(auth_required_url, { 'Authorization' => 'Bearer QWE' })
+        expect(uploader.url).to eq("/uploads/tmp/#{cache_id}/authorization_required.jpg")
+      end
+    end
+
     it "raises an error when trying to download a local file" do
       expect { uploader.download!('/etc/passwd') }.to raise_error(CarrierWave::DownloadError)
     end