Index: tools/telemetry/third_party/gsutil/third_party/boto/boto/sqs/message.py |
diff --git a/tools/telemetry/third_party/gsutil/third_party/boto/boto/sqs/message.py b/tools/telemetry/third_party/gsutil/third_party/boto/boto/sqs/message.py |
deleted file mode 100644 |
index 656734fa6739f4ddf8870d24f93442e61ab8fb64..0000000000000000000000000000000000000000 |
--- a/tools/telemetry/third_party/gsutil/third_party/boto/boto/sqs/message.py |
+++ /dev/null |
@@ -1,271 +0,0 @@ |
-# Copyright (c) 2006,2007 Mitch Garnaat http://garnaat.org/ |
-# |
-# Permission is hereby granted, free of charge, to any person obtaining a |
-# copy of this software and associated documentation files (the |
-# "Software"), to deal in the Software without restriction, including |
-# without limitation the rights to use, copy, modify, merge, publish, dis- |
-# tribute, sublicense, and/or sell copies of the Software, and to permit |
-# persons to whom the Software is furnished to do so, subject to the fol- |
-# lowing conditions: |
-# |
-# The above copyright notice and this permission notice shall be included |
-# in all copies or substantial portions of the Software. |
-# |
-# THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS |
-# OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABIL- |
-# ITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT |
-# SHALL THE AUTHOR BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, |
-# WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, |
-# OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS |
-# IN THE SOFTWARE. |
- |
-""" |
-SQS Message |
- |
-A Message represents the data stored in an SQS queue. The rules for what is allowed within an SQS |
-Message are here: |
- |
- http://docs.amazonwebservices.com/AWSSimpleQueueService/2008-01-01/SQSDeveloperGuide/Query_QuerySendMessage.html |
- |
-So, at it's simplest level a Message just needs to allow a developer to store bytes in it and get the bytes |
-back out. However, to allow messages to have richer semantics, the Message class must support the |
-following interfaces: |
- |
-The constructor for the Message class must accept a keyword parameter "queue" which is an instance of a |
-boto Queue object and represents the queue that the message will be stored in. The default value for |
-this parameter is None. |
- |
-The constructor for the Message class must accept a keyword parameter "body" which represents the |
-content or body of the message. The format of this parameter will depend on the behavior of the |
-particular Message subclass. For example, if the Message subclass provides dictionary-like behavior to the |
-user the body passed to the constructor should be a dict-like object that can be used to populate |
-the initial state of the message. |
- |
-The Message class must provide an encode method that accepts a value of the same type as the body |
-parameter of the constructor and returns a string of characters that are able to be stored in an |
-SQS message body (see rules above). |
- |
-The Message class must provide a decode method that accepts a string of characters that can be |
-stored (and probably were stored!) in an SQS message and return an object of a type that is consistent |
-with the "body" parameter accepted on the class constructor. |
- |
-The Message class must provide a __len__ method that will return the size of the encoded message |
-that would be stored in SQS based on the current state of the Message object. |
- |
-The Message class must provide a get_body method that will return the body of the message in the |
-same format accepted in the constructor of the class. |
- |
-The Message class must provide a set_body method that accepts a message body in the same format |
-accepted by the constructor of the class. This method should alter to the internal state of the |
-Message object to reflect the state represented in the message body parameter. |
- |
-The Message class must provide a get_body_encoded method that returns the current body of the message |
-in the format in which it would be stored in SQS. |
-""" |
- |
-import base64 |
- |
-import boto |
- |
-from boto.compat import StringIO |
-from boto.compat import six |
-from boto.sqs.attributes import Attributes |
-from boto.sqs.messageattributes import MessageAttributes |
-from boto.exception import SQSDecodeError |
- |
-class RawMessage(object): |
- """ |
- Base class for SQS messages. RawMessage does not encode the message |
- in any way. Whatever you store in the body of the message is what |
- will be written to SQS and whatever is returned from SQS is stored |
- directly into the body of the message. |
- """ |
- |
- def __init__(self, queue=None, body=''): |
- self.queue = queue |
- self.set_body(body) |
- self.id = None |
- self.receipt_handle = None |
- self.md5 = None |
- self.attributes = Attributes(self) |
- self.message_attributes = MessageAttributes(self) |
- self.md5_message_attributes = None |
- |
- def __len__(self): |
- return len(self.encode(self._body)) |
- |
- def startElement(self, name, attrs, connection): |
- if name == 'Attribute': |
- return self.attributes |
- if name == 'MessageAttribute': |
- return self.message_attributes |
- return None |
- |
- def endElement(self, name, value, connection): |
- if name == 'Body': |
- self.set_body(value) |
- elif name == 'MessageId': |
- self.id = value |
- elif name == 'ReceiptHandle': |
- self.receipt_handle = value |
- elif name == 'MD5OfBody': |
- self.md5 = value |
- elif name == 'MD5OfMessageAttributes': |
- self.md5_message_attributes = value |
- else: |
- setattr(self, name, value) |
- |
- def endNode(self, connection): |
- self.set_body(self.decode(self.get_body())) |
- |
- def encode(self, value): |
- """Transform body object into serialized byte array format.""" |
- return value |
- |
- def decode(self, value): |
- """Transform seralized byte array into any object.""" |
- return value |
- |
- def set_body(self, body): |
- """Override the current body for this object, using decoded format.""" |
- self._body = body |
- |
- def get_body(self): |
- return self._body |
- |
- def get_body_encoded(self): |
- """ |
- This method is really a semi-private method used by the Queue.write |
- method when writing the contents of the message to SQS. |
- You probably shouldn't need to call this method in the normal course of events. |
- """ |
- return self.encode(self.get_body()) |
- |
- def delete(self): |
- if self.queue: |
- return self.queue.delete_message(self) |
- |
- def change_visibility(self, visibility_timeout): |
- if self.queue: |
- self.queue.connection.change_message_visibility(self.queue, |
- self.receipt_handle, |
- visibility_timeout) |
- |
-class Message(RawMessage): |
- """ |
- The default Message class used for SQS queues. This class automatically |
- encodes/decodes the message body using Base64 encoding to avoid any |
- illegal characters in the message body. See: |
- |
- https://forums.aws.amazon.com/thread.jspa?threadID=13067 |
- |
- for details on why this is a good idea. The encode/decode is meant to |
- be transparent to the end-user. |
- """ |
- |
- def encode(self, value): |
- if not isinstance(value, six.binary_type): |
- value = value.encode('utf-8') |
- return base64.b64encode(value).decode('utf-8') |
- |
- def decode(self, value): |
- try: |
- value = base64.b64decode(value.encode('utf-8')).decode('utf-8') |
- except: |
- boto.log.warning('Unable to decode message') |
- return value |
- return value |
- |
-class MHMessage(Message): |
- """ |
- The MHMessage class provides a message that provides RFC821-like |
- headers like this: |
- |
- HeaderName: HeaderValue |
- |
- The encoding/decoding of this is handled automatically and after |
- the message body has been read, the message instance can be treated |
- like a mapping object, i.e. m['HeaderName'] would return 'HeaderValue'. |
- """ |
- |
- def __init__(self, queue=None, body=None, xml_attrs=None): |
- if body is None or body == '': |
- body = {} |
- super(MHMessage, self).__init__(queue, body) |
- |
- def decode(self, value): |
- try: |
- msg = {} |
- fp = StringIO(value) |
- line = fp.readline() |
- while line: |
- delim = line.find(':') |
- key = line[0:delim] |
- value = line[delim+1:].strip() |
- msg[key.strip()] = value.strip() |
- line = fp.readline() |
- except: |
- raise SQSDecodeError('Unable to decode message', self) |
- return msg |
- |
- def encode(self, value): |
- s = '' |
- for item in value.items(): |
- s = s + '%s: %s\n' % (item[0], item[1]) |
- return s |
- |
- def __contains__(self, key): |
- return key in self._body |
- |
- def __getitem__(self, key): |
- if key in self._body: |
- return self._body[key] |
- else: |
- raise KeyError(key) |
- |
- def __setitem__(self, key, value): |
- self._body[key] = value |
- self.set_body(self._body) |
- |
- def keys(self): |
- return self._body.keys() |
- |
- def values(self): |
- return self._body.values() |
- |
- def items(self): |
- return self._body.items() |
- |
- def has_key(self, key): |
- return key in self._body |
- |
- def update(self, d): |
- self._body.update(d) |
- self.set_body(self._body) |
- |
- def get(self, key, default=None): |
- return self._body.get(key, default) |
- |
-class EncodedMHMessage(MHMessage): |
- """ |
- The EncodedMHMessage class provides a message that provides RFC821-like |
- headers like this: |
- |
- HeaderName: HeaderValue |
- |
- This variation encodes/decodes the body of the message in base64 automatically. |
- The message instance can be treated like a mapping object, |
- i.e. m['HeaderName'] would return 'HeaderValue'. |
- """ |
- |
- def decode(self, value): |
- try: |
- value = base64.b64decode(value.encode('utf-8')).decode('utf-8') |
- except: |
- raise SQSDecodeError('Unable to decode message', self) |
- return super(EncodedMHMessage, self).decode(value) |
- |
- def encode(self, value): |
- value = super(EncodedMHMessage, self).encode(value) |
- return base64.b64encode(value.encode('utf-8')).decode('utf-8') |
- |