installer: deploys tsuru config to hosts

tsuru/installer/defaultconfig/compose.yml

@@ -43,6 +43,7 @@ services:
     image: tsuru/api:v1
     volumes:
       - "/etc/docker/certs.d:/certs:ro"
+      - "/etc/tsuru/tsuru.conf:/etc/tsuru/tsuru.conf:ro"
     ports:
       - 8080:8080
     networks:

tsuru/installer/defaultconfig/generator/main.go

@@ -20,7 +20,7 @@ func main() {
 		panic(err)
 	}
 	out.Write([]byte("// Code generated by generator/main.go, DO NOT EDIT.\n\n"))
-	out.Write([]byte("package config \n\nconst (\n"))
+	out.Write([]byte("package defaultconfig \n\nconst (\n"))
 	for _, f := range fs {
 		if strings.HasSuffix(f.Name(), ".yml") {
 			out.Write([]byte(strings.Title(strings.TrimSuffix(f.Name(), ".yml")) + " = `"))

tsuru/installer/defaultconfig/tsuru.yml

@@ -0,0 +1,50 @@
+listen: "0.0.0.0:$TSURU_PORT"
+host: $TSURU_ADDR:$TSURU_PORT
+use-tls: false
+tls:
+    cert-file: /certs/cert.pem
+    key-file: /certs/key.pem
+repo-manager: none
+database:
+  url: $MONGODB_ADDR:$MONGODB_PORT
+  name: tsuru
+auth:
+  token-expire-days: 2
+  hash-cost: 4
+  user-registration: true
+provisioner: docker
+docker:
+  bs:
+    socket: /var/run/docker.sock
+  cluster:
+    storage: mongodb
+    mongo-url: $MONGODB_ADDR:$MONGODB_PORT
+    mongo-database: cluster
+  collection: docker
+  registry: $REGISTRY_ADDR:$REGISTRY_PORT
+  repository-namespace: tsuru
+  router: hipache
+  deploy-cmd: /var/lib/tsuru/deploy
+  run-cmd:
+    bin: /var/lib/tsuru/start
+    port: "8888"
+  tls:
+    root-path: /certs
+  auto-scale:
+    enabled: true
+    run-interval: $DOCKER_AUTOSCALE_RUN_INTERVAL
+routers:
+  hipache:
+    type: hipache
+    domain: $HIPACHE_DOMAIN
+    redis-server: $REDIS_ADDR:$REDIS_PORT
+queue:
+  mongo-url: $MONGODB_ADDR:$MONGODB_PORT
+  mongo-database: queuedb
+quota:
+  units-per-app: 4
+  apps-per-user: 2
+log:
+  disable-syslog: true
+  use-stderr: true
+iaas: $IAAS_CONF

tsuru/installer/install_test.go

@@ -16,6 +16,7 @@ import (
 
 	"github.com/docker/machine/drivers/fakedriver"
 	"github.com/docker/machine/libmachine/host"
+	"github.com/tsuru/tsuru-client/tsuru/installer/defaultconfig"
 	"github.com/tsuru/tsuru-client/tsuru/installer/dm"
 	"github.com/tsuru/tsuru/cmd"
 	"github.com/tsuru/tsuru/cmd/cmdtest"
@@ -249,7 +250,7 @@ func (s *S) TestInstallConfigInit(c *check.C) {
 	c.Assert(err, check.IsNil)
 	compose, err := ioutil.ReadFile(filepath.Join(d, "compose.yml"))
 	c.Assert(err, check.IsNil)
-	c.Assert(string(compose), check.DeepEquals, defaultCompose)
+	c.Assert(string(compose), check.DeepEquals, defaultconfig.Compose)
 	opts, err := parseConfigFile(filepath.Join(d, "config.yml"))
 	c.Assert(err, check.IsNil)
 	c.Assert(opts, check.DeepEquals, defaultInstallOpts)

tsuru/installer/installer.go

@@ -18,6 +18,7 @@ import (
 	"github.com/docker/machine/libmachine/provision"
 	"github.com/docker/machine/libmachine/provision/serviceaction"
 	"github.com/fsouza/go-dockerclient"
+	"github.com/tsuru/tsuru-client/tsuru/installer/defaultconfig"
 	"github.com/tsuru/tsuru-client/tsuru/installer/dm"
 	"github.com/tsuru/tsuru/cmd"
 	"github.com/tsuru/tsuru/iaas/dockermachine"
@@ -80,7 +81,7 @@ func (i *Installer) Install(opts *InstallOpts) (*Installation, error) {
 		return nil, fmt.Errorf("pre-install checks failed: %s", errChecks)
 	}
 	setCoreDriverDefaultOpts(opts)
-	coreMachines, err := i.ProvisionMachines(opts.Hosts.Core.Size, opts.Hosts.Core.Driver.Options)
+	coreMachines, err := i.ProvisionMachines(opts.Hosts.Core.Size, opts.Hosts.Core.Driver.Options, deployTsuruConfig)
 	if err != nil {
 		return nil, fmt.Errorf("failed to provision components machines: %s", err)
 	}
@@ -112,6 +113,20 @@ func (i *Installer) Install(opts *InstallOpts) (*Installation, error) {
 	}, nil
 }
 
+func deployTsuruConfig(m *dockermachine.Machine) error {
+	fmt.Println("Deploying tsuru config...")
+	_, err := m.Host.RunSSHCommand("sudo mkdir -p /etc/tsuru/")
+	if err != nil {
+		return fmt.Errorf("failed to create tsuru config directory: %s", err)
+	}
+	remoteWriteCmdFmt := "printf '%%s' '%s' | sudo tee %s"
+	_, err = m.Host.RunSSHCommand(fmt.Sprintf(remoteWriteCmdFmt, string(defaultconfig.Tsuru), "/etc/tsuru/tsuru.conf"))
+	if err != nil {
+		return fmt.Errorf("failed to write remote file: %s", err)
+	}
+	return nil
+}
+
 // HACK: Sometimes docker will simply freeze while pulling the images for each
 // service, adding a restart here seems to unclog the pipes.
 func (i *Installer) restartDocker(coreMachines []*dockermachine.Machine) error {
@@ -249,10 +264,10 @@ func preInstallChecks(config *InstallOpts) error {
 
 func (i *Installer) ProvisionPool(config *InstallOpts, hosts []*dockermachine.Machine) ([]*dockermachine.Machine, error) {
 	if config.Hosts.Apps.Dedicated {
-		return i.ProvisionMachines(config.Hosts.Apps.Size, config.Hosts.Apps.Driver.Options)
+		return i.ProvisionMachines(config.Hosts.Apps.Size, config.Hosts.Apps.Driver.Options, nil)
 	}
 	if config.Hosts.Apps.Size > len(hosts) {
-		poolMachines, err := i.ProvisionMachines(config.Hosts.Apps.Size-len(hosts), config.Hosts.Apps.Driver.Options)
+		poolMachines, err := i.ProvisionMachines(config.Hosts.Apps.Size-len(hosts), config.Hosts.Apps.Driver.Options, nil)
 		if err != nil {
 			return nil, fmt.Errorf("failed to provision pool hosts: %s", err)
 		}
@@ -261,7 +276,7 @@ func (i *Installer) ProvisionPool(config *InstallOpts, hosts []*dockermachine.Ma
 	return hosts[:config.Hosts.Apps.Size], nil
 }
 
-func (i *Installer) ProvisionMachines(numMachines int, configs map[string][]interface{}) ([]*dockermachine.Machine, error) {
+func (i *Installer) ProvisionMachines(numMachines int, configs map[string][]interface{}, initFunc func(*dockermachine.Machine) error) ([]*dockermachine.Machine, error) {
 	var machines []*dockermachine.Machine
 	for j := 0; j < numMachines; j++ {
 		opts := make(map[string]interface{})
@@ -273,6 +288,11 @@ func (i *Installer) ProvisionMachines(numMachines int, configs map[string][]inte
 		if err != nil {
 			return nil, fmt.Errorf("failed to provision machines: %s", err)
 		}
+		if initFunc != nil {
+			if err := initFunc(m); err != nil {
+				return nil, fmt.Errorf("failed to initialize host: %s", err)
+			}
+		}
 		machines = append(machines, m)
 	}
 	return machines, nil