1*cdf0e10cSrcweir /************************************************************************* 2*cdf0e10cSrcweir * 3*cdf0e10cSrcweir * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4*cdf0e10cSrcweir * 5*cdf0e10cSrcweir * Copyright 2000, 2010 Oracle and/or its affiliates. 6*cdf0e10cSrcweir * 7*cdf0e10cSrcweir * OpenOffice.org - a multi-platform office productivity suite 8*cdf0e10cSrcweir * 9*cdf0e10cSrcweir * This file is part of OpenOffice.org. 10*cdf0e10cSrcweir * 11*cdf0e10cSrcweir * OpenOffice.org is free software: you can redistribute it and/or modify 12*cdf0e10cSrcweir * it under the terms of the GNU Lesser General Public License version 3 13*cdf0e10cSrcweir * only, as published by the Free Software Foundation. 14*cdf0e10cSrcweir * 15*cdf0e10cSrcweir * OpenOffice.org is distributed in the hope that it will be useful, 16*cdf0e10cSrcweir * but WITHOUT ANY WARRANTY; without even the implied warranty of 17*cdf0e10cSrcweir * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 18*cdf0e10cSrcweir * GNU Lesser General Public License version 3 for more details 19*cdf0e10cSrcweir * (a copy is included in the LICENSE file that accompanied this code). 20*cdf0e10cSrcweir * 21*cdf0e10cSrcweir * You should have received a copy of the GNU Lesser General Public License 22*cdf0e10cSrcweir * version 3 along with OpenOffice.org. If not, see 23*cdf0e10cSrcweir * <http://www.openoffice.org/license.html> 24*cdf0e10cSrcweir * for a copy of the LGPLv3 License. 25*cdf0e10cSrcweir * 26*cdf0e10cSrcweir ************************************************************************/ 27*cdf0e10cSrcweir 28*cdf0e10cSrcweir package mod._streams.uno; 29*cdf0e10cSrcweir 30*cdf0e10cSrcweir import com.sun.star.io.XActiveDataSink; 31*cdf0e10cSrcweir import com.sun.star.io.XActiveDataSource; 32*cdf0e10cSrcweir import com.sun.star.io.XInputStream; 33*cdf0e10cSrcweir import com.sun.star.io.XOutputStream; 34*cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory; 35*cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime; 36*cdf0e10cSrcweir import com.sun.star.uno.XInterface; 37*cdf0e10cSrcweir import java.io.PrintWriter; 38*cdf0e10cSrcweir import java.util.Vector; 39*cdf0e10cSrcweir import lib.StatusException; 40*cdf0e10cSrcweir import lib.TestCase; 41*cdf0e10cSrcweir import lib.TestEnvironment; 42*cdf0e10cSrcweir import lib.TestParameters; 43*cdf0e10cSrcweir 44*cdf0e10cSrcweir /** 45*cdf0e10cSrcweir * Test for object which is represented by service 46*cdf0e10cSrcweir * <code>com.sun.star.io.MarkableOutputStream</code>. <p> 47*cdf0e10cSrcweir * Object implements the following interfaces : 48*cdf0e10cSrcweir * <ul> 49*cdf0e10cSrcweir * <li> <code>com::sun::star::io::XMarkableStream</code></li> 50*cdf0e10cSrcweir * <li> <code>com::sun::star::io::XActiveDataSource</code></li> 51*cdf0e10cSrcweir * <li> <code>com::sun::star::io::XOutputStream</code></li> 52*cdf0e10cSrcweir * <li> <code>com::sun::star::io::XConnectable</code></li> 53*cdf0e10cSrcweir * </ul> 54*cdf0e10cSrcweir * @see com.sun.star.io.MarkableOutputStream 55*cdf0e10cSrcweir * @see com.sun.star.io.XMarkableStream 56*cdf0e10cSrcweir * @see com.sun.star.io.XActiveDataSource 57*cdf0e10cSrcweir * @see com.sun.star.io.XOutputStream 58*cdf0e10cSrcweir * @see com.sun.star.io.XConnectable 59*cdf0e10cSrcweir * @see ifc.io._XMarkableStream 60*cdf0e10cSrcweir * @see ifc.io._XActiveDataSource 61*cdf0e10cSrcweir * @see ifc.io._XOutputStream 62*cdf0e10cSrcweir * @see ifc.io._XConnectable 63*cdf0e10cSrcweir */ 64*cdf0e10cSrcweir public class MarkableOutputStream extends TestCase { 65*cdf0e10cSrcweir 66*cdf0e10cSrcweir /** 67*cdf0e10cSrcweir * Creating a Testenvironment for the interfaces to be tested. 68*cdf0e10cSrcweir * Creates an instances of services <code>com.sun.star.io.Pipe</code>, 69*cdf0e10cSrcweir * <code>com.sun.star.io.MarkableInputStream</code> and 70*cdf0e10cSrcweir * <code>com.sun.star.io.MarkableOutputStream</code>. 71*cdf0e10cSrcweir * Plugs the created pipe as output stream for the created 72*cdf0e10cSrcweir * <code>MarkableOutputStream</code>. Plugs the created pipe as input stream 73*cdf0e10cSrcweir * for the created <code>MarkableInputStream</code>. 74*cdf0e10cSrcweir * Object relations created : 75*cdf0e10cSrcweir * <ul> 76*cdf0e10cSrcweir * <li> <code>'ByteData'</code> for 77*cdf0e10cSrcweir * {@link ifc.io._XOutputStream}(the data that should be written into 78*cdf0e10cSrcweir * the stream) </li> 79*cdf0e10cSrcweir * <li> <code>'StreamData'</code> for 80*cdf0e10cSrcweir * {@link ifc.io._XDataOutputStream}(the data that should be 81*cdf0e10cSrcweir * written into the stream) </li> 82*cdf0e10cSrcweir * <li> <code>'Connectable'</code> for 83*cdf0e10cSrcweir * {@link ifc.io._XConnectable} 84*cdf0e10cSrcweir * (another object that can be connected) </li> 85*cdf0e10cSrcweir * <li> <code>'OutputStream'</code> for 86*cdf0e10cSrcweir * {@link ifc.io._XActiveDataSource} 87*cdf0e10cSrcweir * (an input stream to set and get) </li> 88*cdf0e10cSrcweir * <li> <code>'XOutputStream.StreamChecker'</code> for 89*cdf0e10cSrcweir * {@link ifc.io._XOutputStream}( implementation of the interface 90*cdf0e10cSrcweir * ifc.io._XOutputStream.StreamChecker ) </li> 91*cdf0e10cSrcweir * </ul> 92*cdf0e10cSrcweir * @see com.sun.star.io.Pipe 93*cdf0e10cSrcweir * @see com.sun.star.io.MarkableInputStream 94*cdf0e10cSrcweir * @see com.sun.star.io.MarkableOutputStream 95*cdf0e10cSrcweir */ 96*cdf0e10cSrcweir protected TestEnvironment createTestEnvironment(TestParameters Param, PrintWriter log) { 97*cdf0e10cSrcweir 98*cdf0e10cSrcweir XInterface oObj = null; 99*cdf0e10cSrcweir 100*cdf0e10cSrcweir XMultiServiceFactory xMSF = (XMultiServiceFactory)Param.getMSF(); 101*cdf0e10cSrcweir Object aPipe = null; 102*cdf0e10cSrcweir Object mostream = null; 103*cdf0e10cSrcweir Object mistream = null; 104*cdf0e10cSrcweir XInterface aConnect; 105*cdf0e10cSrcweir 106*cdf0e10cSrcweir try { 107*cdf0e10cSrcweir aPipe = xMSF.createInstance("com.sun.star.io.Pipe"); 108*cdf0e10cSrcweir mistream = xMSF.createInstance 109*cdf0e10cSrcweir ("com.sun.star.io.MarkableInputStream"); 110*cdf0e10cSrcweir mostream = xMSF.createInstance 111*cdf0e10cSrcweir ("com.sun.star.io.MarkableOutputStream"); 112*cdf0e10cSrcweir aConnect = (XInterface)xMSF.createInstance 113*cdf0e10cSrcweir ("com.sun.star.io.DataOutputStream"); 114*cdf0e10cSrcweir } catch(com.sun.star.uno.Exception e) { 115*cdf0e10cSrcweir e.printStackTrace(log); 116*cdf0e10cSrcweir throw new StatusException("Couldn't create instance", e) ; 117*cdf0e10cSrcweir } 118*cdf0e10cSrcweir 119*cdf0e10cSrcweir // Creating construction : 120*cdf0e10cSrcweir // MarkableOutputStream -> Pipe -> MarkableInputStream 121*cdf0e10cSrcweir XActiveDataSource xdSmo = (XActiveDataSource) 122*cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSource.class, mostream); 123*cdf0e10cSrcweir 124*cdf0e10cSrcweir final XOutputStream PipeOut = (XOutputStream) 125*cdf0e10cSrcweir UnoRuntime.queryInterface(XOutputStream.class,aPipe); 126*cdf0e10cSrcweir final XInputStream PipeIn = (XInputStream) 127*cdf0e10cSrcweir UnoRuntime.queryInterface(XInputStream.class,aPipe); 128*cdf0e10cSrcweir 129*cdf0e10cSrcweir xdSmo.setOutputStream(PipeOut); 130*cdf0e10cSrcweir 131*cdf0e10cSrcweir XActiveDataSink xmSi = (XActiveDataSink) 132*cdf0e10cSrcweir UnoRuntime.queryInterface(XActiveDataSink.class, mistream); 133*cdf0e10cSrcweir 134*cdf0e10cSrcweir xmSi.setInputStream(PipeIn) ; 135*cdf0e10cSrcweir 136*cdf0e10cSrcweir oObj = (XInterface) mostream; 137*cdf0e10cSrcweir 138*cdf0e10cSrcweir // all data types for writing to an XDataInputStream 139*cdf0e10cSrcweir Vector data = new Vector() ; 140*cdf0e10cSrcweir data.add(new Boolean(true)) ; 141*cdf0e10cSrcweir data.add(new Byte((byte)123)) ; 142*cdf0e10cSrcweir data.add(new Character((char)1234)) ; 143*cdf0e10cSrcweir data.add(new Short((short)1234)) ; 144*cdf0e10cSrcweir data.add(new Integer(123456)) ; 145*cdf0e10cSrcweir data.add(new Float(1.234)) ; 146*cdf0e10cSrcweir data.add(new Double(1.23456)) ; 147*cdf0e10cSrcweir data.add("DataInputStream") ; 148*cdf0e10cSrcweir // information for writing to the pipe 149*cdf0e10cSrcweir byte[] byteData = new byte[] { 150*cdf0e10cSrcweir 1, 2, 3, 4, 5, 6, 7, 8 } ; 151*cdf0e10cSrcweir 152*cdf0e10cSrcweir log.println( "creating a new environment for object" ); 153*cdf0e10cSrcweir TestEnvironment tEnv = new TestEnvironment( oObj ); 154*cdf0e10cSrcweir 155*cdf0e10cSrcweir tEnv.addObjRelation("StreamData", data); 156*cdf0e10cSrcweir tEnv.addObjRelation("ByteData", byteData); 157*cdf0e10cSrcweir tEnv.addObjRelation("OutputStream", aPipe); 158*cdf0e10cSrcweir tEnv.addObjRelation("Connectable", aConnect); 159*cdf0e10cSrcweir 160*cdf0e10cSrcweir //add relation for io.XOutputStream 161*cdf0e10cSrcweir final XMultiServiceFactory msf = xMSF; 162*cdf0e10cSrcweir tEnv.addObjRelation("XOutputStream.StreamChecker", 163*cdf0e10cSrcweir new ifc.io._XOutputStream.StreamChecker() { 164*cdf0e10cSrcweir XInputStream xInStream = null; 165*cdf0e10cSrcweir public void resetStreams() { 166*cdf0e10cSrcweir if (xInStream != null) { 167*cdf0e10cSrcweir try { 168*cdf0e10cSrcweir xInStream.closeInput(); 169*cdf0e10cSrcweir xInStream = null; 170*cdf0e10cSrcweir } catch(com.sun.star.io.IOException e) { 171*cdf0e10cSrcweir } 172*cdf0e10cSrcweir } else { 173*cdf0e10cSrcweir try { 174*cdf0e10cSrcweir PipeOut.closeOutput(); 175*cdf0e10cSrcweir } catch(com.sun.star.io.IOException e) { 176*cdf0e10cSrcweir } 177*cdf0e10cSrcweir } 178*cdf0e10cSrcweir } 179*cdf0e10cSrcweir 180*cdf0e10cSrcweir public XInputStream getInStream() { 181*cdf0e10cSrcweir resetStreams(); 182*cdf0e10cSrcweir try { 183*cdf0e10cSrcweir Object oInStream = msf.createInstance( 184*cdf0e10cSrcweir "com.sun.star.io.MarkableInputStream"); 185*cdf0e10cSrcweir xInStream = (XInputStream) UnoRuntime.queryInterface 186*cdf0e10cSrcweir (XInputStream.class, oInStream); 187*cdf0e10cSrcweir } catch(com.sun.star.uno.Exception e) { 188*cdf0e10cSrcweir return null; 189*cdf0e10cSrcweir } 190*cdf0e10cSrcweir 191*cdf0e10cSrcweir XActiveDataSink xDataSink = (XActiveDataSink) 192*cdf0e10cSrcweir UnoRuntime.queryInterface( 193*cdf0e10cSrcweir XActiveDataSink.class, xInStream); 194*cdf0e10cSrcweir xDataSink.setInputStream(PipeIn); 195*cdf0e10cSrcweir 196*cdf0e10cSrcweir return xInStream; 197*cdf0e10cSrcweir } 198*cdf0e10cSrcweir }); 199*cdf0e10cSrcweir 200*cdf0e10cSrcweir return tEnv; 201*cdf0e10cSrcweir } // finish method getTestEnvironment 202*cdf0e10cSrcweir 203*cdf0e10cSrcweir } 204*cdf0e10cSrcweir 205