From d94ae1eec391ba577ba3912d2aa8b583fbf43e70 Mon Sep 17 00:00:00 2001
From: "Wiktor S. Ovalle Correa" <w.s.ovalle@mudita.com>
Date: Mon, 12 Apr 2021 18:33:21 +0200
Subject: [PATCH] [EGD-6485] Restore Contact operations handling

Previous commit on EGD-6485 removed ContactAdd/Update/Remove
cases that were still in use
---
 module-services/service-db/ServiceDB.cpp | 29 ++++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/module-services/service-db/ServiceDB.cpp b/module-services/service-db/ServiceDB.cpp
index 824a10ca13955dd5d9e05c36d2cddd8381949574..939e45d46849f3d783c118d39729fac30df4cc9b 100644
--- a/module-services/service-db/ServiceDB.cpp
+++ b/module-services/service-db/ServiceDB.cpp
@@ -102,6 +102,19 @@ sys::MessagePointer ServiceDB::DataReceivedHandler(sys::DataMessage *msgl, sys::
     std::shared_ptr<sys::ResponseMessage> responseMsg;
     auto type = static_cast<MessageType>(msgl->messageType);
     switch (type) {
+
+        /**
+         * Contact records
+         */
+
+    case MessageType::DBContactAdd: {
+        auto time             = utils::time::Scoped("DBContactAdd");
+        DBContactMessage *msg = reinterpret_cast<DBContactMessage *>(msgl);
+        auto ret              = contactRecordInterface->Add(msg->record);
+        responseMsg           = std::make_shared<DBContactResponseMessage>(nullptr, ret);
+        sendUpdateNotification(db::Interface::Name::Contact, db::Query::Type::Create);
+    } break;
+
     case MessageType::DBContactGetByID: {
         auto time             = utils::time::Scoped("DBContactGetByID");
         DBContactMessage *msg = reinterpret_cast<DBContactMessage *>(msgl);
@@ -141,6 +154,22 @@ sys::MessagePointer ServiceDB::DataReceivedHandler(sys::DataMessage *msgl, sys::
         }
     } break;
 
+    case MessageType::DBContactRemove: {
+        auto time             = utils::time::Scoped("DBContactRemove");
+        DBContactMessage *msg = reinterpret_cast<DBContactMessage *>(msgl);
+        auto ret              = contactRecordInterface->RemoveByID(msg->id);
+        responseMsg           = std::make_shared<DBContactResponseMessage>(nullptr, ret);
+        sendUpdateNotification(db::Interface::Name::Contact, db::Query::Type::Delete);
+    } break;
+
+    case MessageType::DBContactUpdate: {
+        auto time             = utils::time::Scoped("DBContactUpdate");
+        DBContactMessage *msg = reinterpret_cast<DBContactMessage *>(msgl);
+        auto ret              = contactRecordInterface->Update(msg->record);
+        responseMsg           = std::make_shared<DBContactResponseMessage>(nullptr, ret);
+        sendUpdateNotification(db::Interface::Name::Contact, db::Query::Type::Update);
+    } break;
+
         /**
          * Calllog records
          */