18590a0fdSAndre Fischer /**************************************************************
28590a0fdSAndre Fischer *
38590a0fdSAndre Fischer * Licensed to the Apache Software Foundation (ASF) under one
48590a0fdSAndre Fischer * or more contributor license agreements. See the NOTICE file
58590a0fdSAndre Fischer * distributed with this work for additional information
68590a0fdSAndre Fischer * regarding copyright ownership. The ASF licenses this file
78590a0fdSAndre Fischer * to you under the Apache License, Version 2.0 (the
88590a0fdSAndre Fischer * "License"); you may not use this file except in compliance
98590a0fdSAndre Fischer * with the License. You may obtain a copy of the License at
108590a0fdSAndre Fischer *
118590a0fdSAndre Fischer * http://www.apache.org/licenses/LICENSE-2.0
128590a0fdSAndre Fischer *
138590a0fdSAndre Fischer * Unless required by applicable law or agreed to in writing,
148590a0fdSAndre Fischer * software distributed under the License is distributed on an
158590a0fdSAndre Fischer * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
168590a0fdSAndre Fischer * KIND, either express or implied. See the License for the
178590a0fdSAndre Fischer * specific language governing permissions and limitations
188590a0fdSAndre Fischer * under the License.
198590a0fdSAndre Fischer *
208590a0fdSAndre Fischer *************************************************************/
218590a0fdSAndre Fischer
228590a0fdSAndre Fischer // MARKER(update_precomp.py): autogen include statement, do not remove
238590a0fdSAndre Fischer #include "precompiled_ucb.hxx"
248590a0fdSAndre Fischer
25c1c10f68SAriel Constenla-Haile #include "SerfPostReqProcImpl.hxx"
268590a0fdSAndre Fischer
2708bb353fSPedro Giffuni #include <serf.h>
288590a0fdSAndre Fischer
298590a0fdSAndre Fischer using namespace com::sun::star;
308590a0fdSAndre Fischer
318590a0fdSAndre Fischer namespace http_dav_ucp
328590a0fdSAndre Fischer {
338590a0fdSAndre Fischer
SerfPostReqProcImpl(const char * inPath,const DAVRequestHeaders & inRequestHeaders,const char * inData,apr_size_t inDataLen,const char * inLockToken,const char * inContentType,const char * inReferer,const com::sun::star::uno::Reference<SerfInputStream> & xioInStrm)348590a0fdSAndre Fischer SerfPostReqProcImpl::SerfPostReqProcImpl( const char* inPath,
35e9ff7e89SOliver-Rainer Wittmann const DAVRequestHeaders& inRequestHeaders,
368590a0fdSAndre Fischer const char* inData,
378590a0fdSAndre Fischer apr_size_t inDataLen,
38*3edf6992SAndrea Pescetti const char* inLockToken,
398590a0fdSAndre Fischer const char* inContentType,
408590a0fdSAndre Fischer const char* inReferer,
418590a0fdSAndre Fischer const com::sun::star::uno::Reference< SerfInputStream > & xioInStrm )
42e9ff7e89SOliver-Rainer Wittmann : SerfRequestProcessorImpl( inPath, inRequestHeaders )
438590a0fdSAndre Fischer , mpPostData( inData )
448590a0fdSAndre Fischer , mnPostDataLen( inDataLen )
45*3edf6992SAndrea Pescetti , mpLockToken( inLockToken )
468590a0fdSAndre Fischer , mpContentType( inContentType )
478590a0fdSAndre Fischer , mpReferer( inReferer )
488590a0fdSAndre Fischer , xInputStream( xioInStrm )
498590a0fdSAndre Fischer , xOutputStream()
508590a0fdSAndre Fischer {
518590a0fdSAndre Fischer }
528590a0fdSAndre Fischer
SerfPostReqProcImpl(const char * inPath,const DAVRequestHeaders & inRequestHeaders,const char * inData,apr_size_t inDataLen,const char * inLockToken,const char * inContentType,const char * inReferer,const com::sun::star::uno::Reference<com::sun::star::io::XOutputStream> & xioOutStrm)538590a0fdSAndre Fischer SerfPostReqProcImpl::SerfPostReqProcImpl( const char* inPath,
54e9ff7e89SOliver-Rainer Wittmann const DAVRequestHeaders& inRequestHeaders,
558590a0fdSAndre Fischer const char* inData,
568590a0fdSAndre Fischer apr_size_t inDataLen,
57*3edf6992SAndrea Pescetti const char* inLockToken,
588590a0fdSAndre Fischer const char* inContentType,
598590a0fdSAndre Fischer const char* inReferer,
608590a0fdSAndre Fischer const com::sun::star::uno::Reference< com::sun::star::io::XOutputStream > & xioOutStrm )
61e9ff7e89SOliver-Rainer Wittmann : SerfRequestProcessorImpl( inPath, inRequestHeaders )
628590a0fdSAndre Fischer , mpPostData( inData )
638590a0fdSAndre Fischer , mnPostDataLen( inDataLen )
64*3edf6992SAndrea Pescetti , mpLockToken( inLockToken )
658590a0fdSAndre Fischer , mpContentType( inContentType )
668590a0fdSAndre Fischer , mpReferer( inReferer )
678590a0fdSAndre Fischer , xInputStream()
688590a0fdSAndre Fischer , xOutputStream( xioOutStrm )
698590a0fdSAndre Fischer {
708590a0fdSAndre Fischer }
718590a0fdSAndre Fischer
~SerfPostReqProcImpl()728590a0fdSAndre Fischer SerfPostReqProcImpl::~SerfPostReqProcImpl()
738590a0fdSAndre Fischer {
748590a0fdSAndre Fischer }
758590a0fdSAndre Fischer
createSerfRequestBucket(serf_request_t * inSerfRequest)768590a0fdSAndre Fischer serf_bucket_t * SerfPostReqProcImpl::createSerfRequestBucket( serf_request_t * inSerfRequest )
778590a0fdSAndre Fischer {
788590a0fdSAndre Fischer serf_bucket_alloc_t* pSerfBucketAlloc = serf_request_get_alloc( inSerfRequest );
798590a0fdSAndre Fischer
808590a0fdSAndre Fischer // create body bucket
818590a0fdSAndre Fischer serf_bucket_t* body_bkt = 0;
828590a0fdSAndre Fischer if ( mpPostData != 0 && mnPostDataLen > 0 )
838590a0fdSAndre Fischer {
848590a0fdSAndre Fischer body_bkt = SERF_BUCKET_SIMPLE_STRING_LEN( mpPostData, mnPostDataLen, pSerfBucketAlloc );
858590a0fdSAndre Fischer }
868590a0fdSAndre Fischer
878590a0fdSAndre Fischer // create serf request
888590a0fdSAndre Fischer serf_bucket_t *req_bkt = serf_request_bucket_request_create( inSerfRequest,
898590a0fdSAndre Fischer "POST",
908590a0fdSAndre Fischer getPathStr(),
918590a0fdSAndre Fischer body_bkt,
928590a0fdSAndre Fischer serf_request_get_alloc( inSerfRequest ) );
9310e20387SAndre Fischer handleChunkedEncoding(req_bkt, mnPostDataLen);
948590a0fdSAndre Fischer
958590a0fdSAndre Fischer // set request header fields
968590a0fdSAndre Fischer serf_bucket_t* hdrs_bkt = serf_bucket_request_get_headers( req_bkt );
97e9ff7e89SOliver-Rainer Wittmann // general header fields provided by caller
98e9ff7e89SOliver-Rainer Wittmann setRequestHeaders( hdrs_bkt );
998590a0fdSAndre Fischer
1008590a0fdSAndre Fischer // request specific header fields
1018590a0fdSAndre Fischer if ( mpContentType != 0 )
1028590a0fdSAndre Fischer {
103e9ff7e89SOliver-Rainer Wittmann serf_bucket_headers_set( hdrs_bkt, "Content-Type", mpContentType );
1048590a0fdSAndre Fischer }
1058590a0fdSAndre Fischer if ( mpReferer != 0 )
1068590a0fdSAndre Fischer {
107e9ff7e89SOliver-Rainer Wittmann serf_bucket_headers_set( hdrs_bkt, "Referer", mpReferer );
1088590a0fdSAndre Fischer }
109*3edf6992SAndrea Pescetti if(mpLockToken)
110*3edf6992SAndrea Pescetti {
111*3edf6992SAndrea Pescetti serf_bucket_headers_set( hdrs_bkt, "if", mpLockToken );
112*3edf6992SAndrea Pescetti }
1138590a0fdSAndre Fischer
1148590a0fdSAndre Fischer return req_bkt;
1158590a0fdSAndre Fischer }
1168590a0fdSAndre Fischer
processChunkOfResponseData(const char * data,apr_size_t len)11749989859SOliver-Rainer Wittmann void SerfPostReqProcImpl::processChunkOfResponseData( const char* data,
11849989859SOliver-Rainer Wittmann apr_size_t len )
1198590a0fdSAndre Fischer {
12049989859SOliver-Rainer Wittmann if ( xInputStream.is() )
12149989859SOliver-Rainer Wittmann {
12249989859SOliver-Rainer Wittmann xInputStream->AddToStream( data, len );
12349989859SOliver-Rainer Wittmann }
12449989859SOliver-Rainer Wittmann else if ( xOutputStream.is() )
12549989859SOliver-Rainer Wittmann {
12649989859SOliver-Rainer Wittmann const uno::Sequence< sal_Int8 > aDataSeq( (sal_Int8 *)data, len );
12749989859SOliver-Rainer Wittmann xOutputStream->writeBytes( aDataSeq );
1288590a0fdSAndre Fischer }
12949989859SOliver-Rainer Wittmann }
1308590a0fdSAndre Fischer
handleEndOfResponseData(serf_bucket_t *)13149989859SOliver-Rainer Wittmann void SerfPostReqProcImpl::handleEndOfResponseData( serf_bucket_t * /*inSerfResponseBucket*/ )
13249989859SOliver-Rainer Wittmann {
13349989859SOliver-Rainer Wittmann // nothing to do;
1348590a0fdSAndre Fischer }
135307c6619SOliver-Rainer Wittmann
1368590a0fdSAndre Fischer } // namespace http_dav_ucp
137