1212from future import standard_library
1313standard_library .install_aliases ()
1414from builtins import object
15- import requests
1615import json
1716import sys
1817import os
2322from os .path import expanduser
2423import codecs
2524import urllib .parse
25+ import nuxeo .client
2626
2727# set the output to utf8 in py2 or py3
2828UTF8Writer = codecs .getwriter ('utf8' )
@@ -157,6 +157,8 @@ def __init__(self, conf={}, rcfile=None, loglevel=_loglevel_):
157157 redacted = self .conf
158158 redacted .update ({'password' : '...redacted...' })
159159 self .logger .debug (redacted )
160+ self .nuxeo_client = nuxeo .client .Nuxeo (auth = self .auth )
161+ self .request = self .nuxeo_client .client .request
160162
161163 ## Python generator for paged API resource
162164 # based on http://stackoverflow.com/questions/17702785/
@@ -173,12 +175,8 @@ def _get_page(self, url, params, current_page_index):
173175 :returns: json from nuxeo
174176 """
175177 params .update ({'currentPageIndex' : current_page_index })
176- res = requests .get (
177- url ,
178- headers = self .document_property_headers ,
179- params = params ,
180- auth = self .auth )
181- res .raise_for_status ()
178+ path = url .split (self .nuxeo_client .client .host ,1 )[1 ]
179+ res = self .request ('GET' , path , params = params )
182180 self .logger .debug (res .content )
183181 return json .loads (res .content .decode ('utf-8' ))
184182
@@ -249,9 +247,8 @@ def get_uid(self, path):
249247 :rtype: string
250248 """
251249 url = u'/' .join ([self .conf ['api' ], "path" , escape_path (path ).strip ('/' )])
252- res = requests .get (
253- url , headers = self .document_property_headers , auth = self .auth )
254- res .raise_for_status ()
250+ path = url .split (self .nuxeo_client .client .host ,1 )[1 ]
251+ res = self .request ('GET' , path )
255252 return json .loads (res .content .decode ('utf-8' ))['uid' ]
256253
257254 def get_metadata (self , ** documentid ):
@@ -268,9 +265,8 @@ def get_metadata(self, **documentid):
268265 elif 'uid' in documentid :
269266 uid = documentid ['uid' ]
270267 url = u'/' .join ([self .conf ['api' ], "id" , uid ])
271- res = requests .get (
272- url , headers = self .document_property_headers , auth = self .auth )
273- res .raise_for_status ()
268+ path = url .split (self .nuxeo_client .client .host ,1 )[1 ]
269+ res = self .request ('GET' , path )
274270 return json .loads (res .content .decode ('utf-8' ))
275271
276272 def update_nuxeo_properties (self , data , ** documentid ):
@@ -297,9 +293,8 @@ def update_nuxeo_properties(self, data, **documentid):
297293 payload ['uid' ] = uid
298294 payload ['entity-type' ] = data .get ('entity-type' , 'document' )
299295 payload ['properties' ] = data ['properties' ]
300- res = requests .put (
301- url , data = json .dumps (payload ), auth = self .auth , headers = headers )
302- res .raise_for_status ()
296+ path = url .split (self .nuxeo_client .client .host ,1 )[1 ]
297+ res = self .request ('PUT' , path , data = json .dumps (payload ))
303298 return json .loads (res .content )
304299
305300 def print_document_summary (self , documents ):
0 commit comments