From be18e569fc45a0017044ca657c01ee38e6ea4795 Mon Sep 17 00:00:00 2001
From: Ronan Abhamon <ronan.abhamon@belledonne-communications.com>
Date: Mon, 23 Oct 2017 10:53:14 +0200
Subject: [PATCH] feat(MainDb): fetch ConferenceParticipantEvent => OK

---
 src/db/main-db.cpp | 30 ++++++++++++++++++++++++------
 1 file changed, 24 insertions(+), 6 deletions(-)

diff --git a/src/db/main-db.cpp b/src/db/main-db.cpp
index e5b5ad26a..0991adb06 100644
--- a/src/db/main-db.cpp
+++ b/src/db/main-db.cpp
@@ -286,8 +286,24 @@ MainDb::MainDb () : AbstractDb(*new MainDbPrivate) {}
 		time_t date,
 		const string &peerAddress
 	) const {
-		// TODO.
-		return nullptr;
+		unsigned int notifyId;
+		string participantAddress;
+
+		soci::session *session = dbSession.getBackendSession<soci::session>();
+		*session << "SELECT notify_id, participant_address_id"
+			"  FROM conference_notified_event, conference_participant_event"
+			"  WHERE conference_participant_event.event_id = :eventId"
+			"    AND conference_notified_event.event_id = conference_participant_event.event_id",
+			soci::into(notifyId), soci::into(participantAddress), soci::use(eventId);
+
+		// TODO: Use cache.
+		return make_shared<ConferenceParticipantEvent>(
+			type,
+			date,
+			Address(peerAddress),
+			notifyId,
+			Address(participantAddress)
+		);
 	}
 
 	shared_ptr<EventLog> MainDbPrivate::selectConferenceParticipantDeviceEvent (
@@ -306,13 +322,15 @@ MainDb::MainDb () : AbstractDb(*new MainDbPrivate) {}
 		time_t date,
 		const string &peerAddress
 	) const {
-		soci::session *session = dbSession.getBackendSession<soci::session>();
-
 		unsigned int notifyId;
 		string subject;
 
-		*session << "SELECT notify_id, subject FROM conference_subject_event WHERE event_id = :eventId",
-			soci::use(eventId), soci::into(notifyId), soci::into(subject);
+		soci::session *session = dbSession.getBackendSession<soci::session>();
+		*session << "SELECT notify_id, subject"
+			"  FROM conference_notified_event, conference_subject_event"
+			"  WHERE conference_subject_event.event_id = :eventId"
+			"    AND conference_notified_event.event_id = conference_subject_event.event_id",
+			soci::into(notifyId), soci::into(subject), soci::use(eventId);
 
 		// TODO: Use cache.
 		return make_shared<ConferenceSubjectEvent>(