cleanup route interface

This commit is contained in:
Joel Wetzell
2025-12-24 19:16:46 -06:00
parent 70878e6df6
commit 7cde1c244a

View File

@@ -28,7 +28,6 @@ type Route interface {
Input() string Input() string
Output() string Output() string
HandleInput(ctx context.Context, sourceId string, payload any, router RouteIO) error HandleInput(ctx context.Context, sourceId string, payload any, router RouteIO) error
HandleOutput(ctx context.Context, sourceId string, payload any, router RouteIO) error
} }
type ProcessorRoute struct { type ProcessorRoute struct {
@@ -78,9 +77,5 @@ func (r *ProcessorRoute) HandleInput(ctx context.Context, sourceId string, paylo
return nil return nil
} }
} }
return r.HandleOutput(ctx, sourceId, payload, router)
}
func (r *ProcessorRoute) HandleOutput(ctx context.Context, sourceId string, payload any, router RouteIO) error {
return router.HandleOutput(sourceId, r.output, payload) return router.HandleOutput(sourceId, r.output, payload)
} }