[RHCLOUD-37354] add bulk resources for Notifications GW (RedHatInsights#3242)

* [RHCLOUD-37354] add bulk resources for Notifications GW

* Sonar fixes

Author: g-duval

backend/src/main/java/com/redhat/cloud/notifications/db/repositories/ApplicationRepository.java

@@ -17,8 +17,11 @@
 import jakarta.validation.constraints.NotNull;
 import jakarta.ws.rs.NotFoundException;
 
+import java.util.ArrayList;
 import java.util.Collection;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.Set;
 import java.util.UUID;
 import java.util.function.Supplier;
@@ -187,7 +190,16 @@ public EventType getEventType(String bundleName, String applicationName, String
         } catch (NoResultException noResultException) {
             return null;
         }
+    }
+
+    public Map<String, Map<String, List<String>>> getBaetList() {
+        final String query = "SELECT application.bundle.name, application.name, name FROM EventType";
+        final List<String[]> flatBaet = entityManager.createQuery(query, String[].class)
+            .getResultList();
 
+        final Map<String, Map<String, List<String>>> mapBaet = new HashMap<>();
+        flatBaet.stream().forEach(baet -> mapBaet.computeIfAbsent(baet[0], k -> new HashMap<>()).computeIfAbsent(baet[1], k -> new ArrayList<>()).add(baet[2]));
+        return mapBaet;
     }
 
     public List<EventType> getEventTypes(UUID appId) {

backend/src/main/java/com/redhat/cloud/notifications/db/repositories/X509CertificateRepository.java

@@ -7,6 +7,7 @@
 import jakarta.persistence.EntityManager;
 import jakarta.persistence.NoResultException;
 import jakarta.transaction.Transactional;
+import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
 
@@ -44,6 +45,13 @@ public Optional<X509Certificate> findCertificate(String bundle, String applicati
         }
     }
 
+    public List<X509Certificate> findCertificates() {
+        final String query = "FROM X509Certificate";
+        return this.entityManager
+            .createQuery(query, X509Certificate.class)
+            .getResultList();
+    }
+
     @Transactional
     public boolean updateCertificate(UUID id, X509Certificate gatewayCertificate) {
         String hql = "UPDATE X509Certificate SET subjectDn = :subjectDn, sourceEnvironment = :sourceEnvironment WHERE id = :id";

backend/src/main/java/com/redhat/cloud/notifications/routers/internal/ValidationResource.java

@@ -23,6 +23,8 @@
 import org.eclipse.microprofile.openapi.annotations.responses.APIResponse;
 import org.eclipse.microprofile.openapi.annotations.responses.APIResponses;
 import org.jboss.resteasy.reactive.RestQuery;
+import java.util.List;
+import java.util.Map;
 import java.util.Optional;
 
 import static com.redhat.cloud.notifications.Constants.API_INTERNAL;
@@ -61,6 +63,13 @@ public Response validate(@RestQuery String bundle, @RestQuery String application
         }
     }
 
+    @GET
+    @Path("/baet_list")
+    @Produces(APPLICATION_JSON)
+    public Map<String, Map<String, List<String>>> listBaet() {
+        return applicationRepository.getBaetList();
+    }
+
     @POST
     @Consumes(APPLICATION_JSON)
     @APIResponses({
@@ -137,4 +146,11 @@ public X509Certificate validateCertificateAccordingBundleAndApp(@RestQuery Strin
             return gatewayCertificate.get();
         }
     }
+
+    @GET
+    @Path("/certificates")
+    @Produces(APPLICATION_JSON)
+    public List<X509Certificate> getCertificates() {
+        return x509CertificateRepository.findCertificates();
+    }
 }

backend/src/test/java/com/redhat/cloud/notifications/routers/internal/ValidationResourceTest.java

