mirror of
https://github.com/jwetzell/showbridge-go.git
synced 2026-07-26 09:58:40 +00:00
87 lines
2.2 KiB
Go
87 lines
2.2 KiB
Go
package processor
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"fmt"
|
|
"log/slog"
|
|
|
|
"github.com/google/jsonschema-go/jsonschema"
|
|
"github.com/jwetzell/showbridge-go/internal/common"
|
|
"github.com/jwetzell/showbridge-go/internal/config"
|
|
)
|
|
|
|
func init() {
|
|
RegisterProcessor(ProcessorRegistration{
|
|
Type: "module.output",
|
|
Title: "Module Output",
|
|
ParamsSchema: &jsonschema.Schema{
|
|
Type: "object",
|
|
Properties: map[string]*jsonschema.Schema{
|
|
"module": {
|
|
Title: "Module ID",
|
|
Description: "ID of module to send output to",
|
|
Type: "string",
|
|
},
|
|
},
|
|
Required: []string{"module"},
|
|
AdditionalProperties: &jsonschema.Schema{Not: &jsonschema.Schema{}},
|
|
},
|
|
New: func(config config.ProcessorConfig) (Processor, error) {
|
|
|
|
params := config.Params
|
|
|
|
moduleId, err := params.GetString("module")
|
|
|
|
if err != nil {
|
|
return nil, fmt.Errorf("module.output module error: %w", err)
|
|
}
|
|
|
|
return &ModuleOutput{config: config, ModuleId: moduleId, logger: slog.Default().With("component", "processor", "type", config.Type)}, nil
|
|
},
|
|
})
|
|
}
|
|
|
|
type ModuleOutput struct {
|
|
config config.ProcessorConfig
|
|
ModuleId string
|
|
logger *slog.Logger
|
|
module common.OutputModule
|
|
}
|
|
|
|
func (mo *ModuleOutput) Process(ctx context.Context, wrappedPayload common.WrappedPayload) (common.WrappedPayload, error) {
|
|
|
|
if mo.module == nil {
|
|
if wrappedPayload.Modules == nil {
|
|
wrappedPayload.End = true
|
|
return wrappedPayload, errors.New("module.output wrapped payload has no modules")
|
|
}
|
|
|
|
module, ok := wrappedPayload.Modules[mo.ModuleId]
|
|
if !ok {
|
|
wrappedPayload.End = true
|
|
return wrappedPayload, fmt.Errorf("module.output unable to find module with id: %s", mo.ModuleId)
|
|
}
|
|
|
|
outputModule, ok := module.(common.OutputModule)
|
|
if !ok {
|
|
wrappedPayload.End = true
|
|
return wrappedPayload, fmt.Errorf("module.output module with id %s is not an OutputModule", mo.ModuleId)
|
|
}
|
|
mo.module = outputModule
|
|
}
|
|
|
|
err := mo.module.Output(ctx, wrappedPayload.Payload)
|
|
|
|
if err != nil {
|
|
wrappedPayload.End = true
|
|
return wrappedPayload, fmt.Errorf("module.output failed to send output: %w", err)
|
|
}
|
|
|
|
return wrappedPayload, nil
|
|
}
|
|
|
|
func (mo *ModuleOutput) Type() string {
|
|
return mo.config.Type
|
|
}
|