as_ezo_mqtt_sender_ec.yaml

globals:
  - id: ec_mqtt_timestamp_0
    type: int
    restore_value: no
    initial_value: '0' 
  
  - id: ec_mqtt_enabled
    type: bool
    restore_value: yes
    initial_value: ${mqtt_ec_enabled}

number: 
  - platform: template
    min_value: ${min_mqtt_interval_ec}
    max_value: ${max_mqtt_interval_ec}
    step: "1"
    id: ${device_name}_ec_mqtt_sample_interval
    name: ${device_name}.ec.mqtt.sample_interval
    optimistic: true
    mode: box
    restore_value : true
    initial_value: ${initial_mqtt_interval_ec}
    update_interval: "10s"
    unit_of_measurement: "ms"
    internal: ${mqtt_entities_internal}
    
switch:
  
  # TEMPERATURE COMPENSATION
  - platform: template
    name: ${device_name_upper}.ec.mqtt
    id: ${device_name}_ec_mqtt
    lambda: |-
      return id(ec_mqtt_enabled);
    turn_on_action:
      - lambda: |-
          id(ec_mqtt_enabled) = true;
          id(ec_mqtt_timestamp_0) = millis();
    turn_off_action:
      - lambda: |-
          id(ec_mqtt_enabled) = false;
    internal: ${mqtt_entities_internal}
    on_turn_on:
      then:
        - mqtt.publish:
            topic: some/topic
            payload: "Something happened!"
      
        # Templated:
        - mqtt.publish:
            topic: !lambda |-
              if (id(${device_name}_ec_mqtt).state) return "topic1";
              else return "topic2";
            payload: !lambda |-
              return id(${device_name}_ec_mqtt).state ? "YES" : "NO";
          
interval:
  - interval: 1s
    then:       
    #  - if:
    #      condition:
    #        lambda: |-
    #          return !${mqtt_entities_internal};
    #      then:
    #        - if:
    #            condition:
    #              lambda: |-
    #                return id(ec_mqtt_enabled);
    #            then:
    #              - if:
    #                  condition:
    #                    lambda: |-
    #                      int time_now = millis();
    #                      // integer overflow protection -> restart waiting timer -> (TODO: maybe implement exact value reset via max integer)
    #                      if (time_now < id(ec_mqtt_timestamp_0))
    #                      	id(ec_mqtt_timestamp_0) = time_now;
    #                      
    #                      // check if we should send a sample
    #                      if (time_now - id(ec_mqtt_timestamp_0) >= id(${device_name}_ec_mqtt_sample_interval).state)
    #                        return true;
    #                      else
    #                        return false;
    #                  then:
    #                    - mqtt.publish:
    #                        topic: !lambda |-
    #                          return "${host_name}/ec";
    #                        payload: !lambda |-
    #                          return to_string(id(${device_name}_ec).state);
    #                          
    #                  else:
    #            else:
    #      else:
      
      
     lambda: |-
       if(!${mqtt_entities_internal})
       {
         if (id(ec_mqtt_enabled))
         {
           int time_now = millis();
           // integer overflow protection -> restart waiting timer -> (TODO: maybe implement exact value reset via max integer)
           if (time_now < id(ec_mqtt_timestamp_0))
           	id(ec_mqtt_timestamp_0) = time_now;
           
           // check if we should send a sample
           if (time_now - id(ec_mqtt_timestamp_0) >= id(${device_name}_ec_mqtt_sample_interval).state)
           {
             id(${device_name}_mqtt_client).publish("sensor/${host_name}/ec", to_string(id(${device_name}_ec).state));
             
             id(ec_mqtt_timestamp_0) = time_now;
           }
         }
       }