/*

* MinIO Java SDK for Amazon S3 Compatible Cloud Storage,

* (C) 2015, 2016, 2017, 2018 MinIO, Inc.

*

* Licensed under the Apache License, Version 2.0 (the "License");

* you may not use this file except in compliance with the License.

* You may obtain a copy of the License at

*

* http://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS,

* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

* See the License for the specific language governing permissions and

* limitations under the License.

*/

import java.security.*;

import java.math.BigInteger;

import java.util.*;

import java.io.*;

import java.util.concurrent.TimeUnit;

import static java.nio.file.StandardOpenOption.*;

import java.nio.file.*;

import java.nio.charset.StandardCharsets;

import javax.crypto.KeyGenerator;

import javax.crypto.spec.SecretKeySpec;

import edu.umd.cs.findbugs.annotations.SuppressFBWarnings;

import org.joda.time.DateTime;

import okhttp3.OkHttpClient;

import okhttp3.HttpUrl;

import okhttp3.Request;

import okhttp3.RequestBody;

import okhttp3.MultipartBody;

import okhttp3.Response;

import io.minio.*;

import io.minio.messages.*;

import io.minio.errors.*;

import io.minio.notification.*;

@SuppressFBWarnings(value = "REC", justification = "Allow catching super class Exception since it's tests")

