Update everything before running cronjob

gbv · Sep 23, 2024 · 59bee9f · 59bee9f
1 parent ca62794
commit 59bee9f
Showing 1 changed file with 25 additions and 0 deletions.
diff --git a/src/main/java/de/vzg/oai_importer/OaiImporterWebApplication.java b/src/main/java/de/vzg/oai_importer/OaiImporterWebApplication.java
@@ -12,11 +12,17 @@
 import org.springframework.boot.autoconfigure.AutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.ApplicationContext;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.FilterType;
 import org.springframework.scheduling.annotation.EnableScheduling;
 import org.springframework.scheduling.annotation.Scheduled;
 
+import de.vzg.oai_importer.foreign.Configuration;
+import de.vzg.oai_importer.foreign.Harvester;
+import de.vzg.oai_importer.mycore.MyCoReSynchronizeService;
+import de.vzg.oai_importer.mycore.MyCoReTargetConfiguration;
+
 @SpringBootApplication()
 @EnableConfigurationProperties(ImporterConfiguration.class)
 @ComponentScan(excludeFilters = { @ComponentScan.Filter(type = FilterType.ASSIGNABLE_TYPE,
@@ -30,9 +36,15 @@ public class OaiImporterWebApplication {
     @Autowired
     private ImporterConfiguration configuration;
 
+    @Autowired
+    MyCoReSynchronizeService myCoReSynchronizeService;
+
     @Autowired
     private JobService jobService;
 
+    @Autowired
+    ApplicationContext context;
+
     public static void main(String[] args) throws IOException {
         SpringApplication.run(OaiImporterWebApplication.class, args);
     }
@@ -45,6 +57,19 @@ public void test() {
             .forEach(job -> {
             LOGGER.info("Running job {}", job);
             try {
+                ImportJobConfiguration jobConfiguration = configuration.getJobs().get(job);
+
+                // update source (harvest)
+                String sourceConfigId = jobConfiguration.getSourceConfigId();
+                Configuration sourceCfg = configuration.getCombinedConfig().get(sourceConfigId);
+                String harvesterID = sourceCfg.getHarvester();
+                Harvester<Configuration> harvester = (Harvester<Configuration>) context.getBean(harvesterID);
+                harvester.update(sourceConfigId, sourceCfg, false);
+
+                // update mycore target
+                MyCoReTargetConfiguration target = configuration.getTargets().get(jobConfiguration.getTargetConfigId());
+                myCoReSynchronizeService.synchronize(target);
+
                 jobService.runJob(job);
             } catch (OAIException | IOException | URISyntaxException e) {
                 LOGGER.error("Error while running job {}", job, e);