Cache AST module parsing in hassfest (#132244)

script/hassfest/__init__.py

@@ -1 +1,14 @@
 """Manifest validator."""
+
+import ast
+from functools import lru_cache
+from pathlib import Path
+
+
+@lru_cache
+def ast_parse_module(file_path: Path) -> ast.Module:
+    """Parse a module.
+
+    Cached to avoid parsing the same file for each plugin.
+    """
+    return ast.parse(file_path.read_text())

script/hassfest/config_schema.py

@@ -6,6 +6,7 @@
 
 from homeassistant.core import DOMAIN as HOMEASSISTANT_DOMAIN
 
+from . import ast_parse_module
 from .model import Config, Integration
 
 CONFIG_SCHEMA_IGNORE = {
@@ -60,7 +61,7 @@ def _validate_integration(config: Config, integration: Integration) -> None:
         # Virtual integrations don't have any implementation
         return
 
-    init = ast.parse(init_file.read_text())
+    init = ast_parse_module(init_file)
 
     # No YAML Support
     if not _has_function(
@@ -81,7 +82,7 @@ def _validate_integration(config: Config, integration: Integration) -> None:
 
     config_file = integration.path / "config.py"
     if config_file.is_file():
-        config_module = ast.parse(config_file.read_text())
+        config_module = ast_parse_module(config_file)
         if _has_function(config_module, ast.AsyncFunctionDef, "async_validate_config"):
             return
 

script/hassfest/dependencies.py

@@ -10,6 +10,7 @@
 from homeassistant.const import Platform
 from homeassistant.requirements import DISCOVERY_INTEGRATIONS
 
+from . import ast_parse_module
 from .model import Config, Integration
 
 
@@ -33,7 +34,7 @@ def collect(self) -> None:
             self._cur_fil_dir = fil.relative_to(self.integration.path)
             self.referenced[self._cur_fil_dir] = set()
             try:
-                self.visit(ast.parse(fil.read_text()))
+                self.visit(ast_parse_module(fil))
             except SyntaxError as e:
                 e.add_note(f"File: {fil}")
                 raise

script/hassfest/quality_scale_validation/config_entry_unloading.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 
@@ -20,7 +21,7 @@ def validate(integration: Integration) -> list[str] | None:
     """Validate that the integration has a config flow."""
 
     init_file = integration.path / "__init__.py"
-    init = ast.parse(init_file.read_text())
+    init = ast_parse_module(init_file)
 
     if not _has_unload_entry_function(init):
         return [

script/hassfest/quality_scale_validation/diagnostics.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 DIAGNOSTICS_FUNCTIONS = {
@@ -31,7 +32,7 @@ def validate(integration: Integration) -> list[str] | None:
             "(is missing diagnostics.py)",
         ]
 
-    diagnostics = ast.parse(diagnostics_file.read_text())
+    diagnostics = ast_parse_module(diagnostics_file)
 
     if not _has_diagnostics_function(diagnostics):
         return [

script/hassfest/quality_scale_validation/discovery.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 MANIFEST_KEYS = [
@@ -49,7 +50,7 @@ def validate(integration: Integration) -> list[str] | None:
         return None
 
     # Fallback => check config_flow step
-    config_flow = ast.parse(config_flow_file.read_text())
+    config_flow = ast_parse_module(config_flow_file)
     if not (_has_discovery_function(config_flow)):
         return [
             f"Integration is missing one of {CONFIG_FLOW_STEPS} "

script/hassfest/quality_scale_validation/reauthentication_flow.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 
@@ -20,7 +21,7 @@ def validate(integration: Integration) -> list[str] | None:
     """Validate that the integration has a reauthentication flow."""
 
     config_flow_file = integration.path / "config_flow.py"
-    config_flow = ast.parse(config_flow_file.read_text())
+    config_flow = ast_parse_module(config_flow_file)
 
     if not _has_step_reauth_function(config_flow):
         return [

script/hassfest/quality_scale_validation/reconfiguration_flow.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 
@@ -20,7 +21,7 @@ def validate(integration: Integration) -> list[str] | None:
     """Validate that the integration has a reconfiguration flow."""
 
     config_flow_file = integration.path / "config_flow.py"
-    config_flow = ast.parse(config_flow_file.read_text())
+    config_flow = ast_parse_module(config_flow_file)
 
     if not _has_step_reconfigure_function(config_flow):
         return [

script/hassfest/quality_scale_validation/runtime_data.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 
@@ -35,7 +36,7 @@ def _get_setup_entry_function(module: ast.Module) -> ast.AsyncFunctionDef | None
 def validate(integration: Integration) -> list[str] | None:
     """Validate correct use of ConfigEntry.runtime_data."""
     init_file = integration.path / "__init__.py"
-    init = ast.parse(init_file.read_text())
+    init = ast_parse_module(init_file)
 
     # Should not happen, but better to be safe
     if not (async_setup_entry := _get_setup_entry_function(init)):

script/hassfest/quality_scale_validation/unique_config_entry.py

@@ -5,6 +5,7 @@
 
 import ast
 
+from script.hassfest import ast_parse_module
 from script.hassfest.model import Integration
 
 
@@ -36,7 +37,7 @@ def validate(integration: Integration) -> list[str] | None:
         return None
 
     config_flow_file = integration.path / "config_flow.py"
-    config_flow = ast.parse(config_flow_file.read_text())
+    config_flow = ast_parse_module(config_flow_file)
 
     if not (
         _has_abort_entries_match(config_flow)