ucb/source/ucp/webdav/SerfRequestProcessorImpl.cxx

   1 /* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
   2 /*
   3  * This file is part of the LibreOffice project.
   4  *
   5  * This Source Code Form is subject to the terms of the Mozilla Public
   6  * License, v. 2.0. If a copy of the MPL was not distributed with this
   7  * file, You can obtain one at http://mozilla.org/MPL/2.0/.
   8  *
   9  * This file incorporates work covered by the following license notice:
  10  *
  11  *   Licensed to the Apache Software Foundation (ASF) under one or more
  12  *   contributor license agreements. See the NOTICE file distributed
  13  *   with this work for additional information regarding copyright
  14  *   ownership. The ASF licenses this file to you under the Apache
  15  *   License, Version 2.0 (the "License"); you may not use this file
  16  *   except in compliance with the License. You may obtain a copy of
  17  *   the License at http://www.apache.org/licenses/LICENSE-2.0 .
  18  */
  19
  20 #include "SerfRequestProcessorImpl.hxx"
  21
  22 namespace
  23 {
  24 // Define a magic value that is used by serf to reset chunked
  25 // encoding.  The value definition is not supported by serf, hence the
  26 // definition here.
  27 static const apr_int64_t SERF_UNKNOWN_LENGTH (-1);
  28 }
  29
  30 namespace http_dav_ucp
  31 {
  32
  33 SerfRequestProcessorImpl::SerfRequestProcessorImpl( const char* inPath,
  34                                                     const DAVRequestHeaders& inRequestHeaders )
  35     : mPathStr( inPath )
  36     , mrRequestHeaders( inRequestHeaders )
  37     , mbUseChunkedEncoding( false )
  38 {
  39 }
  40
  41 SerfRequestProcessorImpl::~SerfRequestProcessorImpl()
  42 {
  43 }
  44
  45 const char* SerfRequestProcessorImpl::getPathStr() const
  46 {
  47     return mPathStr;
  48 }
  49
  50 void SerfRequestProcessorImpl::activateChunkedEncoding()
  51 {
  52     mbUseChunkedEncoding = true;
  53 }
  54
  55 bool SerfRequestProcessorImpl::useChunkedEncoding() const
  56 {
  57     return mbUseChunkedEncoding;
  58 }
  59
  60
  61 void SerfRequestProcessorImpl::handleChunkedEncoding (
  62     serf_bucket_t* pRequestBucket,
  63     apr_int64_t nLength) const
  64 {
  65     if (pRequestBucket != NULL)
  66     {
  67         if (useChunkedEncoding())
  68         {
  69             // Activate chunked encoding.
  70             serf_bucket_request_set_CL(pRequestBucket, SERF_UNKNOWN_LENGTH);
  71         }
  72         else
  73         {
  74             // Deactivate chunked encoding by setting the length.
  75             serf_bucket_request_set_CL(pRequestBucket, nLength);
  76         }
  77     }
  78 }
  79
  80
  81 void SerfRequestProcessorImpl::setRequestHeaders( serf_bucket_t* inoutSerfHeaderBucket )
  82 {
  83     bool bHasUserAgent( false );
  84     DAVRequestHeaders::const_iterator aHeaderIter( mrRequestHeaders.begin() );
  85     const DAVRequestHeaders::const_iterator aEnd( mrRequestHeaders.end() );
  86
  87     while ( aHeaderIter != aEnd )
  88     {
  89         const OString aHeader = OUStringToOString( (*aHeaderIter).first,
  90                                                                RTL_TEXTENCODING_UTF8 );
  91         const OString aValue = OUStringToOString( (*aHeaderIter).second,
  92                                                             RTL_TEXTENCODING_UTF8 );
  93
  94         SAL_INFO("ucb.ucp.webdav",  "Request Header - \"" << aHeader << ": " << aValue << "\"");
  95         if ( !bHasUserAgent )
  96             bHasUserAgent = aHeaderIter->first == "User-Agent";
  97
  98         serf_bucket_headers_setc( inoutSerfHeaderBucket,
  99                                   aHeader.getStr(),
 100                                   aValue.getStr() );
 101
 102         ++aHeaderIter;
 103     }
 104
 105     if ( !bHasUserAgent )
 106     {
 107         serf_bucket_headers_set( inoutSerfHeaderBucket,
 108                                  "User-Agent", "LibreOffice" );
 109     }
 110
 111     serf_bucket_headers_set( inoutSerfHeaderBucket, "Accept-Encoding", "gzip");
 112 }
 113
 114 bool SerfRequestProcessorImpl::processSerfResponseBucket( serf_request_t * /*inSerfRequest*/,
 115                                                           serf_bucket_t * inSerfResponseBucket,
 116                                                           apr_pool_t * /*inAprPool*/,
 117                                                           apr_status_t & outStatus )
 118 {
 119     const char* data;
 120     apr_size_t len;
 121
 122     while (true) {
 123         outStatus = serf_bucket_read(inSerfResponseBucket, 8096, &data, &len);
 124         if (SERF_BUCKET_READ_ERROR(outStatus))
 125         {
 126             return true;
 127         }
 128
 129         if ( len > 0 )
 130         {
 131             processChunkOfResponseData( data, len );
 132         }
 133
 134         /* are we done yet? */
 135         if (APR_STATUS_IS_EOF(outStatus))
 136         {
 137             handleEndOfResponseData( inSerfResponseBucket );
 138
 139             outStatus = APR_EOF;
 140             return true;
 141         }
 142
 143         /* have we drained the response so far? */
 144         if ( APR_STATUS_IS_EAGAIN( outStatus ) )
 145         {
 146             return false;
 147         }
 148     }
 149
 150     /* NOTREACHED */
 151     return true;
 152 }
 153
 154 } // namespace http_dav_ucp
 155
 156 /* vim:set shiftwidth=4 softtabstop=4 expandtab: */