| 1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
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;
}
}
 |