feat: domains module async

Author: drish

examples/domains_async.py

@@ -0,0 +1,54 @@
+import asyncio
+import os
+
+import resend
+
+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:
+    create_params: resend.Domains.CreateParams = {
+        "name": "example.com",
+        "region": "us-east-1",
+        "custom_return_path": "outbound",
+    }
+    domain: resend.Domain = await resend.Domains.create_async(params=create_params)
+    print(domain)
+
+    retrieved: resend.Domain = await resend.Domains.get_async(domain_id=domain["id"])
+    if retrieved["records"] is not None:
+        for record in retrieved["records"]:
+            print(record)
+
+    update_params: resend.Domains.UpdateParams = {
+        "id": domain["id"],
+        "open_tracking": True,
+        "click_tracking": True,
+        "tls": "enforced",
+    }
+
+    updated_domain: resend.Domain = await resend.Domains.update_async(update_params)
+    print(f"Updated domain: {updated_domain['id']}")
+
+    domains: resend.Domains.ListResponse = await resend.Domains.list_async()
+    if not domains:
+        print("No domains found")
+    for domain in domains["data"]:
+        print(domain)
+
+    verified_domain: resend.Domain = await resend.Domains.verify_async(
+        domain_id=domain["id"]
+    )
+    print(f"Verified")
+    print(verified_domain)
+
+    rm_domain: resend.Domain = await resend.Domains.remove_async(domain_id=domain["id"])
+    print(rm_domain)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

resend/domains/_domains.py

@@ -5,6 +5,12 @@
 from resend import request
 from resend.domains._domain import Domain
 
+# Async imports (optional - only available with pip install resend[async])
+try:
+    from resend.async_request import AsyncRequest
+except ImportError:
+    pass
+
 TlsOptions = Literal["enforced", "opportunistic"]
 
 
@@ -171,3 +177,108 @@ def verify(cls, domain_id: str) -> Domain:
             path=path, params={}, verb="post"
         ).perform_with_content()
         return resp
+
+    @classmethod
+    async def create_async(cls, params: CreateParams) -> Domain:
+        """
+        Create a domain through the Resend Email API (async).
+        see more: https://resend.com/docs/api-reference/domains/create-domain
+
+        Args:
+            params (CreateParams): The domain creation parameters
+
+        Returns:
+            Domain: The new domain object
+        """
+        path = "/domains"
+        resp = await AsyncRequest[Domain](
+            path=path, params=cast(Dict[Any, Any], params), verb="post"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def update_async(cls, params: UpdateParams) -> Domain:
+        """
+        Update an existing domain (async).
+        see more: https://resend.com/docs/api-reference/domains/update-domain
+
+        Args:
+            params (UpdateParams): The domain update parameters
+
+        Returns:
+            Domain: The updated domain object
+        """
+        path = f"/domains/{params['id']}"
+        resp = await AsyncRequest[Domain](
+            path=path, params=cast(Dict[Any, Any], params), verb="patch"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def get_async(cls, domain_id: str) -> Domain:
+        """
+        Retrieve a single domain for the authenticated user (async).
+        see more: https://resend.com/docs/api-reference/domains/get-domain
+
+        Args:
+            domain_id (str): The domain ID
+
+        Returns:
+            Domain: The domain object
+        """
+        path = f"/domains/{domain_id}"
+        resp = await AsyncRequest[Domain](
+            path=path, params={}, verb="get"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def list_async(cls) -> ListResponse:
+        """
+        Retrieve a list of domains for the authenticated user (async).
+        see more: https://resend.com/docs/api-reference/domains/list-domains
+
+        Returns:
+            ListResponse: A list of domain objects
+        """
+        path = "/domains"
+        resp = await AsyncRequest[_ListResponse](
+            path=path, params={}, verb="get"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def remove_async(cls, domain_id: str) -> Domain:
+        """
+        Remove an existing domain (async).
+        see more: https://resend.com/docs/api-reference/domains/delete-domain
+
+        Args:
+            domain_id (str): The domain ID
+
+        Returns:
+            Domain: The removed domain object
+        """
+        path = f"/domains/{domain_id}"
+        resp = await AsyncRequest[Domain](
+            path=path, params={}, verb="delete"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def verify_async(cls, domain_id: str) -> Domain:
+        """
+        Verify an existing domain (async).
+        see more: https://resend.com/docs/api-reference/domains/verify-domain
+
+        Args:
+            domain_id (str): The domain ID
+
+        Returns:
+            Domain: The verified domain object
+        """
+        path = f"/domains/{domain_id}/verify"
+        resp = await AsyncRequest[Domain](
+            path=path, params={}, verb="post"
+        ).perform_with_content()
+        return resp