From 5cd99ead80dbd8f811074ee08bfa5f2481b73f29 Mon Sep 17 00:00:00 2001
From: TangBin <tangbin@yunionyun.com>
Date: Mon, 29 Oct 2018 19:47:34 +0800
Subject: [PATCH] deploy vm

---
 pkg/util/aws/instance.go | 38 ++++++++++++++++++++++++++++++++++++--
 1 file changed, 36 insertions(+), 2 deletions(-)

diff --git a/pkg/util/aws/instance.go b/pkg/util/aws/instance.go
index 05db83d94d..7bde39d10e 100644
--- a/pkg/util/aws/instance.go
+++ b/pkg/util/aws/instance.go
@@ -346,7 +346,7 @@ func (self *SInstance) RebuildRoot(imageId string, passwd string, publicKey stri
 }
 
 func (self *SInstance) DeployVM(name string, password string, publicKey string, deleteKeypair bool, description string) error {
-	panic("implement me")
+	return self.host.zone.region.DeployVM(self.InstanceId, name, password, publicKey, deleteKeypair, description)
 }
 
 func (self *SInstance) ChangeConfig(instanceId string, ncpu int, vmem int) error {
@@ -651,7 +651,41 @@ func (self *SRegion) DeleteVM(instanceId string) error {
 }
 
 func (self *SRegion) DeployVM(instanceId string, name string, password string, keypairName string, deleteKeypair bool, description string) error {
-	// todo : implement me
+	params := &ec2.CreateTagsInput{}
+	params.SetResources([]*string{&instanceId})
+	tagspec := TagSpec{ResourceType: "instance"}
+
+	if len(keypairName) > 0 {
+		return fmt.Errorf("aws not support reset publickey")
+	}
+
+	if len(password) > 0 {
+		return fmt.Errorf("aws not support set password, use publickey instead")
+	}
+
+	if deleteKeypair {
+		return fmt.Errorf("aws not support delete publickey")
+	}
+
+	if len(name) > 0 {
+		tagspec.SetNameTag(name)
+	}
+
+	if len(description) > 0 {
+		tagspec.SetDescTag(description)
+	}
+
+	ec2Tag, _ := tagspec.GetTagSpecifications()
+	if len(ec2Tag.Tags) > 0 {
+		params.SetTags(ec2Tag.Tags)
+		_, err := self.ec2Client.CreateTags(params)
+		if err != nil {
+			return err
+		}
+	} else {
+		log.Debugf("no changes")
+	}
+
 	return nil
 }