crossplane
/
function-sdk-go
mirror of https://github.com/crossplane/function-sdk-go.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Refactor to GetCredential and check secret source 

Signed-off-by: Clément Blaise <clementblaise@me.com>
This commit is contained in:
Clément Blaise 2024-05-31 16:43:08 +08:00
parent 7617361f7c
commit 0115992df2
1 changed files with 13 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
request/request.go
View File

@ -21,6 +21,7 @@ import (
"google.golang.org/protobuf/types/known/structpb"
"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
"k8s.io/apimachinery/pkg/runtime"
"reflect"
"github.com/crossplane/function-sdk-go/errors"
"github.com/crossplane/function-sdk-go/proto/v1beta1"
@ -129,9 +130,14 @@ func GetExtraResources(req *v1beta1.RunFunctionRequest) (map[string][]resource.E
return out, nil
}
func GetCredentials(req *v1beta1.RunFunctionRequest) (map[string]resource.Credential, error) {
out := make(map[string]resource.Credential, len(req.GetCredentials()))
for name, cred := range req.GetCredentials() {
func GetCredential(req *v1beta1.RunFunctionRequest, name string) (resource.Credential, error) {
cred, exists := req.GetCredentials()[name]
if !exists {
return resource.Credential{}, errors.Errorf("%s: credential not found", name)
}
switch cred.GetSource().(type) {
case *v1beta1.Credentials_CredentialData:
data := cred.GetCredentialData().GetData()
interfaceMap := make(map[string]interface{}, len(data))
for k, v := range data {
@ -140,7 +146,9 @@ func GetCredentials(req *v1beta1.RunFunctionRequest) (map[string]resource.Creden
credential := resource.Credential{
Data: &unstructured.Unstructured{Object: interfaceMap},
}
out[name] = credential
return credential, nil
default:
sourceType := reflect.TypeOf(cred.GetSource()).String()
return resource.Credential{}, errors.Errorf("%s: not a supported credential source", sourceType)
}
return out, nil
}