feat: add contact imports endpoints

examples/contact_imports.py

@@ -0,0 +1,43 @@
+import os
+
+import resend
+
+if not os.environ["RESEND_API_KEY"]:
+    raise EnvironmentError("RESEND_API_KEY is missing")
+
+file_content = b"Email,First Name,Last Name,Plan\nsteve@example.com,Steve,Wozniak,pro"
+
+create_params: resend.ContactImports.CreateParams = {
+    "file": file_content,
+    "column_map": {
+        "email": "Email",
+        "first_name": "First Name",
+        "last_name": "Last Name",
+        "properties": {
+            "plan": {
+                "column": "Plan",
+                "type": "string",
+            },
+        },
+    },
+    "on_conflict": "upsert",
+    "segments": ["60a2ac5e-0774-456e-817d-ebf40f6dba31"],
+}
+
+import_response: resend.ContactImports.CreateContactImportResponse = (
+    resend.Contacts.Imports.create(create_params)
+)
+print("Created contact import with ID: {}".format(import_response["id"]))
+print(import_response)
+
+contact_import: resend.ContactImport = resend.Contacts.Imports.get(import_response["id"])
+print("Retrieved contact import")
+print(contact_import)
+
+list_response: resend.ContactImports.ListContactImportsResponse = (
+    resend.Contacts.Imports.list()
+)
+print(f"Found {len(list_response['data'])} imports")
+print(f"Has more: {list_response['has_more']}")
+for item in list_response["data"]:
+    print(item)

examples/with_custom_http_client.py

@@ -21,6 +21,8 @@ def request(
         url: str,
         headers: Mapping[str, str],
         json: Optional[Union[Dict[str, Any], List[Any]]] = None,
+        files: Optional[Dict[str, Any]] = None,
+        data: Optional[Dict[str, str]] = None,
     ) -> Tuple[bytes, int, Dict[str, str]]:
         print(f"[HTTP] {method.upper()} {url} with timeout={self.timeout}")
         try:

resend/__init__.py

@@ -22,6 +22,8 @@
 from .contacts._contact_topic import ContactTopic, TopicSubscriptionUpdate
 from .contacts._contacts import Contacts
 from .contacts._topics import Topics as ContactsTopics
+from .contacts.imports._contact_import import ContactImport, ContactImportCounts
+from .contacts.imports._contact_imports import ContactImports
 from .contacts.segments._contact_segment import ContactSegment
 from .contacts.segments._contact_segments import ContactSegments
 from .domains._domain import Domain
@@ -83,6 +85,7 @@
     "Audiences",
     "Automations",
     "Contacts",
+    "ContactImports",
     "ContactProperties",
     "Broadcasts",
     "Events",
@@ -110,6 +113,8 @@
     "EventSchema",
     "EventSchemaFieldType",
     "Contact",
+    "ContactImport",
+    "ContactImportCounts",
     "ContactSegment",
     "ContactSegments",
     "ContactProperty",

resend/async_request.py

@@ -24,11 +24,15 @@ def __init__(
         params: ParamsType,
         verb: RequestVerb,
         options: Optional[Dict[str, Any]] = None,
+        files: Optional[Dict[str, Any]] = None,
+        data: Optional[Dict[str, str]] = None,
     ):
         self.path = path
         self.params = params
         self.verb = verb
         self.options = options
+        self.files = files
+        self.data = data
         self._response_headers: Dict[str, str] = {}
 
     async def perform(self) -> Union[T, None]:
@@ -102,6 +106,8 @@ async def make_request(self, url: str) -> Union[Dict[str, Any], List[Any]]:
                 url=url,
                 headers=headers,
                 json=json_params,
+                files=self.files,
+                data=self.data,
             )
 
         # Safety net around the HTTP Client

resend/contacts/__init__.py

@@ -0,0 +1,5 @@
+from .imports._contact_import import ContactImport as ContactImportObj
+from .imports._contact_import import ContactImportCounts
+from .imports._contact_imports import ContactImports
+
+__all__ = ["ContactImports", "ContactImportObj", "ContactImportCounts"]

resend/contacts/_contacts.py

@@ -8,6 +8,7 @@
 
 from ._contact import Contact
 from ._topics import Topics
+from .imports._contact_imports import ContactImports
 from .segments._contact_segments import ContactSegments
 
 # Async imports (optional - only available with pip install resend[async])
@@ -21,6 +22,7 @@ class Contacts:
     # Sub-API for managing contact-segment associations
     Segments = ContactSegments
     Topics = Topics
+    Imports = ContactImports
 
     class RemoveContactResponse(BaseResponse):
         """

resend/contacts/imports/__init__.py

@@ -0,0 +1,4 @@
+from ._contact_import import ContactImport, ContactImportCounts
+from ._contact_imports import ContactImports
+
+__all__ = ["ContactImports", "ContactImport", "ContactImportCounts"]

resend/contacts/imports/_contact_import.py

@@ -0,0 +1,41 @@
+from typing import Optional
+
+from resend._base_response import BaseResponse
+
+
+class ContactImportCounts(BaseResponse):
+    """
+    ContactImportCounts holds row-level statistics for a contact import.
+
+    Attributes:
+        total (int): Total number of rows processed.
+        created (int): Number of contacts created.
+        updated (int): Number of contacts updated.
+        skipped (int): Number of rows skipped.
+        failed (int): Number of rows that failed.
+    """
+
+    total: int
+    created: int
+    updated: int
+    skipped: int
+    failed: int
+
+
+class ContactImport(BaseResponse):
+    """
+    ContactImport represents a contact import job.
+
+    Attributes:
+        object (str): Always 'contact_import'.
+        id (str): Unique identifier for the contact import.
+        status (str): 'queued', 'in_progress', 'completed', or 'failed'.
+        created_at (str): ISO 8601 timestamp of when the import was created.
+        counts (ContactImportCounts): Row-level import statistics (present when status is completed or failed).
+    """
+
+    object: str
+    id: str
+    status: str
+    created_at: str
+    counts: Optional[ContactImportCounts]