package client

import (
	"bytes"
	"fmt"
	"io"
	"io/ioutil"
	"mime/multipart"
	"os"
	"testing"
	"time"
)

func TestDo(t *testing.T) {

	// 启动服务端
	server.StartHttp2()
	time.Sleep(time.Duration(4) * time.Second)

	// 创建临时文件
	tmpFile, _ := ioutil.TempFile("/tmp", "godfs_test_1.tmp")
	ioutil.WriteFile(tmpFile.Name(), []byte("abc"), 600)
	tmpFile.Close()

	for i := 0; i < 10; i++ {
		go func() {
			for i := 0; i < 10; i++ {
				bodyBuf := &bytes.Buffer{}
				bodyWriter := multipart.NewWriter(bodyBuf)

				fileWriter, _ := bodyWriter.CreateFormFile("file", tmpFile.Name())
				fh, _ := os.Open(tmpFile.Name())

				io.Copy(fileWriter, fh)
				contentType := bodyWriter.FormDataContentType()
				bodyWriter.Close()
				defer fh.Close()
				fmt.Println(contentType)
				url := "https://127.0.0.1:8090/file"
				rsp, _ := Http2Client.Post(url, contentType, bodyBuf)

				defer func() {
					rsp.Body.Close()
				}()
				body, _ := ioutil.ReadAll(rsp.Body)
				fmt.Println(string(body))
			}
		}()
		time.Sleep(time.Duration(1) * time.Second)
		if i == 4 {
			time.Sleep(time.Duration(100) * time.Second)
		}
	}
}