Skip to content

Commit

Permalink
Publish events #13
Browse files Browse the repository at this point in the history
  • Loading branch information
marinasundstrom committed Apr 10, 2024
1 parent 7541f96 commit 405d812
Showing 1 changed file with 12 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,18 @@ public async Task<UserDto> Handle(CreateUserCommand request, CancellationToken c

await eventPublisher.PublishEvent(new UserCreated(user.Id, user.Tenant!.Id, user.Organizations.First()!.Id));

await Task.Delay(600);

var organizationUsers = await context.OrganizationUsers
.AsNoTracking()
.Where(x => x.UserId == user.Id)
.ToListAsync(cancellationToken);

foreach (var organizationUser in organizationUsers)
{
await eventPublisher.PublishEvent(new OrganizationUserAdded(organizationUser.TenantId, organizationUser.OrganizationId, organizationUser.UserId));
}

return user.ToDto();
}
}
Expand Down

0 comments on commit 405d812

Please sign in to comment.