SWEETPONY Posts - Answer Overflow

SWEETPONY

•Created by SWEETPONY on 3/31/2025 in #help

✅ How to convert controller route name to camel case automatically?

I have this:

[Authorize]
[Route("[controller]")]
public class StreamController

[Authorize]
[Route("[controller]")]
public class StreamController

and controller name in swagger is Stream but should be stream

19 replies

CC#

•Created by SWEETPONY on 3/21/2025 in #help

✅ How to handle websockets?

I have this handler. I wanna save all active connections to list, is it worth it?

public sealed class UserConnectionHandler : IDisposable
{
    public required string SessionId { get; init; }

    public required string ConnectionId { get; init; }
    
    public WebSocket? Socket { get; set; }

    public DateTime? LastActivityDateTime { get; set; }

    public async Task SendEventAsync(string message, CancellationToken cancellationToken)
    {
        if(Socket?.State == WebSocketState.Open)
        {
            var buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(message));
            await Socket.SendAsync(buffer, WebSocketMessageType.Text, true, cancellationToken).ConfigureAwait(false);
        }
    }

    public async Task CloseAsync(WebSocketCloseStatus closeStatus, CancellationToken cancellationToken)
    {
        if(Socket?.State == WebSocketState.Open)
        {
            await Socket.CloseAsync(closeStatus, string.Empty, cancellationToken).ConfigureAwait(false);
        }
    }

    public void Dispose()
    {
        Socket?.Dispose();
    }

public sealed class UserConnectionHandler : IDisposable
{
    public required string SessionId { get; init; }

    public required string ConnectionId { get; init; }
    
    public WebSocket? Socket { get; set; }

    public DateTime? LastActivityDateTime { get; set; }

    public async Task SendEventAsync(string message, CancellationToken cancellationToken)
    {
        if(Socket?.State == WebSocketState.Open)
        {
            var buffer = new ArraySegment<byte>(Encoding.UTF8.GetBytes(message));
            await Socket.SendAsync(buffer, WebSocketMessageType.Text, true, cancellationToken).ConfigureAwait(false);
        }
    }

    public async Task CloseAsync(WebSocketCloseStatus closeStatus, CancellationToken cancellationToken)
    {
        if(Socket?.State == WebSocketState.Open)
        {
            await Socket.CloseAsync(closeStatus, string.Empty, cancellationToken).ConfigureAwait(false);
        }
    }

    public void Dispose()
    {
        Socket?.Dispose();
    }

52 replies

CC#

•Created by SWEETPONY on 3/19/2025 in #help

✅ How to make httpcontext threadsafe?

I have this:

public sealed record UserConnectionModel
{
    private readonly CancellationTokenSource cancellationTokenSource;

    public UserConnectionModel(CancellationTokenSource cancellationTokenSource)
    {
        this.cancellationTokenSource = cancellationTokenSource;
        AddedDateTime = DateTime.Now;
    }

    public required string SessionId { get; init; }

    public required string ConnectionId { get; init; }

    public required string ResourceIdentity { get; init; }

    public IReadOnlyCollection<string> ResourceGroupIdentities { get; init; } = [];

    public DateTime AddedDateTime { get; init; }

    public DateTime? DisconnectedDateTime { get; set; }

    public required int TimezoneOffset { get; set; }

    public required HttpContext ConnectionContext { get; init; }

    public Task CloseConnectionAsync() => cancellationTokenSource.CancelAsync();

    public Task SendEventAsync(object data) => ConnectionContext.Response.WriteAsync($"data: {data}\n\n");
}

public sealed record UserConnectionModel
{
    private readonly CancellationTokenSource cancellationTokenSource;

    public UserConnectionModel(CancellationTokenSource cancellationTokenSource)
    {
        this.cancellationTokenSource = cancellationTokenSource;
        AddedDateTime = DateTime.Now;
    }

    public required string SessionId { get; init; }

