Updated lambda calling

TwoAbove · Sep 8, 2024 · 989ef4d · 989ef4d
1 parent d8d2ea0
commit 989ef4d
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/server/io/compute.mjs b/server/io/compute.mjs
@@ -9,10 +9,6 @@ export const counts = {
 };
 const users = {};
 
-setInterval(() => {
-  console.info(users);
-}, 5000);
-
 const registerUserSocket = (userId, socketId, type, appetite = 0) => {
   if (!users[userId]) {
     users[userId] = { hosts: new Set(), workers: new Set() };
@@ -60,8 +56,13 @@ const pingLambda = () => {
 };
 
 setInterval(() => {
+  console.info(users);
   if (counts.hosts > 0) {
-    pingLambda();
+    const userWithHostsAndCompute = Object.values(users).some(user => user.hosts.size > 0 && user.computeLeft > 0);
+
+    if (userWithHostsAndCompute) {
+      pingLambda();
+    }
   }
 }, 10000);