jiazhizhong/higress
1
0
Fork 0
mirror of https://github.com/alibaba/higress.git synced 2026-03-04 00:20:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix transformer plugin (#990)

Browse Source
This commit is contained in:
澄潭
2024-05-22 21:05:05 +08:00
committed by GitHub
parent 76b5f2af79
commit e4d535ea65
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/wasm-go/extensions/transformer/main.go
View File

@@ -249,7 +249,7 @@ func parseConfig(json gjson.Result, config *TransformerConfig, log wrapper.Log)
}
// TODO: 增加检查某些字段比如oldKey&newKey未同时存在时的提示信息
func constructParam(item *gjson.Result, op, valueType string) Param {
func constructParam(item gjson.Result, op, valueType string) Param {
p := Param{
valueType: valueType,
}
@@ -693,10 +693,10 @@ func newTransformRule(rules []gjson.Result) (res []TransformRule, err error) {
}
for _, h := range r.Get("headers").Array() {
tRule.headers = append(tRule.headers, constructParam(&h, tRule.operate, ""))
tRule.headers = append(tRule.headers, constructParam(h, tRule.operate, ""))
}
for _, q := range r.Get("querys").Array() {
tRule.querys = append(tRule.querys, constructParam(&q, tRule.operate, ""))
tRule.querys = append(tRule.querys, constructParam(q, tRule.operate, ""))
}
for _, b := range r.Get("body").Array() {
valueType := strings.ToLower(b.Get("value_type").String())
@@ -707,7 +707,7 @@ func newTransformRule(rules []gjson.Result) (res []TransformRule, err error) {
errors.Wrapf(err, "invalid body params type %q", valueType)
return
}
tRule.body = append(tRule.body, constructParam(&b, tRule.operate, valueType))
tRule.body = append(tRule.body, constructParam(b, tRule.operate, valueType))
}
res = append(res, tRule)
}