fluxcd
/
notification-controller
mirror of https://github.com/fluxcd/notification-controller.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

receiver: update default ImageRepository version 

Signed-off-by: Hidde Beydals <hidde@hhh.computer>
This commit is contained in:
Hidde Beydals 2023-02-28 11:07:03 +01:00
parent 325d6d2fbc
commit 7448a667a0
No known key found for this signature in database
GPG Key ID: 979F380FC2341744
1 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
internal/server/receiver_handlers.go
View File

@ -42,6 +42,15 @@ import (
apiv1 "github.com/fluxcd/notification-controller/api/v1beta2" apiv1 "github.com/fluxcd/notification-controller/api/v1beta2"
) )
// defaultFluxAPIVersions is a map of Flux API kinds to their API versions.
var defaultFluxAPIVersions = map[string]string{
"Bucket": "source.toolkit.fluxcd.io/v1beta2",
"HelmRepository": "source.toolkit.fluxcd.io/v1beta2",
"GitRepository": "source.toolkit.fluxcd.io/v1beta2",
"OCIRepository": "source.toolkit.fluxcd.io/v1beta2",
"ImageRepository": "image.toolkit.fluxcd.io/v1beta2",
}
func (s *ReceiverServer) handlePayload() func(w http.ResponseWriter, r *http.Request) { func (s *ReceiverServer) handlePayload() func(w http.ResponseWriter, r *http.Request) {
return func(w http.ResponseWriter, r *http.Request) { return func(w http.ResponseWriter, r *http.Request) {
ctx := context.Background() ctx := context.Background()
@ -348,20 +357,12 @@ func (s *ReceiverServer) annotate(ctx context.Context, resource apiv1.CrossNames
Name: resource.Name, Name: resource.Name,
} }
apiVersionMap := map[string]string{
"Bucket": "source.toolkit.fluxcd.io/v1beta2",
"HelmRepository": "source.toolkit.fluxcd.io/v1beta2",
"GitRepository": "source.toolkit.fluxcd.io/v1beta2",
"OCIRepository": "source.toolkit.fluxcd.io/v1beta2",
"ImageRepository": "image.toolkit.fluxcd.io/v1beta1",
}
apiVersion := resource.APIVersion apiVersion := resource.APIVersion
if apiVersion == "" { if apiVersion == "" {
if apiVersionMap[resource.Kind] == "" { if defaultFluxAPIVersions[resource.Kind] == "" {
return fmt.Errorf("apiVersion must be specified for kind '%s'", resource.Kind) return fmt.Errorf("apiVersion must be specified for kind '%s'", resource.Kind)
} }
apiVersion = apiVersionMap[resource.Kind] apiVersion = defaultFluxAPIVersions[resource.Kind]
} }
group, version := getGroupVersion(apiVersion) group, version := getGroupVersion(apiVersion)