storage_mover_multi_cloud_connector_endpoint: ResourceWithIdentity, guide error msg, Create/Read identity

Made-with: Cursor

Author: hqhqhqhqhqhqhqhqhqhqhq

internal/services/storagemover/storage_mover_multi_cloud_connector_endpoint_resource.go

@@ -11,6 +11,7 @@ import (
 
 	"github.com/hashicorp/go-azure-helpers/lang/pointer"
 	"github.com/hashicorp/go-azure-helpers/lang/response"
+	"github.com/hashicorp/go-azure-helpers/resourcemanager/resourceids"
 	"github.com/hashicorp/go-azure-sdk/resource-manager/storagemover/2025-07-01/endpoints"
 	"github.com/hashicorp/go-azure-sdk/resource-manager/storagemover/2025-07-01/storagemovers"
 	"github.com/hashicorp/terraform-provider-azurerm/helpers/azure"
@@ -29,7 +30,10 @@ type StorageMoverMultiCloudConnectorEndpointModel struct {
 
 type StorageMoverMultiCloudConnectorEndpointResource struct{}
 
-var _ sdk.ResourceWithUpdate = StorageMoverMultiCloudConnectorEndpointResource{}
+var (
+	_ sdk.ResourceWithUpdate   = StorageMoverMultiCloudConnectorEndpointResource{}
+	_ sdk.ResourceWithIdentity = StorageMoverMultiCloudConnectorEndpointResource{}
+)
 
 func (r StorageMoverMultiCloudConnectorEndpointResource) ResourceType() string {
 	return "azurerm_storage_mover_multi_cloud_connector_endpoint"
@@ -43,6 +47,10 @@ func (r StorageMoverMultiCloudConnectorEndpointResource) IDValidationFunc() plug
 	return endpoints.ValidateEndpointID
 }
 
+func (r StorageMoverMultiCloudConnectorEndpointResource) Identity() resourceids.ResourceId {
+	return &endpoints.EndpointId{}
+}
+
 func (r StorageMoverMultiCloudConnectorEndpointResource) Arguments() map[string]*pluginsdk.Schema {
 	return map[string]*pluginsdk.Schema{
 		"name": {
@@ -106,7 +114,7 @@ func (r StorageMoverMultiCloudConnectorEndpointResource) Create() sdk.ResourceFu
 			id := endpoints.NewEndpointID(storageMoverId.SubscriptionId, storageMoverId.ResourceGroupName, storageMoverId.StorageMoverName, model.Name)
 			existing, err := client.Get(ctx, id)
 			if err != nil && !response.WasNotFound(existing.HttpResponse) {
-				return fmt.Errorf("checking for existing %s: %+v", id, err)
+				return fmt.Errorf("checking for presence of existing %s: %+v", id, err)
 			}
 
 			if !response.WasNotFound(existing.HttpResponse) {
@@ -131,7 +139,10 @@ func (r StorageMoverMultiCloudConnectorEndpointResource) Create() sdk.ResourceFu
 			}
 
 			metadata.SetID(id)
-			return nil
+			if err := pluginsdk.SetResourceIdentityData(metadata.ResourceData, &id); err != nil {
+				return err
+			}
+			return metadata.Encode(&model)
 		},
 	}
 }
@@ -211,6 +222,9 @@ func (r StorageMoverMultiCloudConnectorEndpointResource) Read() sdk.ResourceFunc
 				}
 			}
 
+			if err := pluginsdk.SetResourceIdentityData(metadata.ResourceData, id); err != nil {
+				return err
+			}
 			return metadata.Encode(&state)
 		},
 	}