make events settings configurable

owncloud · Feb 22, 2022 · 0361b35 · 0361b35
1 parent 70a0877
commit 0361b35
Show file tree

Hide file tree

Showing 4 changed files with 25 additions and 2 deletions.
diff --git a/changelog/unreleased/fix-events-config.md b/changelog/unreleased/fix-events-config.md
@@ -0,0 +1,5 @@
+Bugfix: Make events settings configurable
+
+We've fixed the hardcoded events settings to be configurable.
+
+https://github.com/owncloud/ocis/pull/55555
diff --git a/storage/pkg/command/sharing.go b/storage/pkg/command/sharing.go
@@ -179,8 +179,8 @@ func sharingConfigFromStruct(c *cli.Context, cfg *config.Config) map[string]inte
 				"eventsmiddleware": map[string]interface{}{
 					"group":     "sharing",
 					"type":      "nats",
-					"address":   "127.0.0.1:4222",
-					"clusterID": "test-cluster",
+					"address":   cfg.Reva.Sharing.Events.Address,
+					"clusterID": cfg.Reva.Sharing.Events.ClusterID,
 				},
 			},
 		},

diff --git a/storage/pkg/config/config.go b/storage/pkg/config/config.go
@@ -89,6 +89,12 @@ type Sharing struct {
 	PublicEnableExpiredSharesCleanup bool   `ocisConfig:"public_enable_expired_shares_cleanup"`
 	PublicJanitorRunInterval         int    `ocisConfig:"public_janitor_run_interval"`
 	UserStorageMountID               string `ocisConfig:"user_storage_mount_id"`
+	Events                           Events `ocisConfig:"events"`
+}
+
+type Events struct {
+	Address   string `ocisConfig:"address"`
+	ClusterID string `ocisConfig:"cluster_id"`
 }
 
 // Port defines the available port configuration.
@@ -1223,6 +1229,14 @@ func structMappings(cfg *Config) []shared.EnvBinding {
 			EnvVars:     []string{"STORAGE_SHARING_USER_SQL_NAME"},
 			Destination: &cfg.Reva.Sharing.UserSQLName,
 		},
+		{
+			EnvVars:     []string{"STORAGE_SHARING_EVENTS_ADDRESS"},
+			Destination: &cfg.Reva.Sharing.Events.Address,
+		},
+		{
+			EnvVars:     []string{"STORAGE_SHARING_EVENTS_CLUSTER_ID"},
+			Destination: &cfg.Reva.Sharing.Events.ClusterID,
+		},
 
 		// storage metadata
 		{

diff --git a/storage/pkg/config/defaultconfig.go b/storage/pkg/config/defaultconfig.go
@@ -348,6 +348,10 @@ func DefaultConfig() *Config {
 				PublicEnableExpiredSharesCleanup: true,
 				PublicJanitorRunInterval:         60,
 				UserStorageMountID:               "",
+				Events: Events{
+					Address:   "127.0.0.1:4222",
+					ClusterID: "test-cluster",
+				},
 			},
 			StorageShares: StoragePort{
 				Port: Port{