Merge pull request #136 from kobergj/NatsAuthentication

Allow username/password authentication in events/natsjs
micro · Dec 15, 2023 · f7f8d32 · f7f8d32
2 parents bbace9e + ac82881
commit f7f8d32
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/v4/events/natsjs/nats.go b/v4/events/natsjs/nats.go
@@ -69,6 +69,11 @@ func connectToNatsJetStream(options Options) (nats.JetStreamContext, error) {
 		nopts.Name = options.Name
 	}
 
+	if options.Username != "" && options.Password != "" {
+		nopts.User = options.Username
+		nopts.Password = options.Password
+	}
+
 	conn, err := nopts.Connect()
 	if err != nil {
 		tls := nopts.TLSConfig != nil

diff --git a/v4/events/natsjs/options.go b/v4/events/natsjs/options.go
@@ -17,6 +17,8 @@ type Options struct {
 	SyncPublish           bool
 	Name                  string
 	DisableDurableStreams bool
+	Username              string
+	Password              string
 }
 
 // Option is a function which configures options.
@@ -84,3 +86,11 @@ func DisableDurableStreams() Option {
 		o.DisableDurableStreams = true
 	}
 }
+
+// Authenticate authenticates the connection with the given username and password.
+func Authenticate(username, password string) Option {
+	return func(o *Options) {
+		o.Username = username
+		o.Password = password
+	}
+}