chore(application): Various fixes in CSV data exporter

wuespace · Mar 25, 2023 · b71e7a9 · b71e7a9
1 parent cdfa37b
commit b71e7a9
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/application/conf/config.json b/application/conf/config.json
@@ -36,7 +36,8 @@
 						"request-time-sync",
 						"a-gps-transmitter#request",
 						"tc-console-request",
-						"reset-tc-counter"
+						"reset-tc-counter",
+						"csv-data-exporter#request"
 					],
 					"outboundPermitted": [
 						"a-gps-transmitter#notify",

diff --git a/...cation/src/main/java/de/wuespace/telestion/project/daedalus2/mongodb/CSVDataExporter.java b/...cation/src/main/java/de/wuespace/telestion/project/daedalus2/mongodb/CSVDataExporter.java
@@ -79,9 +79,10 @@ public void onStop(Promise<Void> stopPromise) throws Exception {
 	private MongoClient client;
 
 	private void handle(CSVDataRequest request, Message<Object> message) {
+		logger.debug("Get CSV iridium messages for target: {}", request.target());
 		getAllIridiumMessages(request.target())
 				.map(this::createCSVData)
-				.onSuccess(message::reply)
+				.onSuccess(data -> message.reply(data.json()))
 				.onFailure(cause -> message.fail(500, cause.getMessage()));
 	}
 
@@ -92,7 +93,7 @@ private CSVData createCSVData(List<JsonObject> results) {
 				.map(this::mergeInfos)
 				.collect(Collectors.joining("\n"));
 
-		return new CSVData(0, header + body);
+		return new CSVData(results.size(), header + body);
 	}
 
 	private Future<List<JsonObject>> getAllIridiumMessages(String target) {