|
1 | 1 | """Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT.""" |
2 | 2 |
|
3 | | -import requests as requests_http |
4 | | -from . import utils |
| 3 | +from .sdkconfiguration import SDKConfiguration |
| 4 | +from codatsynccommerce import utils |
5 | 5 | from codatsynccommerce.models import operations, shared |
6 | 6 | from typing import Optional |
7 | 7 |
|
8 | 8 | class CompanyManagement: |
9 | 9 | r"""Create new and manage existing Sync for Commerce companies.""" |
10 | | - _client: requests_http.Session |
11 | | - _security_client: requests_http.Session |
12 | | - _server_url: str |
13 | | - _language: str |
14 | | - _sdk_version: str |
15 | | - _gen_version: str |
16 | | - |
17 | | - def __init__(self, client: requests_http.Session, security_client: requests_http.Session, server_url: str, language: str, sdk_version: str, gen_version: str) -> None: |
18 | | - self._client = client |
19 | | - self._security_client = security_client |
20 | | - self._server_url = server_url |
21 | | - self._language = language |
22 | | - self._sdk_version = sdk_version |
23 | | - self._gen_version = gen_version |
| 10 | + sdk_configuration: SDKConfiguration |
| 11 | + |
| 12 | + def __init__(self, sdk_config: SDKConfiguration) -> None: |
| 13 | + self.sdk_configuration = sdk_config |
24 | 14 |
|
25 | 15 |
|
26 | 16 | def create_company(self, request: shared.CreateCompany, retries: Optional[utils.RetryConfig] = None) -> operations.CreateCompanyResponse: |
27 | 17 | r"""Create Sync for Commerce company |
28 | 18 | Creates a Codat company with a commerce partner data connection. |
29 | 19 | """ |
30 | | - base_url = self._server_url |
| 20 | + base_url = utils.template_url(*self.sdk_configuration.get_server_details()) |
31 | 21 |
|
32 | | - url = base_url.removesuffix('/') + '/meta/companies/sync' |
| 22 | + url = base_url + '/meta/companies/sync' |
33 | 23 | headers = {} |
34 | 24 | req_content_type, data, form = utils.serialize_request_body(request, "request", 'json') |
35 | 25 | if req_content_type not in ('multipart/form-data', 'multipart/mixed'): |
36 | 26 | headers['content-type'] = req_content_type |
37 | 27 | headers['Accept'] = 'application/json' |
38 | | - headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}' |
| 28 | + headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}' |
39 | 29 |
|
40 | | - client = self._security_client |
| 30 | + client = self.sdk_configuration.security_client |
41 | 31 |
|
42 | 32 | retry_config = retries |
43 | 33 | if retry_config is None: |
@@ -69,17 +59,17 @@ def create_connection(self, request: operations.CreateConnectionRequest, retries |
69 | 59 | r"""Create connection |
70 | 60 | Create a data connection for company. |
71 | 61 | """ |
72 | | - base_url = self._server_url |
| 62 | + base_url = utils.template_url(*self.sdk_configuration.get_server_details()) |
73 | 63 |
|
74 | 64 | url = utils.generate_url(operations.CreateConnectionRequest, base_url, '/meta/companies/{companyId}/connections', request) |
75 | 65 | headers = {} |
76 | 66 | req_content_type, data, form = utils.serialize_request_body(request, "request_body", 'string') |
77 | 67 | if req_content_type not in ('multipart/form-data', 'multipart/mixed'): |
78 | 68 | headers['content-type'] = req_content_type |
79 | 69 | headers['Accept'] = 'application/json' |
80 | | - headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}' |
| 70 | + headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}' |
81 | 71 |
|
82 | | - client = self._security_client |
| 72 | + client = self.sdk_configuration.security_client |
83 | 73 |
|
84 | 74 | retry_config = retries |
85 | 75 | if retry_config is None: |
@@ -111,15 +101,15 @@ def list_companies(self, request: operations.ListCompaniesRequest, retries: Opti |
111 | 101 | r"""List companies |
112 | 102 | Retrieve a list of all companies the client has created. |
113 | 103 | """ |
114 | | - base_url = self._server_url |
| 104 | + base_url = utils.template_url(*self.sdk_configuration.get_server_details()) |
115 | 105 |
|
116 | | - url = base_url.removesuffix('/') + '/meta/companies' |
| 106 | + url = base_url + '/meta/companies' |
117 | 107 | headers = {} |
118 | 108 | query_params = utils.get_query_params(operations.ListCompaniesRequest, request) |
119 | 109 | headers['Accept'] = 'application/json' |
120 | | - headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}' |
| 110 | + headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}' |
121 | 111 |
|
122 | | - client = self._security_client |
| 112 | + client = self.sdk_configuration.security_client |
123 | 113 |
|
124 | 114 | retry_config = retries |
125 | 115 | if retry_config is None: |
@@ -151,15 +141,15 @@ def list_connections(self, request: operations.ListConnectionsRequest, retries: |
151 | 141 | r"""List data connections |
152 | 142 | Retrieve previously created data connections. |
153 | 143 | """ |
154 | | - base_url = self._server_url |
| 144 | + base_url = utils.template_url(*self.sdk_configuration.get_server_details()) |
155 | 145 |
|
156 | 146 | url = utils.generate_url(operations.ListConnectionsRequest, base_url, '/meta/companies/{companyId}/connections', request) |
157 | 147 | headers = {} |
158 | 148 | query_params = utils.get_query_params(operations.ListConnectionsRequest, request) |
159 | 149 | headers['Accept'] = 'application/json' |
160 | | - headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}' |
| 150 | + headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}' |
161 | 151 |
|
162 | | - client = self._security_client |
| 152 | + client = self.sdk_configuration.security_client |
163 | 153 |
|
164 | 154 | retry_config = retries |
165 | 155 | if retry_config is None: |
@@ -191,17 +181,17 @@ def update_connection(self, request: operations.UpdateConnectionRequest, retries |
191 | 181 | r"""Update data connection |
192 | 182 | Update a data connection |
193 | 183 | """ |
194 | | - base_url = self._server_url |
| 184 | + base_url = utils.template_url(*self.sdk_configuration.get_server_details()) |
195 | 185 |
|
196 | 186 | url = utils.generate_url(operations.UpdateConnectionRequest, base_url, '/meta/companies/{companyId}/connections/{connectionId}', request) |
197 | 187 | headers = {} |
198 | 188 | req_content_type, data, form = utils.serialize_request_body(request, "update_connection", 'json') |
199 | 189 | if req_content_type not in ('multipart/form-data', 'multipart/mixed'): |
200 | 190 | headers['content-type'] = req_content_type |
201 | 191 | headers['Accept'] = 'application/json' |
202 | | - headers['user-agent'] = f'speakeasy-sdk/{self._language} {self._sdk_version} {self._gen_version}' |
| 192 | + headers['user-agent'] = f'speakeasy-sdk/{self.sdk_configuration.language} {self.sdk_configuration.sdk_version} {self.sdk_configuration.gen_version}' |
203 | 193 |
|
204 | | - client = self._security_client |
| 194 | + client = self.sdk_configuration.security_client |
205 | 195 |
|
206 | 196 | retry_config = retries |
207 | 197 | if retry_config is None: |
|
0 commit comments