feat(domain): add chore of new resource order domain

Author: jremy42

go.mod

@@ -36,6 +36,8 @@ require (
 	gopkg.in/dnaeon/go-vcr.v3 v3.2.0
 )
 
+replace github.com/scaleway/scaleway-sdk-go => /Users/jonathanremy/Desktop/scaleway-sdk-go
+
 require (
 	github.com/Masterminds/goutils v1.1.1 // indirect
 	github.com/Masterminds/semver/v3 v3.2.0 // indirect

go.sum

@@ -280,8 +280,6 @@ github.com/posener/complete v1.2.3 h1:NP0eAhjcjImqslEwo/1hq7gpajME0fTLTezBKDqfXq
 github.com/posener/complete v1.2.3/go.mod h1:WZIdtGGp+qx0sLrYKtIRAruyNpv6hFCicSgv7Sy7s/s=
 github.com/robfig/cron/v3 v3.0.1 h1:WdRxkvbJztn8LMz/QEvLN5sBU+xKpSqwwUO1Pjr4qDs=
 github.com/robfig/cron/v3 v3.0.1/go.mod h1:eQICP3HwyT7UooqI/z+Ov+PtYAWygg1TEWWzGIFLtro=
-github.com/scaleway/scaleway-sdk-go v1.0.0-beta.30.0.20241129094524-023aa8142bc1 h1:0OKzyRfLH+dWSPOBvwbhNcBTbEiuNkv8mdYGev1+/1g=
-github.com/scaleway/scaleway-sdk-go v1.0.0-beta.30.0.20241129094524-023aa8142bc1/go.mod h1:kAoejOVBg1E/aVAR6IwKWEmbLCEg2IXklzPAkxzAaXA=
 github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3 h1:n661drycOFuPLCN3Uc8sB6B/s6Z4t2xvBgU1htSHuq8=
 github.com/sergi/go-diff v1.3.2-0.20230802210424-5b0b94c5c0d3/go.mod h1:A0bzQcvG0E7Rwjx0REVgAGH58e96+X0MeOfepqsbeW4=
 github.com/shopspring/decimal v1.2.0 h1:abSATXmQEYyShuxI4/vyW3tV1MrKAJzCZ/0zLUXYbsQ=

internal/services/domain/helpers.go

@@ -4,7 +4,6 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"strconv"
 	"strings"
 	"time"
 
@@ -481,6 +480,7 @@ func flattenTldOffers(offers map[string]*domain.TldOffer) []map[string]interface
 
 	return flattenedOffers
 }
+
 func flattenExternalDomainRegistrationStatus(status *domain.DomainRegistrationStatusExternalDomain) map[string]interface{} {
 	if status == nil {
 		return nil
@@ -590,6 +590,118 @@ func waitForTaskCompletion(ctx context.Context, registrarAPI *domain.RegistrarAP
 		return retry.NonRetryableError(fmt.Errorf("unexpected task status: %v", status))
 	})
 }
+func waitForUpdateDomainTaskCompletion(ctx context.Context, registrarAPI *domain.RegistrarAPI, domainName string, duration int) ([]*domain.Task, error) {
+	timeout := time.Duration(duration) * time.Second
+	var completedTasks []*domain.Task
+
+	err := retry.RetryContext(ctx, timeout, func() *retry.RetryError {
+		tasks, err := registrarAPI.ListTasks(&domain.RegistrarAPIListTasksRequest{
+			Domain: &domainName,
+		}, scw.WithContext(ctx), scw.WithAllPages())
+		if err != nil {
+			return retry.NonRetryableError(fmt.Errorf("failed to list tasks: %w", err))
+		}
+
+		allSuccess := true
+		completedTasks = tasks.Tasks
+		for _, task := range tasks.Tasks {
+			if task.Type == domain.TaskTypeUpdateDomain {
+				if task.Status != domain.TaskStatusSuccess {
+					allSuccess = false
+					if task.Status == domain.TaskStatusPending {
+						return retry.RetryableError(errors.New("update_domain task is still pending, retrying"))
+					}
+				}
+			}
+		}
+
+		if allSuccess {
+			return nil
+		}
+
+		return retry.RetryableError(errors.New("not all update_domain tasks are successful, retrying"))
+	})
+
+	if err != nil {
+		return nil, err
+	}
+
+	return completedTasks, nil
+}
+
+func ExpandDSRecord(dsRecordList []interface{}) *domain.DSRecord {
+	if len(dsRecordList) == 0 || dsRecordList[0] == nil {
+		return nil
+	}
+
+	dsRecordMap := dsRecordList[0].(map[string]interface{})
+	dsRecord := &domain.DSRecord{
+		KeyID:     uint32(dsRecordMap["key_id"].(int)),
+		Algorithm: domain.DSRecordAlgorithm(dsRecordMap["algorithm"].(string)),
+	}
+
+	if digestList, ok := dsRecordMap["digest"].([]interface{}); ok && len(digestList) > 0 {
+		digestMap := digestList[0].(map[string]interface{})
+		dsRecord.Digest = &domain.DSRecordDigest{
+			Type:   domain.DSRecordDigestType(digestMap["type"].(string)),
+			Digest: digestMap["digest"].(string),
+		}
+
+		if publicKeyList, ok := digestMap["public_key"].([]interface{}); ok && len(publicKeyList) > 0 {
+			publicKeyMap := publicKeyList[0].(map[string]interface{})
+			dsRecord.Digest.PublicKey = &domain.DSRecordPublicKey{
+				Key: publicKeyMap["key"].(string),
+			}
+		}
+	}
+
+	if publicKeyList, ok := dsRecordMap["public_key"].([]interface{}); ok && len(publicKeyList) > 0 {
+		publicKeyMap := publicKeyList[0].(map[string]interface{})
+		dsRecord.PublicKey = &domain.DSRecordPublicKey{
+			Key: publicKeyMap["key"].(string),
+		}
+	}
+
+	return dsRecord
+}
+
+func FlattenDSRecord(dsRecord *domain.DSRecord) []map[string]interface{} {
+	if dsRecord == nil {
+		return nil
+	}
+
+	result := map[string]interface{}{
+		"key_id":    dsRecord.KeyID,
+		"algorithm": string(dsRecord.Algorithm),
+	}
+
+	if dsRecord.Digest != nil {
+		digest := map[string]interface{}{
+			"type":   string(dsRecord.Digest.Type),
+			"digest": dsRecord.Digest.Digest,
+		}
+
+		if dsRecord.Digest.PublicKey != nil {
+			digest["public_key"] = []map[string]interface{}{
+				{
+					"key": dsRecord.Digest.PublicKey.Key,
+				},
+			}
+		}
+
+		result["digest"] = []map[string]interface{}{digest}
+	}
+
+	if dsRecord.PublicKey != nil {
+		result["public_key"] = []map[string]interface{}{
+			{
+				"key": dsRecord.PublicKey.Key,
+			},
+		}
+	}
+
+	return []map[string]interface{}{result}
+}
 
 func ExpandDSRecord(dsRecordList []interface{}) *domain.DSRecord {
 	if len(dsRecordList) == 0 || dsRecordList[0] == nil {