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

Merge PR #746: Shelly: Improve debug logging when offline

Browse Source
This commit is contained in:
jenkins 2024-10-28 15:26:41 +01:00
commit dcb1cd056e
2 changed files with 29 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
shelly/integrationpluginshelly.cpp
View File

@ -768,19 +768,30 @@ void IntegrationPluginShelly::joinMulticastGroup()
{
if (m_coap->joinMulticastGroup()) {
qCInfo(dcShelly()) << "Joined CoIoT multicast group";
m_multicastWarningPrintCount = 0;
} else {
qCWarning(dcShelly()) << "Failed to join CoIoT multicast group. Retrying in 5 seconds...";
uint mod = m_multicastWarningPrintCount % 120;
// FIXME: It would probably be better to monitor the network interfaces and re-join if necessary
if (m_multicastWarningPrintCount < 12) {
qCWarning(dcShelly()) << "Failed to join CoIoT multicast group. Retrying in 5 seconds...";
}
if (m_multicastWarningPrintCount >= 12 && mod == 0) {
qCWarning(dcShelly()) << "Failed to join CoIoT multicast group. Retrying in 10 minutes...";
}
QTimer::singleShot(5000, m_coap, [this](){
joinMulticastGroup();
});
m_multicastWarningPrintCount++;
}
}
void IntegrationPluginShelly::onMulticastMessageReceived(const QHostAddress &source, const CoapPdu &pdu)
{
Q_UNUSED(source)
// qCDebug(dcShelly()) << "Multicast message received" << source << pdu;
// qCDebug(dcShelly()) << "Multicast message received" << source << pdu;
if (pdu.reqRspCode() != 0x1e) {
// Not a shelly CoIoT status message (ReqRsp code "0.30")
return;
@ -1544,17 +1555,17 @@ void IntegrationPluginShelly::setupGen1(ThingSetupInfo *info)
});
// For testing and debugging, introspect the coap API. Allows introspecting the coap api on the device
// url.clear();
// url.setScheme("coap");
// url.setHost(address.toString());
// url.setPath("/cit/d");
// url.clear();
// url.setScheme("coap");
// url.setHost(address.toString());
// url.setPath("/cit/d");
// CoapRequest coapRequest(url);
// CoapReply *coapReply = m_coap->get(coapRequest);
// qCDebug(dcShelly) << "Coap request" << url;
// connect(coapReply, &CoapReply::finished, thing, [=](){
// qCDebug(dcShelly) << "Coap reply" << coapReply->error() << qUtf8Printable(QJsonDocument::fromJson(coapReply->payload()).toJson());
// });
// CoapRequest coapRequest(url);
// CoapReply *coapReply = m_coap->get(coapRequest);
// qCDebug(dcShelly) << "Coap request" << url;
// connect(coapReply, &CoapReply::finished, thing, [=](){
// qCDebug(dcShelly) << "Coap reply" << coapReply->error() << qUtf8Printable(QJsonDocument::fromJson(coapReply->payload()).toJson());
// });
// Handle thing settings of gateway devices

1
shelly/integrationpluginshelly.h
View File

@ -94,6 +94,7 @@ private:
PluginTimer *m_reconfigureTimer = nullptr;
Coap *m_coap = nullptr;
uint m_multicastWarningPrintCount = 0;
QHash<Thing*, ShellyJsonRpcClient*> m_rpcClients;
};