as_ezo_mqtt_sender_rtd.yaml

globals:
  - id: rtd_mqtt_timestamp_0
    type: int
    restore_value: no
    initial_value: '0' 
  
  - id: rtd_mqtt_enabled
    type: bool
    restore_value: yes
    initial_value: ${mqtt_rtd_enabled}

number: 
  - platform: template
    min_value: ${min_mqtt_interval_rtd}
    max_value: ${max_mqtt_interval_rtd}
    step: "1"
    id: ${device_name}_rtd_mqtt_sample_interval
    name: ${device_name}.rtd.mqtt.sample_interval
    optimistic: true
    mode: box
    restore_value : true
    initial_value: ${initial_mqtt_interval_rtd}
    update_interval: "10s"
    unit_of_measurement: "ms"
    internal: ${mqtt_entities_internal}
    
switch:
  
  - platform: template
    name: ${device_name_upper}.rtd.mqtt
    id: ${device_name}_rtd_mqtt
    lambda: |-
      return id(rtd_mqtt_enabled);
    turn_on_action:
      - lambda: |-
          id(rtd_mqtt_enabled) = true;
          id(rtd_mqtt_timestamp_0) = millis();
    turn_off_action:
      - lambda: |-
          id(rtd_mqtt_enabled) = false;
    internal: ${mqtt_entities_internal}
          
interval:
  - interval: 1s
    then:    
     lambda: |-
       if(!${mqtt_entities_internal})
       {
         if (id(rtd_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(rtd_mqtt_timestamp_0))
           	id(rtd_mqtt_timestamp_0) = time_now;
           
           // check if we should send a sample
           if (time_now - id(rtd_mqtt_timestamp_0) >= id(${device_name}_rtd_mqtt_sample_interval).state)
           {
             id(${device_name}_mqtt_client).publish("sensor/${host_name}/rtd", to_string(id(${device_name}_rtd).state));
             
             id(rtd_mqtt_timestamp_0) = time_now;
           }
         }
       }