Added public kudos API

Author: mkimberlin

server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosController.java

@@ -1,6 +1,7 @@
 package com.objectcomputing.checkins.services.kudos;
 
 import io.micronaut.core.annotation.Nullable;
+import io.micronaut.core.convert.format.Format;
 import io.micronaut.http.HttpStatus;
 import io.micronaut.http.annotation.Body;
 import io.micronaut.http.annotation.Controller;
@@ -17,6 +18,7 @@
 import jakarta.validation.Valid;
 import jakarta.validation.constraints.NotNull;
 
+import java.time.LocalDate;
 import java.util.List;
 import java.util.UUID;
 
@@ -53,6 +55,9 @@ public List<KudosResponseDTO> getRecent() {
         return kudosServices.getRecent();
     }
 
+    @Get("/public")
+    public List<KudosResponseDTO> getPublic(@Nullable @Format("yyyy-MM-dd") LocalDate since) { return kudosServices.getPublic(since); }
+
     @Get("/{id}")
     public KudosResponseDTO getById(@NotNull UUID id) {
         return kudosServices.getById(id);

server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosRepository.java

@@ -6,6 +6,8 @@
 import io.micronaut.data.model.query.builder.sql.Dialect;
 import io.micronaut.data.repository.CrudRepository;
 
+import java.time.LocalDate;
+import java.util.Arrays;
 import java.util.List;
 import java.util.UUID;
 
@@ -54,4 +56,14 @@ public interface KudosRepository extends CrudRepository<Kudos, UUID> {
                   AND (:includePending OR dateapproved IS NOT NULL)""", nativeQuery = true)
         List<Kudos> search(@Nullable String senderId, boolean includePending);
 
+        @Query(value = """
+                SELECT
+                    id,
+                    PGP_SYM_DECRYPT(cast(message as bytea), '${aes.key}') as message,
+                    senderid, teamid, datecreated, dateapproved, publiclyVisible
+                FROM kudos
+                WHERE publiclyVisible IS TRUE
+                  AND (CAST(:since as date) IS NULL OR dateapproved >= :since) 
+                ORDER BY datecreated DESC""", nativeQuery = true)
+        List<Kudos> getPublic(@Nullable LocalDate since);
 }

server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosServices.java

@@ -2,6 +2,7 @@
 
 import io.micronaut.core.annotation.Nullable;
 
+import java.time.LocalDate;
 import java.util.List;
 import java.util.UUID;
 
@@ -22,4 +23,6 @@ public interface KudosServices {
     void delete(UUID id);
 
     List<KudosResponseDTO> findByValues(@Nullable UUID recipientId, @Nullable UUID senderId, @Nullable Boolean isPending);
+
+    List<KudosResponseDTO> getPublic(@Nullable LocalDate since);
 }

server/src/main/java/com/objectcomputing/checkins/services/kudos/KudosServicesImpl.java

@@ -28,6 +28,7 @@
 import com.objectcomputing.checkins.configuration.CheckInsConfiguration;
 
 import io.micronaut.core.annotation.Nullable;
+import io.micronaut.core.convert.format.Format;
 import io.micronaut.transaction.annotation.Transactional;
 
 import jakarta.inject.Named;
@@ -296,6 +297,13 @@ public List<KudosResponseDTO> getRecent() {
                 .toList();
     }
 
+    public List<KudosResponseDTO> getPublic(@Nullable LocalDate since) {
+        return kudosRepository.getPublic(since)
+                .stream()
+                .map(this::constructKudosResponseDTO)
+                .toList();
+    }
+
     private List<KudosResponseDTO> findByPending(boolean isPending) {
         if (!hasAdministerKudosPermission()) {
             throw new PermissionException(NOT_AUTHORIZED_MSG);

server/src/test/java/com/objectcomputing/checkins/services/fixture/KudosFixture.java

@@ -40,6 +40,17 @@ default Kudos createApprovedKudos(UUID senderId) {
         return getKudosRepository().save(kudos);
     }
 
+    default Kudos createApprovedKudos(UUID senderId, LocalDate approved) {
+        Kudos kudos = new Kudos();
+        kudos.setMessage("Default Kudos");
+        kudos.setSenderId(senderId);
+        kudos.setPubliclyVisible(true);
+        kudos.setDateCreated(approved.minusDays(1));
+        kudos.setDateApproved(approved);
+
+        return getKudosRepository().save(kudos);
+    }
+
     default KudosRecipient createKudosRecipient(UUID kudosId, UUID memberId) {
         KudosRecipient kudosRecipient = new KudosRecipient(kudosId, memberId);
 

server/src/test/java/com/objectcomputing/checkins/services/kudos/KudosControllerTest.java

@@ -26,6 +26,7 @@
 import io.micronaut.http.client.exceptions.HttpClientResponseException;
 import jakarta.inject.Inject;
 import jakarta.inject.Named;
+import jnr.constants.platform.Local;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
@@ -678,4 +679,53 @@ void testUpdateKudosNoMembers() {
 
         assertEquals(HttpStatus.BAD_REQUEST, responseException.getStatus());
     }
+
+    @Test
+    void testGetAllPublicKudos() {
+        UUID recipientId = recipientMembers.getFirst().getId();
+        MemberProfile bob = memberWithoutBoss("bob");
+        UUID someOtherRecipientId = bob.getId();
+
+        Kudos kudos = createApprovedKudos(senderId);
+        Kudos kudos2 = createApprovedKudos(senderId);
+        Kudos kudos3 = createApprovedKudos(senderId);
+        createKudosRecipient(kudos.getId(), recipientId);
+        createKudosRecipient(kudos2.getId(), recipientId);
+        createKudosRecipient(kudos3.getId(), someOtherRecipientId);
+
+        MutableHttpRequest<Object> request = HttpRequest.GET("/public").basicAuth(bob.getWorkEmail(), MEMBER_ROLE);
+        final HttpResponse<List<KudosResponseDTO>> response = client.exchange(request, Argument.listOf(KudosResponseDTO.class));
+
+        assertEquals(OK, response.getStatus());
+        List<KudosResponseDTO> body = response.body();
+        assertEquals(3, body.size());
+        assertEquals(List.of(kudos.getId(), kudos2.getId(), kudos3.getId()), List.of(body.get(0).getId(), body.get(1).getId(), body.get(2).getId()));
+    }
+
+    @Test
+    void testGetPublicKudosSince() {
+        UUID recipientId = recipientMembers.getFirst().getId();
+        MemberProfile bob = memberWithoutBoss("bob");
+        UUID someOtherRecipientId = bob.getId();
+
+        LocalDate now = LocalDate.now();
+        LocalDate since = now.minusMonths(3);
+        LocalDate before = since.minusDays(1);
+        LocalDate inRange = since.plusDays(Math.round(Math.ceil(Math.random()*30))); // up to 30 days
+
+        Kudos kudos = createApprovedKudos(senderId, since);
+        Kudos kudos2 = createApprovedKudos(senderId, before);
+        Kudos kudos3 = createApprovedKudos(senderId, inRange);
+        createKudosRecipient(kudos.getId(), recipientId);
+        createKudosRecipient(kudos2.getId(), recipientId);
+        createKudosRecipient(kudos3.getId(), someOtherRecipientId);
+
+        MutableHttpRequest<Object> request = HttpRequest.GET(String.format("/public?since=%s", since)).basicAuth(bob.getWorkEmail(), MEMBER_ROLE);
+        final HttpResponse<List<KudosResponseDTO>> response = client.exchange(request, Argument.listOf(KudosResponseDTO.class));
+
+        assertEquals(OK, response.getStatus());
+        List<KudosResponseDTO> body = response.body();
+        assertEquals(2, body.size());
+        assertEquals(List.of(kudos.getId(), kudos3.getId()), List.of(body.get(0).getId(), body.get(1).getId()));
+    }
 }