feat: github apps support

Author: klopfdreh

spring-cloud-config-server/pom.xml

@@ -17,6 +17,11 @@
 		<relativePath>..</relativePath>
 	</parent>
 
+	<properties>
+		<jjwt.version>0.13.0</jjwt.version>
+		<bouncycastle.version>1.83</bouncycastle.version>
+	</properties>
+
 	<dependencies>
 		<dependency>
 			<groupId>org.springframework.boot</groupId>
@@ -92,6 +97,31 @@
 			<groupId>tools.jackson.dataformat</groupId>
 			<artifactId>jackson-dataformat-yaml</artifactId>
 		</dependency>
+		<dependency>
+			<groupId>io.jsonwebtoken</groupId>
+			<artifactId>jjwt-api</artifactId>
+			<version>${jjwt.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>io.jsonwebtoken</groupId>
+			<artifactId>jjwt-impl</artifactId>
+			<version>${jjwt.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>io.jsonwebtoken</groupId>
+			<artifactId>jjwt-jackson</artifactId>
+			<version>${jjwt.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.bouncycastle</groupId>
+			<artifactId>bcprov-jdk18on</artifactId>
+			<version>${bouncycastle.version}</version>
+		</dependency>
+		<dependency>
+			<groupId>org.bouncycastle</groupId>
+			<artifactId>bcpkix-jdk18on</artifactId>
+			<version>${bouncycastle.version}</version>
+		</dependency>
 		<dependency>
 			<groupId>org.tmatesoft.svnkit</groupId>
 			<artifactId>svnkit</artifactId>

spring-cloud-config-server/src/main/java/org/springframework/cloud/config/server/support/GitCredentialsProviderFactory.java

@@ -16,12 +16,32 @@
 
 package org.springframework.cloud.config.server.support;
 
+import com.fasterxml.jackson.databind.ObjectMapper;
+import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;
+import io.jsonwebtoken.Jwts;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.bouncycastle.asn1.pkcs.PrivateKeyInfo;
+import org.bouncycastle.openssl.PEMKeyPair;
+import org.bouncycastle.openssl.PEMParser;
 import org.eclipse.jgit.transport.CredentialsProvider;
 import org.eclipse.jgit.transport.UsernamePasswordCredentialsProvider;
-
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
 import org.springframework.util.ClassUtils;
+import org.springframework.web.client.RestTemplate;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.io.StringReader;
+import java.security.KeyFactory;
+import java.security.PrivateKey;
+import java.security.spec.PKCS8EncodedKeySpec;
+import java.time.Instant;
+import java.time.temporal.ChronoUnit;
+import java.util.Date;
 
 import static org.springframework.util.StringUtils.hasText;
 
@@ -44,6 +64,25 @@ public class GitCredentialsProviderFactory {
 	 */
 	protected boolean awsCodeCommitEnabled = true;
 
+	@Value("${spring.cloud.config.server.git.app:false}")
+	public boolean isApp;
+
+	@Value("${spring.cloud.config.server.git.appId:}")
+	public String appId;
+
+	@Value("${spring.cloud.config.server.git.apiUri:}")
+	public String apiUri;
+
+	@Value("${spring.cloud.config.server.git.installationId:}")
+	public String installationId;
+
+	@Value("${spring.cloud.config.server.git.jwtExpirationMinutes:0}")
+	private int jwtExpirationMinutes;
+
+	private String jwtToken;
+
+	private final ObjectMapper mapper = new ObjectMapper();
+
 	/**
 	 * Search for a credential provider that will handle the specified URI. If not found,
 	 * and the username or passphrase has text, then create a default using the provided
@@ -73,6 +112,7 @@ public CredentialsProvider createFor(String uri, String username, String passwor
 		}
 		else if (hasText(username) && password != null) {
 			this.logger.debug("Constructing UsernamePasswordCredentialsProvider for URI " + uri);
+			password = appToken(username, password);
 			provider = new UsernamePasswordCredentialsProvider(username, password.toCharArray());
 		}
 		else if (hasText(passphrase)) {
@@ -116,4 +156,66 @@ public void setAwsCodeCommitEnabled(boolean awsCodeCommitEnabled) {
 		this.awsCodeCommitEnabled = awsCodeCommitEnabled;
 	}
 
+	private String appToken(String username, String password) {
+		if (isApp && "x-access-token".equals(username)) {
+			try {
+				// if jwtToken is null or expired, generate a new one and set it to the field, otherwise use the existing one
+				if (jwtToken == null || Instant.parse(mapper.readTree(jwtToken).get("expires_at").asText()).isBefore(Instant.now())) {
+					this.logger.debug("Using app mode");
+					PrivateKey privateKey = loadPkcs1PrivateKey(password);
+					HttpHeaders headers = new HttpHeaders();
+					headers.setBearerAuth(generateJwt(appId, privateKey));
+					headers.set("Accept", "application/vnd.github+json");
+					HttpEntity<String> entity = new HttpEntity<>(headers);
+					RestTemplate restTemplate = new RestTemplate();
+					UriComponentsBuilder uriBuilder =
+						UriComponentsBuilder.fromUriString(apiUri)
+							.path("app/installations")
+							.pathSegment(installationId)
+							.path("access_tokens");
+					ResponseEntity<String> response = restTemplate.exchange(
+						uriBuilder.build().toUriString(),
+						HttpMethod.POST,
+						entity,
+						String.class
+					);
+					this.jwtToken = response.getBody();
+				}
+				password = mapper.readTree(jwtToken).get("token").asText();
+			} catch (Exception e) {
+				this.logger.error("Fehler beim Parsen des JWT Tokens", e);
+			}
+		}
+		return password;
+	}
+
+	private PrivateKey loadPkcs1PrivateKey(String password) {
+		try (PEMParser pemParser = new PEMParser(new StringReader(password))) {
+			Object object = pemParser.readObject();
+			PrivateKeyInfo privateKeyInfo;
+			if (object instanceof PEMKeyPair pemKeyPair) {
+				privateKeyInfo = pemKeyPair.getPrivateKeyInfo();
+			} else if (object instanceof PrivateKeyInfo privateKeyInfo1) {
+				privateKeyInfo = privateKeyInfo1;
+			} else {
+				throw new IllegalArgumentException("Unknown PEM object: " + object.getClass());
+			}
+			byte[] pkcs8Bytes = privateKeyInfo.getEncoded();
+			PKCS8EncodedKeySpec spec = new PKCS8EncodedKeySpec(pkcs8Bytes);
+			KeyFactory kf = KeyFactory.getInstance("RSA");
+			return kf.generatePrivate(spec);
+		} catch (Exception e) {
+			throw new IllegalStateException("An error occurred while loading the private key", e);
+		}
+	}
+
+	private String generateJwt(String appId, PrivateKey privateKey) {
+		Instant now = Instant.now();
+		return Jwts.builder()
+			.issuer(appId)
+			.issuedAt(Date.from(now))
+			.expiration(Date.from(now.plus(jwtExpirationMinutes, ChronoUnit.MINUTES)))
+			.signWith(privateKey)
+			.compact();
+	}
 }