[test]Add test cases for MultiArray message type

Author: qiuzhong

test/py/publisher_msg.py

@@ -97,6 +97,22 @@ def main():
     publisher = node.create_publisher(Float64, 'Float64_py_js_channel')
     msg = Float64()
     msg.data = 3.14
+  elif rclType == 'Array':
+    node = rclpy.create_node('py_array_publisher')
+    publisher = node.create_publisher(ByteMultiArray, 'Array_py_js_channel');
+
+    lengthDim = MultiArrayDimension()
+    lengthDim.label = 'length'
+    lengthDim.size = 1;
+    lengthDim.stride = 3;
+
+    layout = MultiArrayLayout()
+    layout.dim = [lengthDim]
+    layout.data_offset = 0;
+
+    msg = ByteMultiArray()
+    msg.layout = layout
+    msg.data = [b'\x41', b'\x42', b'\x43']
   elif rclType == 'ColorRGBA':
     node = rclpy.create_node('py_colorrgba_publisher')
     publisher = node.create_publisher(ColorRGBA, 'ColorRGBA_py_js_channel')

test/py/subscription_msg.py

@@ -36,6 +36,10 @@ def callback(msg):
   sys.stdout.write(str(msg.data))
   sys.stdout.flush()
 
+def callback_array(msg):
+  sys.stdout.write(''.join([r.decode('utf-8') for r in msg.data]))
+  sys.stdout.flush()
+
 def callback_colorrgba(msg):
   sys.stdout.write('(' + str(msg.r) + ',' 
                     + str(msg.g) + ',' 
@@ -109,6 +113,9 @@ def main():
   elif rclType == 'Float64':
     node = rclpy.create_node('py_float64_subscription')
     subscription = node.create_subscription(Float64, 'Float64_js_py_channel', callback)
+  elif rclType == 'Array':
+    node = rclpy.create_node('py_array_subscription')
+    subscription = node.create_subscription(ByteMultiArray, 'Array_js_py_channel', callback_array)
   elif rclType == 'ColorRGBA':
     node = rclpy.create_node('py_colorrgba_subscription')
     subscription = node.create_subscription(ColorRGBA, 'ColorRGBA_js_py_channel', callback_colorrgba)

test/test-compound-msg-type-check.js

@@ -38,23 +38,6 @@ describe('Compound types', function() {
     assert.deepStrictEqual(typeof msg.g, 'number');
     assert.deepStrictEqual(typeof msg.b, 'number');
     assert.deepStrictEqual(typeof msg.a, 'number');
-
-    // assertThrowsError(() => {
-    //   msg.r = -1;
-    //   msg.r = 256;
-    // }, TypeError, 'out of bounds', 'Invalid RGBA value');
-    // assertThrowsError(() => {
-    //   msg.g = -1;
-    //   msg.g = 256;
-    // }, TypeError, 'out of bounds', 'Invalid RGBA value');
-    // assertThrowsError(() => {
-    //   msg.b = -1;
-    //   msg.b = 256;
-    // }, TypeError, 'out of bounds', 'Invalid RGBA value');
-    // assertThrowsError(() => {
-    //   msg.a = -0.1;
-    //   msg.a = 1.1;
-    // }, TypeError, 'out of bounds', 'Invalid RGBA value');
   });
 
   it('Array', function() {

test/test-msg-type-py-node.js

@@ -294,8 +294,23 @@ describe('Rclnodejs - Python message type testing', function() {
       rclnodejs.spin(node);
     });
 
-    // it('Array', function(done) {
-    // });
+    it('Array', function(done) {
+      var node = rclnodejs.createNode('array_js_subscription');
+      const ByteMultiArray = rclnodejs.require('std_msgs').msg.ByteMultiArray;
+      var destroy = false;
+      var publisher = utils.launchPythonProcess([`${__dirname}/py/publisher_msg.py`, 'Array']);
+      var subscription = node.createSubscription(ByteMultiArray, 'Array_py_js_channel', (msg) => {
+        assert.deepStrictEqual(msg.data, [65, 66, 67]);
+
+        if (!destroy) {
+          node.destroy();
+          publisher.kill('SIGINT');
+          destroy = true;
+        }
+        done();
+      });
+      rclnodejs.spin(node);
+    });
 
     it('Header', function(done) {
       var node = rclnodejs.createNode('header_js_publisher');
@@ -733,6 +748,47 @@ describe('Rclnodejs - Python message type testing', function() {
   describe('Rclnodejs publisher - Python subscription: compound msg types', function() {
     this.timeout(60 * 1000);
 
+    it('Array', function(done) {
+      var node = rclnodejs.createNode('multiarray_js_publisher');
+      const Byte = rclnodejs.require('std_msgs').msg.Byte;
+      const MultiArrayDimension = rclnodejs.require('std_msgs').msg.MultiArrayDimension;
+      const MultiArrayLayout = rclnodejs.require('std_msgs').msg.MultiArrayLayout;
+      const ByteMultiArray = rclnodejs.require('std_msgs').msg.ByteMultiArray;
+
+      let lengthDim = new MultiArrayDimension();
+      lengthDim.label = 'length';
+      lengthDim.size = 1;
+      lengthDim.stride = 3;
+
+      let layout = new MultiArrayLayout();
+      layout.dim.fill([lengthDim]);
+      // eslint-disable-next-line
+      layout.data_offset = 0;
+
+      let byteArray = new ByteMultiArray();
+      byteArray.layout = layout;
+      byteArray.data = [65, 66, 67];
+
+      var destroy = false;
+      var subscription = utils.launchPythonProcess([`${__dirname}/py/subscription_msg.py`, 'Array']);
+      var publisher = node.createPublisher(ByteMultiArray, 'Array_js_py_channel');
+      const expected = 'ABC';
+      subscription.stdout.on('data', (data) => {
+        if (!destroy) {
+          clearInterval(timer);
+          assert.deepStrictEqual(data.toString(), expected);
+          done();
+          node.destroy();
+          subscription.kill('SIGINT');
+          destroy = true;
+        }
+      });
+      var timer = setInterval(() => {
+        publisher.publish(byteArray);
+      }, 100);
+      rclnodejs.spin(node);
+    });
+
     it('ColorRGBA', function(done) {
       var node = rclnodejs.createNode('colorrgba_js_publisher');
       const ColorRGBA = rclnodejs.require('std_msgs').msg.ColorRGBA;