job stream cmdlet

Author: kiranisaac

src/ServiceManagement/Automation/Commands.Automation/Cmdlet/GetAzureAutomationJobOutput.cs

@@ -0,0 +1,53 @@
+// ----------------------------------------------------------------------------------
+//
+// Copyright Microsoft Corporation
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// http://www.apache.org/licenses/LICENSE-2.0
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+// ----------------------------------------------------------------------------------
+
+using System;
+using System.Collections.Generic;
+using System.Management.Automation;
+using System.Security.Permissions;
+using Microsoft.Azure.Commands.Automation.Common;
+using Microsoft.Azure.Commands.Automation.Model;
+
+namespace Microsoft.Azure.Commands.Automation.Cmdlet
+{
+    /// <summary>
+    /// Gets azure automation variables for a given account.
+    /// </summary>
+    [Cmdlet(VerbsCommon.Get, "AzureAutomationJobOutput")]
+    [OutputType(typeof(Variable))]
+    public class GetAzureAutomationJobOutput : AzureAutomationBaseCmdlet
+    {
+        /// <summary>
+        /// Gets or sets the job id
+        /// </summary>
+        [Parameter(Mandatory = true, ValueFromPipelineByPropertyName = true, HelpMessage = "The job id")]
+        public Guid Id { get; set; }
+
+        [Parameter(Mandatory = false, ValueFromPipelineByPropertyName = true, HelpMessage = "The stream type")]
+        public string Stream { get; set; }
+
+        [Parameter(Mandatory = false, ValueFromPipelineByPropertyName = true, HelpMessage = "The start time filter for job output")]
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// Execute this cmdlet.
+        /// </summary>
+        [PermissionSet(SecurityAction.Demand, Name = "FullTrust")]
+        protected override void AutomationExecuteCmdlet()
+        {
+            var ret = this.AutomationClient.GetJobStream(this.AutomationAccountName, this.Id, this.StartTime, this.Stream );
+            this.GenerateCmdletOutput(ret);
+        }
+    }
+}

src/ServiceManagement/Automation/Commands.Automation/Cmdlet/SetAutomationVariable.cs

@@ -24,7 +24,7 @@ namespace Microsoft.Azure.Commands.Automation.Cmdlet
     /// <summary>
     /// Gets azure automation variables for a given account.
     /// </summary>
-    [Cmdlet(VerbsCommon.Get, "AzureAutomationVariable")]
+    [Cmdlet(VerbsCommon.Set, "AzureAutomationVariable")]
     [OutputType(typeof(Variable))]
     public class SetAzureAutomationVariable : AzureAutomationBaseCmdlet
     {

src/ServiceManagement/Automation/Commands.Automation/Commands.Automation.csproj

@@ -100,6 +100,7 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="Cmdlet\AzureAutomationBaseCmdlet.cs" />
+    <Compile Include="Cmdlet\GetAzureAutomationJobOutput.cs" />
     <Compile Include="Cmdlet\GetAzureAutomationVariable.cs" />
     <Compile Include="Cmdlet\GetAzureAutomationRunbook.cs" />
     <Compile Include="Cmdlet\GetAzureAutomationSchedule.cs" />
@@ -113,6 +114,7 @@
     <Compile Include="DataContract\ErrorResponse.cs" />
     <Compile Include="DataContract\OdataError.cs" />
     <Compile Include="DataContract\OdataErrorMessage.cs" />
+    <Compile Include="Model\JobStream.cs" />
     <Compile Include="Model\Runbook.cs" />
     <Compile Include="Model\Schedule.cs" />
     <Compile Include="Model\ScheduleFrequency.cs" />

src/ServiceManagement/Automation/Commands.Automation/Common/AutomationClient.cs

@@ -89,6 +89,25 @@ public Runbook GetRunbook(string automationAccountName, string name)
             return new Runbook(sdkRunbook);
         }
 
