ETM-Schurig/powersync-core
Archived
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

check for duplicates when an update comes in

Browse Source
This commit is contained in:
Michael Zanetti 2018-09-20 20:31:27 +02:00
parent f243d383e4
commit c7f4dda9d3
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
libnymea-core/cloud/cloudnotifications.cpp
View File

@ -137,10 +137,11 @@ QJsonObject CloudNotifications::metaData() const
DeviceManager::DeviceSetupStatus CloudNotifications::setupDevice(Device *device) DeviceManager::DeviceSetupStatus CloudNotifications::setupDevice(Device *device)
{ {
device->setStateValue(connectedStateTypeId, m_awsConnector->isConnected()); device->setStateValue(connectedStateTypeId, m_awsConnector->isConnected());
connect(m_awsConnector, &AWSConnector::connected, device, [this, device]() { qCDebug(dcCloud) << "Cloud Notifications Device setup:" << device->name() << "Connected:" << m_awsConnector->isConnected();
connect(m_awsConnector, &AWSConnector::connected, device, [device]() {
device->setStateValue(connectedStateTypeId, true); device->setStateValue(connectedStateTypeId, true);
}); });
connect(m_awsConnector, &AWSConnector::disconnected, device, [this, device]() { connect(m_awsConnector, &AWSConnector::disconnected, device, [device]() {
device->setStateValue(connectedStateTypeId, false); device->setStateValue(connectedStateTypeId, false);
}); });
return DeviceManager::DeviceSetupStatusSuccess; return DeviceManager::DeviceSetupStatusSuccess;
@ -184,7 +185,9 @@ void CloudNotifications::pushNotificationEndpointsUpdated(const QList<AWSConnect
QList<DeviceDescriptor> devicesToAdd; QList<DeviceDescriptor> devicesToAdd;
foreach (const AWSConnector::PushNotificationsEndpoint &ep, endpoints) { foreach (const AWSConnector::PushNotificationsEndpoint &ep, endpoints) {
bool found = false; bool found = false;
qCDebug(dcCloud) << "Checking endoint:" << ep.endpointId;
foreach (Device *d, myDevices()) { foreach (Device *d, myDevices()) {
qCDebug(dcCloud) << "Have existing device:" << d->name() << d->paramValue(cloudNotificationsDeviceClassEndpointParamId);
if (d->paramValue(cloudNotificationsDeviceClassUserParamId).toString() == ep.userId if (d->paramValue(cloudNotificationsDeviceClassUserParamId).toString() == ep.userId
&& d->paramValue(cloudNotificationsDeviceClassEndpointParamId).toString() == ep.endpointId) { && d->paramValue(cloudNotificationsDeviceClassEndpointParamId).toString() == ep.endpointId) {
found = true; found = true;
@ -209,6 +212,14 @@ void CloudNotifications::pushNotificationEndpointsUpdated(const QList<AWSConnect
void CloudNotifications::pushNotificationEndpointAdded(const AWSConnector::PushNotificationsEndpoint &endpoint) void CloudNotifications::pushNotificationEndpointAdded(const AWSConnector::PushNotificationsEndpoint &endpoint)
{ {
// Could be just an update, don't add it in that case...
foreach (Device *d, myDevices()) {
if (d->paramValue(cloudNotificationsDeviceClassUserParamId).toString() == endpoint.userId
&& d->paramValue(cloudNotificationsDeviceClassEndpointParamId).toString() == endpoint.endpointId) {
return;
}
}
qCDebug(dcCloud) << "Push notification endpoint added:" << endpoint.displayName;
DeviceDescriptor descriptor(cloudNotificationsDeviceClassId, endpoint.displayName, QString("Send notifications to %1").arg(endpoint.displayName)); DeviceDescriptor descriptor(cloudNotificationsDeviceClassId, endpoint.displayName, QString("Send notifications to %1").arg(endpoint.displayName));
ParamList params; ParamList params;
Param userIdParam(cloudNotificationsDeviceClassUserParamId, endpoint.userId); Param userIdParam(cloudNotificationsDeviceClassUserParamId, endpoint.userId);