mirror of
https://github.com/gusaul/grpcox.git
synced 2025-04-22 14:25:37 +00:00
metadata implemented and refactored
This commit is contained in:
parent
f0c3ab2a2d
commit
7548fe311c
|
@ -221,12 +221,20 @@ func (h *Handler) invokeFunction(w http.ResponseWriter, r *http.Request) {
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
md := r.Header.Get("metadata")
|
// server metadata
|
||||||
|
mdsWithComma := strings.Split(r.Header.Get("metadata"), ",")
|
||||||
|
mdsWithCommaSpace := strings.Split(r.Header.Get("metadata"), ", ")
|
||||||
|
|
||||||
mds := strings.Split(md, ",")
|
var metadata []string
|
||||||
|
|
||||||
|
if len(mdsWithComma) > len(mdsWithCommaSpace) {
|
||||||
|
metadata = mdsWithComma
|
||||||
|
} else {
|
||||||
|
metadata = mdsWithCommaSpace
|
||||||
|
}
|
||||||
|
|
||||||
// get param
|
// get param
|
||||||
result, timer, err := res.Invoke(context.Background(), funcName, r.Body, mds)
|
result, timer, err := res.Invoke(context.Background(), funcName, r.Body, metadata)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
writeError(w, err)
|
writeError(w, err)
|
||||||
return
|
return
|
||||||
|
|
Loading…
Reference in New Issue
Block a user