Merge lp:~facundo/magicicada-protocol/xenial-tests into lp:magicicada-protocol

[Facundo Batista]

Small changes for tests to run ok under xenial.

Small changes for tests to run ok under xenial.

Including:

- removed two tests that checked situations after having a protobuf message with an invalid value, and this is not possible anymore in modern protobuf (can not create the request itself, because of internal verifications at creation time).

- Stop patching the certificates loader, just set the proper env var in the test and use regular code. Also included the certificates in the project (previously they were being taken from SSO).

- Lot of aesthetic small details

[Natalia Bidart (nataliabidart)]

Looks good! Thanks

review: Approve

=== modified file 'run-tests'
--- run-tests	2014-02-24 18:38:33 +0000
+++ run-tests	2016-09-19 02:06:21 +0000
@@ -21,11 +21,11 @@
 
 /usr/bin/env python setup.py build
 # run the tests with pure python protobuf
-PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python u1trial tests
+SSL_CERTIFICATES_DIR=tests/certs PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=python u1trial tests
 if [ "$SYSNAME" != "Darwin" ]; then
     # and with the cpp extension, for server (linux) only:
     if [ $PROTOC_VERSION_AS_INT -lt 2500 ]; then
-        PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=cpp u1trial tests
+        SSL_CERTIFICATES_DIR=tests/certs PROTOCOL_BUFFERS_PYTHON_IMPLEMENTATION=cpp u1trial tests
     fi
 fi
 
 
=== modified file 'samples/easy_client.py'
--- samples/easy_client.py	2012-03-29 20:28:09 +0000
+++ samples/easy_client.py	2016-09-19 02:06:21 +0000
@@ -256,8 +256,9 @@
         return failure
 
 
-# deferred utilities
-skip_result = lambda _, f, *args, **kwargs: f(*args, **kwargs)
+def skip_result(_, f, *args, **kwargs):
+    """Deferred utilities."""
+    return f(*args, **kwargs)
 
 
 def sr_result(result, f, *args, **kwargs):
 
=== modified file 'samples/ping_client.py'
--- samples/ping_client.py	2012-03-29 20:28:09 +0000
+++ samples/ping_client.py	2016-09-19 02:06:21 +0000
@@ -82,12 +82,12 @@
     reactor.connectTCP('75.101.137.174', 80, PingClientFactory())
 
     # using ssl
-    #reactor.connectSSL('localhost', 20101, StorageClientFactory(),
+    # reactor.connectSSL('localhost', 20101, StorageClientFactory(),
     #           ssl.ClientContextFactory())
 
     # using ssl over a proxy
-    #from ubuntuone.storageprotocol import proxy_tunnel
-    #proxy_tunnel.connectHTTPS('localhost', 3128,
+    # from ubuntuone.storageprotocol import proxy_tunnel
+    # proxy_tunnel.connectHTTPS('localhost', 3128,
     #        'localhost', 20101, StorageClientFactory(),
     #        user="test", passwd="test")
 
 
=== modified file 'setup.py'
--- setup.py	2013-05-28 22:07:40 +0000
+++ setup.py	2016-09-19 02:06:21 +0000
@@ -21,8 +21,6 @@
 import sys
 import subprocess
 
-sys.path.insert(0, os.path.abspath("."))
-
 from distutils.core import setup
 from distutils.spawn import find_executable
 from distutils.command import clean, build
 
