#include "detaBaseArduinoESP32.h"
#include <WiFiClientSecure.h>
#include <ArduinoJson.h>
#define LED 2
#define LED1 4
#define botao 13

char* apiKey = "b0eoyx13_Dgz6QtkNvHAUbcKu2BH2gNro8xbszang ";
char* detaID = "b0eoyx13";
char* detaBaseName = "BASE_TESTE";
const char * ssid = "Wokwi-GUEST"; //MENO WiFi SIETE
bool canal = 0;
bool statusAnt = 0;
bool statusAtual = 0;
bool tempo_envio;
unsigned long agora;
unsigned long ultimo_envio;
unsigned long frequencia = 10000;
WiFiClientSecure cliente;
DetaBaseObject detaObj(cliente, detaID, detaBaseName, apiKey, false);
StaticJsonDocument<200> doc;

void setup() {
  Serial.begin(115200);
  Serial.println("Inicializando...");
  pinMode(LED, OUTPUT);
  pinMode(LED1, OUTPUT);
  pinMode(botao, INPUT_PULLUP);
  digitalWrite(LED, LOW);
  digitalWrite(LED1, LOW);
  WiFi.begin(ssid); //pripoj sa na wifi siet s heslom
  Serial.println("Aguardando se conectar ao Wi-Fi");
  while (WiFi.status() != WL_CONNECTED) {
    delay(500);
    Serial.print(".");
  }
  Serial.println();
  Serial.println("conectado!!");
  digitalWrite(LED, HIGH);

}

void loop() {
  statusAtual = digitalRead(botao);
  if (statusAtual != statusAnt && statusAtual == 0) {
    canal = !canal;
    Serial.print("botão pressionado, ");
    if(canal){
      detaObj.putObject("{\"items\":[{\"key\":\"MOD_01\",\"DADOS\":1}]}");
      Serial.println("dados enviado = 1");
    }else{
      detaObj.putObject("{\"items\":[{\"key\":\"MOD_01\",\"DADOS\":0}]}");
      Serial.println("dados enviado = 0");
    }
  }
  statusAnt = statusAtual;
 

  agora = millis();
  tempo_envio = agora - ultimo_envio > frequencia;
  if (tempo_envio) {
    Serial.print("recebendo dados, ");
    result myResult = detaObj.getObject("MOD_02");
    DeserializationError error = deserializeJson(doc, myResult.reply);
    String dados = doc["DADOS"];
    if (dados == "1") {
      digitalWrite(LED1, HIGH);
    } else {
      digitalWrite(LED1, LOW);
    }
    Serial.print("dados recebido = ");
    Serial.print(dados);
    Serial.print(" fim da consulta \n");
    ultimo_envio = millis();
  }

}

Controle_MOD_01.ino

diagram.json

# Wokwi Library List
# See https://docs.wokwi.com/guides/libraries
ArduinoJson

libraries.txt

#ifndef DETABASE_LIBRARY_H
#define DETABASE_LIBRARY_H

#include <Arduino.h>
#include <WiFiClientSecure.h>

#define HTTPS_PORT 443
#define DETA_BASE_HOST "database.deta.sh"
#define TIMEOUT_THRESH 5000

typedef struct {
  int statusCode;
  String reply;
} result;


void printResult(result resultObject);
class DetaBaseObject {
  public:
    DetaBaseObject(WiFiClientSecure wifiObject, const char* detaID, const char* detaBaseName, const char* apiKey, bool debugOption);
    DetaBaseObject(WiFiClientSecure wifiObject, const char* detaID, const char* detaBaseName, const char* apiKey);
    ~DetaBaseObject();

    result putObject(const char* jsonObject);
    result getObject(const char* key);
    result deleteObject(const char* key);
    result insertObject(const char* jsonObject);
    result updateObject(const char* jsonObject, const char* key);
    result query(const char* queryObject);
    const char* getDetaID();
    const char* getBaseURI();

