feat: NetTransporter implements peek method.

teletha · Jan 26, 2023 · f112d18 · f112d18
1 parent 6e66798
commit f112d18
Showing 1 changed file with 11 additions and 1 deletion.
diff --git a/src/main/java/bee/api/Repository.java b/src/main/java/bee/api/Repository.java
@@ -13,7 +13,10 @@
 import java.io.InputStream;
 import java.io.OutputStream;
 import java.net.HttpRetryException;
+import java.net.URI;
 import java.net.http.HttpHeaders;
+import java.net.http.HttpRequest;
+import java.net.http.HttpRequest.Builder;
 import java.net.http.HttpResponse;
 import java.nio.ByteBuffer;
 import java.time.LocalDate;
@@ -924,7 +927,14 @@ public void put(PutTask task) throws Exception {
                  */
                 @Override
                 public void peek(PeekTask task) throws Exception {
-                    throw new Error("HTTP PEEK is not implemented, please FIX.");
+                    URI uri = URI.create(repository.getUrl() + task.getLocation());
+                    Builder request = HttpRequest.newBuilder(uri).HEAD();
+                    I.http(request, HttpResponse.class).waitForTerminate().to((WiseConsumer<HttpResponse>) res -> {
+                        int code = res.statusCode();
+                        if (400 <= code) {
+                            throw new HttpRetryException("Fail to peek resource [" + uri + "]", code);
+                        }
+                    });
                 }
 
                 /**