XpandPosh

1.1.4

Cmdlets/src/XpandPosh.Cmdlets/GetGitHubMilestone/Get-GitHubMilestone.cs

                                using System.Linq;

using System.Management.Automation;

using System.Reactive.Linq;

using System.Reactive.Threading.Tasks;

using System.Threading.Tasks;

using Octokit;

using XpandPosh.CmdLets;

namespace XpandPosh.Cmdlets.GetGitHubMilestone{

    [CmdletBinding()]

    [Cmdlet(VerbsCommon.Get, "GitHubMilestone")]

    [OutputType(typeof(Issue))]

    public class GetGitHubMilestone : GitHubCmdlet{

        [Parameter(Mandatory = true)]

        public string Repository{ get; set; }

        [Parameter]

        public SwitchParameter Latest{ get; set; }

        protected override async Task ProcessRecordAsync(){

            var milestones = GitHubClient.Repository.GetAllForOrg(Organization).ToObservable()

                .Select(list => list.First(repository => repository.Name == Repository))

                .SelectMany(repository => GitHubClient.Issue.Milestone.GetAllForRepository(repository.Id))

                .SelectMany(list => list)

                .HandleErrors(this,Repository)

                .Replay().RefCount();

            await milestones;

            if (Latest)

                milestones = Observable.Return(milestones.ToEnumerable().GetMilestone());

            await milestones

                .HandleErrors(this,Repository)

                .WriteObject(this)

                .ToTask();

        }

    }

}