fix: timeouts

Author: Angular2Guy

Diff for: backend/src/main/java/ch/xxx/trader/usecase/services/CoinbaseService.java

@@ -183,11 +183,11 @@ private String createHourDayAvg() {
 			CompletableFuture<String> future7 = CompletableFuture.supplyAsync(() -> {
 				this.createCbIntervalAvg(false);
 				return "createCbHourlyAvg() Done.";
-			}, CompletableFuture.delayedExecutor(10, TimeUnit.SECONDS));
+			}, CompletableFuture.delayedExecutor(1, TimeUnit.SECONDS));
 			CompletableFuture<String> future8 = CompletableFuture.supplyAsync(() -> {
 				this.createCbIntervalAvg(true);
 				return "createCbDailyAvg() Done.";
-			}, CompletableFuture.delayedExecutor(10, TimeUnit.SECONDS));
+			}, CompletableFuture.delayedExecutor(1, TimeUnit.SECONDS));
 			String combined = Stream.of(future7, future8).map(CompletableFuture::join).collect(Collectors.joining(" "));
 			LOG.info(combined);
 		}
@@ -204,13 +204,13 @@ private void processTimeFrame(MyTimeFrame timeFrame1, boolean isDay) {
 		// Coinbase
 		final var logFailed = String.format("Coinbase prepare %s data failed", isDay ? "day" : "hour");
 		Mono<Collection<QuoteCb>> collectCb = this.myMongoRepository.find(query, QuoteCb.class)
-				.timeout(Duration.ofSeconds(10L)).doOnError(ex -> LOG.warn(logFailed, ex))
+				.timeout(Duration.ofSeconds(30L)).doOnError(ex -> LOG.warn(logFailed, ex))
 				.onErrorResume(ex -> Mono.empty()).subscribeOn(this.mongoScheduler).collectList()
 				.map(quotes -> this.createCbQuoteTimeFrame(timeFrame1, isDay, quotes));
 		collectCb.filter(Predicate.not(Collection::isEmpty))
 				.map(myColl -> this.countRelevantProperties(nonZeroProperties, myColl))
 				.flatMap(myColl -> this.myMongoRepository.insertAll(Mono.just(myColl), isDay ? CB_DAY_COL : CB_HOUR_COL)
-						.timeout(Duration.ofSeconds(10L)).doOnError(ex -> LOG.warn(logFailed, ex))
+						.timeout(Duration.ofSeconds(30L)).doOnError(ex -> LOG.warn(logFailed, ex))
 						.onErrorResume(ex -> Mono.empty()).subscribeOn(this.mongoScheduler).collectList())
 				.subscribeOn(this.mongoScheduler).block();
 		LOG.info(String.format("Prepared Coinbase %s Data for: ", isDay ? "Day" : "Hour")