AggregateRoot not Loading when publishing command

[jessemillerrev]

Hello, I am sure I am doing something wrong but I cannot for the life of me get my AggregateRoot object to load from the event store when publishing a new command by hand.

EX.
var result = await _commandBus.PublishAsync(new UpdateFeasibilityRequestDetailLOSCommand(e.Entity) , CancellationToken.None);

public class UpdateFeasibilityRequestDetailLOSCommand : Command<FeasibilityRequestDetail, FeasibilityRequestDetailId, ExecutionResult>
    {
        public FeasibilityStudyEntity Entity { get; set; }
        

        public UpdateFeasibilityRequestDetailLOSCommand(FeasibilityStudyEntity entity) : base(entity.FeasibilityRequestDetailId)
        {
            Entity = entity;
        }
    }

The Entity loads in fine but when the command handler triggers the aggregate root is marked as new and no data was loaded into state.
I am not sure why this wouldn't work, is there a better solution than this?

[CapitanMurloc]

Make sure that the identifier of the aggregate is the same, if it recognizes the aggregate as new it is mainly because the entity.FeasibilityRequestDetailId must be changing the value and it must not be the same.

[jessemillerrev]

I have verified that the id that I give the command and the id in the event store are the same. When I debug however the id that is used to look up the aggregate from the event store is different. I am trying to find where in the call chain it is changing. No luck so far.

[jessemillerrev]

Ok. I solved this. I wrote a custom EventStore provider for CosmosDB which appeared to be working as expected and in fact was with the exception of one small thing.

public async Task<IReadOnlyCollection<ICommittedDomainEvent>> LoadCommittedEventsAsync(IIdentity id, int fromEventSequenceNumber, CancellationToken cancellationToken)
        {
            var events = new List<EventData>();

            var query = $"SELECT * FROM c WHERE c.StreamId = '{id.Value}'";
            await((IAdvancedEventStore)_eventStore).LoadEvents(query, e =>
            {
                events.AddRange(e.Where(x => (int)x.Version >= fromEventSequenceNumber));
                return Task.CompletedTask;
            }, cancellationToken);

            return Map(events);
        }

My code was checking for events whose x.Version was > fromEventSequenceNumber instead of >=. Once I followed it all the way through and I saw that the id's were correct but the events were not being returned in that lookup I saw that it is counting from 1 and my first event version number is 1 so it was never returning it. This problem had me stuck for far too long!