248 notify user by email

compose.yaml

@@ -66,6 +66,16 @@ services:
       timeout: 5s
       retries: 5
 
+  postfix:
+    image: ghcr.io/ls1admin/postfix:latest
+    container_name: hephaestus-postfix
+    restart: unless-stopped
+    volumes:
+      - ./postfix-config:/config # See https://github.com/ls1admin/postfix-container-tum-mailrelay/tree/main for details
+    hostname: aet.cit.tum.de
+    networks:
+      - app-network
+
 networks:
   app-network:
     driver: bridge

docker/compose.app.yaml

@@ -80,6 +80,8 @@ services:
       LEADERBOARD_SCHEDULE_DAY: ${LEADERBOARD_SCHEDULE_DAY}
       LEADERBOARD_SCHEDULE_TIME: ${LEADERBOARD_SCHEDULE_TIME}
       SENTRY_DSN: ${SENTRY_DSN}
+      POSTFIX_HOST: postfix
+      POSTFIX_PORT: 25
     depends_on:
       - postgres
     restart: unless-stopped

docker/compose.core.yaml

@@ -140,6 +140,16 @@ services:
       timeout: 20s
       retries: 10
 
+  postfix:
+    image: ghcr.io/ls1admin/postfix:latest
+    container_name: hephaestus-postfix
+    restart: unless-stopped
+    volumes:
+      - ./postfix-config:/config # See https://github.com/ls1admin/postfix-container-tum-mailrelay/tree/main for details
+    hostname: aet.cit.tum.de
+    networks:
+      - shared-network
+
 networks:
   shared-network:
     name: shared-network
@@ -362,14 +372,18 @@ configs:
               "description": "Administrator privileges",
               "composites": {
                 "realm": [
-                  "mentor_access"
+                  "mentor_access",
+                  "notification_access"
                 ]
               }
             },
             {
               "name": "mentor_access",
               "description": "Access to AI Mentor"
             },
+            { "name": "notification_access",
+              "description": "Get notification emails"
+            },
             {
               "name": "offline_access",
               "description": "${role_offline-access}",
@@ -407,5 +421,29 @@ configs:
           "description": "${role_default-roles}",
           "composite": true,
           "clientRole": false
-        }
+        },
+        "users": [
+          {
+              "id": "d7b8cea0-f9f6-43df-8a27-eb9a18fb87cb",
+              "username": "service-account-hephaestus-confidential",
+              "emailVerified": false,
+              "createdTimestamp": 1741338840502,
+              "enabled": true,
+              "totp": false,
+              "serviceAccountClientId": "hephaestus-confidential",
+              "disableableCredentialTypes": [],
+              "requiredActions": [],
+              "realmRoles": [
+                  "default-roles-hephaestus"
+              ],
+              "clientRoles": {
+                  "realm-management": [
+                      "view-users",
+                      "query-users",
+                      "manage-users"
+                  ]
+              },
+              "notBefore": 0,
+              "groups": []
+          }]
       }

server/application-server/keycloak-hephaestus-realm-example-config.json

@@ -81,6 +81,15 @@
               "containerId": "69732d45-1431-4909-9335-9f39e304f823",
               "attributes": {}
             },
