Added validation to receive api

vsadokhin · Sep 29, 2018 · 5d1e08e · 5d1e08e
1 parent 5679e50
commit 5d1e08e
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 4 deletions.
diff --git a/data/build.gradle b/data/build.gradle
@@ -13,6 +13,7 @@ def mockito_version = "1.10.19"
 
 dependencies {
   compile 'com.datastax.cassandra:cassandra-driver-core:3.6.0'
+  compile 'org.hibernate:hibernate-validator:6.0.13.Final'
 
   testCompile 'junit:junit:4.12'
   testCompile("org.powermock:powermock-module-junit4:${powermock_version}") {

diff --git a/data/src/main/java/me/vsadokhin/iot/data/domain/Metric.java b/data/src/main/java/me/vsadokhin/iot/data/domain/Metric.java
@@ -1,14 +1,20 @@
 package me.vsadokhin.iot.data.domain;
 
+import javax.validation.constraints.NotNull;
+
 public class Metric {
 
+    @NotNull
     private String sensorId;
 
+    @NotNull
     private String type;
 
-    private long when;
+    @NotNull
+    private Long when;
 
-    private float value;
+    @NotNull
+    private Float value;
 
     public String getSensorId() {
         return sensorId;

diff --git a/receive-api/src/main/java/me/vsadokhin/iot/receive/api/MetricResource.java b/receive-api/src/main/java/me/vsadokhin/iot/receive/api/MetricResource.java
@@ -1,5 +1,7 @@
 package me.vsadokhin.iot.receive.api;
 
+import javax.validation.Valid;
+
 import me.vsadokhin.iot.data.domain.Metric;
 import me.vsadokhin.iot.stream.producer.KafkaProducer;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,8 +22,7 @@ public MetricResource(KafkaProducer kafkaProducer) {
     }
 
     @PostMapping("/metric")
-    ResponseEntity create(@RequestBody Metric metric) {
-        // TODO Vasiliy validate
+    ResponseEntity create(@Valid @RequestBody Metric metric) {
         kafkaProducer.sendAsync("metric", metric);
         return new ResponseEntity<>(HttpStatus.ACCEPTED);
     }