chore(helmbroker): add helm config

Author: lijianguo

rootfs/helmbroker/tasks.py

@@ -7,9 +7,9 @@
     UpdateDetails, BindDetails
 
 from .celery import app
-from .utils import command, get_plan_path, get_chart_path, get_cred_value, \
+from .utils import get_plan_path, get_chart_path, get_cred_value, \
     InstanceLock, dump_instance_meta, dump_binding_meta, load_instance_meta, \
-    get_instance_file
+    get_instance_file, helm
 
 
 @app.task(serializer='pickle')
@@ -25,7 +25,7 @@ def provision(instance_id: str, details: ProvisionDetails):
                 "update",
                 chart_path,
             ]
-            command("helm", *args)
+            helm(instance_id, *args)
         values_file = os.path.join(get_plan_path(instance_id), "values.yaml")
         args = [
             "install",
@@ -43,7 +43,7 @@ def provision(instance_id: str, details: ProvisionDetails):
             f"fullnameOverride=helmbroker-{details.context['instance_name']}"
         ]
 
-        status, output = command("helm", *args)
+        status, output = helm(instance_id, *args)
         data = load_instance_meta(instance_id)
         if status != 0:
             data["last_operation"]["state"] = OperationState.FAILED.value
@@ -91,7 +91,7 @@ def update(instance_id: str, details: UpdateDetails):
         f"fullnameOverride=helmbroker-{details.context['instance_name']}"
     ]
 
-    status, output = command("helm", *args)
+    status, output = helm(instance_id, *args)
     if status != 0:
         data["last_operation"]["state"] = OperationState.FAILED.value
         data["last_operation"]["description"] = (
@@ -131,7 +131,7 @@ def bind(instance_id: str,
         "--set",
         f"fullnameOverride=helmbroker-{details.context['instance_name']}"
     ]
-    status, templates = command("helm", *args)  # output: templates.yaml
+    status, templates = helm(instance_id, *args)  # output: templates.yaml
     if status != 0:
         data["last_operation"]["state"] = OperationState.FAILED.value
         data["last_operation"]["description"] = "binding %s failed: %s" % (instance_id, templates)  # noqa
@@ -179,8 +179,8 @@ def deprovision(instance_id: str):
         data["last_operation"]["description"] = (
             "deprovision %s in progress at %s" % (instance_id, time.time()))
         dump_instance_meta(instance_id, data)
-        status, output = command(
-            "helm",
+        status, output = helm(
+            instance_id,
             "uninstall",
             data["details"]["context"]["instance_name"],
             "--namespace",

rootfs/helmbroker/utils.py

@@ -6,10 +6,14 @@
 import time
 
 from jsonschema import validate
-
 from .config import INSTANCES_PATH, ADDONS_PATH
 
 
+REGISTRY_CONFIG_SUFFIX = '.config/helm/registry.json'
+REPOSITORY_CACHE_SUFFIX = '.cache/helm/repository'
+REPOSITORY_CONFIG_SUFFIX = '.config/helm/repository'
+
+
 def command(cmd, *args, output_type="text"):
     status, output = subprocess.getstatusoutput("%s %s" % (cmd, " ".join(args))) # noqa
     if output_type == "yaml":
@@ -25,6 +29,21 @@ def command(cmd, *args, output_type="text"):
 get_plan_path = lambda instance_id: os.path.join(get_instance_path(instance_id), "plan") # noqa
 
 
+def helm(instance_id, *args, output_type="text"):
+    instance_path = get_instance_path(instance_id)
+    new_args = []
+    new_args.extend(args)
+    new_args.extend([
+        "--registry-config",
+        os.path.join(instance_path, REGISTRY_CONFIG_SUFFIX),
+        "--repository-cache",
+        os.path.join(instance_path, REPOSITORY_CACHE_SUFFIX),
+        "--repository-config",
+        os.path.join(instance_path, REPOSITORY_CONFIG_SUFFIX),
+    ])
+    return command("helm", *args, output_type=output_type)
+
+
 INSTANCE_META_SCHEMA = {
     "type": "object",
     "properties": {