Files
quic-go/h2quic/integration_test.go
2016-06-02 12:05:24 +02:00

81 lines
1.8 KiB
Go

package h2quic_test
import (
"fmt"
"io"
"net/http"
"os"
"os/exec"
"runtime"
"strconv"
"time"
"github.com/lucas-clemente/quic-go/h2quic"
"github.com/lucas-clemente/quic-go/protocol"
"github.com/lucas-clemente/quic-go/testdata"
_ "github.com/lucas-clemente/quic-clients" // download clients
. "github.com/onsi/ginkgo"
. "github.com/onsi/gomega"
. "github.com/onsi/gomega/gbytes"
. "github.com/onsi/gomega/gexec"
)
const port = "6729"
const host = "127.0.0.1"
const addr = host + ":" + port
var _ = Describe("Integration tests", func() {
var (
server *h2quic.Server
clientPath string
)
http.HandleFunc("/hello", func(w http.ResponseWriter, r *http.Request) {
io.WriteString(w, "Hello, World!\n")
})
BeforeSuite(func() {
clientPath = fmt.Sprintf(
"%s/src/github.com/lucas-clemente/quic-clients/client-%s-debug",
os.Getenv("GOPATH"),
runtime.GOOS,
)
server = &h2quic.Server{
Server: &http.Server{
Addr: addr,
TLSConfig: testdata.GetTLSConfig(),
},
}
go func() {
defer GinkgoRecover()
server.ListenAndServe()
}()
time.Sleep(10 * time.Millisecond)
})
AfterSuite(func() {
err := server.Close()
Expect(err).NotTo(HaveOccurred())
})
for _, version := range protocol.SupportedVersions {
Context(fmt.Sprintf("with quic version %d", version), func() {
It("downloads a single file", func() {
command := exec.Command(
clientPath,
"--quic-version="+strconv.Itoa(int(version)),
"--host="+host,
"--port="+port,
"https://quic.clemente.io/hello",
)
session, err := Start(command, GinkgoWriter, GinkgoWriter)
Expect(err).NotTo(HaveOccurred())
Eventually(session).Should(Exit(0))
Expect(session.Out).To(Say("Response:\nheaders: HTTP/1.1 200\nstatus: 200\n\nbody: Hello, World!\n"))
})
})
}
})