@@ -13,53 +13,28 @@ def __init__(self, config):
13
13
'Content-Type' : 'application/json'
14
14
}
15
15
16
- def get (self , path ):
16
+ def send_request (self , http_method , path , body = None ):
17
17
try :
18
- request = requests .get (
19
- self .config .url + '/' + path ,
20
- headers = self .headers ,
21
- )
18
+ request_path = self .config .url + '/' + path
19
+ if body is None :
20
+ request = http_method (request_path , headers = self .headers )
21
+ else :
22
+ request = http_method (request_path , headers = self .headers , json = body )
22
23
return self .__validate (request )
23
24
except requests .exceptions .ConnectionError as err :
24
25
raise MeiliSearchCommunicationError (err )
25
26
27
+ def get (self , path ):
28
+ return self .send_request (requests .get , path )
29
+
26
30
def post (self , path , body = None ):
27
- if body is None :
28
- body = {}
29
- try :
30
- request = requests .post (
31
- self .config .url + '/' + path ,
32
- headers = self .headers ,
33
- json = body
34
- )
35
- return self .__validate (request )
36
- except requests .exceptions .ConnectionError as err :
37
- raise MeiliSearchCommunicationError (err )
31
+ return self .send_request (requests .post , path , body )
32
+
38
33
def put (self , path , body = None ):
39
- if body is None :
40
- body = {}
41
- try :
42
- request = requests .put (
43
- self .config .url + '/' + path ,
44
- headers = self .headers ,
45
- json = body
46
- )
47
- return self .__validate (request )
48
- except requests .exceptions .ConnectionError as err :
49
- raise MeiliSearchCommunicationError (err )
34
+ return self .send_request (requests .put , path , body )
50
35
51
36
def delete (self , path , body = None ):
52
- if body is None :
53
- body = {}
54
- try :
55
- request = requests .delete (
56
- self .config .url + '/' + path ,
57
- headers = self .headers ,
58
- json = body
59
- )
60
- return self .__validate (request )
61
- except requests .exceptions .ConnectionError as err :
62
- raise MeiliSearchCommunicationError (err )
37
+ return self .send_request (requests .delete , path , body )
63
38
64
39
@staticmethod
65
40
def __to_json (request ):
0 commit comments