  private:
    const char* _apiKey;
    const char* _detaID;
    const char* _detaBaseName;
    char* _baseURI;
    const char* _host;
    WiFiClientSecure _wifiObject;
    bool _debugOn;
    bool checkTimeout();
    void parseReply(result* returnObject);
    void writeNonPayloadHeaders();
    void writePayloadHeaders(const char* object);
    void initResult(result* resultObject);
    const char* const _detaRootCa = \
                                    "-----BEGIN CERTIFICATE-----\n" \
                                    "MIIF3jCCA8agAwIBAgIQAf1tMPyjylGoG7xkDjUDLTANBgkqhkiG9w0BAQwFADCB\n" \
                                    "iDELMAkGA1UEBhMCVVMxEzARBgNVBAgTCk5ldyBKZXJzZXkxFDASBgNVBAcTC0pl\n" \
                                    "cnNleSBDaXR5MR4wHAYDVQQKExVUaGUgVVNFUlRSVVNUIE5ldHdvcmsxLjAsBgNV\n" \
                                    "BAMTJVVTRVJUcnVzdCBSU0EgQ2VydGlmaWNhdGlvbiBBdXRob3JpdHkwHhcNMTAw\n" \
                                    "MjAxMDAwMDAwWhcNMzgwMTE4MjM1OTU5WjCBiDELMAkGA1UEBhMCVVMxEzARBgNV\n" \
                                    "BAgTCk5ldyBKZXJzZXkxFDASBgNVBAcTC0plcnNleSBDaXR5MR4wHAYDVQQKExVU\n" \
                                    "aGUgVVNFUlRSVVNUIE5ldHdvcmsxLjAsBgNVBAMTJVVTRVJUcnVzdCBSU0EgQ2Vy\n" \
                                    "dGlmaWNhdGlvbiBBdXRob3JpdHkwggIiMA0GCSqGSIb3DQEBAQUAA4ICDwAwggIK\n" \
                                    "AoICAQCAEmUXNg7D2wiz0KxXDXbtzSfTTK1Qg2HiqiBNCS1kCdzOiZ/MPans9s/B\n" \
                                    "3PHTsdZ7NygRK0faOca8Ohm0X6a9fZ2jY0K2dvKpOyuR+OJv0OwWIJAJPuLodMkY\n" \
                                    "tJHUYmTbf6MG8YgYapAiPLz+E/CHFHv25B+O1ORRxhFnRghRy4YUVD+8M/5+bJz/\n" \
                                    "Fp0YvVGONaanZshyZ9shZrHUm3gDwFA66Mzw3LyeTP6vBZY1H1dat//O+T23LLb2\n" \
                                    "VN3I5xI6Ta5MirdcmrS3ID3KfyI0rn47aGYBROcBTkZTmzNg95S+UzeQc0PzMsNT\n" \
                                    "79uq/nROacdrjGCT3sTHDN/hMq7MkztReJVni+49Vv4M0GkPGw/zJSZrM233bkf6\n" \
                                    "c0Plfg6lZrEpfDKEY1WJxA3Bk1QwGROs0303p+tdOmw1XNtB1xLaqUkL39iAigmT\n" \
                                    "Yo61Zs8liM2EuLE/pDkP2QKe6xJMlXzzawWpXhaDzLhn4ugTncxbgtNMs+1b/97l\n" \
                                    "c6wjOy0AvzVVdAlJ2ElYGn+SNuZRkg7zJn0cTRe8yexDJtC/QV9AqURE9JnnV4ee\n" \
                                    "UB9XVKg+/XRjL7FQZQnmWEIuQxpMtPAlR1n6BB6T1CZGSlCBst6+eLf8ZxXhyVeE\n" \
                                    "Hg9j1uliutZfVS7qXMYoCAQlObgOK6nyTJccBz8NUvXt7y+CDwIDAQABo0IwQDAd\n" \
                                    "BgNVHQ4EFgQUU3m/WqorSs9UgOHYm8Cd8rIDZsswDgYDVR0PAQH/BAQDAgEGMA8G\n" \
                                    "A1UdEwEB/wQFMAMBAf8wDQYJKoZIhvcNAQEMBQADggIBAFzUfA3P9wF9QZllDHPF\n" \
                                    "Up/L+M+ZBn8b2kMVn54CVVeWFPFSPCeHlCjtHzoBN6J2/FNQwISbxmtOuowhT6KO\n" \
                                    "VWKR82kV2LyI48SqC/3vqOlLVSoGIG1VeCkZ7l8wXEskEVX/JJpuXior7gtNn3/3\n" \
                                    "ATiUFJVDBwn7YKnuHKsSjKCaXqeYalltiz8I+8jRRa8YFWSQEg9zKC7F4iRO/Fjs\n" \
                                    "8PRF/iKz6y+O0tlFYQXBl2+odnKPi4w2r78NBc5xjeambx9spnFixdjQg3IM8WcR\n" \
                                    "iQycE0xyNN+81XHfqnHd4blsjDwSXWXavVcStkNr/+XeTWYRUc+ZruwXtuhxkYze\n" \
                                    "Sf7dNXGiFSeUHM9h4ya7b6NnJSFd5t0dCy5oGzuCr+yDZ4XUmFF0sbmZgIn/f3gZ\n" \
                                    "XHlKYC6SQK5MNyosycdiyA5d9zZbyuAlJQG03RoHnHcAP9Dc1ew91Pq7P8yF1m9/\n" \
                                    "qS3fuQL39ZeatTXaw2ewh0qpKJ4jjv9cJ2vhsE/zB+4ALtRZh8tSQZXq9EfX7mRB\n" \
                                    "VXyNWQKV3WKdwrnuWih0hKWbt5DHDAff9Yk2dDLWKMGwsAvgnEzDHNb842m1R0aB\n" \
                                    "L6KCq9NjRHDEjf8tM7qtj3u1cIiuPhnPQCjY/MiQu12ZIvVS5ljFH4gxQ+6IHdfG\n" \
                                    "jjxDah2nGN59PRbxYvnKkKj9\n" \
                                    "-----END CERTIFICATE-----\n";
};

