Resolve conflicts

src/main/java/de/tum/cit/aet/artemis/core/service/TelemetrySendingService.java

@@ -0,0 +1,89 @@
+package de.tum.cit.aet.artemis.core.service;
+
+import static de.tum.cit.aet.artemis.core.config.Constants.PROFILE_SCHEDULING;
+
+import java.util.Arrays;
+import java.util.List;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Profile;
+import org.springframework.core.env.Environment;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestTemplate;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.ObjectWriter;
+
+@Service
+@Profile(PROFILE_SCHEDULING)
+public class TelemetrySendingService {
+
+ private static final Logger log = LoggerFactory.getLogger(TelemetrySendingService.class);
+
+ @JsonInclude(JsonInclude.Include.NON_EMPTY)
+ public record TelemetryData(String version, String serverUrl, String operator, String contact, List<String> profiles, String adminName) {
+ }
+
+ private final Environment env;
+
+ private final RestTemplate restTemplate;
+
+ public TelemetrySendingService(Environment env, RestTemplate restTemplate) {
+ this.env = env;
+ this.restTemplate = restTemplate;
+ }
+
+ @Value("${artemis.version}")
+ private String version;
+
+ @Value("${server.url}")
+ private String serverUrl;
+
+ @Value("${info.operatorName}")
+ private String operator;
+
+ @Value("${info.operatorAdminName}")
+ private String operatorAdminName;
+
+ @Value("${info.contact}")
+ private String contact;
+
+ @Value("${artemis.telemetry.sendAdminDetails}")
+ private boolean sendAdminDetails;
+
+ @Value("${artemis.telemetry.destination}")
+ private String destination;
+
+ /**
+ * Assembles the telemetry data, and sends it to the external telemetry server.
+ *
+ * @throws Exception if the writing the telemetry data to a json format fails, or the connection to the telemetry server fails
+ */
+ @Async
+ public void sendTelemetryByPostRequest() throws Exception {
+ List<String> activeProfiles = Arrays.asList(env.getActiveProfiles());
+ TelemetryData telemetryData;
+ if (sendAdminDetails) {
+ telemetryData = new TelemetryData(version, serverUrl, operator, contact, activeProfiles, operatorAdminName);
+ }
+ else {
+ telemetryData = new TelemetryData(version, serverUrl, operator, null, activeProfiles, null);
+ }
+
+ HttpHeaders headers = new HttpHeaders();
+ headers.setContentType(MediaType.APPLICATION_JSON);
+ ObjectWriter objectWriter = new ObjectMapper().writer().withDefaultPrettyPrinter();
+
+ var telemetryJson = objectWriter.writeValueAsString(telemetryData);
+ HttpEntity<String> requestEntity = new HttpEntity<>(telemetryJson, headers);
+ var response = restTemplate.postForEntity(destination + "/api/telemetry", requestEntity, String.class);
+ log.info("Successfully sent telemetry data. {}", response.getBody());
+ }
+}