ATEST-285

.settings/org.eclipse.jdt.core.prefs

@@ -1,5 +1,5 @@
 #
-#Fri Nov 27 11:43:12 CET 2015
+#Fri Nov 27 16:17:06 CET 2015
 org.eclipse.jdt.core.compiler.debug.localVariable=generate
 org.eclipse.jdt.core.compiler.compliance=1.8
 org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve

src/main/java/ch/psi/daq/queryrest/QueryRestApplication.java

@@ -12,7 +12,6 @@ import org.springframework.boot.context.web.SpringBootServletInitializer;
 @SpringBootApplication
 public class QueryRestApplication extends SpringBootServletInitializer {
 
-
    public static void main(final String[] args) {
       SpringApplication.run(QueryRestApplication.class, args);
    }

src/main/java/ch/psi/daq/queryrest/config/QueryRestConfig.java

@@ -25,7 +25,12 @@ import org.springframework.util.StringUtils;
 import org.springframework.validation.Validator;
 import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter;
 
-import ch.psi.daq.cassandra.util.test.CassandraDataGen;
+import com.fasterxml.jackson.annotation.JsonInclude.Include;
+import com.fasterxml.jackson.core.JsonFactory;
+import com.fasterxml.jackson.core.Version;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.module.SimpleModule;
+
 import ch.psi.daq.common.statistic.StorelessStatistics;
 import ch.psi.daq.domain.DataEvent;
 import ch.psi.daq.query.analyzer.QueryAnalyzer;
@@ -41,12 +46,6 @@ import ch.psi.daq.queryrest.response.JsonByteArraySerializer;
 import ch.psi.daq.queryrest.response.JsonStreamSerializer;
 import ch.psi.daq.queryrest.response.ResponseStreamWriter;
 
-import com.fasterxml.jackson.annotation.JsonInclude.Include;
-import com.fasterxml.jackson.core.JsonFactory;
-import com.fasterxml.jackson.core.Version;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.databind.module.SimpleModule;
-
 @Configuration
 @PropertySource(value = {"classpath:queryrest.properties"})
 @PropertySource(value = {"file:${user.home}/.config/daq/queryrest.properties"}, ignoreResourceNotFound = true)
@@ -72,7 +71,7 @@ public class QueryRestConfig extends WebMvcConfigurerAdapter {
 
    @Resource
    private Environment env;
-   
+
    @Resource
    private ObjectMapper objectMapper;
 
@@ -176,11 +175,4 @@ public class QueryRestConfig extends WebMvcConfigurerAdapter {
    public Filter corsFilter() {
       return new CorsFilter();
    }
-
-   // ==========================================================================================
-   // TODO: This is simply for initial / rudimentary testing - remove once further evolved
-   @Bean
-   public CassandraDataGen cassandraDataGen() {
-      return new CassandraDataGen();
-   }
 }

src/main/java/ch/psi/daq/queryrest/controller/QueryRestController.java

@@ -27,8 +27,9 @@ import org.springframework.web.bind.annotation.RequestMethod;
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import com.google.common.collect.Lists;
+
 import ch.psi.daq.cassandra.request.validate.RequestProviderValidator;
-import ch.psi.daq.cassandra.util.test.CassandraDataGen;
 import ch.psi.daq.common.concurrent.singleton.Deferred;
 import ch.psi.daq.common.json.deserialize.AttributeBasedDeserializer;
 import ch.psi.daq.common.ordering.Ordering;
@@ -46,8 +47,6 @@ import ch.psi.daq.query.request.ChannelsRequest;
 import ch.psi.daq.queryrest.config.QueryRestConfig;
 import ch.psi.daq.queryrest.response.ResponseStreamWriter;
 
-import com.google.common.collect.Lists;
-
 @RestController
 public class QueryRestController {
 
@@ -248,26 +247,4 @@ public class QueryRestController {
          throw new IllegalArgumentException(String.format("Unknown DBMode '%s'", dbMode));
       }
    }
-
-   // ==========================================================================================
-   // TODO: This is simply for initial / rudimentary testing - remove once
-   // further evolved
-
-   @Resource
-   private CassandraDataGen cassandraDataGen;
-
-   @RequestMapping(value = "/write")
-   public void writeDummyEntry() {
-      long nrOfElements = 4;
-      cassandraDataGen.writeData(3, 0, 4, i -> i, i -> 0, i -> i, i -> i, i -> 0, i -> new long[] {i, i, i, i},
-            "TRFCA-channel1");
-
-      cassandraDataGen.writeData(3, 0, 4, i -> i, i -> 0, i -> i, i -> i, i -> 0, i -> new long[] {nrOfElements - i,
-            nrOfElements - i, nrOfElements - i, nrOfElements - i}, "TRFCA-channel2");
-
-      cassandraDataGen.writeData(3, 0, 4, i -> i, i -> 0, i -> i, i -> i, i -> 0, i -> i, "TRFCB-channel3");
-
-      cassandraDataGen.writeData(3, 0, 4, i -> i, i -> 0, i -> i, i -> i, i -> 0, i -> nrOfElements - i,
-            "TRFCB-channel4");
-   }
 }

src/test/java/ch/psi/daq/test/queryrest/DaqWebMvcConfig.java

@@ -4,6 +4,7 @@ import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
+import org.springframework.context.annotation.Lazy;
 import org.springframework.context.annotation.PropertySource;
 import org.springframework.context.annotation.PropertySources;
 import org.springframework.web.servlet.config.annotation.EnableWebMvc;
@@ -32,15 +33,19 @@ public class DaqWebMvcConfig extends WebMvcConfigurationSupport {
    }
    
    @Bean
+   @Lazy
    public QueryProcessor cassandraQueryProcessorLocal() {
       return new QueryProcessorLocal(cassandraReader());
    }
    
-   @Bean CassandraReader cassandraReader() {
+   @Bean
+   @Lazy
+   CassandraReader cassandraReader() {
       return new DummyCassandraReader();
    }
    
    @Bean
+   @Lazy
    public CassandraTestAdmin cassandraTestAdmin() {
       return new CassandraTestAdminImpl();
    }