feat: better registry handling ✨

.vscode/settings.json

@@ -1,6 +1,6 @@
 {
     "python.testing.pytestArgs": [
-        "operator"
+        "client"
     ],
     "python.testing.unittestEnabled": false,
     "python.testing.pytestEnabled": true,

client/gefyra/api/install.py

@@ -51,7 +51,10 @@ def install(
     from gefyra.configuration import ClientConfiguration
 
     config = ClientConfiguration(
-        kube_config_file=kubeconfig, kube_context=kubecontext, ignore_docker=True
+        kube_config_file=kubeconfig,
+        kube_context=kubecontext,
+        ignore_docker=True,
+        registry_url=kwargs.get("registry_url", ""),
     )
     if preset:
         presetoptions = LB_PRESETS.get(preset)  # type: ignore

client/gefyra/api/operator.py

@@ -38,7 +38,7 @@ def update(
                             "containers": [
                                 {
                                     "name": "gefyra",
-                                    "image": f"quay.io/gefyra/operator:{version}",
+                                    "image": config.OPERATOR_IMAGE,
                                 }
                             ]
                         }

client/gefyra/api/status.py

@@ -153,7 +153,9 @@ def status(connection_name: str = "") -> GefyraStatus:
         client = _get_client_status(config)
     except urllib3.exceptions.MaxRetryError as e:
         raise ClientConfigurationError(
-            f"Cannot reach cluster on {e.pool.host}:{e.pool.port}"
+            f"Cannot reach cluster on {e.pool.host}:{e.pool.port}\n"
+            f"Used kubeconfig: {config.KUBE_CONFIG_FILE} from Gefyra connection {connection_name}\n"
+            f"Please delete the connection and create a new one. Use: gefyra connection remove {connection_name}"
         )
 
     if client.connection:

client/gefyra/cli/installation.py

@@ -48,8 +48,9 @@ def install(ctx, component, preset, apply, wait, **kwargs):
     from alive_progress import alive_bar
     from gefyra import api
 
-    if not all(kwargs.values()):
-        kwargs = {}
+    # filter out empty kwargs
+    kwargs = {k: v for k, v in kwargs.items() if v}
+
     if wait and not apply:
         raise click.BadOptionUsage(
             option_name="wait", message="Cannot wait without '--apply'"

client/gefyra/cli/main.py

@@ -15,9 +15,7 @@
 from gefyra.cli.utils import AliasedGroup
 
 
-@click.group(
-    cls=AliasedGroup,
-)
+@click.group(cls=AliasedGroup)
 @click.option(
     "--kubeconfig",
     help="Path to the kubeconfig file to use instead of loading the default",
@@ -32,6 +30,7 @@ def cli(ctx: click.Context, kubeconfig, context, debug):
     import logging
     from gefyra.cli.telemetry import CliTelemetry
 
+    # Set up logging based on the debug flag
     if debug:
         logger = logging.getLogger()
         handler = logging.StreamHandler()
@@ -43,12 +42,14 @@ def cli(ctx: click.Context, kubeconfig, context, debug):
         logging.getLogger("gefyra").setLevel(logging.DEBUG)
     else:
         logging.getLogger("gefyra").setLevel(logging.ERROR)
+
     ctx.ensure_object(dict)
 
     try:
         ctx.obj["telemetry"] = CliTelemetry()
     except Exception:  # pragma: no cover
         ctx.obj["telemetry"] = False
+    ctx.obj["debug"] = debug
     ctx.obj["kubeconfig"] = kubeconfig
     ctx.obj["context"] = context
 

client/gefyra/cli/utils.py

@@ -150,7 +150,7 @@ def parser_process(value, state):
 
 def multi_options(options):
     map_to_types = dict(
-        array=str,
+        array=list,
         number=float,
         string=str,
     )

client/gefyra/misc/comps/deployment.py

@@ -38,7 +38,7 @@ def data(params: "GefyraInstallOptions") -> list[dict]:
                         "containers": [
                             {
                                 "name": "gefyra",
-                                "image": f"quay.io/gefyra/operator:{params.version}",
+                                "image": f"{params.registry_url}/operator:{params.version}",
                                 "imagePullPolicy": "IfNotPresent",
                                 "ports": [{"containerPort": 9443}],
                                 "env": [
@@ -88,7 +88,7 @@ def data(params: "GefyraInstallOptions") -> list[dict]:
                         "containers": [
                             {
                                 "name": "gefyra",
-                                "image": f"quay.io/gefyra/operator:{params.version}",
+                                "image": f"{params.registry_url}/operator:{params.version}",
                                 "imagePullPolicy": "IfNotPresent",
                                 "ports": [{"containerPort": 9443}],
                                 "env": [

client/gefyra/misc/comps/service.py

@@ -23,7 +23,14 @@ def data(params: "GefyraInstallOptions") -> list[dict]:
             )
     if params.service_annotations:
         try:
-            stowaway_annotations.update(params.service_annotations)
+            for annotation in params.service_annotations:
+                try:
+                    # handle cli params as key=value
+                    key, value = annotation[0].split("=")
+                    stowaway_annotations[key] = value
+                except ValueError:
+                    # handle preset values
+                    stowaway_annotations.update(params.service_annotations)
         except IndexError:
             raise ValueError(
                 f"Invalid service-annotations format. Please use the form key=value."

client/gefyra/types.py

@@ -275,6 +275,12 @@ class GefyraInstallOptions:
             type="array",
         ),
     )
+    registry_url: str = field(
+        default_factory=lambda: "quay.io/gefyra",
+        metadata=dict(
+            help="The registry URL for the images (default: quay.io/gefyra)",
+        ),
+    )
 
 
 @dataclass