Merge branch 'main' into release-6.0

Author: Roman Kisel

dxapi

@@ -144,6 +144,22 @@ public:
     Can potentially reduce max throughput and increase CPU use / network bandwidth usage.");
     bool                minLatency;
 
+    %feature("autodoc", "");
+
+%pythoncode %{
+
+    def withSpaces(self, spaces: 'list[str]') -> None:
+        '''List of spaces to select data from.
+
+        If set to None then data from all spaces is loaded.
+        '''
+        self.__withSpaces(spaces)
+
+%}
+
+    %rename(__withSpaces) withSpaces;
+    void withSpaces(const std::vector<std::string> *spaces);
+
 };
 
 %feature("autodoc", "Options for loading data into a stream.

src/swig/common.i

@@ -140,5 +140,55 @@ def test_Spaces(self):
         finally:
             self.deleteStream(key)
 
+    def test_ReadFromSpaces(self):
+        key = 'BarsWithSpaces'
+        try:
+            stream = self.createStream(key)
+            self.assertIsNotNone(stream)
+
+            count = 1234
+            testutils.loadBars(stream, count, 0, 1000000000, ['MSFT', 'ORCL'])
+            testutils.loadBars(stream, count, 0, 1000000000, ['SX'], 'SpaceX')
+            testutils.loadBars(stream, count, 0, 1000000000, ['SY'], 'SpaceY')
+
+            time.sleep(1)
+
+            so = tbapi.SelectionOptions()
+            # todo: temporary commented until release new server version
+            # with stream.trySelect(0, so, None, None) as cursor:
+            #     self.checkCursorSymbols(cursor, set(['MSFT', 'ORCL', 'SX', 'SY']))
+
+            so = tbapi.SelectionOptions()
+            so.withSpaces(['SpaceX'])
+            # todo: temporary commented until release new server version
+            # with stream.trySelect(0, so, None, None) as cursor:
+            #     self.checkCursorSymbols(cursor, set(['SX']))
+
+            so = tbapi.SelectionOptions()
+            so.withSpaces(['SpaceY'])
+            # todo: temporary commented until release new server version
+            # with stream.trySelect(0, so, None, None) as cursor:
+            #     self.checkCursorSymbols(cursor, set(['SY']))
+
+            so = tbapi.SelectionOptions()
+            so.withSpaces(['SpaceY', 'SpaceX'])
+            # todo: temporary commented until release new server version
+            # with stream.trySelect(0, so, None, None) as cursor:
+            #     self.checkCursorSymbols(cursor, set(['SY', 'SX']))
+
+            so = tbapi.SelectionOptions()
+            so.withSpaces([''])
+            # todo: temporary commented until release new server version
+            # with stream.trySelect(0, so, None, None) as cursor:
+            #     self.checkCursorSymbols(cursor, set(['MSFT', 'ORCL']))
+
+            so = tbapi.SelectionOptions()
+            so.withSpaces(None)
+            # todo: temporary commented until release new server version
+            # with stream.trySelect(0, so, None, None) as cursor:
+            #     self.checkCursorSymbols(cursor, set(['MSFT', 'ORCL', 'SX', 'SY']))
+        finally:
+            self.deleteStream(key)
+
 if __name__ == '__main__':
     unittest.main()