Consolidate maven repo accessibility check using System Properties

Author: shunping

buildSrc/build.gradle.kts

@@ -15,32 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-import java.net.HttpURLConnection
-import java.net.URL
-
-fun checkMavenCentralAccessibility(): Boolean {
-  val testUrl = "https://repo.maven.apache.org/maven2/org/slf4j/slf4j-api/1.7.2/slf4j-api-1.7.2.pom"
-  val accessible = try {
-    val connection = URL(testUrl).openConnection() as HttpURLConnection
-    connection.requestMethod = "GET"
-    connection.setRequestProperty("User-Agent", "Gradle")
-    connection.connectTimeout = 2000
-    connection.readTimeout = 2000
-    connection.useCaches = false
-    connection.responseCode == 200
-  } catch (e: Exception) {
-    false
-  }
-
-  if (accessible) {
-    logger.lifecycle("Maven Central is accessible. Using default repositories for buildSrc.")
-  } else {
-    logger.lifecycle("Maven Central is not accessible. Falling back to Google Maven Mirror for buildSrc.")
-  }
-  return accessible
-}
-
-val isMavenAccessible = checkMavenCentralAccessibility()
+val isMavenAccessible = System.getProperty("beam.maven.accessible")?.toBoolean() ?: true
 val mavenCentralMirrorUrl = "https://maven-central.storage-download.googleapis.com/maven2/"
 
 // Plugins for configuring _this build_ of the module
@@ -55,6 +30,7 @@ repositories {
   if (isMavenAccessible) {
     maven { url = uri("https://plugins.gradle.org/m2/") }
   } else {
+    logger.lifecycle("Maven Central is not accessible. Falling back to Google Maven Mirror for buildSrc.")
     maven { url = uri(mavenCentralMirrorUrl) }
     maven { url = uri("https://plugins.gradle.org/m2/") }
   }

buildSrc/src/main/groovy/org/apache/beam/gradle/Repositories.groovy

@@ -19,9 +19,6 @@
 package org.apache.beam.gradle
 
 import org.gradle.api.Project
-import java.net.HttpURLConnection
-import java.net.URL
-
 class Repositories {
 
   private static Boolean isMavenAccessible = null
@@ -30,23 +27,10 @@ class Repositories {
     if (isMavenAccessible != null) {
       return isMavenAccessible
     }
-    def testUrl = "https://repo.maven.apache.org/maven2/org/slf4j/slf4j-api/1.7.2/slf4j-api-1.7.2.pom"
-    try {
-      def url = new URL(testUrl)
-      def connection = (HttpURLConnection) url.openConnection()
-      connection.requestMethod = "GET"
-      connection.setRequestProperty("User-Agent", "Gradle")
-      connection.connectTimeout = 2000
-      connection.readTimeout = 2000
-      connection.useCaches = false
-      isMavenAccessible = (connection.responseCode == 200)
-    } catch (Exception e) {
-      isMavenAccessible = false
-    }
+    def prop = System.getProperty("beam.maven.accessible")
+    isMavenAccessible = prop != null ? Boolean.parseBoolean(prop) : true
 
-    if (isMavenAccessible) {
-      println "Maven Central is accessible. Using default repositories."
-    } else {
+    if (!isMavenAccessible) {
       println "Maven Central is not accessible. Redirecting to Google Maven Mirror."
     }
     return isMavenAccessible

settings.gradle.kts

@@ -29,6 +29,7 @@ pluginManagement {
     } catch (e: Exception) {
         false
     }
+    System.setProperty("beam.maven.accessible", isMavenAccessible.toString())
     val mavenCentralMirrorUrl = "https://maven-central.storage-download.googleapis.com/maven2/"
 
     if (isMavenAccessible) {