    public required string ConnectionId { get; init; }

    public required string ResourceIdentity { get; init; }

    public IReadOnlyCollection<string> ResourceGroupIdentities { get; init; } = [];

    public DateTime AddedDateTime { get; init; }

    public DateTime? DisconnectedDateTime { get; set; }

    public required int TimezoneOffset { get; set; }

    public required HttpContext ConnectionContext { get; init; }

    public Task CloseConnectionAsync() => cancellationTokenSource.CancelAsync();

    public Task SendEventAsync(object data) => ConnectionContext.Response.WriteAsync($"data: {data}\n\n");
}

I save these connections to ConcurrentDictionary, and when I need to send a message, I just find the connection from the dictionary and use SendEventAsync. I don't know why, but sometimes I don't see that any events have been sent, and it looks like a race condition. What can I do about it?

6 replies

CC#

•Created by SWEETPONY on 3/15/2025 in #help

✅ Why memory from heap0 goes to unmanaged?

2 replies

CC#

•Created by SWEETPONY on 3/15/2025 in #help

✅ How to make static field required to use from interface?

I have this interface:

public interface IEventProcessor
{
    public static IReadOnlyCollection<string> HandledEvents { get; } = [];
}

public interface IEventProcessor
{
    public static IReadOnlyCollection<string> HandledEvents { get; } = [];
}

HandledEvents is static because I can easily read values from it using reflection and without Activator.CreateInstance Processor example:

public sealed class FlightEventProcessor(JsonSerializerOptions serializerOptions): IEventProcessor
{
    public static string[] HandledEvents => ["FlightAdded", "FlightUpdated"];
}

public sealed class FlightEventProcessor(JsonSerializerOptions serializerOptions): IEventProcessor
{
    public static string[] HandledEvents => ["FlightAdded", "FlightUpdated"];
}

the main problem HandledEvents can be easily removed from FlightEventProcessor and nothing will happens. compilator allows me to not implement this array inside every classes that inherit IEventProcessor

7 replies

CC#

•Created by SWEETPONY on 12/5/2024 in #help

Is it possible to use pattern matching here?

I want smth like this:

var isInbound = entity.LegData!.Location.LatestArrivalStationIataCode == "SVO";
var isOutbound = entity.LegData!.Location.LatestDepartureStationIataCode == "SVO";

return new PresentationModel
{
     Terminal = 
         isInbound => entity.LegData!.Location.ArrivalTerminal
         isOutbound => entity.LegData!.Location.DepartureTerminal
}

var isInbound = entity.LegData!.Location.LatestArrivalStationIataCode == "SVO";
var isOutbound = entity.LegData!.Location.LatestDepartureStationIataCode == "SVO";

return new PresentationModel
{
     Terminal = 
         isInbound => entity.LegData!.Location.ArrivalTerminal
         isOutbound => entity.LegData!.Location.DepartureTerminal
}

10 replies

CC#

•Created by SWEETPONY on 11/10/2024 in #help

✅ I don't undertand the error: capacity was less than the current size

Hey I have two versions of code and second one doesn't work first version:

int[] array = Enumerable.Range(0, 1000000000).ToArray();
var lst = new List<double>();

var stopWatch = new Stopwatch();
stopWatch.Start();

for (int i = 0; i < array.Length; i++)
{
    var result = Math.Pow(i, 100000000000);
    lst.Add(result);
}

stopWatch.Stop();
Console.WriteLine(stopWatch.Elapsed);

int[] array = Enumerable.Range(0, 1000000000).ToArray();
var lst = new List<double>();

var stopWatch = new Stopwatch();
stopWatch.Start();

for (int i = 0; i < array.Length; i++)
{
    var result = Math.Pow(i, 100000000000);
    lst.Add(result);
}

stopWatch.Stop();
Console.WriteLine(stopWatch.Elapsed);

second version:

int[] array = Enumerable.Range(0, 1000000000).ToArray();
var lst = new List<double>();

var stopWatch = new Stopwatch();
stopWatch.Start();

Parallel.For(0, array.Length, i =>
{
    var result = Math.Pow(i, 100000000000);
    lst.Add(result);
});

stopWatch.Stop();
Console.WriteLine(stopWatch.Elapsed);

int[] array = Enumerable.Range(0, 1000000000).ToArray();
var lst = new List<double>();

var stopWatch = new Stopwatch();
stopWatch.Start();

Parallel.For(0, array.Length, i =>
{
    var result = Math.Pow(i, 100000000000);
    lst.Add(result);
});

stopWatch.Stop();
Console.WriteLine(stopWatch.Elapsed);

second version always throws the exception:

Unhandled exception. System.AggregateException: One or more errors occurred. (capacity was less than the current size. (Parameter 'value')) (capacity was less than the current size. (Parameter 'value')) (capacity was less than the current size. (Parameter 'value')) (capacity was less than the current size.

17 replies

CC#

•Created by SWEETPONY on 11/6/2024 in #help

✅ How to write unit test for this?

I have controller with this method:

[HttpGet("stream")]
public async Task StreamAsync(CancellationToken cancellationToken)
{
    Response.Headers.Append("Content-Type", "text/event-stream");

    while(!cancellationToken.IsCancellationRequested)
    {
        var sseEvent = new SseEvent<object>
        {
            Action = SseAction.Heartbeat,
            Timestamp = timeProvider.GetUtcNow().DateTime
        };

        var serializedSseEvent = Serialization.Serialize(sseEvent);

        await Response.WriteAsync($"{serializedSseEvent}", cancellationToken).ConfigureAwait(false);
        await Response.Body.FlushAsync(cancellationToken).ConfigureAwait(false);

        await Task.Delay(sseSettings.Timeout, cancellationToken).ConfigureAwait(false);
    }
}

[HttpGet("stream")]
public async Task StreamAsync(CancellationToken cancellationToken)
{
    Response.Headers.Append("Content-Type", "text/event-stream");

    while(!cancellationToken.IsCancellationRequested)
    {
        var sseEvent = new SseEvent<object>
        {
            Action = SseAction.Heartbeat,
            Timestamp = timeProvider.GetUtcNow().DateTime
        };

        var serializedSseEvent = Serialization.Serialize(sseEvent);

        await Response.WriteAsync($"{serializedSseEvent}", cancellationToken).ConfigureAwait(false);
        await Response.Body.FlushAsync(cancellationToken).ConfigureAwait(false);

        await Task.Delay(sseSettings.Timeout, cancellationToken).ConfigureAwait(false);
    }
}

unit test:

[Test]
public async Task StreamAsync_ShouldWriteHeartbeatEvents()
{
    var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3));

