1*ef39d40dSAndrew Rist /**************************************************************
2cdf0e10cSrcweir  *
3*ef39d40dSAndrew Rist  * Licensed to the Apache Software Foundation (ASF) under one
4*ef39d40dSAndrew Rist  * or more contributor license agreements.  See the NOTICE file
5*ef39d40dSAndrew Rist  * distributed with this work for additional information
6*ef39d40dSAndrew Rist  * regarding copyright ownership.  The ASF licenses this file
7*ef39d40dSAndrew Rist  * to you under the Apache License, Version 2.0 (the
8*ef39d40dSAndrew Rist  * "License"); you may not use this file except in compliance
9*ef39d40dSAndrew Rist  * with the License.  You may obtain a copy of the License at
10*ef39d40dSAndrew Rist  *
11*ef39d40dSAndrew Rist  *   http://www.apache.org/licenses/LICENSE-2.0
12*ef39d40dSAndrew Rist  *
13*ef39d40dSAndrew Rist  * Unless required by applicable law or agreed to in writing,
14*ef39d40dSAndrew Rist  * software distributed under the License is distributed on an
15*ef39d40dSAndrew Rist  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*ef39d40dSAndrew Rist  * KIND, either express or implied.  See the License for the
17*ef39d40dSAndrew Rist  * specific language governing permissions and limitations
18*ef39d40dSAndrew Rist  * under the License.
19*ef39d40dSAndrew Rist  *
20*ef39d40dSAndrew Rist  *************************************************************/
21*ef39d40dSAndrew Rist 
22*ef39d40dSAndrew Rist 
23cdf0e10cSrcweir 
24cdf0e10cSrcweir package mod._streams.uno;
25cdf0e10cSrcweir 
26cdf0e10cSrcweir import com.sun.star.io.XActiveDataSink;
27cdf0e10cSrcweir import com.sun.star.io.XActiveDataSource;
28cdf0e10cSrcweir import com.sun.star.io.XInputStream;
29cdf0e10cSrcweir import com.sun.star.io.XOutputStream;
30cdf0e10cSrcweir import com.sun.star.lang.XMultiServiceFactory;
31cdf0e10cSrcweir import com.sun.star.uno.UnoRuntime;
32cdf0e10cSrcweir import com.sun.star.uno.XInterface;
33cdf0e10cSrcweir import java.io.PrintWriter;
34cdf0e10cSrcweir import java.util.Vector;
35cdf0e10cSrcweir import lib.StatusException;
36cdf0e10cSrcweir import lib.TestCase;
37cdf0e10cSrcweir import lib.TestEnvironment;
38cdf0e10cSrcweir import lib.TestParameters;
39cdf0e10cSrcweir 
40cdf0e10cSrcweir /**
41cdf0e10cSrcweir * Test for object which is represented by service
42cdf0e10cSrcweir * <code>com.sun.star.io.DataOutputStream</code>. <p>
43cdf0e10cSrcweir * Object implements the following interfaces :
44cdf0e10cSrcweir * <ul>
45cdf0e10cSrcweir *  <li> <code>com::sun::star::io::XActiveDataSource</code></li>
46cdf0e10cSrcweir *  <li> <code>com::sun::star::io::XOutputStream</code></li>
47cdf0e10cSrcweir *  <li> <code>com::sun::star::io::XDataOutputStream</code></li>
48cdf0e10cSrcweir * </ul>
49cdf0e10cSrcweir * @see com.sun.star.io.DataOutputStream
50cdf0e10cSrcweir * @see com.sun.star.io.XActiveDataSource
51cdf0e10cSrcweir * @see com.sun.star.io.XOutputStream
52cdf0e10cSrcweir * @see com.sun.star.io.XDataOutputStream
53cdf0e10cSrcweir * @see ifc.io._XActiveDataSource
54cdf0e10cSrcweir * @see ifc.io._XOutputStream
55cdf0e10cSrcweir * @see ifc.io._XDataOutputStream
56cdf0e10cSrcweir */
57cdf0e10cSrcweir public class DataOutputStream extends TestCase {
58cdf0e10cSrcweir 
59cdf0e10cSrcweir     /**
60cdf0e10cSrcweir     * Creating a Testenvironment for the interfaces to be tested.
61cdf0e10cSrcweir     * Creates an instance of the service
62cdf0e10cSrcweir     * <code>com.sun.star.io.DataOutputStream</code>
63cdf0e10cSrcweir     * and an instance of the service <code>com.sun.star.io.Pipe</code>.
64cdf0e10cSrcweir     * Plugs the created pipe as output stream for the created DataOutputStream.
65cdf0e10cSrcweir     * @see com.sun.star.io.DataOutputStream
66cdf0e10cSrcweir     * Object relations created :
67cdf0e10cSrcweir     * <ul>
68cdf0e10cSrcweir     *  <li> <code>'StreamData'</code> for
69cdf0e10cSrcweir     *      {@link ifc.io._XDataInputStream}(the data that should be written into
70cdf0e10cSrcweir     *      the stream) </li>
71cdf0e10cSrcweir     *  <li> <code>'ByteData'</code> for
72cdf0e10cSrcweir     *      {@link ifc.io._XInputStream}(the data that should be written into
73cdf0e10cSrcweir     *      the stream) </li>
74cdf0e10cSrcweir     *  <li> <code>'OutputStream'</code> for
75cdf0e10cSrcweir     *      {@link ifc.io._XActiveDataSource}
76cdf0e10cSrcweir     *      (an input stream to set and get) </li>
77cdf0e10cSrcweir     *  <li> <code>'XOutputStream.StreamChecker'</code> for
78cdf0e10cSrcweir     *      {@link ifc.io._XOutputStream}( implementation of the interface
79cdf0e10cSrcweir     *      ifc.io._XOutputStream.StreamChecker ) </li>
80cdf0e10cSrcweir     * </ul>
81cdf0e10cSrcweir     */
createTestEnvironment(TestParameters Param, PrintWriter log)82cdf0e10cSrcweir     protected TestEnvironment createTestEnvironment(TestParameters Param, PrintWriter log) {
83cdf0e10cSrcweir 
84cdf0e10cSrcweir         XInterface oObj = null;
85cdf0e10cSrcweir         Object oInterface = null;
86cdf0e10cSrcweir         XInterface oPipe = null;
87cdf0e10cSrcweir         XMultiServiceFactory xMSF = null ;
88cdf0e10cSrcweir 
89cdf0e10cSrcweir         try {
90cdf0e10cSrcweir             xMSF = (XMultiServiceFactory)Param.getMSF();
91cdf0e10cSrcweir             oInterface = xMSF.createInstance
92cdf0e10cSrcweir                 ("com.sun.star.io.DataOutputStream");
93cdf0e10cSrcweir             oPipe = (XInterface)xMSF.createInstance("com.sun.star.io.Pipe");
94cdf0e10cSrcweir         } catch(com.sun.star.uno.Exception e) {
95cdf0e10cSrcweir             e.printStackTrace(log);
96cdf0e10cSrcweir             throw new StatusException("Couldn't create instance", e);
97cdf0e10cSrcweir         }
98cdf0e10cSrcweir 
99cdf0e10cSrcweir         oObj = (XInterface) oInterface;
100cdf0e10cSrcweir 
101cdf0e10cSrcweir         final XOutputStream xPipeOutput = (XOutputStream)
102cdf0e10cSrcweir             UnoRuntime.queryInterface(XOutputStream.class, oPipe);
103cdf0e10cSrcweir 
104cdf0e10cSrcweir         XActiveDataSource xDataSource = (XActiveDataSource)
105cdf0e10cSrcweir             UnoRuntime.queryInterface(XActiveDataSource.class, oObj);
106cdf0e10cSrcweir 
107cdf0e10cSrcweir         xDataSource.setOutputStream(xPipeOutput);
108cdf0e10cSrcweir 
109cdf0e10cSrcweir         // all data types for writing to an XDataInputStream
110cdf0e10cSrcweir         Vector data = new Vector() ;
111cdf0e10cSrcweir         data.add(new Boolean(true)) ;
112cdf0e10cSrcweir         data.add(new Byte((byte)123)) ;
113cdf0e10cSrcweir         data.add(new Character((char)1234)) ;
114cdf0e10cSrcweir         data.add(new Short((short)1234)) ;
115cdf0e10cSrcweir         data.add(new Integer(123456)) ;
116cdf0e10cSrcweir         data.add(new Float(1.234)) ;
117cdf0e10cSrcweir         data.add(new Double(1.23456)) ;
118cdf0e10cSrcweir         data.add("DataInputStream") ;
119cdf0e10cSrcweir         // information for writing to the pipe
120cdf0e10cSrcweir         byte[] byteData = new byte[] {
121cdf0e10cSrcweir             1, 2, 3, 4, 5, 6, 7, 8 } ;
122cdf0e10cSrcweir 
123cdf0e10cSrcweir         log.println("creating a new environment for object");
124cdf0e10cSrcweir         TestEnvironment tEnv = new TestEnvironment( oObj );
125cdf0e10cSrcweir 
126cdf0e10cSrcweir         tEnv.addObjRelation("StreamData", data);
127cdf0e10cSrcweir         tEnv.addObjRelation("ByteData", byteData);
128cdf0e10cSrcweir         tEnv.addObjRelation("OutputStream", oPipe);
129cdf0e10cSrcweir 
130cdf0e10cSrcweir         //add relation for io.XOutputStream
131cdf0e10cSrcweir         final XMultiServiceFactory msf = xMSF;
132cdf0e10cSrcweir         final XInputStream xPipeInput = (XInputStream)
133cdf0e10cSrcweir             UnoRuntime.queryInterface(XInputStream.class, oPipe);
134cdf0e10cSrcweir         tEnv.addObjRelation("XOutputStream.StreamChecker",
135cdf0e10cSrcweir             new ifc.io._XOutputStream.StreamChecker() {
136cdf0e10cSrcweir                 XInputStream xInStream = null;
137cdf0e10cSrcweir                 public void resetStreams() {
138cdf0e10cSrcweir                     if (xInStream != null) {
139cdf0e10cSrcweir                         try {
140cdf0e10cSrcweir                             xInStream.closeInput();
141cdf0e10cSrcweir                             xInStream = null;
142cdf0e10cSrcweir                         } catch(com.sun.star.io.IOException e) {
143cdf0e10cSrcweir                         }
144cdf0e10cSrcweir                     } else {
145cdf0e10cSrcweir                         try {
146cdf0e10cSrcweir                             xPipeOutput.closeOutput();
147cdf0e10cSrcweir                         } catch(com.sun.star.io.IOException e) {
148cdf0e10cSrcweir                         }
149cdf0e10cSrcweir                     }
150cdf0e10cSrcweir                 }
151cdf0e10cSrcweir 
152cdf0e10cSrcweir                 public XInputStream getInStream() {
153cdf0e10cSrcweir                     resetStreams();
154cdf0e10cSrcweir                     try {
155cdf0e10cSrcweir                         Object oInStream = msf.createInstance(
156cdf0e10cSrcweir                             "com.sun.star.io.DataInputStream");
157cdf0e10cSrcweir                         xInStream = (XInputStream) UnoRuntime.queryInterface
158cdf0e10cSrcweir                             (XInputStream.class, oInStream);
159cdf0e10cSrcweir                     } catch(com.sun.star.uno.Exception e) {
160cdf0e10cSrcweir                         return null;
161cdf0e10cSrcweir                     }
162cdf0e10cSrcweir 
163cdf0e10cSrcweir                     XActiveDataSink xDataSink = (XActiveDataSink)
164cdf0e10cSrcweir                         UnoRuntime.queryInterface(
165cdf0e10cSrcweir                             XActiveDataSink.class, xInStream);
166cdf0e10cSrcweir                     xDataSink.setInputStream(xPipeInput);
167cdf0e10cSrcweir 
168cdf0e10cSrcweir                     return xInStream;
169cdf0e10cSrcweir                 }
170cdf0e10cSrcweir             });
171cdf0e10cSrcweir 
172cdf0e10cSrcweir         return tEnv;
173cdf0e10cSrcweir     } // finish method getTestEnvironment
174cdf0e10cSrcweir }
175cdf0e10cSrcweir 
176