summaryrefslogtreecommitdiff
path: root/plugins/http/uploads_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/http/uploads_test.go')
-rw-r--r--plugins/http/uploads_test.go435
1 files changed, 0 insertions, 435 deletions
diff --git a/plugins/http/uploads_test.go b/plugins/http/uploads_test.go
deleted file mode 100644
index b023b28f..00000000
--- a/plugins/http/uploads_test.go
+++ /dev/null
@@ -1,435 +0,0 @@
-package http
-
-//
-//import (
-// "bytes"
-// "context"
-// "crypto/md5"
-// "encoding/hex"
-// "fmt"
-// "io"
-// "io/ioutil"
-// "mime/multipart"
-// "net/http"
-// "os"
-// "testing"
-// "time"
-//
-// json "github.com/json-iterator/go"
-// "github.com/stretchr/testify/assert"
-//)
-//
-//func TestHandler_Upload_File(t *testing.T) {
-// h := &Handler{
-// cfg: &Config{
-// MaxRequestSize: 1024,
-// Uploads: &UploadsConfig{
-// Dir: os.TempDir(),
-// Forbid: []string{},
-// },
-// },
-// pool: roadrunner.NewServer(&roadrunner.ServerConfig{
-// Command: "php ../../tests/http/client.php upload pipes",
-// Relay: "pipes",
-// Pool: &roadrunner.Config{
-// NumWorkers: 1,
-// AllocateTimeout: 10000000,
-// DestroyTimeout: 10000000,
-// },
-// }),
-// }
-//
-// assert.NoError(t, h.pool.Start())
-// defer h.pool.Stop()
-//
-// hs := &http.Server{Addr: ":8021", Handler: h}
-// defer func() {
-// err := hs.Shutdown(context.Background())
-// if err != nil {
-// t.Errorf("error during the shutdown: error %v", err)
-// }
-// }()
-//
-// go func() {
-// err := hs.ListenAndServe()
-// if err != nil && err != http.ErrServerClosed {
-// t.Errorf("error listening the interface: error %v", err)
-// }
-// }()
-// time.Sleep(time.Millisecond * 10)
-//
-// var mb bytes.Buffer
-// w := multipart.NewWriter(&mb)
-//
-// f := mustOpen("uploads_test.go")
-// defer func() {
-// err := f.Close()
-// if err != nil {
-// t.Errorf("failed to close a file: error %v", err)
-// }
-// }()
-// fw, err := w.CreateFormFile("upload", f.Name())
-// assert.NotNil(t, fw)
-// assert.NoError(t, err)
-// _, err = io.Copy(fw, f)
-// if err != nil {
-// t.Errorf("error copying the file: error %v", err)
-// }
-//
-// err = w.Close()
-// if err != nil {
-// t.Errorf("error closing the file: error %v", err)
-// }
-//
-// req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-// assert.NoError(t, err)
-//
-// req.Header.Set("Content-Type", w.FormDataContentType())
-//
-// r, err := http.DefaultClient.Do(req)
-// assert.NoError(t, err)
-// defer func() {
-// err := r.Body.Close()
-// if err != nil {
-// t.Errorf("error closing the Body: error %v", err)
-// }
-// }()
-//
-// b, err := ioutil.ReadAll(r.Body)
-// assert.NoError(t, err)
-//
-// assert.NoError(t, err)
-// assert.Equal(t, 200, r.StatusCode)
-//
-// fs := fileString("uploads_test.go", 0, "application/octet-stream")
-//
-// assert.Equal(t, `{"upload":`+fs+`}`, string(b))
-//}
-//
-//func TestHandler_Upload_NestedFile(t *testing.T) {
-// h := &Handler{
-// cfg: &Config{
-// MaxRequestSize: 1024,
-// Uploads: &UploadsConfig{
-// Dir: os.TempDir(),
-// Forbid: []string{},
-// },
-// },
-// pool: roadrunner.NewServer(&roadrunner.ServerConfig{
-// Command: "php ../../tests/http/client.php upload pipes",
-// Relay: "pipes",
-// Pool: &roadrunner.Config{
-// NumWorkers: 1,
-// AllocateTimeout: 10000000,
-// DestroyTimeout: 10000000,
-// },
-// }),
-// }
-//
-// assert.NoError(t, h.pool.Start())
-// defer h.pool.Stop()
-//
-// hs := &http.Server{Addr: ":8021", Handler: h}
-// defer func() {
-// err := hs.Shutdown(context.Background())
-// if err != nil {
-// t.Errorf("error during the shutdown: error %v", err)
-// }
-// }()
-//
-// go func() {
-// err := hs.ListenAndServe()
-// if err != nil && err != http.ErrServerClosed {
-// t.Errorf("error listening the interface: error %v", err)
-// }
-// }()
-// time.Sleep(time.Millisecond * 10)
-//
-// var mb bytes.Buffer
-// w := multipart.NewWriter(&mb)
-//
-// f := mustOpen("uploads_test.go")
-// defer func() {
-// err := f.Close()
-// if err != nil {
-// t.Errorf("failed to close a file: error %v", err)
-// }
-// }()
-// fw, err := w.CreateFormFile("upload[x][y][z][]", f.Name())
-// assert.NotNil(t, fw)
-// assert.NoError(t, err)
-// _, err = io.Copy(fw, f)
-// if err != nil {
-// t.Errorf("error copying the file: error %v", err)
-// }
-//
-// err = w.Close()
-// if err != nil {
-// t.Errorf("error closing the file: error %v", err)
-// }
-//
-// req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-// assert.NoError(t, err)
-//
-// req.Header.Set("Content-Type", w.FormDataContentType())
-//
-// r, err := http.DefaultClient.Do(req)
-// assert.NoError(t, err)
-// defer func() {
-// err := r.Body.Close()
-// if err != nil {
-// t.Errorf("error closing the Body: error %v", err)
-// }
-// }()
-//
-// b, err := ioutil.ReadAll(r.Body)
-// assert.NoError(t, err)
-//
-// assert.NoError(t, err)
-// assert.Equal(t, 200, r.StatusCode)
-//
-// fs := fileString("uploads_test.go", 0, "application/octet-stream")
-//
-// assert.Equal(t, `{"upload":{"x":{"y":{"z":[`+fs+`]}}}}`, string(b))
-//}
-//
-//func TestHandler_Upload_File_NoTmpDir(t *testing.T) {
-// h := &Handler{
-// cfg: &Config{
-// MaxRequestSize: 1024,
-// Uploads: &UploadsConfig{
-// Dir: "-----",
-// Forbid: []string{},
-// },
-// },
-// pool: roadrunner.NewServer(&roadrunner.ServerConfig{
-// Command: "php ../../tests/http/client.php upload pipes",
-// Relay: "pipes",
-// Pool: &roadrunner.Config{
-// NumWorkers: 1,
-// AllocateTimeout: 10000000,
-// DestroyTimeout: 10000000,
-// },
-// }),
-// }
-//
-// assert.NoError(t, h.pool.Start())
-// defer h.pool.Stop()
-//
-// hs := &http.Server{Addr: ":8021", Handler: h}
-// defer func() {
-// err := hs.Shutdown(context.Background())
-// if err != nil {
-// t.Errorf("error during the shutdown: error %v", err)
-// }
-// }()
-//
-// go func() {
-// err := hs.ListenAndServe()
-// if err != nil && err != http.ErrServerClosed {
-// t.Errorf("error listening the interface: error %v", err)
-// }
-// }()
-// time.Sleep(time.Millisecond * 10)
-//
-// var mb bytes.Buffer
-// w := multipart.NewWriter(&mb)
-//
-// f := mustOpen("uploads_test.go")
-// defer func() {
-// err := f.Close()
-// if err != nil {
-// t.Errorf("failed to close a file: error %v", err)
-// }
-// }()
-// fw, err := w.CreateFormFile("upload", f.Name())
-// assert.NotNil(t, fw)
-// assert.NoError(t, err)
-// _, err = io.Copy(fw, f)
-// if err != nil {
-// t.Errorf("error copying the file: error %v", err)
-// }
-//
-// err = w.Close()
-// if err != nil {
-// t.Errorf("error closing the file: error %v", err)
-// }
-//
-// req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-// assert.NoError(t, err)
-//
-// req.Header.Set("Content-Type", w.FormDataContentType())
-//
-// r, err := http.DefaultClient.Do(req)
-// assert.NoError(t, err)
-// defer func() {
-// err := r.Body.Close()
-// if err != nil {
-// t.Errorf("error closing the Body: error %v", err)
-// }
-// }()
-//
-// b, err := ioutil.ReadAll(r.Body)
-// assert.NoError(t, err)
-//
-// assert.NoError(t, err)
-// assert.Equal(t, 200, r.StatusCode)
-//
-// fs := fileString("uploads_test.go", 5, "application/octet-stream")
-//
-// assert.Equal(t, `{"upload":`+fs+`}`, string(b))
-//}
-//
-//func TestHandler_Upload_File_Forbids(t *testing.T) {
-// h := &Handler{
-// cfg: &Config{
-// MaxRequestSize: 1024,
-// Uploads: &UploadsConfig{
-// Dir: os.TempDir(),
-// Forbid: []string{".go"},
-// },
-// },
-// pool: roadrunner.NewServer(&roadrunner.ServerConfig{
-// Command: "php ../../tests/http/client.php upload pipes",
-// Relay: "pipes",
-// Pool: &roadrunner.Config{
-// NumWorkers: 1,
-// AllocateTimeout: 10000000,
-// DestroyTimeout: 10000000,
-// },
-// }),
-// }
-//
-// assert.NoError(t, h.pool.Start())
-// defer h.pool.Stop()
-//
-// hs := &http.Server{Addr: ":8021", Handler: h}
-// defer func() {
-// err := hs.Shutdown(context.Background())
-// if err != nil {
-// t.Errorf("error during the shutdown: error %v", err)
-// }
-// }()
-//
-// go func() {
-// err := hs.ListenAndServe()
-// if err != nil && err != http.ErrServerClosed {
-// t.Errorf("error listening the interface: error %v", err)
-// }
-// }()
-// time.Sleep(time.Millisecond * 10)
-//
-// var mb bytes.Buffer
-// w := multipart.NewWriter(&mb)
-//
-// f := mustOpen("uploads_test.go")
-// defer func() {
-// err := f.Close()
-// if err != nil {
-// t.Errorf("failed to close a file: error %v", err)
-// }
-// }()
-// fw, err := w.CreateFormFile("upload", f.Name())
-// assert.NotNil(t, fw)
-// assert.NoError(t, err)
-// _, err = io.Copy(fw, f)
-// if err != nil {
-// t.Errorf("error copying the file: error %v", err)
-// }
-//
-// err = w.Close()
-// if err != nil {
-// t.Errorf("error closing the file: error %v", err)
-// }
-//
-// req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-// assert.NoError(t, err)
-//
-// req.Header.Set("Content-Type", w.FormDataContentType())
-//
-// r, err := http.DefaultClient.Do(req)
-// assert.NoError(t, err)
-// defer func() {
-// err := r.Body.Close()
-// if err != nil {
-// t.Errorf("error closing the Body: error %v", err)
-// }
-// }()
-//
-// b, err := ioutil.ReadAll(r.Body)
-// assert.NoError(t, err)
-//
-// assert.NoError(t, err)
-// assert.Equal(t, 200, r.StatusCode)
-//
-// fs := fileString("uploads_test.go", 7, "application/octet-stream")
-//
-// assert.Equal(t, `{"upload":`+fs+`}`, string(b))
-//}
-//
-//func Test_FileExists(t *testing.T) {
-// assert.True(t, exists("uploads_test.go"))
-// assert.False(t, exists("uploads_test."))
-//}
-//
-//func mustOpen(f string) *os.File {
-// r, err := os.Open(f)
-// if err != nil {
-// panic(err)
-// }
-// return r
-//}
-//
-//type fInfo struct {
-// Name string `json:"name"`
-// Size int64 `json:"size"`
-// Mime string `json:"mime"`
-// Error int `json:"error"`
-// MD5 string `json:"md5,omitempty"`
-//}
-//
-//func fileString(f string, errNo int, mime string) string {
-// s, err := os.Stat(f)
-// if err != nil {
-// fmt.Println(fmt.Errorf("error stat the file, error: %v", err))
-// }
-//
-// ff, err := os.Open(f)
-// if err != nil {
-// fmt.Println(fmt.Errorf("error opening the file, error: %v", err))
-// }
-//
-// defer func() {
-// er := ff.Close()
-// if er != nil {
-// fmt.Println(fmt.Errorf("error closing the file, error: %v", er))
-// }
-// }()
-//
-// h := md5.New()
-// _, err = io.Copy(h, ff)
-// if err != nil {
-// fmt.Println(fmt.Errorf("error copying the file, error: %v", err))
-// }
-//
-// v := &fInfo{
-// Name: s.Name(),
-// Size: s.Size(),
-// Error: errNo,
-// Mime: mime,
-// MD5: hex.EncodeToString(h.Sum(nil)),
-// }
-//
-// if errNo != 0 {
-// v.MD5 = ""
-// v.Size = 0
-// }
-//
-// j := json.ConfigCompatibleWithStandardLibrary
-// r, err := j.Marshal(v)
-// if err != nil {
-// fmt.Println(fmt.Errorf("error marshalling fInfo, error: %v", err))
-// }
-// return string(r)
-//
-//}
generated by cgit v1.2.3 (git 2.25.1) at 2025-01-30 21:34:27 +0000