    await controller.StreamAsync(cts.Token).ConfigureAwait(false);
}

[Test]
public async Task StreamAsync_ShouldWriteHeartbeatEvents()
{
    var cts = new CancellationTokenSource(TimeSpan.FromSeconds(3));

    await controller.StreamAsync(cts.Token).ConfigureAwait(false);
}

I want to check that Response contains sseEvents but always get an exception: System.Threading.Tasks.TaskCanceledException : A task was canceled. how to fix it?

3 replies

CC#

•Created by SWEETPONY on 11/6/2024 in #help

✅ Is it worth to use stackalloc here?

Hey, I have this:

[HttpGet("stream")]
public async Task StreamHeartbeatAsync(CancellationToken cancellationToken)
{
    Response.Headers.Append("Content-Type", "text/event-stream");
    Response.Headers.Append("Cache-Control", "no-cache");
    Response.Headers.Append("Connection", "keep-alive");

    while(!cancellationToken.IsCancellationRequested)
    {
        var sseEvent = new SseEvent<object>
        {
            Action = SseAction.Heartbeat,
            Timestamp = DateTime.UtcNow
        };

        await Response.WriteAsJsonAsync(sseEvent, cancellationToken);
        await Response.Body.FlushAsync(cancellationToken);

        await Task.Delay(sseSettings.Timeout, cancellationToken);
    }
}

