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, 0 insertions, 362 deletions
diff --git a/plugins/headers/tests/old.go b/plugins/headers/tests/old.go
deleted file mode 100644
index b3d95aa5..00000000
--- a/plugins/headers/tests/old.go
+++ /dev/null
@@ -1,362 +0,0 @@
-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-29 18:18:20 +0000