Commit 04ba06b5 authored by Abhishek Kumar's avatar Abhishek Kumar
Browse files

method name correction

parent a0cf554f
Pipeline #48240 failed with stages
in 76 minutes and 6 seconds
......@@ -399,11 +399,11 @@ public class SchemaService implements ISchemaService {
continue;
//Compare Minor version is greater or smaller
}else if(inputSchemaInfo.getSchemaIdentity().getSchemaVersionMinor().compareTo(existingSchemaInfo.getSchemaIdentity().getSchemaVersionMinor()) < 0){
versionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.MINOR).validate(resolvedInputSchema, existingSchemaInStore);
versionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.MINOR).validate(resolvedInputSchema, existingSchemaInStore);
}else if(inputSchemaInfo.getSchemaIdentity().getSchemaVersionMinor().compareTo(existingSchemaInfo.getSchemaIdentity().getSchemaVersionMinor()) > 0) {
versionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.MINOR).validate(existingSchemaInStore, resolvedInputSchema);
versionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.MINOR).validate(existingSchemaInStore, resolvedInputSchema);
}else {
versionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.PATCH).validate(existingSchemaInStore, resolvedInputSchema);
versionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.PATCH).validate(existingSchemaInStore, resolvedInputSchema);
}
}catch (SchemaVersionException exc) {
log.error("Failed to resolve the schema and find breaking changes. Reason :" + exc.getMessage());
......
......@@ -12,7 +12,7 @@ public class SchemaVersionValidatorFactory {
@Autowired
private List<SchemaVersionValidator> schemaVersionValidator;
public SchemaVersionValidator geSchemaVersionValidator(SchemaVersionValidatorType validatorType) {
public SchemaVersionValidator getSchemaVersionValidator(SchemaVersionValidatorType validatorType) {
Optional<SchemaVersionValidator> schemaValidator = schemaVersionValidator.stream().filter(validator -> validator.getType().equals(validatorType))
.findAny();
......
......@@ -199,7 +199,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn(schReqPubInt.getSchema().toString());
Mockito.when(schemaUtil.findSchemaToCompare(schReqPubInt.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class))).thenReturn(mock(SchemaVersionValidator.class));
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class))).thenReturn(mock(SchemaVersionValidator.class));
assertEquals(SchemaStatus.PUBLISHED, schemaService.createSchema(schReqPubInt).getStatus());
verify(messageBus, times(1)).publishMessage( anyString(), anyString());
}
......@@ -233,7 +233,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn(schReq.getSchema().toString());
Mockito.when(schemaUtil.findSchemaToCompare(schReq.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
assertEquals(schInfo, schemaService.createSchema(schReq));
verify(messageBus, times(1)).publishMessage( anyString(), anyString());
......@@ -268,7 +268,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn(schReq.getSchema().toString());
Mockito.when(schemaUtil.findSchemaToCompare(schReq.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
schemaService.createSchema(schReq);
verify(messageBus, times(0)).publishMessage(anyString(), anyString());
......@@ -303,7 +303,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn(schReqPub.getSchema().toString());
Mockito.when(schemaUtil.findSchemaToCompare(schReqPub.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
assertEquals(SchemaStatus.PUBLISHED, schemaService.createSchema(schReqPub).getStatus());
verify(messageBus, times(1)).publishMessage( anyString(), anyString());
......@@ -346,7 +346,7 @@ public class SchemaServiceTest {
Mockito.when(schemaResolver.resolveSchema(Mockito.anyString())).thenReturn(inputSchema);
Mockito.when(schemaUtil.findSchemaToCompare(schReqBreakingChange.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.PATCH))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.PATCH))
.thenReturn(patchVersionValidator);
Mockito.doThrow(SchemaVersionException.class).when(patchVersionValidator).validate(anyString(), anyString());
Mockito.when(schemaInfoStore.getLatestMinorVerSchema(getMockSchemaInfo_Published_InternalScope()))
......@@ -386,7 +386,7 @@ public class SchemaServiceTest {
Mockito.when(schemaInfoStore.createSchemaInfo(mockSchReqPubInt))
.thenReturn(mockSchInfoPubInt);
Mockito.when(schemaUtil.findSchemaToCompare(mockSchReqPubInt.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class))).thenReturn(mock(SchemaVersionValidator.class));
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class))).thenReturn(mock(SchemaVersionValidator.class));
assertEquals(mockSchInfoPubInt, schemaService.createSchema(mockSchReqPubInt));
verify(messageBus, times(1)).publishMessage(anyString(), anyString());
......@@ -412,7 +412,7 @@ public class SchemaServiceTest {
Mockito.when(schemaInfoStore.createSchemaInfo(schReqPub)).thenReturn(schReqPub.getSchemaInfo());
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("");
Mockito.when(schemaUtil.findSchemaToCompare(schReqPub.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
schemaService.createSchema(schReqPub);
verify(messageBus, times(0)).publishMessage( anyString(), anyString());
......@@ -437,7 +437,7 @@ public class SchemaServiceTest {
schReqPub.getSchemaInfo().getSchemaIdentity().getEntityType())).thenReturn(true);
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("");
Mockito.when(schemaUtil.findSchemaToCompare(schReqPub.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
schemaService.createSchema(schReqPub);
verify(messageBus, times(0)).publishMessage( anyString(), anyString());
......@@ -462,7 +462,7 @@ public class SchemaServiceTest {
schReqPub.getSchemaInfo().getSchemaIdentity().getEntityType())).thenReturn(true);
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("");
Mockito.when(schemaUtil.findSchemaToCompare(schReqPub.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
schemaService.createSchema(schReqPub);
verify(messageBus, times(0)).publishMessage( anyString(), anyString());
......@@ -597,7 +597,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("");
Mockito.when(schemaUtil.findSchemaToCompare(input)).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
assertNotNull(schemaService.updateSchema(getMockSchemaObject_Development()));
verify(messageBus, times(1)).publishMessage( anyString(), anyString());
......@@ -912,7 +912,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.createSchema(Mockito.anyString(), Mockito.anyString())).thenReturn("{}");
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("");
Mockito.when(schemaUtil.findSchemaToCompare(schInfo)).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
assertEquals(HttpStatus.OK, schemaService.upsertSchema(schReq).getHttpCode());
}
......@@ -952,7 +952,7 @@ public class SchemaServiceTest {
.thenReturn(schInfoCr);
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("");
Mockito.when(schemaUtil.findSchemaToCompare(schReq.getSchemaInfo())).thenReturn(schemaInfoArr);
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(Matchers.any(SchemaVersionValidatorType.class)))
.thenReturn(mock(SchemaVersionValidator.class));
assertEquals(HttpStatus.CREATED, schemaService.upsertSchema(schReq).getHttpCode());
}
......@@ -995,7 +995,7 @@ public class SchemaServiceTest {
Mockito.when(schemaResolver.resolveSchema(Mockito.anyString())).thenReturn("{}");
//Nothing is returned
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("{}");
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.PATCH))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.PATCH))
.thenReturn(patchVersionValidator);
Mockito.doThrow(new SchemaVersionException(SchemaConstants.BREAKING_CHANGES_PATCH)).when(patchVersionValidator).validate(anyString(), anyString());
Mockito.when(headers.getPartitionId()).thenReturn("tenant");
......@@ -1034,7 +1034,7 @@ public class SchemaServiceTest {
//Nothing is returned
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("{}");
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.MINOR))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.MINOR))
.thenReturn(minorVersionValidator);
Mockito.doThrow(new SchemaVersionException(SchemaConstants.BREAKING_CHANGES_MINOR)).when(minorVersionValidator).validate(anyString(), anyString());
Mockito.when(headers.getPartitionId()).thenReturn("tenant");
......@@ -1075,7 +1075,7 @@ public class SchemaServiceTest {
Mockito.when(schemaStore.getSchema(anyString(), anyString())).thenReturn("{}");
//Do nothing when minor level changes are compared
Mockito.when(schemaVersionValidatorFactory.geSchemaVersionValidator(SchemaVersionValidatorType.MINOR))
Mockito.when(schemaVersionValidatorFactory.getSchemaVersionValidator(SchemaVersionValidatorType.MINOR))
.thenReturn(minorVersionValidator);
Mockito.doThrow(new SchemaVersionException(SchemaConstants.BREAKING_CHANGES_MINOR)).when(minorVersionValidator).validate(anyString(), anyString());
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment