From 2039ca687ce5e9f4df22087b2399188d7ad59f28 Mon Sep 17 00:00:00 2001 From: "convoy-sdk-bot[bot]" <307218117+convoy-sdk-bot[bot]@users.noreply.github.com> Date: Wed, 21 Oct 2026 16:01:33 +0000 Subject: [PATCH] feat: regenerate API client from OpenAPI spec --- .../get_delivery_attempts.py | 46 ++++++++++++++++- .../batch_retry_event_delivery.py | 51 ++++++++++++++++++- .../get_event_deliveries_paged.py | 51 ++++++++++++++++++- src/convoy/api/events/batch_replay_events.py | 30 +++++++++++ .../api/events/count_affected_events.py | 30 +++++++++++ src/convoy/api/events/get_events_paged.py | 30 +++++++++++ src/convoy/models/models_update_source.py | 17 +++++++ 7 files changed, 252 insertions(+), 3 deletions(-) diff --git a/src/convoy/api/delivery_attempts/get_delivery_attempts.py b/src/convoy/api/delivery_attempts/get_delivery_attempts.py index 833179b..9a09eac 100644 --- a/src/convoy/api/delivery_attempts/get_delivery_attempts.py +++ b/src/convoy/api/delivery_attempts/get_delivery_attempts.py @@ -10,20 +10,32 @@ from ...models.get_delivery_attempts_response_400 import GetDeliveryAttemptsResponse400 from ...models.get_delivery_attempts_response_401 import GetDeliveryAttemptsResponse401 from ...models.get_delivery_attempts_response_404 import GetDeliveryAttemptsResponse404 -from ...types import Response +from ...types import UNSET, Response, Unset def _get_kwargs( project_id: str, event_delivery_id: str, + *, + paginated: bool | Unset = UNSET, + before: str | Unset = UNSET, ) -> dict[str, Any]: + params: dict[str, Any] = {} + + params["paginated"] = paginated + + params["before"] = before + + params = {k: v for k, v in params.items() if v is not UNSET and v is not None} + _kwargs: dict[str, Any] = { "method": "get", "url": "/v1/projects/{project_id}/eventdeliveries/{event_delivery_id}/deliveryattempts".format( project_id=quote(str(project_id), safe=""), event_delivery_id=quote(str(event_delivery_id), safe=""), ), + "params": params, } return _kwargs @@ -85,6 +97,8 @@ def sync_detailed( event_delivery_id: str, *, client: AuthenticatedClient, + paginated: bool | Unset = UNSET, + before: str | Unset = UNSET, ) -> Response[ GetDeliveryAttemptsResponse200 | GetDeliveryAttemptsResponse400 @@ -94,10 +108,14 @@ def sync_detailed( """List delivery attempts This endpoint fetches an app message's delivery attempts + Default: latest ten attempts as an array. With paginated=true: content and next_cursor. Pass + next_cursor as before for older history; empty means last page. Pages are oldest first. Args: project_id (str): event_delivery_id (str): + paginated (bool | Unset): + before (str | Unset): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. @@ -110,6 +128,8 @@ def sync_detailed( kwargs = _get_kwargs( project_id=project_id, event_delivery_id=event_delivery_id, + paginated=paginated, + before=before, ) response = client.get_httpx_client().request( @@ -124,6 +144,8 @@ def sync( event_delivery_id: str, *, client: AuthenticatedClient, + paginated: bool | Unset = UNSET, + before: str | Unset = UNSET, ) -> ( GetDeliveryAttemptsResponse200 | GetDeliveryAttemptsResponse400 @@ -134,10 +156,14 @@ def sync( """List delivery attempts This endpoint fetches an app message's delivery attempts + Default: latest ten attempts as an array. With paginated=true: content and next_cursor. Pass + next_cursor as before for older history; empty means last page. Pages are oldest first. Args: project_id (str): event_delivery_id (str): + paginated (bool | Unset): + before (str | Unset): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. @@ -151,6 +177,8 @@ def sync( project_id=project_id, event_delivery_id=event_delivery_id, client=client, + paginated=paginated, + before=before, ).parsed @@ -159,6 +187,8 @@ async def asyncio_detailed( event_delivery_id: str, *, client: AuthenticatedClient, + paginated: bool | Unset = UNSET, + before: str | Unset = UNSET, ) -> Response[ GetDeliveryAttemptsResponse200 | GetDeliveryAttemptsResponse400 @@ -168,10 +198,14 @@ async def asyncio_detailed( """List delivery attempts This endpoint fetches an app message's delivery attempts + Default: latest ten attempts as an array. With paginated=true: content and next_cursor. Pass + next_cursor as before for older history; empty means last page. Pages are oldest first. Args: project_id (str): event_delivery_id (str): + paginated (bool | Unset): + before (str | Unset): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. @@ -184,6 +218,8 @@ async def asyncio_detailed( kwargs = _get_kwargs( project_id=project_id, event_delivery_id=event_delivery_id, + paginated=paginated, + before=before, ) response = await client.get_async_httpx_client().request(**kwargs) @@ -196,6 +232,8 @@ async def asyncio( event_delivery_id: str, *, client: AuthenticatedClient, + paginated: bool | Unset = UNSET, + before: str | Unset = UNSET, ) -> ( GetDeliveryAttemptsResponse200 | GetDeliveryAttemptsResponse400 @@ -206,10 +244,14 @@ async def asyncio( """List delivery attempts This endpoint fetches an app message's delivery attempts + Default: latest ten attempts as an array. With paginated=true: content and next_cursor. Pass + next_cursor as before for older history; empty means last page. Pages are oldest first. Args: project_id (str): event_delivery_id (str): + paginated (bool | Unset): + before (str | Unset): Raises: errors.UnexpectedStatus: If the server returns an undocumented status code and Client.raise_on_unexpected_status is True. @@ -224,5 +266,7 @@ async def asyncio( project_id=project_id, event_delivery_id=event_delivery_id, client=client, + paginated=paginated, + before=before, ) ).parsed diff --git a/src/convoy/api/event_deliveries/batch_retry_event_delivery.py b/src/convoy/api/event_deliveries/batch_retry_event_delivery.py index ce80bc8..2cc42fe 100644 --- a/src/convoy/api/event_deliveries/batch_retry_event_delivery.py +++ b/src/convoy/api/event_deliveries/batch_retry_event_delivery.py @@ -33,11 +33,14 @@ def _get_kwargs( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -61,10 +64,14 @@ def _get_kwargs( params["eventId"] = event_id - params["event_type"] = event_type + params["eventType"] = event_type params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + + params["minTrials"] = min_trials + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -75,6 +82,12 @@ def _get_kwargs( params["sort"] = sort + json_source_id: list[str] | Unset = UNSET + if not isinstance(source_id, Unset): + json_source_id = source_id + + params["sourceId"] = json_source_id + params["startDate"] = start_date json_status: list[str] | Unset = UNSET @@ -159,11 +172,14 @@ def sync_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -185,11 +201,14 @@ def sync_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -210,11 +229,14 @@ def sync_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -237,11 +259,14 @@ def sync( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -264,11 +289,14 @@ def sync( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -290,11 +318,14 @@ def sync( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -311,11 +342,14 @@ async def asyncio_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -337,11 +371,14 @@ async def asyncio_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -362,11 +399,14 @@ async def asyncio_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -387,11 +427,14 @@ async def asyncio( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -414,11 +457,14 @@ async def asyncio( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -441,11 +487,14 @@ async def asyncio( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, diff --git a/src/convoy/api/event_deliveries/get_event_deliveries_paged.py b/src/convoy/api/event_deliveries/get_event_deliveries_paged.py index a2ce7f9..4ceecc1 100644 --- a/src/convoy/api/event_deliveries/get_event_deliveries_paged.py +++ b/src/convoy/api/event_deliveries/get_event_deliveries_paged.py @@ -36,11 +36,14 @@ def _get_kwargs( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -64,10 +67,14 @@ def _get_kwargs( params["eventId"] = event_id - params["event_type"] = event_type + params["eventType"] = event_type params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + + params["minTrials"] = min_trials + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -78,6 +85,12 @@ def _get_kwargs( params["sort"] = sort + json_source_id: list[str] | Unset = UNSET + if not isinstance(source_id, Unset): + json_source_id = source_id + + params["sourceId"] = json_source_id + params["startDate"] = start_date json_status: list[str] | Unset = UNSET @@ -169,11 +182,14 @@ def sync_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -196,11 +212,14 @@ def sync_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -221,11 +240,14 @@ def sync_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -248,11 +270,14 @@ def sync( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -276,11 +301,14 @@ def sync( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -302,11 +330,14 @@ def sync( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -323,11 +354,14 @@ async def asyncio_detailed( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -350,11 +384,14 @@ async def asyncio_detailed( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -375,11 +412,14 @@ async def asyncio_detailed( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, @@ -400,11 +440,14 @@ async def asyncio( event_id: str | Unset = UNSET, event_type: str | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, + min_trials: int | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, sort: str | Unset = UNSET, + source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, status: list[str] | Unset = UNSET, subscription_id: str | Unset = UNSET, @@ -428,11 +471,14 @@ async def asyncio( event_id (str | Unset): event_type (str | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): + min_trials (int | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): sort (str | Unset): + source_id (list[str] | Unset): start_date (str | Unset): status (list[str] | Unset): subscription_id (str | Unset): @@ -455,11 +501,14 @@ async def asyncio( event_id=event_id, event_type=event_type, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, + min_trials=min_trials, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, sort=sort, + source_id=source_id, start_date=start_date, status=status, subscription_id=subscription_id, diff --git a/src/convoy/api/events/batch_replay_events.py b/src/convoy/api/events/batch_replay_events.py index 40b291e..57e6047 100644 --- a/src/convoy/api/events/batch_replay_events.py +++ b/src/convoy/api/events/batch_replay_events.py @@ -22,10 +22,12 @@ def _get_kwargs( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -51,6 +53,8 @@ def _get_kwargs( params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -59,6 +63,8 @@ def _get_kwargs( params["query"] = query + params["queryMode"] = query_mode + params["sort"] = sort json_source_id: list[str] | Unset = UNSET @@ -142,10 +148,12 @@ def sync_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -166,10 +174,12 @@ def sync_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -189,10 +199,12 @@ def sync_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -214,10 +226,12 @@ def sync( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -239,10 +253,12 @@ def sync( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -263,10 +279,12 @@ def sync( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -282,10 +300,12 @@ async def asyncio_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -306,10 +326,12 @@ async def asyncio_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -329,10 +351,12 @@ async def asyncio_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -352,10 +376,12 @@ async def asyncio( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -377,10 +403,12 @@ async def asyncio( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -402,10 +430,12 @@ async def asyncio( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, diff --git a/src/convoy/api/events/count_affected_events.py b/src/convoy/api/events/count_affected_events.py index 3f060c3..84bae0b 100644 --- a/src/convoy/api/events/count_affected_events.py +++ b/src/convoy/api/events/count_affected_events.py @@ -22,10 +22,12 @@ def _get_kwargs( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -51,6 +53,8 @@ def _get_kwargs( params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -59,6 +63,8 @@ def _get_kwargs( params["query"] = query + params["queryMode"] = query_mode + params["sort"] = sort json_source_id: list[str] | Unset = UNSET @@ -142,10 +148,12 @@ def sync_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -166,10 +174,12 @@ def sync_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -189,10 +199,12 @@ def sync_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -214,10 +226,12 @@ def sync( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -239,10 +253,12 @@ def sync( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -263,10 +279,12 @@ def sync( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -282,10 +300,12 @@ async def asyncio_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -306,10 +326,12 @@ async def asyncio_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -329,10 +351,12 @@ async def asyncio_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -352,10 +376,12 @@ async def asyncio( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -377,10 +403,12 @@ async def asyncio( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -402,10 +430,12 @@ async def asyncio( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, diff --git a/src/convoy/api/events/get_events_paged.py b/src/convoy/api/events/get_events_paged.py index 8d98242..c439c63 100644 --- a/src/convoy/api/events/get_events_paged.py +++ b/src/convoy/api/events/get_events_paged.py @@ -24,10 +24,12 @@ def _get_kwargs( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -53,6 +55,8 @@ def _get_kwargs( params["idempotencyKey"] = idempotency_key + params["idempotencyValue"] = idempotency_value + params["next_page_cursor"] = next_page_cursor params["perPage"] = per_page @@ -61,6 +65,8 @@ def _get_kwargs( params["query"] = query + params["queryMode"] = query_mode + params["sort"] = sort json_source_id: list[str] | Unset = UNSET @@ -158,10 +164,12 @@ def sync_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -184,10 +192,12 @@ def sync_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -207,10 +217,12 @@ def sync_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -232,10 +244,12 @@ def sync( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -259,10 +273,12 @@ def sync( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -283,10 +299,12 @@ def sync( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -302,10 +320,12 @@ async def asyncio_detailed( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -328,10 +348,12 @@ async def asyncio_detailed( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -351,10 +373,12 @@ async def asyncio_detailed( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, @@ -374,10 +398,12 @@ async def asyncio( end_date: str | Unset = UNSET, endpoint_id: list[str] | Unset = UNSET, idempotency_key: str | Unset = UNSET, + idempotency_value: str | Unset = UNSET, next_page_cursor: str | Unset = UNSET, per_page: int | Unset = UNSET, prev_page_cursor: str | Unset = UNSET, query: str | Unset = UNSET, + query_mode: str | Unset = UNSET, sort: str | Unset = UNSET, source_id: list[str] | Unset = UNSET, start_date: str | Unset = UNSET, @@ -401,10 +427,12 @@ async def asyncio( end_date (str | Unset): endpoint_id (list[str] | Unset): idempotency_key (str | Unset): + idempotency_value (str | Unset): next_page_cursor (str | Unset): per_page (int | Unset): prev_page_cursor (str | Unset): query (str | Unset): + query_mode (str | Unset): sort (str | Unset): source_id (list[str] | Unset): start_date (str | Unset): @@ -426,10 +454,12 @@ async def asyncio( end_date=end_date, endpoint_id=endpoint_id, idempotency_key=idempotency_key, + idempotency_value=idempotency_value, next_page_cursor=next_page_cursor, per_page=per_page, prev_page_cursor=prev_page_cursor, query=query, + query_mode=query_mode, sort=sort, source_id=source_id, start_date=start_date, diff --git a/src/convoy/models/models_update_source.py b/src/convoy/models/models_update_source.py index 416a38b..8be29dd 100644 --- a/src/convoy/models/models_update_source.py +++ b/src/convoy/models/models_update_source.py @@ -6,6 +6,7 @@ from attrs import define as _attrs_define from attrs import field as _attrs_field +from ..models.datastore_source_provider import DatastoreSourceProvider from ..models.datastore_source_type import DatastoreSourceType from ..types import UNSET, Unset @@ -35,6 +36,7 @@ class ModelsUpdateSource: identify the event in an incoming webhooks project. is_disabled (bool | Unset): This is used to manually enable/disable the source. name (str | Unset): Source name. + provider (DatastoreSourceProvider | Unset): pub_sub (ModelsPubSubConfig | Unset): type_ (DatastoreSourceType | Unset): verifier (ModelsVerifierConfig | Unset): @@ -48,6 +50,7 @@ class ModelsUpdateSource: idempotency_keys: list[str] | Unset = UNSET is_disabled: bool | Unset = UNSET name: str | Unset = UNSET + provider: DatastoreSourceProvider | Unset = UNSET pub_sub: ModelsPubSubConfig | Unset = UNSET type_: DatastoreSourceType | Unset = UNSET verifier: ModelsVerifierConfig | Unset = UNSET @@ -76,6 +79,10 @@ def to_dict(self) -> dict[str, Any]: name = self.name + provider: str | Unset = UNSET + if not isinstance(self.provider, Unset): + provider = self.provider.value + pub_sub: dict[str, Any] | Unset = UNSET if not isinstance(self.pub_sub, Unset): pub_sub = self.pub_sub.to_dict() @@ -107,6 +114,8 @@ def to_dict(self) -> dict[str, Any]: field_dict["is_disabled"] = is_disabled if name is not UNSET: field_dict["name"] = name + if provider is not UNSET: + field_dict["provider"] = provider if pub_sub is not UNSET: field_dict["pub_sub"] = pub_sub if type_ is not UNSET: @@ -144,6 +153,13 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: name = d.pop("name", UNSET) + _provider = d.pop("provider", UNSET) + provider: DatastoreSourceProvider | Unset + if isinstance(_provider, Unset): + provider = UNSET + else: + provider = DatastoreSourceProvider(_provider) + _pub_sub = d.pop("pub_sub", UNSET) pub_sub: ModelsPubSubConfig | Unset if isinstance(_pub_sub, Unset): @@ -174,6 +190,7 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T: idempotency_keys=idempotency_keys, is_disabled=is_disabled, name=name, + provider=provider, pub_sub=pub_sub, type_=type_, verifier=verifier,