experiments with avea

This commit is contained in:
Simon Stürz 2015-04-01 13:55:11 +02:00 committed by Michael Zanetti
parent 549a2c8402
commit e0dc6f2c84
8 changed files with 198 additions and 31 deletions

View File

@ -50,6 +50,12 @@ void BluetoothLowEnergyDevice::connectDevice()
m_controller->connectToDevice(); m_controller->connectToDevice();
} }
void BluetoothLowEnergyDevice::reconnectDevice()
{
if (!isConnected())
m_controller->connectToDevice();
}
void BluetoothLowEnergyDevice::disconnectDevice() void BluetoothLowEnergyDevice::disconnectDevice()
{ {
m_controller->disconnectFromDevice(); m_controller->disconnectFromDevice();
@ -63,8 +69,9 @@ bool BluetoothLowEnergyDevice::isConnected() const
void BluetoothLowEnergyDevice::connected() void BluetoothLowEnergyDevice::connected()
{ {
m_connected = true; m_connected = true;
qDebug() << "connected successfully to bluetooth LE device:" << name() << address().toString(); qDebug() << "connected to bluetooth LE device:" << name() << address().toString();
emit connectionStatusChanged(); emit connectionStatusChanged();
qDebug() << "discover services...";
m_controller->discoverServices(); m_controller->discoverServices();
} }
@ -77,5 +84,6 @@ void BluetoothLowEnergyDevice::disconnected()
void BluetoothLowEnergyDevice::deviceError(const QLowEnergyController::Error &error) void BluetoothLowEnergyDevice::deviceError(const QLowEnergyController::Error &error)
{ {
qWarning() << "ERROR: Bluetooth LE device:" << name() << address().toString() << ": " << error << m_controller->errorString(); if (isConnected())
qWarning() << "ERROR: Bluetooth LE device:" << name() << address().toString() << ": " << error << m_controller->errorString();
} }

View File

@ -35,6 +35,7 @@ public:
QBluetoothAddress address() const; QBluetoothAddress address() const;
void connectDevice(); void connectDevice();
void reconnectDevice();
void disconnectDevice(); void disconnectDevice();
bool isConnected() const; bool isConnected() const;

View File

@ -3,11 +3,15 @@
AveaBulb::AveaBulb(const QBluetoothDeviceInfo &deviceInfo, const QLowEnergyController::RemoteAddressType &addressType, QObject *parent) : AveaBulb::AveaBulb(const QBluetoothDeviceInfo &deviceInfo, const QLowEnergyController::RemoteAddressType &addressType, QObject *parent) :
BluetoothLowEnergyDevice(deviceInfo, addressType, parent), BluetoothLowEnergyDevice(deviceInfo, addressType, parent),
m_colorService(0) m_colorService(0),
m_imageService(0)
{ {
m_colorSeviceUuid = QBluetoothUuid(QUuid("f815e810-456c-6761-746f-4d756e696368")); m_colorSeviceUuid = QBluetoothUuid(QUuid("f815e810-456c-6761-746f-4d756e696368"));
m_colorCharacteristicUuid = QBluetoothUuid(QUuid("f815e811-456c-6761-746f-4d756e696368")); m_colorCharacteristicUuid = QBluetoothUuid(QUuid("f815e811-456c-6761-746f-4d756e696368"));
m_imageSeviceUuid = QBluetoothUuid(QUuid("f815e500-456c-6761-746f-4d756e696368"));
m_imageCharacteristicUuid = QBluetoothUuid(QUuid("f815e501-456c-6761-746f-4d756e696368"));
connect(this, SIGNAL(connectionStatusChanged()), this,SLOT(onConnectionStatusChanged())); connect(this, SIGNAL(connectionStatusChanged()), this,SLOT(onConnectionStatusChanged()));
connect(this, SIGNAL(servicesDiscoveryFinished()), this, SLOT(serviceScanFinished())); connect(this, SIGNAL(servicesDiscoveryFinished()), this, SLOT(serviceScanFinished()));
} }
@ -24,12 +28,12 @@ void AveaBulb::serviceScanFinished()
return; return;
} }
if (m_colorService) { if (m_colorService || m_imageService) {
qWarning() << "ERROR: Attention! bad implementation of service handling!!"; qWarning() << "ERROR: Attention! bad implementation of service handling!!";
return; return;
} }
// create color service and discover it // service for colors
m_colorService = controller()->createServiceObject(m_colorSeviceUuid, this); m_colorService = controller()->createServiceObject(m_colorSeviceUuid, this);
if (!m_colorService) { if (!m_colorService) {
@ -38,20 +42,39 @@ void AveaBulb::serviceScanFinished()
} }
connect(m_colorService, SIGNAL(stateChanged(QLowEnergyService::ServiceState)), this, SLOT(serviceStateChanged(QLowEnergyService::ServiceState))); connect(m_colorService, SIGNAL(stateChanged(QLowEnergyService::ServiceState)), this, SLOT(serviceStateChanged(QLowEnergyService::ServiceState)));
connect(m_colorService, SIGNAL(characteristicChanged(QLowEnergyCharacteristic,QByteArray)), this, SLOT(serviceCharacteristicChanged(QLowEnergyCharacteristic,QByteArray))); connect(m_colorService, SIGNAL(characteristicChanged(QLowEnergyCharacteristic, QByteArray)), this, SLOT(serviceCharacteristicChanged(QLowEnergyCharacteristic, QByteArray)));
connect(m_colorService, SIGNAL(characteristicWritten(QLowEnergyCharacteristic,QByteArray)), this, SLOT(confirmedCharacteristicWritten(QLowEnergyCharacteristic,QByteArray))); connect(m_colorService, SIGNAL(characteristicWritten(QLowEnergyCharacteristic, QByteArray)), this, SLOT(confirmedCharacteristicWritten(QLowEnergyCharacteristic, QByteArray)));
connect(m_colorService, SIGNAL(descriptorWritten(QLowEnergyDescriptor, QByteArray)), this, SLOT(confirmedDescriptorWritten(QLowEnergyDescriptor, QByteArray)));
connect(m_colorService, SIGNAL(error(QLowEnergyService::ServiceError)), this, SLOT(serviceError(QLowEnergyService::ServiceError))); connect(m_colorService, SIGNAL(error(QLowEnergyService::ServiceError)), this, SLOT(serviceError(QLowEnergyService::ServiceError)));
// service for images
m_imageService = controller()->createServiceObject(m_imageSeviceUuid, this);
if (!m_imageService) {
qWarning() << "ERROR: could not create color service for device" << name() << address().toString();
return;
}
connect(m_imageService, SIGNAL(stateChanged(QLowEnergyService::ServiceState)), this, SLOT(serviceStateChanged(QLowEnergyService::ServiceState)));
connect(m_imageService, SIGNAL(characteristicChanged(QLowEnergyCharacteristic, QByteArray)), this, SLOT(serviceCharacteristicChanged(QLowEnergyCharacteristic, QByteArray)));
connect(m_imageService, SIGNAL(characteristicWritten(QLowEnergyCharacteristic, QByteArray)), this, SLOT(confirmedCharacteristicWritten(QLowEnergyCharacteristic, QByteArray)));
connect(m_imageService, SIGNAL(descriptorWritten(QLowEnergyDescriptor, QByteArray)), this, SLOT(confirmedDescriptorWritten(QLowEnergyDescriptor, QByteArray)));
connect(m_imageService, SIGNAL(error(QLowEnergyService::ServiceError)), this, SLOT(serviceError(QLowEnergyService::ServiceError)));
m_colorService->discoverDetails(); m_colorService->discoverDetails();
} }
void AveaBulb::onConnectionStatusChanged() void AveaBulb::onConnectionStatusChanged()
{ {
if (!isConnected()) { if (!isConnected()) {
// delete the service, needs to be recreatedand rediscovered once the device will be reconnected // delete the services, they need to be recreated and
// rediscovered once the device will be reconnected
delete m_colorService; delete m_colorService;
m_colorService = 0; m_colorService = 0;
delete m_imageService;
m_imageService = 0;
m_isAvailable = false; m_isAvailable = false;
emit availableChanged(); emit availableChanged();
} }
@ -59,16 +82,45 @@ void AveaBulb::onConnectionStatusChanged()
void AveaBulb::serviceStateChanged(const QLowEnergyService::ServiceState &state) void AveaBulb::serviceStateChanged(const QLowEnergyService::ServiceState &state)
{ {
switch (state) { QLowEnergyService *service =static_cast<QLowEnergyService *>(sender());
case QLowEnergyService::ServiceDiscovered:
m_colorCharacteristic = m_colorService->characteristic(m_colorCharacteristicUuid);
if (!m_colorCharacteristic.isValid()) { switch (state) {
qWarning() << "ERROR: color characteristc not found for device " << name() << address().toString(); case QLowEnergyService::DiscoveringServices:
return; if (service->serviceUuid() == m_colorService->serviceUuid()) {
qDebug() << "start discovering color service...";
} else if (service->serviceUuid() == m_imageService->serviceUuid()) {
qDebug() << "start discovering image service...";
}
break;
case QLowEnergyService::ServiceDiscovered:
// check which service is discovered
if (service->serviceUuid() == m_colorService->serviceUuid()) {
qDebug() << "...color service discovered.";
m_colorCharacteristic = m_colorService->characteristic(m_colorCharacteristicUuid);
if (!m_colorCharacteristic.isValid()) {
qWarning() << "ERROR: color characteristc not found for device " << name() << address().toString();
return;
}
m_imageService->discoverDetails();
}
if (service->serviceUuid() == m_imageService->serviceUuid()) {
qDebug() << "...image service discovered.";
m_imageCharacteristic = m_imageService->characteristic(m_imageCharacteristicUuid);
if (!m_imageCharacteristic.isValid()) {
qWarning() << "ERROR: image characteristc not found for device " << name() << address().toString();
return;
}
}
if (m_colorService->state() == QLowEnergyService::ServiceDiscovered && m_imageService->state() == QLowEnergyService::ServiceDiscovered) {
m_isAvailable = true;
emit availableChanged();
} }
m_isAvailable = true;
emit availableChanged();
break; break;
default: default:
break; break;
@ -83,16 +135,43 @@ void AveaBulb::serviceCharacteristicChanged(const QLowEnergyCharacteristic &char
void AveaBulb::confirmedCharacteristicWritten(const QLowEnergyCharacteristic &characteristic, const QByteArray &value) void AveaBulb::confirmedCharacteristicWritten(const QLowEnergyCharacteristic &characteristic, const QByteArray &value)
{ {
if (characteristic.handle() == m_colorCharacteristic.handle()) { if (characteristic.handle() == m_colorCharacteristic.handle()) {
qDebug() << "color char written successfully" << value.toHex();
if (m_actions.contains(value.toHex())) { if (m_actions.contains(value.toHex())) {
ActionId actionId = m_actions.take(value.toHex()); ActionId actionId = m_actions.take(value.toHex());
emit actionExecutionFinished(actionId, true); emit actionExecutionFinished(actionId, true);
} }
} else if (characteristic.handle() == m_imageCharacteristic.handle()) {
qDebug() << "image char written successfully" << value.toHex();
} }
}
void AveaBulb::confirmedDescriptorWritten(const QLowEnergyDescriptor &descriptor, const QByteArray &value)
{
qDebug() << "descriptor:" << descriptor.name() << "value:" << value.toHex() << "written successfully";
} }
void AveaBulb::serviceError(const QLowEnergyService::ServiceError &error) void AveaBulb::serviceError(const QLowEnergyService::ServiceError &error)
{ {
qWarning() << "ERROR: color service of " << name() << address().toString() << ":" << error; QString errorString;
switch (error) {
case QLowEnergyService::NoError:
errorString = "No error";
break;
case QLowEnergyService::OperationError:
errorString = "Operation error";
break;
case QLowEnergyService::CharacteristicWriteError:
errorString = "Characteristic write error";
break;
case QLowEnergyService::DescriptorWriteError:
errorString = "Descriptor write error";
break;
default:
break;
}
qWarning() << "ERROR: color service of " << name() << address().toString() << ":" << errorString;
} }
bool AveaBulb::enableNotification() bool AveaBulb::enableNotification()
@ -101,8 +180,7 @@ bool AveaBulb::enableNotification()
return false; return false;
qDebug() << "enable notify"; qDebug() << "enable notify";
QByteArray value = "0100"; m_colorService->writeCharacteristic(m_colorCharacteristic, QByteArray::fromHex("0100"), QLowEnergyService::WriteWithResponse);
m_colorService->writeCharacteristic(m_colorCharacteristic, value, QLowEnergyService::WriteWithResponse);
return true; return true;
} }
@ -112,10 +190,7 @@ bool AveaBulb::testMethod()
if (!isAvailable()) if (!isAvailable())
return false; return false;
QByteArray value = "34"; setZauberwald();
qDebug() << "test" << value;
m_colorService->writeCharacteristic(m_colorCharacteristic, QByteArray::fromHex(value), QLowEnergyService::WriteWithResponse);
return true; return true;
} }
@ -144,3 +219,44 @@ bool AveaBulb::setWhite(ActionId actionId)
return true; return true;
} }
bool AveaBulb::setZauberwald()
{
if (!isAvailable())
return false;
m_colorService->writeCharacteristic(m_colorCharacteristic, QByteArray::fromHex("340040143058220010"), QLowEnergyService::WriteWithResponse);
QByteArray value = "1500cd0110cd0020cd0030cd2850cd5842cd14608d0a0ecd04708216c200a04d";
m_imageService->writeCharacteristic(m_imageCharacteristic, QByteArray::fromHex(value), QLowEnergyService::WriteWithResponse);
value = "1600cd0210cd1280a1646301cd14608d080e"
"cd9041f190017402b564f200608d0a7d0ecd"
"6851b1c87402b564f200608d0a7d0ecdff47"
"cd6450cdb470823c44028564c200604d8d0a"
"0ecd17a0";
m_imageService->writeCharacteristic(m_imageCharacteristic, QByteArray::fromHex(value), QLowEnergyService::WriteWithResponse);
value = "1700cd0310cd1280a1646301cde041cd2850"
"b1f07402b564f200608d0a7d0ecd04708216"
"c200a04d";
m_imageService->writeCharacteristic(m_imageCharacteristic, QByteArray::fromHex(value), QLowEnergyService::WriteWithResponse);
value = "1800cd0410cd1280a1646301cdb841cdb470"
"823c7402b564c200604d8d0a0ecd0e41cd28"
"50b1c87402b564f200608d0a7d0ecd6440f1"
"90017402b564f200608d0a7d0e8d0a0ecd04"
"708216c200a04d";
m_imageService->writeCharacteristic(m_imageCharacteristic, QByteArray::fromHex(value), QLowEnergyService::WriteWithResponse);
value = "1900cd0510cd1280a1646301cd6841cdb470"
"823cc200604d8d0a0ecda050f12c017402b5"
"64f200608d0a7d0ecdf040cd2850f1680174"
"02b564f200608d0a7d0ecdcc41b1c87402b5"
"64f200608d0a7d0ecd04708216c200a04d";
m_imageService->writeCharacteristic(m_imageCharacteristic, QByteArray::fromHex(value), QLowEnergyService::WriteWithResponse);
m_colorService->writeCharacteristic(m_colorCharacteristic, QByteArray::fromHex("2a15"), QLowEnergyService::WriteWithResponse);
return true;
}

View File

@ -21,6 +21,12 @@ private:
QBluetoothUuid m_colorSeviceUuid; QBluetoothUuid m_colorSeviceUuid;
QLowEnergyService *m_colorService; QLowEnergyService *m_colorService;
QBluetoothUuid m_imageSeviceUuid;
QLowEnergyService *m_imageService;
QBluetoothUuid m_imageCharacteristicUuid;
QLowEnergyCharacteristic m_imageCharacteristic;
QBluetoothUuid m_colorCharacteristicUuid; QBluetoothUuid m_colorCharacteristicUuid;
QLowEnergyCharacteristic m_colorCharacteristic; QLowEnergyCharacteristic m_colorCharacteristic;
@ -36,16 +42,17 @@ private slots:
void serviceStateChanged(const QLowEnergyService::ServiceState &state); void serviceStateChanged(const QLowEnergyService::ServiceState &state);
void serviceCharacteristicChanged(const QLowEnergyCharacteristic &characteristic, const QByteArray &value); void serviceCharacteristicChanged(const QLowEnergyCharacteristic &characteristic, const QByteArray &value);
void confirmedCharacteristicWritten(const QLowEnergyCharacteristic &characteristic, const QByteArray &value); void confirmedCharacteristicWritten(const QLowEnergyCharacteristic &characteristic, const QByteArray &value);
void confirmedDescriptorWritten(const QLowEnergyDescriptor &descriptor, const QByteArray &value);
void serviceError(const QLowEnergyService::ServiceError &error); void serviceError(const QLowEnergyService::ServiceError &error);
bool enableNotification();
bool testMethod();
public slots: public slots:
bool enableNotification();
bool testMethod();
// actions // actions
bool actionPowerOff(ActionId actionId); bool actionPowerOff(ActionId actionId);
bool setWhite(ActionId actionId); bool setWhite(ActionId actionId);
bool setZauberwald();
}; };
#endif // AVEABULB_H #endif // AVEABULB_H

