Saga 2.2

Account.cs

private Task AdjustBalance(PID replyTo, decimal amount)
{
    if (RefusePermanently())
    {
        _processedMessages.Add(replyTo, new Refused());
        replyTo.Tell(new Refused());
    }
        
    if (Busy())
        replyTo.Tell(new ServiceUnavailable());
    
    var behaviour = DetermineProcessingBehavior();
    if (behaviour == Behavior.FailBeforeProcessing)
        return Failure(replyTo);
    
    // simulate potential slow service
    Thread.Sleep(_random.Next(0, 150));
    
    _balance += amount;
    _processedMessages.Add(replyTo, new OK());
    
    if (behaviour == Behavior.FailAfterProcessing)
        return Failure(replyTo);
    
    replyTo.Tell(new OK());
    return Actor.Done;
}