Allow specifying private end port & public end port for port forward rules

Author: vishesh92

cloudstack/resource_cloudstack_port_forward.go

@@ -73,11 +73,21 @@ func resourceCloudStackPortForward() *schema.Resource {
 							Required: true,
 						},
 
+						"private_end_port": {
+							Type:     schema.TypeInt,
+							Optional: true,
+						},
+
 						"public_port": {
 							Type:     schema.TypeInt,
 							Required: true,
 						},
 
+						"public_end_port": {
+							Type:     schema.TypeInt,
+							Optional: true,
+						},
+
 						"virtual_machine_id": {
 							Type:     schema.TypeString,
 							Required: true,
@@ -175,6 +185,12 @@ func createPortForward(d *schema.ResourceData, meta interface{}, forward map[str
 	// Create a new parameter struct
 	p := cs.Firewall.NewCreatePortForwardingRuleParams(d.Id(), forward["private_port"].(int),
 		forward["protocol"].(string), forward["public_port"].(int), vm.Id)
+	if forward["private_end_port"].(int) != 0 {
+		p.SetPrivateendport(forward["private_end_port"].(int))
+	}
+	if forward["public_end_port"].(int) != 0 {
+		p.SetPublicendport(forward["public_end_port"].(int))
+	}
 
 	if vmGuestIP, ok := forward["vm_guest_ip"]; ok && vmGuestIP.(string) != "" {
 		p.SetVmguestip(vmGuestIP.(string))
@@ -279,15 +295,31 @@ func resourceCloudStackPortForwardRead(d *schema.ResourceData, meta interface{})
 				return err
 			}
 
+			privEndPort, err := strconv.Atoi(f.Privateendport)
+			if err != nil {
+				return err
+			}
+
 			pubPort, err := strconv.Atoi(f.Publicport)
 			if err != nil {
 				return err
 			}
 
+			pubEndPort, err := strconv.Atoi(f.Publicendport)
+			if err != nil {
+				return err
+			}
+
 			// Update the values
 			forward["protocol"] = f.Protocol
 			forward["private_port"] = privPort
 			forward["public_port"] = pubPort
+			if f.Privateendport != "" && f.Privateendport != f.Privateport {
+				forward["private_end_port"] = privEndPort
+			}
+			if f.Publicendport != "" && f.Publicendport != f.Publicport {
+				forward["public_end_port"] = pubEndPort
+			}
 			forward["virtual_machine_id"] = f.Virtualmachineid
 
 			// This one is a bit tricky. We only want to update this optional value