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 #include <stdio.h>
25*b1cdbd2cSJim Jagielski #include <osl/mutex.hxx>
26*b1cdbd2cSJim Jagielski #include <cppuhelper/factory.hxx>
27*b1cdbd2cSJim Jagielski
28*b1cdbd2cSJim Jagielski #include <com/sun/star/uno/XNamingService.hpp>
29*b1cdbd2cSJim Jagielski
30*b1cdbd2cSJim Jagielski #include <com/sun/star/registry/XImplementationRegistration.hpp>
31*b1cdbd2cSJim Jagielski
32*b1cdbd2cSJim Jagielski #include <com/sun/star/connection/XConnector.hpp>
33*b1cdbd2cSJim Jagielski
34*b1cdbd2cSJim Jagielski #include <com/sun/star/bridge/XUnoUrlResolver.hpp>
35*b1cdbd2cSJim Jagielski
36*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/XMain.hpp>
37*b1cdbd2cSJim Jagielski #include <com/sun/star/lang/XComponent.hpp>
38*b1cdbd2cSJim Jagielski
39*b1cdbd2cSJim Jagielski #include <com/sun/star/io/XOutputStream.hpp>
40*b1cdbd2cSJim Jagielski #include <com/sun/star/io/XInputStream.hpp>
41*b1cdbd2cSJim Jagielski
42*b1cdbd2cSJim Jagielski #include <cppuhelper/implbase1.hxx>
43*b1cdbd2cSJim Jagielski
44*b1cdbd2cSJim Jagielski using namespace ::rtl;
45*b1cdbd2cSJim Jagielski using namespace ::cppu;
46*b1cdbd2cSJim Jagielski using namespace ::osl;
47*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::uno;
48*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::lang;
49*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::registry;
50*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::connection;
51*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::bridge;
52*b1cdbd2cSJim Jagielski using namespace ::com::sun::star::io;
53*b1cdbd2cSJim Jagielski
54*b1cdbd2cSJim Jagielski
55*b1cdbd2cSJim Jagielski namespace remotebridges_officeclient {
56*b1cdbd2cSJim Jagielski
57*b1cdbd2cSJim Jagielski class PipeClientMain : public WeakImplHelper1< XMain >
58*b1cdbd2cSJim Jagielski {
59*b1cdbd2cSJim Jagielski public:
PipeClientMain(const Reference<XMultiServiceFactory> & r)60*b1cdbd2cSJim Jagielski PipeClientMain( const Reference< XMultiServiceFactory > &r ) :
61*b1cdbd2cSJim Jagielski m_xSMgr( r )
62*b1cdbd2cSJim Jagielski {}
63*b1cdbd2cSJim Jagielski public: // Methods
64*b1cdbd2cSJim Jagielski
65*b1cdbd2cSJim Jagielski
66*b1cdbd2cSJim Jagielski virtual sal_Int32 SAL_CALL run( const Sequence< OUString >& aArguments )
67*b1cdbd2cSJim Jagielski throw(RuntimeException);
68*b1cdbd2cSJim Jagielski
69*b1cdbd2cSJim Jagielski
70*b1cdbd2cSJim Jagielski private: // helper methods
71*b1cdbd2cSJim Jagielski void testPipe( const Reference < XInterface > & rComponent );
72*b1cdbd2cSJim Jagielski Reference< XMultiServiceFactory > m_xSMgr;
73*b1cdbd2cSJim Jagielski };
74*b1cdbd2cSJim Jagielski
testPipe(const Reference<XInterface> & rxInterface)75*b1cdbd2cSJim Jagielski void PipeClientMain::testPipe( const Reference< XInterface > & rxInterface )
76*b1cdbd2cSJim Jagielski {
77*b1cdbd2cSJim Jagielski // ask for the input stream
78*b1cdbd2cSJim Jagielski Reference< XInputStream > rInputStream( rxInterface, UNO_QUERY );
79*b1cdbd2cSJim Jagielski
80*b1cdbd2cSJim Jagielski // ask for the output stream
81*b1cdbd2cSJim Jagielski Reference< XOutputStream > rOutputStream( rxInterface, UNO_QUERY );
82*b1cdbd2cSJim Jagielski
83*b1cdbd2cSJim Jagielski if( rInputStream.is() && rOutputStream.is() )
84*b1cdbd2cSJim Jagielski {
85*b1cdbd2cSJim Jagielski printf( "got inputstream and outputstream from remote process\n" );
86*b1cdbd2cSJim Jagielski
87*b1cdbd2cSJim Jagielski sal_Int8 a[] = { 5,4,3,2,1,0 };
88*b1cdbd2cSJim Jagielski Sequence< sal_Int8 > seq( a , 6 );
89*b1cdbd2cSJim Jagielski rOutputStream->writeBytes( seq );
90*b1cdbd2cSJim Jagielski rOutputStream->closeOutput();
91*b1cdbd2cSJim Jagielski
92*b1cdbd2cSJim Jagielski Sequence< sal_Int8> seqRead;
93*b1cdbd2cSJim Jagielski if( rInputStream->readBytes( seqRead ,3 ) != 3 )
94*b1cdbd2cSJim Jagielski {
95*b1cdbd2cSJim Jagielski printf( "error : Couldn't read the expected number of bytes\n" );
96*b1cdbd2cSJim Jagielski return;
97*b1cdbd2cSJim Jagielski }
98*b1cdbd2cSJim Jagielski
99*b1cdbd2cSJim Jagielski if( seqRead.getConstArray()[0] != 5 ||
100*b1cdbd2cSJim Jagielski seqRead.getConstArray()[1] != 4 ||
101*b1cdbd2cSJim Jagielski seqRead.getConstArray()[2] != 3 )
102*b1cdbd2cSJim Jagielski {
103*b1cdbd2cSJim Jagielski printf( "error : The array doesn't contain the expected values\n" );
104*b1cdbd2cSJim Jagielski return;
105*b1cdbd2cSJim Jagielski }
106*b1cdbd2cSJim Jagielski
107*b1cdbd2cSJim Jagielski // try to read more bytes than written
108*b1cdbd2cSJim Jagielski if( rInputStream->readBytes( seqRead , 4 ) != 3 )
109*b1cdbd2cSJim Jagielski {
110*b1cdbd2cSJim Jagielski printf( "error : Got an unexpected number of bytes\n" );
111*b1cdbd2cSJim Jagielski return;
112*b1cdbd2cSJim Jagielski }
113*b1cdbd2cSJim Jagielski
114*b1cdbd2cSJim Jagielski if( seqRead.getConstArray()[0] != 2 ||
115*b1cdbd2cSJim Jagielski seqRead.getConstArray()[1] != 1 ||
116*b1cdbd2cSJim Jagielski seqRead.getConstArray()[2] != 0 )
117*b1cdbd2cSJim Jagielski {
118*b1cdbd2cSJim Jagielski printf( "error : The array doesn't contain the expected values\n" );
119*b1cdbd2cSJim Jagielski return;
120*b1cdbd2cSJim Jagielski }
121*b1cdbd2cSJim Jagielski
122*b1cdbd2cSJim Jagielski printf( "pipe test worked perfect\n" );
123*b1cdbd2cSJim Jagielski }
124*b1cdbd2cSJim Jagielski else
125*b1cdbd2cSJim Jagielski {
126*b1cdbd2cSJim Jagielski printf( "Couldn't get inputstream and outputstream\n" );
127*b1cdbd2cSJim Jagielski }
128*b1cdbd2cSJim Jagielski }
129*b1cdbd2cSJim Jagielski
130*b1cdbd2cSJim Jagielski
run(const Sequence<OUString> & aArguments)131*b1cdbd2cSJim Jagielski sal_Int32 PipeClientMain::run( const Sequence< OUString > & aArguments ) throw ( RuntimeException )
132*b1cdbd2cSJim Jagielski {
133*b1cdbd2cSJim Jagielski printf( "Connecting ....\n" );
134*b1cdbd2cSJim Jagielski
135*b1cdbd2cSJim Jagielski if( aArguments.getLength() == 1 )
136*b1cdbd2cSJim Jagielski {
137*b1cdbd2cSJim Jagielski try {
138*b1cdbd2cSJim Jagielski Reference < XInterface > r =
139*b1cdbd2cSJim Jagielski m_xSMgr->createInstance( OUString::createFromAscii( "com.sun.star.bridge.UnoUrlResolver" ) );
140*b1cdbd2cSJim Jagielski Reference < XUnoUrlResolver > rResolver( r , UNO_QUERY );
141*b1cdbd2cSJim Jagielski
142*b1cdbd2cSJim Jagielski // connect to the remote process and retrieve the initial object
143*b1cdbd2cSJim Jagielski r = rResolver->resolve( aArguments.getConstArray()[0] );
144*b1cdbd2cSJim Jagielski
145*b1cdbd2cSJim Jagielski if( r.is() )
146*b1cdbd2cSJim Jagielski {
147*b1cdbd2cSJim Jagielski printf( "got the remote initial object\n" );
148*b1cdbd2cSJim Jagielski testPipe( r );
149*b1cdbd2cSJim Jagielski }
150*b1cdbd2cSJim Jagielski else
151*b1cdbd2cSJim Jagielski {
152*b1cdbd2cSJim Jagielski printf( "error : didn't get the initial object\n" );
153*b1cdbd2cSJim Jagielski }
154*b1cdbd2cSJim Jagielski }
155*b1cdbd2cSJim Jagielski catch( ConnectionSetupException &e )
156*b1cdbd2cSJim Jagielski {
157*b1cdbd2cSJim Jagielski OString o = OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US );
158*b1cdbd2cSJim Jagielski printf( "%s\n", o.pData->buffer );
159*b1cdbd2cSJim Jagielski printf( "couldn't access local resource ( possible security resons )\n" );
160*b1cdbd2cSJim Jagielski }
161*b1cdbd2cSJim Jagielski catch( NoConnectException &e )
162*b1cdbd2cSJim Jagielski {
163*b1cdbd2cSJim Jagielski OString o = OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US );
164*b1cdbd2cSJim Jagielski printf( "%s\n", o.pData->buffer );
165*b1cdbd2cSJim Jagielski printf( "no server listening on the resource\n" );
166*b1cdbd2cSJim Jagielski }
167*b1cdbd2cSJim Jagielski catch( IllegalArgumentException &e )
168*b1cdbd2cSJim Jagielski {
169*b1cdbd2cSJim Jagielski OString o = OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US );
170*b1cdbd2cSJim Jagielski printf( "%s\n", o.pData->buffer );
171*b1cdbd2cSJim Jagielski printf( "uno url invalid\n" );
172*b1cdbd2cSJim Jagielski }
173*b1cdbd2cSJim Jagielski catch( RuntimeException & e )
174*b1cdbd2cSJim Jagielski {
175*b1cdbd2cSJim Jagielski OString o = OUStringToOString( e.Message, RTL_TEXTENCODING_ASCII_US );
176*b1cdbd2cSJim Jagielski printf( "%s\n", o.pData->buffer );
177*b1cdbd2cSJim Jagielski printf( "a remote call was aborted\n" );
178*b1cdbd2cSJim Jagielski }
179*b1cdbd2cSJim Jagielski }
180*b1cdbd2cSJim Jagielski else
181*b1cdbd2cSJim Jagielski {
182*b1cdbd2cSJim Jagielski printf( "usage: (uno remoteclient-component --) uno-url\n"
183*b1cdbd2cSJim Jagielski "e.g.: uno:socket,host=localhost,port=2083;urp;MyPipe\n" );
184*b1cdbd2cSJim Jagielski return 1;
185*b1cdbd2cSJim Jagielski }
186*b1cdbd2cSJim Jagielski return 0;
187*b1cdbd2cSJim Jagielski }
188*b1cdbd2cSJim Jagielski
CreateInstance(const Reference<XMultiServiceFactory> & r)189*b1cdbd2cSJim Jagielski Reference< XInterface > SAL_CALL CreateInstance( const Reference< XMultiServiceFactory > &r)
190*b1cdbd2cSJim Jagielski {
191*b1cdbd2cSJim Jagielski return Reference< XInterface > ( ( OWeakObject * ) new PipeClientMain(r) );
192*b1cdbd2cSJim Jagielski }
193*b1cdbd2cSJim Jagielski
getSupportedServiceNames()194*b1cdbd2cSJim Jagielski Sequence< OUString > getSupportedServiceNames()
195*b1cdbd2cSJim Jagielski {
196*b1cdbd2cSJim Jagielski static Sequence < OUString > *pNames = 0;
197*b1cdbd2cSJim Jagielski if( ! pNames )
198*b1cdbd2cSJim Jagielski {
199*b1cdbd2cSJim Jagielski MutexGuard guard( Mutex::getGlobalMutex() );
200*b1cdbd2cSJim Jagielski if( !pNames )
201*b1cdbd2cSJim Jagielski {
202*b1cdbd2cSJim Jagielski static Sequence< OUString > seqNames(1);
203*b1cdbd2cSJim Jagielski seqNames.getArray()[0] = OUString::createFromAscii( "com.sun.star.bridge.example.RemoteClientSample" );
204*b1cdbd2cSJim Jagielski pNames = &seqNames;
205*b1cdbd2cSJim Jagielski }
206*b1cdbd2cSJim Jagielski }
207*b1cdbd2cSJim Jagielski return *pNames;
208*b1cdbd2cSJim Jagielski }
209*b1cdbd2cSJim Jagielski
210*b1cdbd2cSJim Jagielski }
211*b1cdbd2cSJim Jagielski
212*b1cdbd2cSJim Jagielski using namespace remotebridges_officeclient;
213*b1cdbd2cSJim Jagielski #define IMPLEMENTATION_NAME "com.sun.star.comp.product.example.RemoteClientSample"
214*b1cdbd2cSJim Jagielski
215*b1cdbd2cSJim Jagielski
216*b1cdbd2cSJim Jagielski extern "C"
217*b1cdbd2cSJim Jagielski {
218*b1cdbd2cSJim Jagielski //==================================================================================================
component_getImplementationEnvironment(const sal_Char ** ppEnvTypeName,uno_Environment ** ppEnv)219*b1cdbd2cSJim Jagielski SAL_DLLPUBLIC_EXPORT void SAL_CALL component_getImplementationEnvironment(
220*b1cdbd2cSJim Jagielski const sal_Char ** ppEnvTypeName, uno_Environment ** ppEnv )
221*b1cdbd2cSJim Jagielski {
222*b1cdbd2cSJim Jagielski *ppEnvTypeName = CPPU_CURRENT_LANGUAGE_BINDING_NAME;
223*b1cdbd2cSJim Jagielski }
224*b1cdbd2cSJim Jagielski
225*b1cdbd2cSJim Jagielski //==================================================================================================
226*b1cdbd2cSJim Jagielski // SAL_DLLPUBLIC_EXPORT sal_Bool SAL_CALL component_writeInfo(
227*b1cdbd2cSJim Jagielski // void * pServiceManager, void * pRegistryKey )
228*b1cdbd2cSJim Jagielski // {
229*b1cdbd2cSJim Jagielski // if (pRegistryKey)
230*b1cdbd2cSJim Jagielski // {
231*b1cdbd2cSJim Jagielski // try
232*b1cdbd2cSJim Jagielski // {
233*b1cdbd2cSJim Jagielski // Reference< XRegistryKey > xNewKey(
234*b1cdbd2cSJim Jagielski // reinterpret_cast< XRegistryKey * >( pRegistryKey )->createKey(
235*b1cdbd2cSJim Jagielski // OUString::createFromAscii( "/" IMPLEMENTATION_NAME "/UNO/SERVICES" ) ) );
236*b1cdbd2cSJim Jagielski
237*b1cdbd2cSJim Jagielski // const Sequence< OUString > & rSNL = getSupportedServiceNames();
238*b1cdbd2cSJim Jagielski // const OUString * pArray = rSNL.getConstArray();
239*b1cdbd2cSJim Jagielski // for ( sal_Int32 nPos = rSNL.getLength(); nPos--; )
240*b1cdbd2cSJim Jagielski // xNewKey->createKey( pArray[nPos] );
241*b1cdbd2cSJim Jagielski
242*b1cdbd2cSJim Jagielski // return sal_True;
243*b1cdbd2cSJim Jagielski // }
244*b1cdbd2cSJim Jagielski // catch (InvalidRegistryException &)
245*b1cdbd2cSJim Jagielski // {
246*b1cdbd2cSJim Jagielski // OSL_ENSURE( sal_False, "### InvalidRegistryException!" );
247*b1cdbd2cSJim Jagielski // }
248*b1cdbd2cSJim Jagielski // }
249*b1cdbd2cSJim Jagielski // return sal_False;
250*b1cdbd2cSJim Jagielski // }
251*b1cdbd2cSJim Jagielski
252*b1cdbd2cSJim Jagielski //==================================================================================================
component_getFactory(const sal_Char * pImplName,void * pServiceManager,void * pRegistryKey)253*b1cdbd2cSJim Jagielski SAL_DLLPUBLIC_EXPORT void * SAL_CALL component_getFactory(
254*b1cdbd2cSJim Jagielski const sal_Char * pImplName, void * pServiceManager, void * pRegistryKey )
255*b1cdbd2cSJim Jagielski {
256*b1cdbd2cSJim Jagielski void * pRet = 0;
257*b1cdbd2cSJim Jagielski
258*b1cdbd2cSJim Jagielski if (pServiceManager && rtl_str_compare( pImplName, IMPLEMENTATION_NAME ) == 0)
259*b1cdbd2cSJim Jagielski {
260*b1cdbd2cSJim Jagielski Reference< XSingleServiceFactory > xFactory( createSingleFactory(
261*b1cdbd2cSJim Jagielski reinterpret_cast< XMultiServiceFactory * >( pServiceManager ),
262*b1cdbd2cSJim Jagielski OUString::createFromAscii( pImplName ),
263*b1cdbd2cSJim Jagielski CreateInstance, getSupportedServiceNames() ) );
264*b1cdbd2cSJim Jagielski
265*b1cdbd2cSJim Jagielski if (xFactory.is())
266*b1cdbd2cSJim Jagielski {
267*b1cdbd2cSJim Jagielski xFactory->acquire();
268*b1cdbd2cSJim Jagielski pRet = xFactory.get();
269*b1cdbd2cSJim Jagielski }
270*b1cdbd2cSJim Jagielski }
271*b1cdbd2cSJim Jagielski
272*b1cdbd2cSJim Jagielski return pRet;
273*b1cdbd2cSJim Jagielski }
274*b1cdbd2cSJim Jagielski }
275