-
Notifications
You must be signed in to change notification settings - Fork 89
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Auto configuring newly created GitHub Repos with GH App
supports template for generating namespace for repos Signed-off-by: Shivam Mukhade <[email protected]>
- Loading branch information
Shivam Mukhade
committed
Oct 26, 2022
1 parent
75b3932
commit 08fecbd
Showing
10 changed files
with
380 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,112 @@ | ||
| package github | ||
|
|
||
| import ( | ||
| "context" | ||
| "encoding/json" | ||
| "fmt" | ||
| "net/http" | ||
|
|
||
| "github.com/google/go-github/v47/github" | ||
| "github.com/openshift-pipelines/pipelines-as-code/pkg/apis/pipelinesascode/v1alpha1" | ||
| "github.com/openshift-pipelines/pipelines-as-code/pkg/formatting" | ||
| "github.com/openshift-pipelines/pipelines-as-code/pkg/params" | ||
| "github.com/openshift-pipelines/pipelines-as-code/pkg/params/clients" | ||
| "github.com/openshift-pipelines/pipelines-as-code/pkg/templates" | ||
| "go.uber.org/zap" | ||
| corev1 "k8s.io/api/core/v1" | ||
| "k8s.io/apimachinery/pkg/api/errors" | ||
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" | ||
| ) | ||
|
|
||
| const defaultNsTemplate = "%v-pipelines" | ||
|
|
||
| func ConfigureRepository(ctx context.Context, run *params.Run, req *http.Request, payload string, logger *zap.SugaredLogger) (bool, bool, error) { | ||
| // gitea set x-github-event too, so skip it for the gitea driver | ||
| if h := req.Header.Get("X-Gitea-Event-Type"); h != "" { | ||
| return false, false, nil | ||
| } | ||
| event := req.Header.Get("X-Github-Event") | ||
| if event != "repository" { | ||
| return false, false, nil | ||
| } | ||
|
|
||
| eventInt, err := github.ParseWebHook(event, []byte(payload)) | ||
| if err != nil { | ||
| return true, false, err | ||
| } | ||
| _ = json.Unmarshal([]byte(payload), &eventInt) | ||
| repoEvent, _ := eventInt.(*github.RepositoryEvent) | ||
|
|
||
| if repoEvent.GetAction() != "created" { | ||
| logger.Infof("github: repository event \"%v\" is not supported", repoEvent.GetAction()) | ||
| return true, false, nil | ||
| } | ||
|
|
||
| logger.Infof("github: configuring repository cr for repo: %v", repoEvent.Repo.GetHTMLURL()) | ||
| if err := createRepository(ctx, run.Info.Pac.AutoConfigureRepoNamespaceTemplate, run.Clients, repoEvent, logger); err != nil { | ||
| logger.Errorf("failed repository creation: %v", err) | ||
| return true, true, err | ||
| } | ||
|
|
||
| return true, true, nil | ||
| } | ||
|
|
||
| func createRepository(ctx context.Context, nsTemplate string, clients clients.Clients, gitEvent *github.RepositoryEvent, logger *zap.SugaredLogger) error { | ||
| repoNsName, err := generateNamespaceName(nsTemplate, gitEvent) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to generate namespace for repo: %w", err) | ||
| } | ||
|
|
||
| logger.Info("github: generated namespace name: ", repoNsName) | ||
|
|
||
| // create namespace | ||
| repoNs := &corev1.Namespace{ | ||
| ObjectMeta: metav1.ObjectMeta{ | ||
| Name: repoNsName, | ||
| }, | ||
| } | ||
| repoNs, err = clients.Kube.CoreV1().Namespaces().Create(ctx, repoNs, metav1.CreateOptions{}) | ||
| if err != nil && !errors.IsAlreadyExists(err) { | ||
| return fmt.Errorf("failed to create namespace %v: %w", repoNs.Name, err) | ||
| } | ||
|
|
||
| if errors.IsAlreadyExists(err) { | ||
| logger.Infof("github: namespace %v already exists, creating repository", repoNsName) | ||
| } else { | ||
| logger.Info("github: created repository namespace: ", repoNs.Name) | ||
| } | ||
|
|
||
| // create repository | ||
| repo := &v1alpha1.Repository{ | ||
| ObjectMeta: metav1.ObjectMeta{ | ||
| Name: repoNsName, | ||
| Namespace: repoNsName, | ||
| }, | ||
| Spec: v1alpha1.RepositorySpec{ | ||
| URL: gitEvent.Repo.GetHTMLURL(), | ||
| }, | ||
| } | ||
| repo, err = clients.PipelineAsCode.PipelinesascodeV1alpha1().Repositories(repoNsName).Create(ctx, repo, metav1.CreateOptions{}) | ||
| if err != nil { | ||
| return fmt.Errorf("failed to create repository for repo: %v: %w", gitEvent.Repo.GetHTMLURL(), err) | ||
| } | ||
| logger.Infof("github: repository created: %s/%s ", repo.Namespace, repo.Name) | ||
| return nil | ||
| } | ||
|
|
||
| func generateNamespaceName(nsTemplate string, gitEvent *github.RepositoryEvent) (string, error) { | ||
| repoOwner, repoName, err := formatting.GetRepoOwnerSplitted(gitEvent.Repo.GetHTMLURL()) | ||
| if err != nil { | ||
| return "", fmt.Errorf("failed to parse git repo url: %w", err) | ||
| } | ||
|
|
||
| if nsTemplate == "" { | ||
| return fmt.Sprintf(defaultNsTemplate, repoName), nil | ||
| } | ||
|
|
||
| maptemplate := map[string]string{ | ||
| "repo_owner": repoOwner, | ||
| "repo_name": repoName, | ||
| } | ||
| return templates.ReplacePlaceHoldersVariables(nsTemplate, maptemplate), nil | ||
| } |
Oops, something went wrong.