Adds test for DataPoint.fromByteArray()

src/main/java/com/iobeam/api/resource/DataPoint.java

@@ -179,11 +179,14 @@ public static DataPoint fromByteArray(byte[] array) {
             return new DataPoint(timestamp, buf.getLong());
         } else if (type == TYPE_DOUBLE) {
             return new DataPoint(timestamp, buf.getDouble());
-        } else {
+        } else if (type == TYPE_STRING) {
             int len = buf.getInt();
             byte[] bytes = new byte[len];
             buf.get(bytes, 0, len);
             return new DataPoint(timestamp, new String(bytes));
+        } else {
+            // TODO - Throw exception if invalid format.
+            return null;
         }
     }
 

src/test/java/com/iobeam/api/resource/DataPointTest.java

@@ -73,6 +73,27 @@ public void testToJson() throws Exception {
         assertEquals("11.2", json.getString("value"));
     }
 
+    @Test
+    public void testFromByteArray() throws Exception {
+        long now = System.currentTimeMillis();
+
+        DataPoint dataPointInt = new DataPoint(now, 10);
+        ByteBuffer buf = ByteBuffer.wrap(dataPointInt.toByteArray());
+
+        DataPoint reverse = DataPoint.fromByteArray(buf.array());
+        assertEquals(dataPointInt, reverse);
+
+        DataPoint dataPointDouble = new DataPoint(now, 10.5);
+        buf = ByteBuffer.wrap(dataPointDouble.toByteArray());
+        reverse = DataPoint.fromByteArray(buf.array());
+        assertEquals(dataPointDouble, reverse);
+
+        DataPoint dataPointString = new DataPoint(now, "11.2");
+        buf = ByteBuffer.wrap(dataPointString.toByteArray());
+        reverse = DataPoint.fromByteArray(buf.array());
+        assertEquals(dataPointString, reverse);
+    }
+
     @Test
     public void testToByteArray() throws Exception {
         long now = System.currentTimeMillis();