|
@@ -64,7 +64,7 @@ func (sf *tester) unsubGood2() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("unsubGood2").Fiber()
|
|
fibApp := resServ.Hassert("unsubGood2").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/unsub", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/unsub", body)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("unsubGood2(): err=%v", err)
|
|
sf.t.Fatalf("unsubGood2(): err=%v", err)
|
|
|
}
|
|
}
|
|
@@ -74,10 +74,12 @@ func (sf *tester) unsubGood2() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("unsubGood2(): after request, err=%v", err)
|
|
sf.t.Fatalf("unsubGood2(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- if _resp.StatusCode != 200 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode != http.StatusOK {
|
|
|
sf.t.Fatalf("unsubGood2(): statusCode(%v)!=200", _resp.StatusCode)
|
|
sf.t.Fatalf("unsubGood2(): statusCode(%v)!=200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
|
resp := &msg_unsub.UnsubResp{}
|
|
resp := &msg_unsub.UnsubResp{}
|
|
|
err = json.Unmarshal(binBody, resp)
|
|
err = json.Unmarshal(binBody, resp)
|
|
@@ -97,7 +99,7 @@ func (sf *tester) unsubBad3() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("unsubBad3").Fiber()
|
|
fibApp := resServ.Hassert("unsubBad3").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/unsub", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/unsub", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("unsubBad3(): err=%v", err)
|
|
sf.t.Fatalf("unsubBad3(): err=%v", err)
|
|
@@ -106,8 +108,10 @@ func (sf *tester) unsubBad3() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("unsubBad3(): after request, err=%v", err)
|
|
sf.t.Fatalf("unsubBad3(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
- if _resp.StatusCode == 200 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode == http.StatusOK {
|
|
|
sf.t.Fatalf("unsubBad3(): statusCode(%v)==200", _resp.StatusCode)
|
|
sf.t.Fatalf("unsubBad3(): statusCode(%v)==200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -185,7 +189,7 @@ func (sf *tester) pubGood2() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("pubGood2").Fiber()
|
|
fibApp := resServ.Hassert("pubGood2").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/pub", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/pub", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("pubGood2(): err=%v", err)
|
|
sf.t.Fatalf("pubGood2(): err=%v", err)
|
|
@@ -194,10 +198,12 @@ func (sf *tester) pubGood2() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("pubGood2(): after request, err=%v", err)
|
|
sf.t.Fatalf("pubGood2(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- if _resp.StatusCode != 200 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode != http.StatusOK {
|
|
|
sf.t.Fatalf("pubGood2(): statusCode(%v)!=200", _resp.StatusCode)
|
|
sf.t.Fatalf("pubGood2(): statusCode(%v)!=200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
|
resp := &msg_pub.PublishResp{}
|
|
resp := &msg_pub.PublishResp{}
|
|
|
err = json.Unmarshal(binBody, resp)
|
|
err = json.Unmarshal(binBody, resp)
|
|
@@ -217,7 +223,7 @@ func (sf *tester) pubBad3() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("pubBad3").Fiber()
|
|
fibApp := resServ.Hassert("pubBad3").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/pub", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/pub", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("pubBad3(): err=%v", err)
|
|
sf.t.Fatalf("pubBad3(): err=%v", err)
|
|
@@ -226,8 +232,10 @@ func (sf *tester) pubBad3() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("pubBad3(): after request, err=%v", err)
|
|
sf.t.Fatalf("pubBad3(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
- if _resp.StatusCode == 200 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode == http.StatusOK {
|
|
|
sf.t.Fatalf("pubBad3(): statusCode(%v)==200", _resp.StatusCode)
|
|
sf.t.Fatalf("pubBad3(): statusCode(%v)==200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -309,7 +317,7 @@ func (sf *tester) subGood2() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("subGood2").Fiber()
|
|
fibApp := resServ.Hassert("subGood2").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/sub", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/sub", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("subBad1(): err=%v", err)
|
|
sf.t.Fatalf("subBad1(): err=%v", err)
|
|
@@ -318,10 +326,12 @@ func (sf *tester) subGood2() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("subBad1(): after request, err=%v", err)
|
|
sf.t.Fatalf("subBad1(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- if _resp.StatusCode != 200 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode != http.StatusOK {
|
|
|
sf.t.Fatalf("subBad1(): statusCode(%v)!=200", _resp.StatusCode)
|
|
sf.t.Fatalf("subBad1(): statusCode(%v)!=200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
|
resp := &msg_sub.SubscribeResp{}
|
|
resp := &msg_sub.SubscribeResp{}
|
|
|
err = json.Unmarshal(binBody, resp)
|
|
err = json.Unmarshal(binBody, resp)
|
|
@@ -393,7 +403,7 @@ func (sf *tester) subBad1() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("subBad1").Fiber()
|
|
fibApp := resServ.Hassert("subBad1").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/sub", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/sub", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("subBad1(): err=%v", err)
|
|
sf.t.Fatalf("subBad1(): err=%v", err)
|
|
@@ -402,8 +412,10 @@ func (sf *tester) subBad1() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("subBad1(): after request, err=%v", err)
|
|
sf.t.Fatalf("subBad1(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
- if _resp.StatusCode != 400 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode != http.StatusBadRequest {
|
|
|
sf.t.Fatalf("subBad1(): statusCode(%v)!=400", _resp.StatusCode)
|
|
sf.t.Fatalf("subBad1(): statusCode(%v)!=400", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -432,7 +444,7 @@ func (sf *tester) reqBad4() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("reqBad4").Fiber()
|
|
fibApp := resServ.Hassert("reqBad4").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/request", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/request", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqBad4(): err=%v", err)
|
|
sf.t.Fatalf("reqBad4(): err=%v", err)
|
|
@@ -441,10 +453,12 @@ func (sf *tester) reqBad4() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqBad4(): after request, err=%v", err)
|
|
sf.t.Fatalf("reqBad4(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- if _resp.StatusCode != 200 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if _resp.StatusCode != http.StatusOK {
|
|
|
sf.t.Fatalf("reqBad4(): statusCode(%v)!=200", _resp.StatusCode)
|
|
sf.t.Fatalf("reqBad4(): statusCode(%v)!=200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
|
resp := &msg_serve.ServeResp{}
|
|
resp := &msg_serve.ServeResp{}
|
|
|
err = json.Unmarshal(binBody, resp)
|
|
err = json.Unmarshal(binBody, resp)
|
|
@@ -467,7 +481,7 @@ func (sf *tester) reqGood1() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("reqGood1").Fiber()
|
|
fibApp := resServ.Hassert("reqGood1").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/request", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/request", body)
|
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
hReq.Header.Add("Content-Type", "application/json")
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqGood1(): err=%v", err)
|
|
sf.t.Fatalf("reqGood1(): err=%v", err)
|
|
@@ -476,10 +490,12 @@ func (sf *tester) reqGood1() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqGood1(): after request, err=%v", err)
|
|
sf.t.Fatalf("reqGood1(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- if _resp.StatusCode != 200 {
|
|
|
|
|
|
|
+ if _resp.StatusCode != http.StatusOK {
|
|
|
sf.t.Fatalf("reqGood1(): statusCode(%v)!=200", _resp.StatusCode)
|
|
sf.t.Fatalf("reqGood1(): statusCode(%v)!=200", _resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
- defer _resp.Body.Close()
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = _resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
binBody, _ := io.ReadAll(_resp.Body)
|
|
|
resp := &msg_serve.ServeResp{}
|
|
resp := &msg_serve.ServeResp{}
|
|
|
err = json.Unmarshal(binBody, resp)
|
|
err = json.Unmarshal(binBody, resp)
|
|
@@ -503,7 +519,7 @@ func (sf *tester) reqBad3() {
|
|
|
body := strings.NewReader(string(binReq))
|
|
body := strings.NewReader(string(binReq))
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("reqBad3").Fiber()
|
|
fibApp := resServ.Hassert("reqBad3").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/request", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/request", body)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqBad3(): err=%v", err)
|
|
sf.t.Fatalf("reqBad3(): err=%v", err)
|
|
|
}
|
|
}
|
|
@@ -511,8 +527,10 @@ func (sf *tester) reqBad3() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqBad3(): after request, err=%v", err)
|
|
sf.t.Fatalf("reqBad3(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- defer resp.Body.Close()
|
|
|
|
|
- if resp.StatusCode != 400 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if resp.StatusCode != http.StatusBadRequest {
|
|
|
sf.t.Fatalf("reqBad3(): statusCode(%v)!=400", resp.StatusCode)
|
|
sf.t.Fatalf("reqBad3(): statusCode(%v)!=400", resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -523,7 +541,7 @@ func (sf *tester) reqBad2() {
|
|
|
body := strings.NewReader("test_msg")
|
|
body := strings.NewReader("test_msg")
|
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
resServ := kserv_http.GetKernelServHttp()
|
|
|
fibApp := resServ.Hassert("reqBad2").Fiber()
|
|
fibApp := resServ.Hassert("reqBad2").Fiber()
|
|
|
- hReq, err := http.NewRequest("POST", "/bus/request", body)
|
|
|
|
|
|
|
+ hReq, err := http.NewRequest(http.MethodPost, "/bus/request", body)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqBad1(): err=%v", err)
|
|
sf.t.Fatalf("reqBad1(): err=%v", err)
|
|
|
}
|
|
}
|
|
@@ -531,8 +549,10 @@ func (sf *tester) reqBad2() {
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
sf.t.Fatalf("reqBad1(): after request, err=%v", err)
|
|
sf.t.Fatalf("reqBad1(): after request, err=%v", err)
|
|
|
}
|
|
}
|
|
|
- defer resp.Body.Close()
|
|
|
|
|
- if resp.StatusCode != 400 {
|
|
|
|
|
|
|
+ defer func() {
|
|
|
|
|
+ _ = resp.Body.Close()
|
|
|
|
|
+ }()
|
|
|
|
|
+ if resp.StatusCode != http.StatusBadRequest {
|
|
|
sf.t.Fatalf("reqBad1(): statusCode(%v)!=400", resp.StatusCode)
|
|
sf.t.Fatalf("reqBad1(): statusCode(%v)!=400", resp.StatusCode)
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|
|
@@ -553,7 +573,7 @@ func (sf *tester) get() {
|
|
|
sf.t.Log("get")
|
|
sf.t.Log("get")
|
|
|
_ = MakeEnv()
|
|
_ = MakeEnv()
|
|
|
_ = os.Unsetenv("LOCAL_HTTP_URL")
|
|
_ = os.Unsetenv("LOCAL_HTTP_URL")
|
|
|
- os.Setenv("LOCAL_HTTP_URL", "http://localhost:18312/")
|
|
|
|
|
|
|
+ _ = os.Setenv("LOCAL_HTTP_URL", "http://localhost:18312/")
|
|
|
_ = GetKernelBusHttp()
|
|
_ = GetKernelBusHttp()
|
|
|
if Bus_ == nil {
|
|
if Bus_ == nil {
|
|
|
sf.t.Fatalf("get(): bus==nil")
|
|
sf.t.Fatalf("get(): bus==nil")
|