internal sealed class SessionEventWatcher()

in src/dotnet/AspireWorker/AspireHost/SessionEventWatcher.cs [9:83]
68 lines of code
9 McCabe index (conditional complexity)

internal sealed class SessionEventWatcher(
    IRdConnectionWrapper connectionWrapper,
    AspireHostModel hostModel,
    ChannelWriter<ISessionEvent> sessionEventWriter,
    ILogger logger,
    Lifetime lifetime)
{
    internal async Task WatchSessionEvents()
    {
        await connectionWrapper.AdviceOnProcessStarted(hostModel, lifetime, it =>
        {
            logger.ProcessStarted(it);
            var writingResult =
                sessionEventWriter.TryWrite(new ProcessStartedEvent(it.Id, "processRestarted", it.Pid));
            if (!writingResult)
            {
                logger.FailedToWriteProcessStartedEvent();
            }
        });

        await connectionWrapper.AdviceOnLogReceived(hostModel, lifetime, it =>
        {
            logger.LogReceived(it);
            var message = ModifyText(it.Message);
            if (string.IsNullOrWhiteSpace(message))
            {
                logger.MessageIsEmptyAfterProcessing();
                return;
            }

            var writingResult =
                sessionEventWriter.TryWrite(new LogReceivedEvent(it.Id, "serviceLogs", it.IsStdErr, message));
            if (!writingResult)
            {
                logger.FailedToWriteLogReceivedEvent();
            }
        });

        await connectionWrapper.AdviceOnProcessTerminated(hostModel, lifetime, it =>
        {
            logger.ProcessTerminated(it);
            var writingResult =
                sessionEventWriter.TryWrite(new ProcessTerminatedEvent(it.Id, "sessionTerminated", it.ExitCode));
            if (!writingResult)
            {
                logger.FailedToWriteProcessTerminatedEvent();
            }
        });
    }

    private static string ModifyText(string text)
    {
        var modified = text;

        if (modified.StartsWith("\r\n"))
        {
            modified = modified[2..];
        }
        else if (modified.StartsWith('\n'))
        {
            modified = modified[1..];
        }

        if (modified.EndsWith("\r\n"))
        {
            modified = modified[..^2];
        }
        else if (modified.EndsWith('\n'))
        {
            modified = modified[..^1];
        }

        return modified;
    }
}