XpandPosh

1.1.3

Cmdlets/src/XpandPosh.Cmdlets/GetGitHubCommitIssue/Get-GitHubCommitIssue.cs

                                using System;

using System.Linq;

using System.Management.Automation;

using System.Reactive.Linq;

using System.Reactive.Threading.Tasks;

using System.Threading.Tasks;

using ImpromptuInterface;

using Octokit;

using XpandPosh.CmdLets;

namespace XpandPosh.Cmdlets.GetGitHubCommitIssue{

    [CmdletBinding]

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

    [OutputType(typeof(ICommitIssues))]

    public class GetGitHubCommitIssues : GitHubCmdlet{

        [Parameter(Mandatory = true)]

        public string Repository1{ get; set; } 

        [Parameter(Mandatory = true)]

        public string Repository2{ get; set; } 

        [Parameter]

        public DateTimeOffset? Since{ get; set; }

        protected override async Task BeginProcessingAsync(){

            await base.BeginProcessingAsync();

            if (!Since.HasValue){

                var release = await GitHubClient.Repository.GetForOrg(Organization, Repository1)

                    .SelectMany(repository => GitHubClient.Repository.Release.GetAll(repository.Id))

                    .Select(list => list.First());

                Since = release.PublishedAt;

                WriteVerbose($"Last {Repository1} release was at {release.PublishedAt}");

            }

        }

        protected override Task ProcessRecordAsync(){

            return GitHubClient.CommitIssues(Organization, Repository1, Repository2,Since)

                .Select(_ => _.commitIssues.Select(tuple => (_.repoTuple.repo1,_.repoTuple.repo2,tuple.commit,tuple.issues).ToClass().ActLike<ICommitIssues>()))

                .HandleErrors(this,Repository1)

                .WriteObject(this)

                .ToTask();

        }

    }

    public interface ICommitIssues{

        Repository Repository1{ get; }

        Repository Repository2{ get; }

        Issue[] Issues{ get; }

        GitHubCommit GitHubCommit{ get; set; }

    }

}