From 1c7b694f81fd49735e78da18c4894e64e65498e6 Mon Sep 17 00:00:00 2001
From: Pierre Lafievre <pierre.lafievre@iguanesolutions.com>
Date: Wed, 23 Aug 2023 12:42:15 +0200
Subject: [PATCH] F #467: configurable service timeout

---
 CHANGELOG.md                              |  3 ++-
 opennebula/resource_opennebula_service.go | 19 +++++++++++++++----
 2 files changed, 17 insertions(+), 5 deletions(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index fdff39928..72bc6a159 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,4 @@
-# 1.3.0 (Unreleased)
+# 1.3.1 (Unreleased)
 
 BUG FIXES:
 
@@ -7,6 +7,7 @@ BUG FIXES:
 ENHANCEMENTS:
 
 * provider: `insecure` attribute now also skips TLS verification for the flow client (#482)
+* opennebula_service: allows timeout to be user configurable (#467)
 
 # 1.3.0 (July 28th, 2023)
 
diff --git a/opennebula/resource_opennebula_service.go b/opennebula/resource_opennebula_service.go
index 65993633a..f0a7a6035 100644
--- a/opennebula/resource_opennebula_service.go
+++ b/opennebula/resource_opennebula_service.go
@@ -16,6 +16,11 @@ import (
 	"github.com/OpenNebula/one/src/oca/go/src/goca/schemas/service"
 )
 
+var (
+	defaultServiceTimeoutMin = 20
+	defaultServiceTimeout    = time.Duration(defaultVMTimeoutMin) * time.Minute
+)
+
 func resourceOpennebulaService() *schema.Resource {
 	return &schema.Resource{
 		CreateContext: resourceOpennebulaServiceCreate,
@@ -23,6 +28,10 @@ func resourceOpennebulaService() *schema.Resource {
 		Exists:        resourceOpennebulaServiceExists,
 		UpdateContext: resourceOpennebulaServiceUpdate,
 		DeleteContext: resourceOpennebulaServiceDelete,
+		Timeouts: &schema.ResourceTimeout{
+			Create: schema.DefaultTimeout(defaultServiceTimeout),
+			Delete: schema.DefaultTimeout(defaultServiceTimeout),
+		},
 		Importer: &schema.ResourceImporter{
 			StateContext: schema.ImportStatePassthroughContext,
 		},
@@ -235,7 +244,8 @@ func resourceOpennebulaServiceCreate(ctx context.Context, d *schema.ResourceData
 		}
 	}
 
-	_, err = waitForServiceState(ctx, d, meta, "running")
+	timeout := d.Timeout(schema.TimeoutCreate)
+	_, err = waitForServiceState(ctx, d, meta, "running", timeout)
 	if err != nil {
 		diags = append(diags, diag.Diagnostic{
 			Severity: diag.Error,
@@ -375,7 +385,8 @@ func resourceOpennebulaServiceDelete(ctx context.Context, d *schema.ResourceData
 
 	}
 
-	_, err = waitForServiceState(ctx, d, meta, "done")
+	timeout := d.Timeout(schema.TimeoutDelete)
+	_, err = waitForServiceState(ctx, d, meta, "done", timeout)
 	if err != nil {
 		diags = append(diags, diag.Diagnostic{
 			Severity: diag.Error,
@@ -648,7 +659,7 @@ func changeServiceName(d *schema.ResourceData, meta interface{}, sc *goca.Servic
 	return nil
 }
 
-func waitForServiceState(ctx context.Context, d *schema.ResourceData, meta interface{}, state string) (interface{}, error) {
+func waitForServiceState(ctx context.Context, d *schema.ResourceData, meta interface{}, state string, timeout time.Duration) (interface{}, error) {
 	var service *service.Service
 	var err error
 
@@ -709,7 +720,7 @@ func waitForServiceState(ctx context.Context, d *schema.ResourceData, meta inter
 				return service, "anythingelse", nil
 			}
 		},
-		Timeout:    3 * time.Minute,
+		Timeout:    timeout,
 		Delay:      10 * time.Second,
 		MinTimeout: 3 * time.Second,
 	}