+            {
+                "id": "af3b75a2-9733-44e5-bdc3-1e3e32459743",
+                "name": "notification_access",
+                "description": "",
+                "composite": false,
+                "clientRole": false,
+                "containerId": "69732d45-1431-4909-9335-9f39e304f823",
+                "attributes": {}
+            },
             {
                 "id": "a0bcdf44-1bd1-4b3d-8667-021f2bc8802b",
                 "name": "uma_authorization",
@@ -97,7 +106,8 @@
               "composite": true,
               "composites": {
                 "realm": [
-                  "mentor_access"
+                  "mentor_access",
+                  "notification_access"
                 ]
               },
               "clientRole": false,
@@ -457,6 +467,29 @@
     "webAuthnPolicyPasswordlessAcceptableAaguids": [],
     "webAuthnPolicyPasswordlessExtraOrigins": [],
     "users": [
+        {
+            "id": "d7b8cea0-f9f6-43df-8a27-eb9a18fb87cb",
+            "username": "service-account-hephaestus-confidential",
+            "emailVerified": false,
+            "createdTimestamp": 1741338840502,
+            "enabled": true,
+            "totp": false,
+            "serviceAccountClientId": "hephaestus-confidential",
+            "disableableCredentialTypes": [],
+            "requiredActions": [],
+            "realmRoles": [
+                "default-roles-hephaestus"
+            ],
+            "clientRoles": {
+                "realm-management": [
+                    "view-users",
+                    "query-users",
+                    "manage-users"
+                ]
+            },
+            "notBefore": 0,
+            "groups": []
+        },
         {
             "id": "9d394368-150d-4559-b005-758a50cbb353",
             "username": "admin",

server/application-server/openapi.yaml

@@ -218,6 +218,35 @@ paths:
       responses:
         "200":
           description: OK
+  /user/settings:
+    get:
+      tags:
+      - user
+      operationId: getUserSettings
+      responses:
+        "200":
+          description: OK
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/UserSettings"
+    post:
+      tags:
+      - user
+      operationId: updateUserSettings
+      requestBody:
+        content:
+          application/json:
+            schema:
+              $ref: "#/components/schemas/UserSettings"
+        required: true
+      responses:
+        "200":
+          description: OK
+          content:
+            application/json:
+              schema:
+                $ref: "#/components/schemas/UserSettings"
   /mentor/sessions:
     get:
       tags:
@@ -696,6 +725,11 @@ components:
       - id
       - name
       - nameWithOwner
+    UserSettings:
+      type: object
+      properties:
+        receiveNotifications:
+          type: boolean
     UserTeams:
       type: object
       properties:

server/application-server/pom.xml

@@ -92,6 +92,14 @@
 			<scope>runtime</scope>
 			<optional>true</optional>
 		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-mail</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-thymeleaf</artifactId>
+		</dependency>
 		<dependency>
 			<groupId>org.postgresql</groupId>
 			<artifactId>postgresql</artifactId>

server/application-server/src/main/java/de/tum/in/www1/hephaestus/activity/ActivityService.java

@@ -6,7 +6,7 @@
 import de.tum.in.www1.hephaestus.gitprovider.pullrequest.PullRequest;
 import de.tum.in.www1.hephaestus.gitprovider.pullrequest.PullRequestRepository;
 import de.tum.in.www1.hephaestus.gitprovider.user.UserRepository;
-import jakarta.transaction.Transactional;
+import de.tum.in.www1.hephaestus.notification.MailService;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -34,6 +34,9 @@ public class ActivityService {
     @Autowired
     private UserRepository userRepository;
 
+    @Autowired
+    private MailService mailService;
+
     public ActivityDTO getActivity(String login) {
         logger.info("Getting activity for user with login: {}", login);
 
@@ -95,6 +98,13 @@ public List<PullRequestBadPracticeDTO> detectBadPracticesForPullRequest(Long pul
         List<PullRequestBadPractice> detectedBadPractices = pullRequestBadPracticeDetector.detectAndSyncBadPractices(
             pullRequest
         );
+
+        mailService.sendBadPracticesDetectedInPullRequestEmail(
+            pullRequest.getAuthor(),
+            pullRequest,
+            detectedBadPractices
+        );
+
         return detectedBadPractices.stream().map(PullRequestBadPracticeDTO::fromPullRequestBadPractice).toList();
     }
 }

server/application-server/src/main/java/de/tum/in/www1/hephaestus/activity/badpracticedetector/BadPracticeDetectorScheduler.java

@@ -3,6 +3,10 @@
 import de.tum.in.www1.hephaestus.gitprovider.label.Label;
 import de.tum.in.www1.hephaestus.gitprovider.pullrequest.PullRequest;
 import java.util.Set;
+
+import de.tum.in.www1.hephaestus.notification.MailService;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.core.task.TaskExecutor;
@@ -11,22 +15,36 @@
 @Component
 public class BadPracticeDetectorScheduler {
 
+    private static final Logger logger = LoggerFactory.getLogger(BadPracticeDetectorScheduler.class);
+
     private static final String READY_TO_MERGE = "ready to merge";
 
     @Qualifier("applicationTaskExecutor")
     @Autowired
     TaskExecutor taskExecutor;
 
+    @Autowired
+    PullRequestBadPracticeDetector pullRequestBadPracticeDetector;
+
+    @Autowired
+    MailService mailService;
+
     public void detectBadPracticeForPrIfReadyToMerge(
         PullRequest pullRequest,
         Set<Label> oldLabels,
         Set<Label> newLabels
     ) {
+        logger.info("Checking if bad practice detection should be scheduled for pull request: {}", pullRequest.getId());
+        logger.info("Old labels: {}", oldLabels);
+        logger.info("New labels: {}", newLabels);
         if (
             newLabels.stream().anyMatch(label -> READY_TO_MERGE.equals(label.getName())) &&
             oldLabels.stream().noneMatch(label -> READY_TO_MERGE.equals(label.getName()))
         ) {
+            logger.info("Scheduling bad practice detection for pull request: {}", pullRequest.getId());
             BadPracticeDetectorTask badPracticeDetectorTask = new BadPracticeDetectorTask();
+            badPracticeDetectorTask.setPullRequestBadPracticeDetector(pullRequestBadPracticeDetector);
+            badPracticeDetectorTask.setMailService(mailService);
             badPracticeDetectorTask.setPullRequest(pullRequest);
             taskExecutor.execute(badPracticeDetectorTask);
         }

server/application-server/src/main/java/de/tum/in/www1/hephaestus/activity/badpracticedetector/BadPracticeDetectorTask.java

@@ -1,23 +1,39 @@
 package de.tum.in.www1.hephaestus.activity.badpracticedetector;
 
+import de.tum.in.www1.hephaestus.activity.model.PullRequestBadPractice;
 import de.tum.in.www1.hephaestus.gitprovider.pullrequest.PullRequest;
+import de.tum.in.www1.hephaestus.gitprovider.user.User;
+import de.tum.in.www1.hephaestus.notification.MailService;
+import java.util.List;
 import lombok.Getter;
 import lombok.Setter;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Component;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
-@Component
 @Getter
 @Setter
 public class BadPracticeDetectorTask implements Runnable {
 
-    @Autowired
+    private static final Logger logger = LoggerFactory.getLogger(BadPracticeDetectorTask.class);
+
     private PullRequestBadPracticeDetector pullRequestBadPracticeDetector;
 
+    private MailService mailService;
+
     private PullRequest pullRequest;
 
     @Override
     public void run() {
-        pullRequestBadPracticeDetector.detectAndSyncBadPractices(pullRequest);
+        List<PullRequestBadPractice> badPractices = pullRequestBadPracticeDetector.detectAndSyncBadPractices(
+            pullRequest
+        );
+        logger.info("Bad practices detected in pull request: {}", pullRequest.getId());
+        logger.info("Bad practices: {}", badPractices);
+
+        if (!badPractices.isEmpty()) {
+            for (User user : pullRequest.getAssignees()) {
+                mailService.sendBadPracticesDetectedInPullRequestEmail(user, pullRequest, badPractices);
+            }
+        }
     }
 }

server/application-server/src/main/java/de/tum/in/www1/hephaestus/activity/badpracticedetector/PullRequestBadPracticeDetector.java

@@ -9,6 +9,8 @@
 import de.tum.in.www1.hephaestus.intelligenceservice.model.DetectorResponse;
 import java.util.LinkedList;
 import java.util.List;
+
+import jakarta.transaction.Transactional;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -25,11 +27,13 @@ public class PullRequestBadPracticeDetector {
     @Autowired
     private BadPracticeDetectorService detectorApi;
 
+
     /**
      * Detects bad practices in the given pull request and syncs them with the database.
      * @param pullRequest The pull request to detect bad practices in.
      * @return The detected bad practices.
      */
+    @Transactional
     public List<PullRequestBadPractice> detectAndSyncBadPractices(PullRequest pullRequest) {
         logger.info("Detecting bad practices for pull request: {}", pullRequest.getId());
 

server/application-server/src/main/java/de/tum/in/www1/hephaestus/gitprovider/user/User.java

@@ -99,6 +99,9 @@ public class User extends BaseGitServiceEntity {
     @ToString.Exclude
     private Set<PullRequestReviewComment> reviewComments = new HashSet<>();
 
+    @NonNull
+    private boolean notificationsEnabled = false;
+
     // Current ranking points for the leaderboard leagues
     private int leaguePoints;