mirrors/linphone-iphone
1
0
Fork 1
mirror of https://gitlab.linphone.org/BC/public/linphone-iphone.git synced 2026-05-07 05:53:06 +00:00
Code Issues Projects Releases Packages Wiki Activity

Added update methods for ChatMessageEvents and ChatMessageContent

Browse source
This commit is contained in:
Sylvain Berfini 2017-11-23 17:26:10 +01:00
parent ec7fd6d258
commit b12304668a
4 changed files with 84 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/db/main-db-event-key.h
View file

@ -33,6 +33,7 @@ class MainDbEventKeyPrivate;
class MainDbEventKey : public ClonableObject {
friend class MainDb;
friend class MainDbPrivate;
public:
MainDbEventKey ();

2
src/db/main-db-p.h
View file

@ -41,6 +41,7 @@ private:
long long insertSipAddress (const std::string &sipAddress);
void insertContent (long long messageEventId, const Content &content);
void updateContent (long long messageEventId, long long messageContentId, const Content &content);
long long insertContentType (const std::string &contentType);
long long insertChatRoom (
long long peerSipAddressId,
@ -114,6 +115,7 @@ private:
long long insertConferenceEvent (const std::shared_ptr<EventLog> &eventLog, long long *chatRoomId = nullptr);
long long insertConferenceCallEvent (const std::shared_ptr<EventLog> &eventLog);
long long insertConferenceChatMessageEvent (const std::shared_ptr<EventLog> &eventLog);
void updateConferenceChatMessageEvent(const std::shared_ptr<EventLog> &eventLog);
long long insertConferenceNotifiedEvent (const std::shared_ptr<EventLog> &eventLog, long long *chatRoomId = nullptr);
long long insertConferenceParticipantEvent (const std::shared_ptr<EventLog> &eventLog);
long long insertConferenceParticipantDeviceEvent (const std::shared_ptr<EventLog> &eventLog);

80
src/db/main-db.cpp
View file

@ -148,6 +148,18 @@ MainDb::MainDb (const shared_ptr<Core> &core) : AbstractDb(*new MainDbPrivate),
soci::use(messageContentId), soci::use(appData.first), soci::use(appData.second);
}
void MainDbPrivate::updateContent (long long eventId, long long messageContentId, const Content &content) {
soci::session *session = dbSession.getBackendSession<soci::session>();
long long contentTypeId = insertContentType(content.getContentType().asString());
*session << "UPDATE chat_message_content SET content_type_id=:contentTypeId, body=:body WHERE event_id=:eventId",
soci::use(contentTypeId), soci::use(content.getBodyAsString()), soci::use(eventId);
for (const auto &appData : content.getAppDataMap())
*session << "UPDATE chat_message_content_app_data SET name=:name, data=:data WHERE chat_message_content_id=:messageContentId",
soci::use(appData.first), soci::use(appData.second), soci::use(messageContentId);
}
long long MainDbPrivate::insertContentType (const string &contentType) {
L_Q();
soci::session *session = dbSession.getBackendSession<soci::session>();
@ -581,6 +593,27 @@ MainDb::MainDb (const shared_ptr<Core> &core) : AbstractDb(*new MainDbPrivate),
return eventId;
}
void MainDbPrivate::updateConferenceChatMessageEvent(const std::shared_ptr<EventLog> &eventLog) {
shared_ptr<ChatMessage> chatMessage = static_pointer_cast<ConferenceChatMessageEvent>(eventLog)->getChatMessage();
shared_ptr<ChatRoom> chatRoom = chatMessage->getChatRoom();
if (!chatRoom) {
lError() << "Unable to get a valid chat room. It was removed from database.";
return;
}
const EventLogPrivate *dEventLog = eventLog->getPrivate();
MainDbEventKeyPrivate *dEventKey = dEventLog->dbKey.getPrivate();
long long eventId = dEventKey->storageId;
soci::session *session = dbSession.getBackendSession<soci::session>();
*session << "UPDATE conference_chat_message_event SET state=:state WHERE event_id=:eventId"
, soci::use(static_cast<int>(chatMessage->getState())), soci::use(eventId);
/*for (const Content *content : chatMessage->getContents())
updateContent(eventId, *content);*/
//TODO check if content needs to be inserted, updated or removed
}
long long MainDbPrivate::insertConferenceNotifiedEvent (const shared_ptr<EventLog> &eventLog, long long *chatRoomId) {
long long curChatRoomId;
long long eventId = insertConferenceEvent(eventLog, &curChatRoomId);
@ -1014,6 +1047,53 @@ MainDb::MainDb (const shared_ptr<Core> &core) : AbstractDb(*new MainDbPrivate),
return soFarSoGood;
}
bool MainDb::updateEvent (const shared_ptr<EventLog> &eventLog) {
L_D();
if (!isConnected()) {
lWarning() << "Unable to update event. Not connected.";
return false;
}
const EventLogPrivate *dEventLog = eventLog->getPrivate();
if (!dEventLog->dbKey.isValid()) {
lWarning() << "Unable to update an event that wasn't inserted yet!!!";
return false;
}
L_BEGIN_LOG_EXCEPTION
soci::transaction tr(*d->dbSession.getBackendSession<soci::session>());
switch (eventLog->getType()) {
case EventLog::Type::None:
return false;
case EventLog::Type::ConferenceChatMessage:
d->updateConferenceChatMessageEvent(eventLog);
break;
case EventLog::Type::ConferenceCreated:
case EventLog::Type::ConferenceDestroyed:
case EventLog::Type::ConferenceCallStart:
case EventLog::Type::ConferenceCallEnd:
case EventLog::Type::ConferenceParticipantAdded:
case EventLog::Type::ConferenceParticipantRemoved:
case EventLog::Type::ConferenceParticipantSetAdmin:
case EventLog::Type::ConferenceParticipantUnsetAdmin:
case EventLog::Type::ConferenceParticipantDeviceAdded:
case EventLog::Type::ConferenceParticipantDeviceRemoved:
case EventLog::Type::ConferenceSubjectChanged:
return false;
}
tr.commit();
L_END_LOG_EXCEPTION
return true;
}
bool MainDb::deleteEvent (const shared_ptr<EventLog> &eventLog) {
EventLogPrivate *dEventLog = eventLog->getPrivate();
if (!dEventLog->dbKey.isValid()) {

1
src/db/main-db.h
View file

@ -56,6 +56,7 @@ public:
// ---------------------------------------------------------------------------
bool addEvent (const std::shared_ptr<EventLog> &eventLog);
bool updateEvent (const std::shared_ptr<EventLog> &eventLog);
static bool deleteEvent (const std::shared_ptr<EventLog> &eventLog);
int getEventsCount (FilterMask mask = NoFilter) const;