|
| 1 | +"""Code generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.""" |
| 2 | + |
| 3 | +from .basesdk import BaseSDK |
| 4 | +from polar_sdk import models, utils |
| 5 | +from polar_sdk._hooks import HookContext |
| 6 | +from polar_sdk.types import BaseModel, OptionalNullable, UNSET |
| 7 | +from typing import Any, Mapping, Optional, Union, cast |
| 8 | + |
| 9 | + |
| 10 | +class CustomerSessions(BaseSDK): |
| 11 | + def create( |
| 12 | + self, |
| 13 | + *, |
| 14 | + request: Union[ |
| 15 | + models.CustomerSessionCreate, models.CustomerSessionCreateTypedDict |
| 16 | + ], |
| 17 | + retries: OptionalNullable[utils.RetryConfig] = UNSET, |
| 18 | + server_url: Optional[str] = None, |
| 19 | + timeout_ms: Optional[int] = None, |
| 20 | + http_headers: Optional[Mapping[str, str]] = None, |
| 21 | + ) -> models.CustomerSession: |
| 22 | + r"""Create Customer Session |
| 23 | +
|
| 24 | + Create a customer session. |
| 25 | +
|
| 26 | + :param request: The request object to send. |
| 27 | + :param retries: Override the default retry configuration for this method |
| 28 | + :param server_url: Override the default server URL for this method |
| 29 | + :param timeout_ms: Override the default request timeout configuration for this method in milliseconds |
| 30 | + :param http_headers: Additional headers to set or replace on requests. |
| 31 | + """ |
| 32 | + base_url = None |
| 33 | + url_variables = None |
| 34 | + if timeout_ms is None: |
| 35 | + timeout_ms = self.sdk_configuration.timeout_ms |
| 36 | + |
| 37 | + if server_url is not None: |
| 38 | + base_url = server_url |
| 39 | + |
| 40 | + if not isinstance(request, BaseModel): |
| 41 | + request = utils.unmarshal(request, models.CustomerSessionCreate) |
| 42 | + request = cast(models.CustomerSessionCreate, request) |
| 43 | + |
| 44 | + req = self.build_request( |
| 45 | + method="POST", |
| 46 | + path="/v1/customer-sessions/", |
| 47 | + base_url=base_url, |
| 48 | + url_variables=url_variables, |
| 49 | + request=request, |
| 50 | + request_body_required=True, |
| 51 | + request_has_path_params=False, |
| 52 | + request_has_query_params=True, |
| 53 | + user_agent_header="user-agent", |
| 54 | + accept_header_value="application/json", |
| 55 | + http_headers=http_headers, |
| 56 | + security=self.sdk_configuration.security, |
| 57 | + get_serialized_body=lambda: utils.serialize_request_body( |
| 58 | + request, False, False, "json", models.CustomerSessionCreate |
| 59 | + ), |
| 60 | + timeout_ms=timeout_ms, |
| 61 | + ) |
| 62 | + |
| 63 | + if retries == UNSET: |
| 64 | + if self.sdk_configuration.retry_config is not UNSET: |
| 65 | + retries = self.sdk_configuration.retry_config |
| 66 | + |
| 67 | + retry_config = None |
| 68 | + if isinstance(retries, utils.RetryConfig): |
| 69 | + retry_config = (retries, ["429", "500", "502", "503", "504"]) |
| 70 | + |
| 71 | + http_res = self.do_request( |
| 72 | + hook_ctx=HookContext( |
| 73 | + operation_id="customer-sessions:create", |
| 74 | + oauth2_scopes=[], |
| 75 | + security_source=self.sdk_configuration.security, |
| 76 | + ), |
| 77 | + request=req, |
| 78 | + error_status_codes=["422", "4XX", "5XX"], |
| 79 | + retry_config=retry_config, |
| 80 | + ) |
| 81 | + |
| 82 | + data: Any = None |
| 83 | + if utils.match_response(http_res, "201", "application/json"): |
| 84 | + return utils.unmarshal_json(http_res.text, models.CustomerSession) |
| 85 | + if utils.match_response(http_res, "422", "application/json"): |
| 86 | + data = utils.unmarshal_json(http_res.text, models.HTTPValidationErrorData) |
| 87 | + raise models.HTTPValidationError(data=data) |
| 88 | + if utils.match_response(http_res, ["4XX", "5XX"], "*"): |
| 89 | + http_res_text = utils.stream_to_text(http_res) |
| 90 | + raise models.SDKError( |
| 91 | + "API error occurred", http_res.status_code, http_res_text, http_res |
| 92 | + ) |
| 93 | + |
| 94 | + content_type = http_res.headers.get("Content-Type") |
| 95 | + http_res_text = utils.stream_to_text(http_res) |
| 96 | + raise models.SDKError( |
| 97 | + f"Unexpected response received (code: {http_res.status_code}, type: {content_type})", |
| 98 | + http_res.status_code, |
| 99 | + http_res_text, |
| 100 | + http_res, |
| 101 | + ) |
| 102 | + |
| 103 | + async def create_async( |
| 104 | + self, |
| 105 | + *, |
| 106 | + request: Union[ |
| 107 | + models.CustomerSessionCreate, models.CustomerSessionCreateTypedDict |
| 108 | + ], |
| 109 | + retries: OptionalNullable[utils.RetryConfig] = UNSET, |
| 110 | + server_url: Optional[str] = None, |
| 111 | + timeout_ms: Optional[int] = None, |
| 112 | + http_headers: Optional[Mapping[str, str]] = None, |
| 113 | + ) -> models.CustomerSession: |
| 114 | + r"""Create Customer Session |
| 115 | +
|
| 116 | + Create a customer session. |
| 117 | +
|
| 118 | + :param request: The request object to send. |
| 119 | + :param retries: Override the default retry configuration for this method |
| 120 | + :param server_url: Override the default server URL for this method |
| 121 | + :param timeout_ms: Override the default request timeout configuration for this method in milliseconds |
| 122 | + :param http_headers: Additional headers to set or replace on requests. |
| 123 | + """ |
| 124 | + base_url = None |
| 125 | + url_variables = None |
| 126 | + if timeout_ms is None: |
| 127 | + timeout_ms = self.sdk_configuration.timeout_ms |
| 128 | + |
| 129 | + if server_url is not None: |
| 130 | + base_url = server_url |
| 131 | + |
| 132 | + if not isinstance(request, BaseModel): |
| 133 | + request = utils.unmarshal(request, models.CustomerSessionCreate) |
| 134 | + request = cast(models.CustomerSessionCreate, request) |
| 135 | + |
| 136 | + req = self.build_request_async( |
| 137 | + method="POST", |
| 138 | + path="/v1/customer-sessions/", |
| 139 | + base_url=base_url, |
| 140 | + url_variables=url_variables, |
| 141 | + request=request, |
| 142 | + request_body_required=True, |
| 143 | + request_has_path_params=False, |
| 144 | + request_has_query_params=True, |
| 145 | + user_agent_header="user-agent", |
| 146 | + accept_header_value="application/json", |
| 147 | + http_headers=http_headers, |
| 148 | + security=self.sdk_configuration.security, |
| 149 | + get_serialized_body=lambda: utils.serialize_request_body( |
| 150 | + request, False, False, "json", models.CustomerSessionCreate |
| 151 | + ), |
| 152 | + timeout_ms=timeout_ms, |
| 153 | + ) |
| 154 | + |
| 155 | + if retries == UNSET: |
| 156 | + if self.sdk_configuration.retry_config is not UNSET: |
| 157 | + retries = self.sdk_configuration.retry_config |
| 158 | + |
| 159 | + retry_config = None |
| 160 | + if isinstance(retries, utils.RetryConfig): |
| 161 | + retry_config = (retries, ["429", "500", "502", "503", "504"]) |
| 162 | + |
| 163 | + http_res = await self.do_request_async( |
| 164 | + hook_ctx=HookContext( |
| 165 | + operation_id="customer-sessions:create", |
| 166 | + oauth2_scopes=[], |
| 167 | + security_source=self.sdk_configuration.security, |
| 168 | + ), |
| 169 | + request=req, |
| 170 | + error_status_codes=["422", "4XX", "5XX"], |
| 171 | + retry_config=retry_config, |
| 172 | + ) |
| 173 | + |
| 174 | + data: Any = None |
| 175 | + if utils.match_response(http_res, "201", "application/json"): |
| 176 | + return utils.unmarshal_json(http_res.text, models.CustomerSession) |
| 177 | + if utils.match_response(http_res, "422", "application/json"): |
| 178 | + data = utils.unmarshal_json(http_res.text, models.HTTPValidationErrorData) |
| 179 | + raise models.HTTPValidationError(data=data) |
| 180 | + if utils.match_response(http_res, ["4XX", "5XX"], "*"): |
| 181 | + http_res_text = await utils.stream_to_text_async(http_res) |
| 182 | + raise models.SDKError( |
| 183 | + "API error occurred", http_res.status_code, http_res_text, http_res |
| 184 | + ) |
| 185 | + |
| 186 | + content_type = http_res.headers.get("Content-Type") |
| 187 | + http_res_text = await utils.stream_to_text_async(http_res) |
| 188 | + raise models.SDKError( |
| 189 | + f"Unexpected response received (code: {http_res.status_code}, type: {content_type})", |
| 190 | + http_res.status_code, |
| 191 | + http_res_text, |
| 192 | + http_res, |
| 193 | + ) |
0 commit comments