mirror of
https://github.com/mudita/MuditaOS.git
synced 2026-01-02 10:58:45 -05:00
96 lines
3.3 KiB
C++
96 lines
3.3 KiB
C++
// Copyright (c) 2017-2024, Mudita Sp. z.o.o. All rights reserved.
|
|
// For licensing, see https://github.com/mudita/MuditaOS/LICENSE.md
|
|
|
|
#include "MessagesStyle.hpp"
|
|
#include "SMSdata.hpp"
|
|
#include "ThreadItem.hpp"
|
|
#include "ThreadsModel.hpp"
|
|
#include "ThreadWindowOptions.hpp"
|
|
|
|
#include <InputEvent.hpp>
|
|
#include <ListView.hpp>
|
|
#include <log/log.hpp>
|
|
#include <module-db/queries/messages/threads/QueryThreadsGet.hpp>
|
|
#include <module-db/queries/messages/threads/QueryThreadsGetForList.hpp>
|
|
|
|
ThreadsModel::ThreadsModel(app::ApplicationCommon *app) : BaseThreadsRecordModel(app), app::AsyncCallbackReceiver{app}
|
|
{}
|
|
|
|
auto ThreadsModel::getMinimalItemSpaceRequired() const -> unsigned int
|
|
{
|
|
return style::messages::threadItem::sms_thread_item_h;
|
|
}
|
|
|
|
auto ThreadsModel::getItem(gui::Order order) -> gui::ListItem *
|
|
{
|
|
std::shared_ptr<ThreadListStruct> threadStruct = getRecord(order);
|
|
|
|
if (!threadStruct) {
|
|
return nullptr;
|
|
}
|
|
|
|
auto item = gui::ThreadItem::makeThreadItem(threadStruct);
|
|
|
|
item->activatedCallback = [this, threadStruct](gui::Item &item) {
|
|
if (application) {
|
|
const auto &threadItem = static_cast<gui::ThreadItem &>(item);
|
|
application->switchWindow(
|
|
gui::name::window::thread_view,
|
|
std::make_unique<SMSThreadData>(threadStruct->thread, threadItem.getThreadName()));
|
|
}
|
|
else {
|
|
LOG_ERROR("No application!");
|
|
}
|
|
return true;
|
|
};
|
|
|
|
item->inputCallback = [this, item](gui::Item &, const gui::InputEvent &event) {
|
|
if (!event.isShortRelease()) {
|
|
return false;
|
|
}
|
|
if (event.is(gui::KeyCode::KEY_LF)) {
|
|
application->switchWindow(gui::name::window::thread_options,
|
|
std::make_unique<SMSThreadData>(item->getThreadItem()));
|
|
}
|
|
return false;
|
|
};
|
|
return item;
|
|
}
|
|
|
|
void ThreadsModel::requestRecords(uint32_t offset, uint32_t limit)
|
|
{
|
|
auto query = std::make_unique<db::query::ThreadsGetForList>(offset, limit);
|
|
auto task = app::AsyncQuery::createFromQuery(std::move(query), db::Interface::Name::SMSThread);
|
|
task->setCallback([this](auto response) { return handleQueryResponse(response); });
|
|
task->execute(getApplication(), this);
|
|
}
|
|
|
|
auto ThreadsModel::handleQueryResponse(db::QueryResult *queryResult) -> bool
|
|
{
|
|
auto msgResponse = dynamic_cast<db::query::ThreadsGetForListResults *>(queryResult);
|
|
assert(msgResponse != nullptr);
|
|
|
|
// If list record count has changed we need to rebuild list.
|
|
if (recordsCount != (msgResponse->getCount())) {
|
|
recordsCount = msgResponse->getCount();
|
|
list->reSendLastRebuildRequest();
|
|
return false;
|
|
}
|
|
|
|
auto threads = msgResponse->getResults();
|
|
auto contacts = msgResponse->getContacts();
|
|
auto numbers = msgResponse->getNumbers();
|
|
|
|
std::vector<ThreadListStruct> records;
|
|
|
|
assert(threads.size() == contacts.size() && threads.size() == numbers.size());
|
|
|
|
for (unsigned int i = 0; i < threads.size(); i++) {
|
|
records.emplace_back(std::make_shared<ThreadRecord>(threads[i]),
|
|
std::make_shared<ContactRecord>(contacts[i]),
|
|
std::make_shared<utils::PhoneNumber::View>(numbers[i]));
|
|
}
|
|
|
|
return this->updateRecords(std::move(records));
|
|
}
|