From d52dc4cfb2cb219aa2db25ae6e201b21bbc3079f Mon Sep 17 00:00:00 2001
From: Christian Mollekopf <chrigi_1@fastmail.fm>
Date: Fri, 22 Jun 2018 13:07:47 +0200
Subject: Log query results

---
 common/queryrunner.cpp | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/common/queryrunner.cpp b/common/queryrunner.cpp
index 3710ec8..95a2fb4 100644
--- a/common/queryrunner.cpp
+++ b/common/queryrunner.cpp
@@ -247,6 +247,19 @@ QueryWorker<DomainType>::~QueryWorker()
     SinkTraceCtx(mLogCtx) << "Stopped query worker";
 }
 
+static QString operationName(Sink::Operation operation)
+{
+    switch (operation) {
+        case Sink::Operation_Creation:
+            return "Creation";
+        case Sink::Operation_Modification:
+            return "Modification";
+        case Sink::Operation_Removal:
+            return "Removal";
+    }
+    return "Unknown Operation";
+}
+
 template <class DomainType>
 void QueryWorker<DomainType>::resultProviderCallback(const Sink::Query &query, Sink::ResultProviderInterface<typename DomainType::Ptr> &resultProvider, const ResultSet::Result &result)
 {
@@ -258,6 +271,7 @@ void QueryWorker<DomainType>::resultProviderCallback(const Sink::Query &query, S
     if (mResultTransformation) {
         mResultTransformation(*valueCopy);
     }
+    SinkTraceCtx(mLogCtx) << "Replaying: " << operationName(result.operation) << "\n" <<*valueCopy;
     switch (result.operation) {
         case Sink::Operation_Creation:
             //SinkTraceCtx(mLogCtx) << "Got creation: " << valueCopy->identifier();
-- 
cgit v1.2.3