Skip to content

Commit d6abddc

Browse files
committed
Less hard-coding
1 parent be7b51c commit d6abddc

File tree

1 file changed

+7
-2
lines changed
  • plugins/repository-s3/qa/amazon-s3/src/test/java/org/elasticsearch/repositories/s3

1 file changed

+7
-2
lines changed

plugins/repository-s3/qa/amazon-s3/src/test/java/org/elasticsearch/repositories/s3/AmazonS3Fixture.java

+7-2
Original file line numberDiff line numberDiff line change
@@ -52,12 +52,17 @@ public class AmazonS3Fixture extends AbstractHttpFixture {
5252

5353
/** Request handlers for the requests made by the S3 client **/
5454
private final PathTrie<RequestHandler> handlers;
55+
private final String permanentBucketName;
56+
private final String temporaryBucketName;
5557

5658
/**
5759
* Creates a {@link AmazonS3Fixture}
5860
*/
5961
private AmazonS3Fixture(final String workingDir, final String permanentBucketName, final String temporaryBucketName) {
6062
super(workingDir);
63+
this.permanentBucketName = permanentBucketName;
64+
this.temporaryBucketName = temporaryBucketName;
65+
6166
this.buckets.put(permanentBucketName, new Bucket(permanentBucketName));
6267
this.buckets.put(temporaryBucketName, new Bucket(temporaryBucketName));
6368
this.handlers = defaultHandlers(buckets);
@@ -74,7 +79,7 @@ protected Response handle(final Request request) throws IOException {
7479
if (sessionToken != null) {
7580
return newError(request.getId(), RestStatus.FORBIDDEN, "AccessDenied", "Unexpected session token", "");
7681
}
77-
permittedBucket = "permanent_bucket_test";
82+
permittedBucket = permanentBucketName;
7883
} else if (authorization.contains("s3_integration_test_temporary_access_key")) {
7984
final String sessionToken = request.getHeader("x-amz-security-token");
8085
if (sessionToken == null) {
@@ -83,7 +88,7 @@ protected Response handle(final Request request) throws IOException {
8388
if (sessionToken.equals("s3_integration_test_temporary_session_token") == false) {
8489
return newError(request.getId(), RestStatus.FORBIDDEN, "AccessDenied", "Bad session token", "");
8590
}
86-
permittedBucket = "temporary_bucket_test";
91+
permittedBucket = temporaryBucketName;
8792
} else {
8893
return newError(request.getId(), RestStatus.FORBIDDEN, "AccessDenied", "Bad access key", "");
8994
}

0 commit comments

Comments
 (0)