Обработчик событий сущностей

public interface DynamicCodeContext
{
    /// Тип операции, для которой вызван обработчик
    EntityServiceOperation OperationType { get; }

    /// Событие до коммита транзакции
    event Func<Task> BeforeCommit;

    /// Событие после коммита транзакции
    event Func<Task> AfterCommit;

    /// Сервис работы с сущностями
    IContextEntityService<TEntity> GetEntityService<TEntity>();

    /// Логирование (асинхронное, с уровнем)
    Task Log(string message, DynamicCodeLogLevel level = DynamicCodeLogLevel.Info);
}

Task Log(string message, DynamicCodeLogLevel level = DynamicCodeLogLevel.Info);

public interface IContextEntityService<TEntity> where TEntity : class, IEntity
{
    Task<TEntity> InsertAsync(TEntity detachedEntity, bool checkRights = true);
    Task<TEntity> UpdateAsync(TEntity detachedEntity, bool checkRights = true);
    Task<TEntity> DeleteAsync(Guid entityId, bool checkRights = true);
    Task<TEntity> GetAsync(Guid entityId, bool checkRights = true);

    IQueryable<TEntity> Get(
        Expression<Func<TEntity, bool>> condition = null,
        bool checkRights = true
    );

    Task CheckCanInsertAsync(TEntity entity);
    Task CheckCanEditAsync(TEntity entity);
    Task CheckCanEditAsync(Guid entityId);
    Task CheckCanDeleteAsync(TEntity entity);
    Task CheckCanExecuteAsync(Guid entityId, string granular);
    Task CheckCanViewAsync(Guid entityId, string granularName = null);

    Task<IQueryable<TCollectionType>> GetNavigationAsync<TCollectionType>(
        Guid key,
        Expression<Func<TCollectionType, Guid>> foreignKeyExpression
    ) where TCollectionType : Entity;

    Task<List<TCollectionType>> UpdateNavigationAsync<TCollectionType>(
        Guid key,
        Expression<Func<TCollectionType, Guid>> foreignKeyExpression,
        ICollection<TCollectionType> collection,
        Func<TCollectionType, object> groupByExpression = null
    ) where TCollectionType : Entity;
}

public class CustomHooks : EntityTypeCustomHooks<Activity>
{
    public override async Task BeforeUpsert(
        CustomHooksContext context,
        Activity detachedEntity)
    {
        if (string.IsNullOrWhiteSpace(detachedEntity.Name))
            await context.Log("Имя не задано", DynamicCodeLogLevel.Error);
        await Task.CompletedTask;
    }

    public override async Task AfterUpsert(
        CustomHooksContext context,
        Activity contextEntity,
        Activity detachedEntity)
    {
        await context.Log($"Сущность сохранена: {contextEntity.Id}");
        await Task.CompletedTask;
    }

    public override async Task BeforeDelete(
        CustomHooksContext context,
        Activity detachedEntity)
    {
        await context.Log($"Попытка удаления: {detachedEntity.Id}");
        await Task.CompletedTask;
    }

    public override async Task AfterDelete(
        CustomHooksContext context,
        Activity contextEntity)
    {
        await context.Log($"Сущность удалена: {contextEntity.Id}");
        await Task.CompletedTask;
    }
}

public class CustomHooks : EntityTypeCustomHooks<Project>
{
    public override async Task BeforeSetState(
        CustomHooksContext context,
        Project entity,
        Guid oldStateId,
        Guid newStateId)
    {
        await context.Log($"Смена состояния проекта {entity.Id}: {oldStateId} → {newStateId}");
        await Task.CompletedTask;
    }

    public override async Task AfterSetState(
        CustomHooksContext context,
        Project entity,
        Guid oldStateId,
        Guid newStateId)
    {
        var notificationService = context.GetNotificationService();
        await context.Log($"Состояние проекта {entity.Id} обновлено на {newStateId}");
        await Task.CompletedTask;
    }

    public override async Task BeforeStartWorkflow(
        CustomHooksContext context,
        Project contextEntity)
    {
        await context.Log($"Запуск воркфлоу для проекта {contextEntity.Id}");
        await Task.CompletedTask;
    }
}

public override async Task AfterUpsert(CustomHooksContext context, Activity contextEntity, Activity detachedEntity)
{
    const string url = "https://api.timetta.com/odata";
    const string token = "***";

    using var httClient = new HttpClient();
    httClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", token);

    var newActivity = new { Name = "New Activity" };
    var payload = JsonContent.Create(newActivity);

    var response = await httClient.PostAsync($"{url}/Activities", payload);
    var responseContent = await response.Content.ReadFromJsonAsync<JsonElement>();

    var idOfCreatedEntity = responseContent.GetProperty("id").GetGuid();
}