feat(data-input-status): add methods to retrieve data input status by source and build sources list from tenant config

Author: mjabascal10

backend/src/main/java/com/park/utmstack/service/UtmDataInputStatusService.java

@@ -179,7 +179,7 @@ private void checkDataInputStatus(List<UtmDataInputStatus> inputs, String server
         }
     }
 
-    @Scheduled(fixedDelay = 15000, initialDelay = 30000)
+    @Scheduled(fixedDelay = 1000, initialDelay = 2000)
     public void syncDataInputStatus() {
         final String ctx = CLASSNAME + ".syncDataInputStatus";
 
@@ -198,10 +198,11 @@ public void syncDataInputStatus() {
             latestStats.forEach((key, stat) -> {
                 try {
                     String dataType = stat.getDataType();
-                    String dataSource = getDataSource(stat.getDataSource());
+                    String assetName = this.getDataSource(stat.getDataSource());
+
                     long timestamp = Instant.parse(stat.getTimestamp()).getEpochSecond();
 
-                    String compositeKey = dataType + "-" + dataSource;
+                    String compositeKey = dataType + "-" + assetName;
 
                     UtmDataInputStatus status = existing.get(compositeKey);
                     boolean changed = false;
@@ -210,14 +211,18 @@ public void syncDataInputStatus() {
                         status = UtmDataInputStatus.builder()
                                 .id(compositeKey)
                                 .dataType(dataType)
-                                .source(dataSource)
+                                .source(assetName)
                                 .timestamp(timestamp)
                                 .median(86400L)
                                 .build();
                         changed = true;
 
                     } else if (status.getTimestamp() != timestamp) {
-                        status.setSource(dataSource);
+
+                        if (!assetName.equals(stat.getDataSource())) {
+                             status.setSource(stat.getDataSource());
+                        }
+
                         status.setTimestamp(timestamp);
                         changed = true;
                     }