mirror of
https://github.com/hanzoai/kms-operator.git
synced 2026-10-30 18:32:57 +00:00
- Migrate Go module from github.com/luxfi/kms/k8-operator to github.com/hanzoai/kms-operator - Make API_HOST_URL configurable via KMS_API_HOST_URL env var with fallback to kms.hanzo.ai (overrideable per-CRD or ConfigMap) - Update default API endpoint from kms.lux.network to kms.hanzo.ai - Update USER_AGENT_NAME from k8-operator to kms-operator - Update all sample YAML hostAPI defaults - Update PROJECT file with new repo/module path The CRD API group (secrets.lux.network) is intentionally preserved for the Lux white-label deployment.
46 lines
1.2 KiB
Go
46 lines
1.2 KiB
Go
package controllerhelpers
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/hanzoai/kms-operator/packages/constants"
|
|
corev1 "k8s.io/api/core/v1"
|
|
k8Errors "k8s.io/apimachinery/pkg/api/errors"
|
|
"k8s.io/apimachinery/pkg/types"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
)
|
|
|
|
func GetKMSConfigMap(ctx context.Context, client client.Client) (configMap map[string]string, errToReturn error) {
|
|
// default key values
|
|
defaultConfigMapData := make(map[string]string)
|
|
defaultConfigMapData["hostAPI"] = constants.KMS_DOMAIN
|
|
|
|
kubeConfigMap := &corev1.ConfigMap{}
|
|
err := client.Get(ctx, types.NamespacedName{
|
|
Namespace: constants.OPERATOR_SETTINGS_CONFIGMAP_NAMESPACE,
|
|
Name: constants.OPERATOR_SETTINGS_CONFIGMAP_NAME,
|
|
}, kubeConfigMap)
|
|
|
|
if err != nil {
|
|
if k8Errors.IsNotFound(err) {
|
|
kubeConfigMap = nil
|
|
} else {
|
|
return nil, fmt.Errorf("GetConfigMapByNamespacedName: unable to fetch config map in [namespacedName=%s] [err=%s]", constants.OPERATOR_SETTINGS_CONFIGMAP_NAMESPACE, err)
|
|
}
|
|
}
|
|
|
|
if kubeConfigMap == nil {
|
|
return defaultConfigMapData, nil
|
|
} else {
|
|
for key, value := range defaultConfigMapData {
|
|
_, exists := kubeConfigMap.Data[key]
|
|
if !exists {
|
|
kubeConfigMap.Data[key] = value
|
|
}
|
|
}
|
|
|
|
return kubeConfigMap.Data, nil
|
|
}
|
|
}
|