mcopy: support basic auth via URL (#451)

Author: itzg

src/main/java/me/itzg/helpers/http/FetchBuilderBase.java

@@ -1,17 +1,18 @@
 package me.itzg.helpers.http;
 
-import static io.netty.handler.codec.http.HttpHeaderNames.ACCEPT;
-import static io.netty.handler.codec.http.HttpHeaderNames.CONTENT_TYPE;
+import static io.netty.handler.codec.http.HttpHeaderNames.*;
 
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.netty.handler.codec.http.HttpHeaderNames;
 import io.netty.handler.codec.http.HttpHeaders;
 import io.netty.handler.codec.http.HttpStatusClass;
 import io.netty.handler.codec.http.HttpUtil;
 import java.net.URI;
+import java.nio.charset.StandardCharsets;
 import java.nio.file.Path;
 import java.time.ZoneId;
 import java.time.format.DateTimeFormatter;
+import java.util.Base64;
 import java.util.Collections;
 import java.util.HashMap;
 import java.util.HashSet;
@@ -241,6 +242,15 @@ protected void applyHeaders(io.netty.handler.codec.http.HttpHeaders headers) {
             );
         }
 
+        final String rawUserInfo = state.uri.getRawUserInfo();
+        if (rawUserInfo != null) {
+            headers.set(
+                AUTHORIZATION.toString(),
+                "Basic " +
+                    Base64.getEncoder().encodeToString(rawUserInfo.getBytes(StandardCharsets.UTF_8))
+            );
+        }
+
         state.requestHeaders.forEach(headers::set);
     }
 

src/main/java/me/itzg/helpers/http/OutputToDirectoryFetchBuilder.java

@@ -69,6 +69,7 @@ public Path execute() throws IOException {
     public Mono<Path> assemble() {
         return useReactiveClient(client ->
             client
+                .headers(this::applyHeaders)
                 .followRedirect(true)
                 .doOnRequest(debugLogRequest(log, "file head fetch"))
                 .head()
@@ -202,6 +203,7 @@ else if (skipUpToDate) {
         return alreadyUpToDateMono
             .filter(alreadyUpToDate -> !alreadyUpToDate)
             .flatMap(notUsed -> client
+                .headers(this::applyHeaders)
                 .headersWhen(headers ->
                     skipUpToDate ?
                         fileLastModifiedMono