go/go-micro
1
0
Fork 0
mirror of https://github.com/go-micro/go-micro.git synced 2024-11-24 08:02:32 +02:00
Code Issues Releases Activity

api/handler/rpc: fix encoding of inner message (#1601)

Browse Source 
* api/handler/rpc: fix encoding of inner message

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Vasiliy Tolstov 2020-05-04 15:50:53 +03:00 committed by GitHub
parent 38cdb9cc2f
commit 90dd1f63c8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 18 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
api/handler/rpc/rpc.go
View File

@ -397,13 +397,29 @@ func requestPayload(r *http.Request) ([]byte, error) {
return out, nil return out, nil
} }
} }
var jsonbody map[string]interface{}
if json.Valid(bodybuf) {
if err = json.Unmarshal(bodybuf, &jsonbody); err != nil {
return nil, err
}
}
dstmap := make(map[string]interface{}) dstmap := make(map[string]interface{})
ps := strings.Split(bodydst, ".") ps := strings.Split(bodydst, ".")
if len(ps) == 1 { if len(ps) == 1 {
dstmap[ps[0]] = bodybuf if jsonbody != nil {
dstmap[ps[0]] = jsonbody
} else {
// old unexpected behaviour
dstmap[ps[0]] = bodybuf
}
} else { } else {
em := make(map[string]interface{}) em := make(map[string]interface{})
em[ps[len(ps)-1]] = bodybuf if jsonbody != nil {
em[ps[len(ps)-1]] = jsonbody
} else {
// old unexpected behaviour
em[ps[len(ps)-1]] = bodybuf
}
for i := len(ps) - 2; i > 0; i-- { for i := len(ps) - 2; i > 0; i-- {
nm := make(map[string]interface{}) nm := make(map[string]interface{})
nm[ps[i]] = em nm[ps[i]] = em