mirror/MuditaOS
1
0
Fork 0
mirror of https://github.com/mudita/MuditaOS.git synced 2026-04-26 10:02:13 -04:00
Code Issues Packages Projects Releases Wiki Activity

WiP: ThreadRecord implementation

Browse Source
This commit is contained in:
Mati
2019-06-04 16:25:26 +02:00
parent 35982af81c
commit 9eebf9f658
2 changed files with 101 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

98
module-db/Interface/ThreadRecord.cpp
View File

@@ -10,3 +10,101 @@
#include "ThreadRecord.hpp"
#include "../Databases/SmsDB.hpp"
bool ThreadRecordInterface::Add(const ThreadRecord &rec) {
auto smsDB = std::make_unique<SmsDB>();
auto ret = smsDB->threads.Add(ThreadsTableRow{
.date = rec.date,
.msgCount=rec.msgCount,
.msgRead=rec.msgRead,
.contactID=rec.contactID,
.snippet=rec.snippet,
.type=rec.type
});
return ret;
}
bool ThreadRecordInterface::RemoveByID(uint32_t id) {
auto smsDB = std::make_unique<SmsDB>();
auto ret = smsDB->threads.RemoveByID(id);
if (ret == false) {
return false;
}
//TODO: remove SMS records from SMS tables
}
bool ThreadRecordInterface::Update(const ThreadRecord &rec) {
auto smsDB = std::make_unique<SmsDB>();
auto ret = smsDB->threads.Update(ThreadsTableRow{
.ID = rec.dbID,
.date = rec.date,
.msgCount=rec.msgCount,
.msgRead=rec.msgRead,
.contactID=rec.contactID,
.snippet=rec.snippet,
.type=rec.type
});
}
uint32_t ThreadRecordInterface::GetCount() {
auto smsDB = std::make_unique<SmsDB>();
return smsDB->threads.GetCount();
}
std::unique_ptr<std::vector<ThreadRecord>> ThreadRecordInterface::GetLimitOffset(uint32_t offset, uint32_t limit) {
auto smsDB = std::make_unique<SmsDB>();
auto records = std::make_unique<std::vector<ThreadRecord>>();
auto ret = smsDB->threads.GetLimitOffset(offset, limit);
for (const auto &w: ret) {
records->push_back(ThreadRecord{
.dbID = w.ID,
.date = w.date,
.msgCount=w.msgCount,
.msgRead=w.msgRead,
.snippet=w.snippet,
.type=w.type,
.contactID=w.contactID
});
}
return records;
}
std::unique_ptr<std::vector<ThreadRecord>> ThreadRecordInterface::GetLimitOffsetByField(uint32_t offset, uint32_t limit,
ContactRecordField field,
const char *str) {
auto smsDB = std::make_unique<SmsDB>();
auto records = std::make_unique<std::vector<ThreadRecord>>();
switch (field) {
case ContactRecordField::Date: {
auto ret = smsDB->threads.GetLimitOffsetByField(offset, limit,ThreadsTableFields::Date,str);
for(const auto &w: ret){
records->push_back(ThreadRecord{
.dbID = w.ID,
.date = w.date,
.msgCount=w.msgCount,
.msgRead=w.msgRead,
.snippet=w.snippet,
.type=w.type,
.contactID=w.contactID
});
}
}
break;
}
}