2017-06-12 09:04:52 +03:00
|
|
|
// Copyright 2017 Manu Martinez-Almeida. All rights reserved.
|
|
|
|
// Use of this source code is governed by a MIT style
|
|
|
|
// license that can be found in the LICENSE file.
|
|
|
|
|
2015-05-29 04:28:24 +03:00
|
|
|
package gin
|
|
|
|
|
|
|
|
import (
|
|
|
|
"bufio"
|
2018-10-16 03:48:41 +03:00
|
|
|
"crypto/tls"
|
2015-05-29 04:28:24 +03:00
|
|
|
"fmt"
|
2015-05-29 14:29:33 +03:00
|
|
|
"io/ioutil"
|
2015-05-29 04:28:24 +03:00
|
|
|
"net"
|
|
|
|
"net/http"
|
2017-06-12 05:40:15 +03:00
|
|
|
"net/http/httptest"
|
2015-08-16 17:19:51 +03:00
|
|
|
"os"
|
2018-10-01 05:49:39 +03:00
|
|
|
"sync"
|
2015-05-29 04:28:24 +03:00
|
|
|
"testing"
|
|
|
|
"time"
|
|
|
|
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
|
|
)
|
|
|
|
|
2015-08-16 17:19:51 +03:00
|
|
|
func testRequest(t *testing.T, url string) {
|
2018-10-16 03:48:41 +03:00
|
|
|
tr := &http.Transport{
|
|
|
|
TLSClientConfig: &tls.Config{
|
|
|
|
InsecureSkipVerify: true,
|
|
|
|
},
|
|
|
|
}
|
|
|
|
client := &http.Client{Transport: tr}
|
|
|
|
|
|
|
|
resp, err := client.Get(url)
|
2015-08-16 17:19:51 +03:00
|
|
|
assert.NoError(t, err)
|
2017-06-13 05:50:42 +03:00
|
|
|
defer resp.Body.Close()
|
2015-08-16 17:19:51 +03:00
|
|
|
|
|
|
|
body, ioerr := ioutil.ReadAll(resp.Body)
|
|
|
|
assert.NoError(t, ioerr)
|
|
|
|
assert.Equal(t, "it worked", string(body), "resp body should match")
|
|
|
|
assert.Equal(t, "200 OK", resp.Status, "should get a 200")
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestRunEmpty(t *testing.T) {
|
|
|
|
os.Setenv("PORT", "")
|
2015-05-29 14:29:33 +03:00
|
|
|
router := New()
|
|
|
|
go func() {
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
2015-08-16 17:19:51 +03:00
|
|
|
assert.NoError(t, router.Run())
|
2015-05-29 14:29:33 +03:00
|
|
|
}()
|
|
|
|
// have to wait for the goroutine to start and run the server
|
|
|
|
// otherwise the main thread will complete
|
|
|
|
time.Sleep(5 * time.Millisecond)
|
|
|
|
|
2015-08-16 17:19:51 +03:00
|
|
|
assert.Error(t, router.Run(":8080"))
|
|
|
|
testRequest(t, "http://localhost:8080/example")
|
|
|
|
}
|
2015-06-03 06:25:50 +03:00
|
|
|
|
2018-10-16 03:48:41 +03:00
|
|
|
func TestRunTLS(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
go func() {
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
|
|
|
|
assert.NoError(t, router.RunTLS(":8443", "./testdata/certificate/cert.pem", "./testdata/certificate/key.pem"))
|
|
|
|
}()
|
|
|
|
|
|
|
|
// have to wait for the goroutine to start and run the server
|
|
|
|
// otherwise the main thread will complete
|
|
|
|
time.Sleep(5 * time.Millisecond)
|
|
|
|
|
|
|
|
assert.Error(t, router.RunTLS(":8443", "./testdata/certificate/cert.pem", "./testdata/certificate/key.pem"))
|
|
|
|
testRequest(t, "https://localhost:8443/example")
|
|
|
|
}
|
|
|
|
|
2015-08-16 17:19:51 +03:00
|
|
|
func TestRunEmptyWithEnv(t *testing.T) {
|
|
|
|
os.Setenv("PORT", "3123")
|
|
|
|
router := New()
|
|
|
|
go func() {
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
assert.NoError(t, router.Run())
|
|
|
|
}()
|
|
|
|
// have to wait for the goroutine to start and run the server
|
|
|
|
// otherwise the main thread will complete
|
|
|
|
time.Sleep(5 * time.Millisecond)
|
2015-06-03 06:25:50 +03:00
|
|
|
|
2015-08-16 17:19:51 +03:00
|
|
|
assert.Error(t, router.Run(":3123"))
|
|
|
|
testRequest(t, "http://localhost:3123/example")
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestRunTooMuchParams(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
assert.Panics(t, func() {
|
|
|
|
router.Run("2", "2")
|
|
|
|
})
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestRunWithPort(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
go func() {
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
assert.NoError(t, router.Run(":5150"))
|
|
|
|
}()
|
|
|
|
// have to wait for the goroutine to start and run the server
|
|
|
|
// otherwise the main thread will complete
|
|
|
|
time.Sleep(5 * time.Millisecond)
|
|
|
|
|
|
|
|
assert.Error(t, router.Run(":5150"))
|
|
|
|
testRequest(t, "http://localhost:5150/example")
|
2015-05-29 14:29:33 +03:00
|
|
|
}
|
|
|
|
|
2015-05-29 04:28:24 +03:00
|
|
|
func TestUnixSocket(t *testing.T) {
|
|
|
|
router := New()
|
2015-06-03 06:25:50 +03:00
|
|
|
|
2015-05-29 04:28:24 +03:00
|
|
|
go func() {
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
2015-08-16 17:19:51 +03:00
|
|
|
assert.NoError(t, router.RunUnix("/tmp/unix_unit_test"))
|
2015-05-29 04:28:24 +03:00
|
|
|
}()
|
|
|
|
// have to wait for the goroutine to start and run the server
|
|
|
|
// otherwise the main thread will complete
|
|
|
|
time.Sleep(5 * time.Millisecond)
|
|
|
|
|
|
|
|
c, err := net.Dial("unix", "/tmp/unix_unit_test")
|
2015-06-03 06:25:50 +03:00
|
|
|
assert.NoError(t, err)
|
|
|
|
|
2017-11-29 05:50:14 +03:00
|
|
|
fmt.Fprint(c, "GET /example HTTP/1.0\r\n\r\n")
|
2015-05-29 04:28:24 +03:00
|
|
|
scanner := bufio.NewScanner(c)
|
|
|
|
var response string
|
|
|
|
for scanner.Scan() {
|
|
|
|
response += scanner.Text()
|
|
|
|
}
|
|
|
|
assert.Contains(t, response, "HTTP/1.0 200", "should get a 200")
|
|
|
|
assert.Contains(t, response, "it worked", "resp body should match")
|
|
|
|
}
|
2015-06-03 06:25:50 +03:00
|
|
|
|
|
|
|
func TestBadUnixSocket(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
assert.Error(t, router.RunUnix("#/tmp/unix_unit_test"))
|
|
|
|
}
|
2016-02-23 20:44:52 +03:00
|
|
|
|
2018-11-06 05:28:51 +03:00
|
|
|
func TestFileDescriptor(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
|
2018-12-28 05:26:29 +03:00
|
|
|
addr, err := net.ResolveTCPAddr("tcp", "localhost:0")
|
2018-11-06 05:28:51 +03:00
|
|
|
assert.NoError(t, err)
|
|
|
|
listener, err := net.ListenTCP("tcp", addr)
|
|
|
|
assert.NoError(t, err)
|
|
|
|
socketFile, err := listener.File()
|
|
|
|
assert.NoError(t, err)
|
|
|
|
|
|
|
|
go func() {
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
assert.NoError(t, router.RunFd(int(socketFile.Fd())))
|
|
|
|
}()
|
|
|
|
// have to wait for the goroutine to start and run the server
|
|
|
|
// otherwise the main thread will complete
|
|
|
|
time.Sleep(5 * time.Millisecond)
|
|
|
|
|
2018-12-28 05:26:29 +03:00
|
|
|
c, err := net.Dial("tcp", listener.Addr().String())
|
2018-11-06 05:28:51 +03:00
|
|
|
assert.NoError(t, err)
|
|
|
|
|
|
|
|
fmt.Fprintf(c, "GET /example HTTP/1.0\r\n\r\n")
|
|
|
|
scanner := bufio.NewScanner(c)
|
|
|
|
var response string
|
|
|
|
for scanner.Scan() {
|
|
|
|
response += scanner.Text()
|
|
|
|
}
|
|
|
|
assert.Contains(t, response, "HTTP/1.0 200", "should get a 200")
|
|
|
|
assert.Contains(t, response, "it worked", "resp body should match")
|
|
|
|
}
|
|
|
|
|
|
|
|
func TestBadFileDescriptor(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
assert.Error(t, router.RunFd(0))
|
|
|
|
}
|
|
|
|
|
2016-02-23 20:44:52 +03:00
|
|
|
func TestWithHttptestWithAutoSelectedPort(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
|
|
|
|
ts := httptest.NewServer(router)
|
|
|
|
defer ts.Close()
|
|
|
|
|
|
|
|
testRequest(t, ts.URL+"/example")
|
|
|
|
}
|
|
|
|
|
2018-10-01 05:49:39 +03:00
|
|
|
func TestConcurrentHandleContext(t *testing.T) {
|
|
|
|
router := New()
|
|
|
|
router.GET("/", func(c *Context) {
|
|
|
|
c.Request.URL.Path = "/example"
|
|
|
|
router.HandleContext(c)
|
|
|
|
})
|
|
|
|
router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
|
|
|
|
ts := httptest.NewServer(router)
|
|
|
|
defer ts.Close()
|
|
|
|
|
|
|
|
var wg sync.WaitGroup
|
|
|
|
iterations := 200
|
|
|
|
wg.Add(iterations)
|
|
|
|
for i := 0; i < iterations; i++ {
|
|
|
|
go func() {
|
|
|
|
testRequest(t, ts.URL+"/")
|
|
|
|
wg.Done()
|
|
|
|
}()
|
|
|
|
}
|
|
|
|
wg.Wait()
|
|
|
|
}
|
|
|
|
|
2017-03-16 18:38:30 +03:00
|
|
|
// func TestWithHttptestWithSpecifiedPort(t *testing.T) {
|
|
|
|
// router := New()
|
|
|
|
// router.GET("/example", func(c *Context) { c.String(http.StatusOK, "it worked") })
|
|
|
|
|
|
|
|
// l, _ := net.Listen("tcp", ":8033")
|
|
|
|
// ts := httptest.Server{
|
|
|
|
// Listener: l,
|
|
|
|
// Config: &http.Server{Handler: router},
|
|
|
|
// }
|
|
|
|
// ts.Start()
|
|
|
|
// defer ts.Close()
|
|
|
|
|
|
|
|
// testRequest(t, "http://localhost:8033/example")
|
|
|
|
// }
|