Merge pull request #3 from marmoure/feature/schema-content

Get schema content

Author: marmoure

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

@@ -6,6 +6,7 @@
 import io.micronaut.http.annotation.Controller;
 import io.micronaut.http.annotation.Get;
 import io.micronaut.http.annotation.Produces;
+import io.micronaut.http.annotation.PathVariable;
 
 import java.util.List;
 
@@ -23,4 +24,10 @@ public SchemaController(SchemaService schemaService) {
     public List<SchemaInfo> listSchemas() {
         return schemaService.listSchemas();
     }
+
+    @Get("/{schema-id}")
+    @Produces("text/csv-schema")
+    public String getSchema(@PathVariable("schema-id") String schemaId) throws Exception {
+        return schemaService.getSchema(schemaId);
+    }
 }

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

@@ -14,7 +14,9 @@
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Stream;
 
 @Singleton
@@ -24,6 +26,7 @@ public class SchemaService {
     private static final String SCHEMA_DIRECTORY = "schemas";
 
     private final List<SchemaInfo> schemas = new ArrayList<>();
+    private final Map<String, String> schemaContents = new HashMap<>();
     private final ObjectMapper objectMapper = new ObjectMapper();
 
     @PostConstruct
@@ -78,6 +81,8 @@ private void loadSchemaMetadata(Path metadataPath) {
             Path schemaFilePath = metadataPath.getParent().resolve(schemaFileName);
 
             if (Files.exists(schemaFilePath)) {
+                String schemaContent = Files.readString(schemaFilePath, StandardCharsets.UTF_8);
+                schemaContents.put(schemaInfo.getId(), schemaContent);
                 schemas.add(schemaInfo);
                 LOG.debug("Loaded schema: {}", schemaInfo.getId());
             } else {
@@ -91,5 +96,15 @@ private void loadSchemaMetadata(Path metadataPath) {
     public List<SchemaInfo> listSchemas() {
         return new ArrayList<>(schemas);
     }
+
+    public String getSchema(String schemaId) throws Exception {
+        String content = schemaContents.get(schemaId);
+
+        if (content == null) {
+            throw new Exception("Schema not found: " + schemaId);
+        }
+
+        return content;
+    }
 }