Hotfix: Crash on E-Mail and Webcron

backend/src/app/goals/goal.service.spec.ts

@@ -8,6 +8,7 @@ import { TestConstants } from '../../../test/lib/constants';
 import * as dayjs from 'dayjs';
 import { FitnessData } from '../../integration/fitness/fitness.data';
 import { FitnessGoal } from '../../integration/fitness/fitness.goal';
+import { MockProvider } from '../../integration/fitness/providers/mock.provider';
 
 describe('GoalService', () => {
   let goalService: GoalService;
@@ -73,6 +74,10 @@ describe('GoalService', () => {
         ],
       } as FitnessData);
 
+      fitnessService.getDatasourcesForUser.mockResolvedValue([
+        new MockProvider(),
+      ]);
+
       goalRepository.updateGoal.mockResolvedValue({
         userId: TestConstants.database.users.exampleUser.id,
         type: 'steps',

backend/src/app/goals/goal.service.ts

@@ -24,7 +24,18 @@ export class GoalService {
   }
 
   public async refreshGoals(userId, existing: Goal[]): Promise<Goal[]> {
-    const fitnessData = await this.fitnessService.getFitnessDataForUser(userId);
+    // Verify that the user has at least ony fitness service configured
+    const providers = await this.fitnessService.getDatasourcesForUser(userId);
+
+    if (providers.length < 1) return [];
+
+    let fitnessData;
+    try {
+      fitnessData = await this.fitnessService.getFitnessDataForUser(userId);
+    } catch (e) {
+      // Seems that the fitness provider is not available anymore
+      return [];
+    }
 
     if (!fitnessData) {
       throw new FitnessDataNotAvailable();

backend/src/app/streaks/streak.service.ts

@@ -121,21 +121,26 @@ export class StreakService {
    * @param user ID of the user
    */
   private async verifyDailyGoalsForUser(user: string) {
-    // Verify that the daily goals have not been met yet.
-    const streak = await this.getStreakOf(user);
+    try {
+      // Verify that the daily goals have not been met yet.
+      const streak = await this.getStreakOf(user);
 
-    if (streak.dailyGoalsReached == true) {
-      return;
-    }
+      if (streak.dailyGoalsReached == true) {
+        return;
+      }
 
-    const goals = await this.goalService.getGoalsForUser(user);
+      const goals = await this.goalService.getGoalsForUser(user);
 
-    if (goals.length > 0) {
-      for (const goal of goals) {
-        if (goal.value > goal.target) {
-          await this.addPoints(user, 10, true);
+      if (goals.length > 0) {
+        for (const goal of goals) {
+          if (goal.value > goal.target) {
+            await this.addPoints(user, 10, true);
+          }
         }
       }
+    } catch (e) {
+      // If something fails here, this should not stop the others
+      console.warn(e);
     }
   }
 

backend/src/notification/emailNotifier.ts

@@ -17,11 +17,15 @@ export class EmailNotifier implements Notifier {
   }
 
   async notify(user: User, title: string, content: string) {
-    await this.transporter.sendMail({
-      from: process.env.EMAIL_USER,
-      to: user.email,
-      subject: title,
-      text: content,
-    });
+    try {
+      await this.transporter.sendMail({
+        from: process.env.EMAIL_USER,
+        to: user.email,
+        subject: title,
+        text: content,
+      });
+    } catch (e) {
+      console.warn('Error while sending an email: ', e);
+    }
   }
 }

backend/src/notification/notification.service.ts

@@ -21,7 +21,7 @@ export class NotificationService {
 
     // only supports email notifications for now
     this.notifiers?.[user?.notificationMethod ?? '']?.notify(
-      userId,
+      user,
       title,
       content,
     );