Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
def _toggle_speedups(enabled):
import simplejson.decoder as dec
import simplejson.encoder as enc
import simplejson.scanner as scan
c_make_encoder = _import_c_make_encoder()
if enabled:
dec.scanstring = dec.c_scanstring or dec.py_scanstring
enc.c_make_encoder = c_make_encoder
enc.encode_basestring_ascii = (enc.c_encode_basestring_ascii or
enc.py_encode_basestring_ascii)
scan.make_scanner = scan.c_make_scanner or scan.py_make_scanner
else:
dec.scanstring = dec.py_scanstring
enc.c_make_encoder = None
enc.encode_basestring_ascii = enc.py_encode_basestring_ascii
scan.make_scanner = scan.py_make_scanner
dec.make_scanner = scan.make_scanner
global _default_decoder
_default_decoder = JSONDecoder(
encoding=None,
object_hook=None,
object_pairs_hook=None,
)
def _toggle_speedups(enabled):
from . import decoder as dec
from . import encoder as enc
from . import scanner as scan
c_make_encoder = _import_c_make_encoder()
if enabled:
dec.scanstring = dec.c_scanstring or dec.py_scanstring
enc.c_make_encoder = c_make_encoder
enc.encode_basestring_ascii = (enc.c_encode_basestring_ascii or
enc.py_encode_basestring_ascii)
scan.make_scanner = scan.c_make_scanner or scan.py_make_scanner
else:
dec.scanstring = dec.py_scanstring
enc.c_make_encoder = None
enc.encode_basestring_ascii = enc.py_encode_basestring_ascii
scan.make_scanner = scan.py_make_scanner
dec.make_scanner = scan.make_scanner
global _default_decoder
_default_decoder = JSONDecoder(
encoding=None,
object_hook=None,
object_pairs_hook=None,
)
def _toggle_speedups(enabled):
from . import decoder as dec
from . import encoder as enc
from . import scanner as scan
c_make_encoder = _import_c_make_encoder()
if enabled:
dec.scanstring = dec.c_scanstring or dec.py_scanstring
enc.c_make_encoder = c_make_encoder
enc.encode_basestring_ascii = (enc.c_encode_basestring_ascii or
enc.py_encode_basestring_ascii)
scan.make_scanner = scan.c_make_scanner or scan.py_make_scanner
else:
dec.scanstring = dec.py_scanstring
enc.c_make_encoder = None
enc.encode_basestring_ascii = enc.py_encode_basestring_ascii
scan.make_scanner = scan.py_make_scanner
dec.make_scanner = scan.make_scanner
global _default_decoder
_default_decoder = JSONDecoder(
encoding=None,
object_hook=None,
object_pairs_hook=None,
)
def _toggle_speedups(enabled):
import simplejson.decoder as dec
import simplejson.encoder as enc
import simplejson.scanner as scan
c_make_encoder = _import_c_make_encoder()
if enabled:
dec.scanstring = dec.c_scanstring or dec.py_scanstring
enc.c_make_encoder = c_make_encoder
enc.encode_basestring_ascii = (enc.c_encode_basestring_ascii or
enc.py_encode_basestring_ascii)
scan.make_scanner = scan.c_make_scanner or scan.py_make_scanner
else:
dec.scanstring = dec.py_scanstring
enc.c_make_encoder = None
enc.encode_basestring_ascii = enc.py_encode_basestring_ascii
scan.make_scanner = scan.py_make_scanner
dec.make_scanner = scan.make_scanner
global _default_decoder
_default_decoder = JSONDecoder(
encoding=None,
object_hook=None,
object_pairs_hook=None,
)
elif response.status_code == 403:
raise AuthorizationError()
elif response.status_code == 404:
raise ResourceNameError()
elif response.status_code == 416:
raise DatasetError()
elif response.status_code == 500:
raise ServerError()
elif response.status_code == 503:
raise ServiceError()
else:
raise UnknownResponseError()
# check for response content errors
try:
return response.json()
except simplejson.decoder.JSONDecodeError as e:
logger.error(e.msg)
raise InvalidResponseError()
@raise WebserviceError: if the connection is interrupted
"""
next_row = None
try:
line = self.connection.next()
if line.startswith("]"):
self.footer += line;
for otherline in self.connection:
self.footer += line
self.check_return_status()
else:
line = line.strip().strip(',')
if len(line) > 0:
try:
row = json.loads(line)
except json.decoder.JSONDecodeError, e:
raise WebserviceError("Error parsing line from results: '" + line + "' - " + str(e))
next_row = self.parser.parse(row)
except StopIteration:
raise WebserviceError("Connection interrupted")
if next_row is None:
raise StopIteration
else:
return next_row
def _toggle_speedups(enabled):
import simplejson.decoder as dec
import simplejson.encoder as enc
import simplejson.scanner as scan
c_make_encoder = _import_c_make_encoder()
if enabled:
dec.scanstring = dec.c_scanstring or dec.py_scanstring
enc.c_make_encoder = c_make_encoder
enc.encode_basestring_ascii = (enc.c_encode_basestring_ascii or
enc.py_encode_basestring_ascii)
scan.make_scanner = scan.c_make_scanner or scan.py_make_scanner
else:
dec.scanstring = dec.py_scanstring
enc.c_make_encoder = None
enc.encode_basestring_ascii = enc.py_encode_basestring_ascii
scan.make_scanner = scan.py_make_scanner
dec.make_scanner = scan.make_scanner
global _default_decoder
_default_decoder = JSONDecoder(
encoding=None,
object_hook=None,
object_pairs_hook=None,
)
return request.send_error(404)
if not os.path.exists(path):
logging.error("json.server - non existing file - %s" % path)
request.send_error(404)
return
try:
logging.warn("json.server - attempting to construct %s" % path)
try:
try:
result = Persist(path)
if result.data and result.data.public:
return dumps(result.data)
else:
request.send_error(404)
except (TypeError, simplejson.decoder.JSONDecodeError):
result = Config(path)
logging.warn("json.server - got config - %s" % str(result))
if result and result.public:
try:
return dumps(result)
except TypeError:
request.send_error(404)
except (IOError, TypeError):
handle_exception()
request.send_error(404)
return
request.send_error(404)
except Exception, ex:
handle_exception()
request.send_error(500)
return
def _handle_response(self, response):
try:
response_json = response.json()
except simplejson.decoder.JSONDecodeError:
raise ApiException({'message': response.text}, response.status_code)
if 200 <= response.status_code <= 299:
return response_json
else:
raise ApiException(response_json, response.status_code)