Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit70a5cfd

Browse files
committed
refactor: move response_content into backend code
1 parent4afeaff commit70a5cfd

File tree

14 files changed

+79
-67
lines changed

14 files changed

+79
-67
lines changed

‎gitlab/_backends/protocol.py

Lines changed: 13 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
importabc
22
importsys
3-
fromtypingimportAny,Dict,Optional,Union
3+
fromtypingimportAny,Callable,Dict,Iterator,Optional,Union
44

55
importrequests
66
fromrequests_toolbelt.multipart.encoderimportMultipartEncoder# type: ignore
@@ -32,3 +32,15 @@ def http_request(
3232
**kwargs:Any,
3333
)->BackendResponse:
3434
...
35+
36+
@abc.abstractmethod
37+
defresponse_content(
38+
self,
39+
response:requests.Response,
40+
streamed:bool,
41+
action:Optional[Callable[[bytes],None]],
42+
chunk_size:int,
43+
*,
44+
iterator:bool,
45+
)->Optional[Union[bytes,Iterator[Any]]]:
46+
...

‎gitlab/_backends/requests_backend.py

Lines changed: 26 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,13 @@
11
from __future__importannotations
22

3-
fromtypingimportAny,Dict,Optional,Tuple,TYPE_CHECKING,Union
3+
fromtypingimportAny,Callable,Dict,Iterator,Optional,Tuple,TYPE_CHECKING,Union
44

55
importrequests
66
fromrequests.structuresimportCaseInsensitiveDict
77
fromrequests_toolbelt.multipart.encoderimportMultipartEncoder# type: ignore
88

9+
fromgitlab.utilsimport_StdoutStream
10+
911
from .importprotocol
1012

1113

@@ -117,3 +119,26 @@ def http_request(
117119
**kwargs,
118120
)
119121
returnRequestsResponse(response=response)
122+
123+
defresponse_content(
124+
self,
125+
response:requests.Response,
126+
streamed:bool,
127+
action:Optional[Callable[[bytes],None]],
128+
chunk_size:int,
129+
*,
130+
iterator:bool,
131+
)->Optional[Union[bytes,Iterator[Any]]]:
132+
ifiterator:
133+
returnresponse.iter_content(chunk_size=chunk_size)
134+
135+
ifstreamedisFalse:
136+
returnresponse.content
137+
138+
ifactionisNone:
139+
action=_StdoutStream()
140+
141+
forchunkinresponse.iter_content(chunk_size=chunk_size):
142+
ifchunk:
143+
action(chunk)
144+
returnNone

