Check Name Availability/Validation for SQL Resources

controllers/sqlserver_controller.go

@@ -53,7 +53,6 @@ type SqlServerReconciler struct {
 func (r *SqlServerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
 	ctx := context.Background()
 	log := r.Log.WithValues("sqlserver", req.NamespacedName)
-
 	var instance azurev1.SqlServer
 
 	if err := r.Get(ctx, req.NamespacedName, &instance); err != nil {
@@ -64,6 +63,17 @@ func (r *SqlServerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
 		return ctrl.Result{}, client.IgnoreNotFound(err)
 	}
 
+	location := instance.Spec.Location
+	name := instance.ObjectMeta.Name
+	groupName := instance.Spec.ResourceGroup
+
+	sdkClient := sql.GoSDKClient{
+		Ctx:               ctx,
+		ResourceGroupName: groupName,
+		ServerName:        name,
+		Location:          location,
+	}
+
 	if helpers.IsBeingDeleted(&instance) {
 		if helpers.HasFinalizer(&instance, SQLServerFinalizerName) {
 			if err := r.deleteExternal(&instance); err != nil {
@@ -96,6 +106,18 @@ func (r *SqlServerReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
 		}
 	}
 
+	availableResp, err := sdkClient.CheckNameAvailability()
+	if err != nil {
+		log.Info("error validating name")
+		return ctrl.Result{}, err
+	}
+	log.Info(availableResp.Message)
+	if strings.Contains(availableResp.Message, "unsupported characters") {
+		log.Info("Servername is invalid")
+		r.Recorder.Event(&instance, "Warning", "Failed", "Servername is invalid")
+		return ctrl.Result{Requeue: false}, fmt.Errorf("Servername invalid %s", availableResp.Name)
+	}
+
 	if !instance.IsSubmitted() {
 		r.Recorder.Event(&instance, "Normal", "Submitting", "starting resource reconciliation")
 		if err := r.reconcileExternal(&instance); err != nil {

pkg/resourcemanager/sqlclient/resourceclient.go

@@ -20,4 +20,5 @@ type ResourceClient interface {
 	DeleteSQLFirewallRule(ruleName string) (err error)
 	GetServer() (result sql.Server, err error)
 	IsAsyncNotCompleted(err error) (result bool)
+	CheckNameAvailability() (result AvailabilityResponse, err error)
 }

pkg/resourcemanager/sqlclient/sqlclient_godsk.go

@@ -243,3 +243,22 @@ func (sdk GoSDKClient) GetServer() (result sql.Server, err error) {
 		sdk.ServerName,
 	)
 }
+
+// CheckNameAvailability determines whether a SQL resource can be created with the specified name
+func (sdk GoSDKClient) CheckNameAvailability() (result AvailabilityResponse, err error) {
+	serversClient := getGoServersClient()
+	typeOfService := "Microsoft.Sql/servers"
+
+	response, err := serversClient.CheckNameAvailability(
+		sdk.Ctx,
+		sql.CheckNameAvailabilityRequest{
+			Name: to.StringPtr(sdk.ServerName),
+			Type: to.StringPtr(typeOfService),
+		},
+	)
+	if err != nil {
+		return result, err
+	}
+
+	return ToAvailabilityResponse(response), err
+}

pkg/resourcemanager/sqlclient/sqlproperties.go

@@ -136,3 +136,23 @@ func translateDBEdition(in DBEdition) (result sql.DatabaseEdition) {
 
 	return result
 }
+
+// AvailabilityResponse is the response for checking name validation
+type AvailabilityResponse struct {
+	Available 	bool
+	Message   	string
+	Name      	string
+}
+
+// ToAvailabilityResponse converts CheckNameAvailabilityResponse to AvailabilityResponse
+func ToAvailabilityResponse(response sql.CheckNameAvailabilityResponse) (result AvailabilityResponse) {
+	result.Available = *response.Available
+	if response.Message != nil {
+		result.Message = *response.Message
+	}
+	if response.Name != nil {
+		result.Name = *response.Name
+	}
+
+	return result
+}