Merge pull request #97 from soramitsu/query_with_reports

Query with reports
soramitsu · Jul 1, 2024 · c4985af · c4985af
2 parents a9abdad + 6d51576
commit c4985af
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 45 deletions.
diff --git a/src/test/java/requests/Queries.java b/src/test/java/requests/Queries.java
@@ -14,60 +14,61 @@
 public class Queries extends Constants {
 
     public static ChainBuilder queryPostFindAllDomains = exec(feed(CSV_FEEDER)).exec(feed(PEERS_FEEDER))
-            .exec(
-
-                    http("findAllDomains query")
-                            .post(session -> {return session.getString("peer");})
-                            .body(ByteArrayBody(session -> {
-                                                return SignedQuery.Companion.encode(QueryBuilder
-                                                        .findAllDomains()
-                                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender")))
-                                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
-                                            }
-                                    )
-                            )
-            ).exec(http("findAllDomains status").get(Constants.URL_STATUS).check(status().is(200)));
+            .exec(http("findAllDomains query")
+                    .post(session -> {
+                        return session.getString("peer") + "query";
+                    })
+                    .body(ByteArrayBody(session -> {
+                        return SignedQuery.Companion.encode(QueryBuilder
+                                .findAllDomains()
+                                .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender")))
+                                .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
+                    }))
+            );
 
     public static ChainBuilder queryPostFindAccountsByDomainId = exec(feed(CSV_FEEDER)).exec(feed(PEERS_FEEDER))
             .exec(
                     http("findAccountsByDomainId query")
-                            .post(session -> {return session.getString("peer");})
-                            .body(ByteArrayBody(session -> {
-                                                return SignedQuery.Companion.encode(QueryBuilder
-                                                        .findAccountsByDomainId(ExtensionsKt.asDomainId(session.getString("domainIdSender")))
-                                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender")))
-                                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
-                                            }
-                                    )
+                            .post(session -> {
+                                        return session.getString("peer") + "query";
+                                    }
                             )
+                            .body(ByteArrayBody(session -> {
+                                return SignedQuery.Companion.encode(QueryBuilder
+                                        .findAccountsByDomainId(ExtensionsKt.asDomainId(session.getString("domainIdSender")))
+                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender")))
+                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
+                            }))
 
-            ).exec(http("findAccountsByDomainId status").get(Constants.URL_STATUS).check(status().is(200)));
+            );
 
     public static ChainBuilder queryPostFindAllAssets = exec(feed(CSV_FEEDER)).exec(feed(PEERS_FEEDER))
             .exec(
                     http("findAllAssets query")
-                            .post(session -> {return session.getString("peer");})
-                            .body(ByteArrayBody(session -> {
-                                                return SignedQuery.Companion.encode(QueryBuilder
-                                                        .findAllAssets()
-                                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender")))
-                                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
-                                            }
-                                    )
+                            .post(session -> {
+                                        return session.getString("peer") + "query";
+                                    }
                             )
-            ).exec(http("findAllAssets status").get(Constants.URL_STATUS).check(status().is(200)));
+                            .body(ByteArrayBody(session -> {
+                                return SignedQuery.Companion.encode(QueryBuilder
+                                        .findAllAssets()
+                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender")))
+                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
+                            }))
+            );
 
     public static ChainBuilder queryPostFindAllTransactions = exec(feed(CSV_FEEDER)).exec(feed(PEERS_FEEDER))
             .exec(
                     http("findAllTransactions query")
-                            .post(session -> {return session.getString("peer");})
-                            .body(ByteArrayBody(session -> {
-                                                return SignedQuery.Companion.encode(QueryBuilder
-                                                        .findAllTransactions(null)
-                                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender}")))
-                                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
-                                            }
-                                    )
+                            .post(session -> {
+                                        return session.getString("peer") + "query";
+                                    }
                             )
-            ).exec(http("findAllTransactions status").get(Constants.URL_STATUS).check(status().is(200)));
+                            .body(ByteArrayBody(session -> {
+                                return SignedQuery.Companion.encode(QueryBuilder
+                                        .findAllTransactions(null)
+                                        .account(ExtensionsKt.asAccountId(session.getString("anotherDevAccountIdSender}")))
+                                        .buildSigned(Constants.ALICE_KEYPAIR).getQuery());
+                            }))
+            );
 }
diff --git a/src/test/resources/peers.csv b/src/test/resources/peers.csv
@@ -1,6 +1,6 @@
 peer
-/peer-0/query
-/peer-1/query
-/peer-2/query
-/peer-3/query
-/peer-4/query
+/peer-0/
+/peer-1/
+/peer-2/
+/peer-3/
+/peer-4/