mirror of
https://github.com/mudita/MuditaOS.git
synced 2026-05-24 16:47:00 -04:00
4ad0f29ab4
Fix of the issue that GUI would freeze for several seconds if volume level was being changed intensively for a while.
78 lines
2.5 KiB
C++
78 lines
2.5 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 <service-db/EntryPath.hpp>
|
|
#include <service-db/SettingsMessages.hpp>
|
|
#include <service-db/Settings.hpp>
|
|
#include <service-db/SettingsCache.hpp>
|
|
#include <service-db/DBServiceName.hpp>
|
|
#include <Service/ServiceProxy.hpp>
|
|
#include <Service/Service.hpp>
|
|
#include <utility>
|
|
|
|
namespace settings
|
|
{
|
|
SettingsProxy::SettingsProxy(const service::ServiceProxy &interface) : service::ServiceProxy(interface)
|
|
{}
|
|
|
|
SettingsProxy::~SettingsProxy()
|
|
{
|
|
deinit();
|
|
}
|
|
|
|
std::string SettingsProxy::ownerName()
|
|
{
|
|
return getService()->GetName();
|
|
}
|
|
|
|
void SettingsProxy::init(std::function<void(EntryPath, std::string)> onChangeHandler)
|
|
{
|
|
this->onChangeHandler = std::move(onChangeHandler);
|
|
|
|
getService()->bus.channels.push_back(sys::BusChannel::ServiceDBNotifications);
|
|
getService()->connect(typeid(settings::Messages::VariableChanged), [this](sys::Message *req) {
|
|
if (auto msg = dynamic_cast<settings::Messages::VariableChanged *>(req)) {
|
|
onChange(msg->getPath(), msg->getValue().value_or(""));
|
|
}
|
|
return std::make_shared<sys::ResponseMessage>();
|
|
});
|
|
}
|
|
|
|
void SettingsProxy::deinit()
|
|
{
|
|
if (isValid()) {
|
|
getService()->disconnect(typeid(settings::Messages::VariableChanged));
|
|
}
|
|
}
|
|
|
|
[[nodiscard]] bool SettingsProxy::isValid() const noexcept
|
|
{
|
|
return service::ServiceProxy::isValid();
|
|
}
|
|
|
|
void SettingsProxy::onChange(EntryPath path, std::string value)
|
|
{
|
|
if (onChangeHandler) {
|
|
onChangeHandler(std::move(path), std::move(value));
|
|
}
|
|
}
|
|
|
|
void SettingsProxy::registerValueChange(EntryPath path)
|
|
{
|
|
auto msg = std::make_shared<Messages::RegisterOnVariableChange>(std::move(path));
|
|
getService()->bus.sendUnicast(std::move(msg), service::name::db);
|
|
}
|
|
|
|
void SettingsProxy::unregisterValueChange(EntryPath path)
|
|
{
|
|
auto msg = std::make_shared<Messages::UnregisterOnVariableChange>(std::move(path));
|
|
getService()->bus.sendUnicast(std::move(msg), service::name::db);
|
|
}
|
|
|
|
void SettingsProxy::setValue(const EntryPath &path, const std::string &value)
|
|
{
|
|
auto msg = std::make_shared<Messages::SetVariable>(path, value);
|
|
getService()->bus.sendUnicast(std::move(msg), service::name::db);
|
|
}
|
|
} // namespace settings
|