feat(api): webhooks and stream

Author: stainless-app[bot]

.stats.yml

@@ -1,4 +1,4 @@
-configured_endpoints: 27
-openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/moderation-api/moderation-api-6644e98b7909ae773e2140200f43feaf75382b94fd18918e1ea0f630419839c9.yml
+configured_endpoints: 34
+openapi_spec_url: https://storage.googleapis.com/stainless-sdk-openapi-specs/moderation-api/moderation-api-407f949d64421d5454ec0f4b518a19c14daa41312b6efa370eac631e495ca44a.yml
 openapi_spec_hash: 7bcba0df8e8cb1c5a2d02efc3d6c0fa5
-config_hash: 827ffbc2bec8c435226c9080d32e6833
+config_hash: 6e090a71f4d354167d93b4534a0e7f05

api.md

@@ -92,6 +92,7 @@ from moderation_api.types import ContentSubmitResponse
 
 Methods:
 
+- <code title="get /stream">client.content.<a href="./src/moderation_api/resources/content.py">stream</a>() -> None</code>
 - <code title="post /moderate">client.content.<a href="./src/moderation_api/resources/content.py">submit</a>(\*\*<a href="src/moderation_api/types/content_submit_params.py">params</a>) -> <a href="./src/moderation_api/types/content_submit_response.py">ContentSubmitResponse</a></code>
 
 # Account
@@ -151,3 +152,37 @@ Methods:
 
 - <code title="post /wordlist/{id}/words">client.wordlist.words.<a href="./src/moderation_api/resources/wordlist/words.py">add</a>(id, \*\*<a href="src/moderation_api/types/wordlist/word_add_params.py">params</a>) -> <a href="./src/moderation_api/types/wordlist/word_add_response.py">WordAddResponse</a></code>
 - <code title="delete /wordlist/{id}/words">client.wordlist.words.<a href="./src/moderation_api/resources/wordlist/words.py">remove</a>(id, \*\*<a href="src/moderation_api/types/wordlist/word_remove_params.py">params</a>) -> <a href="./src/moderation_api/types/wordlist/word_remove_response.py">WordRemoveResponse</a></code>
+
+# Webhooks
+
+Types:
+
+```python
+from moderation_api.types import (
+    WebhookCreateResponse,
+    WebhookRetrieveResponse,
+    WebhookUpdateResponse,
+    WebhookListResponse,
+    WebhookDeleteResponse,
+)
+```
+
+Methods:
+
+- <code title="post /webhooks">client.webhooks.<a href="./src/moderation_api/resources/webhooks.py">create</a>(\*\*<a href="src/moderation_api/types/webhook_create_params.py">params</a>) -> <a href="./src/moderation_api/types/webhook_create_response.py">WebhookCreateResponse</a></code>
+- <code title="get /webhooks/{id}">client.webhooks.<a href="./src/moderation_api/resources/webhooks.py">retrieve</a>(id) -> <a href="./src/moderation_api/types/webhook_retrieve_response.py">WebhookRetrieveResponse</a></code>
+- <code title="put /webhooks/{id}">client.webhooks.<a href="./src/moderation_api/resources/webhooks.py">update</a>(id, \*\*<a href="src/moderation_api/types/webhook_update_params.py">params</a>) -> <a href="./src/moderation_api/types/webhook_update_response.py">WebhookUpdateResponse</a></code>
+- <code title="get /webhooks">client.webhooks.<a href="./src/moderation_api/resources/webhooks.py">list</a>() -> <a href="./src/moderation_api/types/webhook_list_response.py">WebhookListResponse</a></code>
+- <code title="delete /webhooks/{id}">client.webhooks.<a href="./src/moderation_api/resources/webhooks.py">delete</a>(id) -> <a href="./src/moderation_api/types/webhook_delete_response.py">WebhookDeleteResponse</a></code>
+
+# WebhookSecret
+
+Types:
+
+```python
+from moderation_api.types import WebhookSecretRetrieveResponse
+```
+
+Methods:
+
+- <code title="get /webhook-secret">client.webhook_secret.<a href="./src/moderation_api/resources/webhook_secret.py">retrieve</a>() -> <a href="./src/moderation_api/types/webhook_secret_retrieve_response.py">WebhookSecretRetrieveResponse</a></code>

src/moderation_api/_client.py

@@ -35,12 +35,14 @@
 )
 
 if TYPE_CHECKING:
