bugfix
This commit is contained in:
parent
7b4eaf3cbe
commit
3270f2bfd6
@ -28,12 +28,18 @@ class ProxyProcessor(BaseProcessor):
|
|||||||
auth = None
|
auth = None
|
||||||
if d.get('user') and d.get('password'):
|
if d.get('user') and d.get('password'):
|
||||||
auth = BasicAuth(d['user'], d['password'])
|
auth = BasicAuth(d['user'], d['password'])
|
||||||
|
if g.get('headers'):
|
||||||
|
regH.update(d['headers'])
|
||||||
|
params = None
|
||||||
|
if d.get('params'):
|
||||||
|
params = params
|
||||||
async with client.request(
|
async with client.request(
|
||||||
request.method,
|
d.get('method', request.method),
|
||||||
d['url'],
|
d['url'],
|
||||||
auth=auth,
|
auth=auth,
|
||||||
headers = reqH,
|
headers = reqH,
|
||||||
allow_redirects=False,
|
allow_redirects=False,
|
||||||
|
params=paams,
|
||||||
data=await request.read()) as res:
|
data=await request.read()) as res:
|
||||||
headers = res.headers.copy()
|
headers = res.headers.copy()
|
||||||
# body = await res.read()
|
# body = await res.read()
|
||||||
|
Loading…
Reference in New Issue
Block a user