blob: 8a72abec40ddcb8f7540e228e8909cb19665246d (
plain)
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
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
|
package org.uscxml.tests.ioprocessor;
import java.io.IOException;
import java.io.StringReader;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import org.uscxml.Data;
import org.uscxml.Event;
import org.uscxml.Factory;
import org.uscxml.IOProcessor;
import org.uscxml.Interpreter;
import org.uscxml.InterpreterException;
import org.uscxml.SendRequest;
import org.uscxml.StringList;
import org.w3c.dom.Document;
import org.xml.sax.InputSource;
import org.xml.sax.SAXException;
public class TestCustomIOProc extends IOProcessor {
public Interpreter interpreter;
/**
* The types we will handle on a <send> element
*/
@Override
public StringList getNames() {
StringList ss = new StringList();
ss.add("java");
return ss;
}
/**
* Optional data we want to make available at
* _ioprocessors[this.getNames.front()] in the datamodel
*/
@Override
public Data getDataModelVariables() {
return new Data();
}
/**
* Send from the SCXML interpreter to this ioprocessor
*/
@Override
public void send(SendRequest req) {
System.out.println(req);
// send in s1.onentry
if ("This is some content!".equals(req.getContent())) {
returnEvent(new Event("received1"));
return;
}
// send in s2.onentry
if (req.getParams().containsKey("foo")
&& "bar".equals(req.getParams().get("foo").get(0).getAtom())) {
returnEvent(new Event("received2"));
return;
}
// send in s3
if (req.getXML().length() > 0) {
try {
DocumentBuilderFactory factory = DocumentBuilderFactory
.newInstance();
Document doc = factory.newDocumentBuilder().parse(
new InputSource(new StringReader(req.getXML())));
System.out.println("Root element :"
+ doc.getDocumentElement().getNodeName());
if ("this".equals(doc.getDocumentElement().getNodeName())) {
returnEvent(new Event("received3"));
return;
}
} catch (ParserConfigurationException e) {
e.printStackTrace();
} catch (SAXException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}
/**
* Create a new instance of this
*/
@Override
public IOProcessor create(Interpreter interpreter) {
TestCustomIOProc ioProc = new TestCustomIOProc();
ioProc.interpreter = interpreter;
ioProc.swigReleaseOwnership();
return ioProc;
}
/**
* @param args
* @throws InterpreterException
*/
public static void main(String[] args) throws InterpreterException {
System.load("/Users/sradomski/Documents/TK/Code/uscxml/build/cli/lib/libuscxmlNativeJava64.jnilib");
TestCustomIOProc ioproc = new TestCustomIOProc();
// just register prototype at global factory
Factory.getInstance().registerIOProcessor(ioproc);
String xml =
"<scxml>" +
" <state id=\"s1\">" +
" <onentry>" +
" <send type=\"java\">" +
" <content>This is some content!</content>" +
" </send>" +
" </onentry>" +
" <transition event=\"received1\" target=\"s2\" />" +
" </state>" +
" <state id=\"s2\">" +
" <onentry>" +
" <send type=\"java\">" +
" <param name=\"foo\" expr=\"bar\" />" +
" </send>" +
" </onentry>" +
" <transition event=\"received2\" target=\"s3\" />" +
" </state>" +
" <state id=\"s3\">" +
" <onentry>" +
" <send type=\"java\">" +
" <content>" +
" <this><is><xml/></is></this>" +
" </content>" +
" </send>" +
" </onentry>" +
" <transition event=\"received3\" target=\"done\" />" +
" </state>" +
" <final id=\"done\" />" +
"</scxml>";
// parse and interpret
Interpreter interpreter = Interpreter.fromXML(xml);
interpreter.interpret();
}
}
|
