mirror/esphome
1
0
Fork 0
mirror of https://github.com/esphome/esphome.git synced 2026-01-10 12:10:48 -07:00
Code Issues Packages Projects Releases Wiki Activity

[api] Store Home Assistant state subscriptions in flash instead of heap (#12008)

Browse Source
This commit is contained in:
J. Nick Koston
2025-12-09 16:26:11 +01:00
committed by GitHub
parent 443f9c3f57
commit 72c74bc0b3
17 changed files with 144 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
tests/integration/fixtures/api_custom_services.yaml
View File

@@ -5,6 +5,7 @@ host:
# This is required for CustomAPIDevice to work
api:
custom_services: true
homeassistant_states: true
# Also test that YAML services still work
actions:
- action: test_yaml_service

9
tests/integration/fixtures/external_components/custom_api_device_component/custom_api_device_component.cpp
View File

@@ -17,6 +17,10 @@ void CustomAPIDeviceComponent::setup() {
// Test array types
register_service(&CustomAPIDeviceComponent::on_service_with_arrays, "custom_service_with_arrays",
{"bool_array", "int_array", "float_array", "string_array"});
// Test Home Assistant state subscription using std::string API (custom_api_device.h)
// This tests the backward compatibility of the std::string overloads
subscribe_homeassistant_state(&CustomAPIDeviceComponent::on_ha_state_changed, std::string("sensor.custom_test"));
}
void CustomAPIDeviceComponent::on_test_service() { ESP_LOGI(TAG, "Custom test service called!"); }
@@ -48,6 +52,11 @@ void CustomAPIDeviceComponent::on_service_with_arrays(std::vector<bool> bool_arr
}
}
void CustomAPIDeviceComponent::on_ha_state_changed(std::string entity_id, std::string state) {
ESP_LOGI(TAG, "Home Assistant state changed for %s: %s", entity_id.c_str(), state.c_str());
ESP_LOGI(TAG, "This subscription uses std::string API for backward compatibility");
}
} // namespace custom_api_device_component
} // namespace esphome
#endif // USE_API

3
tests/integration/fixtures/external_components/custom_api_device_component/custom_api_device_component.h
View File

@@ -22,6 +22,9 @@ class CustomAPIDeviceComponent : public Component, public CustomAPIDevice {
void on_service_with_arrays(std::vector<bool> bool_array, std::vector<int32_t> int_array,
std::vector<float> float_array, std::vector<std::string> string_array);
// Test Home Assistant state subscription with std::string API
void on_ha_state_changed(std::string entity_id, std::string state);
};
} // namespace custom_api_device_component

11
tests/integration/test_api_custom_services.py
View File

@@ -38,6 +38,7 @@ async def test_api_custom_services(
custom_service_future = loop.create_future()
custom_args_future = loop.create_future()
custom_arrays_future = loop.create_future()
ha_state_future = loop.create_future()
# Patterns to match in logs
yaml_service_pattern = re.compile(r"YAML service called")
@@ -50,6 +51,9 @@ async def test_api_custom_services(
custom_arrays_pattern = re.compile(
r"Array service called with 2 bools, 3 ints, 2 floats, 2 strings"
)
ha_state_pattern = re.compile(
r"This subscription uses std::string API for backward compatibility"
)
def check_output(line: str) -> None:
"""Check log output for expected messages."""
@@ -65,6 +69,8 @@ async def test_api_custom_services(
custom_args_future.set_result(True)
elif not custom_arrays_future.done() and custom_arrays_pattern.search(line):
custom_arrays_future.set_result(True)
elif not ha_state_future.done() and ha_state_pattern.search(line):
ha_state_future.set_result(True)
# Run with log monitoring
async with (
@@ -198,3 +204,8 @@ async def test_api_custom_services(
},
)
await asyncio.wait_for(custom_arrays_future, timeout=5.0)
# Test Home Assistant state subscription (std::string API backward compatibility)
# This verifies that custom_api_device.h can still use std::string overloads
client.send_home_assistant_state("sensor.custom_test", "", "42.5")
await asyncio.wait_for(ha_state_future, timeout=5.0)