public sealed class SseEvent<T>
{
    public required DateTime Timestamp { get; set; }
    public required SseAction Action { get; set; }
    public string? Store { get; set; }
    public string? Identity { get; set; }
    public T? Data { get; set; }
}

[HttpGet("stream")]
public async Task StreamHeartbeatAsync(CancellationToken cancellationToken)
{
    Response.Headers.Append("Content-Type", "text/event-stream");
    Response.Headers.Append("Cache-Control", "no-cache");
    Response.Headers.Append("Connection", "keep-alive");

    while(!cancellationToken.IsCancellationRequested)
    {
        var sseEvent = new SseEvent<object>
        {
            Action = SseAction.Heartbeat,
            Timestamp = DateTime.UtcNow
        };

        await Response.WriteAsJsonAsync(sseEvent, cancellationToken);
        await Response.Body.FlushAsync(cancellationToken);

        await Task.Delay(sseSettings.Timeout, cancellationToken);
    }
}

public sealed class SseEvent<T>
{
    public required DateTime Timestamp { get; set; }
    public required SseAction Action { get; set; }
    public string? Store { get; set; }
    public string? Identity { get; set; }
    public T? Data { get; set; }
}

I think it is not good to create sseEvent every second without any memory clean. Is it worth to use stackalloc here?

41 replies

CC#

•Created by SWEETPONY on 10/25/2024 in #help

✅ How to save to database with ISO format?

6 replies

CC#

•Created by SWEETPONY on 10/23/2024 in #help

✅ How to optimize this code?

Hello, I'd like to optimize my code. The best time I got: 00:00:00.536 with chunks count = 256 536ms actually is not too bad but is it possible to speed up method?

private async Task<IEnumerable<JsonNode?>?> GetDmnTasksAsync(IReadOnlyList<PassengerArrivalChunk> chunks)
{
    var tasks = chunks.Select(async chunk =>
    {
       var serializedChunk = Serializer.Serialize(new { passengerArrivalChunk = chunk });

       using var response = await httpClient
          .PostAsync(processingSettings.DmnUrl, new StringContent(serializedChunk, Encoding.UTF32, MediaTypeNames.Application.Json));

       var responseMessage = await response.Content.ReadAsStringAsync();
       var jsonArray = JsonNode.Parse(responseMessage)?["Tasks"]?.AsArray();

       return jsonArray?.Select(el => el).Where(x => x != null);
    }).ToList();

    var results = await Task.WhenAll(tasks);
    return results.SelectMany(result => result ?? []);
}

private async Task<IEnumerable<JsonNode?>?> GetDmnTasksAsync(IReadOnlyList<PassengerArrivalChunk> chunks)
{
    var tasks = chunks.Select(async chunk =>
    {
       var serializedChunk = Serializer.Serialize(new { passengerArrivalChunk = chunk });

       using var response = await httpClient
          .PostAsync(processingSettings.DmnUrl, new StringContent(serializedChunk, Encoding.UTF32, MediaTypeNames.Application.Json));

       var responseMessage = await response.Content.ReadAsStringAsync();
       var jsonArray = JsonNode.Parse(responseMessage)?["Tasks"]?.AsArray();

       return jsonArray?.Select(el => el).Where(x => x != null);
    }).ToList();

    var results = await Task.WhenAll(tasks);
    return results.SelectMany(result => result ?? []);
}

19 replies

CC#

•Created by SWEETPONY on 10/6/2024 in #help

✅ How to speed up execution of BigInteger.Pow?

I have this: var result = BigInteger.Pow(1000, 10000000); I know this is a big number but generation of this number takes too much time. Is it possible to speed up?

13 replies

CC#

