VAL-403 Re-use the previous version and dependency databases if no changes found

Author: QuyenLy87

src/main/java/org/ihtsdo/rvf/core/service/ReleaseDataManager.java

@@ -128,8 +128,8 @@ private void fetchRvfSchemasFromDb() {
 		}
 	}
 
-	public void dropDatabaseIfExist(String schemaName) throws BusinessServiceException{
-		logger.info("Dropping schema: {}", schemaName);
+	public void dropSchema(String schemaName) throws BusinessServiceException{
+		logger.info("Dropping schema {}", schemaName);
 		//clean database
 		try (Statement statement = dataSource.getConnection().createStatement()) {
 			String dropStr = "drop database if exists " + schemaName + ";";
@@ -722,4 +722,25 @@ private void insertIntoProspectiveDeltaTablesFromDependency(MysqlExecutionConfig
 			}
 		}
 	}
+
+	public long getPublishedReleaseLastModifiedDate(String publishedRelease) {
+		ResourceManager resourceManager = new ResourceManager(releaseStorageConfig, cloudResourceLoader);
+        try {
+            return resourceManager.getResourceLastModifiedDate(publishedRelease);
+        } catch (Exception e) {
+            logger.warn("Failed to find the last modified for resource {}", publishedRelease, e);
+			return 0L;
+        }
+    }
+
+	public long getBinaryArchiveSchemaLastModifiedDate(String schemaName) {
+		ResourceManager resourceManager = new ResourceManager(mysqlBinaryStorageConfig, cloudResourceLoader);
+		String archiveFileName = schemaName + ZIP_FILE_EXTENSION;
+		try {
+			return resourceManager.getResourceLastModifiedDate(archiveFileName);
+		} catch (Exception e) {
+			logger.warn("Failed to find the last modified for resource {}", schemaName, e);
+			return 0L;
+		}
+	}
 }

src/main/java/org/ihtsdo/rvf/core/service/ValidationVersionLoader.java

@@ -80,8 +80,6 @@ public void init() {
 	}
 
 	public void loadPreviousVersion(MysqlExecutionConfig executionConfig) throws BusinessServiceException, IOException {
-		String schemaName = constructRVFSchema(executionConfig.getPreviousVersion());
-		releaseDataManager.dropDatabaseIfExist(schemaName);
 		if (executionConfig.getPreviousVersion().endsWith(ZIP_FILE_EXTENSION)) {
 			String rvfDbSchema = loadRelease(executionConfig.getPreviousVersion());
 			executionConfig.setPreviousVersion(rvfDbSchema);
@@ -92,8 +90,6 @@ public void loadPreviousVersion(MysqlExecutionConfig executionConfig) throws Bus
 	}
 
 	public void loadDependencyVersion(MysqlExecutionConfig executionConfig) throws IOException, BusinessServiceException {
-		String schemaName = constructRVFSchema(executionConfig.getExtensionDependencyVersion());
-		releaseDataManager.dropDatabaseIfExist(schemaName);
 		if (executionConfig.getExtensionDependencyVersion().endsWith(ZIP_FILE_EXTENSION)) {
 			String dependencyVersion = loadRelease(executionConfig.getExtensionDependencyVersion());
 			executionConfig.setExtensionDependencyVersion(dependencyVersion);
@@ -145,34 +141,41 @@ private boolean checkDeltaFilesExist(File localProspectiveFile) throws ReleaseIm
 		return false;
 	}
 
-	private String constructRVFSchema(String releaseVersion) {
-		if (releaseVersion != null) {
-			if (releaseVersion.endsWith(ZIP_FILE_EXTENSION)) {
-				return RvfReleaseDbSchemaNameGenerator.generate(releaseVersion);
-			}
-			return releaseVersion.startsWith(RVF_DB_PREFIX) ? releaseVersion : RVF_DB_PREFIX + releaseVersion;
-		} else {
-			return null;
-		}
-	}
-	
 	private String loadRelease(String releaseVersion) throws IOException, BusinessServiceException {
 		if (releaseVersion != null && releaseVersion.endsWith(ZIP_FILE_EXTENSION)) {
 			String schemaName = RvfReleaseDbSchemaNameGenerator.generate(releaseVersion);
-			if (!releaseDataManager.isKnownRelease(schemaName) && (!releaseDataManager.restoreReleaseFromBinaryArchive(schemaName))) {
+			long publishedReleaseLastModifiedDate = releaseDataManager.getPublishedReleaseLastModifiedDate(releaseVersion);
+			long binaryArchiveSchemaLastModifiedDate = releaseDataManager.getBinaryArchiveSchemaLastModifiedDate(schemaName);
+
+			// If the binary archive has been deleted (- or it has not been generated yet), OR the release file has been changed,
+			// then the schema and the binary archive schema need to be re-generated
+			if (binaryArchiveSchemaLastModifiedDate == 0 || publishedReleaseLastModifiedDate > binaryArchiveSchemaLastModifiedDate) {
+				logger.info("The Binary Archive file was deleted (- or it has not been generated yet), OR a new version of published release has been detected.");
+				if (releaseDataManager.isKnownRelease(schemaName)) {
+					releaseDataManager.dropSchema(schemaName);
+				}
+				uploadPublishedReleaseThenGenerateBinaryArchive(releaseVersion, schemaName);
+			} else {
+				// Restore schema from binary archive file
+				if (!releaseDataManager.isKnownRelease(schemaName) && !releaseDataManager.restoreReleaseFromBinaryArchive(schemaName)) {
 					logger.info("No existing mysql binary release available.");
-					releaseDataManager.uploadPublishedReleaseFromStore(releaseVersion, schemaName);
-					if (generateBinaryArchive) {
-						String archiveFilename = releaseDataManager.generateBinaryArchive(schemaName);
-						logger.info("Release mysql binary archive is generated: {}", archiveFilename);
-					}
+					uploadPublishedReleaseThenGenerateBinaryArchive(releaseVersion, schemaName);
+				}
+			}
 
-			} 
-			return schemaName;	
+			return schemaName;
 		}
 		return releaseVersion;
 	}
 
+	private void uploadPublishedReleaseThenGenerateBinaryArchive(String releaseVersion, String schemaName) throws BusinessServiceException {
+		releaseDataManager.uploadPublishedReleaseFromStore(releaseVersion, schemaName);
+		if (generateBinaryArchive) {
+			String archiveFilename = releaseDataManager.generateBinaryArchive(schemaName);
+			logger.info("Release mysql binary archive is generated: {}", archiveFilename);
+		}
+	}
+
 	public MysqlExecutionConfig createExecutionConfig(ValidationRunConfig validationConfig) throws BusinessServiceException {
 		MysqlExecutionConfig executionConfig = new MysqlExecutionConfig(validationConfig.getRunId(), validationConfig.isFirstTimeRelease());
 		executionConfig.setProspectiveVersion(RVF_DB_PREFIX + getProspectiveVersionFromFileNames(validationConfig)