diff --git a/changelog/unreleased/fix-nats-store.md b/changelog/unreleased/fix-nats-store.md new file mode 100644 index 0000000000..8d239d8705 --- /dev/null +++ b/changelog/unreleased/fix-nats-store.md @@ -0,0 +1,5 @@ +Bugfix: Fix natsjskv store + +Small mistake in last iteration made authorization not working. + +https://github.com/cs3org/reva/pull/4466 diff --git a/pkg/storage/utils/decomposedfs/options/options.go b/pkg/storage/utils/decomposedfs/options/options.go index 6e081fdcea..f58edff6a2 100644 --- a/pkg/storage/utils/decomposedfs/options/options.go +++ b/pkg/storage/utils/decomposedfs/options/options.go @@ -91,11 +91,7 @@ type AsyncPropagatorOptions struct { // EventOptions are the configurable options for events type EventOptions struct { - NatsAddress string `mapstructure:"natsaddress"` - NatsClusterID string `mapstructure:"natsclusterid"` - TLSInsecure bool `mapstructure:"tlsinsecure"` - TLSRootCACertificate string `mapstructure:"tlsrootcacertificate"` - NumConsumers int `mapstructure:"numconsumers"` + NumConsumers int `mapstructure:"numconsumers"` } // TokenOptions are the configurable option for tokens diff --git a/pkg/store/store.go b/pkg/store/store.go index f26edff2e2..0038d00580 100644 --- a/pkg/store/store.go +++ b/pkg/store/store.go @@ -151,8 +151,8 @@ func Create(opts ...microstore.Option) microstore.Store { } return natsjskv.NewStore( append(opts, - natsjs.NatsOptions(natsOptions), // always pass in properly initialized default nats options - natsjs.DefaultTTL(ttl))..., + natsjskv.NatsOptions(natsOptions), // always pass in properly initialized default nats options + natsjskv.DefaultTTL(ttl))..., ) case TypeMemory, "mem", "": // allow existing short form and use as default return microstore.NewMemoryStore(opts...)