// Copyright (c) 2017-2022, Mudita Sp. z.o.o. All rights reserved.
// For licensing, see https://github.com/mudita/MuditaOS/LICENSE.md
#include "CalllogTable.hpp"
#include <log/log.hpp>
#include <Utils.hpp>
CalllogTable::CalllogTable(Database *db) : Table(db)
{}
CalllogTable::~CalllogTable()
{}
bool CalllogTable::create()
{
return true;
}
bool CalllogTable::add(CalllogTableRow entry)
{
return db->execute(
"INSERT or ignore INTO calls (number, e164number, presentation, date, duration, type, name, contactId, "
"isRead) VALUES ('%q', '%q', %lu, %q, %q, %lu, '%q', '%lu', %d);",
entry.number.c_str(),
entry.e164number.c_str(),
static_cast<uint32_t>(entry.presentation),
utils::to_string(entry.date).c_str(),
utils::to_string(entry.duration).c_str(),
static_cast<uint32_t>(entry.type),
entry.name.c_str(),
entry.contactId,
entry.isRead);
}
bool CalllogTable::removeById(uint32_t id)
{
return db->execute("DELETE FROM calls where _id = %lu;", id);
}
bool CalllogTable::removeByField(CalllogTableFields field, const char *str)
{
return false; // not implemented // TODO: alek: check this
}
bool CalllogTable::update(CalllogTableRow entry)
{
return db->execute("UPDATE calls SET number = '%q', e164number = '%q', presentation = %lu, date = %lu, duration = "
"%lu, type = %lu, "
"name = '%q', contactId = '%u', isRead = "
"%d WHERE _id = %lu;",
entry.number.c_str(),
entry.e164number.c_str(),
static_cast<uint32_t>(entry.presentation),
static_cast<uint32_t>(entry.date),
static_cast<uint32_t>(entry.duration),
static_cast<uint32_t>(entry.type),
entry.name.c_str(),
entry.contactId,
entry.isRead,
entry.ID);
}
CalllogTableRow CalllogTable::getById(uint32_t id)
{
auto retQuery = db->query("SELECT * FROM calls WHERE _id= %u;", id);
if ((retQuery == nullptr) || (retQuery->getRowCount() == 0)) {
return CalllogTableRow();
}
return CalllogTableRow{
{(*retQuery)[0].getUInt32()}, // ID
(*retQuery)[1].getString(), // number
(*retQuery)[2].getString(), // e164number
static_cast<PresentationType>((*retQuery)[3].getUInt32()), // presentation
static_cast<time_t>((*retQuery)[4].getUInt64()), // date
static_cast<time_t>((*retQuery)[5].getUInt64()), // duration
static_cast<CallType>((*retQuery)[6].getUInt32()), // type
(*retQuery)[7].getString(), // name
(*retQuery)[8].getUInt32(), // contactID
static_cast<bool>((*retQuery)[9].getUInt64()), // isRead
};
}
std::vector<CalllogTableRow> CalllogTable::getByContactId(uint32_t id)
{
auto retQuery = db->query("SELECT * FROM calls WHERE contactId= %lu;", id);
if ((retQuery == nullptr) || (retQuery->getRowCount() == 0)) {
return std::vector<CalllogTableRow>();
}
std::vector<CalllogTableRow> ret;
do {
ret.push_back(CalllogTableRow{
{(*retQuery)[0].getUInt32()}, // ID
(*retQuery)[1].getString(), // number
(*retQuery)[2].getString(), // e164number
static_cast<PresentationType>((*retQuery)[3].getUInt32()), // presentation
static_cast<time_t>((*retQuery)[4].getUInt64()), // date
static_cast<time_t>((*retQuery)[5].getUInt64()), // duration
static_cast<CallType>((*retQuery)[6].getUInt32()), // type
(*retQuery)[7].getString(), // name
(*retQuery)[8].getUInt32(), // contactID
static_cast<bool>((*retQuery)[9].getUInt64()), // isRead
});
} while (retQuery->nextRow());
return ret;
}
std::vector<CalllogTableRow> CalllogTable::getLimitOffset(uint32_t offset, uint32_t limit)
{
auto retQuery = db->query("SELECT * from calls ORDER BY date DESC LIMIT %lu OFFSET %lu;", limit, offset);
if ((retQuery == nullptr) || (retQuery->getRowCount() == 0)) {
return std::vector<CalllogTableRow>();
}
std::vector<CalllogTableRow> ret;
do {
ret.push_back(CalllogTableRow{
{(*retQuery)[0].getUInt32()}, // ID
(*retQuery)[1].getString(), // number
(*retQuery)[2].getString(), // e164number
static_cast<PresentationType>((*retQuery)[3].getUInt32()), // presentation
static_cast<time_t>((*retQuery)[4].getUInt64()), // date
static_cast<time_t>((*retQuery)[5].getUInt64()), // duration
static_cast<CallType>((*retQuery)[6].getUInt32()), // type
(*retQuery)[7].getString(), // name
(*retQuery)[8].getUInt32(), // contactID
static_cast<bool>((*retQuery)[9].getUInt64()), // isRead
});
} while (retQuery->nextRow());
return ret;
}
std::vector<CalllogTableRow> CalllogTable::getLimitOffsetByField(uint32_t offset,
uint32_t limit,
CalllogTableFields field,
const char *str)
{
std::string fieldName; // TODO: alek: add more fields?
switch (field) {
case CalllogTableFields::DATE:
fieldName = "date";
break;
case CalllogTableFields::TYPE:
fieldName = "type";
break;
default:
return std::vector<CalllogTableRow>();
}
auto retQuery = db->query(
"SELECT * from calls WHERE %q='%q' ORDER BY date LIMIT %lu OFFSET %lu;", fieldName.c_str(), str, limit, offset);
if ((retQuery == nullptr) || (retQuery->getRowCount() == 0)) {
return std::vector<CalllogTableRow>();
}
std::vector<CalllogTableRow> ret;
do {
ret.push_back(CalllogTableRow{
{(*retQuery)[0].getUInt32()}, // ID
(*retQuery)[1].getString(), // number
(*retQuery)[2].getString(), // e164number
static_cast<PresentationType>((*retQuery)[3].getUInt32()), // presentation
static_cast<time_t>((*retQuery)[4].getUInt64()), // date
static_cast<time_t>((*retQuery)[5].getUInt64()), // duration
static_cast<CallType>((*retQuery)[6].getUInt32()), // type
(*retQuery)[7].getString(), // name
(*retQuery)[8].getUInt32(), // contactID
static_cast<bool>((*retQuery)[9].getUInt64()), // isRead
});
} while (retQuery->nextRow());
return ret;
}
uint32_t CalllogTable::count(EntryState state)
{
std::string query = "SELECT COUNT(*) FROM calls ";
switch (state) {
case EntryState::ALL:
break;
case EntryState::UNREAD:
query += "WHERE calls.isRead = 0";
break;
case EntryState::READ:
query += "WHERE calls.isRead = 1";
break;
}
query += ";";
auto queryRet = db->query(query.c_str());
if (queryRet == nullptr || queryRet->getRowCount() == 0) {
return 0;
}
return uint32_t{(*queryRet)[0].getUInt32()};
}
uint32_t CalllogTable::count()
{
return count(EntryState::ALL);
}
uint32_t CalllogTable::countByFieldId(const char *field, uint32_t id)
{
auto queryRet = db->query("SELECT COUNT(*) FROM calls WHERE %q=%lu;", field, id);
if ((queryRet == nullptr) || (queryRet->getRowCount() == 0)) {
return 0;
}
return uint32_t{(*queryRet)[0].getUInt32()};
}
bool CalllogTable::SetAllRead()
{
return db->execute("UPDATE calls SET isRead = 1;");
}
bool CalllogTable::DeleteAll()
{
return db->execute("DELETE FROM calls;");
}