=== added directory 'tests/certs'
=== added file 'tests/certs/cert1.pem'
--- tests/certs/cert1.pem	1970-01-01 00:00:00 +0000
+++ tests/certs/cert1.pem	2016-09-19 02:06:21 +0000
@@ -0,0 +1,29 @@
+-----BEGIN CERTIFICATE-----
+MIIE3jCCA8agAwIBAgICAwEwDQYJKoZIhvcNAQEFBQAwYzELMAkGA1UEBhMCVVMx
+ITAfBgNVBAoTGFRoZSBHbyBEYWRkeSBHcm91cCwgSW5jLjExMC8GA1UECxMoR28g
+RGFkZHkgQ2xhc3MgMiBDZXJ0aWZpY2F0aW9uIEF1dGhvcml0eTAeFw0wNjExMTYw
+MTU0MzdaFw0yNjExMTYwMTU0MzdaMIHKMQswCQYDVQQGEwJVUzEQMA4GA1UECBMH
+QXJpem9uYTETMBEGA1UEBxMKU2NvdHRzZGFsZTEaMBgGA1UEChMRR29EYWRkeS5j
+b20sIEluYy4xMzAxBgNVBAsTKmh0dHA6Ly9jZXJ0aWZpY2F0ZXMuZ29kYWRkeS5j
+b20vcmVwb3NpdG9yeTEwMC4GA1UEAxMnR28gRGFkZHkgU2VjdXJlIENlcnRpZmlj
+YXRpb24gQXV0aG9yaXR5MREwDwYDVQQFEwgwNzk2OTI4NzCCASIwDQYJKoZIhvcN
+AQEBBQADggEPADCCAQoCggEBAMQt1RWMnCZM7DI161+4WQFapmGBWTtwY6vj3D3H
+KrjJM9N55DrtPDAjhI6zMBS2sofDPZVUBJ7fmd0LJR4h3mUpfjWoqVTr9vcyOdQm
+VZWt7/v+WIbXnvQAjYwqDL1CBM6nPwT27oDyqu9SoWlm2r4arV3aLGbqGmu75RpR
+SgAvSMeYddi5Kcju+GZtCpyz8/x4fKL4o/K1w/O5epHBp+YlLpyo7RJlbmr2EkRT
+cDCVw5wrWCs9CHRK8r5RsL+H0EwnWGu1NcWdrxcx+AuP7q2BNgWJCJjPOq8lh8BJ
+6qf9Z/dFjpfMFDniNoW1fho3/Rb2cRGadDAW/hOUoz+EDU8CAwEAAaOCATIwggEu
+MB0GA1UdDgQWBBT9rGEyk2xF1uLuhV+auud2mWjM5zAfBgNVHSMEGDAWgBTSxLDS
+kdRMEXGzYcs9of7dqGrU4zASBgNVHRMBAf8ECDAGAQH/AgEAMDMGCCsGAQUFBwEB
+BCcwJTAjBggrBgEFBQcwAYYXaHR0cDovL29jc3AuZ29kYWRkeS5jb20wRgYDVR0f
+BD8wPTA7oDmgN4Y1aHR0cDovL2NlcnRpZmljYXRlcy5nb2RhZGR5LmNvbS9yZXBv
+c2l0b3J5L2dkcm9vdC5jcmwwSwYDVR0gBEQwQjBABgRVHSAAMDgwNgYIKwYBBQUH
+AgEWKmh0dHA6Ly9jZXJ0aWZpY2F0ZXMuZ29kYWRkeS5jb20vcmVwb3NpdG9yeTAO
+BgNVHQ8BAf8EBAMCAQYwDQYJKoZIhvcNAQEFBQADggEBANKGwOy9+aG2Z+5mC6IG
+OgRQjhVyrEp0lVPLN8tESe8HkGsz2ZbwlFalEzAFPIUyIXvJxwqoJKSQ3kbTJSMU
+A2fCENZvD117esyfxVgqwcSeIaha86ykRvOe5GPLL5CkKSkB2XIsKd83ASe8T+5o
+0yGPwLPk9Qnt0hCqU7S+8MxZC9Y7lhyVJEnfzuz9p0iRFEUOOjZv2kWzRaJBydTX
+RE4+uXR21aITVSzGh6O1mawGhId/dQb8vxRMDsxuxN89txJx9OjxUUAiKEngHUuH
+qDTMBqLdElrRhjZkAzVvb3du6/KFUJheqwNTrZEjYx8WnM25sgVjOuH0aBsXBTWV
+U+4=
+-----END CERTIFICATE-----
 
