feat: load and sync nvd database using API

src/main/java/com/redhat/ecosystemappeng/onguard/model/Bulk.java

@@ -0,0 +1,74 @@
+/*
+ * Copyright 2024 Red Hat, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.redhat.ecosystemappeng.onguard.model;
+
+import java.time.LocalDateTime;
+
+import io.quarkus.runtime.annotations.RegisterForReflection;
+
+@RegisterForReflection
+public record Bulk(LocalDateTime started, LocalDateTime completed, Integer index, Integer pageSize) {
+
+    public static class Builder {
+        LocalDateTime started;
+        LocalDateTime completed;
+        Integer index;
+        Integer pageSize;
+
+        private Builder() {}
+
+        private Builder(Bulk other) {
+            this.started = other.started;
+            this.completed = other.completed;
+            this.index = other.index;
+            this.pageSize = other.pageSize;
+        }
+
+        public Builder started(LocalDateTime started) {
+            this.started = started;
+            return this;
+        }
+        public Builder completed(LocalDateTime completed) {
+            this.completed = completed;
+            return this;
+        }
+        public Builder index(Integer index) {
+            this.index = index;
+            return this;
+        }
+        public Builder pageSize(Integer pageSize) {
+            this.pageSize = pageSize;
+            return this;
+        }
+
+        public Bulk build() {
+            if(index == null) {
+                index = 0;
+            }
+            return new Bulk(started, completed, index, pageSize);
+        }
+    }
+
+    public static Bulk.Builder builder(Bulk other) {
+        return new Builder(other);
+    }
+
+    public static Bulk.Builder builder() {
+        return new Builder();
+    }
+}

src/main/java/com/redhat/ecosystemappeng/onguard/model/Vulnerability.java

@@ -17,12 +17,13 @@
  */
 package com.redhat.ecosystemappeng.onguard.model;
 
+import static com.redhat.ecosystemappeng.onguard.model.osv.OsvVulnerability.CVE_PATTERN;
+
 import java.util.Date;
 import java.util.List;
 
 import com.redhat.ecosystemappeng.onguard.model.nvd.Metrics;
 import com.redhat.ecosystemappeng.onguard.model.osv.Affected;
-import com.redhat.ecosystemappeng.onguard.service.cve.CveFileService;
 
 public record Vulnerability(
         List<String> aliases,
@@ -112,7 +113,7 @@ public List<String> getAliases() {
 
         public Vulnerability build() {
             if(cveId == null && aliases != null) {
-                var alias = aliases.stream().filter(a -> CveFileService.CVE_PATTERN.matcher(a).matches()).findAny();
+                var alias = aliases.stream().filter(a -> CVE_PATTERN.matcher(a).matches()).findAny();
                 if(alias.isPresent()) {
                     cveId = alias.get();
                 }

src/main/java/com/redhat/ecosystemappeng/onguard/model/osv/OsvVulnerability.java

@@ -17,16 +17,17 @@
  */
 package com.redhat.ecosystemappeng.onguard.model.osv;
 
-import static com.redhat.ecosystemappeng.onguard.service.cve.CveFileService.CVE_PATTERN;
-
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.Date;
 import java.util.List;
+import java.util.regex.Pattern;
 
 public record OsvVulnerability(String id, String summary, String details, List<String> aliases, Date published,
     Date modified, List<Affected> affected) {
 
+  public static final Pattern CVE_PATTERN = Pattern.compile("CVE-\\d{4}-\\d{4,7}", Pattern.CASE_INSENSITIVE);
+
   public OsvVulnerability {
     if (!CVE_PATTERN.matcher(id).matches() && aliases != null && !aliases.isEmpty()) {
       List<String> newAliases = new ArrayList<>();

src/main/java/com/redhat/ecosystemappeng/onguard/rest/LoadRoute.java

@@ -0,0 +1,117 @@
+/*
+ * Copyright 2024 Red Hat, Inc. and/or its affiliates
+ * and other contributors as indicated by the @author tags.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *       http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package com.redhat.ecosystemappeng.onguard.rest;
+
+import java.text.ParseException;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.redhat.ecosystemappeng.onguard.service.LoadService;
+
+import io.quarkus.vertx.http.ManagementInterface;
+import io.smallrye.mutiny.Uni;
+import io.smallrye.mutiny.infrastructure.Infrastructure;
+import jakarta.enterprise.context.ApplicationScoped;
+import jakarta.enterprise.event.Observes;
+import jakarta.inject.Inject;
+
+@ApplicationScoped
+public class LoadRoute {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(LoadRoute.class);
+
+    @Inject
+    LoadService loadService;
+
+    @Inject
+    ObjectMapper mapper;
+
+    public void registerManagementRoutes(@Observes ManagementInterface mi) {
+        mi.router().post("/load").handler(ctx -> {
+            final LocalDateTime since;
+            try {
+                since = parseDateParam(ctx.request().getParam("since"));
+            } catch (ParseException e) {
+                ctx.response().setStatusCode(400).setStatusMessage(e.getMessage()).end();
+                return;
+            }
+            Boolean reload = Boolean.TRUE.toString().equalsIgnoreCase(ctx.request().getParam("reload"));
+            Uni.createFrom()
+                    .voidItem()
+                    .invoke(() -> {
+                        if(reload) {
+                            loadService.restart();
+                        } else {
+                            loadService.loadFromNvdApi(since);
+                        }
+
+                    })
+                    .runSubscriptionOn(Infrastructure.getDefaultExecutor())
+                    .subscribeAsCompletionStage()
+                    .whenComplete((s, e) -> {
+                        if (e != null) {
+                            LOGGER.error("Load interrupted", e);
+                        } else {
+                            LOGGER.info("Completed");
+                        }
+                    });
+            ctx.response().setStatusCode(202).end();
+        });
+
+        mi.router().get("/load").blockingHandler(ctx -> {
+            try {
+                var bulk = loadService.get();
+                if (bulk == null) {
+                    ctx.response().setStatusCode(404).end();
+                } else {
+                    ctx.response().headers().add("Content-Type", "application/json");
+                    ctx.response().setStatusCode(200).end(mapper.writeValueAsString(bulk));
+                }
+            } catch (JsonProcessingException e) {
+                ctx.response().setStatusCode(500).setStatusMessage(e.getMessage()).end();
+            }
+        });
+
+        mi.router().delete("/load").blockingHandler(ctx -> {
+            try {
+                var bulk = loadService.cancel();
+                if (bulk == null) {
+                    ctx.response().setStatusCode(404).end();
+                } else {
+                    ctx.response().headers().add("Content-Type", "application/json");
+                    ctx.response().setStatusCode(200).end(mapper.writeValueAsString(bulk));
+                }
+            } catch (JsonProcessingException e) {
+                ctx.response().setStatusCode(500).setStatusMessage(e.getMessage()).end();
+            }
+        });
+    }
+
+    private LocalDateTime parseDateParam(String param) throws ParseException {
+        if(param != null) {
+           return LocalDateTime.parse(param, DateTimeFormatter.ISO_DATE);
+        }
+        return null;
+    }
+
+}

src/main/java/com/redhat/ecosystemappeng/onguard/serialization/ObjectMapperCustomizerImpl.java

@@ -29,5 +29,6 @@ public class ObjectMapperCustomizerImpl implements ObjectMapperCustomizer {
     @Override
     public void customize(ObjectMapper mapper) {
         mapper.setSerializationInclusion(Include.NON_NULL);
+
     }
 }