from constrictor.task import Task
from constrictor.script import Script, ScriptManager
from constrictor.log import *
-from osrf.gateway import XMLGatewayRequest
import eg_utils
SERVICE = 'open-ils.actor'
Task.__init__(self, self.__class__.__name__)
def run(self, **kwargs):
- request = XMLGatewayRequest(SERVICE, METHOD)
+ request = eg_utils.request(SERVICE, METHOD)
return request.send()
from constrictor.task import Task
from constrictor.log import *
-from osrf.gateway import XMLGatewayRequest
import eg_utils
from oils.const import *
from osrf.net_obj import *
import osrf.json
from osrf.gateway import GatewayRequest, XMLGatewayRequest, JSONGatewayRequest
from oils.utils.idl import IDLParser
-from oils.utils.utils import eventText, eventCode, md5sum
+from oils.utils.utils import md5sum
+from oils.event import Event
from oils.const import *
import os, errno
def fetchSessionUser():
user = request('open-ils.auth', 'open-ils.auth.session.retrieve', authtoken()).send()
- if eventCode(user):
+ if Event.parse_event(user):
raise ILSEventException(osrf.json.to_json(user))
logInfo("fetched user %s" % user.usrname())
return user
file.close()
logInfo("parsing Evergreen IDL file...")
- parser.setIDL(filePath)
- parser.parseIDL()
+ parser.set_IDL(filePath)
+ parser.parse_IDL()
class AtomicReqWrapper(object):
'type' : 'staff'
}).send()
- if eventText(result) != OILS_EVENT_SUCCESS:
- raise AuthException(eventText(result))
+ evt = Event.parse_event(result)
+ if evt and not evt.success:
+ raise AuthException(evt.textcode)
__authtoken = result['payload']['authtoken']
return __authtoken