add support for managing ssh keys

closes #45

scaleway/provider.go

@@ -45,6 +45,7 @@ func Provider() terraform.ResourceProvider {
 
 		ResourcesMap: map[string]*schema.Resource{
 			"scaleway_server":              resourceScalewayServer(),
+			"scaleway_ssh_key":             resourceScalewaySSHKey(),
 			"scaleway_ip":                  resourceScalewayIP(),
 			"scaleway_security_group":      resourceScalewaySecurityGroup(),
 			"scaleway_security_group_rule": resourceScalewaySecurityGroupRule(),

scaleway/resource_ssh_key.go

@@ -0,0 +1,135 @@
+package scaleway
+
+import (
+	"fmt"
+	"strings"
+
+	"github.com/hashicorp/terraform/helper/schema"
+	api "github.com/nicolai86/scaleway-sdk"
+	"golang.org/x/crypto/ssh"
+)
+
+func resourceScalewaySSHKey() *schema.Resource {
+	return &schema.Resource{
+		Create: resourceScalewaySSHKeyCreate,
+		Read:   resourceScalewaySSHKeyRead,
+		Delete: resourceScalewaySSHKeyDelete,
+		Importer: &schema.ResourceImporter{
+			State: schema.ImportStatePassthrough,
+		},
+
+		Schema: map[string]*schema.Schema{
+			"key": {
+				Type:        schema.TypeString,
+				Required:    true,
+				ForceNew:    true,
+				Description: "The ssh key",
+			},
+		},
+	}
+}
+
+func getSSHKeyFingerprint(key []byte) (string, error) {
+	pubkey, _, _, _, err := ssh.ParseAuthorizedKey(key)
+	if err != nil {
+		return "", err
+	}
+	return ssh.FingerprintLegacyMD5(pubkey), nil
+}
+
+func resourceScalewaySSHKeyCreate(d *schema.ResourceData, m interface{}) error {
+	scaleway := m.(*Client).scaleway
+
+	mu.Lock()
+	defer mu.Unlock()
+	fingerprint, err := getSSHKeyFingerprint([]byte(d.Get("key").(string)))
+	if err != nil {
+		return err
+	}
+
+	user, err := scaleway.GetUser()
+	if err != nil {
+		return err
+	}
+
+	keys := []api.KeyDefinition{}
+	exists := false
+	for _, key := range user.SSHPublicKeys {
+		exists = exists || key.Key == d.Get("key").(string)
+		keys = append(keys, api.KeyDefinition{
+			Key: key.Key,
+		})
+	}
+
+	// remote already contains the key, nothing to do
+	if exists {
+		d.SetId(fingerprint)
+		return nil
+	}
+
+	user, err = scaleway.PatchUserSSHKey(user.ID, api.UserPatchSSHKeyDefinition{
+		SSHPublicKeys: append(keys, api.KeyDefinition{
+			Key: d.Get("key").(string),
+		}),
+	})
+
+	if err != nil {
+		return err
+	}
+
+	d.SetId(fingerprint)
+	return nil
+}
+
+func resourceScalewaySSHKeyRead(d *schema.ResourceData, m interface{}) error {
+	scaleway := m.(*Client).scaleway
+
+	user, err := scaleway.GetUser()
+	if err != nil {
+		return err
+	}
+
+	exists := false
+	for _, key := range user.SSHPublicKeys {
+		exists = exists || strings.Contains(key.Fingerprint, d.Id())
+		if exists {
+			d.Set("key", key.Key)
+			break
+		}
+	}
+	if !exists {
+		return fmt.Errorf("ssh key does not exist anymore")
+	}
+
+	return nil
+}
+
+func resourceScalewaySSHKeyDelete(d *schema.ResourceData, m interface{}) error {
+	scaleway := m.(*Client).scaleway
+
+	mu.Lock()
+	defer mu.Unlock()
+
+	user, err := scaleway.GetUser()
+	if err != nil {
+		return err
+	}
+
+	keys := []api.KeyDefinition{}
+	for _, key := range user.SSHPublicKeys {
+		if !strings.Contains(key.Fingerprint, d.Id()) {
+			keys = append(keys, api.KeyDefinition{
+				Key: key.Key,
+			})
+		}
+	}
+	user, err = scaleway.PatchUserSSHKey(user.ID, api.UserPatchSSHKeyDefinition{
+		SSHPublicKeys: keys,
+	})
+
+	if err != nil {
+		return err
+	}
+	d.SetId("")
+	return nil
+}

scaleway/resource_ssh_key_test.go

@@ -0,0 +1,68 @@
+package scaleway
+
+import (
+	"errors"
+	"strings"
+	"testing"
+
+	"github.com/hashicorp/terraform/helper/resource"
+	"github.com/hashicorp/terraform/terraform"
+)
+
+func TestGetSSHKeyFingerprint(t *testing.T) {
+	key := []byte("ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQDYpDmIzRs5c+xs0jmljMbNYVcgV8fRruMCRDA4HKjGN2lqLTZhngGDXsdt/2kTNQQPAq2sR4N8mfX5wMRT/+jNb+8esPyY5WlElni0zmD7oLoPW4lYRES6f7EeAv6NttLfkDO42r15OtMnglcgWk1u4o3lOXuLbhzJT1qdicpDja22X3uR/xUy1AYhKBOoiSlQbkb7NhL0lA1xQNwerdaJJS8tFB+wViVDyP0f1HaIRxViFlTGuTbTuIJNR/7VJ9VBBuTnYXaRkPxz64sUXrtdVK8U0+4KsisyXwmgQKnvZBDj91wxz12OOzFSQ52iFprIj1JbkzuBmNWXUGKYzXJZ nicolai86@test")
+	fingerprint, err := getSSHKeyFingerprint(key)
+
+	if err != nil {
+		t.Errorf("Expected no error, but got %v", err.Error())
+	}
+	if fingerprint != "d1:4c:45:59:a8:ee:e6:41:10:fb:3c:3e:54:98:5b:6f" {
+		t.Errorf("Expected fingerprint of %q, but got %q", "d1:4c:45:59:a8:ee:e6:41:10:fb:3c:3e:54:98:5b:6f", fingerprint)
+	}
+}
+
+func TestAccScalewaySSHKey_Basic(t *testing.T) {
+	resource.Test(t, resource.TestCase{
+		PreCheck:     func() { testAccPreCheck(t) },
+		Providers:    testAccProviders,
+		CheckDestroy: testAccCheckScalewaySSHKeyDestroy,
+		Steps: []resource.TestStep{
+			resource.TestStep{
+				Config: testAccCheckScalewaySSHKeyConfig,
+				Check: resource.ComposeTestCheckFunc(
+					resource.TestCheckResourceAttr(
+						"scaleway_ssh_key.test", "id", "d1:4c:45:59:a8:ee:e6:41:10:fb:3c:3e:54:98:5b:6f"),
+				),
+			},
+		},
+	})
+}
+
+func testAccCheckScalewaySSHKeyDestroy(s *terraform.State) error {
+	client := testAccProvider.Meta().(*Client).scaleway
+
+	for _, rs := range s.RootModule().Resources {
+		if rs.Type != "scaleway" {
+			continue
+		}
+
+		user, err := client.GetUser()
+		if err != nil {
+			return err
+		}
+		for _, key := range user.SSHPublicKeys {
+			if strings.Contains(key.Fingerprint, rs.Primary.ID) {
+				return errors.New("key still exists.")
+			}
+		}
+		return nil
+	}
+
+	return nil
+}
+
+var testAccCheckScalewaySSHKeyConfig = `
+resource "scaleway_ssh_key" "test" {
+	key = "ssh-rsa AAAAB3NzaC1yc2EAAAADAQABAAABAQDYpDmIzRs5c+xs0jmljMbNYVcgV8fRruMCRDA4HKjGN2lqLTZhngGDXsdt/2kTNQQPAq2sR4N8mfX5wMRT/+jNb+8esPyY5WlElni0zmD7oLoPW4lYRES6f7EeAv6NttLfkDO42r15OtMnglcgWk1u4o3lOXuLbhzJT1qdicpDja22X3uR/xUy1AYhKBOoiSlQbkb7NhL0lA1xQNwerdaJJS8tFB+wViVDyP0f1HaIRxViFlTGuTbTuIJNR/7VJ9VBBuTnYXaRkPxz64sUXrtdVK8U0+4KsisyXwmgQKnvZBDj91wxz12OOzFSQ52iFprIj1JbkzuBmNWXUGKYzXJZ test"
+}
+`