From c5a11763985172f54d0da8a2a2778f882f3656e5 Mon Sep 17 00:00:00 2001
From: Adrian Kummerländer
Date: Sun, 25 May 2014 21:49:59 +0200
Subject: Implemented basic external "execute" function * enables execution of
 external programs ** second parameter is passed to stdin ** stdout is
 captured and returned ** based on booost::process * this was implemented to
 enable access to external content preprocessors such as markdown

---
 src/function/execute.cc | 77 +++++++++++++++++++++++++++++++++++++++++++++++++
 src/function/execute.h  | 28 ++++++++++++++++++
 src/plattform_guard.cc  |  7 +++++
 3 files changed, 112 insertions(+)
 create mode 100644 src/function/execute.cc
 create mode 100644 src/function/execute.h

(limited to 'src')

diff --git a/src/function/execute.cc b/src/function/execute.cc
new file mode 100644
index 0000000..f19ba75
--- /dev/null
+++ b/src/function/execute.cc
@@ -0,0 +1,77 @@
+#include "execute.h"
+
+#include <xercesc/dom/DOMDocument.hpp>
+#include <xercesc/dom/DOMImplementation.hpp>
+#include <xercesc/dom/DOMElement.hpp>
+
+#include <boost/process.hpp>
+
+#include "support/xerces_string_guard.h"
+#include "support/dom/result_node_facade.h"
+
+namespace InputXSLT {
+
+xercesc::DOMDocument* FunctionExecute::constructDocument(
+	const InputXSLT::FilesystemContext&,
+	const FunctionBase::parameter_tuple& parameters
+) {
+	const std::string& executablePath(
+		std::get<0>(parameters)
+	);
+
+	const std::string& stdinText(
+		std::get<1>(parameters)
+	);
+
+	xercesc::DOMDocument* const domDocument(
+		xercesc::DOMImplementation::getImplementation()->createDocument(
+			nullptr,
+			*XercesStringGuard<XMLCh>("content"),
+			nullptr
+		)
+	);
+
+	xercesc::DOMNode* const rootNode(
+		domDocument->getDocumentElement()
+	);
+
+	boost::process::context context;
+	context.stdout_behavior = boost::process::capture_stream();
+	context.stdin_behavior  = boost::process::capture_stream();
+
+	boost::process::child process(
+		boost::process::launch(
+			executablePath,
+			std::vector<std::string>{""},
+			context
+		)
+	);
+
+	boost::process::postream& inputStream  = process.get_stdin();
+	boost::process::pistream& outputStream = process.get_stdout();
+
+	inputStream << stdinText;
+	inputStream.close();
+
+	const std::string resultText(
+		(std::istreambuf_iterator<char>(outputStream)),
+		(std::istreambuf_iterator<char>())
+	);
+
+	boost::process::status status = process.wait();
+
+	if ( status.exited() ) {
+		ResultNodeFacade result(domDocument, rootNode, "result");
+
+		result.setValueNode("code",   std::to_string(status.exit_status()));
+		result.setValueNode("output", resultText);
+	} else {
+		ResultNodeFacade result(domDocument, rootNode, "error");
+
+		result.setValueNode("code", std::to_string(status.exit_status()));
+	}
+
+	return domDocument;
+}
+
+}
diff --git a/src/function/execute.h b/src/function/execute.h
new file mode 100644
index 0000000..12167da
--- /dev/null
+++ b/src/function/execute.h
@@ -0,0 +1,28 @@
+#ifndef INPUTXSLT_SRC_FUNCTION_EXECUTE_H_
+#define INPUTXSLT_SRC_FUNCTION_EXECUTE_H_
+
+#include "base.h"
+
+namespace InputXSLT {
+
+class FunctionExecute : public FunctionBase<
+	FunctionExecute,
+	std::string,
+	std::string
+> {
+	public:
+		using FunctionBase::FunctionBase;
+
+	protected:
+		friend FunctionBase;
+
+		xercesc::DOMDocument* constructDocument(
+			const FilesystemContext&,
+			const FunctionBase::parameter_tuple&
+		);
+
+};
+
+}
+
+#endif  // INPUTXSLT_SRC_FUNCTION_EXECUTE_H_
diff --git a/src/plattform_guard.cc b/src/plattform_guard.cc
index d66c8b5..ff4de08 100644
--- a/src/plattform_guard.cc
+++ b/src/plattform_guard.cc
@@ -10,6 +10,7 @@
 #include "function/read_xml_file.h"
 #include "function/read_directory.h"
 #include "function/transform.h"
+#include "function/execute.h"
 
 namespace InputXSLT {
 
@@ -45,6 +46,12 @@ PlattformGuard::PlattformGuard(const std::vector<std::string>& path):
 		xalan::XalanDOMString("transform"),
 		InputXSLT::FunctionTransform(&this->include_resolver_)
 	);
+
+	xalan::XalanTransformer::installExternalFunctionGlobal(
+		customNamespace,
+		xalan::XalanDOMString("execute"),
+		InputXSLT::FunctionExecute(&this->include_resolver_)
+	);
 }
 
 PlattformGuard::~PlattformGuard() {
-- 
cgit v1.2.3