Fixed UDP

Author: sivar2311

src/SinricPro.h

@@ -140,6 +140,7 @@ void SinricProClass::begin(String socketAuthToken, String signingKey, String ser
   this->signingKey = signingKey;
   this->serverURL = serverURL;
   _begin = true;
+  _udpListener.begin(&receiveQueue);
 }
 
 template <typename DeviceType>
@@ -305,8 +306,8 @@ void SinricProClass::handleSendQueue() {
     #endif
 
     switch (rawMessage->getInterface()) {
-      case IF_WEBSOCKET: _websocketListener.sendMessage(messageStr); break;
-      case IF_UDP:       _udpListener.sendMessage(messageStr); break;
+      case IF_WEBSOCKET: DEBUG_SINRIC("[SinricPro:handleSendQueue]: Sending to websocket\r\n"); _websocketListener.sendMessage(messageStr); break;
+      case IF_UDP:       DEBUG_SINRIC("[SinricPro:handleSendQueue]: Sending to UDP\r\n");_udpListener.sendMessage(messageStr); break;
       default:           break;
     }
     delete rawMessage;
@@ -387,6 +388,7 @@ void SinricProClass::extractTimestamp(JsonDocument &message) {
   // extract timestamp from request message
   tempTimestamp = message["payload"]["createdAt"] | 0;
   if (tempTimestamp) {
+    DEBUG_SINRIC("[SinricPro:extractTimestamp(): Got Timestamp %lu\r\n", tempTimestamp);
     baseTimestamp = tempTimestamp - (millis() / 1000);
     return;
   }

src/SinricProUDP.h

@@ -43,7 +43,7 @@ void udpListener::handle() {
   if (!_udp.available()) return;
   int len = _udp.parsePacket();
   if (len) {
-
+    
     char buffer[1024];
     int n = _udp.read(buffer, 1024);
     buffer[n] = 0;
@@ -57,7 +57,23 @@ void udpListener::sendMessage(String &message) {
   _udp.beginPacket(_udp.remoteIP(), _udp.remotePort());
   _udp.print(message);
   _udp.endPacket();
+  // restart UDP??
+  #if defined ESP8266
+    _udp.beginMulticast(WiFi.localIP(), UDP_MULTICAST_IP, UDP_MULTICAST_PORT);
+  #endif  
+  #if defined ESP32
+    _udp.beginMulticast(UDP_MULTICAST_IP, UDP_MULTICAST_PORT);
+  #endif  
+}
+
+/*
+void udpListener::sendMessage(String &message) {
+  WiFiUDP UDPsender;
+  UDPsender.beginPacket(_udp.remoteIP(), _udp.remotePort());
+  UDPsender.print(message);
+  UDPsender.endPacket();
 }
+*/ 
 
 void udpListener::stop() {
   _udp.stop();