FlowOptions.cs

using System;
using Cleipnir.ResilientFunctions.Domain;

namespace Cleipnir.Flows;

public class FlowOptions
{
    public static FlowOptions Default { get; } = new();

    internal TimeSpan? RetentionPeriod { get; }
    internal bool? EnableWatchdogs { get; }
    internal int? MaxParallelRetryInvocations { get; }
    internal TimeSpan? MessagesDefaultMaxWaitForCompletion { get; }

    public FlowOptions(
        TimeSpan? retentionPeriod = null,
        bool? enableWatchdogs = null,
        TimeSpan? messagesDefaultMaxWaitForCompletion = null,
        int? maxParallelRetryInvocations = null
    )
    {
        RetentionPeriod = retentionPeriod;
        EnableWatchdogs = enableWatchdogs;
        MessagesDefaultMaxWaitForCompletion = messagesDefaultMaxWaitForCompletion;
        MaxParallelRetryInvocations = maxParallelRetryInvocations;
    }

    public FlowOptions Merge(Settings settings)
    {
        return new FlowOptions(
            RetentionPeriod ?? settings.RetentionPeriod,
            EnableWatchdogs ?? settings.EnableWatchdogs,
            MessagesDefaultMaxWaitForCompletion ?? settings.MessagesDefaultMaxWaitForCompletion,
            MaxParallelRetryInvocations ?? settings.MaxParallelRetryInvocations
        );
    }

    internal LocalSettings MapToLocalSettings()
        => new(RetentionPeriod, EnableWatchdogs, MessagesDefaultMaxWaitForCompletion, MaxParallelRetryInvocations);
}