# File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details. from __future__ import annotations from typing_extensions import Literal from ..types import issue_list_params from .._httpx import httpx from .._types import Body, Omit, Query, Headers, NotGiven, omit, not_given from .._utils import path_template, maybe_transform from .._compat import cached_property from .._resource import SyncAPIResource, AsyncAPIResource from .._response import ( to_raw_response_wrapper, to_streamed_response_wrapper, async_to_raw_response_wrapper, async_to_streamed_response_wrapper, ) from ..pagination import SyncOffsetPaginationIssues, AsyncOffsetPaginationIssues from ..types.issue import Issue from .._base_client import AsyncPaginator, make_request_options __all__ = ["IssuesResource", "AsyncIssuesResource"] class IssuesResource(SyncAPIResource): @cached_property def with_raw_response(self) -> IssuesResourceWithRawResponse: """ This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. """ return IssuesResourceWithRawResponse(self) @cached_property def with_streaming_response(self) -> IssuesResourceWithStreamingResponse: """ An alternative to `.with_raw_response` that doesn't eagerly read the response body. """ return IssuesResourceWithStreamingResponse(self) def retrieve( self, id: str, *, # 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, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx.Timeout | None | NotGiven = not_given, ) -> Issue: """ **Beta:** This endpoint is in active development and may change without notice. Returns one issue for the authenticated tenant. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds """ if not id: raise ValueError(f"Expected a non-empty value for `id` but received {id!r}") return self._get( path_template("/api/v1/platform/issues/{id}", id=id), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=Issue, ) def list( self, *, limit: int | Omit = omit, offset: int | Omit = omit, session_id: str | Omit = omit, session_name: str | Omit = omit, severity: Literal[0, 1, 2, 3] | Omit = omit, sort_by: Literal["created_at", "updated_at", "severity"] | Omit = omit, status: Literal["open", "fixing", "watching", "completed", "ignored"] | Omit = omit, tag: str | Omit = omit, trace_id: str | Omit = omit, updated_at: 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, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx.Timeout | None | NotGiven = not_given, ) -> SyncOffsetPaginationIssues[Issue]: """ **Beta:** This endpoint is in active development and may change without notice. Returns issues for the authenticated tenant, optionally filtered by session, status, severity, tag, linked trace, or last modified time. Args: limit: Page size (positive integer; defaults to 50, capped at 500) offset: Page offset (non-negative integer; at most 100000) session_id: Filter by session ID (UUID) session_name: Filter by session name (exact match) severity: Filter by severity sort_by: Sort field status: Filter by status tag: Filter by tag (exact match) trace_id: Return only issues with a linked run in this trace updated_at: Return only issues updated at or after this RFC3339 timestamp extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds """ return self._get_api_list( "/api/v1/platform/issues", page=SyncOffsetPaginationIssues[Issue], options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout, query=maybe_transform( { "limit": limit, "offset": offset, "session_id": session_id, "session_name": session_name, "severity": severity, "sort_by": sort_by, "status": status, "tag": tag, "trace_id": trace_id, "updated_at": updated_at, }, issue_list_params.IssueListParams, ), ), model=Issue, ) class AsyncIssuesResource(AsyncAPIResource): @cached_property def with_raw_response(self) -> AsyncIssuesResourceWithRawResponse: """ This property can be used as a prefix for any HTTP method call to return the raw response object instead of the parsed content. """ return AsyncIssuesResourceWithRawResponse(self) @cached_property def with_streaming_response(self) -> AsyncIssuesResourceWithStreamingResponse: """ An alternative to `.with_raw_response` that doesn't eagerly read the response body. """ return AsyncIssuesResourceWithStreamingResponse(self) async def retrieve( self, id: str, *, # 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, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx.Timeout | None | NotGiven = not_given, ) -> Issue: """ **Beta:** This endpoint is in active development and may change without notice. Returns one issue for the authenticated tenant. Args: extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds """ if not id: raise ValueError(f"Expected a non-empty value for `id` but received {id!r}") return await self._get( path_template("/api/v1/platform/issues/{id}", id=id), options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout ), cast_to=Issue, ) def list( self, *, limit: int | Omit = omit, offset: int | Omit = omit, session_id: str | Omit = omit, session_name: str | Omit = omit, severity: Literal[0, 1, 2, 3] | Omit = omit, sort_by: Literal["created_at", "updated_at", "severity"] | Omit = omit, status: Literal["open", "fixing", "watching", "completed", "ignored"] | Omit = omit, tag: str | Omit = omit, trace_id: str | Omit = omit, updated_at: 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, extra_query: Query | None = None, extra_body: Body | None = None, timeout: float | httpx.Timeout | None | NotGiven = not_given, ) -> AsyncPaginator[Issue, AsyncOffsetPaginationIssues[Issue]]: """ **Beta:** This endpoint is in active development and may change without notice. Returns issues for the authenticated tenant, optionally filtered by session, status, severity, tag, linked trace, or last modified time. Args: limit: Page size (positive integer; defaults to 50, capped at 500) offset: Page offset (non-negative integer; at most 100000) session_id: Filter by session ID (UUID) session_name: Filter by session name (exact match) severity: Filter by severity sort_by: Sort field status: Filter by status tag: Filter by tag (exact match) trace_id: Return only issues with a linked run in this trace updated_at: Return only issues updated at or after this RFC3339 timestamp extra_headers: Send extra headers extra_query: Add additional query parameters to the request extra_body: Add additional JSON properties to the request timeout: Override the client-level default timeout for this request, in seconds """ return self._get_api_list( "/api/v1/platform/issues", page=AsyncOffsetPaginationIssues[Issue], options=make_request_options( extra_headers=extra_headers, extra_query=extra_query, extra_body=extra_body, timeout=timeout, query=maybe_transform( { "limit": limit, "offset": offset, "session_id": session_id, "session_name": session_name, "severity": severity, "sort_by": sort_by, "status": status, "tag": tag, "trace_id": trace_id, "updated_at": updated_at, }, issue_list_params.IssueListParams, ), ), model=Issue, ) class IssuesResourceWithRawResponse: def __init__(self, issues: IssuesResource) -> None: self._issues = issues self.retrieve = to_raw_response_wrapper( issues.retrieve, ) self.list = to_raw_response_wrapper( issues.list, ) class AsyncIssuesResourceWithRawResponse: def __init__(self, issues: AsyncIssuesResource) -> None: self._issues = issues self.retrieve = async_to_raw_response_wrapper( issues.retrieve, ) self.list = async_to_raw_response_wrapper( issues.list, ) class IssuesResourceWithStreamingResponse: def __init__(self, issues: IssuesResource) -> None: self._issues = issues self.retrieve = to_streamed_response_wrapper( issues.retrieve, ) self.list = to_streamed_response_wrapper( issues.list, ) class AsyncIssuesResourceWithStreamingResponse: def __init__(self, issues: AsyncIssuesResource) -> None: self._issues = issues self.retrieve = async_to_streamed_response_wrapper( issues.retrieve, ) self.list = async_to_streamed_response_wrapper( issues.list, )