•Created by SWEETPONY on 9/11/2024 in #help

Error: The value of shadow key property 'ResourceDemandChunks.Id' is unknown when attempting to save

Hey everyone! I'm stuck with this problem: The value of shadow key property 'ResourceDemandChunks.Id' is unknown when attempting to save changes. This is because shadow property values cannot be preserved when the entity is not being tracked. Consider adding the property to the entity's .NET type this is how I register entity in db context:

 modelBuilder.Entity<WorkingTaskEntity>().OwnsOne(c => c.CustomData, t =>  
 {
     t.ToJson();
     t.OwnsMany(customData => customData.ResourceDemandChunks);
 });

 modelBuilder.Entity<WorkingTaskEntity>().OwnsOne(c => c.CustomData, t =>  
 {
     t.ToJson();
     t.OwnsMany(customData => customData.ResourceDemandChunks);
 });

CustomData is jsonb property, in DDL it is jsonb, I absolutely no idea what happening..

public WorkingTaskData? CustomData { get; init; }
public record WorkingTaskData 
{
   public List<ResourceDemandChunks> ResourceDemandChunks { get; set; }

public WorkingTaskData? CustomData { get; init; }
public record WorkingTaskData 
{
   public List<ResourceDemandChunks> ResourceDemandChunks { get; set; }

3 replies

CC#

•Created by SWEETPONY on 7/28/2024 in #help

✅ How to correctly write conditions with expressions?

I have this code:

public static class BookPolicy
    {
        public static void AllowRead(Book book)
        {
            var isHorrorBook = Specifications.IsHorrorBook().Compile();
            var isPonyBook = Specifications.IsPonyBook().Compile();

            if (isHorrorBook(book) || isPonyBook(book))
                throw new Exception("Horror or pony books don't allow here");
        }
    }

    public static class Specifications
    {
        public static Expression<Func<Book, bool>> IsHorrorBook() =>
            book => book.Title.Contains("Frankenstein");
        
        public static Expression<Func<Book, bool>> IsPonyBook() =>
            book => book.Title.Contains("Pony");
    }

public static class BookPolicy
    {
        public static void AllowRead(Book book)
        {
            var isHorrorBook = Specifications.IsHorrorBook().Compile();
            var isPonyBook = Specifications.IsPonyBook().Compile();

            if (isHorrorBook(book) || isPonyBook(book))
                throw new Exception("Horror or pony books don't allow here");
        }
    }

    public static class Specifications
    {
        public static Expression<Func<Book, bool>> IsHorrorBook() =>
            book => book.Title.Contains("Frankenstein");
        
        public static Expression<Func<Book, bool>> IsPonyBook() =>
            book => book.Title.Contains("Pony");
    }

everything is ok but i would like to know is it possible to write smth like this? if(book is Horror or Pony) {...} I don't understand how to do this with expressions

10 replies

CC#

•Created by SWEETPONY on 7/18/2024 in #help

✅ A problem with tracking behavior in unit tests

I have this error in unit tests:

The instance of entity type 'QualificationEntity' cannot be tracked because another instance with the same key value for {'Id'} is already being tracked. When attaching existing entities, ensure that only one entity instance with a given key value is attached. Consider using 'DbContextOptionsBuilder.EnableSensitiveDataLogging' to see the conflicting key values.

The instance of entity type 'QualificationEntity' cannot be tracked because another instance with the same key value for {'Id'} is already being tracked. When attaching existing entities, ensure that only one entity instance with a given key value is attached. Consider using 'DbContextOptionsBuilder.EnableSensitiveDataLogging' to see the conflicting key values.

Unit tests look like this:

[Test]
public Task AddAsync_AddWorkingTask_Success() =>
   ExecuteTestCaseWithTestingContextAsync(async context => {
       context.DbContext.Qualifications.Add(qualification);
       context.DbContext.SaveChanges();
        
       ...
    
       await context.WorkingTaskRepository.ScheduleWorkingTaskAsync(workingTask, eventContext);
});

[Test]
public Task AddAsync_AddWorkingTask_Success() =>
   ExecuteTestCaseWithTestingContextAsync(async context => {
       context.DbContext.Qualifications.Add(qualification);
       context.DbContext.SaveChanges();
        
       ...
    
       await context.WorkingTaskRepository.ScheduleWorkingTaskAsync(workingTask, eventContext);
});

