cron

console.log('Time now ' + new Date());
const t = new Date();
t.setSeconds(t.getSeconds() + 10);
console.log('Setting job to future in 10 seconds ' + t);

SyncedCron.add({
  name: 'aggregateNotifications',
  schedule: function (parser) {
  	// Every 12 hours 
    return parser.text('every 12 hours');
  },
  job: function () {

  	const time = new Date(Date.now() - 1000 * 3600 * 12);
  	notifications = Notifications.aggregate([
      { "$match": {
        "date": { "$gte": time },
      }},
  	]);

		_(notifications).each(function(item) {
      
    });

    var xsmtpapi = {
      "to": receiver,
      "sub": {
        ":firstname":post.createdBy,
        ":friendname":username,
        ":artist":post.artist,
        ":title":post.title,
      },
      "filters": {
        "templates": {
          "settings": {
            "enable": 1,
            "template_id": "d0fa08b2-9400-405f-a47e-d09bbda979b1"
          }
        }
      },
    }

    Email.send({
      from: "hello@village.fm",
      to:receiver,
      subject: subject,
      headers: {
        "X-SMTPAPI": JSON.stringify(xsmtpapi),
        "Content-Type" : "text/html"
      }
    });
  }
});

SyncedCron.start();