fix: log into registry.redhat.io

Signed-off-by: Matej Vasek <[email protected]>

.github/workflows/test-e2e-oncluster-runtime.yaml

@@ -22,6 +22,11 @@ jobs:
         run: ./hack/create-testing-func-image.sh
       - name: Allocate Cluster
         run: ./hack/allocate.sh
+      - name: Pull secrets for KinD cluster
+        env:
+          RH_REG_USR: ${{ secrets.RH_REG_USR }}
+          RH_REG_PWD: ${{ secrets.RH_REG_PWD }}
+        run: go run ./hack/kind_pull_secrtes.go
       - name: Deploy Tekton
         run: ./hack/tekton.sh
       - name: Deploy Test Git Server

.github/workflows/test-e2e-oncluster.yaml

@@ -22,6 +22,11 @@ jobs:
         run: ./hack/create-testing-func-image.sh
       - name: Allocate Cluster
         run: ./hack/allocate.sh
+      - name: Pull secrets for KinD cluster
+        env:
+          RH_REG_USR: ${{ secrets.RH_REG_USR }}
+          RH_REG_PWD: ${{ secrets.RH_REG_PWD }}
+        run: go run ./hack/kind_pull_secrtes.go
       - name: Deploy Tekton
         run: ./hack/tekton.sh
       - name: Deploy Test Git Server

hack/kind_pull_secrtes.go

@@ -0,0 +1,73 @@
+package main
+
+import (
+	"archive/tar"
+	"bytes"
+	"context"
+	"encoding/base64"
+	"encoding/json"
+	"fmt"
+	"os"
+	"os/signal"
+	"syscall"
+
+	"github.com/docker/docker/api/types"
+	"github.com/docker/docker/client"
+)
+
+func main() {
+	ctx, cancel := signal.NotifyContext(context.Background(), syscall.SIGINT, syscall.SIGTERM)
+	defer cancel()
+	err := copySecrets(ctx)
+	if err != nil {
+		fmt.Fprintln(os.Stderr, err)
+		os.Exit(1)
+	}
+}
+
+func copySecrets(ctx context.Context) error {
+	cli, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
+	if err != nil {
+		return fmt.Errorf("cannot get docker client: %w", err)
+	}
+
+	auth := base64.StdEncoding.EncodeToString([]byte(os.Getenv("RH_REG_USR") + ":" + os.Getenv("RH_REG_PWD")))
+
+	config := map[string]any{
+		"auths": map[string]any{
+			"registry.redhat.io": map[string]string{"auth": auth},
+		},
+	}
+
+	configData, err := json.Marshal(&config)
+	if err != nil {
+		return fmt.Errorf("cannot marshal config: %w", err)
+	}
+
+	var buff bytes.Buffer
+	tw := tar.NewWriter(&buff)
+	err = tw.WriteHeader(&tar.Header{
+		Name:     "config.json",
+		Typeflag: tar.TypeReg,
+		Size:     int64(len(configData)),
+		Mode:     0600,
+	})
+	if err != nil {
+		return fmt.Errorf("cannot write tar header: %w", err)
+	}
+	_, err = tw.Write(configData)
+	if err != nil {
+		return fmt.Errorf("cannot write file to tar: %w", err)
+	}
+	err = tw.Close()
+	if err != nil {
+		return fmt.Errorf("cannot close tar: %w", err)
+	}
+
+	err = cli.CopyToContainer(ctx, "func-control-plane", "/var/lib/kubelet/", &buff, types.CopyToContainerOptions{})
+	if err != nil {
+		return fmt.Errorf("cannot copy to container: %w", err)
+	}
+
+	return nil
+}