wunderschedule-run.js

"use strict";
var scheduler = require('node-schedule');

var api = require('./utils/api.js');
var app = require('commander')
var list_api = require('./utils/list.js');
var log = require("./utils/logging.js").log;
var parse = require('./utils/parseTaskTemplate.js');
var task = require("./utils/task.js");

// Name of list to hold task templates
var scheduled = "scheduled";

// Calls back with the list_id of "scheduled" list.
// Makes the "scheduled" list if not found.
function getScheduledListID(cb) {
    list_api.getListID(scheduled, function (list_id) {
        if(!list_id) {
            makeScheduled(cb);
        }
        cb(list_id);
    });
}

// Makes a list called "scheduled" and calls back with the list_id
function makeScheduled(cb) {
    api.post({url: '/lists', body: {"title": scheduled}}, function (err, res, body) {
        if(err) {
            log.error("Error creating scheduled list.");
            log.error(err);
            process.exit(1);
        }
        cb(body.id);
    });
}

// Appends given text to the note associated with the given task_id
function appendNote(task_id, text){
    api({url: '/notes', qs:{task_id: task_id}},function(err,res,body){
        if(err){
            log.error("Error appending note.")
            log.error(err);
            process.exit(1);
        }
        if(body.content){
            var contentStr = body.content + text;
            api.post({url:'/notes/:' + id ,qs:{revision: id, content: contentStr}});
        }
    });
}

// Creates a task with the properties (due_date, list membership, starred
// etc.) of the given template dictionary. Defaults list membership to 'inbox'
function createTaskFromTemplate(template){
    var list_name = template.list || "inbox";
    var due_date = template.due_date;
    list_api.getListID(list_name, function(list_id){
        task.getTask(template.task_id,function(template_task){
            task.createTask(list_id, template_task.title, due_date.toISOString(), template.starred);
        })
    })
}

// Accepts a list of templates. For each template, we see if the start_date was
// before 'now'. If that's the case, create a task from the template. Once
// done, delete the template if it doesn't repeat, otherwise increment the
// start/due dates and update the template.
function handleTemplates(templates){
    var i = 0;
    var now = new Date();

    for(i = 0; i < templates.length; i++){
        var curr = templates[i];
        //Validate that template has start_date
        if(curr.start_time){
            //See if start_date is before now
            if(curr.start_time <= now){
                //Need to create task from template
                createTaskFromTemplate(curr);
                
                //If not a repeating task, delete the spawning template
                if(!curr.repeat_every){
                        task.logTask(curr.task_id, 'Deleting non-repeating task template.', 'info');
                        task.deleteTask(curr.task_id);
                } else {
                    //Otherwise, set start_date to next occurance
                    var template = parse.updateTemplateWithRepeat(curr);
                    if(template) {
                        parse.pushTemplateUpdate(template);
                    } else{
                        // Called when repetition could not be parsed
                        task.deleteTask(curr.task_id);
                        task.logTask(curr.task_id, 'Could not parse repeat in template. Deleting.', 'warn');
                    }
                }

                task.logTask(curr.task_id,'Creating task.','info')
            }
        }
    }
}

// Main checking function of WunderSchedule.
// 1. Gets the list_id of "scheduled"
// 2. Extracts templates from the notes in that list.
// 3. Handles each template, which creates tasks if necessary.
function wunderSchedule(){
    if(!api.isAuthenticated()){
        log.error("WunderSchedule cannot run without authentication credentials.");
        process.exit(1);
    }
    getScheduledListID(function(list_id){
        parse.extractTemplateTasks(list_id,function(templates){
            log.info("Loaded " + templates.length + " task templates.")
            handleTemplates(templates);
        });
    })
}

log.info("Setup and watching scheduled list.")
var currSeconds = new Date().getSeconds();

// Run every 1 minute
scheduler.scheduleJob(currSeconds + " * * * * *", function(){
    log.info("Running scheduled check at " + new Date().toString("yyyy-MM-dd HH:mm:ss"));
    wunderSchedule();
})