feat(library): DatumIoT v1.4.0

- Add setMqttPort() to configure non-default MQTT port
- Implement connectWiFi() (was declared but missing impl)
- Add sendLog(level, message) for structured log publishing
- Add rotateKey() for API key rotation trigger
- Remove phantom private _handleCommand()/_extractJsonVal() declarations

Author: tevfik

libraries/DatumIoT/library.properties

@@ -1,5 +1,5 @@
 name=Datum IoT
-version=1.3.0
+version=1.4.0
 author=Datum IoT Platform
 maintainer=Datum IoT Platform
 sentence=Official Arduino library for connecting devices to the Datum IoT Server.

libraries/DatumIoT/src/DatumIoT.cpp

@@ -50,6 +50,30 @@ void DatumIoT::setServer(String url) {
   _mqtt.setServer(_mqttHost.c_str(), _mqttPort);
 }
 
+void DatumIoT::setMqttPort(int port) {
+  _mqttPort = port;
+  if (_mqttHost.length() > 0)
+    _mqtt.setServer(_mqttHost.c_str(), _mqttPort);
+}
+
+void DatumIoT::connectWiFi(String ssid, String pass) {
+#ifdef ESP8266
+  WiFi.begin(ssid.c_str(), pass.c_str());
+#else
+  WiFi.begin(ssid.c_str(), pass.c_str());
+#endif
+  DATUM_LOG("Connecting WiFi to %s...", ssid.c_str());
+  int attempts = 0;
+  while (WiFi.status() != WL_CONNECTED && attempts < 40) {
+    delay(500);
+    attempts++;
+  }
+  if (WiFi.status() == WL_CONNECTED)
+    DATUM_LOG("WiFi connected! IP: %s", WiFi.localIP().toString().c_str());
+  else
+    DATUM_LOG("WiFi connect failed after %d attempts", attempts);
+}
+
 bool DatumIoT::connect() {
   if (_mqtt.connected())
     return true;
@@ -192,6 +216,46 @@ bool DatumIoT::sendTelemetryJson(JsonObject json) {
   return _mqtt.publish(topic.c_str(), payload.c_str());
 }
 
+bool DatumIoT::sendLog(String msg) {
+  if (!_mqtt.connected()) return false;
+  String topic = "dev/" + _deviceId + "/logs";
+  StaticJsonDocument<256> doc;
+  doc["msg"] = msg;
+  doc["ts"] = millis() / 1000;
+  String payload;
+  serializeJson(doc, payload);
+  return _mqtt.publish(topic.c_str(), payload.c_str());
+}
+
+bool DatumIoT::rotateKey() {
+  HTTPClient http;
+  String url = _serverUrl + "/dev/" + _deviceId + "/rotate-key";
+#ifdef ESP8266
+  WiFiClient client;
+  http.begin(client, url);
+#else
+  http.begin(url);
+#endif
+  http.addHeader("Authorization", "Bearer " + _apiKey);
+  http.addHeader("Content-Type", "application/json");
+  int code = http.POST("{}");
+  if (code == 200 || code == 201) {
+    StaticJsonDocument<256> resp;
+    if (deserializeJson(resp, http.getString()) == DeserializationError::Ok) {
+      const char *newKey = resp["api_key"];
+      if (newKey && strlen(newKey) > 0) {
+        _apiKey = String(newKey);
+        DATUM_LOG("Key rotated successfully");
+        http.end();
+        return true;
+      }
+    }
+  }
+  DATUM_LOG("Key rotation failed: %d", code);
+  http.end();
+  return false;
+}
+
 // Callbacks
 void DatumIoT::onCommand(CommandCallback cb) { _cmdCallback = cb; }
 

libraries/DatumIoT/src/DatumIoT.h

@@ -41,6 +41,7 @@ class DatumIoT {
 
   // Connection
   void setServer(String url);
+  void setMqttPort(int port);                 // Override default MQTT port (1883)
   void connectWiFi(String ssid, String pass); // Helper blocking connect
   bool connect();                             // Find MQTT/active connection
   void loop();
@@ -54,6 +55,12 @@ class DatumIoT {
   // Commands
   void onCommand(CommandCallback cb);
 
+  // Logging
+  bool sendLog(String msg); // Publish to dev/{id}/logs via MQTT
+
+  // Key management
+  bool rotateKey(); // POST /dev/{id}/rotate-key — updates internal _apiKey
+
   // Utils
   String getDeviceId() const { return _deviceId; }
   String getApiKey() const { return _apiKey; }
@@ -74,8 +81,6 @@ class DatumIoT {
   bool _mqttConnect();
   void _mqttCallback(char *topic, byte *payload, unsigned int length);
   void _ackCommand(String cmdId);
-  void _handleCommand(String payload);
-  String _extractJsonVal(String json, String key);
 };
 
 #endif