+        public IEnumerable<JobStream> GetJobStream(string automationAccountName, Guid jobId, DateTime? time, string streamType)
+        {
+            var listParams = new AutomationManagement.Models.JobStreamListParameters();
+            
+            if (time.HasValue)
+            {
+                listParams.Time = time.Value.ToUniversalTime().ToString();
+            }
+
+            if (streamType != null)
+            {
+                listParams.StreamType = streamType;
+            }
+
+            var jobStreams = this.automationManagementClient.JobStreams.List(automationAccountName, jobId, listParams).JobStreams;
+
+            return jobStreams.Select(this.CreateJobStreamFromJobStreamModel);
+        }
+
         public Variable SetVariable(string automationAccountName, Variable variable)
         {
             bool variableExists = true;
@@ -248,6 +267,12 @@ public IEnumerable<Runbook> ListRunbooks(string automationAccountName)
         #endregion
 
         #region Private Methods
+        private JobStream CreateJobStreamFromJobStreamModel(AutomationManagement.Models.JobStream jobStream)
+        {
+            Requires.Argument("jobStream", jobStream).NotNull();
+            return new JobStream(jobStream);
+        }
+
         private Variable CreateVariableFromVariableModel(AutomationManagement.Models.Variable variable)
         {
             Requires.Argument("variable", variable).NotNull();

src/ServiceManagement/Automation/Commands.Automation/Common/IAutomationClient.cs

@@ -24,6 +24,8 @@ public interface IAutomationClient
     {
         AzureSubscription Subscription { get; }
 
+        IEnumerable<JobStream> GetJobStream(string automationAccountname, Guid jobId, DateTime? time, string streamType);
+
         Variable GetVariable(string automationAccountName, string variableName);
 
         IEnumerable<Variable> ListVariables(string automationAccountName);

src/ServiceManagement/Automation/Commands.Automation/Model/JobStream.cs

@@ -0,0 +1,72 @@
+// ----------------------------------------------------------------------------------
+//
+// Copyright Microsoft Corporation
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+// http://www.apache.org/licenses/LICENSE-2.0
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+// ----------------------------------------------------------------------------------
+
+using System;
+using Microsoft.Azure.Commands.Automation.Common;
+
+namespace Microsoft.Azure.Commands.Automation.Model
+{
+    using AutomationManagement = Management.Automation;
+
+    /// <summary>
+    /// The Job Stream.
+    /// </summary>
+    public class JobStream
+    {
+        /// <summary>
+        /// Initializes a new instance of the <see cref="JobStream"/> class.
+        /// </summary>
+        /// <param name="jobStream">
+        /// The job stream.
+        /// </param>
+        /// <exception cref="System.ArgumentException">
+        /// </exception>
+        public JobStream(AutomationManagement.Models.JobStream jobStream)
+        {
+            Requires.Argument("jobStream", jobStream).NotNull();
+
+            this.StreamId = jobStream.Properties.StreamId;
+            this.StreamType = jobStream.Properties.StreamType;
+            this.Summary = jobStream.Properties.Summary;
+            this.Time = jobStream.Properties.Time.ToLocalTime();
+        }
+
+        /// <summary>
+        /// Initializes a new instance of the <see cref="JobStream"/> class.
+        /// </summary>
+        public JobStream()
+        {
+        }
+
+        /// <summary>
+        /// Gets or sets the stream id
+        /// </summary>
+        public string StreamId { get; set; }
+
+        /// <summary>
+        /// Gets or sets the stream time.
+        /// </summary>
+        public DateTimeOffset Time { get; set; }
+
+        /// <summary>
+        /// Gets or sets the stream summary.
+        /// </summary>
+        public string Summary { get; set; }
+
+        /// <summary>
+        /// Gets or sets the stream Type.
+        /// </summary>
+        public string StreamType { get; set; }
+    }
+}

src/ServiceManagement/Automation/Commands.Automation/Model/Variable.cs

@@ -28,7 +28,7 @@ public class Variable
         /// Initializes a new instance of the <see cref="Variable"/> class.
         /// </summary>
         /// <param name="variable">
-        /// The runbook.
+        /// The varaiable.
         /// </param>
         /// <exception cref="System.ArgumentException">
         /// </exception>
@@ -48,7 +48,7 @@ public Variable(AutomationManagement.Models.Variable variable)
         /// Initializes a new instance of the <see cref="Variable"/> class.
         /// </summary>
         /// <param name="variable">
-        /// The runbook.
+        /// The variable.
         /// </param>
         /// <exception cref="System.ArgumentException">
         /// </exception>

src/ServiceManagement/Automation/Commands.Automation/packages.config

@@ -1,6 +1,5 @@
 <?xml version="1.0" encoding="utf-8"?>
 <packages>
-  <package id="Microsoft.Azure.Management.Automation" version="2.0.0-preview" targetFramework="net45" />
   <package id="Microsoft.Bcl" version="1.1.9" targetFramework="net45" />
   <package id="Microsoft.Bcl.Async" version="1.0.168" targetFramework="net45" />
   <package id="Microsoft.Bcl.Build" version="1.0.14" targetFramework="net45" />