[feature] get schema endpoint and list all schema

Author: marmoure

pom.xml

@@ -90,6 +90,13 @@
             <version>2.0</version>
             <scope>runtime</scope>
         </dependency>
+
+        <!-- Jackson Databind for JSON parsing -->
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>2.15.3</version>
+        </dependency>
     </dependencies>
 
     <build>

src/main/java/com/evolvedbinary/bblValidator/controller/SchemaController.java

@@ -0,0 +1,26 @@
+package com.evolvedbinary.bblValidator.controller;
+
+import com.evolvedbinary.bblValidator.dto.SchemaInfo;
+import com.evolvedbinary.bblValidator.service.SchemaService;
+import io.micronaut.http.MediaType;
+import io.micronaut.http.annotation.Controller;
+import io.micronaut.http.annotation.Get;
+import io.micronaut.http.annotation.Produces;
+
+import java.util.List;
+
+@Controller("/schema")
+public class SchemaController {
+
+    private final SchemaService schemaService;
+
+    public SchemaController(SchemaService schemaService) {
+        this.schemaService = schemaService;
+    }
+
+    @Get
+    @Produces(MediaType.APPLICATION_JSON)
+    public List<SchemaInfo> listSchemas() {
+        return schemaService.listSchemas();
+    }
+}

src/main/java/com/evolvedbinary/bblValidator/dto/SchemaInfo.java

@@ -0,0 +1,75 @@
+package com.evolvedbinary.bblValidator.dto;
+
+import io.micronaut.serde.annotation.Serdeable;
+
+@Serdeable
+public class SchemaInfo {
+
+    private String id;
+    private String name;
+    private String version;
+    private String date;
+    private String url;
+    private String description;
+
+    public SchemaInfo() {
+    }
+
+    public SchemaInfo(String id, String name, String version, String date, String url, String description) {
+        this.id = id;
+        this.name = name;
+        this.version = version;
+        this.date = date;
+        this.url = url;
+        this.description = description;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getVersion() {
+        return version;
+    }
+
+    public void setVersion(String version) {
+        this.version = version;
+    }
+
+    public String getDate() {
+        return date;
+    }
+
+    public void setDate(String date) {
+        this.date = date;
+    }
+
+    public String getUrl() {
+        return url;
+    }
+
+    public void setUrl(String url) {
+        this.url = url;
+    }
+
+    public String getDescription() {
+        return description;
+    }
+
+    public void setDescription(String description) {
+        this.description = description;
+    }
+}
+

src/main/java/com/evolvedbinary/bblValidator/service/SchemaService.java

@@ -0,0 +1,95 @@
+package com.evolvedbinary.bblValidator.service;
+
+import com.evolvedbinary.bblValidator.dto.SchemaInfo;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import jakarta.annotation.PostConstruct;
+import jakarta.inject.Singleton;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.charset.StandardCharsets;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Stream;
+
+@Singleton
+public class SchemaService {
+
+    private static final Logger LOG = LoggerFactory.getLogger(SchemaService.class);
+    private static final String SCHEMA_DIRECTORY = "schemas";
+
+    private final List<SchemaInfo> schemas = new ArrayList<>();
+    private final ObjectMapper objectMapper = new ObjectMapper();
+
+    @PostConstruct
+    public void loadSchemas() {
+        try {
+            // Load schemas from classpath
+            ClassLoader classLoader = getClass().getClassLoader();
+
+            // Get all .json files from the schemas directory
+            try (InputStream is = classLoader.getResourceAsStream(SCHEMA_DIRECTORY)) {
+                if (is == null) {
+                    LOG.warn("Schemas directory not found in classpath");
+                    return;
+                }
+            }
+
+            // Scan for schema metadata files
+            loadSchemasFromClasspath();
+
+            LOG.info("Loaded {} schemas from disk", schemas.size());
+        } catch (Exception e) {
+            LOG.error("Error loading schemas from disk", e);
+        }
+    }
+
+    private void loadSchemasFromClasspath() {
+        try {
+            // Get resource URL and list files
+            ClassLoader classLoader = getClass().getClassLoader();
+            var resource = classLoader.getResource(SCHEMA_DIRECTORY);
+
+            if (resource != null) {
+                Path schemaPath = Paths.get(resource.toURI());
+
+                try (Stream<Path> paths = Files.walk(schemaPath, 1)) {
+                    paths.filter(path -> path.toString().endsWith(".json"))
+                            .forEach(this::loadSchemaMetadata);
+                }
+            }
+        } catch (Exception e) {
+            LOG.error("Error scanning schema directory", e);
+        }
+    }
+
+    private void loadSchemaMetadata(Path metadataPath) {
+        try {
+            String content = Files.readString(metadataPath, StandardCharsets.UTF_8);
+            SchemaInfo schemaInfo = objectMapper.readValue(content, SchemaInfo.class);
+
+            // Load corresponding schema file
+            String schemaFileName = metadataPath.getFileName().toString().replace(".json", ".csvs");
+            Path schemaFilePath = metadataPath.getParent().resolve(schemaFileName);
+
+            if (Files.exists(schemaFilePath)) {
+                schemas.add(schemaInfo);
+                LOG.debug("Loaded schema: {}", schemaInfo.getId());
+            } else {
+                LOG.warn("Schema file not found for metadata: {}", schemaFileName);
+            }
+        } catch (IOException e) {
+            LOG.error("Error loading schema metadata from: {}", metadataPath, e);
+        }
+    }
+
+    public List<SchemaInfo> listSchemas() {
+        return new ArrayList<>(schemas);
+    }
+}
+