Merge pull request #12 from CAAPIM/repo_sync_update

repository endpoints can now be updated

Makefile

@@ -186,7 +186,7 @@ build: generate fmt vet ## Build manager binary.
 
 .PHONY: run
 run: manifests generate fmt vet ## Run a controller from your host.
-	go run ./main.go
+	go run ./main.go --zap-log-level=10
 
 .PHONY: docker-build
 docker-build: #test ## Build docker image with the manager.

pkg/gateway/reconcile/l7repositories.go

@@ -24,7 +24,7 @@ func syncRepository(ctx context.Context, params Params) {
 
 	cntr := 0
 	for _, repoRef := range gateway.Spec.App.RepositoryReferences {
-		if repoRef.Enabled && repoRef.Type == "dynamic" {
+		if repoRef.Enabled {
 			cntr++
 		}
 	}
@@ -34,7 +34,7 @@ func syncRepository(ctx context.Context, params Params) {
 	}
 
 	for _, repoRef := range gateway.Spec.App.RepositoryReferences {
-		if repoRef.Enabled && repoRef.Type == "dynamic" {
+		if repoRef.Enabled {
 			err := reconcileDynamicRepository(ctx, params, gateway, repoRef)
 			if err != nil {
 				params.Log.Error(err, "failed to reconcile repository reference", "name", gateway.Name, "repository", repoRef.Name, "namespace", gateway.Namespace)
@@ -65,14 +65,27 @@ func reconcileDynamicRepository(ctx context.Context, params Params, gateway *sec
 			if err != nil {
 				params.Log.Info("failed to apply commit", "name", gateway.Name, "namespace", gateway.Namespace, "error", err.Error())
 			}
+
 		} else {
 			err = applyDbBacked(ctx, params, gateway, repository, repoRef, commit)
 			if err != nil {
 				params.Log.Info("failed to apply commit", "name", gateway.Name, "namespace", gateway.Namespace, "error", err.Error())
 				return err
 			}
 		}
+		//case "static":
+
 	}
+
+	for _, sRepo := range gateway.Status.RepositoryStatus {
+		if sRepo.Name == repoRef.Name {
+			if sRepo.Commit != commit {
+				params.Instance = gateway
+				_ = GatewayStatus(ctx, params)
+			}
+		}
+	}
+
 	return nil
 }
 

pkg/gateway/reconcile/status.go

@@ -95,7 +95,8 @@ func GatewayStatus(ctx context.Context, params Params) error {
 		params.Instance.Status = gatewayStatus
 		err = params.Client.Status().Update(ctx, params.Instance)
 		if err != nil {
-			params.Log.Info("failed to update gateway status", "name", params.Instance.Name, "namespace", params.Instance.Namespace, "message", err.Error())
+			params.Log.V(2).Info("failed to update gateway status", "name", params.Instance.Name, "namespace", params.Instance.Namespace, "message", err.Error())
+			return err
 		}
 	}
 	return nil

pkg/util/git.go

@@ -65,10 +65,22 @@ func CloneRepository(url string, username string, token string, branch string, t
 			return commit.Hash.String(), nil
 		}
 
-		_ = w.Pull(&pullOpts)
-		// if err != nil {
-		// 	return "", err
-		// }
+		gbytes, _ := os.ReadFile("/tmp/" + name + "-" + ext + "/.git/config")
+		if !strings.Contains(string(gbytes), cloneOpts.URL) {
+			err = os.RemoveAll("/tmp/" + name + "-" + ext)
+			if err != nil {
+				return "", err
+			}
+			return "", errors.New("repository endpoint updated, flushing temp storage")
+		}
+
+		err = w.Pull(&pullOpts)
+		if err != nil {
+			if err == git.NoErrAlreadyUpToDate {
+				return commit.Hash.String(), nil
+			}
+			return "", err
+		}
 
 		return commit.Hash.String(), nil
 	}