e1448eb238
Using compose/check package (and less code) Signed-off-by: Vincent Demeester <vincent@sbr.pm>
116 lines
3.1 KiB
Go
116 lines
3.1 KiB
Go
package main
|
|
|
|
import (
|
|
"io/ioutil"
|
|
"net/http"
|
|
"os/exec"
|
|
"time"
|
|
|
|
"github.com/go-check/check"
|
|
"github.com/hashicorp/consul/api"
|
|
|
|
docker "github.com/vdemeester/libkermit/docker/check"
|
|
checker "github.com/vdemeester/shakers"
|
|
)
|
|
|
|
// Consul catalog test suites
|
|
type ConsulCatalogSuite struct {
|
|
BaseSuite
|
|
consulIP string
|
|
consulClient *api.Client
|
|
project *docker.Project
|
|
}
|
|
|
|
func (s *ConsulCatalogSuite) SetUpSuite(c *check.C) {
|
|
s.project = docker.NewProjectFromEnv(c)
|
|
|
|
s.createComposeProject(c, "consul_catalog")
|
|
s.composeProject.Start(c)
|
|
|
|
consul := s.project.Inspect(c, "integration-test-consul_catalog_consul_1")
|
|
|
|
s.consulIP = consul.NetworkSettings.IPAddress
|
|
config := api.DefaultConfig()
|
|
config.Address = s.consulIP + ":8500"
|
|
consulClient, err := api.NewClient(config)
|
|
if err != nil {
|
|
c.Fatalf("Error creating consul client")
|
|
}
|
|
s.consulClient = consulClient
|
|
|
|
// Wait for consul to elect itself leader
|
|
time.Sleep(2000 * time.Millisecond)
|
|
}
|
|
|
|
func (s *ConsulCatalogSuite) registerService(name string, address string, port int) error {
|
|
catalog := s.consulClient.Catalog()
|
|
_, err := catalog.Register(
|
|
&api.CatalogRegistration{
|
|
Node: address,
|
|
Address: address,
|
|
Service: &api.AgentService{
|
|
ID: name,
|
|
Service: name,
|
|
Address: address,
|
|
Port: port,
|
|
},
|
|
},
|
|
&api.WriteOptions{},
|
|
)
|
|
return err
|
|
}
|
|
|
|
func (s *ConsulCatalogSuite) deregisterService(name string, address string) error {
|
|
catalog := s.consulClient.Catalog()
|
|
_, err := catalog.Deregister(
|
|
&api.CatalogDeregistration{
|
|
Node: address,
|
|
Address: address,
|
|
ServiceID: name,
|
|
},
|
|
&api.WriteOptions{},
|
|
)
|
|
return err
|
|
}
|
|
|
|
func (s *ConsulCatalogSuite) TestSimpleConfiguration(c *check.C) {
|
|
cmd := exec.Command(traefikBinary, "--consulCatalog", "--consulCatalog.endpoint="+s.consulIP+":8500", "--configFile=fixtures/consul_catalog/simple.toml")
|
|
err := cmd.Start()
|
|
c.Assert(err, checker.IsNil)
|
|
defer cmd.Process.Kill()
|
|
|
|
time.Sleep(500 * time.Millisecond)
|
|
// TODO validate : run on 80
|
|
resp, err := http.Get("http://127.0.0.1:8000/")
|
|
|
|
// Expected a 404 as we did not configure anything
|
|
c.Assert(err, checker.IsNil)
|
|
c.Assert(resp.StatusCode, checker.Equals, 404)
|
|
}
|
|
|
|
func (s *ConsulCatalogSuite) TestSingleService(c *check.C) {
|
|
cmd := exec.Command(traefikBinary, "--consulCatalog", "--consulCatalog.endpoint="+s.consulIP+":8500", "--consulCatalog.domain=consul.localhost", "--configFile=fixtures/consul_catalog/simple.toml")
|
|
err := cmd.Start()
|
|
c.Assert(err, checker.IsNil)
|
|
defer cmd.Process.Kill()
|
|
|
|
nginx := s.project.Inspect(c, "integration-test-consul_catalog_nginx_1")
|
|
|
|
err = s.registerService("test", nginx.NetworkSettings.IPAddress, 80)
|
|
c.Assert(err, checker.IsNil, check.Commentf("Error registering service"))
|
|
defer s.deregisterService("test", nginx.NetworkSettings.IPAddress)
|
|
|
|
time.Sleep(5000 * time.Millisecond)
|
|
client := &http.Client{}
|
|
req, err := http.NewRequest("GET", "http://127.0.0.1:8000/", nil)
|
|
c.Assert(err, checker.IsNil)
|
|
req.Host = "test.consul.localhost"
|
|
resp, err := client.Do(req)
|
|
|
|
c.Assert(err, checker.IsNil)
|
|
c.Assert(resp.StatusCode, checker.Equals, 200)
|
|
|
|
_, err = ioutil.ReadAll(resp.Body)
|
|
c.Assert(err, checker.IsNil)
|
|
}
|