#endif


detaBaseArduinoESP32.h

#include "detaBaseArduinoESP32.h"

DetaBaseObject::DetaBaseObject(WiFiClientSecure wifiObject, const char* detaID, const char* detaBaseName, const char* apiKey, bool debugOption) {
  _debugOn = debugOption;
  _detaID = detaID;
  _apiKey = apiKey;
  _detaBaseName = detaBaseName;
  _baseURI = (char *)malloc((strlen("/v1/") + strlen(detaID) + strlen("/") + strlen(detaBaseName) + 1 ) * sizeof(char));
  _wifiObject = wifiObject;
  _wifiObject.setCACert(_detaRootCa);
  _host = "database.deta.sh";
  strcpy(_baseURI, "/v1/");
  strncat(_baseURI, detaID, strlen(detaID));
  strncat(_baseURI, "/", strlen("/"));
  strncat(_baseURI, detaBaseName, strlen(detaBaseName));
}

DetaBaseObject::DetaBaseObject(WiFiClientSecure wifiObject, const char* detaID, const char* detaBaseName, const char* apiKey) {
  _detaID = detaID;
  _apiKey = apiKey;
  _detaBaseName = detaBaseName;
  _baseURI = (char *)malloc((strlen("/v1/") + strlen(detaID) + strlen("/") + strlen(detaBaseName) + 1 ) * sizeof(char));
  _wifiObject = wifiObject;
  _wifiObject.setCACert(_detaRootCa);
  _host = "database.deta.sh";
  strcpy(_baseURI, "/v1/");
  strncat(_baseURI, detaID, strlen(detaID));
  strncat(_baseURI, "/", strlen("/"));
  strncat(_baseURI, detaBaseName, strlen(detaBaseName));
}

DetaBaseObject::~DetaBaseObject() {
  free(_baseURI);
}

