Data Exchange, DE_Wrapper - Implement Stream support

src/DataExchange/TKDE/DE/DE_ConfigurationNode.cxx

@@ -103,6 +103,13 @@ bool DE_ConfigurationNode::IsExportSupported() const
 
 //=================================================================================================
 
+bool DE_ConfigurationNode::IsStreamSupported() const
+{
+  return false;
+}
+
+//=================================================================================================
+
 bool DE_ConfigurationNode::CheckExtension(const TCollection_AsciiString& theExtension) const
 {
   TCollection_AsciiString anExtension(theExtension);

src/DataExchange/TKDE/DE/DE_ConfigurationNode.hxx

@@ -92,14 +92,18 @@ public:
                                           const Standard_Boolean theToKeep);
 
 public:
-  //! Checks the import supporting
-  //! @return Standard_True if import is support
+  //! Checks for import support.
+  //! @return Standard_True if import is supported
   Standard_EXPORT virtual bool IsImportSupported() const;
 
-  //! Checks the export supporting
-  //! @return Standard_True if export is support
+  //! Checks for export support.
+  //! @return Standard_True if export is supported
   Standard_EXPORT virtual bool IsExportSupported() const;
 
+  //! Checks for stream support.
+  //! @return Standard_True if streams are supported
+  Standard_EXPORT virtual bool IsStreamSupported() const;
+
   //! Gets CAD format name of associated provider
   //! @return provider CAD format
   Standard_EXPORT virtual TCollection_AsciiString GetFormat() const = 0;

src/DataExchange/TKDE/DE/DE_Provider.cxx

@@ -15,6 +15,7 @@
 
 #include <DE_ConfigurationNode.hxx>
 #include <Message.hxx>
+#include <NCollection_IndexedDataMap.hxx>
 
 IMPLEMENT_STANDARD_RTTIEXT(DE_Provider, Standard_Transient)
 
