azaion/annotations
1
0
Fork 0
mirror of https://github.com/azaion/annotations.git synced 2026-04-22 09:36:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix queue, fix ai email and role set

Browse Source
This commit is contained in:
Alex Bezdieniezhnykh
2025-03-06 19:06:09 +02:00
parent dc44340f67
commit 4e6624ee58
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Azaion.Common/Services/AnnotationService.cs
+2 -2
View File
@@ -82,7 +82,7 @@ public class AnnotationService : INotificationHandler<AnnotationsDeletedEvent>
return Task.CompletedTask; return Task.CompletedTask;
}, SaveTaskId, TimeSpan.FromSeconds(5), cancellationToken); }, SaveTaskId, TimeSpan.FromSeconds(5), cancellationToken);
if (msg.CreatedRole != RoleEnum.Operator) //Process only operator's messages if (msg.CreatedEmail == _authProvider.CurrentUser.Email) //Don't process messages by yourself
return; return;
await SaveAnnotationInner( await SaveAnnotationInner(
@@ -106,7 +106,7 @@ public class AnnotationService : INotificationHandler<AnnotationsDeletedEvent>
{ {
a.Time = TimeSpan.FromMilliseconds(a.Milliseconds); a.Time = TimeSpan.FromMilliseconds(a.Milliseconds);
return await SaveAnnotationInner(DateTime.Now, a.OriginalMediaName, a.Time, ".jpg", a.Detections.ToList(), return await SaveAnnotationInner(DateTime.Now, a.OriginalMediaName, a.Time, ".jpg", a.Detections.ToList(),
a.Source, new MemoryStream(a.Image), a.CreatedRole, a.CreatedEmail, generateThumbnail: true, cancellationToken); a.Source, new MemoryStream(a.Image), _authProvider.CurrentUser.Role, _authProvider.CurrentUser.Email, generateThumbnail: true, cancellationToken);
} }
//Manual //Manual
Azaion.Common/Services/FailsafeProducer.cs
+2 -1
View File
@@ -76,8 +76,9 @@ public class FailsafeAnnotationsProducer
await _annotationConfirmProducer.Send(validatedMessages, CompressionType.Gzip); await _annotationConfirmProducer.Send(validatedMessages, CompressionType.Gzip);
await _dbFactory.Run(async db => await _dbFactory.Run(async db =>
await db.AnnotationsQueue.DeleteAsync(aq => messagesChunk.Any(x => aq.Name == x.OriginalMediaName), token: cancellationToken)); await db.AnnotationsQueue.DeleteAsync(aq => messagesChunk.Any(x => aq.Name == x.Name), token: cancellationToken));
sent = true; sent = true;
_dbFactory.SaveToDisk();
} }
catch (Exception e) catch (Exception e)
{ {