Vulcan/packages/nova-voting/lib/server/cron.js
Comus Leong 464e20a96c eslint & clean up code, also fixed some bugs (#1515)
* [eslint] update eslint rules & add .eslintignore to ignore non-ready nova packages

* [clean-up] nova-voting

* [clean-up] [bug] nova-users: missing user parameter

* [clean-up] nova-users

* [clean-up] nova-subscribe

* [clean-up] nova-settings

* [clean-up] nova-rss

* [clean-up] [bug] nova-posts: correct UsersRemoveDeletePosts

* [clean-up] nova-posts

* [clean-up] nova-notifications

* [clean-up] [bug] nova-newsletter: no error.message on throw error

* [clean-up] nova-newsletter

* [clean-up] nova-lib

* [clean-up] nova-kadira

* [clean-up] nova-inject-data

* [clean-up] nova-getting-started

* [clean-up] nova-forms

* [clean-up] nova-events

* [clean-up] [bug] nova-embedly: no FlowRouter

* [clean-up] nova-embedly

* [clean-up] nova-email-templates

* [clean-up] nova-email

* [clean-up] nova-debug

* [clean-up] nova-core

* [clean-up] [bug] nova-comments: correct UsersRemoveDeleteComments

* [clean-up] nova-comments

* [clean-up] [bug] nova-cloudinary: use Telescope.settings.collection instand

* [clean-up] nova-cloudinary

* [clean-up] nova-categories

* [clean-up] nova-base-components

* [clean-up] nova-api

* [eslint] extends react recommended

* [clean-up] for jsx files

* [eslint] extends meteor recommended

* i forgot this one little change
2016-11-25 13:46:55 -05:00

38 lines
1.6 KiB
JavaScript

import Telescope from 'meteor/nova:lib';
import Posts from "meteor/nova:posts";
import Comments from "meteor/nova:comments";
Meteor.startup(function () {
var scoreInterval = parseInt(Telescope.settings.get("scoreUpdateInterval")) || 30;
if (scoreInterval > 0) {
// active items get updated every N seconds
Meteor.setInterval(function () {
var updatedPosts = 0; // eslint-disable-line
var updatedComments = 0; // eslint-disable-line
// console.log('tick ('+scoreInterval+')');
Posts.find({'status': 2,'inactive': {$ne : true}}).forEach(function (post) { // only run scoring on approved posts
updatedPosts += Telescope.updateScore({collection: Posts, item: post});
});
Comments.find({'inactive': {$ne : true}}).forEach(function (comment) {
updatedComments += Telescope.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 () {
var updatedPosts = 0; // eslint-disable-line
var updatedComments = 0; // eslint-disable-line
Posts.find({'inactive': true}).forEach(function (post) {
updatedPosts += Telescope.updateScore({collection: Posts, item: post});
});
Comments.find({'inactive': true}).forEach(function (comment) {
updatedComments += Telescope.updateScore({collection: Comments, item: comment});
});
}, 3600 * 1000);
}
});