[2.0] Improve Testing Coverage

[strawgate]

Non-test Changes

• Refactor entity_details, es_gateway, datastream_manager for easier testing
• Simplify Gateway Error Handling [2.0] Simplify Elasticsearch Exception Handling #438
• Switch to asyncio.queue to not block event loop during queue operations [2.0] Use of sync queue implementation and blocking queue calls #442
• Remove device area fallback [2.0] Stop using device.area as fallback for entity.area #444
• Fix Unit of Measurement [2.0] Unit of measure missing #443
• Add device.id [2.0] Device id is missing #423
• Remove float from attribute dynamic mapping [2.0] Poor Dataset Quality #445
• Add integration version to initialization logging statement [2.0] Print Integration Version #446

Test Changes

• Switch to using the mock builder [2.0] Try out a mock builder #420
• Add coverage for gateway init (basic, api, no auth, TLS, TLS with Custom CA, TLS without Hostname, No TLS) Improve Test Coverage to 97+% #280
• Switch gateway to using a mock ES client
• Switch config_flow to mocking the Gateway
• Add coverage for datastream rollover on index template update
• Add tests for connection testing state transitions
• Add tests for connection issues during publishing
• Improve system info coverage
• Improve init coverage

Component	Coverage Before	Coverage After
init	90%	100%
es_datastream_manager	97%	100%
es_gateway	86%	100%
es_gateway_8	73%	100%
es_integration	85%	100%
es_publish_pipeline	91%	100%

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
__init__.py	0	0	100%
elasticsearch
__init__.py	148	0	100%
config_flow.py	158	0	100%
const.py	52	0	100%
diagnostics.py	8	0	100%
encoder.py	23	2	91%	42, 51
entity_details.py	109	0	100%
errors.py	11	0	100%
es_datastream_manager.py	44	0	100%
es_gateway.py	103	0	100%
es_gateway_8.py	182	0	100%
es_integration.py	45	0	100%
es_publish_pipeline.py	384	0	100%
logger.py	62	0	100%
loop.py	57	2	96%	31, 36
system_info.py	33	5	84%	34–37, 52
utils.py	27	2	92%	13, 24
elasticsearch/datastreams
__init__.py	2	0	100%
index_template.py	2	0	100%
TOTAL	1450	11	99%

Tests	Skipped	Failures	Errors	Time
359	0 💤	0 ❌	0 🔥	22.285s ⏱️

[strawgate]

@legrego I believe I am done with changes here

[legrego]

@strawgate I get errors on startup when running this version on my HA box. In the past, HA required that all third-party import statements (elasticsearch/elasticsearch8 in our case) need to happen dynamically (within functions), as opposed to the top of the file. I don't know if that's related to what I'm seeing, I haven't spent the time to track this down yet:

Logger: homeassistant.setup
Source: setup.py:334
First occurred: 12:36:38 PM (1 occurrences)
Last logged: 12:36:38 PM

Setup failed for custom integration 'elasticsearch': Unable to import component: No module named 'elasticsearch'
Traceback (most recent call last):
  File "/usr/src/homeassistant/homeassistant/setup.py", line 334, in _async_setup_component
    component = await integration.async_get_component()
                ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/usr/src/homeassistant/homeassistant/loader.py", line 1035, in async_get_component
    self._component_future.result()
    ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~^^
  File "/usr/src/homeassistant/homeassistant/loader.py", line 1015, in async_get_component
    comp = await self.hass.async_add_import_executor_job(
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
        self._get_component, True
        ^^^^^^^^^^^^^^^^^^^^^^^^^
    )
    ^
  File "/usr/local/lib/python3.13/concurrent/futures/thread.py", line 59, in run
    result = self.fn(*self.args, **self.kwargs)
  File "/usr/src/homeassistant/homeassistant/loader.py", line 1075, in _get_component
    ComponentProtocol, importlib.import_module(self.pkg_path)
                       ~~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^
  File "/usr/src/homeassistant/homeassistant/util/loop.py", line 200, in protected_loop_func
    return func(*args, **kwargs)
  File "/usr/local/lib/python3.13/importlib/__init__.py", line 88, in import_module
    return _bootstrap._gcd_import(name[level:], package, level)
           ~~~~~~~~~~~~~~~~~~~~~~^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "<frozen importlib._bootstrap>", line 1387, in _gcd_import
  File "<frozen importlib._bootstrap>", line 1360, in _find_and_load
  File "<frozen importlib._bootstrap>", line 1331, in _find_and_load_unlocked
  File "<frozen importlib._bootstrap>", line 935, in _load_unlocked
  File "<frozen importlib._bootstrap_external>", line 1026, in exec_module
  File "<frozen importlib._bootstrap>", line 488, in _call_with_frames_removed
  File "/config/custom_components/elasticsearch/__init__.py", line 8, in <module>
    from elasticsearch.const import ELASTIC_DOMAIN
ModuleNotFoundError: No module named 'elasticsearch'

[strawgate]

I know what causes this and I'm very surprised I didn't run into it -- I'll get this fixed and try to figure out why it's not happening on my instance

[strawgate]

@legrego I have fixed the namespace issue as we discussed. Sorry about that. I have verified my HA instance is using the latest commit here and is working now.

[legrego]

LGTM, tested locally and all seems to be working as intended. Thanks!

[legrego]

nit, remove?

Suggested change

# import custom_components.elasticsearch # noqa: F401

[legrego]

Suggested change

	# @property
	# def entity(self) -> RegistryEntry:
	# """Return the Hass RegistryEntry object."""
	# return self._entity