FxLifeSheet/reminder.js

"use strict";
exports.__esModule = true;
var moment = require("moment");
var config = require("./classes/config.js");
var postgres = require("./classes/postgres.js");
var telegram = require("./classes/telegram.js");
console.log("Checking if we need to send a reminder to the user...");
setTimeout(function () {
    postgres.client.query({
        text: "SELECT * FROM last_run"
    }, function (err, res) {
        console.log(res);
        if (err) {
            console.error(err);
            return;
        }
        var rows = res.rows;
        for (var i = 0; i < rows.length; i++) {
            var currentRow = rows[i];
            var command = currentRow.command;
            var lastRun = moment(Number(currentRow.last_run));
            if (config.userConfig[command] == null) {
                console.error("Error, command not found, means it's not on the last run sheet, probably due to renaming a command: " +
                    command);
                break;
            }
            var scheduleType = config.userConfig[command].schedule;
            var timeDifferenceHours = moment().diff(moment(lastRun), "hours");
            var shouldRemindUser = false;
            if (scheduleType == "eightTimesADay") {
                if (timeDifferenceHours >= 24 / 8) {
                    shouldRemindUser = true;
                }
            }
            else if (scheduleType == "daily") {
                if (timeDifferenceHours >= 24 * 0.95) {
                    shouldRemindUser = true;
                }
            }
            else if (scheduleType == "weekly") {
                if (timeDifferenceHours >= 24 * 7 * 1.05) {
                    shouldRemindUser = true;
                }
            }
            else if (scheduleType == "monthly") {
                if (timeDifferenceHours >= 24 * 30 * 1.05) {
                    shouldRemindUser = true;
                }
            }
            else if (scheduleType == "manual") {
            }
            else {
                console.error("Unknown schedule type " + scheduleType);
            }
            var didJustSendMessage = false;
            if (currentRow.lastmessage) {
                var lastMessageSent = moment(Number(currentRow.lastmessage));
                if (moment().diff(lastMessageSent, "hours") < 8) {
                    didJustSendMessage = true;
                }
            }
            console.log(command +
                ": " +
                lastRun.format() +
                " should remind? " +
                shouldRemindUser +
                " time diff in h " +
                timeDifferenceHours +
                " didJustSendMessage " +
                didJustSendMessage);
            if (shouldRemindUser && !didJustSendMessage) {
                console.log("Reminding user to run questions again...");
                var textToSend = "Please run /" +
                    command +
                    " again, it's been " +
                    timeDifferenceHours +
                    " hours since you last filled it out";
                if (process.env.TELEGRAM_CHAT_ID == null) {
                    console.error("Please set the `TELEGRAM_CHAT_ID` ENV variable");
                }
                telegram.bot.telegram.sendMessage(process.env.TELEGRAM_CHAT_ID, textToSend);
                postgres.client.query({
                    text: "UPDATE last_run SET last_message = $1 where command = $2",
                    values: [moment().valueOf(), command]
                }, function (err, res) {
                    if (err) {
                        console.log(err);
                    }
                    console.log(res);
                });
            }
        }
        console.log("Reminder check done");
    });
}, 2000);
//# sourceMappingURL=reminder.js.map