Add server creation

This patch adds the ability to create a server with
the given settings.

Author: nfk

online/client.go

@@ -26,6 +26,7 @@ const (
 type Client interface {
 	Server(id int) (*Server, error)
 	SetServer(s *Server) error
+	CreateServer(id int, s *ServerInstall) error
 
 	BootRescueMode(serverID int, image string) (*RescueCredentials, error)
 	BootNormalMode(serverID int) error
@@ -165,6 +166,20 @@ func (c *client) Server(id int) (*Server, error) {
 	return s, json.Unmarshal(js, s)
 }
 
+func (c *client) CreateServer(id int, s *ServerInstall) error {
+	target := fmt.Sprintf("%s/install/%d", serverEndPoint, id)
+	var req map[string]string
+	inreq, _ := json.Marshal(s)
+	json.Unmarshal(inreq, &req)
+
+	_, err := c.doPOST(target, req)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
 func (c *client) ListRPNv2() ([]*RPNv2, error) {
 	js, err := c.doGET(rpnv2EndPoint)
 	if err != nil {

online/mock/mock.go

@@ -24,6 +24,12 @@ func (o *OnlineClientMock) SetServer(s *online.Server) error {
 	return args.Error(0)
 }
 
+// CreateServer is a mock call
+func (o *OnlineClientMock) CreateServer(id int, s *online.ServerInstall) error {
+	args := o.Called(id, s)
+	return args.Error(0)
+}
+
 // GetRescueImages is a mock call
 func (o *OnlineClientMock) GetRescueImages(serverID int) ([]string, error) {
 	args := o.Called(serverID)

online/server.go

@@ -7,6 +7,7 @@ type Server struct {
 	OS                  interface{} `json:"os"`
 	Power               string      `json:"power"`
 	BootMode            string      `json:"boot_mode"`
+	InstallStatus       string      `json:"install_status"`
 	LastReboot          string      `json:"last_reboot"`
 	AntiDDOS            bool        `json:"anti_ddos"`
 	HardwareWatch       bool        `json:"hardware_watch"`
@@ -44,6 +45,15 @@ type Server struct {
 	} `json:"bmc"`
 }
 
+type ServerInstall struct {
+	Hostname                string `json:"hostname"`
+	OS_ID                   string `json:"os_id"`
+	UserLogin               string `json:"user_login"`
+	UserPassword            string `json:"user_password"`
+	RootPassword            string `json:"root_password"`
+	PartitioningTemplateRef string `json:"partitioning_template_ref"`
+}
+
 type OS struct {
 	Name    string `json:"name"`
 	Version string `json:"version"`

provider/resource_server.go

@@ -3,7 +3,9 @@ package provider
 import (
 	"strconv"
 	"strings"
+	"time"
 
+	"github.com/hashicorp/terraform/helper/resource"
 	"github.com/hashicorp/terraform/helper/schema"
 	"github.com/src-d/terraform-provider-online/online"
 )
@@ -40,6 +42,41 @@ func resourceServer() *schema.Resource {
 				Elem:        resourceInterface(),
 				Description: "Private interface properties",
 			},
+			"os_id": &schema.Schema{
+				Type:     schema.TypeString,
+				Required: true,
+				ForceNew: true,
+				Description: "OS id, use the following command to select one " +
+					"`curl -s -H \"Authorization: Bearer $ONLINE_TOKEN\"  " +
+					"https://api.online.net/api/v1/server/operatingSystems/{server id}`",
+			},
+			"user_login": &schema.Schema{
+				Type:        schema.TypeString,
+				Required:    true,
+				Description: "User login",
+			},
+			"user_password": &schema.Schema{
+				Type:        schema.TypeString,
+				Required:    true,
+				Description: "User password",
+			},
+			"root_password": &schema.Schema{
+				Type:        schema.TypeString,
+				Required:    true,
+				Description: "Root password",
+			},
+			"partitioning_template_ref": &schema.Schema{
+				Type:     schema.TypeString,
+				Required: true,
+				ForceNew: true,
+				Description: "UUID of the partitioning template created from " +
+					"https://console.online.net/fr/template/partition",
+			},
+			"status": &schema.Schema{
+				Type:        schema.TypeString,
+				Computed:    true,
+				Description: "Install status",
+			},
 		},
 	}
 }
@@ -71,9 +108,48 @@ func resourceServerDelete(d *schema.ResourceData, meta interface{}) error {
 }
 
 func resourceServerCreate(d *schema.ResourceData, meta interface{}) error {
+	c := meta.(online.Client)
+	s := &online.ServerInstall{
+		Hostname:                d.Get("hostname").(string),
+		OS_ID:                   d.Get("os_id").(string),
+		UserLogin:               d.Get("user_login").(string),
+		UserPassword:            d.Get("user_password").(string),
+		RootPassword:            d.Get("root_password").(string),
+		PartitioningTemplateRef: d.Get("partitioning_template_ref").(string),
+	}
+	id := d.Get("server_id").(int)
+
+	if err := c.CreateServer(id, s); err != nil {
+		return err
+	}
+
+	stateConf := &resource.StateChangeConf{
+		Pending:    []string{"installing"},
+		Target:     []string{"installed"},
+		Refresh:    waitForServerInstall(c, id),
+		Timeout:    60 * time.Minute,
+		Delay:      1 * time.Second,
+		MinTimeout: 10 * time.Second,
+	}
+
+	_, err := stateConf.WaitForState()
+	if err != nil {
+		return err
+	}
+
 	return resourceServerRead(d, meta)
 }
 
+func waitForServerInstall(c online.Client, id int) resource.StateRefreshFunc {
+	return func() (interface{}, string, error) {
+		s, err := c.Server(id)
+		if err != nil {
+			return s, "", err
+		}
+		return s, s.InstallStatus, nil
+	}
+}
+
 func resourceServerUpdate(d *schema.ResourceData, meta interface{}) error {
 	c := meta.(online.Client)
 	s := &online.Server{
@@ -106,6 +182,7 @@ func resourceServerRead(d *schema.ResourceData, meta interface{}) error {
 	d.SetId(strconv.Itoa(id))
 	d.Set("hostname", s.Hostname)
 	setIP(s, d)
+	d.Set("status", s.InstallStatus)
 
 	return nil
 }

provider/resource_server_test.go

@@ -14,7 +14,8 @@ func setupMock() {
 		Hostname: "mock",
 	}).Return(nil)
 	onlineClientMock.On("Server", 123).Return(&online.Server{
-		Hostname: "mock",
+		Hostname:      "mock",
+		InstallStatus: "installed",
 		IP: []*online.Interface{
 			&online.Interface{
 				Address: "1.2.3.4",
@@ -29,6 +30,14 @@ func setupMock() {
 			},
 		},
 	}, nil)
+	onlineClientMock.On("CreateServer", 123, &online.ServerInstall{
+		Hostname:                "mock",
+		OS_ID:                   "101",
+		UserLogin:               "user1",
+		UserPassword:            "pass1",
+		RootPassword:            "rootpass",
+		PartitioningTemplateRef: "81c651de-030b-41f3-8094-36f423375234",
+	}).Return(nil)
 }
 
 func TestResourceServerUnit(t *testing.T) {
@@ -42,6 +51,11 @@ func TestResourceServerUnit(t *testing.T) {
 				resource "online_server" "test" {
 					server_id = 123
 					hostname = "mock"
+					os_id = "101"
+					user_login = "user1"
+					user_password = "pass1"
+					root_password = "rootpass"
+					partitioning_template_ref = "81c651de-030b-41f3-8094-36f423375234"
 				}
 			`,
 			Check: resource.ComposeAggregateTestCheckFunc(
@@ -52,6 +66,7 @@ func TestResourceServerUnit(t *testing.T) {
 				resource.TestCheckResourceAttr("online_server.test", "public_interface.dns", "my.dns.address"),
 				resource.TestCheckResourceAttr("online_server.test", "private_interface.address", "10.2.3.4"),
 				resource.TestCheckResourceAttr("online_server.test", "private_interface.mac", "00:bb:cc:dd:ee:ff"),
+				resource.TestCheckResourceAttr("online_server.test", "status", "installed"),
 			),
 		}},
 	})