batch send

coronabytes · Feb 4, 2024 · eb3209f · eb3209f
1 parent d5e8821
commit eb3209f
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/Core.Email.Abstractions/ICoreEmail.cs b/Core.Email.Abstractions/ICoreEmail.cs
@@ -3,4 +3,5 @@
 public interface ICoreEmail
 {
     public Task<CoreEmailStatus> SendAsync(CoreEmailMessage message, CancellationToken cancellationToken = default);
+    public Task<IReadOnlyCollection<CoreEmailStatus>> SendAsync(List<CoreEmailMessage> message, CancellationToken cancellationToken = default);
 }
diff --git a/Core.Email/CoreEmailService.cs b/Core.Email/CoreEmailService.cs
@@ -31,6 +31,16 @@ public async Task<CoreEmailStatus> SendAsync(CoreEmailMessage message,
         return (await provider.SendBatchAsync([message], cancellationToken)).First();
     }
 
+    public async Task<IReadOnlyCollection<CoreEmailStatus>> SendAsync(List<CoreEmailMessage> messages, CancellationToken cancellationToken = default)
+    {
+        if (_defaultProvider == null)
+            throw new InvalidOperationException($"provider \"Default\" not found");
+
+        var res = await _defaultProvider.SendBatchAsync(messages, cancellationToken);
+
+        return res;
+    }
+
     protected override async Task ExecuteAsync(CancellationToken stoppingToken)
     {
         if (_persistence == null)