vms: use vm fact/secret-store

pkgs/clan-cli/clan_cli/facts/check.py

@@ -11,10 +11,11 @@ def check_facts(machine: Machine) -> bool:
     facts_module = importlib.import_module(machine.facts_module)
     fact_store = facts_module.FactStore(machine=machine)
 
+    existing_facts = fact_store.get_all()
     missing_facts = []
     for service in machine.secrets_data:
         for fact in machine.secrets_data[service]["facts"]:
-            if not fact_store.get(service, fact):
+            if fact not in existing_facts.get(service, {}):
                 log.info(f"Fact {fact} for service {service} is missing")
                 missing_facts.append((service, fact))
 

pkgs/clan-cli/clan_cli/facts/list.py

@@ -1,6 +1,6 @@
-import json
 import argparse
 import importlib
+import json
 import logging
 
 from ..machines.machines import Machine

pkgs/clan-cli/clan_cli/facts/modules/in_repo.py

@@ -7,6 +7,7 @@ from clan_cli.machines.machines import Machine
 class FactStore:
     def __init__(self, machine: Machine) -> None:
         self.machine = machine
+        self.works_remotely = False
 
     def set(self, _service: str, name: str, value: bytes) -> Path | None:
         if isinstance(self.machine.flake, Path):
@@ -23,12 +24,16 @@ class FactStore:
             )
 
     def exists(self, _service: str, name: str) -> bool:
-        fact_path = self.machine.flake_dir / "machines" / self.machine.name / "facts" / name
+        fact_path = (
+            self.machine.flake_dir / "machines" / self.machine.name / "facts" / name
+        )
         return fact_path.exists()
 
     # get a single fact
     def get(self, _service: str, name: str) -> bytes:
-        fact_path = self.machine.flake_dir / "machines" / self.machine.name / "facts" / name
+        fact_path = (
+            self.machine.flake_dir / "machines" / self.machine.name / "facts" / name
+        )
         return fact_path.read_bytes()
 
     # get all facts

pkgs/clan-cli/clan_cli/facts/modules/vm.py

@@ -0,0 +1,44 @@
+import logging
+from pathlib import Path
+
+from clan_cli.dirs import vm_state_dir
+from clan_cli.errors import ClanError
+from clan_cli.machines.machines import Machine
+
+log = logging.getLogger(__name__)
+
+
+class FactStore:
+    def __init__(self, machine: Machine) -> None:
+        self.machine = machine
+        self.works_remotely = False
+        self.dir = vm_state_dir(str(machine.flake), machine.name) / "facts"
+        log.debug(f"FactStore initialized with dir {self.dir}")
+
+    def exists(self, service: str, name: str) -> bool:
+        fact_path = self.dir / service / name
+        return fact_path.exists()
+
+    def set(self, service: str, name: str, value: bytes) -> Path | None:
+        fact_path = self.dir / service / name
+        fact_path.parent.mkdir(parents=True, exist_ok=True)
+        fact_path.write_bytes(value)
+        return None
+
+    # get a single fact
+    def get(self, service: str, name: str) -> bytes:
+        fact_path = self.dir / service / name
+        if fact_path.exists():
+            return fact_path.read_bytes()
+        raise ClanError(f"Fact {name} for service {service} not found")
+
+    # get all facts
+    def get_all(self) -> dict[str, dict[str, bytes]]:
+        facts: dict[str, dict[str, bytes]] = {}
+        if self.dir.exists():
+            for service in self.dir.iterdir():
+                facts[service.name] = {}
+                for fact in service.iterdir():
+                    facts[service.name][fact.name] = fact.read_bytes()
+
+        return facts