Merge pull request #4 from gaurangisaxena/makadiri/object

Makadiri/object

Author: gaurangisaxena

src/DataShare/DataShare/DataSet/NewAzDataShareDataSet.cs

@@ -348,6 +348,7 @@ public override void ExecuteCmdlet()
                 StringComparison.OrdinalIgnoreCase))
             {
                 storageAccountName = parsedStorageResourceId.GetAccountName();
+
                 if (this.ShouldProcess(this.Name, string.Format(Resources.ResourceCreateMessage, NewAzDataShareDataSet.ResourceType)))
                 {
                     if (this.FileName != null)

src/DataShare/DataShare/Synchronization/StartAzDataShareSynchronization.cs

@@ -98,6 +98,17 @@ public class StartAzDataShareSynchronization : AzureDataShareCmdletBase
         [ValidateNotNullOrEmpty]
         public string ResourceId { get; set; }
 
+        /// <summary>
+        /// Data share subscription object
+        /// </summary>
+        [Parameter(
+            Mandatory = true,
+            ParameterSetName = ParameterSetNames.ObjectParameterSet,
+            ValueFromPipeline = true,
+            HelpMessage = "Azure data share subscription object")]
+        [ValidateNotNullOrEmpty]
+        public PSDataShareSubscription InputObject { get; set; }
+
         [Parameter]
         public SwitchParameter AsJob { get; set; }
 
@@ -123,21 +134,33 @@ private void StartSynchronization()
                     this.ShareSubscriptionName,
                     new Synchronize(this.SynchronizationMode));
                 this.WriteObject(synchronization.ToPsObject());
-            } catch (DataShareErrorException ex)
+            } catch (DataShareErrorException ex) when (ex.Response.StatusCode.Equals(HttpStatusCode.Conflict))
             {
-                if (ex.Response.StatusCode.Equals(HttpStatusCode.Conflict)) {
-                    throw new PSArgumentException($"Synchronization already in progress.");
-                }
+                throw new PSArgumentException($"Synchronization already in progress.");
             }
         }
 
         private void SetParametersIfNeeded()
         {
+            string resourceId = null;
+
             if (this.ParameterSetName.Equals(
                 ParameterSetNames.ResourceIdParameterSet,
                 StringComparison.OrdinalIgnoreCase))
             {
-                var parsedResourceId = new ResourceIdentifier(this.ResourceId);
+                resourceId = this.ResourceId;
+            }
+
+            if (this.ParameterSetName.Equals(
+                ParameterSetNames.ObjectParameterSet,
+                StringComparison.OrdinalIgnoreCase))
+            {
+                resourceId = this.InputObject.Id;
+            }
+
+            if (!string.IsNullOrEmpty(resourceId))
+            {
+                var parsedResourceId = new ResourceIdentifier(resourceId);
                 this.ResourceGroupName = parsedResourceId.ResourceGroupName;
                 this.AccountName = parsedResourceId.GetAccountName();
                 this.ShareSubscriptionName = parsedResourceId.GetShareSubscriptionName();

src/DataShare/DataShare/Synchronization/StopAzDataShareSubscriptionSynchronization.cs

@@ -97,6 +97,17 @@ public class StopAzDataShareSubscriptionSynchronization : AzureDataShareCmdletBa
         [ValidateNotNullOrEmpty]
         public string ResourceId { get; set; }
 
+        /// <summary>
+        /// Data share subscription object
+        /// </summary>
+        [Parameter(
+            Mandatory = true,
+            ParameterSetName = ParameterSetNames.ObjectParameterSet,
+            ValueFromPipeline = true,
+            HelpMessage = "Azure data share subscription object")]
+        [ValidateNotNullOrEmpty]
+        public PSDataShareSubscription InputObject { get; set; }
+
         [Parameter]
         public SwitchParameter AsJob { get; set; }
 
@@ -130,24 +141,33 @@ private void StopSynchronization()
                     shareSubscriptionSynchronization
                 );
                 this.WriteObject(synchronization.ToPsObject());
-            } catch (DataShareErrorException ex)
+            } catch (DataShareErrorException ex) when (ex.Response.StatusCode.Equals(HttpStatusCode.Conflict))
             {
-                if (ex.Response.StatusCode.Equals(HttpStatusCode.Conflict)) {
-                    throw new PSArgumentException($"Synchronization already in progress.");
-                } else
-                {
-                    throw ex;
-                }
+                throw new PSArgumentException($"Synchronization already in progress.");
             }
         }
 
         private void SetParametersIfNeeded()
         {
+            string resourceId = null;
+
             if (this.ParameterSetName.Equals(
                 ParameterSetNames.ResourceIdParameterSet,
                 StringComparison.OrdinalIgnoreCase))
             {
-                var parsedResourceId = new ResourceIdentifier(this.ResourceId);
+                resourceId = this.ResourceId;
+            }
+
+            if (this.ParameterSetName.Equals(
+                ParameterSetNames.ObjectParameterSet,
+                StringComparison.OrdinalIgnoreCase))
+            {
+                resourceId = this.InputObject.Id;
+            }
+
+            if (!string.IsNullOrEmpty(resourceId))
+            {
+                var parsedResourceId = new ResourceIdentifier(resourceId);
                 this.ResourceGroupName = parsedResourceId.ResourceGroupName;
                 this.AccountName = parsedResourceId.GetAccountName();
                 this.ShareSubscriptionName = parsedResourceId.GetShareSubscriptionName();

src/DataShare/DataShare/SynchronizationSettings/GetAzDataShareSynchronizationSetting.cs

@@ -131,13 +131,10 @@ public override void ExecuteCmdlet()
                         shareName: this.ShareName,
                         synchronizationSettingName: this.Name) as ScheduledSynchronizationSetting;
                     this.WriteObject(setting.ToPsObject());
-                } catch (DataShareErrorException exception)
+                } catch (DataShareErrorException exception) when (exception.Response.StatusCode.Equals(HttpStatusCode.NotFound))
                 {
-                    if (exception.Response.StatusCode.Equals(HttpStatusCode.NotFound))
-                    {
-                        throw new PSArgumentException(
-                            $"Synchronization setting \"{this.Name}\" not found");
-                    }
+                    throw new PSArgumentException(
+                        $"Synchronization setting \"{this.Name}\" not found");
                 }
             }
         }

