JinyuChen97 commented on code in PR #8500:
URL: https://github.com/apache/camel-quarkus/pull/8500#discussion_r3028118076
##########
integration-tests/ibm-cos/src/test/java/org/apache/camel/quarkus/component/ibm/cos/it/IBMCloudObjectStorageTest.java:
##########
@@ -31,54 +44,438 @@
@EnabledIfSystemProperty(named = "camel.ibm.cos.serviceInstanceId", matches =
".*", disabledReason = "IBM COS Service Instance ID not provided")
@EnabledIfSystemProperty(named = "camel.ibm.cos.endpointUrl", matches = ".*",
disabledReason = "IBM COS Endpoint URL not provided")
@QuarkusTest
+@TestMethodOrder(MethodOrderer.OrderAnnotation.class)
class IBMCloudObjectStorageTest {
@Test
+ @Order(0)
+ void setup() {
+ // Cleanup any existing bucket with same name first
+ cleanupBucket();
+
+ // Create Bucket (shared by all tests)
+ given()
+ .post("/ibm-cos/bucket/create")
+ .then()
+ .statusCode(201);
+ }
+
+ @Test
+ @Order(1)
void basicOperations() {
- try {
- // Create Bucket
+ // Bucket already exists from setup test
+
+ String contentInitial = "Hello Camel Quarkus IBM Cloud Object Storage";
+
+ // Create Object
+ given()
+ .contentType(ContentType.TEXT)
+ .body(contentInitial)
+ .post("/ibm-cos/object/put")
+ .then()
+ .statusCode(201);
+
+ // Read Object
+ given()
+ .get("/ibm-cos/object/read")
+ .then()
+ .statusCode(200)
+ .body(is(contentInitial));
+
+ // List Objects in bucket
+ given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .body("objects[0].key",
is(IBMCloudObjectStorageRoutes.KEY_OF_OBJECT_CREATED));
+
+ // Delete Object
+ given()
+ .body(contentInitial)
+ .post("/ibm-cos/object/delete")
+ .then()
+ .statusCode(201);
+
+ // Don't delete bucket - shared with other tests
+ }
+
+ @Test
+ @Order(2)
+ void consumerBasic() {
+ final String content = "Hello Consumer";
+
+ // Bucket already exists from basicOperations test
+
+ // Reset mock endpoint before test
+ resetMockEndpoint();
+
+ // Upload object
+ given()
+ .contentType(ContentType.TEXT)
+ .body(content)
+ .post("/ibm-cos/object/put")
+ .then()
+ .statusCode(201);
+
+ // Start consumer
+ given()
+ .post("/ibm-cos/consumer/start")
+ .then()
+ .statusCode(204);
+
+ // Wait for consumer to receive the message
+ await().atMost(10, TimeUnit.SECONDS)
+ .pollDelay(500, TimeUnit.MILLISECONDS)
+ .pollInterval(500, TimeUnit.MILLISECONDS)
+ .until(() -> {
+ String countStr = given().get("/ibm-cos/consumer/count")
+ .then().statusCode(200).extract().asString();
+ int count = Integer.parseInt(countStr);
+ return count >= 1;
+ });
+
+ // Stop consumer
+ given()
+ .post("/ibm-cos/consumer/stop")
+ .then()
+ .statusCode(204);
+
+ // Get consumed messages
+ String consumedMessages = given()
+ .get("/ibm-cos/consumer")
+ .then()
+ .statusCode(200)
+ .extract()
+ .body().asString();
+
+ // Verify message consumed
+ Assertions.assertEquals(content, consumedMessages);
+
+ // Verify object deleted (deleteAfterRead)
+ int objectCount = given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .extract()
+ .jsonPath().getList("objects").size();
+
+ Assertions.assertEquals(0, objectCount);
+
+ // Don't delete bucket - shared with other tests
+ }
+
+ @Test
+ @Order(3)
+ void consumerMultipleObjects() {
+ final Map<String, String> objectsToUpload = new HashMap<>();
+ objectsToUpload.put("obj-1", "Content 1");
+ objectsToUpload.put("obj-2", "Content 2");
+ objectsToUpload.put("obj-3", "Content 3");
+ objectsToUpload.put("obj-4", "Content 4");
+ objectsToUpload.put("obj-5", "Content 5");
+
+ // Bucket already exists from basicOperations test
+
+ // Reset mock endpoint before test
+ resetMockEndpoint();
+
+ // Upload 5 objects with different keys
+ for (Map.Entry<String, String> entry : objectsToUpload.entrySet()) {
given()
- .post("/ibm-cos/bucket/create")
+ .contentType(ContentType.TEXT)
+ .body(entry.getValue())
+ .post("/ibm-cos/object/put/" + entry.getKey())
.then()
.statusCode(201);
+ }
+
+ // Start consumer
+ given()
+ .post("/ibm-cos/consumer/start")
+ .then()
+ .statusCode(204);
+
+ // Wait for consumer to receive all 5 messages
+ await().atMost(20, TimeUnit.SECONDS)
+ .pollDelay(500, TimeUnit.MILLISECONDS)
+ .pollInterval(500, TimeUnit.MILLISECONDS)
+ .until(() -> {
+ String countStr = given().get("/ibm-cos/consumer/count")
+ .then().statusCode(200).extract().asString();
+ int count = Integer.parseInt(countStr);
+ return count >= 5;
+ });
+
+ // Stop consumer
+ given()
+ .post("/ibm-cos/consumer/stop")
+ .then()
+ .statusCode(204);
+
+ // Get consumed messages
+ String consumedMessages = given()
+ .get("/ibm-cos/consumer")
+ .then()
+ .statusCode(200)
+ .extract()
+ .body().asString();
+
+ // Verify all messages consumed (split by newline)
+ String[] messages = consumedMessages.split("\n");
+ Assertions.assertEquals(5, messages.length);
- String contentInitial = "Hello Camel Quarkus IBM Cloud Object
Storage";
+ // Verify all contents present
+ Set<String> expectedContents = new HashSet<>(objectsToUpload.values());
+ Set<String> actualContents = new HashSet<>(Arrays.asList(messages));
+ Assertions.assertEquals(expectedContents, actualContents);
- // Create Object
+ // Verify bucket empty (all objects deleted)
+ int objectCount = given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .extract()
+ .jsonPath().getList("objects").size();
+
+ Assertions.assertEquals(0, objectCount);
+
+ // Don't delete bucket - shared with other tests
+ }
+
+ @Test
+ @Order(4)
+ void multipleObjectsOperations() {
+ final Map<String, String> objectsToUpload = new HashMap<>();
+ objectsToUpload.put("obj-1", "Content for obj-1");
+ objectsToUpload.put("obj-2", "Content for obj-2");
+ objectsToUpload.put("obj-3", "Content for obj-3");
+ objectsToUpload.put("obj-4", "Content for obj-4");
+ objectsToUpload.put("obj-5", "Content for obj-5");
+
+ // Bucket already exists from basicOperations test
+
+ // Upload 5 objects with different keys
+ for (Map.Entry<String, String> entry : objectsToUpload.entrySet()) {
given()
.contentType(ContentType.TEXT)
- .body(contentInitial)
- .post("/ibm-cos/object/put")
+ .body(entry.getValue())
+ .post("/ibm-cos/object/put/" + entry.getKey())
.then()
.statusCode(201);
+ }
- // Read Object
- given()
- .get("/ibm-cos/object/read")
- .then()
- .statusCode(200)
- .body(is(contentInitial));
+ // List objects - verify 5 objects
+ int objectCount = given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .extract()
+ .jsonPath().getList("objects").size();
- // List Objects in bucket
- given()
- .get("/ibm-cos/list")
+ Assertions.assertEquals(5, objectCount);
+
+ // Get each object - verify content
+ for (Map.Entry<String, String> entry : objectsToUpload.entrySet()) {
+ String content = given()
+ .get("/ibm-cos/object/read/" + entry.getKey())
.then()
.statusCode(200)
- .body("objects[0].key",
is(IBMCloudObjectStorageRoutes.KEY_OF_OBJECT_CREATED));
+ .extract()
+ .body().asString();
- // Delete Object
- given()
- .body(contentInitial)
- .post("/ibm-cos/object/delete")
- .then()
- .statusCode(201);
+ Assertions.assertEquals(entry.getValue(), content);
+ }
- } finally {
- // Delete Bucket
- given()
- .post("/ibm-cos/bucket/delete")
- .then()
- .statusCode(201);
+ // Copy object obj-1 to obj-1-copy
+ given()
+ .post("/ibm-cos/object/copy/obj-1/obj-1-copy")
+ .then()
+ .statusCode(201);
+
+ // Verify copy exists and content matches
+ String copiedContent = given()
+ .get("/ibm-cos/object/read/obj-1-copy")
+ .then()
+ .statusCode(200)
+ .extract()
+ .body().asString();
+
+ Assertions.assertEquals("Content for obj-1", copiedContent);
+
+ // List objects - verify 6 objects now
+ objectCount = given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .extract()
+ .jsonPath().getList("objects").size();
+
+ Assertions.assertEquals(6, objectCount);
+
+ // Delete objects batch: obj-2, obj-3, obj-4
+ given()
+ .contentType(ContentType.JSON)
+ .body("[\"obj-2\", \"obj-3\", \"obj-4\"]")
+ .post("/ibm-cos/objects/delete")
+ .then()
+ .statusCode(201);
+
+ // List objects - verify 3 objects remain
+ objectCount = given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .extract()
+ .jsonPath().getList("objects").size();
+
+ Assertions.assertEquals(3, objectCount);
+
+ // Verify correct objects remain (obj-1, obj-5, obj-1-copy)
+ List<String> remainingKeys = given()
+ .get("/ibm-cos/list")
+ .then()
+ .statusCode(200)
+ .extract()
+ .jsonPath().getList("objects.key", String.class);
+
+ Assertions.assertTrue(remainingKeys.contains("obj-1"));
+ Assertions.assertTrue(remainingKeys.contains("obj-5"));
+ Assertions.assertTrue(remainingKeys.contains("obj-1-copy"));
Review Comment:
done
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