‎gitlab/mixins.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -637,7 +637,7 @@ def download(
637637
)
638638
ifTYPE_CHECKING:
639639
assertisinstance(result,requests.Response)
640-
returnutils.response_content(
640+
returnself.manager.gitlab._backend.response_content(
641641
result,streamed,action,chunk_size,iterator=iterator
642642
)
643643

‎gitlab/utils.py

Lines changed: 1 addition & 26 deletions
Original file line numberDiff line numberDiff line change
@@ -2,9 +2,7 @@
22
importtraceback
33
importurllib.parse
44
importwarnings
5-
fromtypingimportAny,Callable,Dict,Iterator,Optional,Tuple,Type,Union
6-
7-
importrequests
5+
fromtypingimportAny,Dict,Optional,Tuple,Type,Union
86

97
fromgitlabimporttypes
108

@@ -14,29 +12,6 @@ def __call__(self, chunk: Any) -> None:
1412
print(chunk)
1513

1614

17-
defresponse_content(
18-
response:requests.Response,
19-
streamed:bool,
20-
action:Optional[Callable[[bytes],None]],
21-
chunk_size:int,
22-
*,
23-
iterator:bool,
24-
)->Optional[Union[bytes,Iterator[Any]]]:
25-
ifiterator:
26-
returnresponse.iter_content(chunk_size=chunk_size)
27-
28-
ifstreamedisFalse:
29-
returnresponse.content
30-
31-
ifactionisNone:
32-
action=_StdoutStream()
33-
34-
forchunkinresponse.iter_content(chunk_size=chunk_size):
35-
ifchunk:
36-
action(chunk)
37-
returnNone
38-
39-
4015
def_transform_types(
4116
data:Dict[str,Any],
4217
custom_types:Dict[str,Any],

‎gitlab/v4/objects/artifacts.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ def download(
111111
)
112112
ifTYPE_CHECKING:
113113
assertisinstance(result,requests.Response)
114-
returnutils.response_content(
114+
returnself.gitlab._backend.response_content(
115115
result,streamed,action,chunk_size,iterator=iterator
116116
)
117117

@@ -162,6 +162,6 @@ def raw(
162162
)
163163
ifTYPE_CHECKING:
164164
assertisinstance(result,requests.Response)
165-
returnutils.response_content(
165+
returnself.gitlab._backend.response_content(
166166
result,streamed,action,chunk_size,iterator=iterator
167167
)

‎gitlab/v4/objects/files.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -266,7 +266,7 @@ def raw(
266266
)
267267
ifTYPE_CHECKING:
268268
assertisinstance(result,requests.Response)
269-
returnutils.response_content(
269+
returnself.gitlab._backend.response_content(
270270
result,streamed,action,chunk_size,iterator=iterator
271271
)
272272

‎gitlab/v4/objects/jobs.py

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,6 @@
44

55
fromgitlabimportcli
66
fromgitlabimportexceptionsasexc
7-
fromgitlabimportutils
87
fromgitlab.baseimportRESTManager,RESTObject
98
fromgitlab.mixinsimportRefreshMixin,RetrieveMixin
109
fromgitlab.typesimportArrayAttribute
@@ -149,7 +148,7 @@ def artifacts(
149148
)
150149
ifTYPE_CHECKING:
151150
assertisinstance(result,requests.Response)
152-
returnutils.response_content(
151+
returnself.manager.gitlab._backend.response_content(
153152
result,streamed,action,chunk_size,iterator=iterator
154153
)
155154

@@ -192,7 +191,7 @@ def artifact(
192191
)
193192
ifTYPE_CHECKING:
194193
assertisinstance(result,requests.Response)
195-
returnutils.response_content(
194+
returnself.manager.gitlab._backend.response_content(
196195
result,streamed,action,chunk_size,iterator=iterator
197196
)
198197

@@ -233,7 +232,7 @@ def trace(
233232
)
234233
ifTYPE_CHECKING:
235234
assertisinstance(result,requests.Response)
236-
return_value=utils.response_content(
235+
return_value=self.manager.gitlab._backend.response_content(
237236
result,streamed,action,chunk_size,iterator=iterator
238237
)
239238
ifTYPE_CHECKING:

‎gitlab/v4/objects/packages.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111

1212
fromgitlabimportcli
1313
fromgitlabimportexceptionsasexc
14-
fromgitlabimportutils
1514
fromgitlab.baseimportRESTManager,RESTObject
1615
fromgitlab.mixinsimportDeleteMixin,GetMixin,ListMixin,ObjectDeleteMixin
1716

@@ -136,7 +135,7 @@ def download(
136135
result=self.gitlab.http_get(path,streamed=streamed,raw=True,**kwargs)
137136
ifTYPE_CHECKING:
138137
assertisinstance(result,requests.Response)
139-
returnutils.response_content(
138+
returnself.gitlab._backend.response_content(
140139
result,streamed,action,chunk_size,iterator=iterator
141140
)
142141

‎gitlab/v4/objects/projects.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -541,7 +541,7 @@ def snapshot(
541541
)
542542
ifTYPE_CHECKING:
543543
assertisinstance(result,requests.Response)
544-
returnutils.response_content(
544+
returnself.manager.gitlab._backend.response_content(
545545
result,streamed,action,chunk_size,iterator=iterator
546546
)
547547

‎gitlab/v4/objects/repositories.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ def repository_raw_blob(
140140
)
141141
ifTYPE_CHECKING:
142142
assertisinstance(result,requests.Response)
143-
returnutils.response_content(
143+
returnself.manager.gitlab._backend.response_content(
144144
result,streamed,action,chunk_size,iterator=iterator
145145
)
146146

@@ -242,7 +242,7 @@ def repository_archive(
242242
)
243243
ifTYPE_CHECKING:
244244
assertisinstance(result,requests.Response)
245-
returnutils.response_content(
245+
returnself.manager.gitlab._backend.response_content(
246246
result,streamed,action,chunk_size,iterator=iterator
247247
)
248248

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp