wip

Author: ja-openai

webapp/src/main/java/com/box/l10n/mojito/quartz/multi/QuartzMultiSchedulerConfig.java

@@ -39,6 +39,7 @@ public class QuartzMultiSchedulerConfig {
 
   @PostConstruct
   public void createSchedulers() {
+    logger.error("Create quartz schedulers");
 
     for (Map.Entry<String, SchedulerConfigurationProperties> entry :
         quartzMultiSchedulerConfigurationProperties.getSchedulers().entrySet()) {

webapp/src/main/java/com/box/l10n/mojito/quartz/multi/QuartzMultiSchedulerConfigurationProperties.java

@@ -15,8 +15,6 @@ public class QuartzMultiSchedulerConfigurationProperties {
 
   Map<String, SchedulerConfigurationProperties> schedulers;
 
-  List<SchedulerConfigurationProperties> schedulerConfigurationProperties = new ArrayList<>();
-
   public Map<String, SchedulerConfigurationProperties> getSchedulers() {
     return schedulers;
   }

webapp/src/main/java/com/box/l10n/mojito/rest/textunit/AiTranslateWS.java

@@ -1,10 +1,13 @@
-package com.box.l10n.mojito.rest.textunit;
+package com.box.l10n.mojito.service.oaitranslate;
 
 import com.box.l10n.mojito.json.ObjectMapper;
 import com.box.l10n.mojito.openai.OpenAIClient;
+import java.time.Duration;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
+import reactor.util.retry.Retry;
+import reactor.util.retry.RetryBackoffSpec;
 
 @Configuration
 public class AiTranslateConfig {
@@ -16,18 +19,24 @@ public AiTranslateConfig(AiTranslateConfigurationProperties aiTranslateConfigura
   }
 
   @Bean
-  @Qualifier("AiTranslateWS")
+  @Qualifier("AiTranslate")
   OpenAIClient openAIClient() {
     return new OpenAIClient.Builder()
         .apiKey(aiTranslateConfigurationProperties.getOpenaiClientToken())
         .build();
   }
 
   @Bean
-  @Qualifier("AiTranslateWS")
+  @Qualifier("AiTranslate")
   ObjectMapper objectMapper() {
     ObjectMapper objectMapper = new ObjectMapper();
-    AiTranslateWS.configureObjectMapper(objectMapper);
+    AiTranslateService.configureObjectMapper(objectMapper);
     return objectMapper;
   }
+
+  @Bean
+  @Qualifier("AiTranslate")
+  RetryBackoffSpec retryBackoffSpec() {
+    return Retry.backoff(5, Duration.ofMillis(500)).maxBackoff(Duration.ofSeconds(5));
+  }
 }

webapp/src/main/java/com/box/l10n/mojito/rest/textunit/AiTranslateConfig.java renamed to webapp/src/main/java/com/box/l10n/mojito/service/oaitranslate/AiTranslateConfig.java

@@ -1,4 +1,4 @@
-package com.box.l10n.mojito.rest.textunit;
+package com.box.l10n.mojito.service.oaitranslate;
 
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.stereotype.Component;
@@ -7,6 +7,7 @@
 @ConfigurationProperties("l10n.ai-translate")
 public class AiTranslateConfigurationProperties {
   String openaiClientToken;
+  String schedulerName = "default";
 
   public String getOpenaiClientToken() {
     return openaiClientToken;
@@ -15,4 +16,12 @@ public String getOpenaiClientToken() {
   public void setOpenaiClientToken(String openaiClientToken) {
     this.openaiClientToken = openaiClientToken;
   }
+
+  public String getSchedulerName() {
+    return schedulerName;
+  }
+
+  public void setSchedulerName(String schedulerName) {
+    this.schedulerName = schedulerName;
+  }
 }

webapp/src/main/java/com/box/l10n/mojito/rest/textunit/AiTranslateConfigurationProperties.java renamed to webapp/src/main/java/com/box/l10n/mojito/service/oaitranslate/AiTranslateConfigurationProperties.java

@@ -0,0 +1,32 @@
+package com.box.l10n.mojito.service.oaitranslate;
+
+import static com.box.l10n.mojito.service.oaitranslate.AiTranslateJob.*;
+
+import com.box.l10n.mojito.quartz.QuartzPollableJob;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+/**
+ * Class to process a batch of strings for machine translation against a set of target languages.
+ *
+ * @author garion
+ */
+@Component
+public class AiTranslateJob extends QuartzPollableJob<AiTranslateJobInput, Void> {
+
+  static Logger logger = LoggerFactory.getLogger(AiTranslateJob.class);
+
+  @Autowired AiTranslateService aiTranslateService;
+
+  @Override
+  public Void call(AiTranslateJobInput aiTranslateJobInput) throws Exception {
+    logger.debug(
+        "Start AiTranslateJob with repository id:  {}", aiTranslateJobInput.repositoryId());
+    aiTranslateService.aiTranslate(aiTranslateJobInput.repositoryId());
+    return null;
+  }
+
+  public record AiTranslateJobInput(long repositoryId) {}
+}