feature: WS-279 made it so that command receivers are explicitly add …

…(instead of magically via providers)

README.md

@@ -42,4 +42,4 @@ For general help using WeOS, please refer to [the official WeOS documentation](h
 
 ## License
 
-See the [LICENSE](./LICENSE) file for licensing information.
+See the [LICENSE](./LICENSE) file for licensing information

rest/command.go

@@ -15,8 +15,7 @@ const DELETE_COMMAND = "delete"
 
 type CommandDispatcherParams struct {
 	fx.In
-	CommandConfigs []CommandConfig
-	Logger         Log
+	Logger Log
 }
 
 type CommandDispatcherResult struct {
@@ -29,9 +28,6 @@ func NewCommandDispatcher(p CommandDispatcherParams) CommandDispatcherResult {
 	dispatcher := &DefaultCommandDispatcher{
 		handlers: make(map[string][]CommandHandler),
 	}
-	for _, config := range p.CommandConfigs {
-		dispatcher.AddSubscriber(config)
-	}
 	return CommandDispatcherResult{
 		Dispatcher: dispatcher,
 	}

rest/integration_test.go

@@ -31,8 +31,8 @@ func TestIntegrations(t *testing.T) {
 	os.Setenv("WEOS_PORT", "8681")
 	os.Setenv("WEOS_SPEC", "./fixtures/blog.yaml")
 	//use fx Module to start the server
-	Receivers := func() []rest.CommandConfig {
-		return []rest.CommandConfig{
+	Receivers := func(commandDispatcher rest.CommandDispatcher) {
+		handlers := []rest.CommandConfig{
 			{
 				Type: "CreateBlog",
 				Handler: func(ctx context.Context, command *rest.Command, logger rest.Log, options *rest.CommandOptions) (response rest.CommandResponse, err error) {
@@ -45,8 +45,11 @@ func TestIntegrations(t *testing.T) {
 				},
 			},
 		}
+		for _, handler := range handlers {
+			commandDispatcher.AddSubscriber(handler)
+		}
 	}
-	app := fxtest.New(t, fx.Provide(Receivers), rest.Core, fx.Invoke(func(techo *echo.Echo) {
+	app := fxtest.New(t, fx.Invoke(Receivers), rest.Core, fx.Invoke(func(techo *echo.Echo) {
 		e = techo
 	}))
 	defer app.RequireStop()