server_test.go

package main

import (
	"crypto/tls"
	"fmt"
	"io/ioutil"
	"log"
	"net"
	"reflect"
	"testing"
)

var snakeoilCert = `-----BEGIN CERTIFICATE-----
MIICGTCCAYICCQCww5WxTI3a5jANBgkqhkiG9w0BAQUFADBFMQswCQYDVQQGEwJB
VTETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8GA1UECgwYSW50ZXJuZXQgV2lkZ2l0
cyBQdHkgTHRkMB4XDTEzMTIxOTExMDMzNloXDTQxMDUwNjExMDMzNlowXTELMAkG
A1UEBhMCVVMxEzARBgNVBAgMCkNhbGlmb3JuaWExITAfBgNVBAoMGEludGVybmV0
IFdpZGdpdHMgUHR5IEx0ZDEWMBQGA1UEAwwNKi5leGFtcGxlLmNvbTCBnzANBgkq
hkiG9w0BAQEFAAOBjQAwgYkCgYEArmBi147MNv5v+97eznwD2OTyCOToKV/IIOBM
qrSNu3iKASb817CoiPV9x9NmxdoLeVvVWHgGC9cBDo+j5fTPEdxQCE4Xm6KOUy0S
4/rJzxNniWFWusVgT4VbwWeNdEg22PM8uGKM9nrQ42UXdNsrXRWQdAxR966ZBCoG
xcwx4ZcCAwEAATANBgkqhkiG9w0BAQUFAAOBgQBd4bS8qYe7vld2rgIOsNM5sqBk
mMcVCZPqUDX9axYQGGHkxF1qXv2ohnNvdmlVQtreuKF82HNL0P5uuU5jIms8fXPv
20TxAD7CbdR4dFn38mRHovprt9No3vtL8PmxhDOs7EOKtNyXplbVtmjf1N27UbQ3
K+MApaOowXqkoBSx9Q==
-----END CERTIFICATE-----`

var snakeoilKey = `-----BEGIN RSA PRIVATE KEY-----
MIICXAIBAAKBgQCuYGLXjsw2/m/73t7OfAPY5PII5OgpX8gg4EyqtI27eIoBJvzX
sKiI9X3H02bF2gt5W9VYeAYL1wEOj6Pl9M8R3FAITheboo5TLRLj+snPE2eJYVa6
xWBPhVvBZ410SDbY8zy4Yoz2etDjZRd02ytdFZB0DFH3rpkEKgbFzDHhlwIDAQAB
AoGAWw7sLqJcE8+0TLOqZ+ss2yNbHLfkYE6rJDfc8TuN07rzXfytBjkzGSoQ/7tu
LJ1bZolFFIjAp4gj/iWWMewwAMfkoG3nT25z3Q8v+EPwO97kT5rgMW/sI9yamRhb
LQpENsaxF1UFW4ADxl32go2sPbYv/5hnMLB7bfR0vgZaFHkCQQDaAUgmKogKj0qb
BeuIftzLJWJ+uYYtUGpICF53LAbd/lUygnUx4fapcVQDTyHcpb1lRRRXuGfZn1x2
jn9KRC87AkEAzMSIpdZXXCigvEMWYi0laNV/AJjKKafBcq/l8VQcAq0FUhgeRCoB
FjSVJrngMwzu1cQC1Xwtp6Dh6+V4T51pVQJBALPQatpQKnXLSxYjA+tJ+IP3Cg7M
p8eolIFlpcVWIzPoHA3VXSUP5IxOVaWFF8EPU/C70dOo3r+5mmKPlp6DLxECQAxM
QWi0VsrSJdUosk9zJqwFJnuCsaGO0a9xoP29b3E5svgbOrYdT7NltQ9+Wli2jiGI
hCMOMi+/GdJxFaiya4ECQCabLUAE0YEZL0M4mrcALa4T0C2sKCW8Xo2wvbwDGc1Y
+GQErfiGNv0xDOWLYrqe40x71R8z4kZv4EKLH/7zjTE=
-----END RSA PRIVATE KEY-----`

func loadSnakeoilConfig(crtPath, keyPath string) (*tls.Config, error) {
	cert, err := tls.X509KeyPair([]byte(snakeoilCert), []byte(snakeoilKey))
	if err != nil {
		return nil, err
	}

	return &tls.Config{Certificates: []tls.Certificate{cert}}, nil
}

func backendOrFail(t *testing.T) (net.Listener, string) {
	cfg, err := loadSnakeoilConfig("", "")
	if err != nil {
		t.Fatalf("Failed to make snakeoil certificate: %v", err)
	}

	l, err := tls.Listen("tcp", "127.0.0.1:0", cfg)
	if err != nil {
		t.Fatalf("Failed to listen: %v", err)
	}

	return l, fmt.Sprintf("127.0.0.1:%d", l.Addr().(*net.TCPAddr).Port)
}

func mkServer(t *testing.T, cfgString string) *Server {
	config, err := parseConfig([]byte(cfgString), loadSnakeoilConfig)
	if err != nil {
		t.Fatalf("Failed to parse config: %v", err)
	}

	return &Server{
		Configuration: config,
		Logger:        log.New(ioutil.Discard, "", 0),
		ready:         make(chan int),
	}
}

