style(nats): update comments formatting and add blank lines for clarity

refactor(nats): remove unused replaceDots function to clean up code
refactor(nats): change context parameter to blank identifier in connect, ensureStream, and ensureConsumer methods to indicate unused parameter

Author: bounoable

backend/nats/bus.go

@@ -26,7 +26,7 @@ var (
 
 // EventBus is an event bus that uses NATS to publish and subscribe to events.
 //
-// Drivers
+// # Drivers
 //
 // The event bus supports both NATS Core and NATS JetStream. By default, the
 // Core driver is used, but you can create and specify the JetStream driver with
@@ -81,6 +81,7 @@ type envelope struct {
 //
 // If no other specified, the returned event bus will use the NATS Core Driver.
 // To use the NATS JetStream Driver instead, explicitly set the Driver:
+//
 //	NewEventBus(enc, Use(JetStream()))
 func NewEventBus(enc codec.Encoding, opts ...EventBusOption) *EventBus {
 	if enc == nil {
@@ -122,7 +123,7 @@ func (bus *EventBus) Connect(ctx context.Context) error {
 	return err
 }
 
-func (bus *EventBus) connect(ctx context.Context) error {
+func (bus *EventBus) connect(_ context.Context) error {
 	// *nats.Conn provided via Conn() option.
 	if bus.conn != nil {
 		return nil

backend/nats/internal.go

@@ -9,10 +9,6 @@ var replacer = strings.NewReplacer(
 	// " ", "_",
 )
 
-func replaceDots(s string) string {
-	return strings.ReplaceAll(s, ".", "_")
-}
-
 func subscribeSubject(userProvidedSubject, event string) string {
 	if event == "*" {
 		return ">"

backend/nats/jetstream.go

@@ -64,6 +64,7 @@ func DurableFunc(fn func(event, queue string) string) JetStreamOption {
 
 // Durable returns an option that makes JetStream consumers / subscriptions
 // durable (see DurableFunc). The durable name is formatted like this:
+//
 //	fmt.Sprintf("%s:%s:%s", prefix, queue, event)
 func Durable(prefix string) JetStreamOption {
 	return DurableFunc(func(event, queue string) string {
@@ -278,7 +279,7 @@ func (js *jetStream) publish(ctx context.Context, bus *EventBus, evt event.Event
 	return nil
 }
 
-func (js *jetStream) ensureStream(ctx context.Context) error {
+func (js *jetStream) ensureStream(_ context.Context) error {
 	info, err := js.ctx.StreamInfo(js.stream)
 	if err == nil {
 		if info.Config.Name != js.stream {
@@ -308,7 +309,7 @@ func (js *jetStream) ensureStream(ctx context.Context) error {
 	return nil
 }
 
-func (js *jetStream) ensureConsumer(ctx context.Context, bus *EventBus, name, eventName, subject, queue string) error {
+func (js *jetStream) ensureConsumer(_ context.Context, bus *EventBus, name, eventName, subject, queue string) error {
 	if info, err := js.ctx.ConsumerInfo(js.stream, name); err == nil {
 		if info.Stream != js.stream {
 			return fmt.Errorf("%w: stream name mismatch: %q != %q", ErrConsumerExists, info.Stream, js.stream)

go.work.sum

@@ -0,0 +1,34 @@
+cel.dev/expr v0.23.0/go.mod h1:hLPLo1W4QUmuYdA72RBX06QTs6MXw941piREPl3Yfiw=
+cloud.google.com/go/compute/metadata v0.6.0/go.mod h1:FjyFAW1MW0C203CEOMDTu3Dk1FlqW3Rga40jzHL4hfg=
+github.com/GoogleCloudPlatform/opentelemetry-operations-go/detectors/gcp v1.27.0/go.mod h1:yAZHSGnqScoU556rBOVkwLze6WP5N+U11RHuWaGVxwY=
+github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/cncf/xds/go v0.0.0-20250326154945-ae57f3c0d45f/go.mod h1:W+zGtBO5Y1IgJhy4+A9GOqVhqLpfZi+vwmdNXUehLA8=
+github.com/envoyproxy/go-control-plane v0.13.4/go.mod h1:kDfuBlDVsSj2MjrLEtRWtHlsWIFcGyB2RMO44Dc5GZA=
+github.com/envoyproxy/go-control-plane/envoy v1.32.4/go.mod h1:Gzjc5k8JcJswLjAx1Zm+wSYE20UrLtt7JZMWiWQXQEw=
+github.com/envoyproxy/go-control-plane/ratelimit v0.1.0/go.mod h1:Wk+tMFAFbCXaJPzVVHnPgRKdUdwW/KdbRt94AzgRee4=
+github.com/envoyproxy/protoc-gen-validate v1.2.1/go.mod h1:d/C80l/jxXLdfEIhX1W2TmLfsJ31lvEjwamM4DxlWXU=
+github.com/go-jose/go-jose/v4 v4.0.5/go.mod h1:s3P1lRrkT8igV8D9OjyL4WRyHvjB6a4JSllnOrmmBOA=
+github.com/golang/glog v1.2.4/go.mod h1:6AhwSGph0fcJtXVM/PEHPqZlFeoLxhs7/t5UDAwmO+w=
+github.com/google/go-cmp v0.5.9/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=
+github.com/jackc/chunkreader v1.0.0 h1:4s39bBR8ByfqH+DKm8rQA3E1LHZWB9XWcrz8fqaZbe0=
+github.com/jackc/pgproto3 v1.1.0 h1:FYYE4yRw+AgI8wXIinMlNjBbp/UitDJwfj5LqqewP1A=
+github.com/klauspost/compress v1.16.7/go.mod h1:ntbaceVETuRiXiv4DpjP66DpAtAGkEQskQzEyD//IeE=
+github.com/planetscale/vtprotobuf v0.6.1-0.20240319094008-0393e58bdf10/go.mod h1:t/avpk3KcrXxUnYOhZhMXJlSEyie6gQbtLq5NM3loB8=
+github.com/spiffe/go-spiffe/v2 v2.5.0/go.mod h1:P+NxobPc6wXhVtINNtFjNWGBTreew1GBUCwT2wPmb7g=
+github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
+github.com/zeebo/errs v1.4.0/go.mod h1:sgbWHsvVuTPHcqJJGQ1WhI5KbWlHYz+2+2C/LSEtCw4=
+go.opentelemetry.io/contrib/detectors/gcp v1.35.0/go.mod h1:qGWP8/+ILwMRIUf9uIVLloR1uo5ZYAslM4O6OqUi1DA=
+golang.org/x/crypto v0.26.0/go.mod h1:GY7jblb9wI+FOo5y8/S2oY4zWP07AkOJ4+jxCqdqn54=
+golang.org/x/crypto v0.36.0/go.mod h1:Y4J0ReaxCR1IMaabaSMugxJES1EpwhBHhv2bDHklZvc=
+golang.org/x/mod v0.17.0/go.mod h1:hTbmBsO62+eylJbnUtE2MGJUyE7QWk4xUqPFrRgJ+7c=
+golang.org/x/net v0.21.0/go.mod h1:bIjVDfnllIU7BJ2DNgfnXvpSvtn8VRwhlsaeUTyUS44=
+golang.org/x/oauth2 v0.28.0/go.mod h1:onh5ek6nERTohokkhCD/y2cV4Do3fxFHFuAejCkRWT8=
+golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sys v0.31.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=
+golang.org/x/telemetry v0.0.0-20240228155512-f48c80bd79b2/go.mod h1:TeRTkGYfJXctD9OcfyVLyj2J3IxLnKwHJR8f4D8a3YE=
+golang.org/x/term v0.30.0/go.mod h1:NYYFdzHoI5wRh/h5tDMdMqCqPJZEuNqVR5xJLd/n67g=
+golang.org/x/term v0.31.0/go.mod h1:R4BeIy7D95HzImkxGkTW1UQTtP54tio2RyHz7PwK0aw=
+golang.org/x/text v0.17.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=
+golang.org/x/tools v0.21.1-0.20240508182429-e35e4ccd0d2d/go.mod h1:aiJjzUbINMkxbQROHiO6hDPo2LHcIPhhQsa9DLh0yGk=
+google.golang.org/genproto/googleapis/api v0.0.0-20250324211829-b45e905df463/go.mod h1:U90ffi8eUL9MwPcrJylN5+Mk2v3vuPDptd5yyNUiRR8=