Feat: Added Config and MustConnect function

* Config for NATS Connection
* MustConnect function uses Config to connect to remote servers
* internal helper functions

bridge.go

@@ -23,7 +23,7 @@ func newNATSBridge(servers []string, log LogFunc) (*natsBridge, error) {
 	url := strings.Join(servers, ",")
 
 	nb.connection, err = nats.Connect(url,
-		nats.DisconnectErrHandler(func(nc *nats.Conn, err error) {
+		nats.DisconnectErrHandler(func(_ *nats.Conn, err error) {
 			log("Got disconnected: %v", err)
 		}),
 		nats.ReconnectHandler(func(nc *nats.Conn) {

connection.go

@@ -2,6 +2,9 @@ package vnats
 
 import (
 	"fmt"
+	"log/slog"
+	"os"
+	"strings"
 
 	"github.com/nats-io/nats.go"
 )
@@ -29,6 +32,14 @@ type LogFunc func(format string, a ...interface{})
 // NoLogging is the default LogFunc. It logs nothing.
 var NoLogging = func(_ string, _ ...interface{}) {}
 
+// Config is a struct to hold the configuration of a NATS connection.
+type Config struct {
+	Password string
+	Username string
+	Hosts    string
+	Port     int
+}
+
 // Connection is the main entry point for the library. It is used to create Publishers and Subscribers.
 // It is also used to close the connection to the NATS server/ cluster.
 type Connection struct {
@@ -139,3 +150,37 @@ func WithLogger(log LogFunc) Option {
 		c.log = log
 	}
 }
+
+// MustConnectToNATS to NATS Server. This function panics if the connection could not be established.
+// servers: List of NATS servers in the form of "nats://<user:password>@<host>:<port>"
+// logger: an optional slog.Logger instance
+func MustConnectToNATS(config *Config, logger *slog.Logger) *Connection {
+	if logger == nil {
+		logger = slog.New(slog.NewJSONHandler(os.Stdout, &slog.HandlerOptions{}))
+	}
+	natsConn, err := Connect(servers(config), WithLogger(logger.Info))
+	if err != nil {
+		panic("error while connecting to nats: " + err.Error())
+	}
+	return natsConn
+}
+
+func servers(cfg *Config) []string {
+	parsedServers := trimSpaceSlice(strings.Split(cfg.Hosts, ","))
+	servers := make([]string, 0, len(parsedServers))
+
+	for _, server := range parsedServers {
+		s := fmt.Sprintf("nats://%s:%s@%s:%d", cfg.Username, cfg.Password, server, cfg.Port)
+		servers = append(servers, s)
+	}
+
+	return servers
+}
+
+func trimSpaceSlice(values []string) []string {
+	trimmed := make([]string, len(values))
+	for i, value := range values {
+		trimmed[i] = strings.TrimSpace(value)
+	}
+	return trimmed
+}

subscriber_test.go

@@ -377,7 +377,7 @@ func TestSubscriberMultiple(t *testing.T) {
 }
 
 func makeHandlerSubscriber(t *testing.T, alwaysFail bool, s *subscriptionState, idx int) func(msg Msg) error {
-	handler := func(msg Msg) error {
+	handler := func(_ Msg) error {
 		if alwaysFail {
 			s.FailedMsgs++
 			t.Logf("Subscriber %v: Failed msg handeling, failesp: %v", idx, s.FailedMsgs)