✨ Feat(scheduler): regularly check api ademe and log errors (#865)

Author: mattboll

dossierfacile-api-owner/src/main/java/fr/dossierfacile/api/dossierfacileapiowner/property/PropertyServiceImpl.java

@@ -11,6 +11,7 @@
 import fr.dossierfacile.common.entity.PropertyLog;
 import fr.dossierfacile.common.entity.Tenant;
 import fr.dossierfacile.common.enums.OwnerLogType;
+import fr.dossierfacile.common.model.AdemeApiResultModel;
 import fr.dossierfacile.common.repository.PropertyLogRepository;
 import fr.dossierfacile.common.service.interfaces.TenantCommonService;
 import fr.dossierfacile.common.utils.MapperUtil;

dossierfacile-api-owner/src/main/java/fr/dossierfacile/api/dossierfacileapiowner/property/AdemeApiResultModel.java renamed to dossierfacile-common-library/src/main/java/fr/dossierfacile/common/model/AdemeApiResultModel.java

@@ -1,4 +1,4 @@
-package fr.dossierfacile.api.dossierfacileapiowner.property;
+package fr.dossierfacile.common.model;
 
 import com.fasterxml.jackson.annotation.JsonInclude;
 import lombok.AllArgsConstructor;

dossierfacile-task-scheduler/src/main/java/fr/dossierfacile/scheduler/tasks/TaskName.java

@@ -2,6 +2,7 @@
 
 public enum TaskName {
 
+    CHECK_API_ADEME,
     GARBAGE_COLLECTION,
     OWNER_DELETE,
     OWNER_WARNINGS_1,

dossierfacile-task-scheduler/src/main/java/fr/dossierfacile/scheduler/tasks/ademe/CheckAdemeApiTask.java

@@ -0,0 +1,65 @@
+package fr.dossierfacile.scheduler.tasks.ademe;
+
+import com.fasterxml.jackson.databind.DeserializationFeature;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import fr.dossierfacile.common.model.AdemeApiResultModel;
+import fr.dossierfacile.common.utils.MapperUtil;
+import fr.dossierfacile.scheduler.LoggingContext;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.time.Instant;
+import java.util.Date;
+import java.util.concurrent.TimeUnit;
+
+import static fr.dossierfacile.scheduler.tasks.TaskName.CHECK_API_ADEME;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class CheckAdemeApiTask {
+    private final ObjectMapper objectMapper = MapperUtil.newObjectMapper();
+
+    // Used to check if the API is down and log details
+    @Scheduled(fixedDelayString = "${scheduled.process.check.api.ademe:10}", initialDelayString = "${scheduled.process.check.api.ademe:10}", timeUnit = TimeUnit.MINUTES)
+    public void checkAdemeApi() {
+        LoggingContext.startTask(CHECK_API_ADEME);
+        URI uri;
+        HttpResponse<String> response;
+        try {
+            uri = new URI("https://observatoire-dpe-audit.ademe.fr/pub/dpe/2392E2001612S");
+            HttpRequest request = HttpRequest.newBuilder()
+                    .uri(uri)
+                    .GET()
+                    .build();
+            try (HttpClient client = HttpClient.newHttpClient()) {
+                response = client.send(request, HttpResponse.BodyHandlers.ofString());
+                String json = response.body();
+                if (response.statusCode() == 404) {
+                    log.error("ADEME API ERROR 404 : DPE NOT FOUND");
+                }
+                objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
+                AdemeApiResultModel ademeApiResultModel = objectMapper.readValue(json, AdemeApiResultModel.class);
+
+                if(!ademeApiResultModel.getNumero().equals("2392E2001612S")) {
+                    log.error("ADEME API ERROR : Error with number : {}", ademeApiResultModel.getNumero());
+                }
+                if (!ademeApiResultModel.getDateRealisation().equals("2023-06-14T22:00:00Z")) {
+                    log.error("ADEME API ERROR : Error with date : {}", ademeApiResultModel.getDateRealisation());
+                }
+            } catch (Exception e) {
+                log.error("ADEME API ERROR : An error occurred while processing the request", e);
+            }
+        } catch (URISyntaxException e) {
+            log.error("ADEME API ERROR : An URISyntaxException occured", e);
+        }
+        LoggingContext.endTask();
+    }
+}