Skip to content

feat: regenerate API client from OpenAPI spec #31

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
convoy-sdk-bot merged 1 commit into from
Aug 5, 2026
Merged

feat: regenerate API client from OpenAPI spec #31

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
26 changes: 19 additions & 7 deletions src/convoy/models/datastore_project_config.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -34,6 +34,10 @@ class DatastoreProjectConfig:
"""
Attributes:
add_event_id_trace_headers (bool | Unset):
allow_unmatched_dynamic_urls (bool | Unset): AllowUnmatchedDynamicURLs lets a dynamic event URL that matches
none of the
project's endpoint URL templates auto-create an endpoint. Default false
rejects unmatched URLs.
circuit_breaker (DatastoreCircuitBreakerConfiguration | None | Unset):
disable_endpoint (bool | Unset):
max_payload_read_size (int | Unset):
Expand All @@ -46,11 +50,12 @@ class DatastoreProjectConfig:
signature (DatastoreSignatureConfiguration | None | Unset):
ssl (DatastoreSSLConfiguration | None | Unset):
strategy (DatastoreStrategyConfiguration | None | Unset):
sync_dynamic_event_ack (bool | Unset): SyncDynamicEventAck waits for endpoint/subscription resolve before
verify_dynamic_events (bool | Unset): VerifyDynamicEvents waits for endpoint/subscription resolve before
returning 2xx from POST /events/dynamic. Default false keeps 201-on-queue.
"""

add_event_id_trace_headers: bool | Unset = UNSET
allow_unmatched_dynamic_urls: bool | Unset = UNSET
circuit_breaker: DatastoreCircuitBreakerConfiguration | None | Unset = UNSET
disable_endpoint: bool | Unset = UNSET
max_payload_read_size: int | Unset = UNSET
Expand All @@ -63,7 +68,7 @@ class DatastoreProjectConfig:
signature: DatastoreSignatureConfiguration | None | Unset = UNSET
ssl: DatastoreSSLConfiguration | None | Unset = UNSET
strategy: DatastoreStrategyConfiguration | None | Unset = UNSET
sync_dynamic_event_ack: bool | Unset = UNSET
verify_dynamic_events: bool | Unset = UNSET
additional_properties: dict[str, Any] = _attrs_field(init=False, factory=dict)

def to_dict(self) -> dict[str, Any]:
Expand All @@ -86,6 +91,8 @@ def to_dict(self) -> dict[str, Any]:

add_event_id_trace_headers = self.add_event_id_trace_headers

allow_unmatched_dynamic_urls = self.allow_unmatched_dynamic_urls

circuit_breaker: dict[str, Any] | None | Unset
if isinstance(self.circuit_breaker, Unset):
circuit_breaker = UNSET
Expand Down Expand Up @@ -148,13 +155,15 @@ def to_dict(self) -> dict[str, Any]:
else:
strategy = self.strategy

sync_dynamic_event_ack = self.sync_dynamic_event_ack
verify_dynamic_events = self.verify_dynamic_events

field_dict: dict[str, Any] = {}
field_dict.update(self.additional_properties)
field_dict.update({})
if add_event_id_trace_headers is not UNSET:
field_dict["add_event_id_trace_headers"] = add_event_id_trace_headers
if allow_unmatched_dynamic_urls is not UNSET:
field_dict["allow_unmatched_dynamic_urls"] = allow_unmatched_dynamic_urls
if circuit_breaker is not UNSET:
field_dict["circuit_breaker"] = circuit_breaker
if disable_endpoint is not UNSET:
Expand Down Expand Up @@ -183,8 +192,8 @@ def to_dict(self) -> dict[str, Any]:
field_dict["ssl"] = ssl
if strategy is not UNSET:
field_dict["strategy"] = strategy
if sync_dynamic_event_ack is not UNSET:
field_dict["sync_dynamic_event_ack"] = sync_dynamic_event_ack
if verify_dynamic_events is not UNSET:
field_dict["verify_dynamic_events"] = verify_dynamic_events

return field_dict

Expand All @@ -210,6 +219,8 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T:
d = dict(src_dict)
add_event_id_trace_headers = d.pop("add_event_id_trace_headers", UNSET)

allow_unmatched_dynamic_urls = d.pop("allow_unmatched_dynamic_urls", UNSET)

