11"""Code generated by Speakeasy (https://speakeasyapi.dev). DO NOT EDIT."""
22
3- import requests as requests_http
4- from . import utils
3+ from . sdkconfiguration import SDKConfiguration
4+ from airbyte import utils
55from airbyte .models import operations , shared
66from typing import Optional
77
88class Connections :
9- _client : requests_http .Session
10- _security_client : requests_http .Session
11- _server_url : str
12- _language : str
13- _sdk_version : str
14- _gen_version : str
9+ sdk_configuration : SDKConfiguration
1510
16- def __init__ (self , client : requests_http .Session , security_client : requests_http .Session , server_url : str , language : str , sdk_version : str , gen_version : str ) -> None :
17- self ._client = client
18- self ._security_client = security_client
19- self ._server_url = server_url
20- self ._language = language
21- self ._sdk_version = sdk_version
22- self ._gen_version = gen_version
11+ def __init__ (self , sdk_config : SDKConfiguration ) -> None :
12+ self .sdk_configuration = sdk_config
2313
2414
2515 def create_connection (self , request : shared .ConnectionCreateRequest ) -> operations .CreateConnectionResponse :
2616 r"""Create a connection"""
27- base_url = self ._server_url
17+ base_url = utils . template_url ( * self .sdk_configuration . get_server_details ())
2818
29- url = base_url . removesuffix ( '/' ) + '/connections'
19+ url = base_url + '/connections'
3020 headers = {}
3121 req_content_type , data , form = utils .serialize_request_body (request , "request" , 'json' )
3222 if req_content_type not in ('multipart/form-data' , 'multipart/mixed' ):
3323 headers ['content-type' ] = req_content_type
3424 if data is None and form is None :
3525 raise Exception ('request body is required' )
3626 headers ['Accept' ] = 'application/json'
37- headers ['user-agent' ] = f'speakeasy-sdk/{ self ._language } { self ._sdk_version } { self ._gen_version } '
27+ headers ['user-agent' ] = f'speakeasy-sdk/{ self .sdk_configuration . language } { self .sdk_configuration . sdk_version } { self .sdk_configuration . gen_version } '
3828
39- client = self ._security_client
29+ client = self .sdk_configuration . security_client
4030
4131 http_res = client .request ('POST' , url , data = data , files = form , headers = headers )
4232 content_type = http_res .headers .get ('Content-Type' )
@@ -55,14 +45,14 @@ def create_connection(self, request: shared.ConnectionCreateRequest) -> operatio
5545
5646 def delete_connection (self , request : operations .DeleteConnectionRequest ) -> operations .DeleteConnectionResponse :
5747 r"""Delete a Connection"""
58- base_url = self ._server_url
48+ base_url = utils . template_url ( * self .sdk_configuration . get_server_details ())
5949
6050 url = utils .generate_url (operations .DeleteConnectionRequest , base_url , '/connections/{connectionId}' , request )
6151 headers = {}
6252 headers ['Accept' ] = '*/*'
63- headers ['user-agent' ] = f'speakeasy-sdk/{ self ._language } { self ._sdk_version } { self ._gen_version } '
53+ headers ['user-agent' ] = f'speakeasy-sdk/{ self .sdk_configuration . language } { self .sdk_configuration . sdk_version } { self .sdk_configuration . gen_version } '
6454
65- client = self ._security_client
55+ client = self .sdk_configuration . security_client
6656
6757 http_res = client .request ('DELETE' , url , headers = headers )
6858 content_type = http_res .headers .get ('Content-Type' )
@@ -75,14 +65,14 @@ def delete_connection(self, request: operations.DeleteConnectionRequest) -> oper
7565
7666 def get_connection (self , request : operations .GetConnectionRequest ) -> operations .GetConnectionResponse :
7767 r"""Get Connection details"""
78- base_url = self ._server_url
68+ base_url = utils . template_url ( * self .sdk_configuration . get_server_details ())
7969
8070 url = utils .generate_url (operations .GetConnectionRequest , base_url , '/connections/{connectionId}' , request )
8171 headers = {}
8272 headers ['Accept' ] = 'application/json'
83- headers ['user-agent' ] = f'speakeasy-sdk/{ self ._language } { self ._sdk_version } { self ._gen_version } '
73+ headers ['user-agent' ] = f'speakeasy-sdk/{ self .sdk_configuration . language } { self .sdk_configuration . sdk_version } { self .sdk_configuration . gen_version } '
8474
85- client = self ._security_client
75+ client = self .sdk_configuration . security_client
8676
8777 http_res = client .request ('GET' , url , headers = headers )
8878 content_type = http_res .headers .get ('Content-Type' )
@@ -101,15 +91,15 @@ def get_connection(self, request: operations.GetConnectionRequest) -> operations
10191
10292 def list_connections (self , request : operations .ListConnectionsRequest ) -> operations .ListConnectionsResponse :
10393 r"""List connections"""
104- base_url = self ._server_url
94+ base_url = utils . template_url ( * self .sdk_configuration . get_server_details ())
10595
106- url = base_url . removesuffix ( '/' ) + '/connections'
96+ url = base_url + '/connections'
10797 headers = {}
10898 query_params = utils .get_query_params (operations .ListConnectionsRequest , request )
10999 headers ['Accept' ] = 'application/json'
110- headers ['user-agent' ] = f'speakeasy-sdk/{ self ._language } { self ._sdk_version } { self ._gen_version } '
100+ headers ['user-agent' ] = f'speakeasy-sdk/{ self .sdk_configuration . language } { self .sdk_configuration . sdk_version } { self .sdk_configuration . gen_version } '
111101
112- client = self ._security_client
102+ client = self .sdk_configuration . security_client
113103
114104 http_res = client .request ('GET' , url , params = query_params , headers = headers )
115105 content_type = http_res .headers .get ('Content-Type' )
0 commit comments