@@ -0,0 +1,73 @@
+package com.redhat.cloud.notifications.routers.internal;
+
+import com.redhat.cloud.notifications.TestHelpers;
+import com.redhat.cloud.notifications.TestLifecycleManager;
+import com.redhat.cloud.notifications.db.DbIsolatedTest;
+import com.redhat.cloud.notifications.models.EventType;
+import io.quarkus.test.common.QuarkusTestResource;
+import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.common.mapper.TypeRef;
+import io.restassured.http.Header;
+import org.apache.commons.lang3.RandomStringUtils;
+import org.eclipse.microprofile.config.inject.ConfigProperty;
+import org.junit.jupiter.api.Test;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+import static com.redhat.cloud.notifications.CrudTestHelpers.createApp;
+import static com.redhat.cloud.notifications.CrudTestHelpers.createBundle;
+import static com.redhat.cloud.notifications.CrudTestHelpers.createEventType;
+import static io.restassured.RestAssured.given;
+import static io.restassured.http.ContentType.JSON;
+import static jakarta.ws.rs.core.Response.Status.OK;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertTrue;
+
+
+@QuarkusTest
+@QuarkusTestResource(TestLifecycleManager.class)
+class ValidationResourceTest extends DbIsolatedTest {
+
+
+    @ConfigProperty(name = "internal.admin-role")
+    String adminRole;
+
+    @Test
+    void testGetBaetList() {
+        Header adminIdentity = TestHelpers.createTurnpikeIdentityHeader("user", adminRole);
+
+        final String bundleName = "bundle-name-baet1";
+        final String applicationName = "application-name-baet1";
+        String bundleId = createBundle(adminIdentity, bundleName, RandomStringUtils.secure().nextAlphanumeric(10), OK.getStatusCode()).get();
+        String applicationId = createApp(adminIdentity, bundleId, applicationName, RandomStringUtils.secure().nextAlphanumeric(10), null, OK.getStatusCode()).get();
+        EventType eventType = new EventType();
+        eventType.setDescription(RandomStringUtils.secure().nextAlphanumeric(10));
+        eventType.setName("event1");
+        eventType.setDisplayName("Event 1");
+        eventType.setApplicationId(UUID.fromString(applicationId));
+        createEventType(adminIdentity, eventType, OK.getStatusCode());
+
+        eventType.setName("event2");
+        eventType.setDisplayName("Event 2");
+        createEventType(adminIdentity, eventType, OK.getStatusCode());
+
+        Map<String, Map<String, List<String>>> baetMap = given()
+            .header(adminIdentity)
+            .contentType(JSON)
+            .when()
+            .get("/internal/validation/baet_list")
+            .then()
+            .statusCode(OK.getStatusCode()).extract().as(new TypeRef<>() { });
+
+        assertEquals(2, baetMap.size());
+        assertEquals(1, baetMap.get("rhel").size());
+        assertEquals(1, baetMap.get("rhel").get("policies").size());
+        assertTrue(baetMap.get("rhel").get("policies").contains("policy-triggered"));
+
+        assertEquals(1, baetMap.get(bundleName).size());
+        assertEquals(2, baetMap.get(bundleName).get(applicationName).size());
+        assertTrue(baetMap.get(bundleName).get(applicationName).contains("event1"));
+        assertTrue(baetMap.get(bundleName).get(applicationName).contains("event2"));
+    }
+}

backend/src/test/java/com/redhat/cloud/notifications/routers/internal/X509CertificatesResourceTest.java

@@ -7,11 +7,13 @@
 import com.redhat.cloud.notifications.models.X509Certificate;
 import io.quarkus.test.common.QuarkusTestResource;
 import io.quarkus.test.junit.QuarkusTest;
+import io.restassured.common.mapper.TypeRef;
 import io.restassured.http.Header;
 import io.vertx.core.json.JsonObject;
 import jakarta.ws.rs.core.Response;
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 import org.junit.jupiter.api.Test;
+import java.util.List;
 import java.util.UUID;
 
 import static com.redhat.cloud.notifications.CrudTestHelpers.createApp;
@@ -44,6 +46,9 @@ void testCrudX509Certificate() {
 
         checkGatewayCertificate(intenralUserIdentity, bundleName, applicationName, "certificate data", FORBIDDEN);
 
+        List<X509Certificate> certificates = getCertificates(adminIdentity);
+        assertEquals(0, certificates.size());
+
         X509Certificate x509Certificate = new X509Certificate();
         x509Certificate.setSubjectDn("certificate data");
         x509Certificate.setBundle(bundleName);
@@ -62,6 +67,9 @@ void testCrudX509Certificate() {
         String certificateId = createdCertificateId.getString("id");
         assertNotNull(certificateId);
 
+        certificates = getCertificates(adminIdentity);
+        assertEquals(1, certificates.size());
+
         x509Certificate = checkGatewayCertificate(intenralUserIdentity, bundleName, applicationName, "certificate data", OK);
         assertEquals("stage", x509Certificate.getSourceEnvironment());
 
@@ -95,6 +103,18 @@ void testCrudX509Certificate() {
             .statusCode(OK.getStatusCode());
 
         checkGatewayCertificate(intenralUserIdentity, bundleName, applicationName, "certificate data updated", FORBIDDEN);
+
+        given()
+            .header(adminIdentity)
+            .contentType(JSON)
+            .pathParam("certificateId", x509Certificate.getId())
+            .when()
+            .delete("/internal/x509Certificates/{certificateId}")
+            .then()
+            .statusCode(OK.getStatusCode());
+
+        certificates = getCertificates(adminIdentity);
+        assertEquals(0, certificates.size());
     }
 
     @Test
@@ -146,9 +166,21 @@ private static X509Certificate checkGatewayCertificate(Header adminIdentity, Str
 
         if (Response.Status.OK == status) {
             JsonObject jsonApp = new JsonObject(responseBody);
-            return jsonApp.mapTo(X509Certificate.class);
+            X509Certificate certificate = jsonApp.mapTo(X509Certificate.class);
+            certificate.setId(UUID.fromString(jsonApp.getString("id")));
+            return certificate;
         }
         return null;
     }
 
+    private static List<X509Certificate> getCertificates(Header adminIdentity) {
+        return given()
+            .header(adminIdentity)
+            .contentType(JSON)
+            .when()
+            .get("/internal/validation/certificates")
+            .then()
+            .statusCode(OK.getStatusCode()).extract().as(new TypeRef<>() { });
+    }
+
 }