Browse Source

Add isDraft control to background services

pull/79/head
berkansasmaz 5 years ago
parent
commit
a9c27b2170
No known key found for this signature in database GPG Key ID: 884D815C3F32BE00
  1. 6
      src/EventHub.BackgroundServices/Events/EventReminderNotifier.cs
  2. 4
      src/EventHub.BackgroundServices/Events/EventReminderWorker.cs
  3. 6
      src/EventHub.BackgroundServices/Events/EventTimingChangeNotifier.cs
  4. 4
      src/EventHub.BackgroundServices/Events/EventTimingChangeWorker.cs
  5. 4
      src/EventHub.BackgroundServices/Events/NewEventNotifier.cs
  6. 4
      src/EventHub.BackgroundServices/Events/NewEventWorker.cs

6
src/EventHub.BackgroundServices/Events/EventReminderNotifier.cs

@ -37,7 +37,7 @@ namespace EventHub.Events
public async Task NotifyAsync(Event @event)
{
if (@event is null || @event.IsRemindingEmailSent)
if (@event is null || @event.IsRemindingEmailSent || !@event.IsDraft)
{
return;
}
@ -47,7 +47,7 @@ namespace EventHub.Events
var userQuery = from eventRegistration in registrationQueryable
join user in userQueryable on eventRegistration.UserId equals user.Id
where eventRegistration.EventId == @event.Id
where eventRegistration.EventId == @event.Id && !@event.IsDraft
select user;
var users = await _asyncExecuter.ToListAsync(userQuery);
@ -71,4 +71,4 @@ namespace EventHub.Events
}
}
}
}
}

4
src/EventHub.BackgroundServices/Events/EventReminderWorker.cs

@ -32,7 +32,7 @@ namespace EventHub.Events
var queryable = await eventRepository.GetQueryableAsync();
var query = queryable.Where(x =>
x.IsRemindingEmailSent == false &&
x.StartTime <= thirtyMinutesLater
x.StartTime <= thirtyMinutesLater && !x.IsDraft
);
var events = await asyncExecuter.ToListAsync(query);
@ -56,4 +56,4 @@ namespace EventHub.Events
}
}
}
}
}

6
src/EventHub.BackgroundServices/Events/EventTimingChangeNotifier.cs

@ -37,7 +37,7 @@ namespace EventHub.Events
public async Task NotifyAsync(Event @event)
{
if (@event is null || @event.IsTimingChangeEmailSent)
if (@event is null || @event.IsTimingChangeEmailSent || !@event.IsDraft)
{
return;
}
@ -47,7 +47,7 @@ namespace EventHub.Events
var userQuery = from eventRegistration in registrationQueryable
join user in userQueryable on eventRegistration.UserId equals user.Id
where eventRegistration.EventId == @event.Id
where eventRegistration.EventId == @event.Id && !@event.IsDraft
select user;
var users = await _asyncExecuter.ToListAsync(userQuery);
@ -71,4 +71,4 @@ namespace EventHub.Events
}
}
}
}
}

4
src/EventHub.BackgroundServices/Events/EventTimingChangeWorker.cs

@ -31,7 +31,7 @@ namespace EventHub.Events
var asyncExecuter = workerContext.ServiceProvider.GetRequiredService<IAsyncQueryableExecuter>();
var queryable = await eventRepository.GetQueryableAsync();
var query = queryable.Where(x => !x.IsTimingChangeEmailSent);
var query = queryable.Where(x => !x.IsTimingChangeEmailSent && !x.IsDraft);
var events = await asyncExecuter.ToListAsync(query);
@ -51,4 +51,4 @@ namespace EventHub.Events
}
}
}
}
}

4
src/EventHub.BackgroundServices/Events/NewEventNotifier.cs

@ -37,7 +37,7 @@ namespace EventHub.Events
public async Task NotifyAsync(Event @event)
{
if (@event is null || @event.IsEmailSentToMembers)
if (@event is null || @event.IsEmailSentToMembers || !@event.IsDraft)
{
return;
}
@ -71,4 +71,4 @@ namespace EventHub.Events
}
}
}
}
}

4
src/EventHub.BackgroundServices/Events/NewEventWorker.cs

@ -34,7 +34,7 @@ namespace EventHub.Events
var queryable = await eventRepository.GetQueryableAsync();
var newEvents = await asyncExecuter.ToListAsync(
queryable.Where(x => x.IsEmailSentToMembers == false)
queryable.Where(x => x.IsEmailSentToMembers == false && !x.IsDraft)
);
var fiveMinutesLater = clock.Now.AddMinutes(5);
@ -57,4 +57,4 @@ namespace EventHub.Events
}
}
}
}
}

Loading…
Cancel
Save