feat(vertx): Use more robust time constrained mining instead of resul…

…t based (#833)
MartinWitt · Jul 13, 2023 · 8aeb521 · 8aeb521
1 parent 7b89a83
commit 8aeb521
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/.../src/main/java/io/github/martinwitt/laughing_train/mining/AnalyzerResultsPersistence.java b/.../src/main/java/io/github/martinwitt/laughing_train/mining/AnalyzerResultsPersistence.java
@@ -5,7 +5,6 @@
 import io.github.martinwitt.laughing_train.data.result.CodeAnalyzerResult;
 import io.github.martinwitt.laughing_train.domain.entity.AnalyzerStatus;
 import io.github.martinwitt.laughing_train.domain.entity.GitHubCommit;
-import io.github.martinwitt.laughing_train.mining.requests.MineNextProject;
 import io.github.martinwitt.laughing_train.mining.requests.StoreResults;
 import io.github.martinwitt.laughing_train.persistence.repository.ProjectRepository;
 import io.vertx.core.AbstractVerticle;
@@ -42,7 +41,6 @@ void persistResults(StoreResults storeResults) {
         } else if (result instanceof CodeAnalyzerResult.Success success) {
             logger.atInfo().log("Analyzer %s succeeded for project %s", SERVICE_NAME, project.name());
         }
-        eventBus.publish("miner", new MineNextProject(storeResults.analyzerName()));
     }
 
     private AnalyzerStatus getAnalyzerStatus(CodeAnalyzerResult spoonResult, String name) {

diff --git a/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/MiningStartup.java b/github-bot/src/main/java/io/github/martinwitt/laughing_train/mining/MiningStartup.java
@@ -37,9 +37,9 @@ void startup(@Observes StartupEvent event) {
             System.out.println("Received message: " + v.toString());
             v.next();
         });
-        vertx.setTimer(TimeUnit.MINUTES.toMillis(3), v -> vertx.eventBus()
+        vertx.setPeriodic(TimeUnit.MINUTES.toMillis(3), TimeUnit.MINUTES.toMillis(25), v -> vertx.eventBus()
                 .publish("miner", new MineNextProject(QodanaPeriodicMiner.ANALYZER_NAME)));
-        vertx.setTimer(TimeUnit.MINUTES.toMillis(3), v -> vertx.eventBus()
+        vertx.setPeriodic(TimeUnit.MINUTES.toMillis(3), TimeUnit.MINUTES.toMillis(15), v -> vertx.eventBus()
                 .publish("miner", new MineNextProject(SpoonPeriodicMiner.ANALYZER_NAME)));
     }
 }