autogen/src/libs/Microsoft.AI.DevTeam/Actors/Hubber/Hubber.cs

using Orleans.Concurrency;
using Orleans.Runtime;
using Orleans.Streams;
using Orleans.Timers;

namespace Microsoft.AI.DevTeam;

[StatelessWorker]
[ImplicitStreamSubscription("Hubber")]
public class Hubber : Grain, IGrainWithStringKey
{
    private readonly IManageGithub _ghService;

    public Hubber( IManageGithub ghService)
    {
        _ghService = ghService;
    }

    public async override Task OnActivateAsync(CancellationToken cancellationToken)
    {
        var streamProvider = this.GetStreamProvider("StreamProvider");
        var streamId = StreamId.Create("Hubber", this.GetPrimaryKeyString());
        var stream = streamProvider.GetStream<Event>(streamId);

        await stream.SubscribeAsync(HandleEvent);
    }

    // -> Hubber
    // -> NewAsk
    //     -> create PM issue
    //     -> create DevLead issue
    // -> ReadmeGenerated
    //     -> post comment
    // -> DevPlanGenerated
    //     -> post comment
    // -> DevPlanFinished
    //     -> for each step, create Dev issue
    // -> CodeGenerated
    //     -> post comment
    public async Task HandleEvent(Event item, StreamSequenceToken? token)
    {
        switch (item.Type)
        {
            case EventType.NewAsk:
                var org = item.Data["org"];
                var repo = item.Data["repo"];
                var input = item.Message;
                var parentNumber = long.Parse(item.Data["parentNumber"]);
                var pmIssue = await CreateIssue(org, repo, input, "", parentNumber);
                var devLeadIssue = await CreateIssue(org, repo, input, "", parentNumber);

                break;
            case EventType.NewAskReadme:
                
                break;
            case EventType.ChainClosed:
                
                break;
            default:
                break;
        }
    }
    
    public async Task<NewIssueResponse> CreateIssue(string org, string repo, string input, string function, long parentNumber)
    {
        return await _ghService.CreateIssue(org, repo,input,function,parentNumber);
    }
     public async Task PostComment(string org, string repo,long issueNumber, string comment )
    {
        await _ghService.PostComment(org, repo, issueNumber, comment);
    }
     public async Task CreateBranch()
    {
        // await _ghService.CreateBranch();
    }
     public async Task CreatePullRequest()
    {
        // await _ghService.CreatePR();
    }
     public async Task CommitToBranch()
    {
        // await _ghService.CommitToBranch()
    }
}