const char* DetaBaseObject::getDetaID() {
  return _detaID;
}

const char* DetaBaseObject::getBaseURI() {
  return _baseURI;
}

result DetaBaseObject::putObject(const char* jsonObject) {

  if (_debugOn) {
    Serial.println("This is putObject");
    Serial.print("json: \t");
    Serial.println(jsonObject);
    Serial.print("Length: \t");
    Serial.println(strlen(jsonObject));
  }
  result returnObject;
  initResult(&returnObject);

  if (_wifiObject.connect(_host, HTTPS_PORT)) {
    _wifiObject.print("PUT ");
    _wifiObject.print(_baseURI);
    _wifiObject.print("/items");
    writePayloadHeaders(jsonObject);
  } else {
    returnObject.reply = "Could not connect to server";
    return returnObject;
  }
  if (checkTimeout()) {
    returnObject.reply = "Client Timeout";
    return returnObject;
  }
  parseReply(&returnObject);
  _wifiObject.stop();
  if (_debugOn) {
    Serial.println("closed connection");
  }
  return returnObject;
}

result DetaBaseObject::insertObject(const char* jsonObject) {
  if (_debugOn) {
    Serial.println("This is insertObject");
    Serial.print("jsonObject: \t");
    Serial.println(jsonObject);
    Serial.print("Length: \t");
    Serial.println(strlen(jsonObject));
  }
  result returnObject;
  initResult(&returnObject);
  if (_wifiObject.connect(_host, HTTPS_PORT)) {
    _wifiObject.print("POST ");
    _wifiObject.print(_baseURI);
    _wifiObject.print("/items");
    writePayloadHeaders(jsonObject);
  } else {
    returnObject.reply = "Could not connect to server";
    return returnObject;
  }
  if (checkTimeout()) {
    returnObject.reply = "Client Timeout";
    return returnObject;
  }
  parseReply(&returnObject);
  _wifiObject.stop();
  if (_debugOn) {
    Serial.println("closed connection");
  }
  return returnObject;
}

result DetaBaseObject::updateObject(const char* jsonObject, const char* key) {
  if (_debugOn) {
    Serial.println("This is updateObject");
    Serial.print("key: \t");
    Serial.println(key);
    Serial.print("Length: \t");
    Serial.println(strlen(key));
    Serial.print("json: \t");
    Serial.println(jsonObject);
    Serial.print("Length: \t");
    Serial.println(strlen(jsonObject));
  }
  result returnObject;
  initResult(&returnObject);

  if (_wifiObject.connect(_host, HTTPS_PORT)) {
    _wifiObject.print("PATCH ");
    _wifiObject.print(_baseURI);
    _wifiObject.print("/items/");
    _wifiObject.print(key);
    writePayloadHeaders(jsonObject);
  } else {
    returnObject.reply = "Could not connect to server";
    return returnObject;
  }
  if (checkTimeout()) {
    returnObject.reply = "Client Timeout";
    return returnObject;
  }
  parseReply(&returnObject);
  _wifiObject.stop();
  if (_debugOn) {
    Serial.println("closed connection");
  }
  return returnObject;
}

result DetaBaseObject::query(const char* queryObject) {
  if (_debugOn) {
    Serial.println("This is query");
    Serial.print("key: \t\t");
    Serial.println(queryObject);
    Serial.print("Length: \t");
    Serial.println(strlen(queryObject));
  }
  result returnObject;
  initResult(&returnObject);
  if (_wifiObject.connect(_host, HTTPS_PORT)) {
    _wifiObject.print("POST ");
    _wifiObject.print(_baseURI);
    _wifiObject.print("/query");
    writePayloadHeaders(queryObject);
  } else {
    returnObject.reply = "Could not connect to server";
    return returnObject;
  }
  if (checkTimeout()) {
    returnObject.reply = "Client Timeout";
    return returnObject;
  }
  parseReply(&returnObject);
  _wifiObject.stop();
  if (_debugOn) {
    Serial.println("closed connection");
  }
  return returnObject;
}

