Lines Matching refs:self
203 def __init__(self, url, errcode, errmsg, headers):
204 Error.__init__(self)
205 self.url = url
206 self.errcode = errcode
207 self.errmsg = errmsg
208 self.headers = headers
209 def __repr__(self):
212 (self.__class__.__name__, self.url, self.errcode, self.errmsg)
235 def __init__(self, faultCode, faultString, **extra):
236 Error.__init__(self)
237 self.faultCode = faultCode
238 self.faultString = faultString
239 def __repr__(self):
240 return "<%s %s: %r>" % (self.__class__.__name__,
241 self.faultCode, self.faultString)
302 def __init__(self, value=0):
304 self.value = value
306 self.value = _strftime(value)
308 def make_comparable(self, other):
310 s = self.value
313 s = self.value
316 s = self.value
319 s = self.timetuple()
322 s = self
326 def __lt__(self, other):
327 s, o = self.make_comparable(other)
332 def __le__(self, other):
333 s, o = self.make_comparable(other)
338 def __gt__(self, other):
339 s, o = self.make_comparable(other)
344 def __ge__(self, other):
345 s, o = self.make_comparable(other)
350 def __eq__(self, other):
351 s, o = self.make_comparable(other)
356 def timetuple(self):
357 return time.strptime(self.value, "%Y%m%dT%H:%M:%S")
364 def __str__(self):
365 return self.value
367 def __repr__(self):
368 return "<%s %r at %#x>" % (self.__class__.__name__, self.value, id(self))
370 def decode(self, data):
371 self.value = str(data).strip()
373 def encode(self, out):
375 out.write(self.value)
396 def __init__(self, data=None):
404 self.data = data
411 def __str__(self):
412 return str(self.data, "latin-1") # XXX encoding?!
414 def __eq__(self, other):
417 return self.data == other
419 def decode(self, data):
420 self.data = base64.decodebytes(data)
422 def encode(self, out):
424 encoded = base64.encodebytes(self.data)
441 def __init__(self, target):
442 self._parser = parser = expat.ParserCreate(None, None)
443 self._target = target
450 def feed(self, data):
451 self._parser.Parse(data, False)
453 def close(self):
455 parser = self._parser
459 del self._target, self._parser # get rid of circular references
485 def __init__(self, encoding=None, allow_none=False):
486 self.memo = {}
487 self.data = None
488 self.encoding = encoding
489 self.allow_none = allow_none
493 def dumps(self, values):
496 dump = self.__dump
520 def __dump(self, value, write):
522 f = self.dispatch[type(value)]
531 if type_ in self.dispatch.keys():
535 f = self.dispatch["_arbitrary_instance"]
536 f(self, value, write)
538 def dump_nil (self, value, write):
539 if not self.allow_none:
544 def dump_bool(self, value, write):
550 def dump_long(self, value, write):
561 def dump_double(self, value, write):
567 def dump_unicode(self, value, write, escape=escape):
573 def dump_bytes(self, value, write):
581 def dump_array(self, value, write):
583 if i in self.memo:
585 self.memo[i] = None
586 dump = self.__dump
591 del self.memo[i]
595 def dump_struct(self, value, write, escape=escape):
597 if i in self.memo:
599 self.memo[i] = None
600 dump = self.__dump
610 del self.memo[i]
613 def dump_datetime(self, value, write):
619 def dump_instance(self, value, write):
622 self.write = write
623 value.encode(self)
624 del self.write
627 self.dump_struct(value.__dict__, write)
651 def __init__(self, use_datetime=False, use_builtin_types=False):
652 self._type = None
653 self._stack = []
654 self._marks = []
655 self._data = []
656 self._value = False
657 self._methodname = None
658 self._encoding = "utf-8"
659 self.append = self._stack.append
660 self._use_datetime = use_builtin_types or use_datetime
661 self._use_bytes = use_builtin_types
663 def close(self):
665 if self._type is None or self._marks:
667 if self._type == "fault":
668 raise Fault(**self._stack[0])
669 return tuple(self._stack)
671 def getmethodname(self):
672 return self._methodname
677 def xml(self, encoding, standalone):
678 self._encoding = encoding
681 def start(self, tag, attrs):
686 self._marks.append(len(self._stack))
687 self._data = []
688 if self._value and tag not in self.dispatch:
690 self._value = (tag == "value")
692 def data(self, text):
693 self._data.append(text)
695 def end(self, tag):
698 f = self.dispatch[tag]
703 f = self.dispatch[tag.split(':')[-1]]
706 return f(self, "".join(self._data))
711 def end_dispatch(self, tag, data):
714 f = self.dispatch[tag]
719 f = self.dispatch[tag.split(':')[-1]]
722 return f(self, data)
729 def end_nil (self, data):
730 self.append(None)
731 self._value = 0
734 def end_boolean(self, data):
736 self.append(False)
738 self.append(True)
741 self._value = 0
744 def end_int(self, data):
745 self.append(int(data))
746 self._value = 0
754 def end_double(self, data):
755 self.append(float(data))
756 self._value = 0
760 def end_bigdecimal(self, data):
761 self.append(Decimal(data))
762 self._value = 0
765 def end_string(self, data):
766 if self._encoding:
767 data = data.decode(self._encoding)
768 self.append(data)
769 self._value = 0
773 def end_array(self, data):
774 mark = self._marks.pop()
776 self._stack[mark:] = [self._stack[mark:]]
777 self._value = 0
780 def end_struct(self, data):
781 mark = self._marks.pop()
784 items = self._stack[mark:]
787 self._stack[mark:] = [dict]
788 self._value = 0
791 def end_base64(self, data):
794 if self._use_bytes:
796 self.append(value)
797 self._value = 0
800 def end_dateTime(self, data):
803 if self._use_datetime:
805 self.append(value)
808 def end_value(self, data):
811 if self._value:
812 self.end_string(data)
815 def end_params(self, data):
816 self._type = "params"
819 def end_fault(self, data):
820 self._type = "fault"
823 def end_methodName(self, data):
824 if self._encoding:
825 data = data.decode(self._encoding)
826 self._methodname = data
827 self._type = "methodName" # no params
836 def __init__(self, call_list, name):
837 self.__call_list = call_list
838 self.__name = name
839 def __getattr__(self, name):
840 return _MultiCallMethod(self.__call_list, "%s.%s" % (self.__name, name))
841 def __call__(self, *args):
842 self.__call_list.append((self.__name, args))
848 def __init__(self, results):
849 self.results = results
851 def __getitem__(self, i):
852 item = self.results[i]
877 def __init__(self, server):
878 self.__server = server
879 self.__call_list = []
881 def __repr__(self):
882 return "<%s at %#x>" % (self.__class__.__name__, id(self))
884 def __getattr__(self, name):
885 return _MultiCallMethod(self.__call_list, name)
887 def __call__(self):
889 for name, args in self.__call_list:
892 return MultiCallIterator(self.__server.system.multicall(marshalled_list))
1095 def __init__(self, response):
1100 self.io = BytesIO(response.read())
1101 gzip.GzipFile.__init__(self, mode="rb", fileobj=self.io)
1103 def close(self):
1105 gzip.GzipFile.close(self)
1107 self.io.close()
1116 def __init__(self, send, name):
1117 self.__send = send
1118 self.__name = name
1119 def __getattr__(self, name):
1120 return _Method(self.__send, "%s.%s" % (self.__name, name))
1121 def __call__(self, *args):
1122 return self.__send(self.__name, args)
1144 def __init__(self, use_datetime=False, use_builtin_types=False,
1146 self._use_datetime = use_datetime
1147 self._use_builtin_types = use_builtin_types
1148 self._connection = (None, None)
1149 self._headers = list(headers)
1150 self._extra_headers = []
1162 def request(self, host, handler, request_body, verbose=False):
1166 return self.single_request(host, handler, request_body, verbose)
1175 def single_request(self, host, handler, request_body, verbose=False):
1178 http_conn = self.send_request(host, handler, request_body, verbose)
1181 self.verbose = verbose
1182 return self.parse_response(resp)
1189 self.close()
1208 def getparser(self):
1210 return getparser(use_datetime=self._use_datetime,
1211 use_builtin_types=self._use_builtin_types)
1223 def get_host_info(self, host):
1249 def make_connection(self, host):
1252 if self._connection and host == self._connection[0]:
1253 return self._connection[1]
1255 chost, self._extra_headers, x509 = self.get_host_info(host)
1256 self._connection = host, http.client.HTTPConnection(chost)
1257 return self._connection[1]
1263 def close(self):
1264 host, connection = self._connection
1266 self._connection = (None, None)
1278 def send_request(self, host, handler, request_body, debug):
1279 connection = self.make_connection(host)
1280 headers = self._headers + self._extra_headers
1283 if self.accept_gzip_encoding and gzip:
1289 headers.append(("User-Agent", self.user_agent))
1290 self.send_headers(connection, headers)
1291 self.send_content(connection, request_body)
1301 def send_headers(self, connection, headers):
1312 def send_content(self, connection, request_body):
1314 if (self.encode_threshold is not None and
1315 self.encode_threshold < len(request_body) and
1329 def parse_response(self, response):
1340 p, u = self.getparser()
1346 if self.verbose:
1362 def __init__(self, use_datetime=False, use_builtin_types=False,
1367 self.context = context
1371 def make_connection(self, host):
1372 if self._connection and host == self._connection[0]:
1373 return self._connection[1]
1380 chost, self._extra_headers, x509 = self.get_host_info(host)
1381 self._connection = host, http.client.HTTPSConnection(chost,
1382 None, context=self.context, **(x509 or {}))
1383 return self._connection[1]
1424 def __init__(self, uri, transport=None, encoding=None, verbose=False,
1433 self.__host = p.netloc
1434 self.__handler = urllib.parse.urlunsplit(["", "", *p[2:]])
1435 if not self.__handler:
1436 self.__handler = "/RPC2"
1449 self.__transport = transport
1451 self.__encoding = encoding or 'utf-8'
1452 self.__verbose = verbose
1453 self.__allow_none = allow_none
1455 def __close(self):
1456 self.__transport.close()
1458 def __request(self, methodname, params):
1461 request = dumps(params, methodname, encoding=self.__encoding,
1462 allow_none=self.__allow_none).encode(self.__encoding, 'xmlcharrefreplace')
1464 response = self.__transport.request(
1465 self.__host,
1466 self.__handler,
1468 verbose=self.__verbose
1476 def __repr__(self):
1479 (self.__class__.__name__, self.__host, self.__handler)
1482 def __getattr__(self, name):
1484 return _Method(self.__request, name)
1489 def __call__(self, attr):
1494 return self.__close
1496 return self.__transport
1499 def __enter__(self):
1500 return self
1502 def __exit__(self, *args):
1503 self.__close()