Merge master to resolve conflicts

This commit is contained in:
Lucas Jandrew 2020-11-05 13:04:17 -05:00
commit 7e0a1573ea
4 changed files with 21 additions and 16 deletions

View File

@ -22,7 +22,7 @@
#include "Adafruit_MQTT.h" #include "Adafruit_MQTT.h"
#if defined(ARDUINO_SAMD_ZERO) || defined(ARDUINO_SAMD_MKR1000) || \ #if defined(ARDUINO_SAMD_ZERO) || defined(ARDUINO_SAMD_MKR1000) || \
defined(ARDUINO_ARCH_SAMD) defined(ARDUINO_SAMD_MKR1010) || defined(ARDUINO_ARCH_SAMD)
static char *dtostrf(double val, signed char width, unsigned char prec, static char *dtostrf(double val, signed char width, unsigned char prec,
char *sout) { char *sout) {
char fmt[20]; char fmt[20];

View File

@ -41,11 +41,14 @@ public:
const char *user = "", const char *pass = "") const char *user = "", const char *pass = "")
: Adafruit_MQTT(server, port, user, pass), client(client) {} : Adafruit_MQTT(server, port, user, pass), client(client) {}
bool connectServer(); bool connected() override;
bool disconnectServer();
bool connected(); protected:
uint16_t readPacket(uint8_t *buffer, uint16_t maxlen, int16_t timeout); bool connectServer() override;
bool sendPacket(uint8_t *buffer, uint16_t len); bool disconnectServer() override;
uint16_t readPacket(uint8_t *buffer, uint16_t maxlen,
int16_t timeout) override;
bool sendPacket(uint8_t *buffer, uint16_t len) override;
private: private:
Client *client; Client *client;

View File

@ -42,7 +42,13 @@ public:
const char *user = "", const char *pass = "") const char *user = "", const char *pass = "")
: Adafruit_MQTT(server, port, user, pass), fona(f) {} : Adafruit_MQTT(server, port, user, pass), fona(f) {}
bool connectServer() { bool connected() {
// Return true if connected, false if not connected.
return fona->TCPconnected();
}
protected:
bool connectServer() override {
char server[40]; char server[40];
strncpy(server, servername, 40); strncpy(server, servername, 40);
#ifdef ADAFRUIT_SLEEPYDOG_H #ifdef ADAFRUIT_SLEEPYDOG_H
@ -54,14 +60,10 @@ public:
return fona->TCPconnect(server, portnum); return fona->TCPconnect(server, portnum);
} }
bool disconnectServer() { return fona->TCPclose(); } bool disconnectServer() override { return fona->TCPclose(); }
bool connected() { uint16_t readPacket(uint8_t *buffer, uint16_t maxlen,
// Return true if connected, false if not connected. int16_t timeout) override {
return fona->TCPconnected();
}
uint16_t readPacket(uint8_t *buffer, uint16_t maxlen, int16_t timeout) {
uint8_t *buffp = buffer; uint8_t *buffp = buffer;
DEBUG_PRINTLN(F("Reading data..")); DEBUG_PRINTLN(F("Reading data.."));
@ -114,7 +116,7 @@ public:
return len; return len;
} }
bool sendPacket(uint8_t *buffer, uint16_t len) { bool sendPacket(uint8_t *buffer, uint16_t len) override {
DEBUG_PRINTLN(F("Writing packet")); DEBUG_PRINTLN(F("Writing packet"));
if (fona->TCPconnected()) { if (fona->TCPconnected()) {
boolean ret = fona->TCPsend((char *)buffer, len); boolean ret = fona->TCPsend((char *)buffer, len);

View File

@ -35,7 +35,7 @@
// Create an ESP8266 WiFiClient class to connect to the MQTT server. // Create an ESP8266 WiFiClient class to connect to the MQTT server.
WiFiClient client; WiFiClient client;
// or... use WiFiFlientSecure for SSL // or... use WiFiClientSecure for SSL
//WiFiClientSecure client; //WiFiClientSecure client;
// Setup the MQTT client class by passing in the WiFi client and MQTT server and login details. // Setup the MQTT client class by passing in the WiFi client and MQTT server and login details.