From 63407d96e37df8457e8350e9184b9e3de376fd1f Mon Sep 17 00:00:00 2001
From: Newe <speedy.wolfy@outlook.com>
Date: Tue, 25 May 2021 12:41:28 +0200
Subject: [edit] Retrieve the event name from mongoDB event payload

---
 src/mongoStub.cpp | 26 ++++++++++++++++++++++----
 1 file changed, 22 insertions(+), 4 deletions(-)

(limited to 'src/mongoStub.cpp')

diff --git a/src/mongoStub.cpp b/src/mongoStub.cpp
index 50312fc6..3e7ae3df 100644
--- a/src/mongoStub.cpp
+++ b/src/mongoStub.cpp
@@ -17,10 +17,28 @@ mongoStub::mongoStub() {
     }
 }
 
-std::vector<std::string>mongoStub::getNewMessages(mongocxx::change_stream* colCs) {
-	std::vector<std::string> retVec;
-    for (const auto& event : *colCs) {
-        retVec.push_back(bsoncxx::to_json(event));
+//Too slow for my liking
+std::vector<mongoStub::mongoMessage> mongoStub::getNewMessages(mongocxx::change_stream* colCs) {
+	std::vector<mongoStub::mongoMessage> retVec;
+	
+    for (auto&& event : *colCs) {
+		mongoStub::mongoMessage returnValue;
+
+		/*if(event["fullDocument"]["data"]){
+				returnValue.data.push_back(event["fullDocument"]["data"].get_utf8().value.to_string());
+			}*/
+
+
+		
+		std::cout << bsoncxx::to_json(event) << std::endl;
+
+		//Oly listen to insert events (to avoid "precondition failed: data" exception)
+		if(event["operationType"].get_utf8().value.to_string()!="insert"){
+			continue;
+		}
+		returnValue.eventName = event["fullDocument"]["event"].get_utf8().value.to_string();
+		retVec.push_back(returnValue);
     }
+
 	return retVec;
 }
-- 
cgit 1.5.1