   protected async Task ExecuteTestCaseWithTestingContextAsync(Func<TestingContext, Task> asserter)
    {
        if(asserter == null)
            Assert.Fail();
        var options = CreateDbOptions();
        using(var dbContext = new DbContext(options))
        {
            await dbContext.Database.EnsureDeletedAsync().ConfigureAwait(false);
            await dbContext.Database.EnsureCreatedAsync().ConfigureAwait(false);
            var testingContext = new TestingContext(dbContext);
            await asserter.Invoke(testingContext).ConfigureAwait(false);
        }
    }

   protected async Task ExecuteTestCaseWithTestingContextAsync(Func<TestingContext, Task> asserter)
    {
        if(asserter == null)
            Assert.Fail();
        var options = CreateDbOptions();
        using(var dbContext = new DbContext(options))
        {
            await dbContext.Database.EnsureDeletedAsync().ConfigureAwait(false);
            await dbContext.Database.EnsureCreatedAsync().ConfigureAwait(false);
            var testingContext = new TestingContext(dbContext);
            await asserter.Invoke(testingContext).ConfigureAwait(false);
        }
    }

everything will be ok if I remove context.DbContext.Qualifications.Add(qualification); but I don't want to

1 replies

CC#

•Created by SWEETPONY on 7/16/2024 in #help

✅ is there any way to delete items from the database and return the deleted list in one request?

is there any way to delete items from the database and return the deleted list in one request? I can do something like this: DbContext.T.Where(entity => ..).ExecuteDelete(), but my business logic assumes that I will return items that were deleted I can do this: var deleted = DbContext.T.Where(entity => ..) DbContext.RemoveRange(deleted) but these are already two requests to database

14 replies

CC#

•Created by SWEETPONY on 7/2/2024 in #help

✅ How to optimize this method?

I have this method:

protected override async Task UpdateCoreAsync(WorkingTaskModel workingTask, EventHandlingContext context)
    {
        var exist = await FindByIdentityAsync(workingTask.Identity, context).ConfigureAwait(false);
        if(exist == null)
            return;
        if(await UpdateInternalAsync(workingTask, exist, context).ConfigureAwait(false))
        {
            var stateIsChanged = exist.State != workingTask.State;
            if(stateIsChanged)
            {
                var historyModel = new WorkingTaskHistoryModel
                {
                    ChangedData = new ChangedWorkingTaskModel(){State = workingTask.State},
                    UserIdentity = context.Context.UserAccountIdentity,
                    SourceName = context.Context.SourceName,
                    UpdatedAt = timeProvider.GetUtcNow().DateTime
                };

                await UpdateWorkingTaskHistoryAsync(historyModel, exist, context).ConfigureAwait(false);
            }

            var found = await FindByIdentityAsync(workingTask.Identity, context).ConfigureAwait(false);
            await eventDispatcher.WorkingTaskUpdatedAsync(found!, exist, context).ConfigureAwait(false);
        }
    }

protected override async Task UpdateCoreAsync(WorkingTaskModel workingTask, EventHandlingContext context)
    {
        var exist = await FindByIdentityAsync(workingTask.Identity, context).ConfigureAwait(false);
        if(exist == null)
            return;
        if(await UpdateInternalAsync(workingTask, exist, context).ConfigureAwait(false))
        {
            var stateIsChanged = exist.State != workingTask.State;
            if(stateIsChanged)
            {
                var historyModel = new WorkingTaskHistoryModel
                {
                    ChangedData = new ChangedWorkingTaskModel(){State = workingTask.State},
                    UserIdentity = context.Context.UserAccountIdentity,
                    SourceName = context.Context.SourceName,
                    UpdatedAt = timeProvider.GetUtcNow().DateTime
                };

                await UpdateWorkingTaskHistoryAsync(historyModel, exist, context).ConfigureAwait(false);
            }

            var found = await FindByIdentityAsync(workingTask.Identity, context).ConfigureAwait(false);
            await eventDispatcher.WorkingTaskUpdatedAsync(found!, exist, context).ConfigureAwait(false);
        }
    }

the problem is: I need to call FindByIdentityAsync twice and we need this just to check updated property and send event. is it possible to remove second FindByIdentityAsync?

4 replies

CC#

•Created by SWEETPONY on 6/21/2024 in #help

Is it possible to update public IReadOnlyList?

There is public IReadOnlyList<ISelectionNode> Selections { get; } from public api I know it is not a good idea but I want to extend it. Is it possible?

12 replies

CC#

•Created by SWEETPONY on 6/19/2024 in #help

✅ how to convert Dictionary to C# object?

I have Dictionary<string, object> map string is property name and object is property value is it possible to deserialize this to real object?

2 replies

CC#

•Created by SWEETPONY on 5/28/2024 in #help

The instance of entity type 'OptimizerInstanceEntity' cannot be tracked

Can someone help me to update model?

public sealed record OptimizerSettingsSetsEntity : OptimizerSettingsSets, IIdentityEntity
{
    public new string Identity { get => base.Identity; init => base.Identity = value; }
    public List<OptimizerInstanceEntity> OptimizerInstances { get; init; } = [];
    public DateTime Created { get; init; }
    public Guid Id { get; init; }
    public DateTime Timestamp { get; init; }
    public DateTime? Updated { get; init; }
}

public sealed record OptimizerInstanceEntity : IdentityEntity
{
    public required string Url { get; set; }
}

public sealed record OptimizerSettingsSetsEntity : OptimizerSettingsSets, IIdentityEntity
{
    public new string Identity { get => base.Identity; init => base.Identity = value; }
    public List<OptimizerInstanceEntity> OptimizerInstances { get; init; } = [];
    public DateTime Created { get; init; }
    public Guid Id { get; init; }
    public DateTime Timestamp { get; init; }
    public DateTime? Updated { get; init; }
}

public sealed record OptimizerInstanceEntity : IdentityEntity
{
    public required string Url { get; set; }
}

I want to create entity, add it to database and then update only instances My command doesn't work, I got exception after trying to update:

