Scheduler for jobs

Author: Stigmatoz

package.json

@@ -15,6 +15,7 @@
   },
   "dependencies": {
     "vue": "^3.2.47"
+    "date-fns": "^2.30.0",
   },
   "devDependencies": {
     "@types/webextension-polyfill": "^0.10.0",

src/background.ts

@@ -1,11 +1,13 @@
 import Browser from 'webextension-polyfill';
 import { initTracker } from './tracker';
 import { logger } from './compositions/logger';
+import { scheduleJobs } from './jobs/sheduler';
 
 logger.log('Start background script');
 
 Browser.runtime.onInstalled.addListener(details => {
   logger.log('Extension installed:', details);
 });
 
+scheduleJobs();
 initTracker();

src/jobs/sheduler.ts

@@ -0,0 +1,46 @@
+import Browser, { Alarms } from 'webextension-polyfill';
+import { logger } from '../compositions/logger';
+import { StorageParams } from '../storage/storage-params';
+import { injecStorage } from '../storage/inject-storage';
+import { DAY_MINUTES, getNextTimeOfDay } from '../utils/time';
+
+export enum JobId {
+  DailySummaryNotification = '@alarm/daily-summary-notification',
+}
+
+export function scheduleJobs(): void {
+  Browser.alarms.onAlarm.addListener(async alarm => {
+    logger.log(`[schedule-jobs] Alarm ${alarm.name} triggered`, alarm);
+    switch (alarm.name) {
+      case JobId.DailySummaryNotification: {
+        //await dailySummaryNotification();
+        break;
+      }
+    }
+    logger.log(`[schedule-jobs] ${alarm.name} finished`);
+  });
+
+  Browser.runtime.onInstalled.addListener(rescheduleJobs);
+}
+
+async function rescheduleJobs(): Promise<void> {
+  const storage = injecStorage();
+  const dailySummaryNotificationTime = (await storage.getValue(
+    StorageParams.DAILY_SUMMARY_NOTIFICATION_TIME,
+  )) as number;
+  await Browser.alarms.clear(JobId.DailySummaryNotification);
+  Browser.alarms.create(JobId.DailySummaryNotification, {
+    when: getNextTimeOfDay(dailySummaryNotificationTime),
+    periodInMinutes: DAY_MINUTES,
+  });
+}
+
+async function createAlarmIfMissing(
+  name: string,
+  alarmInfo: Alarms.CreateAlarmInfoType,
+): Promise<void> {
+  const existing = await Browser.alarms.get(name).catch(() => undefined);
+  if (existing == null) {
+    Browser.alarms.create(name, alarmInfo);
+  }
+}

src/utils/time.ts

@@ -0,0 +1,9 @@
+import { getToday } from './today';
+
+//Every day - 60 minutes * 24 hours
+export const DAY_MINUTES = 1440;
+
+export function getNextTimeOfDay(timeOfDay: number): number {
+  const todaysTime = getToday() + timeOfDay;
+  return todaysTime > Date.now() ? todaysTime : todaysTime + DAY_MINUTES;
+}

src/utils/today.ts

@@ -1,3 +1,9 @@
+import startOfToday from 'date-fns/startOfToday';
+
 export function todayLocalDate() {
-    return new Date().toLocaleDateString('en-US');
-}
+  return new Date().toLocaleDateString('en-US');
+}
+
+export function getToday(): number {
+  return startOfToday().getTime();
+}