diff --git a/src/user/jobs.ts b/src/user/jobs.ts
new file mode 100644
index 000000000..4494f2dcd
--- /dev/null
+++ b/src/user/jobs.ts
@@ -0,0 +1,64 @@
+import * as winston from 'winston';
+import * as cronJob from 'cron';
+import * as db from '../database';
+import * as meta from '../meta';
+
+const jobs = {};
+
+module.exports = function (User) {
+    User.startJobs = function () {
+        winston.verbose('[user/jobs] (Re-)starting jobs...');
+
+        let { digestHour } = meta.config;
+
+        // Fix digest hour if invalid
+        if (isNaN(digestHour)) {
+            digestHour = 17;
+        } else if (digestHour > 23 || digestHour < 0) {
+            digestHour = 0;
+        }
+
+        User.stopJobs();
+
+        startDigestJob('digest.daily', `0 ${digestHour} * * *`, 'day');
+        startDigestJob('digest.weekly', `0 ${digestHour} * * 0`, 'week');
+        startDigestJob('digest.monthly', `0 ${digestHour} 1 * *`, 'month');
+
+        jobs['reset.clean'] = new cronJob('0 0 * * *', User.reset.clean, null, true);
+        winston.verbose('[user/jobs] Starting job (reset.clean)');
+
+        winston.verbose(`[user/jobs] jobs started`);
+    };
+
+    function startDigestJob(name, cronString, term) {
+        jobs[name] = new cronJob(cronString, (async () => {
+            winston.verbose(`[user/jobs] Digest job (${name}) started.`);
+            try {
+                if (name === 'digest.weekly') {
+                    const counter = await db.increment('biweeklydigestcounter');
+                    if (counter % 2) {
+                        await User.digest.execute({ interval: 'biweek' });
+                    }
+                }
+                await User.digest.execute({ interval: term });
+            } catch (err) {
+                winston.error(err.stack);
+            }
+        }), null, true);
+        winston.verbose(`[user/jobs] Starting job (${name})`);
+    }
+
+    User.stopJobs = function () {
+        let terminated = 0;
+        // Terminate any active cron jobs
+        for (const jobId of Object.keys(jobs)) {
+            winston.verbose(`[user/jobs] Terminating job (${jobId})`);
+            jobs[jobId].stop();
+            delete jobs[jobId];
+            terminated += 1;
+        }
+        if (terminated > 0) {
+            winston.verbose(`[user/jobs] ${terminated} jobs terminated`);
+        }
+    };
+};