func TestSimple(t *testing.T) {
	l, addr := backendOrFail(t)
	s := mkServer(t, fmt.Sprintf(`
bind_addr: "127.0.0.1:55111"
frontends:
  test.example.com:
    backends:
      -
        addr: %s
`, addr))

	go s.Run()
	// wait for the listener to bind
	<-s.ready
	defer s.mux.Close()

	expected := []byte("Hello World")
	go func() {

		out, err := tls.Dial("tcp", "127.0.0.1:55111", &tls.Config{ServerName: "test.example.com", InsecureSkipVerify: true})
		if err != nil {
			t.Fatalf("Failed to dial: %v", err)
		}
		out.Write(expected)
		out.Close()
	}()

	in, err := l.Accept()
	if err != nil {
		t.Fatalf("Failed to accept new connection: %v", err)
	}

	got, err := ioutil.ReadAll(in)
	if err != nil {
		t.Fatalf("Error reading data from connection: %v", err)
	}

	if !reflect.DeepEqual(got, expected) {
		t.Errorf("Wrong data read from connection. Got %v, expected %v", got, expected)
	}
}

func TestMany(t *testing.T) {
	l1, addr1 := backendOrFail(t)
	l2, addr2 := backendOrFail(t)

	s := mkServer(t, fmt.Sprintf(`
bind_addr: "127.0.0.1:55111"
frontends:
  test1.example.com:
    backends:
      -
        addr: %s

  test2.example.com:
    backends:
      -
        addr: %s
`, addr1, addr2))

	go s.Run()
	// wait for the listener to bind
	<-s.ready
	defer s.mux.Close()

	sendData := func(payload, name string) {
		out, err := tls.Dial("tcp", "127.0.0.1:55111", &tls.Config{ServerName: name, InsecureSkipVerify: true})
		if err != nil {
			t.Fatalf("Failed to dial: %v", err)
		}

		out.Write([]byte(payload))
		out.Close()
	}

	check := func(l net.Listener, expected string) {
		in, err := l.Accept()
		if err != nil {
			t.Errorf("Failed to accept new connection: %v", err)
			return
		}

		got, err := ioutil.ReadAll(in)
		if err != nil {
			t.Errorf("Error reading data from connection: %v", err)
			return
		}

		if !reflect.DeepEqual(got, []byte(expected)) {
			t.Errorf("Wrong data read from connection. Got %v, expected %v", got, []byte(expected))
		}
	}

	go sendData("Hello 1", "test1.example.com")
	check(l1, "Hello 1")

	go sendData("Hello 2", "test2.example.com")
	check(l2, "Hello 2")
}

func TestHostNotFound(t *testing.T) {
	_, addr := backendOrFail(t)

	s := mkServer(t, fmt.Sprintf(`
bind_addr: "127.0.0.1:55111"
frontends:
  test.example.com:
    backends:
      -
        addr: %s
`, addr))

	go s.Run()
	<-s.ready
	defer s.mux.Close()

	_, err := tls.Dial("tcp", "127.0.0.1:55111", &tls.Config{ServerName: "foo.example.com", InsecureSkipVerify: true})
	if err == nil {
		t.Fatalf("Expected error when dialing wrong name, got nil")
	}
}

func TestRoundRobin(t *testing.T) {
	l1, addr1 := backendOrFail(t)
	l2, addr2 := backendOrFail(t)

	s := mkServer(t, fmt.Sprintf(`
bind_addr: "127.0.0.1:55111"
frontends:
  test.example.com:
    backends:
      -
        addr: %s
      -
        addr: %s
`, addr1, addr2))

	go s.Run()
	// wait for the listener to bind
	<-s.ready
	defer s.mux.Close()

	payload := "Hello world!"
	go func() {
		for i := 0; i < 20; i++ {
			out, err := tls.Dial("tcp", "127.0.0.1:55111", &tls.Config{ServerName: "test.example.com", InsecureSkipVerify: true})
			if err != nil {
				t.Fatalf("Failed to dial: %v", err)
			}

			out.Write([]byte(payload))
			out.Close()
		}
	}()

	var count1, count2 int

	var l net.Listener = l1
	for i := 0; i < 20; i++ {
		// conections should switch off between backends
		if l == l1 {
			l = l2
		} else {
			l = l1
		}

		in, err := l.Accept()
		if err != nil {
			t.Errorf("Failed to accept new connection: %v", err)
			return
		}

		got, err := ioutil.ReadAll(in)
		if err != nil {
			t.Errorf("Error reading data from connection: %v", err)
			return
		}

		if !reflect.DeepEqual(got, []byte(payload)) {
			t.Errorf("Wrong data read from connection. Got %v, expected %v", got, []byte(payload))
			return
		}

		if l == l1 {
			count1 += 1
		} else {
			count2 += 1
		}
	}

	if count1 != 10 || count2 != 10 {
		t.Fatalf("Expected 10 connections to each backend, got: %v %v", count1, count2)
	}
}

// Check that we un
func TestTerminateTLS(t *testing.T) {
	l, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		t.Fatalf("Failed to listen: %v", err)
	}

	addr := fmt.Sprintf("127.0.0.1:%d", l.Addr().(*net.TCPAddr).Port)

	s := mkServer(t, fmt.Sprintf(`
bind_addr: "127.0.0.1:55111"
frontends:
  test.example.com:
    tls_crt: /snakeoil.crt
    tls_key: /snakeoil.key
    backends:
      -
        addr: %s
`, addr))

	go s.Run()
	// wait for the listener to bind
	<-s.ready
	defer s.mux.Close()

	expected := []byte("Hello World")
	go func() {
		out, err := tls.Dial("tcp", "127.0.0.1:55111", &tls.Config{ServerName: "test.example.com", InsecureSkipVerify: true})
		if err != nil {
			t.Fatalf("Failed to dial: %v", err)
		}
		out.Write(expected)
		out.Close()
	}()

	in, err := l.Accept()
	if err != nil {
		t.Fatalf("Failed to accept new connection: %v", err)
	}

	got, err := ioutil.ReadAll(in)
	if err != nil {
		t.Fatalf("Error reading data from connection: %v", err)
	}

	if !reflect.DeepEqual(got, expected) {
		t.Errorf("Wrong data read from connection. Got %v, expected %v", got, expected)
	}
}