diff options
Diffstat (limited to 'plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy')
4 files changed, 0 insertions, 703 deletions
diff --git a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventGenerator.java b/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventGenerator.java deleted file mode 100644 index 9c8696c6c..000000000 --- a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventGenerator.java +++ /dev/null @@ -1,119 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2016-2018 Ericsson. All rights reserved. - * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.plugins.event.protocol.xml; - -import java.util.Random; -import lombok.Getter; - -/** - * The Class XmlEventGenerator. - */ -public class XmlEventGenerator { - @Getter - private static int nextEventNo = 0; - - /** - * Xml events. - * - * @param eventCount the event count - * @return the string - */ - public static String xmlEvents(final int eventCount) { - final StringBuilder builder = new StringBuilder(); - - for (int i = 0; i < eventCount; i++) { - if (i > 0) { - builder.append("\n"); - } - builder.append(xmlEvent()); - } - - return builder.toString(); - } - - /** - * Xml event. - * - * @return the string - */ - public static String xmlEvent() { - final Random rand = new Random(); - - final StringBuilder builder = new StringBuilder(); - - int nextEventNo = rand.nextInt(2); - final String eventName = (nextEventNo == 0 ? "Event0000" : "Event0100"); - final int nextMatchCase = rand.nextInt(4); - final float nextTestTemperature = rand.nextFloat() * 10000; - - builder.append("<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n"); - builder.append("<xmlApexEvent xmlns=\"http://www.onap.org/policy/apex-pdp/apexevent\">\n"); - - builder.append(" <name>" + eventName + "</name>\n"); - builder.append(" <version>0.0.1</version>\n"); - builder.append(" <nameSpace>org.onap.policy.apex.sample.events</nameSpace>\n"); - builder.append(" <source>test</source>\n"); - builder.append(" <target>apex</target>\n"); - builder.append(" <data>\n"); - builder.append(" <key>TestSlogan</key>\n"); - builder.append(" <value>Test slogan for External Event" + (nextEventNo++) + "</value>\n"); - builder.append(" </data>\n"); - builder.append(" <data>\n"); - builder.append(" <key>TestMatchCase</key>\n"); - builder.append(" <value>" + nextMatchCase + "</value>\n"); - builder.append(" </data>\n"); - builder.append(" <data>\n"); - builder.append(" <key>TestTimestamp</key>\n"); - builder.append(" <value>" + System.currentTimeMillis() + "</value>\n"); - builder.append(" </data>\n"); - builder.append(" <data>\n"); - builder.append(" <key>TestTemperature</key>\n"); - builder.append(" <value>" + nextTestTemperature + "</value>\n"); - builder.append(" </data>\n"); - builder.append("</xmlApexEvent>"); - - return builder.toString(); - } - - /** - * The main method. - * - * @param args the arguments - */ - public static void main(final String[] args) { - if (args.length != 1) { - System.err.println("usage EventGenerator #events"); - return; - } - - int eventCount = 0; - try { - eventCount = Integer.parseInt(args[0]); - } catch (final Exception e) { - System.err.println("usage EventGenerator #events"); - e.printStackTrace(); - return; - } - - System.out.println(xmlEvents(eventCount)); - } -} diff --git a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventHandlerTest.java b/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventHandlerTest.java deleted file mode 100644 index f8caf8c2f..000000000 --- a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventHandlerTest.java +++ /dev/null @@ -1,205 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2016-2018 Ericsson. All rights reserved. - * Modifications Copyright (C) 2020-2021 Nordix Foundation. - * Modifications Copyright (C) 2022 Bell Canada. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.plugins.event.protocol.xml; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertNull; -import static org.junit.Assert.assertTrue; - -import java.util.Date; -import java.util.HashMap; -import java.util.Map; -import java.util.Random; -import org.apache.commons.lang3.RandomStringUtils; -import org.junit.Test; -import org.onap.policy.apex.model.basicmodel.concepts.ApexException; -import org.onap.policy.apex.service.engine.event.ApexEvent; -import org.onap.policy.apex.service.engine.event.ApexEventException; -import org.onap.policy.apex.service.engine.event.ApexEventRuntimeException; -import org.slf4j.ext.XLogger; -import org.slf4j.ext.XLoggerFactory; - -/** - * The Class TestApexXMLEventHandlerURL. - * - * @author Liam Fallon (liam.fallon@ericsson.com) - */ -public class XmlEventHandlerTest { - private static final XLogger logger = XLoggerFactory.getXLogger(XmlEventHandlerTest.class); - - /** - * Test XML to apex event. Null value is passed as parameter. - * - * @throws ApexException on Apex event handling errors - */ - @Test(expected = ApexException.class) - public void testApexEventToApexNullObject() throws ApexException { - final Apex2XmlEventConverter xmlEventConverter = new Apex2XmlEventConverter(); - // This is only for code coverage stats. This method does nothing - xmlEventConverter.init(null); - - xmlEventConverter.toApexEvent("XMLEventName", null); - } - - /** - * Test XML to apex event. There is no string passed as parameter. - * - * @throws ApexException on Apex event handling errors - */ - @Test(expected = ApexEventRuntimeException.class) - public void testApexEventToApexNotString() throws ApexException { - final Apex2XmlEventConverter xmlEventConverter = new Apex2XmlEventConverter(); - - xmlEventConverter.toApexEvent("XMLEventName", new Random().nextInt()); - } - - /** - * Test not valid XML to apex event. - * - * @throws ApexException on Apex event handling errors - */ - @Test(expected = ApexException.class) - public void testApexEventToApexNotXml() throws ApexException { - final Apex2XmlEventConverter xmlEventConverter = new Apex2XmlEventConverter(); - - xmlEventConverter.toApexEvent("XMLEventName", RandomStringUtils.randomAlphabetic(25)); - } - - /** - * Test XML to apex event. - * - * @throws ApexException on Apex event handling errors - */ - @Test - public void testXmltoApexEvent() throws ApexException { - try { - final Apex2XmlEventConverter xmlEventConverter = new Apex2XmlEventConverter(); - assertNotNull(xmlEventConverter); - - final String apexEventXmlStringIn = XmlEventGenerator.xmlEvent(); - - logger.debug("input event\n" + apexEventXmlStringIn); - - for (final ApexEvent apexEvent : xmlEventConverter.toApexEvent("XMLEventName", apexEventXmlStringIn)) { - assertNotNull(apexEvent); - - logger.debug(apexEvent.toString()); - - assertTrue(apexEvent.getName().equals("Event0000") || apexEvent.getName().equals("Event0100")); - assertEquals("0.0.1", apexEvent.getVersion()); - assertEquals("org.onap.policy.apex.sample.events", apexEvent.getNameSpace()); - assertEquals("test", apexEvent.getSource()); - assertEquals("apex", apexEvent.getTarget()); - assertTrue(apexEvent.get("TestSlogan").toString().startsWith("Test slogan for External Event")); - - final Object testMatchCaseSelected = apexEvent.get("TestMatchCaseSelected"); - assertNull(testMatchCaseSelected); - } - } catch (final Exception e) { - e.printStackTrace(); - throw new ApexException("Exception reading Apex event xml file", e); - } - } - - /** - * Test null as apex event to xml. - * - * @throws ApexEventException on Apex event handling errors - */ - @Test(expected = ApexEventException.class) - public void testApexEventToXmlNullEvent() throws ApexEventException { - final Apex2XmlEventConverter xmlEventConverter = new Apex2XmlEventConverter(); - xmlEventConverter.fromApexEvent(null); - } - - /** - * Test apex event to xml. - * - * @throws ApexException on Apex event handling errors - */ - @Test - public void testApexEventToXml() throws ApexException { - try { - final Apex2XmlEventConverter xmlEventConverter = new Apex2XmlEventConverter(); - assertNotNull(xmlEventConverter); - - final Date event0000StartTime = new Date(); - final Map<String, Object> event0000DataMap = new HashMap<String, Object>(); - event0000DataMap.put("TestSlogan", "This is a test slogan"); - event0000DataMap.put("TestMatchCase", 12345); - event0000DataMap.put("TestTimestamp", event0000StartTime.getTime()); - event0000DataMap.put("TestTemperature", 34.5445667); - event0000DataMap.put("NullValue", null); - - final ApexEvent apexEvent0000 = - new ApexEvent("Event0000", "0.0.1", "org.onap.policy.apex.sample.events", "test", "apex", ""); - apexEvent0000.putAll(event0000DataMap); - - final String apexEvent0000XmlString = xmlEventConverter.fromApexEvent(apexEvent0000); - - logger.debug(apexEvent0000XmlString); - - assertTrue(apexEvent0000XmlString.contains("<name>Event0000</name>")); - assertTrue(apexEvent0000XmlString.contains("<version>0.0.1</version>")); - assertTrue(apexEvent0000XmlString.contains("<value>This is a test slogan</value>")); - assertTrue(apexEvent0000XmlString.contains("<value>12345</value>")); - assertTrue(apexEvent0000XmlString.contains("<value></value>")); - assertTrue(apexEvent0000XmlString.contains("<value>" + event0000StartTime.getTime() + "</value>")); - assertTrue(apexEvent0000XmlString.contains("<value>34.5445667</value>")); - - final Date event0004StartTime = new Date(1434363272000L); - final Map<String, Object> event0004DataMap = new HashMap<String, Object>(); - event0004DataMap.put("TestSlogan", "Test slogan for External Event"); - event0004DataMap.put("TestMatchCase", Integer.valueOf(2)); - event0004DataMap.put("TestTimestamp", Long.valueOf(event0004StartTime.getTime())); - event0004DataMap.put("TestTemperature", Double.valueOf(1064.43)); - event0004DataMap.put("TestMatchCaseSelected", Integer.valueOf(2)); - event0004DataMap.put("TestMatchStateTime", Long.valueOf(1434370506078L)); - event0004DataMap.put("TestEstablishCaseSelected", Integer.valueOf(0)); - event0004DataMap.put("TestEstablishStateTime", Long.valueOf(1434370506085L)); - event0004DataMap.put("TestDecideCaseSelected", Integer.valueOf(3)); - event0004DataMap.put("TestDecideStateTime", Long.valueOf(1434370506092L)); - event0004DataMap.put("TestActCaseSelected", Integer.valueOf(2)); - event0004DataMap.put("TestActStateTime", Long.valueOf(1434370506095L)); - - final ApexEvent apexEvent0004 = new ApexEvent("Event0004", "0.0.1", - "org.onap.policy.apex.domains.sample.events", "test", "apex", ""); - apexEvent0004.putAll(event0004DataMap); - - final String apexEvent0004XmlString = xmlEventConverter.fromApexEvent(apexEvent0004); - - logger.debug(apexEvent0004XmlString); - - assertTrue(apexEvent0004XmlString.contains("<name>Event0004</name>")); - assertTrue(apexEvent0004XmlString.contains("<version>0.0.1</version>")); - assertTrue(apexEvent0004XmlString.contains("<value>Test slogan for External Event</value>")); - assertTrue(apexEvent0004XmlString.contains("<value>1434370506078</value>")); - assertTrue(apexEvent0004XmlString.contains("<value>" + event0004StartTime.getTime() + "</value>")); - assertTrue(apexEvent0004XmlString.contains("<value>1064.43</value>")); - } catch (final Exception e) { - e.printStackTrace(); - throw new ApexException("Exception reading Apex event xml file", e); - } - } -}
\ No newline at end of file diff --git a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventProtocolParametersTest.java b/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventProtocolParametersTest.java deleted file mode 100644 index 27fd22095..000000000 --- a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlEventProtocolParametersTest.java +++ /dev/null @@ -1,40 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2021 Nordix Foundation. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.plugins.event.protocol.xml; - -import static org.junit.Assert.assertEquals; - -import org.junit.Test; - -public class XmlEventProtocolParametersTest { - - /** - * Test object creation. - */ - @Test - public void instantiationTest() { - final XmlEventProtocolParameters parameters = new XmlEventProtocolParameters(); - - assertEquals(XmlEventProtocolParameters.XML_EVENT_PROTOCOL_LABEL, parameters.getLabel()); - assertEquals("<?xml", parameters.getStartDelimiterToken()); - assertEquals(Apex2XmlEventConverter.class.getName(), parameters.getEventProtocolPluginClass()); - } -}
\ No newline at end of file diff --git a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlTaggedEventConsumerTest.java b/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlTaggedEventConsumerTest.java deleted file mode 100644 index 320d7ba22..000000000 --- a/plugins/plugins-event/plugins-event-protocol/plugins-event-protocol-xml/src/test/java/org/onap/policy/apex/plugins/event/protocol/xml/XmlTaggedEventConsumerTest.java +++ /dev/null @@ -1,339 +0,0 @@ -/*- - * ============LICENSE_START======================================================= - * Copyright (C) 2016-2018 Ericsson. All rights reserved. - * Modifications Copyright (C) 2021 AT&T Intellectual Property. All rights reserved. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.policy.apex.plugins.event.protocol.xml; - -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertNull; -import static org.junit.Assert.assertTrue; - -import java.io.ByteArrayInputStream; -import java.io.IOException; -import java.io.InputStream; -import org.junit.Test; -import org.onap.policy.apex.service.engine.event.impl.filecarrierplugin.consumer.HeaderDelimitedTextBlockReader; -import org.onap.policy.apex.service.engine.event.impl.filecarrierplugin.consumer.TextBlock; - -/** - * The Class TestXmlTaggedEventConsumer. - */ -public class XmlTaggedEventConsumerTest { - - /** - * Test garbage text line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testGarbageTextLine() throws IOException { - verifyNull("testGarbageTextLine", "hello there"); - } - - /** - * Test partial event line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testPartialEventLine() throws IOException { - verifyNull("testPartialEventLine", "1469781869268</TestTimestamp></MainTag>"); - } - - /** - * Test full event line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventLine() throws IOException { - verifyLine("testFullEventLine", "<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>", - "<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>"); - } - - /** - * Test full event garbage before line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventGarbageBeforeLine() throws IOException { - verifyEnd("testFullEventGarbageBeforeLine", - "Garbage<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>"); - } - - /** - * Test full event garbage before after line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventGarbageBeforeAfterLine() throws IOException { - verifyEnd("testFullEventGarbageBeforeAfterLine", - "Garbage<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>Rubbish"); - } - - /** - * Test full event garbage after line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventGarbageAfterLine() throws IOException { - verifyLine("testFullEventGarbageAfterLine", - "<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>Rubbish", - "<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>Rubbish"); - } - - /** - * Test garbage text multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testGarbageTextMultiLine() throws IOException { - verifyEnd("testGarbageTextMultiLine", "hello\nthere"); - } - - /** - * Test partial event multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testPartialEventMultiLine() throws IOException { - verifyEnd("testPartialEventMultiLine", "1469781869268\n</TestTimestamp>\n</MainTag>"); - } - - /** - * Test full event multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventMultiLine() throws IOException { - verifyLine("testFullEventMultiLine", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\n\n", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>"); - } - - /** - * Test full event garbage before multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventGarbageBeforeMultiLine() throws IOException { - verifyLine("testFullEventGarbageBeforeMultiLine", - "Garbage\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\n\n", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>"); - } - - /** - * Test full event garbage before after multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventGarbageBeforeAfterMultiLine() throws IOException { - String garbageString = "Garbage\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>" - + "\n</MainTag>\nRubbish\n\n"; - - verifyLine("testFullEventsGarbageAfterLine", garbageString, - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRubbish"); - } - - /** - * Test full event garbage after multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventGarbageAfterMultiLine() throws IOException { - verifyLine("testFullEventGarbageAfterMultiLine", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRubbish", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRubbish"); - } - - /** - * Test partial events line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testPartialEventsLine() throws IOException { - verifyEnd("testPartialEventsLine", "1469781869268</TestTimestamp></MainTag><?xml><MainTag>" - + "<TestTimestamp>1469781869268</TestTimestamp>"); - } - - /** - * Test full events garbage before line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsGarbageBeforeLine() throws IOException { - verifyEnd("testPartialEventsLine", - "Garbage<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp></MainTag>" - + "<?xml><MainTag><TestTimestamp>"); - } - - /** - * Test full events garbage before after line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsGarbageBeforeAfterLine() throws IOException { - verifyEnd("testFullEventGarbageBeforeLine", "Garbage<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp>" - + "</MainTag>Rubbish<?xml><MainTag><TestTimestamp>\nRefuse"); - } - - /** - * Test full events garbage after line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsGarbageAfterLine() throws IOException { - String garbageString = "<?xml><MainTag><TestTimestamp>1469781869268</TestTimestamp>" - + "</MainTag>Rubbish<?xml><MainTag><TestTimestamp>Refuse"; - - verifyLine("testFullEventsGarbageAfterLine", garbageString, garbageString); - } - - /** - * Test partial events multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testPartialEventsMultiLine() throws IOException { - verifyLine("testPartialEventsMultiLine", - "1469781869268\n</TestTimestamp>\n</MainTag>\n<?xml>\n<MainTag>\n<TestTimestamp>", - "<?xml>\n<MainTag>\n<TestTimestamp>"); - } - - /** - * Test full events multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsMultiLine() throws IOException { - String garbageString = "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n" - + "</MainTag>\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\n"; - - verifyLines("testFullEventsMultiLine", garbageString, - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>"); - } - - /** - * Test full events garbage before multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsGarbageBeforeMultiLine() throws IOException { - String garbageString = "Garbage\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n" - + "</MainTag>\n\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\n"; - - verifyLines("testFullEventsGarbageBeforeMultiLine", garbageString, - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>"); - } - - /** - * Test full events garbage before after multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsGarbageBeforeAfterMultiLine() throws IOException { - String garbageString = "Garbage\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n" - + "</MainTag>\nRubbish\n<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n" - + "</MainTag>\nRefuse\n"; - - verifyLines("testFullEventsGarbageBeforeAfterMultiLine", garbageString, - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRubbish", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRefuse"); - } - - /** - * Test full events garbage after multi line. - * - * @throws IOException Signals that an I/O exception has occurred. - */ - @Test - public void testFullEventsGarbageAfterMultiLine() throws IOException { - verifyLine("testFullEventsGarbageAfterMultiLine", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRubbish", - "<?xml>\n<MainTag>\n<TestTimestamp>1469781869268</TestTimestamp>\n</MainTag>\nRubbish"); - } - - private void verifyNull(String testName, String xml) throws IOException { - final InputStream xmlInputStream = new ByteArrayInputStream(xml.getBytes()); - - final HeaderDelimitedTextBlockReader xmlTaggedReader = new HeaderDelimitedTextBlockReader("<?xml", null, true); - xmlTaggedReader.init(xmlInputStream); - - final TextBlock textBlock = xmlTaggedReader.readTextBlock(); - assertNull(testName, textBlock.getText()); - assertTrue(testName, textBlock.isEndOfText()); - } - - private void verifyLine(String testName, String xml, String expected) throws IOException { - final InputStream xmlInputStream = new ByteArrayInputStream(xml.getBytes()); - - final HeaderDelimitedTextBlockReader xmlTaggedReader = new HeaderDelimitedTextBlockReader("<?xml", null, true); - xmlTaggedReader.init(xmlInputStream); - - final TextBlock textBlock = xmlTaggedReader.readTextBlock(); - assertEquals(testName, expected, textBlock.getText()); - assertTrue(testName, textBlock.isEndOfText()); - } - - private void verifyLines(String testName, String xml, String expected, String expected2) throws IOException { - final InputStream xmlInputStream = new ByteArrayInputStream(xml.getBytes()); - - final HeaderDelimitedTextBlockReader xmlTaggedReader = new HeaderDelimitedTextBlockReader("<?xml", null, true); - xmlTaggedReader.init(xmlInputStream); - - TextBlock textBlock = xmlTaggedReader.readTextBlock(); - assertEquals(testName, expected, textBlock.getText()); - assertFalse(testName, textBlock.isEndOfText()); - - textBlock = xmlTaggedReader.readTextBlock(); - assertEquals(testName, expected2, textBlock.getText()); - assertTrue(testName, textBlock.isEndOfText()); - } - - private void verifyEnd(String testName, String xml) throws IOException { - final InputStream xmlInputStream = new ByteArrayInputStream(xml.getBytes()); - - final HeaderDelimitedTextBlockReader xmlTaggedReader = new HeaderDelimitedTextBlockReader("<?xml", null, true); - xmlTaggedReader.init(xmlInputStream); - - final TextBlock textBlock = xmlTaggedReader.readTextBlock(); - assertTrue(testName, textBlock.isEndOfText()); - } -} |