    protected override async Task UpdateCoreAsync(OptimizerSettingsSetsModel model, EventHandlingContext context)
    {
        var exists = await FindByIdentityAsync(model.Identity, context);
        if(exists == null)
            return;

        if(!ChangesComparer.HasChanges(exists.ToModel(), model))
            return;

        var entity = CreateEntity(model, exists);
        var entry = dbContext.OptimizerSettingsSets.Update(entity);
        await dbContext.SaveChangesAsync(context.CancellationToken);
        entry.State = EntityState.Detached;
        await eventDispatcher.OptimizerSettingsSetsUpdatedAsync(entity, context);
    }

    protected override async Task UpdateCoreAsync(OptimizerSettingsSetsModel model, EventHandlingContext context)
    {
        var exists = await FindByIdentityAsync(model.Identity, context);
        if(exists == null)
            return;

        if(!ChangesComparer.HasChanges(exists.ToModel(), model))
            return;

        var entity = CreateEntity(model, exists);
        var entry = dbContext.OptimizerSettingsSets.Update(entity);
        await dbContext.SaveChangesAsync(context.CancellationToken);
        entry.State = EntityState.Detached;
        await eventDispatcher.OptimizerSettingsSetsUpdatedAsync(entity, context);
    }

6 replies

Gaming

Programming