-    from .resources import auth, queue, account, actions, authors, content, wordlist
+    from .resources import auth, queue, account, actions, authors, content, webhooks, wordlist, webhook_secret
     from .resources.auth import AuthResource, AsyncAuthResource
     from .resources.account import AccountResource, AsyncAccountResource
     from .resources.authors import AuthorsResource, AsyncAuthorsResource
     from .resources.content import ContentResource, AsyncContentResource
+    from .resources.webhooks import WebhooksResource, AsyncWebhooksResource
     from .resources.queue.queue import QueueResource, AsyncQueueResource
+    from .resources.webhook_secret import WebhookSecretResource, AsyncWebhookSecretResource
     from .resources.actions.actions import ActionsResource, AsyncActionsResource
     from .resources.wordlist.wordlist import WordlistResource, AsyncWordlistResource
 
@@ -97,6 +99,7 @@ def __init__(
 
         if base_url is None:
             base_url = os.environ.get("MODERATION_API_BASE_URL")
+        self._base_url_overridden = base_url is not None
         if base_url is None:
             base_url = f"https://api.moderationapi.com/v1"
 
@@ -162,6 +165,18 @@ def wordlist(self) -> WordlistResource:
 
         return WordlistResource(self)
 
+    @cached_property
+    def webhooks(self) -> WebhooksResource:
+        from .resources.webhooks import WebhooksResource
+
+        return WebhooksResource(self)
+
+    @cached_property
+    def webhook_secret(self) -> WebhookSecretResource:
+        from .resources.webhook_secret import WebhookSecretResource
+
+        return WebhookSecretResource(self)
+
     @cached_property
     def with_raw_response(self) -> ModerationAPIWithRawResponse:
         return ModerationAPIWithRawResponse(self)
@@ -226,7 +241,7 @@ def copy(
             params = set_default_query
 
         http_client = http_client or self._client
-        return self.__class__(
+        client = self.__class__(
             secret_key=secret_key or self.secret_key,
             base_url=base_url or self.base_url,
             timeout=self.timeout if isinstance(timeout, NotGiven) else timeout,
@@ -236,6 +251,8 @@ def copy(
             default_query=params,
             **_extra_kwargs,
         )
+        client._base_url_overridden = self._base_url_overridden or base_url is not None
+        return client
 
     # Alias for `copy` for nicer inline usage, e.g.
     # client.with_options(timeout=10).foo.create(...)
@@ -316,6 +333,7 @@ def __init__(
 
         if base_url is None:
             base_url = os.environ.get("MODERATION_API_BASE_URL")
+        self._base_url_overridden = base_url is not None
         if base_url is None:
             base_url = f"https://api.moderationapi.com/v1"
 
@@ -381,6 +399,18 @@ def wordlist(self) -> AsyncWordlistResource:
 
         return AsyncWordlistResource(self)
 
+    @cached_property
+    def webhooks(self) -> AsyncWebhooksResource:
+        from .resources.webhooks import AsyncWebhooksResource
+
+        return AsyncWebhooksResource(self)
+
+    @cached_property
+    def webhook_secret(self) -> AsyncWebhookSecretResource:
+        from .resources.webhook_secret import AsyncWebhookSecretResource
+
+        return AsyncWebhookSecretResource(self)
+
     @cached_property
     def with_raw_response(self) -> AsyncModerationAPIWithRawResponse:
         return AsyncModerationAPIWithRawResponse(self)
@@ -445,7 +475,7 @@ def copy(
             params = set_default_query
 
         http_client = http_client or self._client
-        return self.__class__(
+        client = self.__class__(
             secret_key=secret_key or self.secret_key,
             base_url=base_url or self.base_url,
             timeout=self.timeout if isinstance(timeout, NotGiven) else timeout,
@@ -455,6 +485,8 @@ def copy(
             default_query=params,
             **_extra_kwargs,
         )
+        client._base_url_overridden = self._base_url_overridden or base_url is not None
+        return client
 
     # Alias for `copy` for nicer inline usage, e.g.
     # client.with_options(timeout=10).foo.create(...)
@@ -542,6 +574,18 @@ def wordlist(self) -> wordlist.WordlistResourceWithRawResponse:
 
         return WordlistResourceWithRawResponse(self._client.wordlist)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithRawResponse:
+        from .resources.webhooks import WebhooksResourceWithRawResponse
+
+        return WebhooksResourceWithRawResponse(self._client.webhooks)
+
+    @cached_property
+    def webhook_secret(self) -> webhook_secret.WebhookSecretResourceWithRawResponse:
+        from .resources.webhook_secret import WebhookSecretResourceWithRawResponse
+
+        return WebhookSecretResourceWithRawResponse(self._client.webhook_secret)
+
 
 class AsyncModerationAPIWithRawResponse:
     _client: AsyncModerationAPI
@@ -591,6 +635,18 @@ def wordlist(self) -> wordlist.AsyncWordlistResourceWithRawResponse:
 
         return AsyncWordlistResourceWithRawResponse(self._client.wordlist)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithRawResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithRawResponse
+
+        return AsyncWebhooksResourceWithRawResponse(self._client.webhooks)
+
+    @cached_property
+    def webhook_secret(self) -> webhook_secret.AsyncWebhookSecretResourceWithRawResponse:
+        from .resources.webhook_secret import AsyncWebhookSecretResourceWithRawResponse
+
+        return AsyncWebhookSecretResourceWithRawResponse(self._client.webhook_secret)
+
 
 class ModerationAPIWithStreamedResponse:
     _client: ModerationAPI
@@ -640,6 +696,18 @@ def wordlist(self) -> wordlist.WordlistResourceWithStreamingResponse:
 
         return WordlistResourceWithStreamingResponse(self._client.wordlist)
 
+    @cached_property
+    def webhooks(self) -> webhooks.WebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import WebhooksResourceWithStreamingResponse
+
+        return WebhooksResourceWithStreamingResponse(self._client.webhooks)
+
+    @cached_property
+    def webhook_secret(self) -> webhook_secret.WebhookSecretResourceWithStreamingResponse:
+        from .resources.webhook_secret import WebhookSecretResourceWithStreamingResponse
+
+        return WebhookSecretResourceWithStreamingResponse(self._client.webhook_secret)
+
 
 class AsyncModerationAPIWithStreamedResponse:
     _client: AsyncModerationAPI
@@ -689,6 +757,18 @@ def wordlist(self) -> wordlist.AsyncWordlistResourceWithStreamingResponse:
 
         return AsyncWordlistResourceWithStreamingResponse(self._client.wordlist)
 
+    @cached_property
+    def webhooks(self) -> webhooks.AsyncWebhooksResourceWithStreamingResponse:
+        from .resources.webhooks import AsyncWebhooksResourceWithStreamingResponse
+
+        return AsyncWebhooksResourceWithStreamingResponse(self._client.webhooks)
+
+    @cached_property
+    def webhook_secret(self) -> webhook_secret.AsyncWebhookSecretResourceWithStreamingResponse:
+        from .resources.webhook_secret import AsyncWebhookSecretResourceWithStreamingResponse
+
+        return AsyncWebhookSecretResourceWithStreamingResponse(self._client.webhook_secret)
+
 
 Client = ModerationAPI
 

src/moderation_api/resources/__init__.py

@@ -48,6 +48,14 @@
     ContentResourceWithStreamingResponse,
     AsyncContentResourceWithStreamingResponse,
 )
+from .webhooks import (
+    WebhooksResource,
+    AsyncWebhooksResource,
+    WebhooksResourceWithRawResponse,
+    AsyncWebhooksResourceWithRawResponse,
+    WebhooksResourceWithStreamingResponse,
+    AsyncWebhooksResourceWithStreamingResponse,
+)
 from .wordlist import (
     WordlistResource,
     AsyncWordlistResource,
@@ -56,6 +64,14 @@
     WordlistResourceWithStreamingResponse,
     AsyncWordlistResourceWithStreamingResponse,
 )
+from .webhook_secret import (
+    WebhookSecretResource,
+    AsyncWebhookSecretResource,
+    WebhookSecretResourceWithRawResponse,
+    AsyncWebhookSecretResourceWithRawResponse,
+    WebhookSecretResourceWithStreamingResponse,
+    AsyncWebhookSecretResourceWithStreamingResponse,
+)
 
 __all__ = [
     "AuthorsResource",
@@ -100,4 +116,16 @@
     "AsyncWordlistResourceWithRawResponse",
     "WordlistResourceWithStreamingResponse",
     "AsyncWordlistResourceWithStreamingResponse",
+    "WebhooksResource",
+    "AsyncWebhooksResource",
+    "WebhooksResourceWithRawResponse",
+    "AsyncWebhooksResourceWithRawResponse",
+    "WebhooksResourceWithStreamingResponse",
+    "AsyncWebhooksResourceWithStreamingResponse",
+    "WebhookSecretResource",
+    "AsyncWebhookSecretResource",
+    "WebhookSecretResourceWithRawResponse",
+    "AsyncWebhookSecretResourceWithRawResponse",
+    "WebhookSecretResourceWithStreamingResponse",
+    "AsyncWebhookSecretResourceWithStreamingResponse",
 ]