lighthub/lighthub/abstractin.cpp

#include "abstractin.h"
#include <PubSubClient.h>
#include "utils.h"
#include <aJSON.h>
#include "inputs.h"
#include "main.h"

extern lan_status lanStatus;
extern PubSubClient mqttClient;

int abstractIn::publish(long value, char* subtopic)
{
  char valstr[16];
  printUlongValueToStr(valstr, value);
  return publish(valstr,subtopic);
};

int abstractIn::publish(float value, char* subtopic)
{
  char valstr[16];
  printFloatValueToStr(value, valstr);
  return publish(valstr,subtopic);
};

int abstractIn::publish(char * value, char* subtopic)
{
  char addrstr[MQTT_TOPIC_LENGTH];
  if (in)
  {
  aJsonObject *emit = aJson.getObjectItem(in->inputObj, "emit");
    if (emit)
     {
       strncpy(addrstr,emit->valuestring,sizeof(addrstr));
       if (!strchr(addrstr,'/')) setTopic(addrstr,sizeof(addrstr),T_OUT,emit->valuestring);
       strncat(addrstr,subtopic,sizeof(addrstr));
       if (mqttClient.connected() && lanStatus == OPERATION)
                       {
                        mqttClient.publish(addrstr, value, true);
                        return 1;
                      }
     }
  }
return 0;
};