@@ -52,6 +52,16 @@ def update_payload(self, request, params):
52
52
)
53
53
return params
54
54
55
+ def preprocess_request_body (self , request ):
56
+ if request .body :
57
+ params = json .loads (request .body )
58
+ else :
59
+ params = {}
60
+ logger .debug (f"JSON Params: { params } " )
61
+ path = self .get_proxy_path (request )
62
+ params = self .update_payload (request , params )
63
+ return path , params
64
+
55
65
def send_request (
56
66
self , method , url , params = None , data = None , json = None , timeout = 180 , verify = True
57
67
):
@@ -85,10 +95,7 @@ def post(self, request, *args, **kwargs):
85
95
logger .debug ("----- Proxy POST" )
86
96
response = {"status" : "error" }
87
97
with logger .catch ():
88
- params = json .loads (request .body )
89
- logger .debug (f"JSON Params: { params } " )
90
- path = self .get_proxy_path (request )
91
- params = self .update_payload (request , params )
98
+ path , params = self .preprocess_request_body (request )
92
99
middle_resp_ = self .send_request ("POST" , path , json = params )
93
100
response = middle_resp_ .json ()
94
101
return self .response (response )
@@ -98,10 +105,7 @@ def patch(self, request, *args, **kwargs):
98
105
logger .debug ("----- Proxy PATCH" )
99
106
response = {"status" : "error" }
100
107
with logger .catch ():
101
- params = json .loads (request .body )
102
- logger .debug (f"JSON Params: { params } " )
103
- path = self .get_proxy_path (request )
104
- params = self .update_payload (request , params )
108
+ path , params = self .preprocess_request_body (request )
105
109
middle_resp_ = self .send_request ("PATCH" , path , json = params )
106
110
response = middle_resp_ .json ()
107
111
return self .response (response )
@@ -111,10 +115,7 @@ def delete(self, request, *args, **kwargs):
111
115
logger .debug ("----- Proxy DELETE" )
112
116
response = {"status" : "error" }
113
117
with logger .catch ():
114
- params = json .loads (request .body )
115
- logger .debug (f"JSON Params: { params } " )
116
- path = self .get_proxy_path (request )
117
- params = self .update_payload (request , params )
118
+ path , params = self .preprocess_request_body (request )
118
119
middle_resp_ = self .send_request ("DELETE" , path , json = params )
119
120
response = middle_resp_ .json ()
120
121
return self .response (response )
@@ -124,10 +125,7 @@ def put(self, request, *args, **kwargs):
124
125
logger .debug ("----- Proxy PUT" )
125
126
response = {"status" : "error" }
126
127
with logger .catch ():
127
- params = json .loads (request .body )
128
- logger .debug (f"JSON Params: { params } " )
129
- path = self .get_proxy_path (request )
130
- params = self .update_payload (request , params )
128
+ path , params = self .preprocess_request_body (request )
131
129
middle_resp_ = self .send_request ("PUT" , path , json = params )
132
130
response = middle_resp_ .json ()
133
131
return self .response (response )
0 commit comments