/***

* ==++==

*

* Copyright (c) Microsoft Corporation. All rights reserved.

* Licensed under the Apache License, Version 2.0 (the "License");

* you may not use this file except in compliance with the License.

* You may obtain a copy of the License at

* http://www.apache.org/licenses/LICENSE-2.0

*

* Unless required by applicable law or agreed to in writing, software

* distributed under the License is distributed on an "AS IS" BASIS,

* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

* See the License for the specific language governing permissions and

* limitations under the License.

*

* ==--==

* =+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+=+

*

* HTTP Library: Request and reply message definitions (client side).

*

* For the latest on this and related APIs, please see http://casablanca.codeplex.com.

*

* =-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-

****/

#include "stdafx.h"

namespace web { namespace http

{

uri details::_http_request::relative_uri() const

{

// If the listener path is empty, then just return the request URI.

if(m_listener_path.empty() || m_listener_path == _XPLATSTR("/"))

{

return m_uri.resource();

}

utility::string_t prefix = uri::decode(m_listener_path);

utility::string_t path = uri::decode(m_uri.resource().to_string());

if(path.empty())

{

path = _XPLATSTR("/");

}

auto pos = path.find(prefix);

if (pos == 0)

{

return uri(uri::encode_uri(path.erase(0, prefix.length())));

}

else

{

throw http_exception(_XPLATSTR("Error: request was not prefixed with listener uri"));

}

}

uri details::_http_request::absolute_uri() const

{

if (m_base_uri.is_empty())

{

return m_uri;

}

else

{

return uri_builder(m_base_uri).append(m_uri).to_uri();

}

}

void details::_http_request::set_request_uri(const uri& relative)

{

m_uri = relative;

}

utility::string_t details::_http_request::to_string() const

{

utility::ostringstream_t buffer;

buffer.imbue(std::locale::classic());

buffer << m_method << _XPLATSTR(" ") << (this->m_uri.is_empty() ? _XPLATSTR("/") : this->m_uri.to_string()) << _XPLATSTR(" HTTP/1.1\r\n");

buffer << http_msg_base::to_string();

return buffer.str();

}

utility::string_t details::_http_response::to_string() const

{

// If the user didn't explicitly set a reason phrase then we should have it default

// if they used one of the standard known status codes.

auto reason_phrase = m_reason_phrase;

if(reason_phrase.empty())

{

static http_status_to_phrase idToPhraseMap[] = {

#define _PHRASES

#define DAT(a,b,c) {status_codes::a, c},

#include "cpprest/details/http_constants.dat"

#undef _PHRASES

#undef DAT

};

for( auto iter = std::begin(idToPhraseMap); iter != std::end(idToPhraseMap); ++iter)

{

if( iter->id == status_code() )

{

reason_phrase = iter->phrase;

break;

}

}

}

utility::ostringstream_t buffer;

buffer.imbue(std::locale::classic());

buffer << _XPLATSTR("HTTP/1.1 ") << m_status_code << _XPLATSTR(" ") << reason_phrase << _XPLATSTR("\r\n");

buffer << http_msg_base::to_string();

return buffer.str();

}

// Macros to help build string at compile time and avoid overhead.

#define STRINGIFY(x) _XPLATSTR(#x)

#define TOSTRING(x) STRINGIFY(x)

#define USERAGENT _XPLATSTR("cpprestsdk/") TOSTRING(CPPREST_VERSION_MAJOR) _XPLATSTR(".") TOSTRING(CPPREST_VERSION_MINOR) _XPLATSTR(".") TOSTRING(CPPREST_VERSION_REVISION)

pplx::task<http_response> client::http_client::request(http_request request, const pplx::cancellation_token &token)

{

if(!request.headers().has(header_names::user_agent))

{

request.headers().add(header_names::user_agent, USERAGENT);

}

request._set_base_uri(base_uri());

request._set_cancellation_token(token);

return m_pipeline->propagate(request);

}

}} // namespace web::http