@@ -148,3 +149,123 @@ Standard_Boolean DE_Provider::Write(const TCollection_AsciiString& thePath,
                       << " doesn't support write operation";
   return Standard_False;
 }
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Read(ReadStreamList&                 theStreams,
+                                   const Handle(TDocStd_Document)& theDocument,
+                                   Handle(XSControl_WorkSession)&  theWS,
+                                   const Message_ProgressRange&    theProgress)
+{
+  (void)theStreams;
+  (void)theDocument;
+  (void)theWS;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream read operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Write(WriteStreamList&                theStreams,
+                                    const Handle(TDocStd_Document)& theDocument,
+                                    Handle(XSControl_WorkSession)&  theWS,
+                                    const Message_ProgressRange&    theProgress)
+{
+  (void)theStreams;
+  (void)theDocument;
+  (void)theWS;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream write operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Read(ReadStreamList&                theStreams,
+                                   TopoDS_Shape&                  theShape,
+                                   Handle(XSControl_WorkSession)& theWS,
+                                   const Message_ProgressRange&   theProgress)
+{
+  (void)theStreams;
+  (void)theShape;
+  (void)theWS;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream read operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Write(WriteStreamList&               theStreams,
+                                    const TopoDS_Shape&            theShape,
+                                    Handle(XSControl_WorkSession)& theWS,
+                                    const Message_ProgressRange&   theProgress)
+{
+  (void)theStreams;
+  (void)theShape;
+  (void)theWS;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream write operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Read(ReadStreamList&                 theStreams,
+                                   const Handle(TDocStd_Document)& theDocument,
+                                   const Message_ProgressRange&    theProgress)
+{
+  (void)theStreams;
+  (void)theDocument;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream read operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Write(WriteStreamList&                theStreams,
+                                    const Handle(TDocStd_Document)& theDocument,
+                                    const Message_ProgressRange&    theProgress)
+{
+  (void)theStreams;
+  (void)theDocument;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream write operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Read(ReadStreamList&              theStreams,
+                                   TopoDS_Shape&                theShape,
+                                   const Message_ProgressRange& theProgress)
+{
+  (void)theStreams;
+  (void)theShape;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream read operation";
+  return Standard_False;
+}
+
+//=================================================================================================
+
+Standard_Boolean DE_Provider::Write(WriteStreamList&             theStreams,
+                                    const TopoDS_Shape&          theShape,
+                                    const Message_ProgressRange& theProgress)
+{
+  (void)theStreams;
+  (void)theShape;
+  (void)theProgress;
+  Message::SendFail() << "Error: provider " << GetFormat() << " " << GetVendor()
+                      << " doesn't support stream write operation";
+  return Standard_False;
+}

src/DataExchange/TKDE/DE/DE_Provider.hxx

@@ -15,6 +15,9 @@
 #define _DE_Provider_HeaderFile
 
 #include <Message_ProgressRange.hxx>
+#include <NCollection_List.hxx>
+#include <Standard_IStream.hxx>
+#include <Standard_OStream.hxx>
 
 class DE_ConfigurationNode;
 class TopoDS_Shape;
@@ -43,6 +46,45 @@ class DE_Provider : public Standard_Transient
 public:
   DEFINE_STANDARD_RTTIEXT(DE_Provider, Standard_Transient)
 
+  //! Node to store write stream information
+  //! Contains relative path and reference to output stream
+  struct WriteStreamNode
+  {
+    TCollection_AsciiString Path;   //!< Relative path to the output file
+    Standard_OStream&       Stream; //!< Reference to output stream
+
+    //! Constructor
+    WriteStreamNode(const TCollection_AsciiString& thePath, Standard_OStream& theStream)
+        : Path(thePath),
+          Stream(theStream)
+    {
+    }
+  };
+
+  //! Node to store read stream information
+  //! Contains relative path and reference to input stream
+  struct ReadStreamNode
+  {
+    TCollection_AsciiString Path;   //!< Relative path to the input file
+    Standard_IStream&       Stream; //!< Reference to input stream
+
+    //! Constructor
+    ReadStreamNode(const TCollection_AsciiString& thePath, Standard_IStream& theStream)
+        : Path(thePath),
+          Stream(theStream)
+    {
+    }
+  };
+
+public:
+  //! List to store write stream nodes
+  //! First element is the main stream, others are for internal referencing
+  using WriteStreamList = NCollection_List<WriteStreamNode>;
+
+  //! List to store read stream nodes
+  //! First element is the main stream, others are for internal referencing
+  using ReadStreamList = NCollection_List<ReadStreamNode>;
+
 public:
   //! Default constructor
   //! Configure translation process with global configuration
@@ -77,6 +119,30 @@ public:
     Handle(XSControl_WorkSession)&  theWS,
     const Message_ProgressRange&    theProgress = Message_ProgressRange());
 
+  //! Reads streams according to internal configuration
+  //! @param[in] theStreams streams to read from
+  //! @param[out] theDocument document to save result
+  //! @param[in] theWS current work session
+  //! @param[in] theProgress progress indicator
+  //! @return True if Read was successful
+  Standard_EXPORT virtual Standard_Boolean Read(
+    ReadStreamList&                 theStreams,
+    const Handle(TDocStd_Document)& theDocument,
+    Handle(XSControl_WorkSession)&  theWS,
+    const Message_ProgressRange&    theProgress = Message_ProgressRange());
+
+  //! Writes streams according to internal configuration
+  //! @param[in] theStreams streams to write to
+  //! @param[out] theDocument document to export
+  //! @param[in] theWS current work session
+  //! @param[in] theProgress progress indicator
+  //! @return True if Write was successful
+  Standard_EXPORT virtual Standard_Boolean Write(
+    WriteStreamList&                theStreams,
+    const Handle(TDocStd_Document)& theDocument,
+    Handle(XSControl_WorkSession)&  theWS,
+    const Message_ProgressRange&    theProgress = Message_ProgressRange());
+
   //! Reads a CAD file, according internal configuration
   //! @param[in] thePath path to the import CAD file
   //! @param[out] theDocument document to save result
@@ -97,6 +163,26 @@ public:
     const Handle(TDocStd_Document)& theDocument,
     const Message_ProgressRange&    theProgress = Message_ProgressRange());
 
+  //! Reads streams according to internal configuration
+  //! @param[in] theStreams streams to read from
+  //! @param[out] theDocument document to save result
+  //! @param[in] theProgress progress indicator
+  //! @return True if Read was successful
+  Standard_EXPORT virtual Standard_Boolean Read(
+    ReadStreamList&                 theStreams,
+    const Handle(TDocStd_Document)& theDocument,
+    const Message_ProgressRange&    theProgress = Message_ProgressRange());
+
+  //! Writes streams according to internal configuration
+  //! @param[in] theStreams streams to write to
+  //! @param[out] theDocument document to export
+  //! @param[in] theProgress progress indicator
+  //! @return True if Write was successful
+  Standard_EXPORT virtual Standard_Boolean Write(
+    WriteStreamList&                theStreams,
+    const Handle(TDocStd_Document)& theDocument,
+    const Message_ProgressRange&    theProgress = Message_ProgressRange());
+
   //! Reads a CAD file, according internal configuration
   //! @param[in] thePath path to the import CAD file
   //! @param[out] theShape shape to save result
@@ -121,6 +207,30 @@ public:
     Handle(XSControl_WorkSession)& theWS,
     const Message_ProgressRange&   theProgress = Message_ProgressRange());
 
+  //! Reads streams according to internal configuration
+  //! @param[in] theStreams streams to read from
+  //! @param[out] theShape shape to save result
+  //! @param[in] theWS current work session
+  //! @param[in] theProgress progress indicator
+  //! @return True if Read was successful
+  Standard_EXPORT virtual Standard_Boolean Read(
+    ReadStreamList&                theStreams,
+    TopoDS_Shape&                  theShape,
+    Handle(XSControl_WorkSession)& theWS,
+    const Message_ProgressRange&   theProgress = Message_ProgressRange());
+
+  //! Writes streams according to internal configuration
+  //! @param[in] theStreams streams to write to
+  //! @param[out] theShape shape to export
+  //! @param[in] theWS current work session
+  //! @param[in] theProgress progress indicator
+  //! @return True if Write was successful
+  Standard_EXPORT virtual Standard_Boolean Write(
+    WriteStreamList&               theStreams,
+    const TopoDS_Shape&            theShape,
+    Handle(XSControl_WorkSession)& theWS,
+    const Message_ProgressRange&   theProgress = Message_ProgressRange());
+
   //! Reads a CAD file, according internal configuration
   //! @param[in] thePath path to the import CAD file
   //! @param[out] theShape shape to save result
@@ -141,6 +251,26 @@ public:
     const TopoDS_Shape&            theShape,
     const Message_ProgressRange&   theProgress = Message_ProgressRange());
 
+  //! Reads streams according to internal configuration
+  //! @param[in] theStreams streams to read from
+  //! @param[out] theShape shape to save result
+  //! @param[in] theProgress progress indicator
+  //! @return True if Read was successful
+  Standard_EXPORT virtual Standard_Boolean Read(
+    ReadStreamList&              theStreams,
+    TopoDS_Shape&                theShape,
+    const Message_ProgressRange& theProgress = Message_ProgressRange());
+
+  //! Writes streams according to internal configuration
+  //! @param[in] theStreams streams to write to
+  //! @param[out] theShape shape to export
+  //! @param[in] theProgress progress indicator
+  //! @return True if Write was successful
+  Standard_EXPORT virtual Standard_Boolean Write(
+    WriteStreamList&             theStreams,
+    const TopoDS_Shape&          theShape,
+    const Message_ProgressRange& theProgress = Message_ProgressRange());
+
 public:
   //! Gets CAD format name of associated provider
   //! @return provider CAD format