feat: contacts async module

Author: drish

examples/contacts_async.py

@@ -0,0 +1,73 @@
+import asyncio
+import os
+from typing import List
+
+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()
+
+# replace with some audience id
+audience_id: str = "ca4e37c5-a82a-4199-a3b8-bf912a6472aa"
+
+
+async def main() -> None:
+    create_params: resend.Contacts.CreateParams = {
+        "audience_id": audience_id,
+        "email": "sw@exmple.com",
+        "first_name": "Steve",
+        "last_name": "Wozniak",
+        "unsubscribed": False,
+    }
+
+    contact: resend.Contact = await resend.Contacts.create_async(create_params)
+    print("Created contact !")
+    print(contact)
+
+    update_params: resend.Contacts.UpdateParams = {
+        "audience_id": audience_id,
+        "id": contact["id"],
+        "unsubscribed": False,
+        "first_name": "Steve (Async)",
+    }
+
+    updated: resend.Contact = await resend.Contacts.update_async(update_params)
+    print("updated contact !")
+    print(updated)
+
+    cont_by_id: resend.Contact = await resend.Contacts.get_async(
+        id=contact["id"], audience_id=audience_id
+    )
+    print("Retrieved contact by ID")
+    print(cont_by_id)
+
+    cont_by_email: resend.Contact = await resend.Contacts.get_async(
+        email="sw@exmple.com", audience_id=audience_id
+    )
+    print("Retrieved contact by Email")
+    print(cont_by_email)
+
+    contacts: resend.Contacts.ListResponse = await resend.Contacts.list_async(
+        audience_id=audience_id
+    )
+    print("List of contacts")
+    for contact in contacts["data"]:
+        print(contact)
+
+    # remove by email
+    rmed = await resend.Contacts.remove_async(
+        audience_id=audience_id, email=contact["email"]
+    )
+
+    # remove by id
+    # rmed: resend.Contact = await resend.Contacts.remove_async(audience_id=audience_id, id=cont["id"])
+
+    print(f"Removed contact")
+    print(rmed)
+
+
+if __name__ == "__main__":
+    asyncio.run(main())

resend/contacts/_contacts.py

@@ -6,6 +6,12 @@
 
 from ._contact import Contact
 
+# Async imports (optional - only available with pip install resend[async])
+try:
+    from resend.async_request import AsyncRequest
+except ImportError:
+    pass
+
 
 class _ListResponse(TypedDict):
     data: List[Contact]
@@ -182,3 +188,114 @@ def remove(
             path=path, params={}, verb="delete"
         ).perform_with_content()
         return resp
+
+    @classmethod
+    async def create_async(cls, params: CreateParams) -> Contact:
+        """
+        Create a new contact (async).
+        see more: https://resend.com/docs/api-reference/contacts/create-contact
+
+        Args:
+            params (CreateParams): The contact creation parameters
+
+        Returns:
+            Contact: The new contact object
+        """
+        path = f"/audiences/{params['audience_id']}/contacts"
+        resp = await AsyncRequest[Contact](
+            path=path, params=cast(Dict[Any, Any], params), verb="post"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def update_async(cls, params: UpdateParams) -> Contact:
+        """
+        Update an existing contact (async).
+        see more: https://resend.com/docs/api-reference/contacts/update-contact
+
+        Args:
+            params (UpdateParams): The contact update parameters
+
+        Returns:
+            Contact: The updated contact object
+        """
+        if params.get("id") is None and params.get("email") is None:
+            raise ValueError("id or email must be provided")
+
+        val = params.get("id") if params.get("id") is not None else params.get("email")
+
+        path = f"/audiences/{params['audience_id']}/contacts/{val}"
+        resp = await AsyncRequest[Contact](
+            path=path, params=cast(Dict[Any, Any], params), verb="patch"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def list_async(cls, audience_id: str) -> ListResponse:
+        """
+        List all contacts for the provided audience (async).
+        see more: https://resend.com/docs/api-reference/contacts/list-contacts
+
+        Args:
+            audience_id (str): The audience ID
+
+        Returns:
+            ListResponse: A list of contact objects
+        """
+        path = f"/audiences/{audience_id}/contacts"
+        resp = await AsyncRequest[_ListResponse](
+            path=path, params={}, verb="get"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def get_async(
+        cls, audience_id: str, id: Optional[str] = None, email: Optional[str] = None
+    ) -> Contact:
+        """
+        Get a contact (async).
+        see more: https://resend.com/docs/api-reference/contacts/get-contact
+
+        Args:
+            audience_id (str): The audience ID
+            id (Optional[str]): The contact ID
+            email (Optional[str]): The contact email
+
+        Returns:
+            Contact: The contact object
+        """
+        contact = email if id is None else id
+        if contact is None:
+            raise ValueError("id or email must be provided")
+
+        path = f"/audiences/{audience_id}/contacts/{contact}"
+        resp = await AsyncRequest[Contact](
+            path=path, params={}, verb="get"
+        ).perform_with_content()
+        return resp
+
+    @classmethod
+    async def remove_async(
+        cls, audience_id: str, id: Optional[str] = None, email: Optional[str] = None
+    ) -> Contact:
+        """
+        Remove a contact by ID or by Email (async).
+        see more: https://resend.com/docs/api-reference/contacts/delete-contact
+
+        Args:
+            audience_id (str): The audience ID
+            id (Optional[str]): The contact ID
+            email (Optional[str]): The contact email
+
+        Returns:
+            Contact: The removed contact object
+        """
+        contact = email if id is None else id
+        if contact is None:
+            raise ValueError("id or email must be provided")
+        path = f"/audiences/{audience_id}/contacts/{contact}"
+
+        resp = await AsyncRequest[Contact](
+            path=path, params={}, verb="delete"
+        ).perform_with_content()
+        return resp