diff --git a/src/test/java/requests/Constants.java b/src/test/java/requests/Constants.java index 24addc3..4a90e61 100644 --- a/src/test/java/requests/Constants.java +++ b/src/test/java/requests/Constants.java @@ -8,6 +8,9 @@ import jp.co.soramitsu.iroha2.generated.Name; import java.security.KeyPair; +import java.util.ArrayList; +import java.util.List; +import java.util.Random; import java.util.UUID; import static io.gatling.javaapi.core.CoreDsl.csv; @@ -29,4 +32,5 @@ public class Constants { public static final DomainId NEW_DOMAIN_ID = new DomainId(new Name("new_domain_name")); public static final UUID CHAIN_ID = UUID.fromString("00000000-0000-0000-0000-000000000000"); public static FeederBuilder CSV_FEEDER = csv("preconditionList.csv").circular(); + public static FeederBuilder PEERS_FEEDER = csv("peers.csv").circular(); } diff --git a/src/test/java/requests/Queries.java b/src/test/java/requests/Queries.java index 4734745..243c152 100644 --- a/src/test/java/requests/Queries.java +++ b/src/test/java/requests/Queries.java @@ -5,16 +5,19 @@ import jp.co.soramitsu.iroha2.generated.SignedQuery; import jp.co.soramitsu.iroha2.query.QueryBuilder; +import java.util.List; + import static io.gatling.javaapi.core.CoreDsl.*; import static io.gatling.javaapi.http.HttpDsl.http; import static io.gatling.javaapi.http.HttpDsl.status; public class Queries extends Constants { - public static ChainBuilder queryPostFindAllDomains = exec(feed(CSV_FEEDER)) + public static ChainBuilder queryPostFindAllDomains = exec(feed(CSV_FEEDER)).exec(feed(PEERS_FEEDER)) .exec( + http("findAllDomains query") - .post(Constants.URL_QUERY) + .post(session -> {return session.getString("peer");}) .body(ByteArrayBody(session -> { return SignedQuery.Companion.encode(QueryBuilder .findAllDomains() @@ -28,7 +31,7 @@ public class Queries extends Constants { public static ChainBuilder queryPostFindAccountsByDomainId = exec(feed(CSV_FEEDER)) .exec( http("findAccountsByDomainId query") - .post(Constants.URL_QUERY) + .post(session -> {return session.getString("peer");}) .body(ByteArrayBody(session -> { return SignedQuery.Companion.encode(QueryBuilder .findAccountsByDomainId(ExtensionsKt.asDomainId(session.getString("domainIdSender"))) @@ -43,7 +46,7 @@ public class Queries extends Constants { public static ChainBuilder queryPostFindAllAssets = exec(feed(CSV_FEEDER)) .exec( http("findAllAssets query") - .post(Constants.URL_QUERY) + .post(session -> {return session.getString("peer");}) .body(ByteArrayBody(session -> { return SignedQuery.Companion.encode(QueryBuilder .findAllAssets() @@ -57,7 +60,7 @@ public class Queries extends Constants { public static ChainBuilder queryPostFindAllTransactions = exec(feed(CSV_FEEDER)) .exec( http("findAllTransactions query") - .post(Constants.URL_QUERY) + .post(session -> {return session.getString("peer");}) .body(ByteArrayBody(session -> { return SignedQuery.Companion.encode(QueryBuilder .findAllTransactions(null) diff --git a/src/test/resources/peers.csv b/src/test/resources/peers.csv new file mode 100644 index 0000000..0af6433 --- /dev/null +++ b/src/test/resources/peers.csv @@ -0,0 +1,6 @@ +peer +/peer-0/query +/peer-1/query +/peer-2/query +/peer-3/query +/peer-4/query \ No newline at end of file