149 lines
6.9 KiB
C++
149 lines
6.9 KiB
C++
/* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * *
|
|
* *
|
|
* Copyright (C) 2015 Simon Stuerz <simon.stuerz@guh.guru> *
|
|
* Copyright (C) 2014 Michael Zanetti <michael_zanetti@gmx.net> *
|
|
* *
|
|
* This file is part of guh. *
|
|
* *
|
|
* Guh is free software: you can redistribute it and/or modify *
|
|
* it under the terms of the GNU General Public License as published by *
|
|
* the Free Software Foundation, version 2 of the License. *
|
|
* *
|
|
* Guh is distributed in the hope that it will be useful, *
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
|
|
* GNU General Public License for more details. *
|
|
* *
|
|
* You should have received a copy of the GNU General Public License *
|
|
* along with guh. If not, see <http://www.gnu.org/licenses/>. *
|
|
* *
|
|
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
|
|
|
#ifndef GUHCORE_H
|
|
#define GUHCORE_H
|
|
|
|
#include "rule.h"
|
|
#include "types/event.h"
|
|
#include "plugin/deviceplugin.h"
|
|
#include "plugin/deviceclass.h"
|
|
#include "plugin/devicedescriptor.h"
|
|
|
|
#include "devicemanager.h"
|
|
#include "ruleengine.h"
|
|
#include "servermanager.h"
|
|
|
|
#include <QObject>
|
|
#include <QDebug>
|
|
|
|
class Device;
|
|
|
|
namespace guhserver {
|
|
|
|
class JsonRPCServer;
|
|
class LogEngine;
|
|
|
|
class GuhCore : public QObject
|
|
{
|
|
Q_OBJECT
|
|
public:
|
|
enum RunningMode {
|
|
RunningModeApplication,
|
|
RunningModeService
|
|
};
|
|
|
|
static GuhCore* instance();
|
|
~GuhCore();
|
|
|
|
// Used for testing
|
|
void destroy();
|
|
|
|
RunningMode runningMode() const;
|
|
void setRunningMode(const RunningMode &runningMode);
|
|
|
|
QList<DevicePlugin *> plugins() const;
|
|
DeviceManager::DeviceError setPluginConfig(const PluginId &pluginId, const ParamList ¶ms);
|
|
|
|
// Device handling
|
|
QList<Vendor> supportedVendors() const;
|
|
QList<DeviceClass> supportedDevices(const VendorId &vendorId = VendorId()) const;
|
|
DeviceClass findDeviceClass(const DeviceClassId &deviceClassId) const;
|
|
DeviceManager::DeviceError discoverDevices(const DeviceClassId &deviceClassId, const ParamList ¶ms);
|
|
DeviceManager::DeviceError addConfiguredDevice(const DeviceClassId &deviceClassId, const ParamList ¶ms, const DeviceId &newId);
|
|
DeviceManager::DeviceError addConfiguredDevice(const DeviceClassId &deviceClassId, const DeviceDescriptorId &deviceDescriptorId, const DeviceId &newId);
|
|
QList<Device *> configuredDevices() const;
|
|
Device *findConfiguredDevice(const DeviceId &deviceId) const;
|
|
QList<Device *> findConfiguredDevices(const DeviceClassId &deviceClassId) const;
|
|
DeviceManager::DeviceError editDevice(const DeviceId &deviceId, const ParamList ¶ms);
|
|
DeviceManager::DeviceError editDevice(const DeviceId &deviceId, const DeviceDescriptorId &deviceDescriptorId);
|
|
QPair<DeviceManager::DeviceError, QList<RuleId> >removeConfiguredDevice(const DeviceId &deviceId, const QHash<RuleId, RuleEngine::RemovePolicy> &removePolicyList);
|
|
DeviceManager::DeviceError removeConfiguredDevice(const DeviceId &deviceId, const RuleEngine::RemovePolicy &removePolicy);
|
|
|
|
DeviceManager::DeviceError pairDevice(const PairingTransactionId &pairingTransactionId, const DeviceClassId &deviceClassId, const DeviceDescriptorId &deviceDescriptorId);
|
|
DeviceManager::DeviceError pairDevice(const PairingTransactionId &pairingTransactionId, const DeviceClassId &deviceClassId, const ParamList ¶ms);
|
|
DeviceManager::DeviceError confirmPairing(const PairingTransactionId &pairingTransactionId, const QString &secret = QString());
|
|
|
|
DeviceManager::DeviceError executeAction(const Action &action);
|
|
|
|
void executeRuleActions(const QList<RuleAction> ruleActions);
|
|
|
|
QList<Rule> rules() const;
|
|
QList<RuleId> ruleIds() const;
|
|
Rule findRule(const RuleId &ruleId);
|
|
RuleEngine::RuleError addRule(const RuleId &id, const QString &name, const QList<EventDescriptor> &eventDescriptorList, const StateEvaluator &stateEvaluator, const QList<RuleAction> &actionList, const QList<RuleAction> &exitActionList, bool enabled = true, bool executable = true);
|
|
RuleEngine::RuleError editRule(const RuleId &id, const QString &name, const QList<EventDescriptor> &eventDescriptorList, const StateEvaluator &stateEvaluator, const QList<RuleAction> &actionList, const QList<RuleAction> &exitActionList, bool enabled = true, bool executable = true);
|
|
RuleEngine::RuleError removeRule(const RuleId &id);
|
|
QList<RuleId> findRules(const DeviceId &deviceId);
|
|
RuleEngine::RuleError enableRule(const RuleId &ruleId);
|
|
RuleEngine::RuleError disableRule(const RuleId &ruleId);
|
|
RuleEngine::RuleError executeRuleActions(const RuleId &ruleId);
|
|
RuleEngine::RuleError executeRuleExitActions(const RuleId &ruleId);
|
|
|
|
LogEngine* logEngine() const;
|
|
JsonRPCServer *jsonRPCServer() const;
|
|
RestServer *restServer() const;
|
|
DeviceManager *deviceManager() const;
|
|
|
|
signals:
|
|
void eventTriggered(const Event &event);
|
|
void deviceStateChanged(Device *device, const QUuid &stateTypeId, const QVariant &value);
|
|
void deviceRemoved(const DeviceId &deviceId);
|
|
void deviceAdded(Device *device);
|
|
void deviceParamsChanged(Device *device);
|
|
void actionExecuted(const ActionId &id, DeviceManager::DeviceError status);
|
|
|
|
void devicesDiscovered(const DeviceClassId &deviceClassId, const QList<DeviceDescriptor> deviceDescriptors);
|
|
void deviceSetupFinished(Device *device, DeviceManager::DeviceError status);
|
|
void deviceEditFinished(Device *device, DeviceManager::DeviceError status);
|
|
void pairingFinished(const PairingTransactionId &pairingTransactionId, DeviceManager::DeviceError status, const DeviceId &deviceId);
|
|
|
|
void ruleRemoved(const RuleId &ruleId);
|
|
void ruleAdded(const Rule &rule);
|
|
void ruleActiveChanged(const Rule &rule);
|
|
void ruleConfigurationChanged(const Rule &rule);
|
|
|
|
private:
|
|
RuleEngine *ruleEngine() const;
|
|
|
|
explicit GuhCore(QObject *parent = 0);
|
|
static GuhCore *s_instance;
|
|
RunningMode m_runningMode;
|
|
|
|
ServerManager *m_serverManager;
|
|
DeviceManager *m_deviceManager;
|
|
RuleEngine *m_ruleEngine;
|
|
|
|
LogEngine *m_logger;
|
|
|
|
QHash<ActionId, Action> m_pendingActions;
|
|
|
|
private slots:
|
|
void gotEvent(const Event &event);
|
|
void actionExecutionFinished(const ActionId &id, DeviceManager::DeviceError status);
|
|
|
|
friend class GuhTestBase;
|
|
};
|
|
|
|
}
|
|
|
|
#endif // GUHCORE_H
|