Browse Source

Marketing and Payment. Fixed async/await misuses

pull/574/head
Marusyk 6 years ago
parent
commit
c203f9cdcf
3 changed files with 8 additions and 8 deletions
  1. +2
    -2
      src/Services/Marketing/Marketing.API/Infrastructure/MarketingContextSeed.cs
  2. +4
    -4
      src/Services/Marketing/Marketing.API/Infrastructure/Repositories/MarketingDataRepository.cs
  3. +2
    -2
      src/Services/Payment/Payment.API/IntegrationEvents/EventHandling/OrderStatusChangedToStockConfirmedIntegrationEventHandler.cs

+ 2
- 2
src/Services/Marketing/Marketing.API/Infrastructure/MarketingContextSeed.cs View File

@ -11,11 +11,11 @@
public class MarketingContextSeed
{
public async Task SeedAsync(MarketingContext context,ILogger<MarketingContextSeed> logger,int retries = 3)
public Task SeedAsync(MarketingContext context,ILogger<MarketingContextSeed> logger,int retries = 3)
{
var policy = CreatePolicy(retries, logger, nameof(MarketingContextSeed));
await policy.ExecuteAsync(async () =>
return policy.ExecuteAsync(async () =>
{
if (!context.Campaigns.Any())
{


+ 4
- 4
src/Services/Marketing/Marketing.API/Infrastructure/Repositories/MarketingDataRepository.cs View File

@ -15,22 +15,22 @@ namespace Microsoft.eShopOnContainers.Services.Marketing.API.Infrastructure.Repo
_context = new MarketingReadDataContext(settings);
}
public async Task<MarketingData> GetAsync(string userId)
public Task<MarketingData> GetAsync(string userId)
{
var filter = Builders<MarketingData>.Filter.Eq("UserId", userId);
return await _context.MarketingData
return _context.MarketingData
.Find(filter)
.FirstOrDefaultAsync();
}
public async Task UpdateLocationAsync(MarketingData marketingData)
public Task UpdateLocationAsync(MarketingData marketingData)
{
var filter = Builders<MarketingData>.Filter.Eq("UserId", marketingData.UserId);
var update = Builders<MarketingData>.Update
.Set("Locations", marketingData.Locations)
.CurrentDate("UpdateDate");
await _context.MarketingData
return _context.MarketingData
.UpdateOneAsync(filter, update, new UpdateOptions { IsUpsert = true });
}
}


+ 2
- 2
src/Services/Payment/Payment.API/IntegrationEvents/EventHandling/OrderStatusChangedToStockConfirmedIntegrationEventHandler.cs View File

@ -19,7 +19,7 @@
_settings = settings.Value;
}
public async Task Handle(OrderStatusChangedToStockConfirmedIntegrationEvent @event)
public Task Handle(OrderStatusChangedToStockConfirmedIntegrationEvent @event)
{
IntegrationEvent orderPaymentIntegrationEvent;
@ -40,7 +40,7 @@
_eventBus.Publish(orderPaymentIntegrationEvent);
await Task.CompletedTask;
return Task.CompletedTask;
}
}
}

Loading…
Cancel
Save