migrate to SDK v0.5.0: typed Result return for Handle

tpoxa · tpoxa · commit 0df7f31f78eb · 2026-05-10T21:37:27.000+01:00
Updates echo to the new module.Handler / Component.Handle signature
returning module.Result. The chained handler() call already returns
Result via the new typed Handler and passes through unchanged.

No behavior changes — purely the typed-return migration.
diff --git a/components/echo/echo.go b/components/echo/echo.go
@@ -36,11 +36,11 @@ func (t *Component) GetInfo() module.ComponentInfo {
 	}
 }
 
-func (t *Component) Handle(ctx context.Context, handler module.Handler, port string, msg interface{}) any {
+func (t *Component) Handle(ctx context.Context, handler module.Handler, port string, msg interface{}) module.Result {
 	if in, ok := msg.(InMessage); ok {
 		return handler(ctx, OutPort, in.Context)
 	}
-	return fmt.Errorf("invalid message")
+	return module.Fail(fmt.Errorf("invalid message"))
 }
 
 func (t *Component) Ports() []module.Port {
diff --git a/go.mod b/go.mod
@@ -8,7 +8,7 @@ require (
 	github.com/rs/zerolog v1.34.0
 	github.com/spf13/cobra v1.10.2
 	github.com/spf13/viper v1.20.1
-	github.com/tiny-systems/module v0.2.0
+	github.com/tiny-systems/module v0.5.0
 )
 
 require (
diff --git a/go.sum b/go.sum
@@ -423,8 +423,8 @@ github.com/tiny-systems/ajson v0.1.6 h1:Ch7E4Oerx4mHse+wbCdb1ZYuVATLuH76g2RWHC+B
 github.com/tiny-systems/ajson v0.1.6/go.mod h1:a1M1W+3VQu6yNLxOwtKRq+y58Hy/oFWMkQBE/aKhVBs=
 github.com/tiny-systems/errorpanic v0.7.1 h1:GgbimfhC2wnQ8012SGGxh743ryaJXSSD7boLK+IQ0Xs=
 github.com/tiny-systems/errorpanic v0.7.1/go.mod h1:AQobicdSB/J3RzN81pTG4dqgcULaEIrEOvNC8TpSgxw=
-github.com/tiny-systems/module v0.2.0 h1:8hwHefXgtQGW4rYg0kbgvqRFbC9OXXZfWVDiQrVon8I=
-github.com/tiny-systems/module v0.2.0/go.mod h1:dsuKa7EUGkkEEYfc11RlENDw1p8oXLedhkz9I0qR8sw=
+github.com/tiny-systems/module v0.5.0 h1:fOf8VGvu/OoVs2feK75VPg1aprlBlFosQcDPTNzUXxk=
+github.com/tiny-systems/module v0.5.0/go.mod h1:dsuKa7EUGkkEEYfc11RlENDw1p8oXLedhkz9I0qR8sw=
 github.com/tiny-systems/otel-collector v0.5.1 h1:tylLj7f7O7n5o9R383Lojd0fN7j5jgZ76zFshJ0SE6c=
 github.com/tiny-systems/otel-collector v0.5.1/go.mod h1:EGo1dQ3+5iG3ejGJ8y9kMgHhOGB6WyoasJDUHesKXEA=
 github.com/tiny-systems/platform-api v0.5.0 h1:3pPr1MjMGYwbrXtUG9mZvA6aXTvyQdHrgM3UAzpUQkw=

Original file line number	Diff line number	Diff line change
`@@ -36,11 +36,11 @@ func (t *Component) GetInfo() module.ComponentInfo {`
`36`	`36`	`}`
`37`	`37`	`}`
`38`	`38`
`39`		`-func (t *Component) Handle(ctx context.Context, handler module.Handler, port string, msg interface{}) any {`
	`39`	`+func (t *Component) Handle(ctx context.Context, handler module.Handler, port string, msg interface{}) module.Result {`
`40`	`40`	`if in, ok := msg.(InMessage); ok {`
`41`	`41`	`return handler(ctx, OutPort, in.Context)`
`42`	`42`	`}`
`43`		`- return fmt.Errorf("invalid message")`
	`43`	`+ return module.Fail(fmt.Errorf("invalid message"))`
`44`	`44`	`}`
`45`	`45`
`46`	`46`	`func (t *Component) Ports() []module.Port {`
Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@ require (`
`8`	`8`	`github.com/rs/zerolog v1.34.0`
`9`	`9`	`github.com/spf13/cobra v1.10.2`
`10`	`10`	`github.com/spf13/viper v1.20.1`
`11`		`- github.com/tiny-systems/module v0.2.0`
	`11`	`+ github.com/tiny-systems/module v0.5.0`
`12`	`12`	`)`
`13`	`13`
`14`	`14`	`require (`