use invokeinterval for livegames

odota · Dec 4, 2023 · c88a35f · c88a35f
1 parent cbd0f9a
commit c88a35f
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 3 deletions.
diff --git a/svc/gcdata.mjs b/svc/gcdata.mjs
@@ -1,6 +1,6 @@
 // Processes a queue of requests for gcdata (replay salts) without parsing
 // The parser will also request gcdata if needed
-import getGcData from '../util/getGcData.mjs';
+import getGcData from '../store/getGcData.mjs';
 import queue from '../store/queue.mjs';
 import config from '../config.js';
 import utility from '../util/utility.mjs';

diff --git a/svc/leagues.mjs b/svc/leagues.mjs
@@ -4,6 +4,7 @@ import utility from '../util/utility.mjs';
 import db from '../store/db.mjs';
 import queries from '../store/queries.mjs';
 const { invokeInterval, generateJob, getData } = utility;
+
 function doLeagues(cb) {
   const container = generateJob('api_leagues', {});
   getData(container.url, (err, apiLeagues) => {

diff --git a/svc/livegames.mjs b/svc/livegames.mjs
@@ -5,6 +5,7 @@ import request from 'request';
 import redis from '../store/redis.mjs';
 import db from '../store/db.mjs';
 import config from '../config.js';
+import { invokeInterval } from '../util/utility.mjs';
 function doLiveGames(cb) {
   // Get the list of pro players
   db.select()
@@ -58,4 +59,4 @@ function doLiveGames(cb) {
       });
     });
 }
-setInterval(doLiveGames, 60 * 1000);
+invokeInterval(doLiveGames, 60 * 1000);
diff --git a/util/utility.mjs b/util/utility.mjs
@@ -797,7 +797,7 @@ function getRedisCountHour(redis, prefix, cb) {
   }
   redis.pfcount(...keyArr, cb);
 }
-function invokeInterval(func, delay) {
+export function invokeInterval(func, delay) {
   // invokes the function immediately, waits for callback, waits the delay, and then calls it again
   (function invoker() {
     console.log('running %s', func.name);