add processor to push input into router (#104)

internal/processor/router-input.go

@@ -0,0 +1,55 @@
+package processor
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"log/slog"
+
+	"github.com/jwetzell/showbridge-go/internal/common"
+	"github.com/jwetzell/showbridge-go/internal/config"
+)
+
+type RouterInput struct {
+	config   config.ProcessorConfig
+	SourceId string
+	logger   *slog.Logger
+}
+
+func (ro *RouterInput) Process(ctx context.Context, payload any) (any, error) {
+
+	router, ok := ctx.Value(common.RouterContextKey).(common.RouteIO)
+	if !ok {
+		return nil, errors.New("router.input no router found")
+	}
+
+	_, err := router.HandleInput(ctx, ro.SourceId, payload)
+
+	if err != nil {
+		return nil, errors.New("router.input failed to send input")
+	}
+
+	return payload, nil
+}
+
+func (ro *RouterInput) Type() string {
+	return ro.config.Type
+}
+
+func init() {
+	RegisterProcessor(ProcessorRegistration{
+		Type: "router.input",
+		New: func(config config.ProcessorConfig) (Processor, error) {
+
+			params := config.Params
+
+			sourceId, err := params.GetString("source")
+
+			if err != nil {
+				return nil, fmt.Errorf("router.input source error: %w", err)
+			}
+
+			return &RouterInput{config: config, SourceId: sourceId, logger: slog.Default().With("component", "processor", "type", config.Type)}, nil
+		},
+	})
+}