From 382cc47747023a18eee265fc84bb488b037b2681 Mon Sep 17 00:00:00 2001
From: Ming Wang <miwan@redhat.com>
Date: Wed, 25 Oct 2023 16:03:56 -0400
Subject: [PATCH] tmp

---
 .../java/io/cryostat/ConfigProperties.java    |  1 +
 .../io/cryostat/events/EventTemplates.java    | 53 +++++++++++--------
 .../java/io/cryostat/CustomEventTemplate.java | 24 +++++++--
 3 files changed, 54 insertions(+), 24 deletions(-)

diff --git a/src/main/java/io/cryostat/ConfigProperties.java b/src/main/java/io/cryostat/ConfigProperties.java
index 952461e1f..19b19c648 100644
--- a/src/main/java/io/cryostat/ConfigProperties.java
+++ b/src/main/java/io/cryostat/ConfigProperties.java
@@ -17,6 +17,7 @@
 
 public class ConfigProperties {
     public static final String AWS_BUCKET_NAME_ARCHIVES = "storage.buckets.archives.name";
+    public static final String AWS_EVENT_TEMPLATE_NAME = "storage.buckets.event-templates.name";
     public static final String AWS_OBJECT_EXPIRATION_LABELS =
             "storage.buckets.archives.expiration-label";
 
diff --git a/src/main/java/io/cryostat/events/EventTemplates.java b/src/main/java/io/cryostat/events/EventTemplates.java
index ab3280c2d..e9cbec391 100644
--- a/src/main/java/io/cryostat/events/EventTemplates.java
+++ b/src/main/java/io/cryostat/events/EventTemplates.java
@@ -22,7 +22,11 @@
 import java.util.List;
 import java.util.Objects;
 import java.util.concurrent.CompletableFuture;
+import java.util.Optional;
 
+import org.jsoup.nodes.Document;
+import org.openjdk.jmc.common.unit.IConstrainedMap;
+import org.openjdk.jmc.flightrecorder.configuration.events.EventOptionID;
 import org.openjdk.jmc.flightrecorder.controlpanel.ui.configuration.model.xml.JFCGrammar;
 import org.openjdk.jmc.flightrecorder.controlpanel.ui.configuration.model.xml.XMLAttributeInstance;
 import org.openjdk.jmc.flightrecorder.controlpanel.ui.configuration.model.xml.XMLModel;
@@ -32,7 +36,10 @@
 
 import io.cryostat.core.templates.MutableTemplateService.InvalidEventTemplateException;
 import io.cryostat.core.templates.MutableTemplateService.InvalidXmlException;
+import io.cryostat.ConfigProperties;
+import io.cryostat.core.FlightRecorderException;
 import io.cryostat.core.templates.Template;
+import io.cryostat.core.templates.TemplateService;
 import io.cryostat.core.templates.TemplateType;
 import io.cryostat.targets.Target;
 import io.cryostat.targets.TargetConnectionManager;
@@ -56,6 +63,9 @@
 import software.amazon.awssdk.services.s3.S3Client;
 import software.amazon.awssdk.services.s3.model.CreateBucketRequest;
 import software.amazon.awssdk.services.s3.model.HeadBucketRequest;
+import software.amazon.awssdk.services.s3.model.GetObjectRequest;
+import software.amazon.awssdk.services.s3.model.GetObjectTaggingRequest;
+import software.amazon.awssdk.services.s3.model.ListObjectsV2Request;
 
 import org.jboss.resteasy.reactive.RestPath;
 import org.jboss.resteasy.reactive.RestResponse;
@@ -80,8 +90,8 @@ public class EventTemplates {
     @Inject S3Client storage;
     @Inject Logger logger;
 
-    @ConfigProperty(name = "storage.buckets.event-templates.name")
-    String eventTemplatesBucket;
+    @ConfigProperty(name = ConfigProperties.AWS_BUCKET_NAME_ARCHIVES)
+    static String eventTemplatesBucket;
 
     void onStart(@Observes StartupEvent evt) {
         boolean exists = false;
@@ -193,28 +203,29 @@ public String getTargetTemplate(
                                 .toString());
     }
 
-    // static class S3TemplateService implements TemplateService {
-    //     S3Client s3;
+    static class S3TemplateService implements TemplateService {
+        S3Client s3;
 
-    //     @Override
-    //     public Optional<IConstrainedMap<EventOptionID>> getEvents(String arg0, TemplateType arg1)
-    //             throws FlightRecorderException {
-    //         return Optional.empty();
-    //     }
+        @Override
+        public Optional<IConstrainedMap<EventOptionID>> getEvents(String templateName, TemplateType templateType)
+                throws FlightRecorderException {
+            return Optional.empty();
+        }
 
-    //     @Override
-    //     public List<Template> getTemplates() throws FlightRecorderException {
-    //         var objects = s3.listObjectsV2();
-    //         var templates = convertObjects(objects);
-    //         return templates;
-    //     }
+        @Override
+        public List<Template> getTemplates() throws FlightRecorderException {
+            var builder = ListObjectsV2Request.builder().bucket(eventTemplatesBucket);
+            var objects = s3.listObjectsV2(builder.build());
+            var templates = convertObjects(objects);
+            return templates;
+        }
 
-    //     @Override
-    //     public Optional<Document> getXml(String arg0, TemplateType arg1)
-    //             throws FlightRecorderException {
-    //         return Optional.empty();
-    //     }
-    // }
+        @Override
+        public Optional<Document> getXml(String templateName, TemplateType templateType)
+                throws FlightRecorderException {
+            return Optional.empty();
+        }
+    }
 
     @Blocking
     public Template addTemplate(String templateText)
diff --git a/src/test/java/io/cryostat/CustomEventTemplate.java b/src/test/java/io/cryostat/CustomEventTemplate.java
index a24fa3127..2aac7f208 100644
--- a/src/test/java/io/cryostat/CustomEventTemplate.java
+++ b/src/test/java/io/cryostat/CustomEventTemplate.java
@@ -2,25 +2,43 @@
 
 import static io.cryostat.TestUtils.givenBasicAuth;
 
+import javax.swing.text.AbstractDocument.Content;
+
+import org.apache.http.entity.ContentType;
 import org.eclipse.microprofile.openapi.models.media.XML;
 import org.junit.Test;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 
+import io.cryostat.core.templates.Template;
+import io.cryostat.core.templates.TemplateType;
+import io.vertx.core.json.JsonObject;
+import jakarta.transaction.Transactional;
+
 public class CustomEventTemplate {
 
+    Template template;
+    
+    static String TEMPLATE_NAME = "customEventTemplate";
+
     @BeforeEach
     public void setup() {
-
+        template = new Template(TEMPLATE_NAME, "desc", "prov", TemplateType.CUSTOM);
     }
 
     @AfterEach
+    @Transactional
     public void afterEach() {
-
+        template.deleteAll();
     }
 
     @Test
     public void testCustomEventTemplate() {
-        givenBasicAuth().get().contentType(XML).then().post().statusCode(200);
+        givenBasicAuth().get().then().statusCode(200);
+    }
+
+    @Test
+    public void testCustom() {
+        givenBasicAuth().body().contentType(ContentType.APPLICATION_XML).post().then().statusCode(200);
     }
 }