#ifndef SensorSplitterDef
#define SensorSplitterDef 1
#include "defines.h"
//sensor virtual
class SplitterSend
{
  public:
  SplitterSend(){}
  DomoEspSensorReceiver *sen;
};

class SensorSplitter: public DomoEspSensorReceiver
{
  float val;
  SplitterSend sensorSend[MAX_ACTIVADORES];

  public:
  SensorSplitter()
  {
    val=0;
    topic[0]=0;
    for(int i=0; i<MAX_ACTIVADORES; i++)
      sensorSend[i].sen=0;
  }
  void set(char* topic_id, float =0)
  {
    val=0;
    strcpy(topic, topic_id);
  }
  void AddSens(DomoEspSensorReceiver* sen)
  {
      for(int i=0; i<MAX_ACTIVADORES; i++)
      {  
        if(sensorSend[i].sen==NULL)
        {
          sensorSend[i].sen=sen;
          return;
        }
      }
      #ifdef DEBUG_PS

        Serial.println("----------------------ERROR NO ENTRAN MAS SENSORES EN SPLITTER---------------- ");
       #endif
  }
  virtual float getVal()
  {
      return (float)val;
  }
  virtual void SubscribeMqtt(IMqttManager* man){
          //char buffer_t[MAXTOPICVAR];
          sprintf(buffer_t, "%s/set",topic);
          man->MqttSubs(buffer_t);
          sprintf(buffer_t, "%s/pul",topic);
          man->MqttSubs(buffer_t);
  }
  virtual void OnMqtt(IMqttManager * man, char* _topic, char* payload, int tipo)
  {
    if(tipo!=Topic::SET && tipo!=Topic::PUL)
          return;
    if(strcmp(_topic, topic))
          return;

    if(tipo==Topic::SET )
    {
      if(payload[0]=='X')
      {
        if(val==0)
          val=1;
        else
          val=0;
      }
      else
          val=atof(payload);
      for(int i=0; i<MAX_ACTIVADORES; i++)
      {
        if(sensorSend[i].sen)
              {
                  sprintf(buffer_t, "%s/set",sensorSend[i].sen->topic);
                  man->MqttSend(buffer_t, payload);
              }
      }
        
    }
    else if(tipo==Topic::PUL )
    {
        for(int i=0; i<MAX_ACTIVADORES; i++)
        {

          if(sensorSend[i].sen)
          {
             sprintf(buffer_t, "%s/pul",sensorSend[i].sen->topic);
             man->MqttSend(buffer_t, payload);
          }
        }
      }   
  }
};

#endif