84 lines
2.8 KiB
C++
84 lines
2.8 KiB
C++
#include "nymeaappservice.h"
|
|
#include "androidbinder.h"
|
|
|
|
#include <QtAndroid>
|
|
#include <QDebug>
|
|
#include <QSettings>
|
|
#include <QJsonDocument>
|
|
|
|
#include "connection/discovery/nymeadiscovery.h"
|
|
#include "connection/nymeahosts.h"
|
|
|
|
NymeaAppService::NymeaAppService(int argc, char **argv):
|
|
QAndroidService(argc, argv, [=](const QAndroidIntent &) {
|
|
return new AndroidBinder{this};
|
|
})
|
|
{
|
|
setApplicationName("nymea-app");
|
|
setOrganizationName("nymea");
|
|
|
|
QSettings settings;
|
|
|
|
NymeaDiscovery *discovery = new NymeaDiscovery(this);
|
|
|
|
settings.beginGroup("ConfiguredHosts");
|
|
foreach (const QString &childGroup, settings.childGroups()) {
|
|
settings.beginGroup(childGroup);
|
|
QUuid lastConnected = settings.value("uuid").toUuid();
|
|
QString cachedName = settings.value("cachedName").toString();
|
|
settings.endGroup();
|
|
|
|
if (lastConnected.isNull()) {
|
|
continue;
|
|
}
|
|
NymeaHost *host = discovery->nymeaHosts()->find(lastConnected);
|
|
if (!host) {
|
|
continue;
|
|
}
|
|
|
|
Engine *engine = new Engine(this);
|
|
engine->jsonRpcClient()->connectToHost(host);
|
|
m_engines.insert(host->uuid(), engine);
|
|
|
|
|
|
QObject::connect(engine->thingManager(), &ThingManager::thingStateChanged, [=](const QUuid &thingId, const QUuid &stateTypeId, const QVariant &value){
|
|
QVariantMap params;
|
|
params.insert("nymeaId", engine->jsonRpcClient()->currentHost()->uuid());
|
|
params.insert("thingId", thingId);
|
|
params.insert("stateTypeId", stateTypeId);
|
|
params.insert("value", value);
|
|
sendNotification("ThingStateChanged", params);
|
|
});
|
|
|
|
connect(engine->thingManager(), &ThingManager::fetchingDataChanged, [=]() {
|
|
qDebug() << "Fetching data changed";
|
|
QVariantMap params;
|
|
params.insert("nymeaId", engine->jsonRpcClient()->currentHost()->uuid());
|
|
params.insert("isReady", !engine->thingManager()->fetchingData());
|
|
qDebug() << "Nymea host is ready" << engine->jsonRpcClient()->currentHost()->uuid();
|
|
sendNotification("ReadyStateChanged", params);
|
|
});
|
|
}
|
|
settings.endGroup();
|
|
|
|
qDebug() << "NymeaAppService started.";
|
|
|
|
}
|
|
|
|
QHash<QUuid, Engine *> NymeaAppService::engines() const
|
|
{
|
|
return m_engines;
|
|
}
|
|
|
|
void NymeaAppService::sendNotification(const QString ¬ification, const QVariantMap ¶ms)
|
|
{
|
|
QVariantMap data;
|
|
data.insert("notification", notification);
|
|
data.insert("params", params);
|
|
QString payload = QJsonDocument::fromVariant(data).toJson();
|
|
QtAndroid::androidService().callMethod<void>("sendBroadcast",
|
|
"(Ljava/lang/String;)V",
|
|
QAndroidJniObject::fromString(payload).object<jstring>());
|
|
|
|
}
|