=== added file 'tests/certs/cert2.pem'
--- tests/certs/cert2.pem	1970-01-01 00:00:00 +0000
+++ tests/certs/cert2.pem	2016-09-19 02:06:21 +0000
@@ -0,0 +1,25 @@
+-----BEGIN CERTIFICATE-----
+MIIEADCCAuigAwIBAgIBADANBgkqhkiG9w0BAQUFADBjMQswCQYDVQQGEwJV
+UzEhMB8GA1UEChMYVGhlIEdvIERhZGR5IEdyb3VwLCBJbmMuMTEwLwYDVQQL
+EyhHbyBEYWRkeSBDbGFzcyAyIENlcnRpZmljYXRpb24gQXV0aG9yaXR5MB4X
+DTA0MDYyOTE3MDYyMFoXDTM0MDYyOTE3MDYyMFowYzELMAkGA1UEBhMCVVMx
+ITAfBgNVBAoTGFRoZSBHbyBEYWRkeSBHcm91cCwgSW5jLjExMC8GA1UECxMo
+R28gRGFkZHkgQ2xhc3MgMiBDZXJ0aWZpY2F0aW9uIEF1dGhvcml0eTCCASAw
+DQYJKoZIhvcNAQEBBQADggENADCCAQgCggEBAN6d1+pXGEmhW+vXX0iG6r7d
+/+TvZxz0ZWizV3GgXne77ZtJ6XCAPVYYYwhv2vLM0D9/AlQiVBDYsoHUwHU9
+S3/Hd8M+eKsaA7Ugay9qK7HFiH7Eux6wwdhFJ2+qN1j3hybX2C32qRe3H3I2
+TqYXP2WYktsqbl2i/ojgC95/5Y0V4evLOtXiEqITLdiOr18SPaAIBQi2XKVl
+OARFmR6jYGB0xUGlcmIbYsUfb18aQr4CUWWoriMYavx4A6lNf4DD+qta/KFA
+pMoZFv6yyO9ecw3ud72a9nmYvLEHZ6IVDd2gWMZEewo+YihfukEHU1jPEX44
+dMX4/7VpkI+EdOqXG68CAQOjgcAwgb0wHQYDVR0OBBYEFNLEsNKR1EwRcbNh
+yz2h/t2oatTjMIGNBgNVHSMEgYUwgYKAFNLEsNKR1EwRcbNhyz2h/t2oatTj
+oWekZTBjMQswCQYDVQQGEwJVUzEhMB8GA1UEChMYVGhlIEdvIERhZGR5IEdy
+b3VwLCBJbmMuMTEwLwYDVQQLEyhHbyBEYWRkeSBDbGFzcyAyIENlcnRpZmlj
+YXRpb24gQXV0aG9yaXR5ggEAMAwGA1UdEwQFMAMBAf8wDQYJKoZIhvcNAQEF
+BQADggEBADJL87LKPpH8EsahB4yOd6AzBhRckB4Y9wimPQoZ+YeAEW5p5JYX
+MP80kWNyOO7MHAGjHZQopDH2esRU1/blMVgDoszOYtuURXO1v0XJJLXVggKt
+I3lpjbi2Tc7PTMozI+gciKqdi0FuFskg5YmezTvacPd+mSYgFFQlq25zheab
+IZ0KbIIOqPjCDPoQHmyW74cNxA9hi63ugyuV+I6ShHI56yDqg+2DzZduCLzr
+Tia2cyvk0/ZM/iZx4mERdEr/VxqHD3VILs9RaRegAhJhldXRQLIQTO7ErBBD
+pqWeCtWVYpoNz4iCxTIM5CufReYNnyicsbkqWletNw+vHX/bvZ8=
+-----END CERTIFICATE-----
 
=== modified file 'tests/test_client.py'
--- tests/test_client.py	2015-05-18 17:23:03 +0000
+++ tests/test_client.py	2016-09-19 02:06:21 +0000
@@ -135,6 +135,10 @@
     message.share.access_level = 0
 
 