void printResult(result resultObject) {
  Serial.print("Status:\t");
  Serial.println(resultObject.statusCode);
  Serial.print("Reply:\t");
  Serial.println(resultObject.reply);  //should be println
}

result DetaBaseObject::getObject(const char* key) {
  if (_debugOn) {
    Serial.println("This is getObject");
    Serial.print("key: \t\t");
    Serial.println(key);
    Serial.print("Length: \t");
    Serial.println(strlen(key));
  }
  result returnObject;
  initResult(&returnObject);
  if (_wifiObject.connect(_host, HTTPS_PORT)) {
    _wifiObject.print("GET ");
    _wifiObject.print(_baseURI);
    _wifiObject.print("/items/");
    _wifiObject.print(key);
    writeNonPayloadHeaders();
    _wifiObject.println();
  } else {
    returnObject.reply = "Could not connect to server";
    return returnObject;
  }

  if (checkTimeout()) {
    returnObject.reply = "Client Timeout";
    return returnObject;
  }
  parseReply(&returnObject);

  _wifiObject.stop();
  if (_debugOn) {
    Serial.println("closed connection");
  }
  return returnObject;
}

result DetaBaseObject::deleteObject(const char* key) {
  if (_debugOn) {
    Serial.println("This is delete Object");
    Serial.print("key: \t\t");
    Serial.println(key);
    Serial.print("Length: \t");
    Serial.println(strlen(key));
  }
  result returnObject;
  initResult(&returnObject);
  if (_wifiObject.connect(_host, HTTPS_PORT)) {
    _wifiObject.print("DELETE ");
    _wifiObject.print(_baseURI);
    _wifiObject.print("/items/");
    _wifiObject.print(key);
    writeNonPayloadHeaders();
    _wifiObject.println();
  } else {
    returnObject.reply = "Could not connect to server";
    return returnObject;
  }

  if (checkTimeout()) {
    returnObject.reply = "Client Timeout";
    return returnObject;
  }
  parseReply(&returnObject);

  _wifiObject.stop();
  if (_debugOn) {
    Serial.println("closed connection");
  }
  return returnObject;

}

bool DetaBaseObject::checkTimeout() {
  unsigned long timeout = millis();
  while (_wifiObject.available() == 0) {
    if (millis() - timeout > TIMEOUT_THRESH) {
      _wifiObject.stop();
      return true;
    }
  }
  return false;
}

void DetaBaseObject::parseReply(result* returnObject) {
  returnObject->statusCode = _wifiObject.readStringUntil('\r').substring(9, 12).toInt();
  for (int i = 0; i < 8; i++) {
    returnObject->reply = _wifiObject.readStringUntil('\r');
  }
  returnObject->reply = _wifiObject.readStringUntil('\r').substring(1);
  returnObject->reply = returnObject->reply.substring(0, returnObject->reply.length() - 1);
}

void DetaBaseObject::writeNonPayloadHeaders() {
  _wifiObject.println(" HTTP/1.1");
  _wifiObject.println("Host: database.deta.sh");
  _wifiObject.println("User-Agent: Arduino/1.0");
  _wifiObject.println("Accept-Encoding: gzip, deflate");
  _wifiObject.println("Accept: */*");
  _wifiObject.println("Connection: keep-alive");
  _wifiObject.print("x-api-key: ");
  _wifiObject.println(_apiKey);
}

void DetaBaseObject::writePayloadHeaders(const char* object) {
  writeNonPayloadHeaders();
  _wifiObject.println("Content-Type: application/json");
  _wifiObject.print("Content-Length: ");
  _wifiObject.println(strlen(object));
  _wifiObject.println();
  _wifiObject.println(object);
}

void DetaBaseObject::initResult(result* resultObject) {
  resultObject->statusCode = -1;
  resultObject->reply = "If you see this, something went wrong and error was not assigned here. Contact developer.";
}
