incubation

build.gradle

@@ -28,11 +28,11 @@ dependencies {
     // maven: provided
     compileOnly 'org.projectlombok:lombok'
 
-    implementation 'javax.inject:javax.inject:1'
-
     annotationProcessor 'org.projectlombok:lombok'
     annotationProcessor 'org.springframework.boot:spring-boot-configuration-processor'
 
+    implementation 'javax.inject:javax.inject:1'
+
     testImplementation('org.springframework.boot:spring-boot-starter-test') {
         exclude group: 'org.junit.vintage', module: 'junit-vintage-engine'
     }

settings.gradle

@@ -1 +1 @@
-rootProject.name = 'opentrading-core'
+rootProject.name = 'opentrading-core'

src/main/java/dev/opentrading/core/spring/CoreApplicationConfiguration.java

@@ -6,7 +6,7 @@
 import org.springframework.context.annotation.Configuration;
 
 @Configuration
-@EnableConfigurationProperties(CoreApplicationProperties.class)
+@EnableConfigurationProperties(CoreProperties.class)
 public class CoreApplicationConfiguration {
     @Bean
     public ExitCodeGenerator exitCodeGenerator() {

src/main/java/dev/opentrading/core/spring/CoreApplicationRunner.java

@@ -7,6 +7,10 @@
 import org.springframework.core.annotation.Order;
 
 import javax.inject.Named;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.CompletableFuture;
+import java.util.stream.Collectors;
 
 /**
  * First runner
@@ -15,12 +19,12 @@
 @Named
 @Order(1)
 public abstract class CoreApplicationRunner implements ApplicationRunner {
-    private final CoreApplicationProperties applicationProperties;
+    private final CoreProperties coreProperties;
 
     private final CoreBootstrap coreBootstrap;
 
-    protected CoreApplicationRunner(CoreApplicationProperties applicationProperties, CoreBootstrap coreBootstrap) {
-        this.applicationProperties = applicationProperties;
+    protected CoreApplicationRunner(CoreProperties applicationProperties, CoreBootstrap coreBootstrap) {
+        this.coreProperties = applicationProperties;
         this.coreBootstrap = coreBootstrap;
     }
 
@@ -39,18 +43,36 @@ public void run(ApplicationArguments args) {
                     coreBootstrap.getTradingInstruments().thenAccept(tradingInstrument -> {
                         log.info("Filtered trading instruments");
 
-                        coreBootstrap.initWebSocket().thenAccept(initWebsocket -> {
+                        coreBootstrap.<Boolean> initWebSocket().thenApply(initialized -> {
                             log.info("Initialized WebSocket");
 
-                            coreBootstrap.streamTicks().thenAccept(ScheduledStreamingTicks -> {
-                                log.info("Started streaming ticks");
-
-                                coreBootstrap.scheduleTicksAggregator().thenAccept(success -> {
-                                    log.info("Scheduled tick aggregator");
-
-                                    log.info("Started CoreApplicationRunner.");
-                                });
-                            });
+                            List<CompletableFuture<Boolean>> completableFutureList = new ArrayList<>();
+                            if (coreProperties.getOptions().isStreamTicks()) {
+                                completableFutureList.add((coreBootstrap.<Boolean> streamTicks()
+                                        .thenApply(scheduled -> {
+                                            log.info("Scheduled streaming ticks");
+                                            return scheduled;
+                                        })));
+                            }
+                            if (coreProperties.getOptions().isStreamTicksAggregator()) {
+                                completableFutureList.add((coreBootstrap.<Boolean> scheduleTicksAggregator()
+                                        .thenApply(scheduled -> {
+                                            log.info("Scheduled ticks aggregator");
+                                            return scheduled;
+                                        })));
+                            }
+                            return initialized && completableFutureList.stream()
+                                    .map(CompletableFuture::join)
+                                    .collect(Collectors.toList())
+                                    .stream()
+                                    .reduce(true, Boolean::logicalAnd);
+                        }).whenComplete((initialized, throwable) -> {
+                            if (throwable != null) {
+                                log.error("Exception occurred. exception={}", throwable.getCause().getMessage());
+                            }
+                            if (initialized) {
+                                log.info("Started CoreApplicationRunner");
+                            }
                         });
                     });
                 });

src/main/java/dev/opentrading/core/spring/CoreProperties.java

@@ -0,0 +1,31 @@
+package dev.opentrading.core.spring;
+
+import lombok.Data;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import java.util.List;
+
+@Data
+@ConfigurationProperties(prefix = "opentrading.core")
+public class CoreProperties {
+    Options options;
+    MarketData marketData;
+    TradingData tradingData;
+
+    @Data
+    public static class Options {
+        private boolean streamTicks;
+        private boolean streamTicksAggregator;
+    }
+    @Data
+    public static class MarketData {
+        private String openTime;
+        private String closeTime;
+    }
+    @Data
+    public static class TradingData {
+        private String startTime;
+        private String endTime;
+        private List<String> instrumentGroups;
+    }
+}

src/main/resources/application.yml

@@ -1 +1,68 @@
-opentrading:
+#
+# 1. core properties
+#
+opentrading.core:
+  options:
+    streamTicks: false
+    streamTicksAggregator: false
+  marketData:
+    openTime: 09-00
+    closeTime: 15-30
+  tradingData:
+    startTime: 09:30
+    endTime: 15:00
+    instrumentGroups:
+      - a
+      - b
+  orchestrator:
+###
+
+
+#
+# 2. persistence properties
+#
+opentrading.persistence:
+###
+
+
+#
+# 3. data properties
+#
+opentrading.data:
+  tickIntevalMillSeconds: 300000
+###
+
+
+#
+# 4. compute properties
+#
+opentrading.compute:
+###
+
+
+#
+# 5. strategy properties
+#
+opentrading.strategy
+###
+
+
+#
+# 6. analyzer properties
+#
+opentrading.analyzer
+###
+
+
+#
+# 7. agent properties
+#
+opentrading.agent
+###
+
+
+#
+# 8. simulator properties
+#
+opentrading.simulator
+###