Skip to content

Commit

Permalink
Junits: Change in no.of invocations to searchAsync client
Browse files Browse the repository at this point in the history
  • Loading branch information
@Kranthi-Guribilli
Kranthi-Guribilli committed Jun 21, 2024
1 parent 85a3f1d commit de3ae71
Showing 1 changed file with 40 additions and 40 deletions.
80 changes: 40 additions & 40 deletions src/test/java/iudx/catalogue/server/database/DatabaseServiceImplTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -264,7 +264,7 @@ public void testGetItemFailed(VertxTestContext vertxTestContext) {
request,
handler -> {
if (handler.failed()) {
verify(client, times(14)).searchAsync(any(), any(), any());
verify(client, times(15)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand All @@ -283,7 +283,7 @@ public void testGetItem(VertxTestContext vertxTestContext) {
request,
handler -> {
if (handler.succeeded()) {
verify(client, times(23)).searchAsync(anyString(), any(), any());
verify(client, times(25)).searchAsync(anyString(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -396,7 +396,7 @@ public void testVerifyInstanceFailed(VertxTestContext vertxTestContext) {
handler -> {
if (handler.failed()) {
databaseService.verifyInstance(instanceId);
verify(client, times(44)).searchAsync(any(), any(), any());
verify(client, times(46)).searchAsync(any(), any(), any());
assertEquals(TYPE_INTERNAL_SERVER_ERROR, handler.cause().getMessage());
vertxTestContext.completeNow();
} else {
Expand All @@ -422,7 +422,7 @@ public void testVerifyInstance0Hits(VertxTestContext vertxTestContext) {
boolHandler -> {
if (boolHandler.failed()) {
assertEquals(json, asyncResult.result());
verify(client, times(16)).searchAsync(anyString(), any(), any());
verify(client, times(17)).searchAsync(anyString(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand All @@ -447,7 +447,7 @@ public void testVerifyInstance(VertxTestContext vertxTestContext) {
boolHandler -> {
if (boolHandler.succeeded()) {
assertEquals(json, asyncResult.result());
verify(client, times(26)).searchAsync(anyString(), any(), any());
verify(client, times(28)).searchAsync(anyString(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -483,7 +483,7 @@ public void testCreateRating(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.failed()) {
verify(client, times(9)).searchAsync(any(), any(), any());
verify(client, times(10)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -603,7 +603,7 @@ public void testCreateItem(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.failed()) {
verify(client, times(47)).searchAsync(any(), any(), any());
verify(client, times(49)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else vertxTestContext.failNow("Fail");
});
Expand Down Expand Up @@ -635,7 +635,7 @@ public void testRelSearchResource(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(72)).searchAsync(any(), any(), any());
verify(client, times(75)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -684,7 +684,7 @@ public void testRelSearchResourceFailed(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.failed()) {
verify(client, times(70)).searchAsync(any(), any(), any());
verify(client, times(73)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -810,7 +810,7 @@ public void testGetRatingsFailed2(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.failed()) {
verify(client, times(59)).searchAsync(any(), any(), any());
verify(client, times(62)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand All @@ -833,7 +833,7 @@ public void testSearchQuery(VertxTestContext vertxTestContext) {
handler -> {
if (handler.failed()) {
assertEquals("dummy", asyncResult.cause().getMessage());
verify(client, times(11)).searchAsync(any(), any(), any());
verify(client, times(12)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -884,7 +884,7 @@ public void testListRealtionship(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(49)).searchAsync(any(), any(), any());
verify(client, times(51)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();

} else {
Expand Down Expand Up @@ -1036,7 +1036,7 @@ public void testListRelationshipItemRS(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(22)).searchAsync(any(), any(), any());
verify(client, times(24)).searchAsync(any(), any(), any());

vertxTestContext.completeNow();
} else {
Expand Down Expand Up @@ -1102,7 +1102,7 @@ public void testListRelationshipResourceGroup(VertxTestContext vertxTestContext)
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(68)).searchAsync(any(), any(), any());
verify(client, times(71)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();

} else {
Expand Down Expand Up @@ -1138,7 +1138,7 @@ public void testListRelationshipItem(VertxTestContext vertxTestContext) {
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(33)).searchAsync(any(), any(), any());
verify(client, times(35)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();

} else {
Expand Down Expand Up @@ -1217,7 +1217,7 @@ public void testCreateItemFailed(VertxTestContext vertxTestContext) {
.onComplete(
handler -> {
if (handler.failed()) {
verify(client, times(7)).searchAsync(any(), any(), any());
verify(client, times(8)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -1250,7 +1250,7 @@ public void testCreateItemSucceeded(VertxTestContext vertxTestContext) {
.onComplete(
handler -> {
if (handler.succeeded()) {
verify(client, times(13)).searchAsync(any(), any(), any());
verify(client, times(14)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();
} else {
vertxTestContext.failNow("Fail");
Expand Down Expand Up @@ -1283,7 +1283,7 @@ public void testCreateItemHits0(VertxTestContext vertxTestContext) {
.onComplete(
handler -> {
if (handler.failed()) {
verify(client, times(42)).searchAsync(any(), any(), any());
verify(client, times(44)).searchAsync(any(), any(), any());
verify(nlpService, times(0)).getEmbedding(any(), any());
verify(geoService, times(0)).geoSummarize(any(), any());
vertxTestContext.completeNow();
Expand Down Expand Up @@ -1311,7 +1311,7 @@ public void testCreateInstanceWhenInstanceExists(VertxTestContext testContext) {
json,
handler -> {
if (handler.failed()) {
verify(client, times(64)).searchAsync(any(), any(), any());
verify(client, times(67)).searchAsync(any(), any(), any());
testContext.completeNow();
} else {
testContext.failNow("fail");
Expand Down Expand Up @@ -1343,7 +1343,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(29)).searchAsync(any(), any(), any());
verify(client, times(31)).searchAsync(any(), any(), any());
verify(client, times(4)).docPostAsync(any(), any(), any());
testContext.completeNow();
} else {
Expand All @@ -1364,7 +1364,7 @@ public void testCreateMlayerInstanceFailure(VertxTestContext testContext) {
json,
handler -> {
if (handler.failed()) {
verify(client, times(61)).searchAsync(any(), any(), any());
verify(client, times(64)).searchAsync(any(), any(), any());
testContext.completeNow();

} else {
Expand Down Expand Up @@ -1396,7 +1396,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
handler -> {
if (handler.failed()) {
verify(client, times(5)).docPostAsync(any(), any(), any());
verify(client, times(54)).searchAsync(any(), any(), any());
verify(client, times(57)).searchAsync(any(), any(), any());

testContext.completeNow();

Expand Down Expand Up @@ -1434,7 +1434,7 @@ public void testGetMlayerInstance(VertxTestContext testContext) {
requestParams,
handler -> {
if (handler.succeeded()) {
verify(client, times(34)).searchAsync(any(), any(), any());
verify(client, times(36)).searchAsync(any(), any(), any());
testContext.completeNow();
} else {
testContext.failNow("Fail");
Expand All @@ -1452,7 +1452,7 @@ public void testGetMlayerInstanceFailure(VertxTestContext testContext) {
requestParams,
handler -> {
if (handler.failed()) {
verify(client, times(62)).searchAsync(any(), any(), any());
verify(client, times(65)).searchAsync(any(), any(), any());
testContext.completeNow();

} else {
Expand Down Expand Up @@ -1760,7 +1760,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
handler -> {
if (handler.failed()) {
verify(client, times(2)).docPostAsync(any(), any(), any());
verify(client, times(10)).searchAsync(any(), any(), any());
verify(client, times(11)).searchAsync(any(), any(), any());

testContext.completeNow();

Expand Down Expand Up @@ -1794,7 +1794,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
json,
handler -> {
if (handler.succeeded()) {
verify(client, times(19)).searchAsync(any(), any(), any());
verify(client, times(21)).searchAsync(any(), any(), any());
verify(client, times(3)).docPostAsync(any(), any(), any());
testContext.completeNow();
} else {
Expand All @@ -1815,7 +1815,7 @@ public void testCreateMlayerDomainfail(VertxTestContext testContext) {
handler -> {
if (handler.failed()) {

verify(client, times(69)).searchAsync(any(), any(), any());
verify(client, times(72)).searchAsync(any(), any(), any());

testContext.completeNow();

Expand Down Expand Up @@ -1860,7 +1860,7 @@ public void testGetMlayerDomain(VertxTestContext testContext) {
requestParams,
handler -> {
if (handler.succeeded()) {
verify(client, times(37)).searchAsync(any(), any(), any());
verify(client, times(39)).searchAsync(any(), any(), any());
testContext.completeNow();
} else {
testContext.failNow("Fail");
Expand All @@ -1879,7 +1879,7 @@ public void testGetMlayerDomainFailure(VertxTestContext testContext) {
requestParams,
handler -> {
if (handler.failed()) {
verify(client, times(57)).searchAsync(any(), any(), any());
verify(client, times(60)).searchAsync(any(), any(), any());
testContext.completeNow();

} else {
Expand Down Expand Up @@ -2173,7 +2173,7 @@ public void testGetMlayerProviders(VertxTestContext testContext) {
requestParams,
handler -> {
if (handler.succeeded()) {
verify(client, times(24)).searchAsync(any(), any(), any());
verify(client, times(26)).searchAsync(any(), any(), any());
testContext.completeNow();
} else {
testContext.failNow("Fail");
Expand All @@ -2192,7 +2192,7 @@ public void testGetMlayerProvidersFailure(VertxTestContext testContext) {
requestParams,
handler -> {
if (handler.failed()) {
verify(client, times(45)).searchAsync(any(), any(), any());
verify(client, times(47)).searchAsync(any(), any(), any());
testContext.completeNow();

} else {
Expand Down Expand Up @@ -2283,7 +2283,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
request,
handler -> {
if (handler.succeeded()) {
verify(client, times(51)).searchAsync(any(), any(), any());
verify(client, times(53)).searchAsync(any(), any(), any());
verify(client, times(2)).searchAsyncDataset(any(), any(), any());

testContext.completeNow();
Expand Down Expand Up @@ -2329,7 +2329,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
testContext.failNow("fail");

} else {
verify(client, times(65)).searchAsync(any(), any(), any());
verify(client, times(68)).searchAsync(any(), any(), any());
verify(client, times(2)).searchAsyncDataset(any(), any(), any());

testContext.completeNow();
Expand Down Expand Up @@ -2385,7 +2385,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
"abc",
handler -> {
if (handler.succeeded()) {
verify(client, times(5)).searchAsync(any(), any(), any());
verify(client, times(6)).searchAsync(any(), any(), any());
verify(client, times(1)).resourceAggregationAsync(any(), any(), any());
testContext.completeNow();

Expand Down Expand Up @@ -2438,7 +2438,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
"abc",
handler -> {
if (handler.succeeded()) {
verify(client, times(18)).searchAsync(any(), any(), any());
verify(client, times(20)).searchAsync(any(), any(), any());
verify(client, times(2)).resourceAggregationAsync(any(), any(), any());
testContext.completeNow();

Expand Down Expand Up @@ -2511,7 +2511,7 @@ public AsyncResult<JsonObject> answer(InvocationOnMock arg0) throws Throwable {
handler -> {
if (handler.succeeded()) {
// verify(client, times(1)).searchAsyncDataset(any(), any(), any());
verify(client, times(53)).searchAsync(any(), any(), any());
verify(client, times(56)).searchAsync(any(), any(), any());
verify(client, times(5)).resourceAggregationAsync(any(), any(), any());
testContext.completeNow();

Expand All @@ -2534,7 +2534,7 @@ public void testGetMlayerAllDatasetsResourceFails(VertxTestContext testContext)
handler -> {
if (handler.failed()) {
// verify(client, times(1)).searchAsyncDataset(any(), any(), any());
verify(client, times(28)).searchAsync(any(), any(), any());
verify(client, times(30)).searchAsync(any(), any(), any());

testContext.completeNow();

Expand Down Expand Up @@ -2612,7 +2612,7 @@ public void testGetMlayerPopularDatasetsSuccess(VertxTestContext testContext) {
highestCountResource,
handler -> {
if (handler.succeeded()) {
verify(client, times(56)).searchAsync(any(), any(), any());
verify(client, times(59)).searchAsync(any(), any(), any());
verify(client, times(5)).searchAsyncResourceGroupAndProvider(any(), any(), any());
verify(client, times(6)).resourceAggregationAsync(any(), any(), any());
testContext.completeNow();
Expand Down Expand Up @@ -2737,7 +2737,7 @@ public void testGetMlayerPopularDatasetsProviderSuccess(VertxTestContext testCon
highestCountResource,
handler -> {
if (handler.succeeded()) {
verify(DatabaseServiceImpl.client, times(39)).searchAsync(any(), any(), any());
verify(DatabaseServiceImpl.client, times(41)).searchAsync(any(), any(), any());
verify(DatabaseServiceImpl.client, times(3))
.searchAsyncResourceGroupAndProvider(any(), any(), any());
verify(DatabaseServiceImpl.client, times(4))
Expand Down Expand Up @@ -2802,7 +2802,7 @@ public void testSearchQueryTextSearch(VertxTestContext vertxTestContext) {
request,
handler -> {
if (handler.succeeded()) {
verify(client, times(20)).searchAsync(any(), any(), any());
verify(client, times(22)).searchAsync(any(), any(), any());
vertxTestContext.completeNow();

} else {
Expand Down

0 comments on commit de3ae71

Please sign in to comment.