phoenix-firestorm/indra/llmessage/fscorehttputil.cpp

/**
 * @file fscorehttputil.h
 * @brief Core HTTP utility classes.
 *
 * $LicenseInfo:firstyear=2015&license=viewerlgpl$
 * Phoenix Firestorm Viewer Source Code
 * Copyright (c) 2015 Nicky Dasmijn
 *
 * This library is free software; you can redistribute it and/or
 * modify it under the terms of the GNU Lesser General Public
 * License as published by the Free Software Foundation;
 * version 2.1 of the License only.
 *
 * This library is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
 *
 * The Phoenix Firestorm Project, Inc., 1831 Oakwood Drive, Fairmont, Minnesota 56031-3225 USA
 * http://www.firestormviewer.org
 * $/LicenseInfo$
 */

#include "fscorehttputil.h"

namespace FSCoreHttpUtil
{
void trivialPostCoroRaw(std::string                   url,
                        LLCore::HttpRequest::policy_t policyId,
                        LLCore::BufferArray::ptr_t    postData,
                        LLCore::HttpHeaders::ptr_t    aHeader,
                        LLCore::HttpOptions::ptr_t    options,
                        completionCallback_t          success,
                        completionCallback_t          failure)
{
    LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t httpAdapter =
        std::make_shared<LLCoreHttpUtil::HttpCoroutineAdapter>("genericPostCoroRaw", policyId);
    LLCore::HttpRequest::ptr_t httpRequest = std::make_shared<LLCore::HttpRequest>();

    if (!options)
    {
        options = std::make_shared<LLCore::HttpOptions>();
        options->setWantHeaders(true);
    }

    LL_INFOS("HttpCoroutineAdapter", "genericPostCoroRaw") << "Generic POST for " << url << LL_ENDL;

    LLSD result = httpAdapter->postRawAndSuspend(httpRequest, url, postData, options, aHeader);

    LLSD               httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
    LLCore::HttpStatus status      = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);

    if (!status)
    {
        // If a failure routine is provided do it.
        if (failure)
        {
            failure(httpResults);
        }
    }
    else
    {
        // If a success routine is provided do it.
        if (success)
        {
            success(result);
        }
    }
}

void callbackHttpPostRaw(const std::string&         url,
                         std::string                postData,
                         completionCallback_t       success,
                         completionCallback_t       failure,
                         LLCore::HttpHeaders::ptr_t aHeader,
                         LLCore::HttpOptions::ptr_t options)
{
    LLCore::BufferArray::ptr_t postDataBuffer(new LLCore::BufferArray());
    postDataBuffer->append(postData.c_str(), postData.size());

    LLCoros::instance().launch(
        "HttpCoroutineAdapter::genericPostCoroRaw",
        boost::bind(trivialPostCoroRaw, url, LLCore::HttpRequest::DEFAULT_POLICY_ID, postDataBuffer, aHeader, options, success, failure));
}

void trivialGetCoroRaw(std::string                   url,
                       LLCore::HttpRequest::policy_t policyId,
                       LLCore::HttpHeaders::ptr_t    aHeader,
                       LLCore::HttpOptions::ptr_t    options,
                       completionCallback_t          success,
                       completionCallback_t          failure)
{
    LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t httpAdapter =
        std::make_shared<LLCoreHttpUtil::HttpCoroutineAdapter>("genericGetCoro", policyId);
    LLCore::HttpRequest::ptr_t httpRequest = std::make_shared<LLCore::HttpRequest>();

    if (!options)
    {
        options = std::make_shared<LLCore::HttpOptions>();
        options->setWantHeaders(true);
    }

    LL_INFOS("HttpCoroutineAdapter", "genericGetCoroRaw") << "Generic GET for " << url << LL_ENDL;

    LLSD result = httpAdapter->getRawAndSuspend(httpRequest, url, options, aHeader);

    LLSD               httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
    LLCore::HttpStatus status      = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);

    if (!status)
    {
        if (failure)
        {
            failure(httpResults);
        }
    }
    else
    {
        if (success)
        {
            success(result);
        }
    }
}

void callbackHttpGetRaw(const std::string&         url,
                        completionCallback_t       success,
                        completionCallback_t       failure,
                        LLCore::HttpHeaders::ptr_t aHeader,
                        LLCore::HttpOptions::ptr_t options)
{
    LLCoros::instance().launch(
        "HttpCoroutineAdapter::genericGetCoroRaw",
        boost::bind(trivialGetCoroRaw, url, LLCore::HttpRequest::DEFAULT_POLICY_ID, aHeader, options, success, failure));
}

void trivialGetCoro(std::string url, time_t last_modified, completionCallback_t success, completionCallback_t failure)
{
    LLCoreHttpUtil::HttpCoroutineAdapter::ptr_t httpAdapter =
        std::make_shared<LLCoreHttpUtil::HttpCoroutineAdapter>("trivialGetCoro", LLCore::HttpRequest::DEFAULT_POLICY_ID);
    LLCore::HttpRequest::ptr_t httpRequest = std::make_shared<LLCore::HttpRequest>();
    LLCore::HttpOptions::ptr_t httpOpts    = std::make_shared<LLCore::HttpOptions>();

    httpOpts->setWantHeaders(true);
    httpOpts->setLastModified((long)last_modified);

    LLSD result = httpAdapter->getAndSuspend(httpRequest, url, httpOpts);

    LLSD               httpResults = result[LLCoreHttpUtil::HttpCoroutineAdapter::HTTP_RESULTS];
    LLCore::HttpStatus status      = LLCoreHttpUtil::HttpCoroutineAdapter::getStatusFromLLSD(httpResults);

    if (!status)
    {
        if (failure)
        {
            failure(httpResults);
        }
    }
    else
    {
        if (success)
        {
            success(result);
        }
    }
}

void callbackHttpGet(const std::string& url, const time_t& last_modified, completionCallback_t success, completionCallback_t failure)
{
    LLCoros::instance().launch("HttpCoroutineAdapter::genericGetCoro", boost::bind(&trivialGetCoro, url, last_modified, success, failure));
}
} // namespace FSCoreHttpUtil