+def noop_callback(*a):
+    """No op callback."""
+
+
 class MethodMock(object):
     """A class to overwrite methods to know if they were called.
 
@@ -258,9 +262,8 @@
 
     def test_set_volume_deleted_callback(self):
         """Test callback setting."""
-        a_callback = lambda x: None
-        self.client.set_volume_deleted_callback(a_callback)
-        self.assertTrue(self.client._volume_deleted_callback is a_callback)
+        self.client.set_volume_deleted_callback(noop_callback)
+        self.assertTrue(self.client._volume_deleted_callback is noop_callback)
 
     def test_callback_must_be_callable(self):
         """Test set callback parameters."""
@@ -275,31 +278,33 @@
 
     def test_set_volume_created_callback(self):
         """Test callback setting."""
-        a_callback = lambda y, z: None
-        self.client.set_volume_created_callback(a_callback)
-        self.assertTrue(self.client._volume_created_callback is a_callback)
+        self.client.set_volume_created_callback(noop_callback)
+        self.assertIs(self.client._volume_created_callback, noop_callback)
 
     def test_set_volume_new_generation_callback(self):
         """Test callback setting."""
-        cback = lambda y, z: None
-        self.client.set_volume_new_generation_callback(cback)
-        self.assertTrue(self.client._volume_new_generation_callback is cback)
+        self.client.set_volume_new_generation_callback(noop_callback)
+        self.assertIs(self.client._volume_new_generation_callback,
+                      noop_callback)
 
     # share notification callbacks
     def test_share_change_callback(self):
         """Test share_change callback usage."""
         self.assertRaises(TypeError, self.client.set_share_change_callback,
                           'hello')
-        #create a response and message
+        # create a response and message
         share_resp = sharersp.NotifyShareHolder.from_params(
             uuid.uuid4(), uuid.uuid4(), 'sname', 'byu', 'tou', 'View')
         proto_msg = protocol_pb2.Message()
         proto_msg.type = protocol_pb2.Message.NOTIFY_SHARE
         share_resp.dump_to_msg(proto_msg.notify_share)
 
-        #wire up a call back and make sure it's correct
+        # wire up a call back and make sure it's correct
         self.share_notif = None
-        a_callback = lambda notif: setattr(self, 'share_notif', notif)
+
+        def a_callback(notif):
+            setattr(self, 'share_notif', notif)
+
         self.client.set_share_change_callback(a_callback)
         self.assertTrue(self.client._share_change_callback is a_callback)
         self.client.handle_NOTIFY_SHARE(proto_msg)
@@ -315,9 +320,12 @@
         proto_msg.type = protocol_pb2.Message.SHARE_DELETED
         proto_msg.share_deleted.share_id = str(share_id)
 
-        #wire up a call back and make sure it's correct
+        # wire up a call back and make sure it's correct
         self.deleted_share_id = None
-        a_callback = lambda notif: setattr(self, 'deleted_share_id', notif)
+
+        def a_callback(notif):
+            setattr(self, 'deleted_share_id', notif)
+
         self.client.set_share_delete_callback(a_callback)
         self.assertTrue(self.client._share_delete_callback is a_callback)
         self.client.handle_SHARE_DELETED(proto_msg)
@@ -334,9 +342,12 @@
         proto_msg.share_accepted.share_id = str(share_id)
         proto_msg.share_accepted.answer = protocol_pb2.ShareAccepted.YES
 
-        #wire up a call back and make sure it's correct
+        # wire up a call back and make sure it's correct
         self.answer = None
-        a_callback = lambda s, a: setattr(self, 'answer', (s, a))
+
+        def a_callback(s, a):
+            setattr(self, 'answer', (s, a))
+
         self.client.set_share_answer_callback(a_callback)
         self.assertTrue(self.client._share_answer_callback is a_callback)
         self.client.handle_SHARE_ACCEPTED(proto_msg)
@@ -347,8 +358,8 @@
         """Test handle_VOLUME_NEW_GENERATION with an uuid id."""
         # set the callback to record the info
         called = []
-        f = lambda *a: called.append(a)
-        self.client.set_volume_new_generation_callback(f)
+        self.client.set_volume_new_generation_callback(
+            lambda *a: called.append(a))
 
         # create the message
         message = protocol_pb2.Message()
@@ -365,8 +376,8 @@
         """Test handle_VOLUME_NEW_GENERATION for ROOT."""
         # set the callback to record the info
         called = []
-        f = lambda *a: called.append(a)
-        self.client.set_volume_new_generation_callback(f)
+        self.client.set_volume_new_generation_callback(
+            lambda *a: called.append(a))
 
         # create the message
         message = protocol_pb2.Message()
@@ -393,7 +404,10 @@
     def test_handle_root_created_passes_a_root(self):
         """Test handle_VOLUME_CREATED parameter passing."""
         self.volume = None
-        a_callback = lambda vol: setattr(self, 'volume', vol)
+
+        def a_callback(vol):
+            setattr(self, 'volume', vol)
+
         self.client.set_volume_created_callback(a_callback)
 
         message = build_volume_created()
@@ -406,7 +420,10 @@
     def test_handle_udf_created_passes_a_udf(self):
         """Test handle_VOLUME_CREATED parameter passing."""
         self.volume = None
-        a_callback = lambda vol: setattr(self, 'volume', vol)
+
+        def a_callback(vol):
+            setattr(self, 'volume', vol)
+
         self.client.set_volume_created_callback(a_callback)
 
         message = build_volume_created()
@@ -419,7 +436,10 @@
     def test_handle_share_created_passes_a_share(self):
         """Test handle_VOLUME_CREATED parameter passing."""
         self.volume = None
-        a_callback = lambda vol: setattr(self, 'volume', vol)
+
+        def a_callback(vol):
+            setattr(self, 'volume', vol)
+
         self.client.set_volume_created_callback(a_callback)
 
         message = build_volume_created()
@@ -429,14 +449,6 @@
         self.client.handle_VOLUME_CREATED(message)
         self.assertEquals(share, self.volume)
 
-    def test_handle_volume_created_if_volume_is_buggy(self):
-        """Test handle_VOLUME_CREATED if the volume is buggy."""
-        message = build_volume_created()
-        message.volume_created.type = -1  # invalid type!
-        self.client.set_volume_created_callback(lambda vol: None)
-        self.assertRaises(TypeError, self.client.handle_VOLUME_CREATED,
-                          message)
-
     def test_handle_volume_created_if_callback_is_none(self):
         """Test handle_VOLUME_CREATED if callback is none."""
         message = build_volume_created()
@@ -456,7 +468,10 @@
     def test_handle_volume_deleted_passes_the_id(self):
         """Test handle_VOLUME_DELETED."""
         self.volume = None
-        a_callback = lambda vol_id: setattr(self, 'volume', vol_id)
+
+        def a_callback(vol):
+            setattr(self, 'volume', vol)
+
         self.client.set_volume_deleted_callback(a_callback)
 
         message = build_volume_deleted()
@@ -566,12 +581,6 @@
         message = protocol_pb2.Message()
         self.assertRaises(FakedError, self.request.processMessage, message)
 
-    def test_process_message_error_when_incorrect_volume(self):
-        """Test error condition when incorrect volume type."""
-        message = build_list_volumes()
-        message.list_volumes.type = -1
-        self.assertRaises(FakedError, self.request.processMessage, message)
-
     def test_process_message_volume_created(self):
         """Test request processMessage on sucess."""
         message = build_list_volumes()
 
=== modified file 'tests/test_context.py'
--- tests/test_context.py	2015-05-18 17:23:03 +0000
+++ tests/test_context.py	2016-09-19 02:06:21 +0000
@@ -36,12 +36,6 @@
 
 from ubuntuone.storageprotocol import context
 
-try:
-    from ubuntu_sso.utils import get_cert_dir
-except ImportError:
-    # old system, let's support Precise
-    get_cert_dir = lambda: '/etc/ssl/certs'
-
 
 class FakeCerts(object):
     """CA and Server certificate."""
@@ -123,24 +117,6 @@
     """Tests for the context.get_ssl_context function."""
 
     @defer.inlineCallbacks
-    def setUp(self):
-        yield super(SSLContextTestCase, self).setUp()
-        self.patch(context, "get_certificates", self.get_certificates)
-
-    def get_certificates(self):
-        """Get the uninstalled certificates, for testing."""
-        certs = []
-        data_dir = get_cert_dir()
-
-        for certname in ['UbuntuOne-Go_Daddy_Class_2_CA.pem',
-                         'UbuntuOne-Go_Daddy_CA.pem']:
-            cert_path = os.path.abspath(os.path.join(data_dir, certname))
-            c = ssl.Certificate.loadPEM(file(cert_path, 'r').read())
-            certs.append(c.original)
-
-        return certs
-
-    @defer.inlineCallbacks
     def verify_context(self, server_context, client_context):
         """Verify a client context with a given server context."""
         site = server.Site(FakeResource())
@@ -177,7 +153,7 @@
 
         d = self.verify_context(server_context, client_context)
         e = yield self.assertFailure(d, SSL.Error)
-        self.assertEqual(e[0][0][1], "SSL3_GET_SERVER_CERTIFICATE")
+        self.assertEqual(e[0][0][1], "ssl3_get_server_certificate")
 
     @defer.inlineCallbacks
     def test_fails_hostname(self):
@@ -191,7 +167,7 @@
 
         d = self.verify_context(server_context, client_context)
         e = yield self.assertFailure(d, SSL.Error)
-        self.assertEqual(e[0][0][1], "SSL3_GET_SERVER_CERTIFICATE")
+        self.assertEqual(e[0][0][1], "ssl3_get_server_certificate")
 
     @defer.inlineCallbacks
     def test_matches_all(self):
@@ -212,7 +188,7 @@
     def test_load_all_certificates(self):
         """Load all available certificates."""
         certs = FakeCerts(self, "localhost")
-        self.patch(context, 'get_cert_dir', lambda: certs.cert_dir)
+        os.environ['SSL_CERTIFICATES_DIR'] = certs.cert_dir
         # remove the key
         os.unlink(certs.server_key_path)
         loaded = context.get_certificates()
 
=== modified file 'tests/test_proxy_tunnel.py'
--- tests/test_proxy_tunnel.py	2012-03-29 20:28:09 +0000
+++ tests/test_proxy_tunnel.py	2016-09-19 02:06:21 +0000
@@ -135,7 +135,7 @@
         if auth is not None:
             auth_line = "Proxy-Authorization: Basic " + \
                 base64.b64encode("test:test")
-            if not auth_line in data:
+            if auth_line not in data:
                 proto.dataReceived("HTTP/1.0 403 Forbidden\r\n\r\n")
             else:
                 proto.dataReceived(response_string)
 
=== modified file 'ubuntuone/storageprotocol/client.py'
--- ubuntuone/storageprotocol/client.py	2015-05-18 17:23:03 +0000
+++ ubuntuone/storageprotocol/client.py	2016-09-19 02:06:21 +0000
@@ -1689,8 +1689,8 @@
         """
         delayed_call = getattr(self, call_id)
         # check if we already have a DelayedCall running
