Hi @rsl_lucky .
I happened to touch this topic recently and here is the same code. The code below uploads and image under /content/dam.
String aemHost = "<aem-host>";
long length = new File("test.png").length();
InputStream is = new FileInputStream("test.png");
Map<String, String> parameters = Map.of("fileSize", String.valueOf(length),
"fileName", "test.png");
String form = parameters.entrySet()
.stream()
.map(e -> e.getKey() + "=" + URLEncoder.encode(e.getValue(), StandardCharsets.UTF_8))
.collect(Collectors.joining("&"));
System.out.println("Init upload");
// initate upload and get meta info
HttpClient httpClient = HttpClient.newHttpClient();
HttpRequest request = HttpRequest.newBuilder(URI.create(aemHost + "/content/dam.initiateUpload.json"))
.POST(HttpRequest.BodyPublishers.ofString(form))
.header("Authorization", "Bearer <access-token>")
.header("Content-Type", "application/x-www-form-urlencoded")
.build();
HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString(StandardCharsets.UTF_8));
String body = response.body();
Gson gson = new Gson();
UploadResponse uploadResponse = gson.fromJson(body, UploadResponse.class);
System.out.println("Received Upload Info.");
System.out.println();
String uploadURI = uploadResponse.getFiles().get(0).uploadURIs.get(0);
System.out.println("Uploading chunk...");
// upload chunk to Blob storage
HttpRequest uploadRequest = HttpRequest.newBuilder(URI.create(uploadURI))
.header("Content-Type", "application/x-www-form-urlencoded")
.PUT(HttpRequest.BodyPublishers.ofByteArray(is.readAllBytes()))
.build();
HttpResponse<String> upload = httpClient.send(uploadRequest, HttpResponse.BodyHandlers.ofString());
if (upload.statusCode() != 201) {
System.out.println("Upload chunk failed: " + upload.statusCode());
System.out.println(upload.body());
return;
}
System.out.println("Chunk has been uploaded successfully.");
System.out.println();
Map<String, String> params = Map.of("mimeType", "image/png",
"uploadToken", uploadResponse.files.get(0).uploadToken,
"fileName", "test.png");
String uploadCompleteForm = params.entrySet()
.stream()
.map(e -> e.getKey() + "=" + e.getValue())
.collect(Collectors.joining("&"));
System.out.println("Completing upload...");
// Complete upload - Commit the uploaded blocks
HttpRequest uploadCompleteRequest = HttpRequest.newBuilder(URI.create(aemHost + uploadResponse.completeURI))
.POST(HttpRequest.BodyPublishers.ofString(uploadCompleteForm))
.header("Content-Type", "application/x-www-form-urlencoded")
.header("Authorization", "Bearer <access-token>")
.build();
HttpResponse<String> uploadCompleteResponse = httpClient.send(uploadCompleteRequest, HttpResponse.BodyHandlers.ofString());
System.out.println("Upload complete with status: " + uploadCompleteResponse.statusCode());
@Data
public class UploadResponse {
@SerializedName("folderPath")
@Expose
public String folderPath;
@SerializedName("files")
@Expose
public List<FileInfo> files;
@SerializedName("completeURI")
@Expose
public String completeURI;
}
@Data
public class FileInfo {
@SerializedName("fileName")
@Expose
public String fileName;
@SerializedName("uploadURIs")
@Expose
public List<String> uploadURIs;
@SerializedName("uploadToken")
@Expose
public String uploadToken;
@SerializedName("mimeType")
@Expose
public String mimeType;
@SerializedName("minPartSize")
@Expose
public Integer minPartSize;
@SerializedName("maxPartSize")
@Expose
public Integer maxPartSize;
}
