Fix SDKMAN automation

Author: mbhave

ci/images/releasescripts/src/main/java/io/spring/concourse/releasescripts/command/PublishToSdkmanCommand.java

@@ -37,12 +37,19 @@ public class PublishToSdkmanCommand implements Command {
 
 	private static final Logger logger = LoggerFactory.getLogger(PublishToSdkmanCommand.class);
 
+	private static final String PUBLISH_TO_SDKMAN_COMMAND = "publishToSdkman";
+
 	private final SdkmanService service;
 
 	public PublishToSdkmanCommand(SdkmanService service) {
 		this.service = service;
 	}
 
+	@Override
+	public String getName() {
+		return PUBLISH_TO_SDKMAN_COMMAND;
+	}
+
 	@Override
 	public void run(ApplicationArguments args) throws Exception {
 		logger.debug("Running 'push to SDKMAN' command");

ci/images/releasescripts/src/main/java/io/spring/concourse/releasescripts/sdkman/SdkmanService.java

@@ -25,7 +25,6 @@
 import org.springframework.http.MediaType;
 import org.springframework.http.RequestEntity;
 import org.springframework.stereotype.Component;
-import org.springframework.util.StringUtils;
 import org.springframework.web.client.RestTemplate;
 
 /**
@@ -47,13 +46,15 @@ public class SdkmanService {
 
 	private final RestTemplate restTemplate;
 
+	private final SdkmanProperties properties;
+
+	private final String CONSUMER_KEY_HEADER = "Consumer-Key";
+
+	private final String CONSUMER_TOKEN_HEADER = "Consumer-Token";
+
 	public SdkmanService(RestTemplateBuilder builder, SdkmanProperties properties) {
-		String consumerKey = properties.getConsumerKey();
-		String consumerToken = properties.getConsumerToken();
-		if (StringUtils.hasLength(consumerKey)) {
-			builder = builder.basicAuthentication(consumerKey, consumerToken);
-		}
 		this.restTemplate = builder.build();
+		this.properties = properties;
 	}
 
 	public void publish(String version, boolean makeDefault) {
@@ -67,6 +68,8 @@ public void publish(String version, boolean makeDefault) {
 	private void broadcast(String version) {
 		BroadcastRequest broadcastRequest = new BroadcastRequest(version);
 		RequestEntity<BroadcastRequest> broadcastEntity = RequestEntity.post(URI.create(SDKMAN_URL + "announce/struct"))
+				.header(CONSUMER_KEY_HEADER, this.properties.getConsumerKey())
+				.header(CONSUMER_TOKEN_HEADER, this.properties.getConsumerToken())
 				.contentType(MediaType.APPLICATION_JSON).body(broadcastRequest);
 		this.restTemplate.exchange(broadcastEntity, String.class);
 		logger.debug("Broadcast complete");
@@ -76,6 +79,8 @@ private void makeDefault(String version) {
 		logger.debug("Making this version the default");
 		Request request = new Request(version);
 		RequestEntity<Request> requestEntity = RequestEntity.post(URI.create(SDKMAN_URL + "default"))
+				.header(CONSUMER_KEY_HEADER, this.properties.getConsumerKey())
+				.header(CONSUMER_TOKEN_HEADER, this.properties.getConsumerToken())
 				.contentType(MediaType.APPLICATION_JSON).body(request);
 		this.restTemplate.exchange(requestEntity, String.class);
 		logger.debug("Make default complete");
@@ -84,6 +89,8 @@ private void makeDefault(String version) {
 	private void release(String version) {
 		ReleaseRequest releaseRequest = new ReleaseRequest(version, String.format(DOWNLOAD_URL, version, version));
 		RequestEntity<ReleaseRequest> releaseEntity = RequestEntity.post(URI.create(SDKMAN_URL + "release"))
+				.header(CONSUMER_KEY_HEADER, this.properties.getConsumerKey())
+				.header(CONSUMER_TOKEN_HEADER, this.properties.getConsumerToken())
 				.contentType(MediaType.APPLICATION_JSON).body(releaseRequest);
 		this.restTemplate.exchange(releaseEntity, String.class);
 		logger.debug("Release complete");

ci/images/releasescripts/src/test/java/io/spring/concourse/releasescripts/sdkman/SdkmanServiceTests.java

@@ -25,7 +25,6 @@
 import org.springframework.http.HttpMethod;
 import org.springframework.http.MediaType;
 import org.springframework.test.web.client.MockRestServiceServer;
-import org.springframework.util.Base64Utils;
 
 import static org.springframework.test.web.client.match.MockRestRequestMatchers.content;
 import static org.springframework.test.web.client.match.MockRestRequestMatchers.header;
@@ -80,10 +79,8 @@ void publishWhenMakeDefaultFalse() throws Exception {
 
 	private void setupExpectation(String url, String body) {
 		this.server.expect(requestTo(url)).andExpect(method(HttpMethod.POST)).andExpect(content().json(body))
-				.andExpect(header("Authorization",
-						"Basic " + Base64Utils.encodeToString(String
-								.format("%s:%s", this.properties.getConsumerKey(), this.properties.getConsumerToken())
-								.getBytes())))
+				.andExpect(header("Consumer-Key", "sdkman-consumer-key"))
+				.andExpect(header("Consumer-Token", "sdkman-consumer-token"))
 				.andExpect(header("Content-Type", MediaType.APPLICATION_JSON.toString())).andRespond(withSuccess());
 	}