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

Use token & channel in azureevent 

For JWT
* channel = eventhub namespace
* address = eventhub name
* token   = jwt token

For SAS
* address = connectionString, including endpoint tokens etc

Signed-off-by: Edvin Norling <edvin.norling@xenit.se>
This commit is contained in:
Edvin Norling 2021-05-05 10:18:19 +02:00
parent 45a77978b5
commit cfa71bf7a8
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
internal/notifier/azure_eventhub.go
View File

@ -17,7 +17,6 @@ import (
"context"
"encoding/json"
"fmt"
"strings"
"time"
"github.com/Azure/azure-amqp-common-go/v3/auth"
@ -31,12 +30,13 @@ type AzureEventHub struct {
}
// NewAzureEventHub creates a eventhub client
func NewAzureEventHub(endpointURL string) (*AzureEventHub, error) {
func NewAzureEventHub(endpointURL, token, eventhubNamespace string) (*AzureEventHub, error) {
var hub *eventhub.Hub
var err error
if strings.ToLower(endpointURL[:8]) != "endpoint" {
hub, err = newJWTHub(endpointURL)
// token should only be defined if JWT is used
if token != "" {
hub, err = newJWTHub(endpointURL, token, eventhubNamespace)
if err != nil {
return nil, fmt.Errorf("failed to create a eventhub using JWT %v", err)
}
@ -96,10 +96,10 @@ func (j *PureJWT) GetToken(uri string) (*auth.Token, error) {
}
// newJWTHub used when address is a JWT token
func newJWTHub(address string) (*eventhub.Hub, error) {
provider := NewJWTProvider(address)
func newJWTHub(eventhubName, token, eventhubNamespace string) (*eventhub.Hub, error) {
provider := NewJWTProvider(token)
hub, err := eventhub.NewHub("fluxv2", "fluxv2", provider)
hub, err := eventhub.NewHub(eventhubNamespace, eventhubName, provider)
if err != nil {
return nil, err
}

2
internal/notifier/factory.go
View File

@ -76,7 +76,7 @@ func (f Factory) Notifier(provider string) (Interface, error) {
case v1beta1.SentryProvider:
n, err = NewSentry(f.CertPool, f.URL)
case v1beta1.AzureEventHubProvider:
n, err = NewAzureEventHub(f.URL)
n, err = NewAzureEventHub(f.URL, f.Token, f.Channel)
default:
err = fmt.Errorf("provider %s not supported", provider)
}