diff -r 261778de26ff -r 620f9b141567 thirdparty/google_appengine/google/appengine/api/urlfetch_service_pb.py --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/thirdparty/google_appengine/google/appengine/api/urlfetch_service_pb.py Tue Aug 26 21:49:54 2008 +0000 @@ -0,0 +1,717 @@ +#!/usr/bin/env python +# +# Copyright 2007 Google Inc. +# +# Licensed under the Apache License, Version 2.0 (the "License"); +# you may not use this file except in compliance with the License. +# You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +from google.net.proto import ProtocolBuffer +import array +import dummy_thread as thread + +__pychecker__ = """maxreturns=0 maxbranches=0 no-callinit + unusednames=printElemNumber,debug_strs no-special""" + +from google.appengine.api.api_base_pb import StringProto +class URLFetchServiceError(ProtocolBuffer.ProtocolMessage): + + OK = 0 + INVALID_URL = 1 + FETCH_ERROR = 2 + UNSPECIFIED_ERROR = 3 + RESPONSE_TOO_LARGE = 4 + + _ErrorCode_NAMES = { + 0: "OK", + 1: "INVALID_URL", + 2: "FETCH_ERROR", + 3: "UNSPECIFIED_ERROR", + 4: "RESPONSE_TOO_LARGE", + } + + def ErrorCode_Name(cls, x): return cls._ErrorCode_NAMES.get(x, "") + ErrorCode_Name = classmethod(ErrorCode_Name) + + def __init__(self, contents=None): + pass + if contents is not None: self.MergeFromString(contents) + + + def MergeFrom(self, x): + assert x is not self + + def Equals(self, x): + if x is self: return 1 + return 1 + + def __eq__(self, other): + return (other is not None) and (other.__class__ == self.__class__) and self.Equals(other) + + def __ne__(self, other): + return not (self == other) + + def IsInitialized(self, debug_strs=None): + initialized = 1 + return initialized + + def ByteSize(self): + n = 0 + return n + 0 + + def Clear(self): + pass + + def OutputUnchecked(self, out): + pass + + def TryMerge(self, d): + while d.avail() > 0: + tt = d.getVarInt32() + if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError + d.skipData(tt) + + + def __str__(self, prefix="", printElemNumber=0): + res="" + return res + + + _TEXT = ( + "ErrorCode", + ) + + _TYPES = ( + ProtocolBuffer.Encoder.NUMERIC, + ) + + _STYLE = """""" + _STYLE_CONTENT_TYPE = """""" +class URLFetchRequest_Header(ProtocolBuffer.ProtocolMessage): + def __init__(self, contents=None): + self.key_ = "" + self.value_ = "" + self.has_key_ = 0 + self.has_value_ = 0 + if contents is not None: self.MergeFromString(contents) + + def key(self): return self.key_ + + def set_key(self, x): + self.has_key_ = 1 + self.key_ = x + + def clear_key(self): + self.has_key_ = 0 + self.key_ = "" + + def has_key(self): return self.has_key_ + + def value(self): return self.value_ + + def set_value(self, x): + self.has_value_ = 1 + self.value_ = x + + def clear_value(self): + self.has_value_ = 0 + self.value_ = "" + + def has_value(self): return self.has_value_ + + + def MergeFrom(self, x): + assert x is not self + if (x.has_key()): self.set_key(x.key()) + if (x.has_value()): self.set_value(x.value()) + + def Equals(self, x): + if x is self: return 1 + if self.has_key_ != x.has_key_: return 0 + if self.has_key_ and self.key_ != x.key_: return 0 + if self.has_value_ != x.has_value_: return 0 + if self.has_value_ and self.value_ != x.value_: return 0 + return 1 + + def __eq__(self, other): + return (other is not None) and (other.__class__ == self.__class__) and self.Equals(other) + + def __ne__(self, other): + return not (self == other) + + def IsInitialized(self, debug_strs=None): + initialized = 1 + if (not self.has_key_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: key not set.') + if (not self.has_value_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: value not set.') + return initialized + + def ByteSize(self): + n = 0 + n += self.lengthString(len(self.key_)) + n += self.lengthString(len(self.value_)) + return n + 2 + + def Clear(self): + self.clear_key() + self.clear_value() + + def OutputUnchecked(self, out): + out.putVarInt32(34) + out.putPrefixedString(self.key_) + out.putVarInt32(42) + out.putPrefixedString(self.value_) + + def TryMerge(self, d): + while 1: + tt = d.getVarInt32() + if tt == 28: break + if tt == 34: + self.set_key(d.getPrefixedString()) + continue + if tt == 42: + self.set_value(d.getPrefixedString()) + continue + if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError + d.skipData(tt) + + + def __str__(self, prefix="", printElemNumber=0): + res="" + if self.has_key_: res+=prefix+("Key: %s\n" % self.DebugFormatString(self.key_)) + if self.has_value_: res+=prefix+("Value: %s\n" % self.DebugFormatString(self.value_)) + return res + +class URLFetchRequest(ProtocolBuffer.ProtocolMessage): + + GET = 1 + POST = 2 + HEAD = 3 + PUT = 4 + DELETE = 5 + + _RequestMethod_NAMES = { + 1: "GET", + 2: "POST", + 3: "HEAD", + 4: "PUT", + 5: "DELETE", + } + + def RequestMethod_Name(cls, x): return cls._RequestMethod_NAMES.get(x, "") + RequestMethod_Name = classmethod(RequestMethod_Name) + + def __init__(self, contents=None): + self.method_ = 0 + self.url_ = "" + self.header_ = [] + self.payload_ = "" + self.has_method_ = 0 + self.has_url_ = 0 + self.has_payload_ = 0 + if contents is not None: self.MergeFromString(contents) + + def method(self): return self.method_ + + def set_method(self, x): + self.has_method_ = 1 + self.method_ = x + + def clear_method(self): + self.has_method_ = 0 + self.method_ = 0 + + def has_method(self): return self.has_method_ + + def url(self): return self.url_ + + def set_url(self, x): + self.has_url_ = 1 + self.url_ = x + + def clear_url(self): + self.has_url_ = 0 + self.url_ = "" + + def has_url(self): return self.has_url_ + + def header_size(self): return len(self.header_) + def header_list(self): return self.header_ + + def header(self, i): + return self.header_[i] + + def mutable_header(self, i): + return self.header_[i] + + def add_header(self): + x = URLFetchRequest_Header() + self.header_.append(x) + return x + + def clear_header(self): + self.header_ = [] + def payload(self): return self.payload_ + + def set_payload(self, x): + self.has_payload_ = 1 + self.payload_ = x + + def clear_payload(self): + self.has_payload_ = 0 + self.payload_ = "" + + def has_payload(self): return self.has_payload_ + + + def MergeFrom(self, x): + assert x is not self + if (x.has_method()): self.set_method(x.method()) + if (x.has_url()): self.set_url(x.url()) + for i in xrange(x.header_size()): self.add_header().CopyFrom(x.header(i)) + if (x.has_payload()): self.set_payload(x.payload()) + + def Equals(self, x): + if x is self: return 1 + if self.has_method_ != x.has_method_: return 0 + if self.has_method_ and self.method_ != x.method_: return 0 + if self.has_url_ != x.has_url_: return 0 + if self.has_url_ and self.url_ != x.url_: return 0 + if len(self.header_) != len(x.header_): return 0 + for e1, e2 in zip(self.header_, x.header_): + if e1 != e2: return 0 + if self.has_payload_ != x.has_payload_: return 0 + if self.has_payload_ and self.payload_ != x.payload_: return 0 + return 1 + + def __eq__(self, other): + return (other is not None) and (other.__class__ == self.__class__) and self.Equals(other) + + def __ne__(self, other): + return not (self == other) + + def IsInitialized(self, debug_strs=None): + initialized = 1 + if (not self.has_method_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: method not set.') + if (not self.has_url_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: url not set.') + for i in xrange(len(self.header_)): + if (not self.header_[i].IsInitialized(debug_strs)): initialized=0 + return initialized + + def ByteSize(self): + n = 0 + n += self.lengthVarInt64(self.method_) + n += self.lengthString(len(self.url_)) + n += 2 * len(self.header_) + for i in xrange(len(self.header_)): n += self.header_[i].ByteSize() + if (self.has_payload_): n += 1 + self.lengthString(len(self.payload_)) + return n + 2 + + def Clear(self): + self.clear_method() + self.clear_url() + self.clear_header() + self.clear_payload() + + def OutputUnchecked(self, out): + out.putVarInt32(8) + out.putVarInt32(self.method_) + out.putVarInt32(18) + out.putPrefixedString(self.url_) + for i in xrange(len(self.header_)): + out.putVarInt32(27) + self.header_[i].OutputUnchecked(out) + out.putVarInt32(28) + if (self.has_payload_): + out.putVarInt32(50) + out.putPrefixedString(self.payload_) + + def TryMerge(self, d): + while d.avail() > 0: + tt = d.getVarInt32() + if tt == 8: + self.set_method(d.getVarInt32()) + continue + if tt == 18: + self.set_url(d.getPrefixedString()) + continue + if tt == 27: + self.add_header().TryMerge(d) + continue + if tt == 50: + self.set_payload(d.getPrefixedString()) + continue + if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError + d.skipData(tt) + + + def __str__(self, prefix="", printElemNumber=0): + res="" + if self.has_method_: res+=prefix+("Method: %s\n" % self.DebugFormatInt32(self.method_)) + if self.has_url_: res+=prefix+("Url: %s\n" % self.DebugFormatString(self.url_)) + cnt=0 + for e in self.header_: + elm="" + if printElemNumber: elm="(%d)" % cnt + res+=prefix+("Header%s {\n" % elm) + res+=e.__str__(prefix + " ", printElemNumber) + res+=prefix+"}\n" + cnt+=1 + if self.has_payload_: res+=prefix+("Payload: %s\n" % self.DebugFormatString(self.payload_)) + return res + + kMethod = 1 + kUrl = 2 + kHeaderGroup = 3 + kHeaderKey = 4 + kHeaderValue = 5 + kPayload = 6 + + _TEXT = ( + "ErrorCode", + "Method", + "Url", + "Header", + "Key", + "Value", + "Payload", + ) + + _TYPES = ( + ProtocolBuffer.Encoder.NUMERIC, + ProtocolBuffer.Encoder.NUMERIC, + + ProtocolBuffer.Encoder.STRING, + + ProtocolBuffer.Encoder.STARTGROUP, + + ProtocolBuffer.Encoder.STRING, + + ProtocolBuffer.Encoder.STRING, + + ProtocolBuffer.Encoder.STRING, + + ) + + _STYLE = """""" + _STYLE_CONTENT_TYPE = """""" +class URLFetchResponse_Header(ProtocolBuffer.ProtocolMessage): + def __init__(self, contents=None): + self.key_ = "" + self.value_ = "" + self.has_key_ = 0 + self.has_value_ = 0 + if contents is not None: self.MergeFromString(contents) + + def key(self): return self.key_ + + def set_key(self, x): + self.has_key_ = 1 + self.key_ = x + + def clear_key(self): + self.has_key_ = 0 + self.key_ = "" + + def has_key(self): return self.has_key_ + + def value(self): return self.value_ + + def set_value(self, x): + self.has_value_ = 1 + self.value_ = x + + def clear_value(self): + self.has_value_ = 0 + self.value_ = "" + + def has_value(self): return self.has_value_ + + + def MergeFrom(self, x): + assert x is not self + if (x.has_key()): self.set_key(x.key()) + if (x.has_value()): self.set_value(x.value()) + + def Equals(self, x): + if x is self: return 1 + if self.has_key_ != x.has_key_: return 0 + if self.has_key_ and self.key_ != x.key_: return 0 + if self.has_value_ != x.has_value_: return 0 + if self.has_value_ and self.value_ != x.value_: return 0 + return 1 + + def __eq__(self, other): + return (other is not None) and (other.__class__ == self.__class__) and self.Equals(other) + + def __ne__(self, other): + return not (self == other) + + def IsInitialized(self, debug_strs=None): + initialized = 1 + if (not self.has_key_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: key not set.') + if (not self.has_value_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: value not set.') + return initialized + + def ByteSize(self): + n = 0 + n += self.lengthString(len(self.key_)) + n += self.lengthString(len(self.value_)) + return n + 2 + + def Clear(self): + self.clear_key() + self.clear_value() + + def OutputUnchecked(self, out): + out.putVarInt32(34) + out.putPrefixedString(self.key_) + out.putVarInt32(42) + out.putPrefixedString(self.value_) + + def TryMerge(self, d): + while 1: + tt = d.getVarInt32() + if tt == 28: break + if tt == 34: + self.set_key(d.getPrefixedString()) + continue + if tt == 42: + self.set_value(d.getPrefixedString()) + continue + if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError + d.skipData(tt) + + + def __str__(self, prefix="", printElemNumber=0): + res="" + if self.has_key_: res+=prefix+("Key: %s\n" % self.DebugFormatString(self.key_)) + if self.has_value_: res+=prefix+("Value: %s\n" % self.DebugFormatString(self.value_)) + return res + +class URLFetchResponse(ProtocolBuffer.ProtocolMessage): + def __init__(self, contents=None): + self.content_ = "" + self.statuscode_ = 0 + self.header_ = [] + self.contentwastruncated_ = 0 + self.has_content_ = 0 + self.has_statuscode_ = 0 + self.has_contentwastruncated_ = 0 + if contents is not None: self.MergeFromString(contents) + + def content(self): return self.content_ + + def set_content(self, x): + self.has_content_ = 1 + self.content_ = x + + def clear_content(self): + self.has_content_ = 0 + self.content_ = "" + + def has_content(self): return self.has_content_ + + def statuscode(self): return self.statuscode_ + + def set_statuscode(self, x): + self.has_statuscode_ = 1 + self.statuscode_ = x + + def clear_statuscode(self): + self.has_statuscode_ = 0 + self.statuscode_ = 0 + + def has_statuscode(self): return self.has_statuscode_ + + def header_size(self): return len(self.header_) + def header_list(self): return self.header_ + + def header(self, i): + return self.header_[i] + + def mutable_header(self, i): + return self.header_[i] + + def add_header(self): + x = URLFetchResponse_Header() + self.header_.append(x) + return x + + def clear_header(self): + self.header_ = [] + def contentwastruncated(self): return self.contentwastruncated_ + + def set_contentwastruncated(self, x): + self.has_contentwastruncated_ = 1 + self.contentwastruncated_ = x + + def clear_contentwastruncated(self): + self.has_contentwastruncated_ = 0 + self.contentwastruncated_ = 0 + + def has_contentwastruncated(self): return self.has_contentwastruncated_ + + + def MergeFrom(self, x): + assert x is not self + if (x.has_content()): self.set_content(x.content()) + if (x.has_statuscode()): self.set_statuscode(x.statuscode()) + for i in xrange(x.header_size()): self.add_header().CopyFrom(x.header(i)) + if (x.has_contentwastruncated()): self.set_contentwastruncated(x.contentwastruncated()) + + def Equals(self, x): + if x is self: return 1 + if self.has_content_ != x.has_content_: return 0 + if self.has_content_ and self.content_ != x.content_: return 0 + if self.has_statuscode_ != x.has_statuscode_: return 0 + if self.has_statuscode_ and self.statuscode_ != x.statuscode_: return 0 + if len(self.header_) != len(x.header_): return 0 + for e1, e2 in zip(self.header_, x.header_): + if e1 != e2: return 0 + if self.has_contentwastruncated_ != x.has_contentwastruncated_: return 0 + if self.has_contentwastruncated_ and self.contentwastruncated_ != x.contentwastruncated_: return 0 + return 1 + + def __eq__(self, other): + return (other is not None) and (other.__class__ == self.__class__) and self.Equals(other) + + def __ne__(self, other): + return not (self == other) + + def IsInitialized(self, debug_strs=None): + initialized = 1 + if (not self.has_statuscode_): + initialized = 0 + if debug_strs is not None: + debug_strs.append('Required field: statuscode not set.') + for i in xrange(len(self.header_)): + if (not self.header_[i].IsInitialized(debug_strs)): initialized=0 + return initialized + + def ByteSize(self): + n = 0 + if (self.has_content_): n += 1 + self.lengthString(len(self.content_)) + n += self.lengthVarInt64(self.statuscode_) + n += 2 * len(self.header_) + for i in xrange(len(self.header_)): n += self.header_[i].ByteSize() + if (self.has_contentwastruncated_): n += 2 + return n + 1 + + def Clear(self): + self.clear_content() + self.clear_statuscode() + self.clear_header() + self.clear_contentwastruncated() + + def OutputUnchecked(self, out): + if (self.has_content_): + out.putVarInt32(10) + out.putPrefixedString(self.content_) + out.putVarInt32(16) + out.putVarInt32(self.statuscode_) + for i in xrange(len(self.header_)): + out.putVarInt32(27) + self.header_[i].OutputUnchecked(out) + out.putVarInt32(28) + if (self.has_contentwastruncated_): + out.putVarInt32(48) + out.putBoolean(self.contentwastruncated_) + + def TryMerge(self, d): + while d.avail() > 0: + tt = d.getVarInt32() + if tt == 10: + self.set_content(d.getPrefixedString()) + continue + if tt == 16: + self.set_statuscode(d.getVarInt32()) + continue + if tt == 27: + self.add_header().TryMerge(d) + continue + if tt == 48: + self.set_contentwastruncated(d.getBoolean()) + continue + if (tt == 0): raise ProtocolBuffer.ProtocolBufferDecodeError + d.skipData(tt) + + + def __str__(self, prefix="", printElemNumber=0): + res="" + if self.has_content_: res+=prefix+("Content: %s\n" % self.DebugFormatString(self.content_)) + if self.has_statuscode_: res+=prefix+("StatusCode: %s\n" % self.DebugFormatInt32(self.statuscode_)) + cnt=0 + for e in self.header_: + elm="" + if printElemNumber: elm="(%d)" % cnt + res+=prefix+("Header%s {\n" % elm) + res+=e.__str__(prefix + " ", printElemNumber) + res+=prefix+"}\n" + cnt+=1 + if self.has_contentwastruncated_: res+=prefix+("ContentWasTruncated: %s\n" % self.DebugFormatBool(self.contentwastruncated_)) + return res + + kContent = 1 + kStatusCode = 2 + kHeaderGroup = 3 + kHeaderKey = 4 + kHeaderValue = 5 + kContentWasTruncated = 6 + + _TEXT = ( + "ErrorCode", + "Content", + "StatusCode", + "Header", + "Key", + "Value", + "ContentWasTruncated", + ) + + _TYPES = ( + ProtocolBuffer.Encoder.NUMERIC, + ProtocolBuffer.Encoder.STRING, + + ProtocolBuffer.Encoder.NUMERIC, + + ProtocolBuffer.Encoder.STARTGROUP, + + ProtocolBuffer.Encoder.STRING, + + ProtocolBuffer.Encoder.STRING, + + ProtocolBuffer.Encoder.NUMERIC, + + ) + + _STYLE = """""" + _STYLE_CONTENT_TYPE = """""" + +__all__ = ['URLFetchServiceError','URLFetchRequest','URLFetchRequest_Header','URLFetchResponse','URLFetchResponse_Header']