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 // MARKER(update_precomp.py): autogen include statement, do not remove
23*b1cdbd2cSJim Jagielski #include "precompiled_ucb.hxx"
24*b1cdbd2cSJim Jagielski
25*b1cdbd2cSJim Jagielski #include "SerfPropFindReqProcImpl.hxx"
26*b1cdbd2cSJim Jagielski #include "SerfTypes.hxx"
27*b1cdbd2cSJim Jagielski #include "DAVProperties.hxx"
28*b1cdbd2cSJim Jagielski
29*b1cdbd2cSJim Jagielski #include "webdavresponseparser.hxx"
30*b1cdbd2cSJim Jagielski #include <comphelper/seqstream.hxx>
31*b1cdbd2cSJim Jagielski #include <rtl/ustrbuf.hxx>
32*b1cdbd2cSJim Jagielski
33*b1cdbd2cSJim Jagielski
34*b1cdbd2cSJim Jagielski using namespace com::sun::star;
35*b1cdbd2cSJim Jagielski
36*b1cdbd2cSJim Jagielski namespace http_dav_ucp
37*b1cdbd2cSJim Jagielski {
38*b1cdbd2cSJim Jagielski
SerfPropFindReqProcImpl(const char * inPath,const DAVRequestHeaders & inRequestHeaders,const Depth inDepth,const std::vector<::rtl::OUString> & inPropNames,std::vector<DAVResource> & ioResources)39*b1cdbd2cSJim Jagielski SerfPropFindReqProcImpl::SerfPropFindReqProcImpl( const char* inPath,
40*b1cdbd2cSJim Jagielski const DAVRequestHeaders& inRequestHeaders,
41*b1cdbd2cSJim Jagielski const Depth inDepth,
42*b1cdbd2cSJim Jagielski const std::vector< ::rtl::OUString > & inPropNames,
43*b1cdbd2cSJim Jagielski std::vector< DAVResource > & ioResources )
44*b1cdbd2cSJim Jagielski : SerfRequestProcessorImpl( inPath, inRequestHeaders )
45*b1cdbd2cSJim Jagielski , mDepthStr( 0 )
46*b1cdbd2cSJim Jagielski , mpPropNames( &inPropNames )
47*b1cdbd2cSJim Jagielski , mpResources( &ioResources )
48*b1cdbd2cSJim Jagielski , mpResInfo( 0 )
49*b1cdbd2cSJim Jagielski , mbOnlyPropertyNames( false )
50*b1cdbd2cSJim Jagielski , xInputStream( new SerfInputStream() )
51*b1cdbd2cSJim Jagielski {
52*b1cdbd2cSJim Jagielski init( inDepth );
53*b1cdbd2cSJim Jagielski }
54*b1cdbd2cSJim Jagielski
SerfPropFindReqProcImpl(const char * inPath,const DAVRequestHeaders & inRequestHeaders,const Depth inDepth,std::vector<DAVResourceInfo> & ioResInfo)55*b1cdbd2cSJim Jagielski SerfPropFindReqProcImpl::SerfPropFindReqProcImpl( const char* inPath,
56*b1cdbd2cSJim Jagielski const DAVRequestHeaders& inRequestHeaders,
57*b1cdbd2cSJim Jagielski const Depth inDepth,
58*b1cdbd2cSJim Jagielski std::vector< DAVResourceInfo > & ioResInfo )
59*b1cdbd2cSJim Jagielski : SerfRequestProcessorImpl( inPath, inRequestHeaders )
60*b1cdbd2cSJim Jagielski , mDepthStr( 0 )
61*b1cdbd2cSJim Jagielski , mpPropNames( 0 )
62*b1cdbd2cSJim Jagielski , mpResources( 0 )
63*b1cdbd2cSJim Jagielski , mpResInfo( &ioResInfo )
64*b1cdbd2cSJim Jagielski , mbOnlyPropertyNames( true )
65*b1cdbd2cSJim Jagielski , xInputStream( new SerfInputStream() )
66*b1cdbd2cSJim Jagielski {
67*b1cdbd2cSJim Jagielski init( inDepth );
68*b1cdbd2cSJim Jagielski }
69*b1cdbd2cSJim Jagielski
init(const Depth inDepth)70*b1cdbd2cSJim Jagielski void SerfPropFindReqProcImpl::init( const Depth inDepth )
71*b1cdbd2cSJim Jagielski {
72*b1cdbd2cSJim Jagielski switch ( inDepth )
73*b1cdbd2cSJim Jagielski {
74*b1cdbd2cSJim Jagielski case DAVZERO:
75*b1cdbd2cSJim Jagielski mDepthStr = "0";
76*b1cdbd2cSJim Jagielski break;
77*b1cdbd2cSJim Jagielski case DAVONE:
78*b1cdbd2cSJim Jagielski mDepthStr = "1";
79*b1cdbd2cSJim Jagielski break;
80*b1cdbd2cSJim Jagielski case DAVINFINITY:
81*b1cdbd2cSJim Jagielski mDepthStr = "infinity";
82*b1cdbd2cSJim Jagielski break;
83*b1cdbd2cSJim Jagielski }
84*b1cdbd2cSJim Jagielski }
85*b1cdbd2cSJim Jagielski
~SerfPropFindReqProcImpl()86*b1cdbd2cSJim Jagielski SerfPropFindReqProcImpl::~SerfPropFindReqProcImpl()
87*b1cdbd2cSJim Jagielski {
88*b1cdbd2cSJim Jagielski }
89*b1cdbd2cSJim Jagielski
90*b1cdbd2cSJim Jagielski #define PROPFIND_HEADER "<?xml version=\"1.0\" encoding=\"utf-8\"?><propfind xmlns=\"DAV:\">"
91*b1cdbd2cSJim Jagielski #define PROPFIND_TRAILER "</propfind>"
92*b1cdbd2cSJim Jagielski
createSerfRequestBucket(serf_request_t * inSerfRequest)93*b1cdbd2cSJim Jagielski serf_bucket_t * SerfPropFindReqProcImpl::createSerfRequestBucket( serf_request_t * inSerfRequest )
94*b1cdbd2cSJim Jagielski {
95*b1cdbd2cSJim Jagielski serf_bucket_alloc_t* pSerfBucketAlloc = serf_request_get_alloc( inSerfRequest );
96*b1cdbd2cSJim Jagielski
97*b1cdbd2cSJim Jagielski // body bucket - certain properties OR all properties OR only property names
98*b1cdbd2cSJim Jagielski serf_bucket_t* body_bkt = 0;
99*b1cdbd2cSJim Jagielski rtl::OString aBodyText;
100*b1cdbd2cSJim Jagielski {
101*b1cdbd2cSJim Jagielski // TODO is it really needed a Unicode string buffer?
102*b1cdbd2cSJim Jagielski // All properties and property names aren't supposed to be ASCII?
103*b1cdbd2cSJim Jagielski rtl::OUStringBuffer aBuffer;
104*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( PROPFIND_HEADER ));
105*b1cdbd2cSJim Jagielski
106*b1cdbd2cSJim Jagielski // create and fill body bucket with requested properties
107*b1cdbd2cSJim Jagielski const int nPropCount = ( !mbOnlyPropertyNames && mpPropNames )
108*b1cdbd2cSJim Jagielski ? mpPropNames->size()
109*b1cdbd2cSJim Jagielski : 0;
110*b1cdbd2cSJim Jagielski if ( nPropCount > 0 )
111*b1cdbd2cSJim Jagielski {
112*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "<prop>" ) );
113*b1cdbd2cSJim Jagielski SerfPropName thePropName;
114*b1cdbd2cSJim Jagielski for ( int theIndex = 0; theIndex < nPropCount; theIndex ++ )
115*b1cdbd2cSJim Jagielski {
116*b1cdbd2cSJim Jagielski // split fullname into namespace and name!
117*b1cdbd2cSJim Jagielski DAVProperties::createSerfPropName( (*mpPropNames)[ theIndex ],
118*b1cdbd2cSJim Jagielski thePropName );
119*b1cdbd2cSJim Jagielski
120*b1cdbd2cSJim Jagielski /* <*propname* xmlns="*propns*" /> */
121*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "<" ));
122*b1cdbd2cSJim Jagielski aBuffer.appendAscii( thePropName.name );
123*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( " xmlnx=\"" ));
124*b1cdbd2cSJim Jagielski aBuffer.appendAscii( thePropName.nspace );
125*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "\"/>" ));
126*b1cdbd2cSJim Jagielski }
127*b1cdbd2cSJim Jagielski
128*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "</prop>" ));
129*b1cdbd2cSJim Jagielski }
130*b1cdbd2cSJim Jagielski else
131*b1cdbd2cSJim Jagielski {
132*b1cdbd2cSJim Jagielski if ( mbOnlyPropertyNames )
133*b1cdbd2cSJim Jagielski {
134*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "<propname/>" ));
135*b1cdbd2cSJim Jagielski }
136*b1cdbd2cSJim Jagielski else
137*b1cdbd2cSJim Jagielski {
138*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "<allprop/>" ));
139*b1cdbd2cSJim Jagielski }
140*b1cdbd2cSJim Jagielski }
141*b1cdbd2cSJim Jagielski
142*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( PROPFIND_TRAILER ));
143*b1cdbd2cSJim Jagielski aBodyText = rtl::OUStringToOString( aBuffer.makeStringAndClear(), RTL_TEXTENCODING_UTF8 );
144*b1cdbd2cSJim Jagielski body_bkt = serf_bucket_simple_copy_create( aBodyText.getStr(),
145*b1cdbd2cSJim Jagielski aBodyText.getLength(),
146*b1cdbd2cSJim Jagielski pSerfBucketAlloc );
147*b1cdbd2cSJim Jagielski }
148*b1cdbd2cSJim Jagielski
149*b1cdbd2cSJim Jagielski // create serf request
150*b1cdbd2cSJim Jagielski serf_bucket_t *req_bkt = serf_request_bucket_request_create( inSerfRequest,
151*b1cdbd2cSJim Jagielski "PROPFIND",
152*b1cdbd2cSJim Jagielski getPathStr(),
153*b1cdbd2cSJim Jagielski body_bkt,
154*b1cdbd2cSJim Jagielski pSerfBucketAlloc );
155*b1cdbd2cSJim Jagielski handleChunkedEncoding(req_bkt, aBodyText.getLength());
156*b1cdbd2cSJim Jagielski
157*b1cdbd2cSJim Jagielski // set request header fields
158*b1cdbd2cSJim Jagielski serf_bucket_t* hdrs_bkt = serf_bucket_request_get_headers( req_bkt );
159*b1cdbd2cSJim Jagielski if (hdrs_bkt != NULL)
160*b1cdbd2cSJim Jagielski {
161*b1cdbd2cSJim Jagielski // general header fields provided by caller
162*b1cdbd2cSJim Jagielski setRequestHeaders( hdrs_bkt );
163*b1cdbd2cSJim Jagielski
164*b1cdbd2cSJim Jagielski // request specific header fields
165*b1cdbd2cSJim Jagielski serf_bucket_headers_set( hdrs_bkt, "Depth", mDepthStr );
166*b1cdbd2cSJim Jagielski if (hdrs_bkt!=NULL && body_bkt != 0 && aBodyText.getLength() > 0 )
167*b1cdbd2cSJim Jagielski {
168*b1cdbd2cSJim Jagielski serf_bucket_headers_set( hdrs_bkt, "Content-Type", "application/xml" );
169*b1cdbd2cSJim Jagielski }
170*b1cdbd2cSJim Jagielski }
171*b1cdbd2cSJim Jagielski else
172*b1cdbd2cSJim Jagielski {
173*b1cdbd2cSJim Jagielski OSL_ASSERT("Headers Bucket missing");
174*b1cdbd2cSJim Jagielski }
175*b1cdbd2cSJim Jagielski
176*b1cdbd2cSJim Jagielski return req_bkt;
177*b1cdbd2cSJim Jagielski }
178*b1cdbd2cSJim Jagielski
processChunkOfResponseData(const char * data,apr_size_t len)179*b1cdbd2cSJim Jagielski void SerfPropFindReqProcImpl::processChunkOfResponseData( const char* data,
180*b1cdbd2cSJim Jagielski apr_size_t len )
181*b1cdbd2cSJim Jagielski {
182*b1cdbd2cSJim Jagielski if ( xInputStream.is() )
183*b1cdbd2cSJim Jagielski {
184*b1cdbd2cSJim Jagielski xInputStream->AddToStream( data, len );
185*b1cdbd2cSJim Jagielski }
186*b1cdbd2cSJim Jagielski }
187*b1cdbd2cSJim Jagielski
handleEndOfResponseData(serf_bucket_t *)188*b1cdbd2cSJim Jagielski void SerfPropFindReqProcImpl::handleEndOfResponseData( serf_bucket_t * /*inSerfResponseBucket*/ )
189*b1cdbd2cSJim Jagielski {
190*b1cdbd2cSJim Jagielski if ( mbOnlyPropertyNames )
191*b1cdbd2cSJim Jagielski {
192*b1cdbd2cSJim Jagielski const std::vector< DAVResourceInfo > rResInfo( parseWebDAVPropNameResponse( xInputStream.get() ) );
193*b1cdbd2cSJim Jagielski *mpResInfo = rResInfo;
194*b1cdbd2cSJim Jagielski }
195*b1cdbd2cSJim Jagielski else
196*b1cdbd2cSJim Jagielski {
197*b1cdbd2cSJim Jagielski const std::vector< DAVResource > rResources( parseWebDAVPropFindResponse( xInputStream.get() ) );
198*b1cdbd2cSJim Jagielski *mpResources = rResources;
199*b1cdbd2cSJim Jagielski }
200*b1cdbd2cSJim Jagielski }
201*b1cdbd2cSJim Jagielski
202*b1cdbd2cSJim Jagielski } // namespace http_dav_ucp
203