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 <rtl/ustring.hxx>
26*b1cdbd2cSJim Jagielski #include <rtl/ustrbuf.hxx>
27*b1cdbd2cSJim Jagielski #include "DAVProperties.hxx"
28*b1cdbd2cSJim Jagielski #include "UCBDeadPropertyValue.hxx"
29*b1cdbd2cSJim Jagielski
30*b1cdbd2cSJim Jagielski #include "SerfPropPatchReqProcImpl.hxx"
31*b1cdbd2cSJim Jagielski #include "SerfTypes.hxx"
32*b1cdbd2cSJim Jagielski
33*b1cdbd2cSJim Jagielski namespace http_dav_ucp
34*b1cdbd2cSJim Jagielski {
35*b1cdbd2cSJim Jagielski
SerfPropPatchReqProcImpl(const char * inPath,const DAVRequestHeaders & inRequestHeaders,const std::vector<ProppatchValue> & inProperties,const char * inLockToken)36*b1cdbd2cSJim Jagielski SerfPropPatchReqProcImpl::SerfPropPatchReqProcImpl( const char* inPath,
37*b1cdbd2cSJim Jagielski const DAVRequestHeaders& inRequestHeaders,
38*b1cdbd2cSJim Jagielski const std::vector< ProppatchValue > & inProperties,
39*b1cdbd2cSJim Jagielski const char* inLockToken )
40*b1cdbd2cSJim Jagielski : SerfRequestProcessorImpl( inPath, inRequestHeaders )
41*b1cdbd2cSJim Jagielski , mpProperties( &inProperties )
42*b1cdbd2cSJim Jagielski , mpLockToken( inLockToken )
43*b1cdbd2cSJim Jagielski {
44*b1cdbd2cSJim Jagielski }
45*b1cdbd2cSJim Jagielski
~SerfPropPatchReqProcImpl()46*b1cdbd2cSJim Jagielski SerfPropPatchReqProcImpl::~SerfPropPatchReqProcImpl()
47*b1cdbd2cSJim Jagielski {
48*b1cdbd2cSJim Jagielski }
49*b1cdbd2cSJim Jagielski
50*b1cdbd2cSJim Jagielski #define PROPPATCH_HEADER "<?xml version=\"1.0\" encoding=\"utf-8\"?><propertyupdate xmlns=\"DAV:\">"
51*b1cdbd2cSJim Jagielski #define PROPPATCH_TRAILER "</propertyupdate>"
52*b1cdbd2cSJim Jagielski
createSerfRequestBucket(serf_request_t * inSerfRequest)53*b1cdbd2cSJim Jagielski serf_bucket_t * SerfPropPatchReqProcImpl::createSerfRequestBucket( serf_request_t * inSerfRequest )
54*b1cdbd2cSJim Jagielski {
55*b1cdbd2cSJim Jagielski serf_bucket_alloc_t* pSerfBucketAlloc = serf_request_get_alloc( inSerfRequest );
56*b1cdbd2cSJim Jagielski
57*b1cdbd2cSJim Jagielski // body bucket
58*b1cdbd2cSJim Jagielski serf_bucket_t* body_bkt = 0;
59*b1cdbd2cSJim Jagielski rtl::OString aBodyText;
60*b1cdbd2cSJim Jagielski {
61*b1cdbd2cSJim Jagielski // create and fill body bucket with properties to be set or removed
62*b1cdbd2cSJim Jagielski static const struct
63*b1cdbd2cSJim Jagielski {
64*b1cdbd2cSJim Jagielski const char *str;
65*b1cdbd2cSJim Jagielski sal_Int32 len;
66*b1cdbd2cSJim Jagielski }
67*b1cdbd2cSJim Jagielski OpCode [] = {
68*b1cdbd2cSJim Jagielski { RTL_CONSTASCII_STRINGPARAM( "set" ) },
69*b1cdbd2cSJim Jagielski { RTL_CONSTASCII_STRINGPARAM( "remove" ) }
70*b1cdbd2cSJim Jagielski };
71*b1cdbd2cSJim Jagielski const int nPropCount = ( mpProperties != 0 )
72*b1cdbd2cSJim Jagielski ? mpProperties->size()
73*b1cdbd2cSJim Jagielski : 0;
74*b1cdbd2cSJim Jagielski if ( nPropCount > 0 )
75*b1cdbd2cSJim Jagielski {
76*b1cdbd2cSJim Jagielski rtl::OUStringBuffer aBuffer;
77*b1cdbd2cSJim Jagielski // add PropPatch xml header in front
78*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( PROPPATCH_HEADER ));
79*b1cdbd2cSJim Jagielski
80*b1cdbd2cSJim Jagielski // <*operation code*><prop>
81*b1cdbd2cSJim Jagielski
82*b1cdbd2cSJim Jagielski ProppatchOperation lastOp = (*mpProperties)[ 0 ].operation;
83*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "<" ));
84*b1cdbd2cSJim Jagielski aBuffer.appendAscii( OpCode[lastOp].str, OpCode[lastOp].len );
85*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "><prop>" ));
86*b1cdbd2cSJim Jagielski
87*b1cdbd2cSJim Jagielski SerfPropName thePropName;
88*b1cdbd2cSJim Jagielski for ( int n = 0; n < nPropCount; ++n )
89*b1cdbd2cSJim Jagielski {
90*b1cdbd2cSJim Jagielski const ProppatchValue & rProperty = (*mpProperties)[ n ];
91*b1cdbd2cSJim Jagielski // split fullname into namespace and name!
92*b1cdbd2cSJim Jagielski DAVProperties::createSerfPropName( rProperty.name,
93*b1cdbd2cSJim Jagielski thePropName );
94*b1cdbd2cSJim Jagielski
95*b1cdbd2cSJim Jagielski if ( rProperty.operation != lastOp )
96*b1cdbd2cSJim Jagielski {
97*b1cdbd2cSJim Jagielski // </prop></*last operation code*><*operation code><prop>
98*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "</prop></" ));
99*b1cdbd2cSJim Jagielski aBuffer.appendAscii( OpCode[lastOp].str, OpCode[lastOp].len );
100*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "><" ));
101*b1cdbd2cSJim Jagielski aBuffer.appendAscii( OpCode[rProperty.operation].str, OpCode[rProperty.operation].len );
102*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "><prop>" ));
103*b1cdbd2cSJim Jagielski }
104*b1cdbd2cSJim Jagielski
105*b1cdbd2cSJim Jagielski // <*propname* xmlns="*propns*"
106*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "<" ));
107*b1cdbd2cSJim Jagielski aBuffer.appendAscii( thePropName.name );
108*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( " xmlns=\"" ));
109*b1cdbd2cSJim Jagielski aBuffer.appendAscii( thePropName.nspace );
110*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "\"" ));
111*b1cdbd2cSJim Jagielski
112*b1cdbd2cSJim Jagielski if ( rProperty.operation == PROPSET )
113*b1cdbd2cSJim Jagielski {
114*b1cdbd2cSJim Jagielski // >*property value*</*propname*>
115*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( ">" ));
116*b1cdbd2cSJim Jagielski
117*b1cdbd2cSJim Jagielski rtl::OUString aStringValue;
118*b1cdbd2cSJim Jagielski if ( DAVProperties::isUCBDeadProperty( thePropName ) )
119*b1cdbd2cSJim Jagielski {
120*b1cdbd2cSJim Jagielski UCBDeadPropertyValue::toXML( rProperty.value,
121*b1cdbd2cSJim Jagielski aStringValue );
122*b1cdbd2cSJim Jagielski }
123*b1cdbd2cSJim Jagielski else
124*b1cdbd2cSJim Jagielski {
125*b1cdbd2cSJim Jagielski rProperty.value >>= aStringValue;
126*b1cdbd2cSJim Jagielski }
127*b1cdbd2cSJim Jagielski aBuffer.append( aStringValue );
128*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "</" ));
129*b1cdbd2cSJim Jagielski aBuffer.appendAscii( thePropName.name );
130*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( ">" ));
131*b1cdbd2cSJim Jagielski }
132*b1cdbd2cSJim Jagielski else
133*b1cdbd2cSJim Jagielski {
134*b1cdbd2cSJim Jagielski // />
135*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "/>" ));
136*b1cdbd2cSJim Jagielski }
137*b1cdbd2cSJim Jagielski
138*b1cdbd2cSJim Jagielski lastOp = rProperty.operation;
139*b1cdbd2cSJim Jagielski }
140*b1cdbd2cSJim Jagielski
141*b1cdbd2cSJim Jagielski // </prop></*last operation code*>
142*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( "</prop></" ));
143*b1cdbd2cSJim Jagielski aBuffer.appendAscii( OpCode[lastOp].str, OpCode[lastOp].len );
144*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( ">" ));
145*b1cdbd2cSJim Jagielski
146*b1cdbd2cSJim Jagielski // add PropPatch xml trailer at end
147*b1cdbd2cSJim Jagielski aBuffer.appendAscii( RTL_CONSTASCII_STRINGPARAM( PROPPATCH_TRAILER ));
148*b1cdbd2cSJim Jagielski
149*b1cdbd2cSJim Jagielski aBodyText = rtl::OUStringToOString( aBuffer.makeStringAndClear(), RTL_TEXTENCODING_UTF8 );
150*b1cdbd2cSJim Jagielski body_bkt = serf_bucket_simple_copy_create( aBodyText.getStr(),
151*b1cdbd2cSJim Jagielski aBodyText.getLength(),
152*b1cdbd2cSJim Jagielski pSerfBucketAlloc );
153*b1cdbd2cSJim Jagielski }
154*b1cdbd2cSJim Jagielski }
155*b1cdbd2cSJim Jagielski
156*b1cdbd2cSJim Jagielski // create serf request
157*b1cdbd2cSJim Jagielski serf_bucket_t *req_bkt = serf_request_bucket_request_create( inSerfRequest,
158*b1cdbd2cSJim Jagielski "PROPPATCH",
159*b1cdbd2cSJim Jagielski getPathStr(),
160*b1cdbd2cSJim Jagielski body_bkt,
161*b1cdbd2cSJim Jagielski pSerfBucketAlloc ) ;
162*b1cdbd2cSJim Jagielski handleChunkedEncoding(req_bkt, aBodyText.getLength());
163*b1cdbd2cSJim Jagielski
164*b1cdbd2cSJim Jagielski // set request header fields
165*b1cdbd2cSJim Jagielski serf_bucket_t* hdrs_bkt = serf_bucket_request_get_headers( req_bkt );
166*b1cdbd2cSJim Jagielski if (hdrs_bkt != NULL)
167*b1cdbd2cSJim Jagielski {
168*b1cdbd2cSJim Jagielski // general header fields provided by caller
169*b1cdbd2cSJim Jagielski setRequestHeaders( hdrs_bkt );
170*b1cdbd2cSJim Jagielski
171*b1cdbd2cSJim Jagielski // request specific header fields
172*b1cdbd2cSJim Jagielski if(mpLockToken)
173*b1cdbd2cSJim Jagielski {
174*b1cdbd2cSJim Jagielski serf_bucket_headers_set( hdrs_bkt, "if", mpLockToken );
175*b1cdbd2cSJim Jagielski }
176*b1cdbd2cSJim Jagielski if ( body_bkt != 0 && aBodyText.getLength() > 0 )
177*b1cdbd2cSJim Jagielski {
178*b1cdbd2cSJim Jagielski serf_bucket_headers_set( hdrs_bkt, "Content-Type", "application/xml" );
179*b1cdbd2cSJim Jagielski }
180*b1cdbd2cSJim Jagielski }
181*b1cdbd2cSJim Jagielski else
182*b1cdbd2cSJim Jagielski {
183*b1cdbd2cSJim Jagielski OSL_ASSERT("Headers Bucket missing");
184*b1cdbd2cSJim Jagielski }
185*b1cdbd2cSJim Jagielski
186*b1cdbd2cSJim Jagielski return req_bkt;
187*b1cdbd2cSJim Jagielski }
188*b1cdbd2cSJim Jagielski
processChunkOfResponseData(const char *,apr_size_t)189*b1cdbd2cSJim Jagielski void SerfPropPatchReqProcImpl::processChunkOfResponseData( const char* /*data*/,
190*b1cdbd2cSJim Jagielski apr_size_t /*len*/ )
191*b1cdbd2cSJim Jagielski {
192*b1cdbd2cSJim Jagielski // nothing to do;
193*b1cdbd2cSJim Jagielski }
194*b1cdbd2cSJim Jagielski
handleEndOfResponseData(serf_bucket_t *)195*b1cdbd2cSJim Jagielski void SerfPropPatchReqProcImpl::handleEndOfResponseData( serf_bucket_t * /*inSerfResponseBucket*/ )
196*b1cdbd2cSJim Jagielski {
197*b1cdbd2cSJim Jagielski // nothing to do;
198*b1cdbd2cSJim Jagielski }
199*b1cdbd2cSJim Jagielski
200*b1cdbd2cSJim Jagielski } // namespace http_dav_ucp
201