1 /*------------------------------------------------------------------------------
2 Name: TestGetFilter.java
3 Project: xmlBlaster.org
4 Copyright: xmlBlaster.org, see xmlBlaster-LICENSE file
5 Comment: Login/logout test for xmlBlaster
6 Version: $Id: TestGetFilter.java 14833 2006-03-06 21:38:58Z laghi $
7 ------------------------------------------------------------------------------*/
8 package org.xmlBlaster.test.mime;
9
10 import java.util.logging.Logger;
11 import java.util.logging.Level;
12 import org.xmlBlaster.util.Global;
13 import org.xmlBlaster.util.XmlBlasterException;
14 import org.xmlBlaster.client.qos.ConnectQos;
15 import org.xmlBlaster.client.qos.DisconnectQos;
16 import org.xmlBlaster.client.I_XmlBlasterAccess;
17 import org.xmlBlaster.client.qos.GetQos;
18 import org.xmlBlaster.client.qos.EraseReturnQos;
19 import org.xmlBlaster.util.MsgUnit;
20 import org.xmlBlaster.util.qos.AccessFilterQos;
21 import org.xmlBlaster.util.EmbeddedXmlBlaster;
22
23 import org.xmlBlaster.test.Util;
24 import junit.framework.*;
25
26
27 /**
28 * This client tests the <a href="http://www.xmlblaster.org/xmlBlaster/doc/requirements/mime.plugin.accessfilter.html">
29 * access filter plugin framework</a> on get() invocations.
30 * <p />
31 * We start our own xmlBlaster server in a thread.
32 * This client may be invoked multiple time on the same xmlBlaster server,
33 * as it cleans up everything after his tests are done.
34 * <p>
35 * Invoke examples:<br />
36 * <pre>
37 * java junit.textui.TestRunner org.xmlBlaster.test.mime.TestGetFilter
38 * java junit.swingui.TestRunner -noloading org.xmlBlaster.test.mime.TestGetFilter
39 * </pre>
40 */
41 public class TestGetFilter extends TestCase
42 {
43 private static String ME = "TestGetFilter";
44 private final Global glob;
45 private static Logger log = Logger.getLogger(TestGetFilter.class.getName());
46
47 private I_XmlBlasterAccess con = null;
48 private String name;
49 private String passwd = "secret";
50 private EmbeddedXmlBlaster serverThread;
51 private int serverPort = 7615;
52 private int filterMessageContentBiggerAs = 10;
53
54 /**
55 * Constructs the TestGetFilter object.
56 * <p />
57 * @param testName The name used in the test suite
58 * @param name The name to login to the xmlBlaster
59 */
60 public TestGetFilter(Global glob, String testName, String name)
61 {
62 super(testName);
63 this.glob = glob;
64
65 this.name = name;
66 }
67
68 /**
69 * Sets up the fixture.
70 * <p />
71 * We start an own xmlBlaster server in a separate thread,
72 * it is configured to load our simple demo MIME filter plugin.
73 * <p />
74 * Then we connect as a client
75 */
76 protected void setUp()
77 {
78 // We register here the demo plugin with xmlBlaster server, supplying an argument to the plugin
79 String[] args = new String[10];
80 args[0] = "-bootstrapPort"; // For all protocol we may use set an alternate server port
81 args[1] = "" + serverPort;
82 args[2] = "-plugin/socket/port";
83 args[3] = "" + (serverPort-1);
84 args[4] = "-plugin/rmi/registryPort";
85 args[5] = "" + (serverPort-2);
86 args[6] = "-plugin/xmlrpc/port";
87 args[7] = "" + (serverPort-3);
88 args[8] = "-MimeAccessPlugin[ContentLenFilter][1.0]";
89 args[9] = "org.xmlBlaster.engine.mime.demo.ContentLenFilter,DEFAULT_MAX_LEN=200,THROW_EXCEPTION_FOR_LEN=3";
90 glob.init(args);
91
92 serverThread = EmbeddedXmlBlaster.startXmlBlaster(glob);
93 log.info("XmlBlaster is ready for testing subscribe MIME filter");
94
95 try {
96 log.info("Connecting ...");
97 con = glob.getXmlBlasterAccess();
98 ConnectQos qos = new ConnectQos(glob, name, passwd);
99 con.connect(qos, null); // Login to xmlBlaster
100 }
101 catch (Exception e) {
102 Thread.currentThread().dumpStack();
103 log.severe("Can't connect to xmlBlaster: " + e.toString());
104 }
105 }
106
107 /**
108 * Tears down the fixture.
109 * <p />
110 * cleaning up .... erase() the previous message OID and logout
111 */
112 protected void tearDown()
113 {
114 try { Thread.sleep(200L); } catch( InterruptedException i) {} // Wait 200 milli seconds, until all updates are processed ...
115
116 try {
117 EraseReturnQos[] arr = con.erase("<key oid='MSG'/>", null);
118 if (arr.length != 1) log.severe("Erased " + arr.length + " messages:");
119 } catch(XmlBlasterException e) { log.severe("XmlBlasterException: " + e.getMessage()); }
120
121 con.disconnect(null);
122 con=null;
123
124 try { Thread.sleep(500L); } catch( InterruptedException i) {} // Wait some time
125 EmbeddedXmlBlaster.stopXmlBlaster(this.serverThread);
126 this.serverThread = null;
127
128 // reset to default server port (necessary if other tests follow in the same JVM).
129 Util.resetPorts();
130 }
131
132 /**
133 * First we send a message <= 10 content length which should be updated to us,
134 * then we send a message with 11 bytes in the content which should be filtered
135 */
136 public void testFilter()
137 {
138 log.info("testFilter() with filterMessageContentBiggerAs=" + filterMessageContentBiggerAs + " ...");
139
140 log.info("TEST 1: Testing unfiltered message");
141 String content = "1234567890";
142 try {
143 con.publish(new MsgUnit("<key oid='MSG'/>", content.getBytes(), null));
144 } catch(XmlBlasterException e) {
145 log.warning("XmlBlasterException: " + e.getMessage());
146 assertTrue("publish - XmlBlasterException: " + e.getMessage(), false);
147 }
148
149 try {
150 GetQos qos = new GetQos(glob);
151 qos.addAccessFilter(new AccessFilterQos(glob, "ContentLenFilter", "1.0", ""+filterMessageContentBiggerAs));
152
153 MsgUnit[] msgUnits = con.get("<key oid='MSG'/>", qos.toXml());
154 assertTrue("Expected one returned message", msgUnits!=null);
155 assertTrue("Expected exactly one returned message", msgUnits.length==1);
156 assertTrue("Message content in corrupted '" + new String(msgUnits[0].getContent()) + "' versus '" + content + "'",
157 msgUnits[0].getContent().length == content.length());
158 log.info("Success: Got one message.");
159 } catch(XmlBlasterException e) {
160 log.warning("XmlBlasterException: " + e.getMessage());
161 assertTrue("get - XmlBlasterException: " + e.getMessage(), false);
162 }
163
164
165 log.info("TEST 2: Testing filtered message");
166 content = "12345678901"; // content is too long, our plugin denies this message
167 try {
168 con.publish(new MsgUnit("<key oid='MSG'/>", content.getBytes(), null));
169 } catch(XmlBlasterException e) {
170 log.warning("XmlBlasterException: " + e.getMessage());
171 assertTrue("publish - XmlBlasterException: " + e.getMessage(), false);
172 }
173
174 try {
175 GetQos qos = new GetQos(glob);
176 qos.addAccessFilter(new AccessFilterQos(glob, "ContentLenFilter", "1.0", ""+filterMessageContentBiggerAs));
177
178 MsgUnit[] msgUnits = con.get("<key oid='MSG'/>", qos.toXml());
179 assertTrue("Expected one returned message", msgUnits!=null);
180 assertEquals("Expected no returned message", 0, msgUnits.length);
181 log.info("Success: Got no message.");
182 } catch(XmlBlasterException e) {
183 log.warning("XmlBlasterException: " + e.getMessage());
184 fail("get - XmlBlasterException: " + e.getMessage());
185 }
186
187
188 log.info("TEST 3: Test what happens if the plugin throws an exception");
189 try { // see THROW_EXCEPTION_FOR_LEN=3
190 con.publish(new MsgUnit("<key oid='MSG'/>", "123".getBytes(), null));
191 } catch(XmlBlasterException e) {
192 log.warning("XmlBlasterException: " + e.getMessage());
193 fail("publish - XmlBlasterException: " + e.getMessage());
194 }
195
196 try {
197 GetQos qos = new GetQos(glob);
198 qos.addAccessFilter(new AccessFilterQos(glob, "ContentLenFilter", "1.0", ""+filterMessageContentBiggerAs));
199
200 MsgUnit[] msgUnits = con.get("<key oid='MSG'/>", qos.toXml());
201 fail("get() message should throw an XmlBlasterException, but it didn't happen");
202 } catch(XmlBlasterException e) {
203 log.info("SUCCESS: We expected an XmlBlasterException: " + e.getMessage());
204 }
205
206 log.info("Success in testFilter()");
207 }
208
209 /**
210 * Method is used by TestRunner to load these tests
211 */
212 public static Test suite()
213 {
214 TestSuite suite= new TestSuite();
215 String loginName = "Tim";
216 suite.addTest(new TestGetFilter(new Global(), "testFilter", "Tim"));
217 return suite;
218 }
219
220 /**
221 * Invoke:
222 * <pre>
223 * java org.xmlBlaster.test.mime.TestGetFilter
224 * java -Djava.compiler= junit.textui.TestRunner org.xmlBlaster.test.mime.TestGetFilter
225 * <pre>
226 */
227 public static void main(String args[])
228 {
229 Global glob = new Global();
230 if (glob.init(args) != 0) {
231 System.err.println(ME + ": Init failed");
232 System.exit(1);
233 }
234 TestGetFilter testSub = new TestGetFilter(glob, "TestGetFilter", "Tim");
235 testSub.setUp();
236 testSub.testFilter();
237 }
238 }
syntax highlighted by Code2HTML, v. 0.9.1