Merge pull request #2174 from objectcomputing/feature-2173/send-sheduled-emails

Send emails that are scheduled

Author: mkimberlin

server/src/main/java/com/objectcomputing/checkins/services/request_notifications/CheckServicesController.java

@@ -1,17 +1,24 @@
 package com.objectcomputing.checkins.services.request_notifications;
 
 
+import com.google.api.client.googleapis.auth.oauth2.GoogleIdToken;
+import com.google.api.client.googleapis.auth.oauth2.GoogleIdTokenVerifier;
+import com.google.api.client.http.javanet.NetHttpTransport;
+import com.google.api.client.json.gson.GsonFactory;
 import io.micronaut.http.HttpResponse;
 import io.micronaut.http.annotation.Controller;
 import io.micronaut.http.annotation.Get;
+import io.micronaut.http.annotation.Header;
 import io.micronaut.scheduling.TaskExecutors;
 import io.netty.channel.EventLoopGroup;
 import jakarta.annotation.security.PermitAll;
-
 import jakarta.inject.Named;
 import reactor.core.publisher.Mono;
 import reactor.core.scheduler.Schedulers;
 
+import java.io.IOException;
+import java.security.GeneralSecurityException;
+import java.util.Collections;
 import java.util.concurrent.ExecutorService;
 
 @Controller("/services/feedback/daily-request-check")
@@ -20,6 +27,10 @@ public class CheckServicesController {
     private final CheckServices checkServices;
     private final EventLoopGroup eventLoopGroup;
     private final ExecutorService ioExecutorService;
+    private final GoogleIdTokenVerifier verifier =
+            new GoogleIdTokenVerifier.Builder(new NetHttpTransport(), new GsonFactory())
+                    .setAudience(Collections.singletonList("https://checkins.objectcomputing.com/services/feedback/daily-request-check"))
+                    .build();
 
     public CheckServicesController(CheckServices checkServices, EventLoopGroup eventLoopGroup,
                               @Named(TaskExecutors.IO) ExecutorService ioExecutorService) {
@@ -29,7 +40,37 @@ public CheckServicesController(CheckServices checkServices, EventLoopGroup event
     }
 
     @Get
-    public Mono<? extends HttpResponse<?>> GetTodaysRequests() {
+    public Mono<? extends HttpResponse<?>> GetTodaysRequests(@Header("Authorization") String authorizationHeader) {
+        System.out.println("!!!!!!-"+authorizationHeader);
+        String authorization = authorizationHeader.split(" ")[1];
+        GoogleIdToken idToken = null;
+        try {
+            idToken = verifier.verify(authorization);
+            GoogleIdToken.Payload payload = idToken.getPayload();
+
+            // Print user identifier
+            String userId = payload.getSubject();
+            System.out.println("User ID: " + userId);
+
+            // Get profile information from payload
+            String email = payload.getEmail();
+            System.out.println("Email:"+ email);
+            String hostedDomain = payload.getHostedDomain();
+            System.out.println("Hosted Domain" + hostedDomain);
+            String prettyString = payload.toPrettyString();
+            System.out.println(prettyString);
+            boolean emailVerified = payload.getEmailVerified();
+            System.out.println("emailVerified:" + emailVerified);
+//            String name = (String) payload.get("name");
+//            String pictureUrl = (String) payload.get("picture");
+//            String locale = (String) payload.get("locale");
+//            String familyName = (String) payload.get("family_name");
+//            String givenName = (String) payload.get("given_name");
+        } catch (GeneralSecurityException | IOException e) {
+            throw new RuntimeException(e);
+        }
+
+        GoogleIdToken.Payload payload = idToken.getPayload();
         return Mono.fromCallable(checkServices::GetTodaysRequests)
                 .publishOn(Schedulers.fromExecutor(eventLoopGroup))
                 .map(success -> (HttpResponse<?>) HttpResponse.ok())

server/src/main/java/com/objectcomputing/checkins/services/request_notifications/CheckServicesImpl.java

@@ -1,11 +1,13 @@
 package com.objectcomputing.checkins.services.request_notifications;
 
 import com.objectcomputing.checkins.notifications.email.EmailSender;
+import com.objectcomputing.checkins.notifications.email.MailJetConfig;
 import com.objectcomputing.checkins.services.feedback_request.FeedbackRequest;
 import com.objectcomputing.checkins.services.feedback_request.FeedbackRequestRepository;
 import com.objectcomputing.checkins.services.memberprofile.MemberProfile;
 import com.objectcomputing.checkins.services.memberprofile.MemberProfileServices;
 import io.micronaut.context.annotation.Property;
+import jakarta.inject.Named;
 import jakarta.inject.Singleton;
 import java.time.LocalDate;
 import java.util.*;
@@ -21,7 +23,8 @@ public class CheckServicesImpl implements CheckServices {
     private String notificationContent;
     private final MemberProfileServices memberProfileServices;
 
-    public CheckServicesImpl(FeedbackRequestRepository feedbackReqRepository, EmailSender emailSender,
+    public CheckServicesImpl(FeedbackRequestRepository feedbackReqRepository,
+                             @Named(MailJetConfig.HTML_FORMAT) EmailSender emailSender,
                              @Property(name = FEEDBACK_REQUEST_NOTIFICATION_SUBJECT) String notificationSubject,
                              @Property(name = FEEDBACK_REQUEST_NOTIFICATION_CONTENT) String notificationContent,
                              MemberProfileServices memberProfileServices) {