View File

@ -450,6 +450,12 @@ DeviceManager::DeviceError DevicePluginElgato::executeAction(Device *device, con
if (device->deviceClassId() == aveaDeviceClassId) { if (device->deviceClassId() == aveaDeviceClassId) {
AveaBulb *bulb = m_bulbs.key(device); AveaBulb *bulb = m_bulbs.key(device);
// reconnect action does not need available true
if (action.actionTypeId() == reconnectActionTypeId) {
bulb->reconnectDevice();
return DeviceManager::DeviceErrorNoError;
}
// check available
if (!bulb->isAvailable()) if (!bulb->isAvailable())
return DeviceManager::DeviceErrorHardwareNotAvailable; return DeviceManager::DeviceErrorHardwareNotAvailable;
@ -458,9 +464,10 @@ DeviceManager::DeviceError DevicePluginElgato::executeAction(Device *device, con
bulb->actionPowerOff(action.id()); bulb->actionPowerOff(action.id());
return DeviceManager::DeviceErrorAsync; return DeviceManager::DeviceErrorAsync;
} else if (action.actionTypeId() == whiteActionTypeId) { } else if (action.actionTypeId() == whiteActionTypeId) {
bulb->setWhite(action.id()); bulb->testMethod();
return DeviceManager::DeviceErrorAsync; return DeviceManager::DeviceErrorAsync;
} }
return DeviceManager::DeviceErrorActionTypeNotFound; return DeviceManager::DeviceErrorActionTypeNotFound;
} }
return DeviceManager::DeviceErrorDeviceClassNotFound; return DeviceManager::DeviceErrorDeviceClassNotFound;
@ -511,6 +518,10 @@ void DevicePluginElgato::bulbAvailableChanged()
AveaBulb *bulb =static_cast<AveaBulb *>(sender()); AveaBulb *bulb =static_cast<AveaBulb *>(sender());
Device *device = m_bulbs.value(bulb); Device *device = m_bulbs.value(bulb);
device->setStateValue(availableStateTypeId, bulb->isAvailable()); device->setStateValue(availableStateTypeId, bulb->isAvailable());
if (bulb->isAvailable()) {
bulb->testMethod();
}
} }
void DevicePluginElgato::actionFinished(const ActionId actionId, const bool &success) void DevicePluginElgato::actionFinished(const ActionId actionId, const bool &success)

View File

@ -2,15 +2,15 @@ include(../../plugins.pri)
TARGET = $$qtLibraryTarget(guh_devicepluginelgato) TARGET = $$qtLibraryTarget(guh_devicepluginelgato)
QT+= bluetooth
SOURCES += \ SOURCES += \
devicepluginelgato.cpp \ devicepluginelgato.cpp \
aveabulb.cpp aveabulb.cpp \
imagefairywoods.cpp
HEADERS += \ HEADERS += \
devicepluginelgato.h \ devicepluginelgato.h \
aveabulb.h aveabulb.h \
imagefairywoods.h

View File

@ -0,0 +1,6 @@
#include "imagefairywoods.h"
ImageFairyWoods::ImageFairyWoods(QObject *parent) :
QObject(parent)
{
}

View File

@ -0,0 +1,18 @@
#ifndef IMAGEFAIRYWOODS_H
#define IMAGEFAIRYWOODS_H
#include <QObject>
class ImageFairyWoods : public QObject
{
Q_OBJECT
public:
explicit ImageFairyWoods(QObject *parent = 0);
signals:
public slots:
};
#endif // IMAGEFAIRYWOODS_H