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