summaryrefslogtreecommitdiff
path: root/service/http/server_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'service/http/server_test.go')
-rw-r--r--service/http/server_test.go478
1 files changed, 343 insertions, 135 deletions
diff --git a/service/http/server_test.go b/service/http/server_test.go
index 2499de7c..cde28ea2 100644
--- a/service/http/server_test.go
+++ b/service/http/server_test.go
@@ -1,12 +1,7 @@
package http
import (
- "testing"
- "github.com/spiral/roadrunner"
- "os"
- "github.com/stretchr/testify/assert"
"net/http"
- "context"
"io/ioutil"
)
@@ -21,133 +16,346 @@ func get(url string) (string, *http.Response, error) {
b, err := ioutil.ReadAll(r.Body)
return string(b), r, err
}
-
-func TestServer_Echo(t *testing.T) {
- st := &Server{
- cfg: &Config{
- MaxRequest: 1024,
- Uploads: &UploadsConfig{
- Dir: os.TempDir(),
- Forbid: []string{},
- },
- },
- rr: roadrunner.NewServer(&roadrunner.ServerConfig{
- Command: "php ../../php-src/tests/http/client.php echo pipes",
- Relay: "pipes",
- Pool: &roadrunner.Config{
- NumWorkers: 1,
- AllocateTimeout: 10000000,
- DestroyTimeout: 10000000,
- },
- }),
- }
-
- assert.NoError(t, st.rr.Start())
- defer st.rr.Stop()
-
- hs := &http.Server{Addr: ":8077", Handler: st,}
- defer hs.Shutdown(context.Background())
-
- go func() { hs.ListenAndServe() }()
-
- body, r, err := get("http://localhost:8077/?hello=world")
- assert.NoError(t, err)
- assert.Equal(t, 200, r.StatusCode)
- assert.Equal(t, "WORLD", body)
-}
-
-func TestServer_Headers(t *testing.T) {
- st := &Server{
- cfg: &Config{
- MaxRequest: 1024,
- Uploads: &UploadsConfig{
- Dir: os.TempDir(),
- Forbid: []string{},
- },
- },
- rr: roadrunner.NewServer(&roadrunner.ServerConfig{
- Command: "php ../../php-src/tests/http/client.php header pipes",
- Relay: "pipes",
- Pool: &roadrunner.Config{
- NumWorkers: 1,
- AllocateTimeout: 10000000,
- DestroyTimeout: 10000000,
- },
- }),
- }
-
- assert.NoError(t, st.rr.Start())
- defer st.rr.Stop()
-
- hs := &http.Server{Addr: ":8077", Handler: st,}
- defer hs.Shutdown(context.Background())
-
- go func() { hs.ListenAndServe() }()
-
- req, err := http.NewRequest("GET", "http://localhost:8077?hello=world", nil)
- assert.NoError(t, err)
-
- req.Header.Add("input", "sample")
-
- r, err := http.DefaultClient.Do(req)
- assert.NoError(t, err)
- defer r.Body.Close()
-
- b, err := ioutil.ReadAll(r.Body)
- assert.NoError(t, err)
-
- assert.NoError(t, err)
- assert.Equal(t, 200, r.StatusCode)
- assert.Equal(t, "world", r.Header.Get("Header"))
- assert.Equal(t, "SAMPLE", string(b))
-}
-
-func TestServer_Cookies(t *testing.T) {
- st := &Server{
- cfg: &Config{
- MaxRequest: 1024,
- Uploads: &UploadsConfig{
- Dir: os.TempDir(),
- Forbid: []string{},
- },
- },
- rr: roadrunner.NewServer(&roadrunner.ServerConfig{
- Command: "php ../../php-src/tests/http/client.php cookie pipes",
- Relay: "pipes",
- Pool: &roadrunner.Config{
- NumWorkers: 1,
- AllocateTimeout: 10000000,
- DestroyTimeout: 10000000,
- },
- }),
- }
-
- assert.NoError(t, st.rr.Start())
- defer st.rr.Stop()
-
- hs := &http.Server{Addr: ":8077", Handler: st,}
- defer hs.Shutdown(context.Background())
-
- go func() { hs.ListenAndServe() }()
-
- req, err := http.NewRequest("GET", "http://localhost:8077", nil)
- assert.NoError(t, err)
-
- req.AddCookie(&http.Cookie{Name: "input", Value: "input-value"})
-
- r, err := http.DefaultClient.Do(req)
- assert.NoError(t, err)
- defer r.Body.Close()
-
- b, err := ioutil.ReadAll(r.Body)
- assert.NoError(t, err)
-
- assert.NoError(t, err)
- assert.Equal(t, 200, r.StatusCode)
- assert.Equal(t, "INPUT-VALUE", string(b))
-
- for _, c := range r.Cookies() {
- assert.Equal(t, "output", c.Name)
- assert.Equal(t, "cookie-output", c.Value)
- }
-}
+//
+//func TestServer_Echo(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php echo pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// body, r, err := get("http://localhost:8077/?hello=world")
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, "WORLD", body)
+//}
+//
+//func TestServer_Headers(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php header pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// req, err := http.NewRequest("GET", "http://localhost:8077?hello=world", nil)
+// assert.NoError(t, err)
+//
+// req.Header.Add("input", "sample")
+//
+// r, err := http.DefaultClient.Do(req)
+// assert.NoError(t, err)
+// defer r.Body.Close()
+//
+// b, err := ioutil.ReadAll(r.Body)
+// assert.NoError(t, err)
+//
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, "world", r.Header.Get("Header"))
+// assert.Equal(t, "SAMPLE", string(b))
+//}
+//
+//func TestServer_Cookies(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php cookie pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// req, err := http.NewRequest("GET", "http://localhost:8077", nil)
+// assert.NoError(t, err)
+//
+// req.AddCookie(&http.Cookie{Name: "input", Value: "input-value"})
+//
+// r, err := http.DefaultClient.Do(req)
+// assert.NoError(t, err)
+// defer r.Body.Close()
+//
+// b, err := ioutil.ReadAll(r.Body)
+// assert.NoError(t, err)
+//
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, "INPUT-VALUE", string(b))
+//
+// for _, c := range r.Cookies() {
+// assert.Equal(t, "output", c.Name)
+// assert.Equal(t, "cookie-output", c.Value)
+// }
+//}
+//
+//func TestServer_JsonPayload_POST(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php payload pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// req, err := http.NewRequest(
+// "POST",
+// "http://localhost:8077",
+// bytes.NewBufferString(`{"key":"value"}`),
+// )
+// assert.NoError(t, err)
+//
+// req.Header.Add("Content-Type", "application/json")
+//
+// r, err := http.DefaultClient.Do(req)
+// assert.NoError(t, err)
+// defer r.Body.Close()
+//
+// b, err := ioutil.ReadAll(r.Body)
+// assert.NoError(t, err)
+//
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, `{"value":"key"}`, string(b))
+//}
+//
+//func TestServer_JsonPayload_PUT(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php payload pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// req, err := http.NewRequest(
+// "PUT",
+// "http://localhost:8077",
+// bytes.NewBufferString(`{"key":"value"}`),
+// )
+// assert.NoError(t, err)
+//
+// req.Header.Add("Content-Type", "application/json")
+//
+// r, err := http.DefaultClient.Do(req)
+// assert.NoError(t, err)
+// defer r.Body.Close()
+//
+// b, err := ioutil.ReadAll(r.Body)
+// assert.NoError(t, err)
+//
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, `{"value":"key"}`, string(b))
+//}
+//
+//func TestServer_JsonPayload_PATCH(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php payload pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// req, err := http.NewRequest(
+// "PATCH",
+// "http://localhost:8077",
+// bytes.NewBufferString(`{"key":"value"}`),
+// )
+// assert.NoError(t, err)
+//
+// req.Header.Add("Content-Type", "application/json")
+//
+// r, err := http.DefaultClient.Do(req)
+// assert.NoError(t, err)
+// defer r.Body.Close()
+//
+// b, err := ioutil.ReadAll(r.Body)
+// assert.NoError(t, err)
+//
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, `{"value":"key"}`, string(b))
+//}
+//
+//func TestServer_FormData_POST(t *testing.T) {
+// st := &Server{
+// cfg: &Config{
+// MaxRequest: 1024,
+// Uploads: &UploadsConfig{
+// Dir: os.TempDir(),
+// Forbid: []string{},
+// },
+// },
+// rr: roadrunner.NewServer(&roadrunner.ServerConfig{
+// Command: "php ../../php-src/tests/http/client.php data pipes",
+// Relay: "pipes",
+// Pool: &roadrunner.Config{
+// NumWorkers: 1,
+// AllocateTimeout: 10000000,
+// DestroyTimeout: 10000000,
+// },
+// }),
+// }
+//
+// assert.NoError(t, st.rr.Start())
+// defer st.rr.Stop()
+//
+// hs := &http.Server{Addr: ":8077", Handler: st,}
+// defer hs.Shutdown(context.Background())
+//
+// go func() { hs.ListenAndServe() }()
+//
+// form := url.Values{}
+//
+// form.Add("key", "value")
+// form.Add("name[]", "name1")
+// form.Add("name[]", "name2")
+// form.Add("name[]", "name3")
+// form.Add("arr[x][y][z]", "y")
+// form.Add("arr[x][y][e]", "f")
+// form.Add("arr[c]p", "l")
+//
+// req, err := http.NewRequest(
+// "POST",
+// "http://localhost:8077",
+// strings.NewReader(form.Encode()),
+// )
+// assert.NoError(t, err)
+//
+// req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
+//
+// r, err := http.DefaultClient.Do(req)
+// assert.NoError(t, err)
+// defer r.Body.Close()
+//
+// b, err := ioutil.ReadAll(r.Body)
+// assert.NoError(t, err)
+//
+// assert.NoError(t, err)
+// assert.Equal(t, 200, r.StatusCode)
+//
+// log.Println(`{"arr":{"c":{"p":"l"},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`)
+// log.Println(string(b))
+//
+//
+//
+//
+// assert.Equal(t, `{"arr":{"c":{"p":"l"},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
+//}
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-31 19:01:30 +0000