Skip to content
Snippets Groups Projects
Commit db35c637 authored by Sören Henning's avatar Sören Henning
Browse files

removed cross origin/domain settings (not longer required)

parent 33b8a54e
No related branches found
No related tags found
No related merge requests found
package kiekpad.vizprovider.controller; package kiekpad.vizprovider.controller;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.CrossOrigin; import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.RestController;
import com.datastax.driver.core.ResultSet;
import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Row;
import com.datastax.driver.core.Row; import com.datastax.driver.core.querybuilder.QueryBuilder;
import com.datastax.driver.core.querybuilder.QueryBuilder; import com.datastax.driver.core.querybuilder.Select;
import com.datastax.driver.core.querybuilder.Select; import com.fasterxml.jackson.databind.node.ArrayNode;
import com.fasterxml.jackson.databind.node.ArrayNode; import com.fasterxml.jackson.databind.node.JsonNodeFactory;
import com.fasterxml.jackson.databind.node.JsonNodeFactory; import com.fasterxml.jackson.databind.node.ObjectNode;
import com.fasterxml.jackson.databind.node.ObjectNode;
import kiekpad.vizprovider.service.CassandraService;
import kiekpad.vizprovider.service.CassandraService;
@RestController
@RestController public class MeasurementsController {
public class MeasurementsController {
private final CassandraService cassandraService;
private final CassandraService cassandraService;
@Autowired
@Autowired public MeasurementsController(final CassandraService cassandraService) {
public MeasurementsController(final CassandraService cassandraService) { this.cassandraService = cassandraService;
this.cassandraService = cassandraService; }
}
@RequestMapping("/measurements")
@CrossOrigin // TODO Cross Origin is just for development public ArrayNode measurements(@RequestParam(value = "after", defaultValue = "0") final long after) {
@RequestMapping("/measurements")
public ArrayNode measurements(@RequestParam(value = "after", defaultValue = "0") final long after) { JsonNodeFactory jsonNodeFactory = JsonNodeFactory.instance;
JsonNodeFactory jsonNodeFactory = JsonNodeFactory.instance; ArrayNode array = jsonNodeFactory.arrayNode();
ArrayNode array = jsonNodeFactory.arrayNode(); final Select statement = QueryBuilder.select("time", "measurement", "prediction", "anomalyscore")
.from("measurements")
final Select statement = QueryBuilder.select("time", "measurement", "prediction", "anomalyscore") .where(QueryBuilder.eq("series_id", "temp2")) // TODO insert value
.from("measurements") .and(QueryBuilder.gt("time", after))
.where(QueryBuilder.eq("series_id", "temp2")) .orderBy(QueryBuilder.asc("time"));
.and(QueryBuilder.gt("time", after)) final ResultSet results = this.cassandraService.getSession().execute(statement);
.orderBy(QueryBuilder.asc("time"));
final ResultSet results = this.cassandraService.getSession().execute(statement); for (Row row : results) {
for (Row row : results) { ObjectNode node = jsonNodeFactory.objectNode();
node.set("time", jsonNodeFactory.numberNode(row.getTimestamp("time").toInstant().toEpochMilli()));
ObjectNode node = jsonNodeFactory.objectNode(); node.set("measurement", jsonNodeFactory.numberNode(row.getDouble("measurement")));
node.set("time", jsonNodeFactory.numberNode(row.getTimestamp("time").toInstant().toEpochMilli())); node.set("prediction", jsonNodeFactory.numberNode(row.getDouble("prediction")));
node.set("measurement", jsonNodeFactory.numberNode(row.getDouble("measurement"))); node.set("anomalyscore", jsonNodeFactory.numberNode(row.getDouble("anomalyscore")));
node.set("prediction", jsonNodeFactory.numberNode(row.getDouble("prediction")));
node.set("anomalyscore", jsonNodeFactory.numberNode(row.getDouble("anomalyscore"))); array.add(node);
array.add(node); }
} return array;
}
return array;
} }
}
...@@ -42,11 +42,10 @@ ...@@ -42,11 +42,10 @@
var latestMeasurementTime = 0; var latestMeasurementTime = 0;
function requestNewData() { function requestNewData() {
$.ajax({ $.ajax({
url: "http://localhost:8080/measurements", url: "measurements",
method: "GET", method: "GET",
data: { after: latestMeasurementTime }, data: { after: latestMeasurementTime },
dataType: "json", dataType: "json",
crossDomain: true, //TODO temp
success: function(data) { success: function(data) {
visualization.addMeasurements(data); visualization.addMeasurements(data);
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment