mirror of
https://github.com/vale981/Vulcan
synced 2025-03-09 20:16:39 -04:00
36ca34a267
* add collection as the last parameter of a collection.async cb, * when inserting a new document, run upvote.async cb once the document has been inserted (collection.new.async) * remove pre-meteor 1.3 '/server' folder, put everything in the root (initiated by grouping callbacks in the same file for less confusion)
41 lines
1.6 KiB
JavaScript
41 lines
1.6 KiB
JavaScript
import Posts from "meteor/nova:posts";
|
|
import Comments from "meteor/nova:comments";
|
|
import { getSetting } from 'meteor/nova:core';
|
|
import { updateScore } from './scoring.js';
|
|
|
|
// TODO use a node cron or at least synced-cron
|
|
Meteor.startup(function () {
|
|
const scoreInterval = parseInt(getSetting("scoreUpdateInterval")) || 30;
|
|
if (scoreInterval > 0) {
|
|
|
|
// active items get updated every N seconds
|
|
Meteor.setInterval(function () {
|
|
let updatedPosts = 0;
|
|
let updatedComments = 0;
|
|
|
|
// console.log('tick ('+scoreInterval+')');
|
|
Posts.find({'status': 2,'inactive': {$ne : true}}).forEach(function (post) { // only run scoring on approved posts
|
|
updatedPosts += updateScore({collection: Posts, item: post});
|
|
});
|
|
Comments.find({'inactive': {$ne : true}}).forEach(function (comment) {
|
|
updatedComments += updateScore({collection: Comments, item: comment});
|
|
});
|
|
// console.log("Updated "+updatedPosts+"/"+Posts.find().count()+" Posts")
|
|
// console.log("Updated "+updatedComments+"/"+Comments.find().count()+" Comments")
|
|
}, scoreInterval * 1000);
|
|
|
|
// inactive items get updated every hour
|
|
Meteor.setInterval(function () {
|
|
let updatedPosts = 0;
|
|
let updatedComments = 0;
|
|
|
|
Posts.find({'inactive': true}).forEach(function (post) {
|
|
updatedPosts += updateScore({collection: Posts, item: post});
|
|
});
|
|
Comments.find({'inactive': true}).forEach(function (comment) {
|
|
updatedComments += updateScore({collection: Comments, item: comment});
|
|
});
|
|
}, 3600 * 1000);
|
|
|
|
}
|
|
});
|