diff --git a/src/db/main-db-p.h b/src/db/main-db-p.h index cec8344a1..6e33241b3 100644 --- a/src/db/main-db-p.h +++ b/src/db/main-db-p.h @@ -43,6 +43,10 @@ class MainDbPrivate : public AbstractDbPrivate { public: private: + // --------------------------------------------------------------------------- + // Low level API. + // --------------------------------------------------------------------------- + long insertSipAddress (const std::string &sipAddress); void insertContent (long messageEventId, const Content &content); long insertContentType (const std::string &contentType); @@ -61,6 +65,8 @@ private: void insertMessageParticipant (long messageEventId, long sipAddressId, ChatMessage::State state); + void insertConferenceEvent (long eventId, long chatRoomId); + std::unordered_map> chatRooms; L_DECLARE_PUBLIC(MainDb); diff --git a/src/db/main-db.cpp b/src/db/main-db.cpp index db0d2360c..4a085a0a2 100644 --- a/src/db/main-db.cpp +++ b/src/db/main-db.cpp @@ -236,6 +236,12 @@ MainDb::MainDb () : AbstractDb(*new MainDbPrivate) {} soci::use(messageEventId), soci::use(sipAddressId), soci::use(static_cast(state)); } + void MainDbPrivate::insertConferenceEvent (long eventId, long chatRoomId) { + soci::session *session = dbSession.getBackendSession(); + *session << "INSERT INTO conference_event (event_id, chat_room_id) VALUES (:eventId, :chatRoomId)", + soci::use(eventId), soci::use(chatRoomId); + } + // ----------------------------------------------------------------------------- #define LEGACY_MESSAGE_COL_LOCAL_ADDRESS 1