app: update all users every 5 minutes

src/main/java/org/cryptodrink/data/model/UserModel.java

@@ -3,6 +3,7 @@
 import lombok.Data;
 
 import javax.persistence.*;
+import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.ArrayList;
@@ -31,5 +32,5 @@ public class UserModel {
     @ManyToMany(mappedBy = "users")
     private List<ScoreboardModel> scoreboards = new ArrayList<>();
 
-    private LocalDateTime lastRefreshed;
+    private Instant lastRefreshed;
 }

src/main/java/org/cryptodrink/domain/entity/UserEntity.java

@@ -3,6 +3,7 @@
 import lombok.AllArgsConstructor;
 import lombok.Data;
 
+import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 
@@ -18,5 +19,5 @@ public class UserEntity {
     private Integer rank;
     private Integer score;
     private String website;
-    private LocalDateTime lastRefreshed;
+    private Instant lastRefreshed;
 }

src/main/java/org/cryptodrink/domain/service/ApplicationService.java

@@ -0,0 +1,18 @@
+package org.cryptodrink.domain.service;
+
+import javax.annotation.PostConstruct;
+import javax.enterprise.context.ApplicationScoped;
+import javax.inject.Inject;
+
+@ApplicationScoped
+public class ApplicationService {
+
+    @Inject
+    UserService userService;
+
+    @PostConstruct
+    public void onStart() {
+        userService.startScheduledUpdates();
+    }
+}
+

src/main/java/org/cryptodrink/domain/service/UserService.java

@@ -22,6 +22,9 @@
 import java.security.SignatureException;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
 
 @ApplicationScoped
 public class UserService {
@@ -118,4 +121,25 @@ public UserEntity getUserFromToken(String token) {
             return null;
         }
     }
+
+    private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
+
+    public void startScheduledUpdates() {
+        scheduler.scheduleAtFixedRate(this::updateAllUsers, 0, 5, TimeUnit.MINUTES);
+    }
+
+    private void updateAllUsers() {
+        logger.info("Starting user updates...");
+
+        users.listAll().forEach(user -> {
+            scheduler.submit(() -> {
+                try {
+                    cryptoHack.updateUserInfo(user.getUsername());
+                    logger.info("Successfully updated user info for {}", user.getUsername());
+                } catch (Exception e) {
+                    logger.error("Failed to update user info for {}", user.getUsername(), e);
+                }
+            });
+        });
+    }
 }

src/main/java/org/cryptodrink/domain/service/cryptohack/CryptoHackAPI.java

@@ -26,6 +26,7 @@
 import java.net.http.HttpClient;
 import java.net.http.HttpRequest;
 import java.net.http.HttpResponse;
+import java.time.Instant;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
@@ -127,7 +128,7 @@ public void saveUserInfo(CryptoHackResponse userInfo) {
         user.setRank(userInfo.getRank());
         user.setScore(userInfo.getScore());
         user.setWebsite(userInfo.getWebsite());
-        user.setLastRefreshed(LocalDateTime.now());
+        user.setLastRefreshed(Instant.now());
         users.persist(user);
 
         List<SolvedChallengeModel> solvedChallenges = user.getSolvedChallenges();

src/main/java/org/cryptodrink/utils/TimeString.java

@@ -1,8 +1,6 @@
 package org.cryptodrink.utils;
 
-import java.time.LocalDateTime;
-import java.time.ZoneOffset;
-import java.time.ZonedDateTime;
+import java.time.*;
 import java.time.format.DateTimeFormatter;
 
 public class TimeString {
@@ -14,4 +12,9 @@ public static String convertToUTCString(LocalDateTime localDateTime) {
         DateTimeFormatter formatter = DateTimeFormatter.ISO_INSTANT;
         return zonedDateTime.format(formatter);
     }
+
+    public static String convertToUTCString(Instant instant) {
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd'T'HH:mm:ss'Z'");
+        return formatter.withZone(ZoneId.of("UTC")).format(instant);
+    }
 }