Commitd6be0ce

committed

Requests chunk encoded request handling

1 parent4658b25 commitd6be0ceCopy full SHA for d6be0ce

File tree

+31

-0

lines changed

+31

-0

lines changed

Lines changed: 13 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`"""OpenAPI core contrib requests requests module"""`
	`2`	`+fromtypingimportMapping`
`2`	`3`	`fromtypingimportOptional`
`3`	`4`	`fromtypingimportUnion`
`4`	`5`	`fromurllib.parseimportparse_qs`
`@@ -7,6 +8,7 @@`
`7`	`8`	`fromrequestsimportPreparedRequest`
`8`	`9`	`fromrequestsimportRequest`
`9`	`10`	`fromrequests.cookiesimportRequestsCookieJar`
	`11`	`+fromrequests.utilsimportrewind_body`
`10`	`12`	`fromwerkzeug.datastructuresimportHeaders`
`11`	`13`	`fromwerkzeug.datastructuresimportImmutableMultiDict`
`12`	`14`
`@@ -67,6 +69,17 @@ def method(self) -> str:`
`67`	`69`	`defbody(self)->Optional[str]:`
`68`	`70`	`ifself.request.bodyisNone:`
`69`	`71`	`returnNone`
	`72`	`+is_stream=all(`
	`73`	`+ [`
	`74`	`+hasattr(self.request.body,"__iter__"),`
	`75`	`+notisinstance(self.request.body, (str,list,tuple,Mapping)),`
	`76`	`+ ]`
	`77`	`+ )`
	`78`	`+ifis_stream:`
	`79`	`+chunks=list(self.request.body)`
	`80`	`+body="".join(chunks)`
	`81`	`+self.request.body= (xforxinchunks)`
	`82`	`+returnbody`
`70`	`83`	`ifisinstance(self.request.body,bytes):`
`71`	`84`	`returnself.request.body.decode("utf-8")`
`72`	`85`	`assertisinstance(self.request.body,str)`

Lines changed: 18 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,5 @@`
	`1`	`+fromtypesimportGeneratorType`
	`2`	`+`
`1`	`3`	`importpytest`
`2`	`4`	`importrequests`
`3`	`5`	`importresponses`
`@@ -72,6 +74,22 @@ def test_request_validator_path_pattern(self, request_unmarshaller):`
`72`	`74`	`result=request_unmarshaller.unmarshal(openapi_request)`
`73`	`75`	`assertnotresult.errors`
`74`	`76`
	`77`	`+deftest_request_validator_encoded_chunks(self,request_unmarshaller):`
	`78`	`+defgen():`
	`79`	`+yield'{"param1": 1}'`
	`80`	`+`
	`81`	`+request=requests.Request(`
	`82`	`+"POST",`
	`83`	`+"http://localhost/browse/12/",`
	`84`	`+params={"q":"string"},`
	`85`	`+headers={"content-type":"application/json"},`
	`86`	`+data=gen(),`
	`87`	`+ )`
	`88`	`+openapi_request=RequestsOpenAPIRequest(request)`
	`89`	`+result=request_unmarshaller.unmarshal(openapi_request)`
	`90`	`+assertnotresult.errors`
	`91`	`+assertrequest.dataisGeneratorType`
	`92`	`+`
`75`	`93`	`deftest_request_validator_prepared_request(self,request_unmarshaller):`
`76`	`94`	`request=requests.Request(`
`77`	`95`	`"POST",`

Comments

(0)