fixup path filling

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
Василий Толстов 2024-05-04 15:05:21 +03:00
parent b92b2541e0
commit 1160c0e86d
5 changed files with 43 additions and 28 deletions

2
go.mod
View File

@ -2,7 +2,7 @@ module go.unistack.org/micro-client-http/v3
go 1.20 go 1.20
require go.unistack.org/micro/v3 v3.10.67 require go.unistack.org/micro/v3 v3.10.69
require ( require (
golang.org/x/sys v0.19.0 // indirect golang.org/x/sys v0.19.0 // indirect

4
go.sum
View File

@ -1,6 +1,6 @@
github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI= github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=
go.unistack.org/micro/v3 v3.10.67 h1:Bk2VXsmMoKS2xkiultQS5WQCzsQlinYY+cAk4mAXi0U= go.unistack.org/micro/v3 v3.10.69 h1:V4g9LqUhzGab73U2aevnjtffCdJqGTuMfWY7fy4qGwI=
go.unistack.org/micro/v3 v3.10.67/go.mod h1:erMgt3Bl7vQQ0e9UpQyR5NlLiZ9pKeEJ9+1tfYFaqUg= go.unistack.org/micro/v3 v3.10.69/go.mod h1:erMgt3Bl7vQQ0e9UpQyR5NlLiZ9pKeEJ9+1tfYFaqUg=
golang.org/x/net v0.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4= golang.org/x/net v0.21.0 h1:AQyQV4dYCvJ7vGmJyKki9+PBdyvhkSd8EIx/qb0AYv4=
golang.org/x/sys v0.19.0 h1:q5f1RH2jigJ1MoAWp2KTp3gm5zAGFUTarQZ5U386+4o= golang.org/x/sys v0.19.0 h1:q5f1RH2jigJ1MoAWp2KTp3gm5zAGFUTarQZ5U386+4o=
golang.org/x/sys v0.19.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA= golang.org/x/sys v0.19.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=

View File

@ -7,7 +7,7 @@ import (
) )
type request struct { type request struct {
Nested *request `json:"nested"` NestedTest *request `json:"nested_test"`
Name string `json:"name"` Name string `json:"name"`
Field1 string `json:"field1"` Field1 string `json:"field1"`
ClientID string ClientID string
@ -16,8 +16,8 @@ type request struct {
} }
func TestNestedPath(t *testing.T) { func TestNestedPath(t *testing.T) {
req := &request{Name: "first", Nested: &request{Name: "second"}, Field1: "fieldval"} req := &request{Name: "first", NestedTest: &request{Name: "second"}, Field1: "fieldval"}
p, _, err := newPathRequest("/api/v1/{name}/{nested.name}", "GET", "", req, []string{"json", "protobuf"}, nil) p, m, err := newPathRequest("/api/v1/{name}/{nested_test.name}", "PUT", "*", req, []string{"json", "protobuf"}, nil)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -28,6 +28,7 @@ func TestNestedPath(t *testing.T) {
if s := u.String(); s != "/api/v1/first/second?field1=fieldval" { if s := u.String(); s != "/api/v1/first/second?field1=fieldval" {
t.Fatalf("nested path error %s", s) t.Fatalf("nested path error %s", s)
} }
_ = m
} }
func TestPathWithHeader(t *testing.T) { func TestPathWithHeader(t *testing.T) {

34
util.go
View File

@ -88,6 +88,7 @@ func newPathRequest(path string, method string, body string, msg interface{}, ta
values := url.Values{} values := url.Values{}
// copy cycle // copy cycle
cleanPath := make(map[string]bool)
for i := 0; i < tmsg.NumField(); i++ { for i := 0; i < tmsg.NumField(); i++ {
val := tmsg.Field(i) val := tmsg.Field(i)
if val.IsZero() { if val.IsZero() {
@ -156,29 +157,28 @@ func newPathRequest(path string, method string, body string, msg interface{}, ta
default: default:
fieldsmap[t.name] = getParam(val) fieldsmap[t.name] = getParam(val)
} }
} else if (body == "*" || body == t.name) && method != http.MethodGet {
if tnmsg.Field(i).CanSet() {
tnmsg.Field(i).Set(val)
}
} else { } else {
isSet := false
for k, v := range fieldsmap { for k, v := range fieldsmap {
isSet := false
if v != "" { if v != "" {
continue continue
} }
var clean []string
fld := msg fld := msg
parts := strings.Split(k, ".") parts := strings.Split(k, ".")
for idx := 0; idx < len(parts); idx++ { for idx := 0; idx < len(parts); idx++ {
var nfld interface{} var nfld interface{}
var name string
if tags == nil { if tags == nil {
tags = []string{"json"} tags = []string{"json"}
} }
tagsloop: tagsloop:
for i := 0; i < len(tags); i++ { for ti := 0; ti < len(tags); ti++ {
nfld, err = rutil.StructFieldByTag(fld, tags[i], parts[idx]) name, nfld, err = rutil.StructFieldNameByTag(fld, tags[ti], parts[idx])
if err == nil { if err == nil {
clean = append(clean, name)
break tagsloop break tagsloop
} }
} }
@ -187,20 +187,34 @@ func newPathRequest(path string, method string, body string, msg interface{}, ta
if len(parts)-1 == idx { if len(parts)-1 == idx {
isSet = true isSet = true
fieldsmap[k] = fmt.Sprintf("%v", fld) fieldsmap[k] = fmt.Sprintf("%v", fld)
} }
} }
} }
if isSet {
cleanPath[strings.Join(clean, ".")] = true
}
}
if (body == "*" || body == t.name) && method != http.MethodGet {
if tnmsg.Field(i).CanSet() {
tnmsg.Field(i).Set(val)
}
}
for k := range cleanPath {
if err = rutil.ZeroFieldByPath(nmsg, k); err != nil {
return "", nil, err
}
} }
if !isSet {
if val.Type().Kind() == reflect.Slice { if val.Type().Kind() == reflect.Slice {
for idx := 0; idx < val.Len(); idx++ { for idx := 0; idx < val.Len(); idx++ {
values.Add(t.name, getParam(val.Index(idx))) values.Add(t.name, getParam(val.Index(idx)))
} }
} else { } else if !rutil.IsEmpty(val) {
values.Add(t.name, getParam(val)) values.Add(t.name, getParam(val))
} }
}
} }
} }

View File

@ -119,7 +119,7 @@ func TestNewPathVarRequest(t *testing.T) {
t.Fatalf("invalid nmsg: %#+v\n", nmsg) t.Fatalf("invalid nmsg: %#+v\n", nmsg)
} }
if nmsg.(*Message).Name != "test_name" { if nmsg.(*Message).Name != "test_name" {
t.Fatalf("invalid nmsg: %v nmsg: %v", path, nmsg) t.Fatalf("invalid path: %v nmsg: %#+v", path, nmsg)
} }
} else { } else {
vals := u.Query() vals := u.Query()