ppalaga commented on a change in pull request #2988:
URL: https://github.com/apache/camel-quarkus/pull/2988#discussion_r683162597
##########
File path:
integration-test-groups/aws2/aws2-ddb/src/test/java/org/apache/camel/quarkus/component/aws2/ddb/it/Aws2DdbTest.java
##########
@@ -139,31 +111,183 @@ public void crud() {
},
Matchers.is(204));
- Awaitility.await().atMost(120, TimeUnit.SECONDS).until(
+ }
+
+ @Test
+ public void operations() {
+
+ final String key1 = "key-1-" +
UUID.randomUUID().toString().replace("-", "");
+ final String msg1 = "val-1-" +
UUID.randomUUID().toString().replace("-", "");
+ final String key2 = "key-2-" +
UUID.randomUUID().toString().replace("-", "");
+ final String msg2 = "val-2-" +
UUID.randomUUID().toString().replace("-", "");
+ final String key3 = "key-3-" +
UUID.randomUUID().toString().replace("-", "");
+ final String msg3 = "val-3-" +
UUID.randomUUID().toString().replace("-", "");
+
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .queryParam("table", Table.operations)
+ .body(msg1)
+ .post("/aws2-ddb/item/" + key1)
+ .then()
+ .statusCode(201);
+
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body(msg2)
+ .queryParam("table", Table.operations)
+ .post("/aws2-ddb/item/" + key2)
+ .then()
+ .statusCode(201);
+
+ RestAssured.given()
+ .contentType(ContentType.TEXT)
+ .body(msg3)
+ .queryParam("table", Table.operations)
+ .post("/aws2-ddb/item/" + key3)
+ .then()
+ .statusCode(201);
+
+ /* Batch items */
+ Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120,
TimeUnit.SECONDS).until(
+ () -> {
+
+ ExtractableResponse<Response> result = RestAssured.given()
+ .contentType(ContentType.JSON)
+ .body(Stream.of(key1,
key2).collect(Collectors.toList()))
+ .post("/aws2-ddb/batchItems")
+ .then()
+ .statusCode(200)
+ .extract();
+
+ LOG.info("Expecting 2 items, got " + result.statusCode() +
": " + result.body().asString());
+
+ return result.jsonPath().getMap("$");
+ },
+ /* Both inserted pairs have to be returned */
+ map -> map.size() == 2
+ && msg1.equals(map.get(key1))
+ && msg2.equals(map.get(key2)));
+
+ /* Query */
+ Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120,
TimeUnit.SECONDS).until(
() -> {
- ExtractableResponse<Response> result =
RestAssured.get("/aws2-ddbstream/change")
+ ExtractableResponse<Response> result = RestAssured.given()
+ .contentType(ContentType.JSON)
+ .body(key3)
+ .post("/aws2-ddb/query")
.then()
.statusCode(200)
.extract();
- LOG.info("Expecting 3 events got " + result.statusCode() +
": " + result.body().asString());
- List<Map> retVal = result.jsonPath().getList("$",
Map.class);
- //remove init events
- return retVal.stream().filter(m ->
!String.valueOf(m.get("key")).startsWith("initKey"))
- .collect(Collectors.toList());
+ LOG.info("Expecting 1 item, got " + result.statusCode() +
": " + result.body().asString());
+
+ return result.jsonPath().getMap("$");
},
- /* The above actions should trigger the following three change
events (initEvent is also present) */
- list -> list.size() == 3
+ map -> map.size() == 1
+ && msg3.equals(map.get(key3)));
+
+ /* Scan */
+ Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120,
TimeUnit.SECONDS).until(
+ () -> {
+ ExtractableResponse<Response> result =
RestAssured.get("/aws2-ddb/scan")
+ .then()
+ .statusCode(200)
+ .extract();
- && key.equals(list.get(0).get("key"))
- && msg.equals(list.get(0).get("new"))
+ LOG.info("Expecting 3 items, got " + result.statusCode() +
": " + result.body().asString());
- && key.equals(list.get(1).get("key"))
- && msg.equals(list.get(1).get("old"))
- && newMsg.equals(list.get(1).get("new"))
+ return result.jsonPath().getMap("$");
+ },
+ map -> map.size() == 3
+ && msg1.equals(map.get(key1))
+ && msg2.equals(map.get(key2))
+ && msg3.equals(map.get(key3)));
- && key.equals(list.get(2).get("key"))
- && newMsg.equals(list.get(2).get("old")));
+ /* Describe table */
+ Awaitility.await().pollInterval(1, TimeUnit.SECONDS).atMost(120,
TimeUnit.SECONDS).until(
+ () -> {
+ ExtractableResponse<Response> result = RestAssured.given()
+ .contentType(ContentType.JSON)
+ .body(Ddb2Operations.DescribeTable)
+ .post("/aws2-ddb/operation")
+ .then()
+ .statusCode(200)
+ .extract();
+
+ LOG.info("Expecting table description, got " +
result.statusCode() + ": " + result.body().asString());
+
+ return result.jsonPath().getMap("$");
+ },
+ map -> map.size() == 8
+ && map.containsKey(Ddb2Constants.CREATION_DATE)
+ && map.containsKey(Ddb2Constants.READ_CAPACITY)
+ &&
TableStatus.ACTIVE.name().equals(map.get(Ddb2Constants.TABLE_STATUS))
+ && map.containsKey(Ddb2Constants.WRITE_CAPACITY)
+ && map.containsKey(Ddb2Constants.TABLE_SIZE)
+ && map.containsKey(Ddb2Constants.KEY_SCHEMA)
+ && map.containsKey(Ddb2Constants.ITEM_COUNT)
+ && Table.operations == Table.valueOf((String)
map.get(Ddb2Constants.TABLE_NAME)));
Review comment:
Does DescribeTable need to be enclosed in await()? Maybe TableStatus is
not active initially?
--
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: commits-unsubscr...@camel.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
