From 5e527213a2430bb3018e5eebd909aef294edf9b5 Mon Sep 17 00:00:00 2001
From: Karen Arutyunov <karen@codesynthesis.com>
Date: Fri, 18 Dec 2020 18:48:46 +0300
Subject: Switch to build2

---
 xsd-examples/cxx/tree/streaming/driver.cxx | 139 +++++++++++++++++++++++++++++
 1 file changed, 139 insertions(+)
 create mode 100644 xsd-examples/cxx/tree/streaming/driver.cxx

(limited to 'xsd-examples/cxx/tree/streaming/driver.cxx')

diff --git a/xsd-examples/cxx/tree/streaming/driver.cxx b/xsd-examples/cxx/tree/streaming/driver.cxx
new file mode 100644
index 0000000..8a70f58
--- /dev/null
+++ b/xsd-examples/cxx/tree/streaming/driver.cxx
@@ -0,0 +1,139 @@
+// file      : cxx/tree/streaming/driver.cxx
+// copyright : not copyrighted - public domain
+
+#include <iostream>
+#include <fstream>
+
+#include <xercesc/dom/DOM.hpp>
+
+#include <xsd/cxx/xml/string.hxx>  // xml::string
+
+#include "parser.hxx"
+#include "serializer.hxx"
+#include "position.hxx"
+
+using namespace std;
+using namespace xercesc;
+
+int
+main (int argc, char* argv[])
+{
+  if (argc != 2)
+  {
+    cerr << "usage: " << argv[0] << " position.xml" << endl;
+    return 1;
+  }
+
+  int r (0);
+
+  // We need to initialize the Xerces-C++ runtime because we are doing
+  // the XML-to-DOM parsing ourselves.
+  //
+  xercesc::XMLPlatformUtils::Initialize ();
+
+  try
+  {
+    using namespace op;
+    namespace xml = xsd::cxx::xml;
+
+    // Parse and serialize at the same time, in the streaming mode.
+    //
+
+    ifstream ifs;
+    ifs.exceptions (ifstream::badbit | ifstream::failbit);
+    ifs.open (argv[1]);
+
+    ofstream ofs;
+    ofs.exceptions (ios_base::badbit | ios_base::failbit);
+    ofs.open ("out.xml");
+
+    xml_schema::namespace_infomap ns_map;
+    ns_map["op"].name = "http://www.codesynthesis.com/op";
+    ns_map["op"].schema = "position.xsd";
+
+    parser p;
+    serializer s;
+
+    p.start (ifs, argv[1], true);
+    s.start (ofs);
+
+    typedef xml_schema::dom::unique_ptr<DOMDocument> document_ptr;
+
+    // Peek at the root element. This way we only get the "carcase"
+    // of the document, that is, the root element with its name, all
+    // the attributes, and namespace declarations but without any of
+    // the nested elements.
+    //
+    document_ptr docr (p.peek ());
+    bool parsed (false);
+
+    // Parse first-level elements.
+    //
+    for (document_ptr doc1 (p.peek ()); doc1.get () != 0; doc1 = p.peek ())
+    {
+      // Check whether it is an element that we should stream (position) or
+      // just add to the root (header).
+      //
+      string n1 (xml::transcode<char> (
+                   doc1->getDocumentElement ()->getLocalName ()));
+
+      // If we see the first streaming element, then parse the root carcase.
+      //
+      if (!parsed && n1 == "position")
+      {
+        object o (*docr->getDocumentElement ());
+
+        cerr << "id:   " << o.id () << endl
+             << "name: " << o.header ().name () << endl
+             << "type: " << o.header ().type () << endl;
+
+        // Start serializing the document by writing out the root carcase.
+        // Note that we leave it open so that we can serialize more elements.
+        //
+        s.next_open (ns_map["op"].name, "op:object", ns_map, o);
+        parsed = true;
+      }
+
+      // Handle elements that need streaming.
+      //
+      if (n1 == "position")
+      {
+        // Position has no nested elements that we need to stream so we
+        // finish parsing it in one go.
+        //
+        doc1 = p.next (move (doc1));
+        position pos (*doc1->getDocumentElement ());
+
+        cerr << "lat: " << pos.lat () << " lon: " << pos.lon () << endl;
+
+        // Serialize it (append) to the root element.
+        //
+        s.next ("position", pos);
+      }
+      else
+      {
+        // Element that doesn't require streaming (header in our case). Add
+        // to the root element and finish parsing.
+        //
+        docr = p.next (move (doc1), move (docr));
+      }
+    }
+
+    // Close the root element in serializer.
+    //
+    s.next_close ("op:object");
+  }
+  catch (const xml_schema::exception& e)
+  {
+    cerr << e << endl;
+    r = 1;
+  }
+  catch (const ios_base::failure&)
+  {
+    cerr << "io failure" << endl;
+    r = 1;
+  }
+
+  xercesc::XMLPlatformUtils::Terminate ();
+  return r;
+}
-- 
cgit v1.1