summaryrefslogtreecommitdiff
path: root/plugins/headers/tests/old.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/headers/tests/old.go')
-rw-r--r--plugins/headers/tests/old.go362
1 files changed, 362 insertions, 0 deletions
diff --git a/plugins/headers/tests/old.go b/plugins/headers/tests/old.go
new file mode 100644
index 00000000..b3d95aa5
--- /dev/null
+++ b/plugins/headers/tests/old.go
@@ -0,0 +1,362 @@
+package tests
+
+//type mockCfg struct{ cfg string }
+//
+//func (cfg *mockCfg) Get(name string) service.Config { return nil }
+//func (cfg *mockCfg) Unmarshal(out interface{}) error {
+// j := json.ConfigCompatibleWithStandardLibrary
+// return j.Unmarshal([]byte(cfg.cfg), out)
+//}
+//
+//func Test_Config_Hydrate_Error1(t *testing.T) {
+// cfg := &mockCfg{`{"request": {"From": "Something"}}`}
+// c := &Config{}
+//
+// assert.NoError(t, c.Hydrate(cfg))
+//}
+//
+//func Test_Config_Hydrate_Error2(t *testing.T) {
+// cfg := &mockCfg{`{"dir": "/dir/"`}
+// c := &Config{}
+//
+// assert.Error(t, c.Hydrate(cfg))
+//}
+//-------------------------------------------------------------------------------
+//import (
+// "github.com/cenkalti/backoff/v4"
+// json "github.com/json-iterator/go"
+// "github.com/sirupsen/logrus"
+// "github.com/sirupsen/logrus/hooks/test"
+// "github.com/spiral/roadrunner/service"
+// rrhttp "github.com/spiral/roadrunner/service/http"
+// "github.com/stretchr/testify/assert"
+// "io/ioutil"
+// "net/http"
+// "testing"
+// "time"
+//)
+//
+//type testCfg struct {
+// httpCfg string
+// headers string
+// target string
+//}
+//
+//func (cfg *testCfg) Get(name string) service.Config {
+// if name == rrhttp.ID {
+// return &testCfg{target: cfg.httpCfg}
+// }
+//
+// if name == ID {
+// return &testCfg{target: cfg.headers}
+// }
+// return nil
+//}
+//
+//func (cfg *testCfg) Unmarshal(out interface{}) error {
+// return json.Unmarshal([]byte(cfg.target), out)
+//}
+//
+//func Test_RequestHeaders(t *testing.T) {
+// bkoff := backoff.NewExponentialBackOff()
+// bkoff.MaxElapsedTime = time.Second * 15
+//
+// err := backoff.Retry(func() error {
+// logger, _ := test.NewNullLogger()
+// logger.SetLevel(logrus.DebugLevel)
+//
+// c := service.NewContainer(logger)
+// c.Register(rrhttp.ID, &rrhttp.Service{})
+// c.Register(ID, &Service{})
+//
+// assert.NoError(t, c.Init(&testCfg{
+// headers: `{"request":{"input": "custom-header"}}`,
+// httpCfg: `{
+// "enable": true,
+// "address": ":6078",
+// "maxRequestSize": 1024,
+// "workers":{
+// "command": "php ../../tests/http/client.php header pipes",
+// "relay": "pipes",
+// "pool": {
+// "numWorkers": 1,
+// "allocateTimeout": 10000000,
+// "destroyTimeout": 10000000
+// }
+// }
+// }`}))
+//
+// go func() {
+// err := c.Serve()
+// if err != nil {
+// t.Errorf("error during Serve: error %v", err)
+// }
+// }()
+//
+// time.Sleep(time.Millisecond * 100)
+// defer c.Stop()
+//
+// req, err := http.NewRequest("GET", "http://localhost:6078?hello=value", nil)
+// if err != nil {
+// return err
+// }
+//
+// r, err := http.DefaultClient.Do(req)
+// if err != nil {
+// return err
+// }
+//
+// b, err := ioutil.ReadAll(r.Body)
+// if err != nil {
+// return err
+// }
+//
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, "CUSTOM-HEADER", string(b))
+//
+// err = r.Body.Close()
+// if err != nil {
+// return err
+// }
+//
+// return nil
+// }, bkoff)
+//
+// if err != nil {
+// t.Fatal(err)
+// }
+//}
+//
+//func Test_ResponseHeaders(t *testing.T) {
+// bkoff := backoff.NewExponentialBackOff()
+// bkoff.MaxElapsedTime = time.Second * 15
+//
+// err := backoff.Retry(func() error {
+// logger, _ := test.NewNullLogger()
+// logger.SetLevel(logrus.DebugLevel)
+//
+// c := service.NewContainer(logger)
+// c.Register(rrhttp.ID, &rrhttp.Service{})
+// c.Register(ID, &Service{})
+//
+// assert.NoError(t, c.Init(&testCfg{
+// headers: `{"response":{"output": "output-header"},"request":{"input": "custom-header"}}`,
+// httpCfg: `{
+// "enable": true,
+// "address": ":6079",
+// "maxRequestSize": 1024,
+// "workers":{
+// "command": "php ../../tests/http/client.php header pipes",
+// "relay": "pipes",
+// "pool": {
+// "numWorkers": 1,
+// "allocateTimeout": 10000000,
+// "destroyTimeout": 10000000
+// }
+// }
+// }`}))
+//
+// go func() {
+// err := c.Serve()
+// if err != nil {
+// t.Errorf("error during the Serve: error %v", err)
+// }
+// }()
+// time.Sleep(time.Millisecond * 100)
+// defer c.Stop()
+//
+// req, err := http.NewRequest("GET", "http://localhost:6079?hello=value", nil)
+// if err != nil {
+// return err
+// }
+//
+// r, err := http.DefaultClient.Do(req)
+// if err != nil {
+// return err
+// }
+//
+// assert.Equal(t, "output-header", r.Header.Get("output"))
+//
+// b, err := ioutil.ReadAll(r.Body)
+// if err != nil {
+// return err
+// }
+// assert.Equal(t, 200, r.StatusCode)
+// assert.Equal(t, "CUSTOM-HEADER", string(b))
+//
+// err = r.Body.Close()
+// if err != nil {
+// return err
+// }
+//
+// return nil
+// }, bkoff)
+//
+// if err != nil {
+// t.Fatal(err)
+// }
+//}
+//
+//func TestCORS_OPTIONS(t *testing.T) {
+// bkoff := backoff.NewExponentialBackOff()
+// bkoff.MaxElapsedTime = time.Second * 15
+//
+// err := backoff.Retry(func() error {
+// logger, _ := test.NewNullLogger()
+// logger.SetLevel(logrus.DebugLevel)
+//
+// c := service.NewContainer(logger)
+// c.Register(rrhttp.ID, &rrhttp.Service{})
+// c.Register(ID, &Service{})
+//
+// assert.NoError(t, c.Init(&testCfg{
+// headers: `{
+//"cors":{
+// "allowedOrigin": "*",
+// "allowedHeaders": "*",
+// "allowedMethods": "GET,POST,PUT,DELETE",
+// "allowCredentials": true,
+// "exposedHeaders": "Cache-Control,Content-Language,Content-Type,Expires,Last-Modified,Pragma",
+// "maxAge": 600
+//}
+//}`,
+// httpCfg: `{
+// "enable": true,
+// "address": ":16379",
+// "maxRequestSize": 1024,
+// "workers":{
+// "command": "php ../../tests/http/client.php headers pipes",
+// "relay": "pipes",
+// "pool": {
+// "numWorkers": 1,
+// "allocateTimeout": 10000000,
+// "destroyTimeout": 10000000
+// }
+// }
+// }`}))
+//
+// go func() {
+// err := c.Serve()
+// if err != nil {
+// t.Errorf("error during the Serve: error %v", err)
+// }
+// }()
+// time.Sleep(time.Millisecond * 100)
+// defer c.Stop()
+//
+// req, err := http.NewRequest("OPTIONS", "http://localhost:16379", nil)
+// if err != nil {
+// return err
+// }
+//
+// r, err := http.DefaultClient.Do(req)
+// if err != nil {
+// return err
+// }
+//
+// assert.Equal(t, "true", r.Header.Get("Access-Control-Allow-Credentials"))
+// assert.Equal(t, "*", r.Header.Get("Access-Control-Allow-Headers"))
+// assert.Equal(t, "GET,POST,PUT,DELETE", r.Header.Get("Access-Control-Allow-Methods"))
+// assert.Equal(t, "*", r.Header.Get("Access-Control-Allow-Origin"))
+// assert.Equal(t, "600", r.Header.Get("Access-Control-Max-Age"))
+// assert.Equal(t, "true", r.Header.Get("Access-Control-Allow-Credentials"))
+//
+// _, err = ioutil.ReadAll(r.Body)
+// if err != nil {
+// return err
+// }
+// assert.Equal(t, 200, r.StatusCode)
+//
+// err = r.Body.Close()
+// if err != nil {
+// return err
+// }
+//
+// return nil
+// }, bkoff)
+//
+// if err != nil {
+// t.Fatal(err)
+// }
+//}
+//
+//func TestCORS_Pass(t *testing.T) {
+// bkoff := backoff.NewExponentialBackOff()
+// bkoff.MaxElapsedTime = time.Second * 15
+//
+// err := backoff.Retry(func() error {
+// logger, _ := test.NewNullLogger()
+// logger.SetLevel(logrus.DebugLevel)
+//
+// c := service.NewContainer(logger)
+// c.Register(rrhttp.ID, &rrhttp.Service{})
+// c.Register(ID, &Service{})
+//
+// assert.NoError(t, c.Init(&testCfg{
+// headers: `{
+//"cors":{
+// "allowedOrigin": "*",
+// "allowedHeaders": "*",
+// "allowedMethods": "GET,POST,PUT,DELETE",
+// "allowCredentials": true,
+// "exposedHeaders": "Cache-Control,Content-Language,Content-Type,Expires,Last-Modified,Pragma",
+// "maxAge": 600
+//}
+//}`,
+// httpCfg: `{
+// "enable": true,
+// "address": ":6672",
+// "maxRequestSize": 1024,
+// "workers":{
+// "command": "php ../../tests/http/client.php headers pipes",
+// "relay": "pipes",
+// "pool": {
+// "numWorkers": 1,
+// "allocateTimeout": 10000000,
+// "destroyTimeout": 10000000
+// }
+// }
+// }`}))
+//
+// go func() {
+// err := c.Serve()
+// if err != nil {
+// t.Errorf("error during the Serve: error %v", err)
+// }
+// }()
+// time.Sleep(time.Millisecond * 100)
+// defer c.Stop()
+//
+// req, err := http.NewRequest("GET", "http://localhost:6672", nil)
+// if err != nil {
+// return err
+// }
+//
+// r, err := http.DefaultClient.Do(req)
+// if err != nil {
+// return err
+// }
+//
+// assert.Equal(t, "true", r.Header.Get("Access-Control-Allow-Credentials"))
+// assert.Equal(t, "*", r.Header.Get("Access-Control-Allow-Headers"))
+// assert.Equal(t, "*", r.Header.Get("Access-Control-Allow-Origin"))
+// assert.Equal(t, "true", r.Header.Get("Access-Control-Allow-Credentials"))
+//
+// _, err = ioutil.ReadAll(r.Body)
+// if err != nil {
+// return err
+// }
+// assert.Equal(t, 200, r.StatusCode)
+//
+// err = r.Body.Close()
+// if err != nil {
+// return err
+// }
+//
+// return nil
+// }, bkoff)
+//
+// if err != nil {
+// t.Fatal(err)
+// }
+//} \ No newline at end of file
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-23 23:16:33 +0000