call recursively

Author: mayeaux

caching/calculateUploadViews.js

@@ -2,6 +2,7 @@ const Promise = require('bluebird');
 const _ = require('lodash');
 const View = require('../models/index').View;
 const Upload = require('../models/index').Upload;
+const moment = require('moment');
 
 const c = {
   l : console.log
@@ -23,6 +24,7 @@ async function calculateViewAmounts(){
 
   if(logCaching == 'true'){
     c.l('Calculating view amounts for particular videos');
+    console.log(moment(new Date).format('hh:mm:ss A'))
   }
 
   // TODO: have to have a job to update upload's view amounts
@@ -47,6 +49,11 @@ async function calculateViewAmounts(){
     await upload.save();
   }
 
+  if(logCaching == 'true'){
+    c.l('View amounts calculated');
+    console.log(moment(new Date).format('hh:mm:ss A'))
+  }
+
   // if(logCaching == 'true'){
   //   c.l('Uploads received from database');
   //

caching/runCaching.js

@@ -3,6 +3,10 @@ const dotenv = require('dotenv');
 const logCaching = process.env.LOG_CACHING;
 const jsHelpers = require('../lib/helpers/js-helpers');
 
+function sleep(ms) {
+  return new Promise(resolve => setTimeout(resolve, ms));
+}
+
 /** FOR FINDING ERRANT LOGS **/
 if(process.env.SHOW_LOG_LOCATION == 'true' || 1 == 2){
   jsHelpers.showLogLocation();
@@ -76,6 +80,7 @@ async function cacheOnlyRecentUploads(){
 async function cachePopularDailyStatsAndIndex(){
   try {
     await cachePopularUploads();
+    await calculateUploadViews();
     await setCache.setDailyStats();
     await setCache.setIndexValues();
 
@@ -108,26 +113,42 @@ console.log(`CACHE TOTAL VIEW INTERVAL IN MINUTES: ${cacheIntervalInMinutes} \n`
 // TODO: ideally, they should push into an array, run the most recent job in array, then delete it from array,
 // TODO: and run them sequentially
 
-async function main(){
-
-  // setInterval(cacheOnlyRecentUploads, cacheRecentIntervalInMs);
-  //
-  // setInterval(cachePopularDailyStatsAndIndex, cacheIntervalInMs);
-  //
-  // // calculate total amount of views for channel display
-  // // TODO: couldn't this just be done during popular? maybe not because it doesn't do for sensitive?
-  // // TODO: then just do a separate job for
-  // setInterval(calculateUploadViews, cacheTotalViewsIntervalInMs);
-
+async function runRecentInterval(){
   // calculate and cache recent uploads every minute
   await cacheOnlyRecentUploads();
+  await sleep(cacheRecentIntervalInMs)
+  runRecentInterval();
+}
 
-  await cachePopularDailyStatsAndIndex();
+runRecentInterval();
 
-  await calculateUploadViews();
+async function runOtherCaching(){
+  await cachePopularDailyStatsAndIndex();
+  await sleep(cacheIntervalInMs)
+  runOtherCaching()
 }
 
-main();
+runOtherCaching()
+
+// async function main(){
+//
+//   // setInterval(cacheOnlyRecentUploads, cacheRecentIntervalInMs);
+//   //
+//   // setInterval(cachePopularDailyStatsAndIndex, cacheIntervalInMs);
+//   //
+//   // // calculate total amount of views for channel display
+//   // // TODO: couldn't this just be done during popular? maybe not because it doesn't do for sensitive?
+//   // // TODO: then just do a separate job for
+//   // setInterval(calculateUploadViews, cacheTotalViewsIntervalInMs);
+//
+//   // calculate and cache recent uploads every minute
+//   // await cacheOnlyRecentUploads();
+//
+//   // also does total view amounts
+//   await cachePopularDailyStatsAndIndex();
+// }
+
+// main();
 
 // calculateUploadViews()