KException when Serialization fails. Closes #55 (#56)

Author: csteppe-kx

kx.Test/Connection/ConnectionSerialisationTests.cs

@@ -20,6 +20,29 @@ public void ConnectionSerialiseThrowsIfInputIsNull()
             }
         }
 
+        [Test]
+        public void ConnectionSerialiseThrowsKExceptionWithInnerExceptionIfSerialisationThrowsException()
+        {
+            using (var connection = new c(_testVersionNumber))
+            {
+
+                c.Dict dataRow = new c.Dict(
+                new[]
+                {
+                "sym"
+                },
+                new object[]
+                {
+                new object[] { null },
+                });
+
+                c.Flip f = new c.Flip(dataRow);
+
+                var exception = Assert.Throws<KException>(() => connection.Serialize(1, f));
+                Assert.NotNull(exception.InnerException);
+
+            }
+        }
         [Test]
         public void ConnectionSerialiseThrowsIfGuidSerialisationIsNotSupported()
         {

kx/c.cs

@@ -700,22 +700,29 @@ public byte[] Serialize(int messageType, object x, bool zip)
                     $"Unable to serialize data. {nameof(x)} parameter cannot be null");
             }
 
-            int length = nx(x) + 8;
-            _writeBuffer = new byte[length];
-            _writeBuffer[0] = 1;
-            _writeBuffer[1] = (byte)messageType;
-            _writePosition = 4;
-            w(length);
-            w(x);
+            try
+            {
+                int length = nx(x) + 8;
+                _writeBuffer = new byte[length];
+                _writeBuffer[0] = 1;
+                _writeBuffer[1] = (byte)messageType;
+                _writePosition = 4;
+                w(length);
+                w(x);
 
-            if (zip &&
-                _writePosition > 2000 &&
-                !_isLoopback)
+                if (zip &&
+                    _writePosition > 2000 &&
+                    !_isLoopback)
+                {
+                    Compress();
+                }
+
+                return _writeBuffer;
+            }
+            catch (Exception ex)
             {
-                Compress();
+                throw new KException("Error occurred while trying to serialize object.", ex);
             }
-
-            return _writeBuffer;
         }
 
         /// <summary>