backup/showbridge-go
1
0
Fork 0
mirror of https://github.com/jwetzell/showbridge-go.git synced 2026-04-27 13:25:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

wrap literal payloads into a struct for expr processors

Browse Source
This commit is contained in:
Joel Wetzell
2026-03-01 23:35:08 -06:00
parent e9d5931e9d
commit 28a5d1ea90
2 changed files with 40 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
internal/processor/filter-expr.go
View File

@@ -15,9 +15,29 @@ type FilterExpr struct {
Program *vm.Program Program *vm.Program
} }
func (se *FilterExpr) Process(ctx context.Context, payload any) (any, error) { type PayloadStruct struct {
Payload any
}
output, err := expr.Run(se.Program, payload) func (se *FilterExpr) Process(ctx context.Context, payload any) (any, error) {
payloadType := fmt.Sprintf("%T", payload)
exprEnv := payload
switch payloadType {
case "uint", "uint8", "uint16", "uint32", "uint64":
exprEnv = PayloadStruct{Payload: payload}
case "int", "int8", "int16", "int32", "int64":
exprEnv = PayloadStruct{Payload: payload}
case "float32", "float64":
exprEnv = PayloadStruct{Payload: payload}
case "string":
exprEnv = PayloadStruct{Payload: payload}
case "bool":
exprEnv = PayloadStruct{Payload: payload}
}
output, err := expr.Run(se.Program, exprEnv)
if err != nil { if err != nil {
return nil, err return nil, err
} }

19
internal/processor/script-expr.go
View File

@@ -17,7 +17,24 @@ type ScriptExpr struct {
func (se *ScriptExpr) Process(ctx context.Context, payload any) (any, error) { func (se *ScriptExpr) Process(ctx context.Context, payload any) (any, error) {
output, err := expr.Run(se.Program, payload) payloadType := fmt.Sprintf("%T", payload)
exprEnv := payload
switch payloadType {
case "uint", "uint8", "uint16", "uint32", "uint64":
exprEnv = PayloadStruct{Payload: payload}
case "int", "int8", "int16", "int32", "int64":
exprEnv = PayloadStruct{Payload: payload}
case "float32", "float64":
exprEnv = PayloadStruct{Payload: payload}
case "string":
exprEnv = PayloadStruct{Payload: payload}
case "bool":
exprEnv = PayloadStruct{Payload: payload}
}
output, err := expr.Run(se.Program, exprEnv)
if err != nil { if err != nil {
return nil, err return nil, err
} }