| | | 1 | | using System.Diagnostics; |
| | | 2 | | using Estud.Back.Domain.Institutions; |
| | | 3 | | |
| | | 4 | | namespace Estud.Back.Domain.Commands; |
| | | 5 | | |
| | | 6 | | public class Command |
| | | 7 | | { |
| | 808 | 8 | | public int Id { get; set; } |
| | 54 | 9 | | public int InstitutionId { get; set; } |
| | 3232 | 10 | | public string Type { get; set; } |
| | 1616 | 11 | | public string Data { get; set; } |
| | 808 | 12 | | public CommandStatus Status { get; set; } |
| | 808 | 13 | | public DateTime CreatedAt { get; set; } |
| | 808 | 14 | | public int Duration { get; set; } |
| | 808 | 15 | | public DateTime? ProcessedAt { get; set; } |
| | 0 | 16 | | public Guid? ProcessorId { get; set; } |
| | 1616 | 17 | | public string? Error { get; set; } |
| | | 18 | | |
| | | 19 | | /// <summary> |
| | | 20 | | /// Id do comando que gerou o comando |
| | | 21 | | /// Utilizado quando um comando gera outro em seu handler |
| | | 22 | | /// </summary> |
| | 808 | 23 | | public int? ParentId { get; set; } |
| | | 24 | | |
| | | 25 | | /// <summary> |
| | | 26 | | /// Id do comando com erro que gerou o comando atual |
| | | 27 | | /// Utilizado quando o comando original está com erro e é reprocessado |
| | | 28 | | /// O comando atual é uma cópia do original (imutabilidade) |
| | | 29 | | /// </summary> |
| | 808 | 30 | | public int? OriginalId { get; set; } |
| | | 31 | | |
| | | 32 | | /// <summary> |
| | | 33 | | /// Id do lote que contém o comando |
| | | 34 | | /// </summary> |
| | 808 | 35 | | public int? BatchId { get; set; } |
| | | 36 | | |
| | 808 | 37 | | public DateTime? NotBefore { get; set; } |
| | | 38 | | |
| | 2424 | 39 | | public string? ActivityId { get; set; } |
| | | 40 | | |
| | | 41 | | /// <summary> |
| | | 42 | | /// Número máximo de tentativas de reprocessamento automático do comando. |
| | | 43 | | /// Quando o comando falha e MaxRetries > 0, um novo comando de retry é criado com MaxRetries - 1. |
| | | 44 | | /// </summary> |
| | 810 | 45 | | public int MaxRetries { get; set; } |
| | | 46 | | |
| | | 47 | | /// <summary> |
| | | 48 | | /// Which retry attempt this is. 0 for the original command, 1 for first retry, etc. |
| | | 49 | | /// </summary> |
| | 0 | 50 | | public int RetryAttempt { get; set; } |
| | | 51 | | |
| | | 52 | | /// <summary> |
| | | 53 | | /// Backoff strategy for computing delay between retries. |
| | | 54 | | /// When None (default), retries are immediate. |
| | | 55 | | /// </summary> |
| | 808 | 56 | | public BackoffStrategy BackoffStrategy { get; set; } |
| | | 57 | | |
| | | 58 | | /// <summary> |
| | | 59 | | /// Base delay in seconds used by the backoff formula. Default is 5. |
| | | 60 | | /// </summary> |
| | 808 | 61 | | public int BaseDelaySeconds { get; set; } |
| | | 62 | | |
| | 2426 | 63 | | public List<string> Logs { get; set; } = []; |
| | | 64 | | |
| | 754 | 65 | | public Institution? Institution { get; set; } |
| | | 66 | | |
| | 1620 | 67 | | public Command() { } |
| | | 68 | | |
| | 754 | 69 | | public Command( |
| | 754 | 70 | | Institution institution, |
| | 754 | 71 | | object data, |
| | 754 | 72 | | int? parentId = null, |
| | 754 | 73 | | int? originalId = null, |
| | 754 | 74 | | int? batchId = null, |
| | 754 | 75 | | int? delaySeconds = null, |
| | 754 | 76 | | string? activityId = null, |
| | 754 | 77 | | int maxRetries = 0, |
| | 754 | 78 | | BackoffStrategy backoffStrategy = BackoffStrategy.None, |
| | 754 | 79 | | int baseDelaySeconds = 5 |
| | 754 | 80 | | ) { |
| | 754 | 81 | | Institution = institution; |
| | 754 | 82 | | Type = data.GetType().Name; |
| | 754 | 83 | | Data = data.Serialize(); |
| | 754 | 84 | | CreatedAt = DateTime.UtcNow; |
| | 754 | 85 | | ParentId = parentId; |
| | 754 | 86 | | OriginalId = originalId; |
| | 754 | 87 | | BatchId = batchId; |
| | 754 | 88 | | ActivityId = activityId; |
| | 754 | 89 | | NotBefore = delaySeconds != null ? DateTime.UtcNow.AddSeconds(delaySeconds.Value) : null; |
| | 754 | 90 | | MaxRetries = maxRetries; |
| | 754 | 91 | | BackoffStrategy = backoffStrategy; |
| | 754 | 92 | | BaseDelaySeconds = baseDelaySeconds; |
| | 754 | 93 | | } |
| | | 94 | | |
| | 54 | 95 | | public Command( |
| | 54 | 96 | | int institutionId, |
| | 54 | 97 | | object data, |
| | 54 | 98 | | int? parentId = null, |
| | 54 | 99 | | int? originalId = null, |
| | 54 | 100 | | int? batchId = null, |
| | 54 | 101 | | int? delaySeconds = null, |
| | 54 | 102 | | string? activityId = null, |
| | 54 | 103 | | int maxRetries = 0, |
| | 54 | 104 | | BackoffStrategy backoffStrategy = BackoffStrategy.None, |
| | 54 | 105 | | int baseDelaySeconds = 5 |
| | 54 | 106 | | ) { |
| | 54 | 107 | | InstitutionId = institutionId; |
| | 54 | 108 | | Type = data.GetType().Name; |
| | 54 | 109 | | Data = data.Serialize(); |
| | 54 | 110 | | CreatedAt = DateTime.UtcNow; |
| | 54 | 111 | | ParentId = parentId; |
| | 54 | 112 | | OriginalId = originalId; |
| | 54 | 113 | | BatchId = batchId; |
| | 54 | 114 | | ActivityId = activityId; |
| | 54 | 115 | | NotBefore = delaySeconds != null ? DateTime.UtcNow.AddSeconds(delaySeconds.Value) : null; |
| | 54 | 116 | | MaxRetries = maxRetries; |
| | 54 | 117 | | BackoffStrategy = backoffStrategy; |
| | 54 | 118 | | BaseDelaySeconds = baseDelaySeconds; |
| | 54 | 119 | | } |
| | | 120 | | |
| | | 121 | | public void SetAwaiting() |
| | | 122 | | { |
| | 0 | 123 | | Status = CommandStatus.Awaiting; |
| | 0 | 124 | | } |
| | | 125 | | |
| | | 126 | | public void Processed(double duration) |
| | | 127 | | { |
| | 808 | 128 | | ProcessedAt = DateTime.UtcNow; |
| | 808 | 129 | | Duration = Convert.ToInt32(duration); |
| | 808 | 130 | | Status = Error.HasValue() ? CommandStatus.Error : CommandStatus.Success; |
| | 808 | 131 | | } |
| | | 132 | | |
| | | 133 | | public ActivityContext GetParentActivityContext() |
| | | 134 | | { |
| | 808 | 135 | | ActivityContext.TryParse(ActivityId, null, out var parsedContext); |
| | 808 | 136 | | return parsedContext; |
| | | 137 | | } |
| | | 138 | | } |