feat: batch send async module

Author: drish

examples/batch_email_send_async.py

@@ -0,0 +1,62 @@
+import asyncio
+import os
+from typing import List
+
+import resend
+import resend.exceptions
+
+if not os.environ["RESEND_API_KEY"]:
+    raise EnvironmentError("RESEND_API_KEY is missing")
+
+# Set up async HTTP client
+resend.default_http_client = resend.HTTPXClient()
+
+
+async def main() -> None:
+    params: List[resend.Emails.SendParams] = [
+        {
+            "from": "onboarding@resend.dev",
+            "to": ["delivered@resend.dev"],
+            "subject": "hey",
+            "html": "<strong>hello, world!</strong>",
+        },
+        {
+            "from": "onboarding@resend.dev",
+            "to": ["delivered@resend.dev"],
+            "subject": "hello",
+            "html": "<strong>hello, world!</strong>",
+        },
+    ]
+
+    try:
+        # Send batch emails
+        print("sending without idempotency_key")
+        emails: resend.Batch.SendResponse = await resend.Batch.send_async(params)
+        for email in emails["data"]:
+            print(f"Email id: {email['id']}")
+    except resend.exceptions.ResendError as err:
+        print("Failed to send batch emails")
+        print(f"Error: {err}")
+        exit(1)
+
+    try:
+        # Send batch emails with idempotency_key
+        print("sending with idempotency_key")
+
+        options: resend.Batch.SendOptions = {
+            "idempotency_key": "af477dc78aa9fa91fff3b8c0d4a2e1a5",
+        }
+
+        e: resend.Batch.SendResponse = await resend.Batch.send_async(
+            params, options=options
+        )
+        for email in e["data"]:
+            print(f"Email id: {email['id']}")
+    except resend.exceptions.ResendError as err:
+        print("Failed to send batch emails")
+        print(f"Error: {err}")
+        exit(1)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

resend/emails/_batch.py

@@ -7,6 +7,12 @@
 from ._email import Email
 from ._emails import Emails
 
+# Async imports (optional - only available with pip install resend[async])
+try:
+    from resend.async_request import AsyncRequest
+except ImportError:
+    pass
+
 
 class _SendOptions(TypedDict):
     idempotency_key: NotRequired[str]
@@ -68,3 +74,28 @@ def send(
             options=cast(Dict[Any, Any], options),
         ).perform_with_content()
         return resp
+
+    @classmethod
+    async def send_async(
+        cls, params: List[Emails.SendParams], options: Optional[SendOptions] = None
+    ) -> SendResponse:
+        """
+        Trigger up to 100 batch emails at once (async).
+        see more: https://resend.com/docs/api-reference/emails/send-batch-emails
+
+        Args:
+            params (List[Emails.SendParams]): The list of emails to send
+            options (Optional[SendOptions]): Batch options, ie: idempotency_key
+
+        Returns:
+            SendResponse: A list of email objects
+        """
+        path = "/emails/batch"
+
+        resp = await AsyncRequest[_SendResponse](
+            path=path,
+            params=cast(List[Dict[Any, Any]], params),
+            verb="post",
+            options=cast(Dict[Any, Any], options),
+        ).perform_with_content()
+        return resp

tests/batch_emails_async_test.py

@@ -0,0 +1,96 @@
+from typing import List
+
+import resend
+from resend.exceptions import NoContentError
+from tests.conftest import ResendBaseTest
+
+# flake8: noqa
+
+
+class TestResendBatchSendAsync(ResendBaseTest):
+    async def test_batch_email_send_async(self) -> None:
+        self.set_mock_json(
+            {
+                "data": [
+                    {"id": "ae2014de-c168-4c61-8267-70d2662a1ce1"},
+                    {"id": "faccb7a5-8a28-4e9a-ac64-8da1cc3bc1cb"},
+                ]
+            }
+        )
+
+        params: List[resend.Emails.SendParams] = [
+            {
+                "from": "from@resend.dev",
+                "to": ["to@resend.dev"],
+                "subject": "hey",
+                "html": "<strong>hello, world!</strong>",
+            },
+            {
+                "from": "from@resend.dev",
+                "to": ["to@resend.dev"],
+                "subject": "hello",
+                "html": "<strong>hello, world!</strong>",
+            },
+        ]
+
+        emails: resend.Batch.SendResponse = await resend.Batch.send_async(params)
+        assert len(emails["data"]) == 2
+        assert emails["data"][0]["id"] == "ae2014de-c168-4c61-8267-70d2662a1ce1"
+        assert emails["data"][1]["id"] == "faccb7a5-8a28-4e9a-ac64-8da1cc3bc1cb"
+
+    async def test_batch_email_send_async_with_options(self) -> None:
+        self.set_mock_json(
+            {
+                "data": [
+                    {"id": "ae2014de-c168-4c61-8267-70d2662a1ce1"},
+                    {"id": "faccb7a5-8a28-4e9a-ac64-8da1cc3bc1cb"},
+                ]
+            }
+        )
+
+        params: List[resend.Emails.SendParams] = [
+            {
+                "from": "from@resend.dev",
+                "to": ["to@resend.dev"],
+                "subject": "hey",
+                "html": "<strong>hello, world!</strong>",
+            },
+            {
+                "from": "from@resend.dev",
+                "to": ["to@resend.dev"],
+                "subject": "hello",
+                "html": "<strong>hello, world!</strong>",
+            },
+        ]
+
+        options: resend.Batch.SendOptions = {
+            "idempotency_key": "af477dc78aa9fa91fff3b8c0d4a2e1a5",
+        }
+
+        emails: resend.Batch.SendResponse = await resend.Batch.send_async(
+            params, options=options
+        )
+        assert len(emails["data"]) == 2
+        assert emails["data"][0]["id"] == "ae2014de-c168-4c61-8267-70d2662a1ce1"
+        assert emails["data"][1]["id"] == "faccb7a5-8a28-4e9a-ac64-8da1cc3bc1cb"
+
+    async def test_should_send_batch_email_async_raise_exception_when_no_content(
+        self,
+    ) -> None:
+        self.set_mock_json(None)
+        params: List[resend.Emails.SendParams] = [
+            {
+                "from": "from@resend.dev",
+                "to": ["to@resend.dev"],
+                "subject": "hey",
+                "html": "<strong>hello, world!</strong>",
+            },
+            {
+                "from": "from@resend.dev",
+                "to": ["to@resend.dev"],
+                "subject": "hello",
+                "html": "<strong>hello, world!</strong>",
+            },
+        ]
+        with self.assertRaises(NoContentError):
+            _ = await resend.Batch.send_async(params)