Skip to content

Commit 0670355

Browse files
committed
Save post info and payload info concurrently.
1 parent 772782e commit 0670355

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

src/Exceptionless.Core/Services/EventPostService.cs

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -29,16 +29,20 @@ public async Task<string> EnqueueAsync(EventPost data, Stream stream, Cancellati
2929
? GetArchivePath(SystemClock.UtcNow, data.ProjectId, $"{Guid.NewGuid():N}.json")
3030
: Path.Combine("q", $"{Guid.NewGuid():N}.json");
3131

32-
if (!await _storage.SaveFileAsync(Path.ChangeExtension(data.FilePath, ".payload"), stream, cancellationToken).AnyContext()) {
32+
var saveTask = _storage.SaveObjectAsync(data.FilePath, (EventPostInfo)data, cancellationToken);
33+
var savePayloadTask = _storage.SaveFileAsync(Path.ChangeExtension(data.FilePath, ".payload"), stream, cancellationToken);
34+
35+
if (!await saveTask.AnyContext()) {
3336
using (_logger.BeginScope(new ExceptionlessState().Organization(data.OrganizationId).Property(nameof(EventPostInfo), data)))
34-
_logger.LogError("Unable to save event post payload");
37+
_logger.LogError("Unable to save event post info");
3538

39+
await savePayloadTask.AnyContext();
3640
return null;
3741
}
3842

39-
if (!await _storage.SaveObjectAsync(data.FilePath, (EventPostInfo)data, cancellationToken).AnyContext()) {
43+
if (!await savePayloadTask.AnyContext()) {
4044
using (_logger.BeginScope(new ExceptionlessState().Organization(data.OrganizationId).Property(nameof(EventPostInfo), data)))
41-
_logger.LogError("Unable to save event post info");
45+
_logger.LogError("Unable to save event post payload");
4246

4347
return null;
4448
}

0 commit comments

Comments
 (0)