gravel: ctrl/nodes: add host to orchestrator

Signed-off-by: Joao Eduardo Luis <[email protected]>

src/gravel/controllers/nodes/mgr.py

@@ -560,6 +560,9 @@ async def _handle_ready_to_add(
         node: JoiningNodeModel = self._joining[address]
         logger.info("=> mgr -- handle ready to add > "
                     f"hostname: {node.hostname}, address: {node.address}")
+        orch = Orchestrator()
+        if not orch.host_add(node.hostname, node.address):
+            logger.error("=> mgr -- handle ready > failed adding host to orch")
 
 
 _nodemgr: Optional[NodeMgr] = None

src/gravel/controllers/orch/orchestrator.py

@@ -3,10 +3,20 @@
 
 from typing import Any, Dict, List
 
+from logging import Logger
+from fastapi.logger import logger as fastapi_logger
 from pydantic.tools import parse_obj_as
-from gravel.controllers.orch.ceph import Mgr
-from gravel.controllers.orch.models \
-    import OrchDevicesPerHostModel, OrchHostListModel
+from gravel.controllers.orch.ceph import (
+    CephCommandError,
+    Mgr
+)
+from gravel.controllers.orch.models import (
+    OrchDevicesPerHostModel,
+    OrchHostListModel
+)
+
+
+logger: Logger = fastapi_logger
 
 
 class Orchestrator:
@@ -61,3 +71,21 @@ def get_public_key(self) -> str:
         res = self.call(cmd)
         assert "result" in res
         return res["result"]
+
+    def host_add(self, hostname: str, address: str) -> bool:
+        assert hostname
+        assert address
+
+        cmd = {
+            "prefix": "orch host add",
+            "hostname": hostname,
+            "addr": address
+        }
+        try:
+            self.call(cmd)
+        except CephCommandError:
+            logger.error(
+                f"=> orch -- host add > unable to add {hostname} {address}"
+            )
+            return False
+        return True