Expand CRUD testing

Signed-off-by: Andy Goldstein <andy.goldstein@redhat.com>

Author: ncdc

controllers/configmap_controller.go

@@ -18,6 +18,7 @@ package controllers
 
 import (
 	"context"
+	"fmt"
 
 	kcpclient "github.com/kcp-dev/apimachinery/pkg/client"
 	corev1 "k8s.io/api/core/v1"
@@ -35,13 +36,47 @@ func (r *ConfigMapReconciler) Reconcile(ctx context.Context, req ctrl.Request) (
 
 	ctx = kcpclient.WithCluster(ctx, req.ObjectKey.Cluster)
 
-	var configmap corev1.ConfigMap
-	if err := r.Get(ctx, req.ObjectKey, &configmap); err != nil {
+	// Test get
+	var configMap corev1.ConfigMap
+
+	if err := r.Get(ctx, req.ObjectKey, &configMap); err != nil {
 		log.Error(err, "unable to get configmap")
-		return ctrl.Result{}, err
+		return ctrl.Result{}, nil
+	}
+
+	log.Info("Get: retrieved configMap")
+
+	// Test list
+	var configMapList corev1.ConfigMapList
+	if err := r.List(ctx, &configMapList); err != nil {
+		log.Error(err, "unable to list configmaps")
+		return ctrl.Result{}, nil
+	}
+	for _, cm := range configMapList.Items {
+		log.Info("List: got", "namespace", cm.Namespace, "name", cm.Name)
+	}
+
+	labels := configMap.Labels
+	if labels == nil {
+		return ctrl.Result{}, nil
 	}
 
-	log.Info("Retrieved configmap")
+	// Test Update
+	if labels["name"] == "" {
+		return ctrl.Result{}, nil
+	}
+
+	response := fmt.Sprintf("hello-%s", labels["name"])
+
+	if labels["response"] == response {
+		return ctrl.Result{}, nil
+	}
+
+	labels["response"] = response
+
+	if err := r.Update(ctx, &configMap); err != nil {
+		return ctrl.Result{}, err
+	}
 
 	return ctrl.Result{}, nil
 }

main.go

@@ -17,6 +17,7 @@ limitations under the License.
 package main
 
 import (
+	"flag"
 	"os"
 
 	kcpcache "github.com/kcp-dev/apimachinery/pkg/cache"
@@ -26,6 +27,7 @@ import (
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
+	"sigs.k8s.io/controller-runtime/pkg/client/config"
 
 	_ "k8s.io/client-go/plugin/pkg/client/auth/gcp"
 	"k8s.io/client-go/rest"
@@ -38,18 +40,27 @@ import (
 )
 
 var (
-	scheme   = runtime.NewScheme()
-	setupLog = ctrl.Log.WithName("setup")
+	scheme            = runtime.NewScheme()
+	setupLog          = ctrl.Log.WithName("setup")
+	kubeconfigContext string
 )
 
 func init() {
 	utilruntime.Must(corev1.AddToScheme(scheme))
+
+	flag.StringVar(&kubeconfigContext, "context", "", "kubeconfig context")
 }
 
 func main() {
+	flag.Parse()
+
 	ctrl.SetLogger(zap.New())
 
-	cfg := ctrl.GetConfigOrDie()
+	cfg, err := config.GetConfigWithContext(kubeconfigContext)
+	if err != nil {
+		setupLog.Error(err, "unable to get rest config")
+		os.Exit(1)
+	}
 
 	httpClient, err := rest.HTTPClientFor(cfg)
 	if err != nil {