1 files changed, 17 insertions, 3 deletions
diff --git a/lib/api/helpers/packages/dependency_proxy_helpers.rb b/lib/api/helpers/packages/dependency_proxy_helpers.rb
index b8ae1dddd7e..a09499e00d7 100644
--- a/lib/api/helpers/packages/dependency_proxy_helpers.rb
+++ b/lib/api/helpers/packages/dependency_proxy_helpers.rb
@@ -6,16 +6,18 @@ module API
       module DependencyProxyHelpers
         REGISTRY_BASE_URLS = {
           npm: 'https://registry.npmjs.org/',
-          pypi: 'https://pypi.org/simple/'
+          pypi: 'https://pypi.org/simple/',
+          maven: 'https://repo.maven.apache.org/maven2/'
         }.freeze
 
         APPLICATION_SETTING_NAMES = {
           npm: 'npm_package_requests_forwarding',
-          pypi: 'pypi_package_requests_forwarding'
+          pypi: 'pypi_package_requests_forwarding',
+          maven: 'maven_package_requests_forwarding'
         }.freeze
 
         def redirect_registry_request(forward_to_registry, package_type, options)
-          if forward_to_registry && redirect_registry_request_available?(package_type)
+          if forward_to_registry && redirect_registry_request_available?(package_type) && maven_forwarding_ff_enabled?(package_type, options[:target])
             ::Gitlab::Tracking.event(self.options[:for].name, "#{package_type}_request_forward")
             redirect(registry_url(package_type, options))
           else
@@ -33,6 +35,8 @@ module API
             "#{base_url}#{options[:package_name]}"
           when :pypi
             "#{base_url}#{options[:package_name]}/"
+          when :maven
+            "#{base_url}#{options[:path]}/#{options[:file_name]}"
           end
         end
 
@@ -46,6 +50,16 @@ module API
             .attributes
             .fetch(application_setting_name, false)
         end
+
+        private
+
+        def maven_forwarding_ff_enabled?(package_type, target)
+          return true unless package_type == :maven
+          return true if Feature.enabled?(:maven_central_request_forwarding)
+          return false unless target
+
+          Feature.enabled?(:maven_central_request_forwarding, target.root_ancestor)
+        end
       end
     end
   end