Standing PR for 1.0.0 rc.2 (#16)

* 1048 - required fields must not be blank

* initial queryables implementation

* initial switch to rc.2

Author: joshfix

pom.xml

@@ -5,7 +5,7 @@
 
     <groupId>com.planet.staccato</groupId>
     <artifactId>staccato</artifactId>
-    <version>1.0.0-rc1</version>
+    <version>1.0.0-rc.2</version>
     <packaging>pom</packaging>
 
     <parent>

staccato-application/pom.xml

@@ -12,7 +12,7 @@
     <parent>
         <groupId>com.planet.staccato</groupId>
         <artifactId>staccato</artifactId>
-        <version>1.0.0-rc1</version>
+        <version>1.0.0-rc.2</version>
     </parent>
 
     <properties>

staccato-application/src/main/java/com/planet/staccato/catalog/RootCatalog.java

@@ -11,7 +11,7 @@ public class RootCatalog extends Catalog {
     protected Object conformsTo;
 
     public Catalog conformsTo(Object conformsTo) {
-        this.conformsTo = conformsTo;
+        setConformsTo(conformsTo);
         return this;
     }
 }

staccato-application/src/main/java/com/planet/staccato/catalog/RootCatalogConfig.java

@@ -15,6 +15,7 @@
 import org.springframework.web.reactive.function.server.RouterFunction;
 import org.springframework.web.reactive.function.server.ServerResponse;
 
+import static com.planet.staccato.config.StaccatoRelType.QUERYABLES_LINK_REL;
 import static org.springframework.web.reactive.function.BodyInserters.fromValue;
 import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
 import static org.springframework.web.reactive.function.server.RouterFunctions.route;
@@ -46,6 +47,7 @@ public class RootCatalogConfig {
     public static final String CONFORMANCE_LINK_HREF = "/conformance";
     public static final String DATA_LINK_REL = "data";
     public static final String DATA_LINK_HREF = "/collections";
+    public static final String QUERYABLES_LINK_HREF = "/queryables";
 
     /**
      * Creates the root catalog object.
@@ -88,6 +90,11 @@ public Catalog rootCatalog() {
                 .type(MediaType.APPLICATION_JSON_VALUE)
                 .href(LinksConfigProps.LINK_PREFIX + DATA_LINK_HREF));
 
+        catalog.getLinks().add(Link.build()
+                .rel(QUERYABLES_LINK_REL)
+                .type(StaccatoMediaType.APPLICATION_SCHEMA_JSON_VALUE)
+                .href(LinksConfigProps.LINK_PREFIX + QUERYABLES_LINK_HREF));
+
         return catalog;
     }
 

staccato-application/src/main/java/com/planet/staccato/collection/CollectionApi.java

@@ -5,6 +5,7 @@
 import com.planet.staccato.model.Collections;
 import com.planet.staccato.model.Item;
 import com.planet.staccato.model.ItemCollection;
+import com.planet.staccato.queryables.Queryables;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -26,6 +27,10 @@ public interface CollectionApi {
     @GetMapping(value = "/collections/{collectionId}", produces = MediaType.APPLICATION_JSON_VALUE)
     Mono<CollectionMetadata> getCollection(@PathVariable("collectionId") String collectionId);
 
+    @GetMapping(value = "/collections/{collectionId}/queryables",
+            produces = {StaccatoMediaType.APPLICATION_GEO_JSON_VALUE, MediaType.APPLICATION_JSON_VALUE})
+    Mono<Queryables> getQueryables(@PathVariable("collectionId") String collectionId);
+
     @GetMapping(value = "/collections/{collectionId}/items",
             produces = {StaccatoMediaType.APPLICATION_GEO_JSON_VALUE, MediaType.APPLICATION_JSON_VALUE})
     Mono<ItemCollection> getCollectionItems(@PathVariable("collectionId") String collectionId,

staccato-application/src/main/java/com/planet/staccato/collection/CollectionController.java

@@ -4,6 +4,7 @@
 import com.planet.staccato.model.Collections;
 import com.planet.staccato.model.Item;
 import com.planet.staccato.model.ItemCollection;
+import com.planet.staccato.queryables.Queryables;
 import com.planet.staccato.service.ApiService;
 import com.planet.staccato.service.CollectionService;
 import lombok.RequiredArgsConstructor;
@@ -37,6 +38,11 @@ public Mono<CollectionMetadata> getCollection(@PathVariable("collectionId") Stri
         return collectionService.getCollectionMetadata(collectionId);
     }
 
+    @Override
+    public Mono<Queryables> getQueryables(String collectionId) {
+        return collectionService.getQueryables(collectionId);
+    }
+
     @Override
     public Mono<ItemCollection> getCollectionItems(@PathVariable("collectionId") String collectionId,
                                                    @RequestParam(value = "filter-lang", required = false) String filterLang,

staccato-application/src/main/java/com/planet/staccato/oaf/DefaultOafService.java

@@ -3,10 +3,12 @@
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
 import com.planet.staccato.model.Conformance;
+import com.planet.staccato.queryables.Queryables;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.core.io.Resource;
 import org.springframework.core.io.UrlResource;
 import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 import javax.annotation.PostConstruct;
@@ -23,9 +25,14 @@
 @Service
 public class DefaultOafService {
 
+    private final List<Queryables> queryables;
     private final ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
     private final Conformance conformance = new Conformance();
 
+    public DefaultOafService(List<Queryables> queryables) {
+        this.queryables = queryables;
+    }
+
     @PostConstruct
     public void init() {
         initConformance();
@@ -58,4 +65,9 @@ public Mono<Conformance> getConformanceMono() {
         return Mono.just(conformance);
     }
 
+    public Flux<Queryables> getQueryables() {
+        return Flux.fromIterable(queryables);
+    }
+
+
 }

staccato-application/src/main/java/com/planet/staccato/oaf/OafApi.java

@@ -2,8 +2,10 @@
 
 import com.planet.staccato.config.StaccatoMediaType;
 import com.planet.staccato.model.Conformance;
+import com.planet.staccato.queryables.Queryables;
 import org.springframework.http.MediaType;
 import org.springframework.web.bind.annotation.GetMapping;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 /**
@@ -19,4 +21,7 @@ public interface OafApi {
     @GetMapping(path = "/conformance", produces = MediaType.APPLICATION_JSON_VALUE)
     Mono<Conformance> getConformance();
 
+    @GetMapping(path = "/queryables", produces = StaccatoMediaType.APPLICATION_SCHEMA_JSON_VALUE)
+    Flux<Queryables> getQueryables();
+
 }

staccato-application/src/main/java/com/planet/staccato/oaf/OafController.java

@@ -1,8 +1,10 @@
 package com.planet.staccato.oaf;
 
 import com.planet.staccato.model.Conformance;
+import com.planet.staccato.queryables.Queryables;
 import lombok.RequiredArgsConstructor;
 import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 /**
@@ -24,4 +26,10 @@ public Mono<Object> getApi() {
     public Mono<Conformance> getConformance() {
         return service.getConformanceMono();
     }
+
+    @Override
+    public Flux<Queryables> getQueryables() {
+        return service.getQueryables();
+    }
+
 }

staccato-application/src/main/resources/application.yml

@@ -48,7 +48,7 @@ logging:
     #org.springframework.web.reactive.result.method.annotation.RequestMappingHandlerMapping: WARN
 
 staccato:
-  version: 1.0.0-rc1
+  version: 1.0.0-rc.2
   rsocket:
     enabled: false
   kafka: