cache save session

oneteme · Oct 10, 2024 · e1aa5b2 · e1aa5b2
1 parent fe3d129
commit e1aa5b2
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/main/java/org/usf/inspect/server/controller/CacheController.java b/src/main/java/org/usf/inspect/server/controller/CacheController.java
@@ -16,6 +16,7 @@
 import org.usf.inspect.core.DispatchState;
 import org.usf.inspect.server.dao.RequestDao;
 import org.usf.inspect.server.model.ServerSession;
+import org.usf.inspect.server.service.RequestService;
 import org.usf.inspect.server.service.SessionQueueService;
 
 import lombok.RequiredArgsConstructor;
@@ -27,7 +28,7 @@
 public class CacheController {
 
     private final ObjectMapper mapper;
-    private final RequestDao dao;
+    private final RequestService service;
     private final SessionQueueService queue;
 
     RestTemplate defaultRestTemplate() {
@@ -53,7 +54,7 @@ public int addSession(@RequestParam(name = "host") String host) {
         var rt = defaultRestTemplate();
         var ses = rt.getForObject(host + "/cache", ServerSession[].class);
         if(ses != null && ses.length > 0) {
-            dao.saveSessions(Arrays.asList(ses));
+            service.addSessions(Arrays.asList(ses));
             return ses.length;
         }
         return 0;