chore(api): update composite API spec

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
 configured_endpoints: 1993
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-f0c3645a37032449aee08f0bfc7f373ce8ebe0bdaa2c6964b4c9328f712bbae9.yml
-openapi_spec_hash: ab3368c4c9aa05dff33b51f542fb7786
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/cloudflare%2Fcloudflare-0d52971b01c25a36f6fcfb4f73b19445b8fd83818763a6fd66f5616b49f6dd81.yml
+openapi_spec_hash: c389912f9fa531e76127e9d8a2500f22
 config_hash: ef319a79ff462ce842b47460e889e37b

src/cloudflare/resources/cloudforce_one/threat_events/threat_events.py

@@ -196,6 +196,7 @@ def create(
         tags: SequenceNotStr[str] | Omit = omit,
         target_country: str | Omit = omit,
         target_industry: str | Omit = omit,
+        uuid: str | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -215,6 +216,9 @@ def create(
           indicators: Array of indicators for this event. Supports multiple indicators per event for
               complex scenarios.
 
+          uuid: Optional UUID for the event. Only used when preserveUuid=true in bulk create.
+              Must be a valid UUID format.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -245,6 +249,7 @@ def create(
                     "tags": tags,
                     "target_country": target_country,
                     "target_industry": target_industry,
+                    "uuid": uuid,
                 },
                 threat_event_create_params.ThreatEventCreateParams,
             ),
@@ -260,6 +265,7 @@ def list(
         account_id: str,
         dataset_id: SequenceNotStr[str] | Omit = omit,
         force_refresh: bool | Omit = omit,
+        format: Literal["json", "stix2"] | Omit = omit,
         order: Literal["asc", "desc"] | Omit = omit,
         order_by: str | Omit = omit,
         page: float | Omit = omit,
@@ -303,6 +309,7 @@ def list(
                     {
                         "dataset_id": dataset_id,
                         "force_refresh": force_refresh,
+                        "format": format,
                         "order": order,
                         "order_by": order_by,
                         "page": page,
@@ -365,6 +372,7 @@ def bulk_create(
         account_id: str,
         data: Iterable[threat_event_bulk_create_params.Data],
         dataset_id: str,
+        preserve_uuid: bool | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -382,6 +390,10 @@ def bulk_create(
         Args:
           account_id: Account ID.
 
+          preserve_uuid: When true, use provided UUIDs from event data instead of generating new ones.
+              Used for migration scenarios where original UUIDs must be preserved. Duplicate
+              UUIDs will be skipped.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -398,6 +410,7 @@ def bulk_create(
                 {
                     "data": data,
                     "dataset_id": dataset_id,
+                    "preserve_uuid": preserve_uuid,
                 },
                 threat_event_bulk_create_params.ThreatEventBulkCreateParams,
             ),
@@ -604,6 +617,7 @@ async def create(
         tags: SequenceNotStr[str] | Omit = omit,
         target_country: str | Omit = omit,
         target_industry: str | Omit = omit,
+        uuid: str | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -623,6 +637,9 @@ async def create(
           indicators: Array of indicators for this event. Supports multiple indicators per event for
               complex scenarios.
 
+          uuid: Optional UUID for the event. Only used when preserveUuid=true in bulk create.
+              Must be a valid UUID format.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -653,6 +670,7 @@ async def create(
                     "tags": tags,
                     "target_country": target_country,
                     "target_industry": target_industry,
+                    "uuid": uuid,
                 },
                 threat_event_create_params.ThreatEventCreateParams,
             ),
@@ -668,6 +686,7 @@ async def list(
         account_id: str,
         dataset_id: SequenceNotStr[str] | Omit = omit,
         force_refresh: bool | Omit = omit,
+        format: Literal["json", "stix2"] | Omit = omit,
         order: Literal["asc", "desc"] | Omit = omit,
         order_by: str | Omit = omit,
         page: float | Omit = omit,
@@ -711,6 +730,7 @@ async def list(
                     {
                         "dataset_id": dataset_id,
                         "force_refresh": force_refresh,
+                        "format": format,
                         "order": order,
                         "order_by": order_by,
                         "page": page,
@@ -773,6 +793,7 @@ async def bulk_create(
         account_id: str,
         data: Iterable[threat_event_bulk_create_params.Data],
         dataset_id: str,
+        preserve_uuid: bool | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -790,6 +811,10 @@ async def bulk_create(
         Args:
           account_id: Account ID.
 
+          preserve_uuid: When true, use provided UUIDs from event data instead of generating new ones.
+              Used for migration scenarios where original UUIDs must be preserved. Duplicate
+              UUIDs will be skipped.
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -806,6 +831,7 @@ async def bulk_create(
                 {
                     "data": data,
                     "dataset_id": dataset_id,
+                    "preserve_uuid": preserve_uuid,
                 },
                 threat_event_bulk_create_params.ThreatEventBulkCreateParams,
             ),

src/cloudflare/resources/email_security/investigate/investigate.py

@@ -160,8 +160,11 @@ def list(
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
     ) -> SyncV4PagePaginationArray[InvestigateListResponse]:
-        """
-        Returns information for each email that matches the search parameter(s).
+        """Returns information for each email that matches the search parameter(s).
+
+        If the
+        search takes too long, the endpoint returns 202 with a Location header pointing
+        to a polling endpoint where results can be retrieved once ready.
 
         Args:
           account_id: Account Identifier
@@ -374,8 +377,11 @@ def list(
         extra_body: Body | None = None,
         timeout: float | httpx.Timeout | None | NotGiven = not_given,
     ) -> AsyncPaginator[InvestigateListResponse, AsyncV4PagePaginationArray[InvestigateListResponse]]:
-        """
-        Returns information for each email that matches the search parameter(s).
+        """Returns information for each email that matches the search parameter(s).
+
+        If the
+        search takes too long, the endpoint returns 202 with a Location header pointing
+        to a polling endpoint where results can be retrieved once ready.
 
         Args:
           account_id: Account Identifier

src/cloudflare/resources/r2_data_catalog/maintenance_configs.py

@@ -51,6 +51,7 @@ def update(
         *,
         account_id: str,
         compaction: maintenance_config_update_params.Compaction | Omit = omit,
+        snapshot_expiration: maintenance_config_update_params.SnapshotExpiration | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -70,6 +71,8 @@ def update(
 
           compaction: Updates compaction configuration (all fields optional).
 
+          snapshot_expiration: Updates snapshot expiration configuration (all fields optional).
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -85,7 +88,11 @@ def update(
         return self._post(
             f"/accounts/{account_id}/r2-catalog/{bucket_name}/maintenance-configs",
             body=maybe_transform(
-                {"compaction": compaction}, maintenance_config_update_params.MaintenanceConfigUpdateParams
+                {
+                    "compaction": compaction,
+                    "snapshot_expiration": snapshot_expiration,
+                },
+                maintenance_config_update_params.MaintenanceConfigUpdateParams,
             ),
             options=make_request_options(
                 extra_headers=extra_headers,
@@ -171,6 +178,7 @@ async def update(
         *,
         account_id: str,
         compaction: maintenance_config_update_params.Compaction | Omit = omit,
+        snapshot_expiration: maintenance_config_update_params.SnapshotExpiration | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -190,6 +198,8 @@ async def update(
 
           compaction: Updates compaction configuration (all fields optional).
 
+          snapshot_expiration: Updates snapshot expiration configuration (all fields optional).
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -205,7 +215,11 @@ async def update(
         return await self._post(
             f"/accounts/{account_id}/r2-catalog/{bucket_name}/maintenance-configs",
             body=await async_maybe_transform(
-                {"compaction": compaction}, maintenance_config_update_params.MaintenanceConfigUpdateParams
+                {
+                    "compaction": compaction,
+                    "snapshot_expiration": snapshot_expiration,
+                },
+                maintenance_config_update_params.MaintenanceConfigUpdateParams,
             ),
             options=make_request_options(
                 extra_headers=extra_headers,

src/cloudflare/resources/r2_data_catalog/namespaces/tables/maintenance_configs.py

@@ -55,6 +55,7 @@ def update(
         bucket_name: str,
         namespace: str,
         compaction: maintenance_config_update_params.Compaction | Omit = omit,
+        snapshot_expiration: maintenance_config_update_params.SnapshotExpiration | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -74,6 +75,8 @@ def update(
 
           compaction: Updates compaction configuration (all fields optional).
 
+          snapshot_expiration: Updates snapshot expiration configuration (all fields optional).
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -93,7 +96,11 @@ def update(
         return self._post(
             f"/accounts/{account_id}/r2-catalog/{bucket_name}/namespaces/{namespace}/tables/{table_name}/maintenance-configs",
             body=maybe_transform(
-                {"compaction": compaction}, maintenance_config_update_params.MaintenanceConfigUpdateParams
+                {
+                    "compaction": compaction,
+                    "snapshot_expiration": snapshot_expiration,
+                },
+                maintenance_config_update_params.MaintenanceConfigUpdateParams,
             ),
             options=make_request_options(
                 extra_headers=extra_headers,
@@ -187,6 +194,7 @@ async def update(
         bucket_name: str,
         namespace: str,
         compaction: maintenance_config_update_params.Compaction | Omit = omit,
+        snapshot_expiration: maintenance_config_update_params.SnapshotExpiration | Omit = omit,
         # Use the following arguments if you need to pass additional parameters to the API that aren't available via kwargs.
         # The extra values given here take precedence over values defined on the client or passed to this method.
         extra_headers: Headers | None = None,
@@ -206,6 +214,8 @@ async def update(
 
           compaction: Updates compaction configuration (all fields optional).
 
+          snapshot_expiration: Updates snapshot expiration configuration (all fields optional).
+
           extra_headers: Send extra headers
 
           extra_query: Add additional query parameters to the request
@@ -225,7 +235,11 @@ async def update(
         return await self._post(
             f"/accounts/{account_id}/r2-catalog/{bucket_name}/namespaces/{namespace}/tables/{table_name}/maintenance-configs",
             body=await async_maybe_transform(
-                {"compaction": compaction}, maintenance_config_update_params.MaintenanceConfigUpdateParams
+                {
+                    "compaction": compaction,
+                    "snapshot_expiration": snapshot_expiration,
+                },
+                maintenance_config_update_params.MaintenanceConfigUpdateParams,
             ),
             options=make_request_options(
                 extra_headers=extra_headers,

src/cloudflare/types/cloudforce_one/threat_event_bulk_create_params.py

@@ -20,6 +20,13 @@ class ThreatEventBulkCreateParams(TypedDict, total=False):
 
     dataset_id: Required[Annotated[str, PropertyInfo(alias="datasetId")]]
 
+    preserve_uuid: Annotated[bool, PropertyInfo(alias="preserveUuid")]
+    """When true, use provided UUIDs from event data instead of generating new ones.
+
+    Used for migration scenarios where original UUIDs must be preserved. Duplicate
+    UUIDs will be skipped.
+    """
+
 
 class DataRaw(TypedDict, total=False):
     data: Required[Optional[Dict[str, object]]]
@@ -73,3 +80,9 @@ class Data(TypedDict, total=False):
     target_country: Annotated[str, PropertyInfo(alias="targetCountry")]
 
     target_industry: Annotated[str, PropertyInfo(alias="targetIndustry")]
+
+    uuid: str
+    """Optional UUID for the event.
+
+    Only used when preserveUuid=true in bulk create. Must be a valid UUID format.
+    """

src/cloudflare/types/cloudforce_one/threat_event_bulk_create_response.py

@@ -32,6 +32,9 @@ class ThreatEventBulkCreateResponse(BaseModel):
     queued_indicators_count: float = FieldInfo(alias="queuedIndicatorsCount")
     """Number of indicators queued for async processing"""
 
+    skipped_events_count: float = FieldInfo(alias="skippedEventsCount")
+    """Number of events skipped due to duplicate UUID (only when preserveUuid=true)"""
+
     create_bulk_events_request_id: Optional[str] = FieldInfo(alias="createBulkEventsRequestId", default=None)
     """Correlation ID for async indicator processing"""
 

src/cloudflare/types/cloudforce_one/threat_event_create_params.py

@@ -52,6 +52,12 @@ class ThreatEventCreateParams(TypedDict, total=False):
 
     target_industry: Annotated[str, PropertyInfo(alias="targetIndustry")]
 
+    uuid: str
+    """Optional UUID for the event.
+
+    Only used when preserveUuid=true in bulk create. Must be a valid UUID format.
+    """
+
 
 class Raw(TypedDict, total=False):
     data: Required[Optional[Dict[str, object]]]

src/cloudflare/types/cloudforce_one/threat_event_list_params.py

@@ -19,6 +19,8 @@ class ThreatEventListParams(TypedDict, total=False):
 
     force_refresh: Annotated[bool, PropertyInfo(alias="forceRefresh")]
 
+    format: Literal["json", "stix2"]
+
     order: Literal["asc", "desc"]
 
     order_by: Annotated[str, PropertyInfo(alias="orderBy")]

src/cloudflare/types/email_security/investigate/move_bulk_response.py

@@ -13,6 +13,8 @@ class MoveBulkResponse(BaseModel):
 
     item_count: int
 
+    success: bool
+
     destination: Optional[str] = None
 
     message_id: Optional[str] = None