public class FunctionalTest {

private static final String PASS = "PASS";

private static final String FAILED = "FAIL";

private static final String IGNORED = "NA";

private static final int KB = 1024;

private static final int MB = 1024 * 1024;

private static final Random random = new Random(new SecureRandom().nextLong());

private static final String customContentType = "application/javascript";

private static final String nullContentType = null;

private static String bucketName = getRandomName();

private static boolean mintEnv = false;

private static Path dataFile1Kb;

private static Path dataFile6Mb;

private static String endpoint;

private static String accessKey;

private static String secretKey;

private static String region;

private static MinioClient client = null;

/**

* Do no-op.

*/

public static void ignore(Object... args) {

}

/**

* Create given sized file and returns its name.

*/

public static String createFile(int size) throws IOException {

String filename = getRandomName();

try (OutputStream os = Files.newOutputStream(Paths.get(filename), CREATE, APPEND)) {

int totalBytesWritten = 0;

int bytesToWrite = 0;

byte[] buf = new byte[1 * MB];

while (totalBytesWritten < size) {

random.nextBytes(buf);

bytesToWrite = size - totalBytesWritten;

if (bytesToWrite > buf.length) {

bytesToWrite = buf.length;

}

os.write(buf, 0, bytesToWrite);

totalBytesWritten += bytesToWrite;

}

}

return filename;

}

/**

* Create 1 KB temporary file.

*/

public static String createFile1Kb() throws IOException {

if (mintEnv) {

String filename = getRandomName();

Files.createSymbolicLink(Paths.get(filename).toAbsolutePath(), dataFile1Kb);

return filename;

}

return createFile(1 * KB);

}

/**

* Create 6 MB temporary file.

*/

public static String createFile6Mb() throws IOException {

if (mintEnv) {

String filename = getRandomName();

Files.createSymbolicLink(Paths.get(filename).toAbsolutePath(), dataFile6Mb);

return filename;

}

return createFile(6 * MB);

}

/**

* Generate random name.

*/

public static String getRandomName() {

return "minio-java-test-" + new BigInteger(32, random).toString(32);

}

/**

* Returns byte array contains all data in given InputStream.

*/

public static byte[] readAllBytes(InputStream is) throws IOException {

ByteArrayOutputStream buffer = new ByteArrayOutputStream();

int nRead;

byte[] data = new byte[16384];

while ((nRead = is.read(data, 0, data.length)) != -1) {

buffer.write(data, 0, nRead);

}

return buffer.toByteArray();

}

/**

* Prints a success log entry in JSON format.

*/

public static void mintSuccessLog(String function, String args, long startTime) {

if (mintEnv) {

System.out

.println(new MintLogger(function, args, System.currentTimeMillis() - startTime, PASS, null, null, null));

}

}

/**

* Prints a failure log entry in JSON format.

*/

public static void mintFailedLog(String function, String args, long startTime, String message, String error) {

if (mintEnv) {

System.out.println(

new MintLogger(function, args, System.currentTimeMillis() - startTime, FAILED, null, message, error));

}

}

/**

* Prints a ignore log entry in JSON format.

*/

public static void mintIgnoredLog(String function, String args, long startTime) {

if (mintEnv) {

System.out

.println(new MintLogger(function, args, System.currentTimeMillis() - startTime, IGNORED, null, null, null));

}

}

/**

* Read object content of the given url.

*/

public static byte[] readObject(String urlString) throws Exception {

Request.Builder requestBuilder = new Request.Builder();

Request request = requestBuilder.url(HttpUrl.parse(urlString)).method("GET", null).build();

OkHttpClient transport = new OkHttpClient().newBuilder().connectTimeout(20, TimeUnit.SECONDS)

.writeTimeout(20, TimeUnit.SECONDS).readTimeout(20, TimeUnit.SECONDS).build();

Response response = transport.newCall(request).execute();

if (response == null) {

throw new Exception("empty response");

}

if (!response.isSuccessful()) {

String errorXml = "";

// read entire body stream to string.

Scanner scanner = new Scanner(response.body().charStream());

scanner.useDelimiter("\\A");

if (scanner.hasNext()) {

errorXml = scanner.next();

}

scanner.close();

response.body().close();

throw new Exception("failed to read object. Response: " + response + ", Response body: " + errorXml);

}

return readAllBytes(response.body().byteStream());

}

/**

* Write data to given object url.

*/

public static void writeObject(String urlString, byte[] dataBytes) throws Exception {

Request.Builder requestBuilder = new Request.Builder();

// Set header 'x-amz-acl' to 'bucket-owner-full-control', so objects created

// anonymously, can be downloaded by bucket owner in AWS S3.

Request request = requestBuilder.url(HttpUrl.parse(urlString)).method("PUT", RequestBody.create(null, dataBytes))

.addHeader("x-amz-acl", "bucket-owner-full-control").build();

OkHttpClient transport = new OkHttpClient().newBuilder().connectTimeout(20, TimeUnit.SECONDS)

.writeTimeout(20, TimeUnit.SECONDS).readTimeout(20, TimeUnit.SECONDS).build();

Response response = transport.newCall(request).execute();

if (response == null) {

throw new Exception("empty response");

}

if (!response.isSuccessful()) {

String errorXml = "";

// read entire body stream to string.

Scanner scanner = new Scanner(response.body().charStream());

scanner.useDelimiter("\\A");

if (scanner.hasNext()) {

errorXml = scanner.next();

}

scanner.close();

response.body().close();

throw new Exception("failed to create object. Response: " + response + ", Response body: " + errorXml);

}

}

/**

* Test: makeBucket(String bucketName).

*/

public static void makeBucket_test1() throws Exception {

if (!mintEnv) {

System.out.println("Test: makeBucket(String bucketName)");

}

long startTime = System.currentTimeMillis();

try {

String name = getRandomName();

client.makeBucket(name);

client.removeBucket(name);

mintSuccessLog("makeBucket(String bucketName)", null, startTime);

} catch (Exception e) {

mintFailedLog("makeBucket(String bucketName)", null, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: makeBucket(String bucketName, String region).

*/

public static void makeBucketwithRegion_test() throws Exception {

if (!mintEnv) {

System.out.println("Test: makeBucket(String bucketName, String region)");

}

long startTime = System.currentTimeMillis();

try {

String name = getRandomName();

client.makeBucket(name, "eu-west-1");

client.removeBucket(name);

mintSuccessLog("makeBucket(String bucketName, String region)", "region: eu-west-1", startTime);

} catch (Exception e) {

mintFailedLog("makeBucket(String bucketName, String region)", "region: eu-west-1", startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: makeBucket(String bucketName, String region) where bucketName has

* periods in its name.

*/

public static void makeBucketWithPeriod_test() throws Exception {

if (!mintEnv) {

System.out.println("Test: makeBucket(String bucketName, String region)");

}

long startTime = System.currentTimeMillis();

String name = getRandomName() + ".withperiod";

try {

client.makeBucket(name, "eu-central-1");

client.removeBucket(name);

mintSuccessLog("makeBucket(String bucketName, String region)", "name: " + name + ", region: eu-central-1",

startTime);

} catch (Exception e) {

mintFailedLog("makeBucket(String bucketName, String region)", "name: " + name + ", region: eu-central-1",

startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: listBuckets().

*/

public static void listBuckets_test() throws Exception {

if (!mintEnv) {

System.out.println("Test: listBuckets()");

}

long startTime = System.currentTimeMillis();

try {

Date expectedTime = new Date();

String bucketName = getRandomName();

boolean found = false;

client.makeBucket(bucketName);

for (Bucket bucket : client.listBuckets()) {

if (bucket.name().equals(bucketName)) {

if (found) {

throw new Exception("[FAILED] duplicate entry " + bucketName + " found in list buckets");

}

found = true;

Date time = bucket.creationDate();

long diff = time.getTime() - expectedTime.getTime();

// excuse 15 minutes

if (diff > (15 * 60 * 1000)) {

throw new Exception(

"[FAILED] bucket creation time too apart. expected: " + expectedTime + ", got: " + time);

}

}

}

client.removeBucket(bucketName);

if (!found) {

throw new Exception("[FAILED] created bucket not found in list buckets");

}

mintSuccessLog("listBuckets()", null, startTime);

} catch (Exception e) {

mintFailedLog("listBuckets()", null, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: bucketExists(String bucketName).

*/

public static void bucketExists_test() throws Exception {

if (!mintEnv) {

System.out.println("Test: bucketExists(String bucketName)");

}

long startTime = System.currentTimeMillis();

try {

String name = getRandomName();

client.makeBucket(name);

if (!client.bucketExists(name)) {

throw new Exception("[FAILED] bucket does not exist");

}

client.removeBucket(name);

mintSuccessLog("bucketExists(String bucketName)", null, startTime);

} catch (Exception e) {

mintFailedLog("bucketExists(String bucketName)", null, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: removeBucket(String bucketName).

*/

public static void removeBucket_test() throws Exception {

if (!mintEnv) {

System.out.println("Test: removeBucket(String bucketName)");

}

long startTime = System.currentTimeMillis();

try {

String name = getRandomName();

client.makeBucket(name);

client.removeBucket(name);

mintSuccessLog("removeBucket(String bucketName)", null, startTime);

} catch (Exception e) {

mintFailedLog("removeBucket(String bucketName)", null, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Tear down test setup.

*/

public static void setup() throws Exception {

client.makeBucket(bucketName);

}

/**

* Tear down test setup.

*/

public static void teardown() throws Exception {

client.removeBucket(bucketName);

}

/**

* Test: putObject(String bucketName, String objectName, String filename).

*/

public static void putObject_test1() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, String filename)");

}

long startTime = System.currentTimeMillis();

try {

String filename = createFile1Kb();

client.putObject(bucketName, filename, filename);

Files.delete(Paths.get(filename));

client.removeObject(bucketName, filename);

mintSuccessLog("putObject(String bucketName, String objectName, String filename)", "filename: 1KB", startTime);

} catch (Exception e) {

mintFailedLog("putObject(String bucketName, String objectName, String filename)", "filename: 1KB", startTime,

null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: multipart: putObject(String bucketName, String objectName, String

* filename).

*/

public static void putObject_test2() throws Exception {

if (!mintEnv) {

System.out.println("Test: multipart: putObject(String bucketName, String objectName, String filename)");

}

long startTime = System.currentTimeMillis();

try {

String filename = createFile6Mb();

client.putObject(bucketName, filename, filename);

Files.delete(Paths.get(filename));

client.removeObject(bucketName, filename);

mintSuccessLog("putObject(String bucketName, String objectName, String filename)", "filename: 65MB", startTime);

} catch (Exception e) {

mintFailedLog("putObject(String bucketName, String objectName, String filename)", "filename: 65MB", startTime,

null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: With content-type: putObject(String bucketName, String objectName,

* String filename, String contentType).

*/

public static void putObject_test3() throws Exception {

if (!mintEnv) {

System.out

.println("Test: putObject(String bucketName, String objectName, String filename," + " String contentType)");

}

long startTime = System.currentTimeMillis();

try {

String filename = createFile1Kb();

client.putObject(bucketName, filename, filename, customContentType);

Files.delete(Paths.get(filename));

client.removeObject(bucketName, filename);

mintSuccessLog("putObject(String bucketName, String objectName, String filename, String contentType)",

"contentType: " + customContentType, startTime);

} catch (Exception e) {

mintFailedLog("putObject(String bucketName, String objectName, String filename, String contentType)",

"contentType: " + customContentType, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream body, long

* size, String contentType).

*/

public static void putObject_test4() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream body, "

+ "long size, String contentType)");

}

long startTime = System.currentTimeMillis();

try {

String objectName = getRandomName();

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, customContentType);

}

client.removeObject(bucketName, objectName);

mintSuccessLog(

"putObject(String bucketName, String objectName, InputStream body, long size," + " String contentType)",

"size: 1 KB, objectName: " + customContentType, startTime);

} catch (Exception e) {

mintFailedLog("putObject(String bucketName, String objectName, InputStream body, long size, String contentType)",

"size: 1 KB, objectName: " + customContentType, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream body, long

* size, String contentType). where objectName has multiple path segments.

*/

public static void putObject_test6() throws Exception {

if (!mintEnv) {

System.out.println("Test: objectName with path segments: "

+ "putObject(String bucketName, String objectName, InputStream body, " + "long size, String contentType)");

}

long startTime = System.currentTimeMillis();

try {

String objectName = "/path/to/" + getRandomName();

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, customContentType);

}

client.removeObject(bucketName, objectName);

mintSuccessLog(

"putObject(String bucketName, String objectName, InputStream body, long size," + " String contentType)",

"size: 1 KB, contentType: " + customContentType, startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream body, long size," + " String contentType)",

"size: 1 KB, contentType: " + customContentType, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test put object with unknown sized stream.

*/

public static void testPutObjectUnknownStreamSize(long size) throws Exception {

if (!mintEnv) {

System.out

.println("Test: putObject(String bucketName, String objectName, InputStream body, " + "String contentType)");

}

long startTime = System.currentTimeMillis();

try {

String objectName = getRandomName();

try (final InputStream is = new ContentInputStream(size)) {

client.putObject(bucketName, objectName, is, customContentType);

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream body, String contentType)",

"contentType: " + customContentType, startTime);

} catch (Exception e) {

mintFailedLog("putObject(String bucketName, String objectName, InputStream body, long size, String contentType)",

"contentType: " + customContentType, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream body,

* String contentType).

*/

public static void putObject_test7() throws Exception {

testPutObjectUnknownStreamSize(3 * KB);

}

/**

* Test: multipart: putObject(String bucketName, String objectName, InputStream

* body, String contentType).

*/

public static void putObject_test8() throws Exception {

testPutObjectUnknownStreamSize(10 * MB);

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, Map&lt;String, String&gt; headerMap).

*/

public static void putObject_test9() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap).");

}

long startTime = System.currentTimeMillis();

try {

String objectName = getRandomName();

Map<String, String> headerMap = new HashMap<>();

headerMap.put("Content-Type", customContentType);

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, headerMap);

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, Map&lt;String, String&gt; headerMap) with Storage Class

* REDUCED_REDUNDANCY.

*/

@SuppressFBWarnings("UCF")

public static void putObject_test10() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap). with Storage Class REDUCED_REDUNDANCY set");

}

long startTime = System.currentTimeMillis();

try {

String storageClass = "REDUCED_REDUNDANCY";

String objectName = getRandomName();

Map<String, String> headerMap = new HashMap<>();

headerMap.put("Content-Type", customContentType);

headerMap.put("X-Amz-Storage-Class", storageClass);

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, headerMap);

}

ObjectStat objectStat = client.statObject(bucketName, objectName);

Map<String, List<String>> returnHeader = objectStat.httpHeaders();

List<String> returnStorageClass = returnHeader.get("X-Amz-Storage-Class");

if ((returnStorageClass != null) && (!storageClass.equals(returnStorageClass.get(0)))) {

throw new Exception("Metadata mismatch");

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, Map&lt;String, String&gt; headerMap) with Storage Class STANDARD.

*/

public static void putObject_test11() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap). with Storage Class STANDARD set");

}

long startTime = System.currentTimeMillis();

try {

String storageClass = "STANDARD";

String objectName = getRandomName();

Map<String, String> headerMap = new HashMap<>();

headerMap.put("Content-Type", customContentType);

headerMap.put("X-Amz-Storage-Class", storageClass);

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, headerMap);

}

ObjectStat objectStat = client.statObject(bucketName, objectName);

Map<String, List<String>> returnHeader = objectStat.httpHeaders();

List<String> returnStorageClass = returnHeader.get("X-Amz-Storage-Class");

// Standard storage class shouldn't be present in metadata response

if (returnStorageClass != null) {

throw new Exception("Did not expect: " + storageClass + " in response metadata");

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, Map&lt;String, String&gt; headerMap). with invalid Storage Class

* set

*/

public static void putObject_test12() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap). with invalid Storage Class set");

}

long startTime = System.currentTimeMillis();

try {

String storageClass = "INVALID";

String objectName = getRandomName();

Map<String, String> headerMap = new HashMap<>();

headerMap.put("Content-Type", customContentType);

headerMap.put("X-Amz-Storage-Class", storageClass);

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, headerMap);

} catch (ErrorResponseException e) {

if (!e.errorResponse().code().equals("InvalidStorageClass")) {

throw e;

}

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, Map<String, String> headerMap)",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, ServerSideEncryption sse). To test SSE_C

*/

public static void putObject_test13() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_C. ");

}

long startTime = System.currentTimeMillis();

// Generate a new 256 bit AES key - This key must be remembered by the client.

KeyGenerator keyGen = KeyGenerator.getInstance("AES");

keyGen.init(256);

ServerSideEncryption sse = ServerSideEncryption.withCustomerKey(keyGen.generateKey());

try {

String objectName = getRandomName();

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, sse);

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_C.", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_C.",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, ServerSideEncryption sse). To test SSE_S3

*/

public static void putObject_test14() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_S3.");

}

long startTime = System.currentTimeMillis();

ServerSideEncryption sse = ServerSideEncryption.atRest();

try {

String objectName = getRandomName();

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, sse);

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_S3.", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_S3.",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, ServerSideEncryption sse). To test SSE_KMS

*/

public static void putObject_test15() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_KMS.");

}

long startTime = System.currentTimeMillis();

Map<String, String> myContext = new HashMap<>();

myContext.put("key1", "value1");

String keyId = "";

keyId = System.getenv("MINT_KEY_ID");

if (keyId.equals("")) {

mintIgnoredLog("getBucketPolicy(String bucketName)", null, startTime);

}

ServerSideEncryption sse = ServerSideEncryption.withManagedKeys("keyId", myContext);

try {

String objectName = getRandomName();

try (final InputStream is = new ContentInputStream(1 * KB)) {

client.putObject(bucketName, objectName, is, 1 * KB, sse);

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_KMS.", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_KMS.",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, InputStream stream,

* long size, ServerSideEncryption sse). To test SSE_C (multi-part upload).

*/

public static void putObject_test16() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_C (Multi-part upload). ");

}

long startTime = System.currentTimeMillis();

// Generate a new 256 bit AES key - This key must be remembered by the client.

KeyGenerator keyGen = KeyGenerator.getInstance("AES");

keyGen.init(256);

ServerSideEncryption sse = ServerSideEncryption.withCustomerKey(keyGen.generateKey());

try {

String objectName = getRandomName();

try (final InputStream is = new ContentInputStream(6 * MB)) {

client.putObject(bucketName, objectName, is, 6 * MB, sse);

}

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_C (Multi-part upload).", "size: 6 MB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, InputStream stream, "

+ "long size, ServerSideEncryption sse) using SSE_C (Multi-part upload).",

"size: 6 MB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: putObject(String bucketName, String objectName, ServerSideEncryption

* sse, String filename). To test SSE_C

*

*/

public static void putObject_test17() throws Exception {

if (!mintEnv) {

System.out.println("Test: putObject(String bucketName, String objectName, ServerSideEncryption sse, "

+ "String filename). To test SSE_C. ");

}

long startTime = System.currentTimeMillis();

// Generate a new 256 bit AES key - This key must be remembered by the client.

KeyGenerator keyGen = KeyGenerator.getInstance("AES");

keyGen.init(256);

ServerSideEncryption sse = ServerSideEncryption.withCustomerKey(keyGen.generateKey());

try {

String objectName = getRandomName();

String filename = createFile1Kb();

client.putObject(bucketName, objectName, sse, filename);

Files.delete(Paths.get(filename));

client.removeObject(bucketName, objectName);

mintSuccessLog("putObject(String bucketName, String objectName, ServerSideEncryption sse, "

+ "String filename). To test SSE_C", "size: 1 KB", startTime);

} catch (Exception e) {

mintFailedLog(

"putObject(String bucketName, String objectName, ServerSideEncryption sse, "

+ "String filename). To test SSE_C",

"size: 1 KB", startTime, null, e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: statObject(String bucketName, String objectName).

*/

public static void statObject_test1() throws Exception {

if (!mintEnv) {

System.out.println("Test: statObject(String bucketName, String objectName)");

}

long startTime = System.currentTimeMillis();

try {

String objectName = getRandomName();

Map<String, String> headerMap = new HashMap<>();

headerMap.put("Content-Type", customContentType);

headerMap.put("my-custom-data", "foo");

try (final InputStream is = new ContentInputStream(1)) {

client.putObject(bucketName, objectName, is, 1, headerMap);

}

ObjectStat objectStat = client.statObject(bucketName, objectName);

if (!(objectName.equals(objectStat.name()) && (objectStat.length() == 1)

&& bucketName.equals(objectStat.bucketName()) && objectStat.contentType().equals(customContentType))) {

throw new Exception("[FAILED] object stat differs");

}

Map<String, List<String>> httpHeaders = objectStat.httpHeaders();

if (!httpHeaders.containsKey("x-amz-meta-my-custom-data")) {

throw new Exception("[FAILED] metadata not found in object stat");

}

List<String> values = httpHeaders.get("x-amz-meta-my-custom-data");

if (values.size() != 1) {

throw new Exception("[FAILED] too many metadata value. expected: 1, got: " + values.size());

}

if (!values.get(0).equals("foo")) {

throw new Exception("[FAILED] wrong metadata value. expected: foo, got: " + values.get(0));

}

client.removeObject(bucketName, objectName);

mintSuccessLog("statObject(String bucketName, String objectName)", null, startTime);

} catch (Exception e) {

mintFailedLog("statObject(String bucketName, String objectName)", null, startTime, null,

e.toString() + " >>> " + Arrays.toString(e.getStackTrace()));

throw e;

}

}

/**

* Test: statObject(String bucketName, String objectName, ServerSideEncryption

* sse). To test statObject using SSE_C.

*/

public static void statObject_test2() throws Exception {

if (!mintEnv) {

System.out.println(

"Test: statObject(String bucketName, String objectName, ServerSideEncryption sse)" + " using SSE_C.");

}

long startTime = System.currentTimeMillis();

try {

String objectName = getRandomName();

// Generate a new 256 bit AES key - This key must be remembered by the client.

KeyGenerator keyGen = KeyGenerator.getInstance("AES");

keyGen.init(256);

ServerSideEncryption sse = ServerSideEncryption.withCustomerKey(keyGen.generateKey());

try (final InputStream is = new ContentInputStream(1)) {

client.putObject(bucketName, objectName, is, 1, sse);

}

ObjectStat objectStat = client.statObject(bucketName, objectName, sse);

if (!(objectName.equals(objectStat.name()) && (objectStat.length() == 1)

&& bucketName.equals(objectStat.bucketName()))) {

throw new Exception("[FAILED] object stat differs");

}

Map<String, List<String>> httpHeaders = objectStat.httpHeaders();

if (!httpHeaders.containsKey("X-Amz-Server-Side-Encryption-Customer-Algorithm")) {

throw new Exception("[FAILED] metadata not found in object stat");

}

List<String> values = httpHeaders.get("X-Amz-Server-Side-Encryption-Customer-Algorithm");

if (values.size() != 1) {

throw new Exception("[FAILED] too many metadata value. expected: 1, got: " + values.size());

}

if (!values.get(0).equals("AES256")) {

throw new Exception("[FAILED] wrong metadata value. expected: AES256, got: " + values.get(0));

}

client.removeObject(bucketName, objectName);