-        if delayed_call is None or (not delayed_call.active()
-                                    and delayed_call.cancelled):
+        if delayed_call is None or (
+                not delayed_call.active() and delayed_call.cancelled):
             return self.callLater(period, func)
         return delayed_call
 
@@ -1837,12 +1837,12 @@
     reactor.connectTCP('localhost', 20100, StorageClientFactory())
 
     # using ssl
-    #reactor.connectSSL('localhost', 20101, StorageClientFactory(),
+    # reactor.connectSSL('localhost', 20101, StorageClientFactory(),
     #           ssl.ClientContextFactory())
 
     # using ssl over a proxy
-    #from ubuntuone.storageprotocol import proxy_tunnel
-    #proxy_tunnel.connectHTTPS('localhost', 3128,
+    # from ubuntuone.storageprotocol import proxy_tunnel
+    # proxy_tunnel.connectHTTPS('localhost', 3128,
     #        'localhost', 20101, StorageClientFactory(),
     #        user="test", passwd="test")
 
 
=== modified file 'ubuntuone/storageprotocol/content_hash.py'
--- ubuntuone/storageprotocol/content_hash.py	2012-03-29 20:28:09 +0000
+++ ubuntuone/storageprotocol/content_hash.py	2016-09-19 02:06:21 +0000
@@ -36,6 +36,10 @@
 import zlib
 
 
+def noop():
+    """No op."""
+
+
 class ContentHash(object):
     """Encapsulate the generation of content hashes.
 
@@ -43,7 +47,7 @@
     composition to get similar methods.
 
     """
-    method = lambda: None
+    method = noop
     method_name = ""
 
     def __init__(self):
 
=== modified file 'ubuntuone/storageprotocol/request.py'
--- ubuntuone/storageprotocol/request.py	2013-08-01 21:32:53 +0000
+++ ubuntuone/storageprotocol/request.py	2016-09-19 02:06:21 +0000
@@ -214,8 +214,7 @@
 
         if is_invalid:
             self.log.error("Validation error: " + ", ".join(is_invalid))
-            comment = ("Validation error:\n"
-                       + "\n".join(is_invalid))
+            comment = "Validation error:\n" + "\n".join(is_invalid)
             if len(comment) > MAX_PAYLOAD_SIZE - 100:
                 comment = comment[:MAX_PAYLOAD_SIZE - 112] + ' [truncated]'
             error_message = protocol_pb2.Message()