src/DataShare/DataShare/SynchronizationSettings/RemoveAzureDataShareSynchronizationSetting.cs

@@ -95,6 +95,17 @@ public class RemoveAzureDataShareSynchronizationSetting : AzureDataShareCmdletBa
         [ValidateNotNullOrEmpty]
         public string ResourceId { get; set; }
 
+        /// <summary>
+        /// Share synchronization setting object.
+        /// </summary>
+        [Parameter(
+            Mandatory = true,
+            ParameterSetName = ParameterSetNames.ObjectParameterSet,
+            ValueFromPipeline = true,
+            HelpMessage = "The Azure Data Share Synchronization setting.")]
+        [ValidateNotNullOrEmpty]
+        public PSDataShareSynchronizationSetting InputObject { get; set; }
+
         /// <summary>
         /// Indicates whether you want to see deleted object or not
         /// </summary>
@@ -106,14 +117,6 @@ public class RemoveAzureDataShareSynchronizationSetting : AzureDataShareCmdletBa
         [Parameter]
         public SwitchParameter AsJob { get; set; }
 
-        [Parameter(
-            Mandatory = true,
-            ParameterSetName = ParameterSetNames.ObjectParameterSet,
-            ValueFromPipeline = true,
-            HelpMessage = "The Azure Data Share Synchronization setting.")]
-        [ValidateNotNullOrEmpty]
-        public PSDataShareSynchronizationSetting InputObject { get; set; }
-
         public override void ExecuteCmdlet()
         {
             string resourceId = null;