def _parse_circuit_breaker(
data: object,
) -> DatastoreCircuitBreakerConfiguration | None | Unset:
Expand Down Expand Up @@ -345,10 +356,11 @@ def _parse_strategy(

strategy = _parse_strategy(d.pop("strategy", UNSET))

sync_dynamic_event_ack = d.pop("sync_dynamic_event_ack", UNSET)
verify_dynamic_events = d.pop("verify_dynamic_events", UNSET)

datastore_project_config = cls(
add_event_id_trace_headers=add_event_id_trace_headers,
allow_unmatched_dynamic_urls=allow_unmatched_dynamic_urls,
circuit_breaker=circuit_breaker,
disable_endpoint=disable_endpoint,
max_payload_read_size=max_payload_read_size,
Expand All @@ -361,7 +373,7 @@ def _parse_strategy(
signature=signature,
ssl=ssl,
strategy=strategy,
sync_dynamic_event_ack=sync_dynamic_event_ack,
verify_dynamic_events=verify_dynamic_events,
)

datastore_project_config.additional_properties = d
Expand Down
27 changes: 19 additions & 8 deletions src/convoy/models/models_project_config.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,10 @@ class ModelsProjectConfig:
Attributes:
add_event_id_trace_headers (bool | Unset): Controls of the Event ID and Event Delivery ID Headers are added to
the request when events are dispatched to endpoints
allow_unmatched_dynamic_urls (bool | Unset): AllowUnmatchedDynamicURLs lets a dynamic event URL that matches
none of the project's
endpoint URL templates auto-create an endpoint instead of failing. When false (the
default), a project with templates configured rejects unmatched URLs.
circuit_breaker (DatastoreCircuitBreakerConfiguration | Unset):
disable_endpoint (bool | Unset): Controls if the project will disable and endpoint after the retry threshold for
an event is reached
Expand All @@ -48,12 +52,12 @@ class ModelsProjectConfig:
signature (ModelsSignatureConfiguration | Unset):
ssl (ModelsSSLConfiguration | Unset):
strategy (ModelsStrategyConfiguration | Unset):
sync_dynamic_event_ack (bool | Unset): SyncDynamicEventAck waits for dynamic endpoint/subscription resolve
before
verify_dynamic_events (bool | Unset): VerifyDynamicEvents waits for dynamic endpoint/subscription resolve before
acknowledging POST /events/dynamic. When false, the handler returns 201 after enqueue.
"""

add_event_id_trace_headers: bool | Unset = UNSET
allow_unmatched_dynamic_urls: bool | Unset = UNSET
circuit_breaker: DatastoreCircuitBreakerConfiguration | Unset = UNSET
disable_endpoint: bool | Unset = UNSET
max_payload_read_size: int | Unset = UNSET
Expand All @@ -66,12 +70,14 @@ class ModelsProjectConfig:
signature: ModelsSignatureConfiguration | Unset = UNSET
ssl: ModelsSSLConfiguration | Unset = UNSET
strategy: ModelsStrategyConfiguration | Unset = UNSET
sync_dynamic_event_ack: bool | Unset = UNSET
verify_dynamic_events: bool | Unset = UNSET
additional_properties: dict[str, Any] = _attrs_field(init=False, factory=dict)

def to_dict(self) -> dict[str, Any]:
add_event_id_trace_headers = self.add_event_id_trace_headers

allow_unmatched_dynamic_urls = self.allow_unmatched_dynamic_urls

circuit_breaker: dict[str, Any] | Unset = UNSET
if not isinstance(self.circuit_breaker, Unset):
circuit_breaker = self.circuit_breaker.to_dict()
Expand Down Expand Up @@ -110,13 +116,15 @@ def to_dict(self) -> dict[str, Any]:
if not isinstance(self.strategy, Unset):
strategy = self.strategy.to_dict()

sync_dynamic_event_ack = self.sync_dynamic_event_ack
verify_dynamic_events = self.verify_dynamic_events

field_dict: dict[str, Any] = {}
field_dict.update(self.additional_properties)
field_dict.update({})
if add_event_id_trace_headers is not UNSET:
field_dict["add_event_id_trace_headers"] = add_event_id_trace_headers
if allow_unmatched_dynamic_urls is not UNSET:
field_dict["allow_unmatched_dynamic_urls"] = allow_unmatched_dynamic_urls
if circuit_breaker is not UNSET:
field_dict["circuit_breaker"] = circuit_breaker
if disable_endpoint is not UNSET:
Expand Down Expand Up @@ -145,8 +153,8 @@ def to_dict(self) -> dict[str, Any]:
field_dict["ssl"] = ssl
if strategy is not UNSET:
field_dict["strategy"] = strategy
if sync_dynamic_event_ack is not UNSET:
field_dict["sync_dynamic_event_ack"] = sync_dynamic_event_ack
if verify_dynamic_events is not UNSET:
field_dict["verify_dynamic_events"] = verify_dynamic_events

return field_dict

Expand All @@ -168,6 +176,8 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T:
d = dict(src_dict)
add_event_id_trace_headers = d.pop("add_event_id_trace_headers", UNSET)

allow_unmatched_dynamic_urls = d.pop("allow_unmatched_dynamic_urls", UNSET)

_circuit_breaker = d.pop("circuit_breaker", UNSET)
circuit_breaker: DatastoreCircuitBreakerConfiguration | Unset
if isinstance(_circuit_breaker, Unset):
Expand Down Expand Up @@ -233,10 +243,11 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T:
else:
strategy = ModelsStrategyConfiguration.from_dict(_strategy)

sync_dynamic_event_ack = d.pop("sync_dynamic_event_ack", UNSET)
verify_dynamic_events = d.pop("verify_dynamic_events", UNSET)

models_project_config = cls(
add_event_id_trace_headers=add_event_id_trace_headers,
allow_unmatched_dynamic_urls=allow_unmatched_dynamic_urls,
circuit_breaker=circuit_breaker,
disable_endpoint=disable_endpoint,
max_payload_read_size=max_payload_read_size,
Expand All @@ -249,7 +260,7 @@ def from_dict(cls: type[T], src_dict: Mapping[str, Any]) -> T:
signature=signature,
ssl=ssl,
strategy=strategy,
sync_dynamic_event_ack=sync_dynamic_event_ack,
verify_dynamic_events=verify_dynamic_events,
)

models_project_config.additional_properties = d
Expand Down