ImageServerConnection Class Reference

Handles a client connection to the image server. More...

#include "ImageServerConnection.h"

Inheritance diagram for ImageServerConnection:

Collaboration diagram for ImageServerConnection:

Public Member Functions
void	Process ()
boost::asio::ip::tcp::socket &	socket ()

Static Public Member Functions
static std::shared_ptr < ImageServerConnection >	create (boost::asio::io_context &io)

Private Member Functions
	ImageServerConnection (boost::asio::io_context &io)
void	ProcessHeaders ()
void	SendImage ()
void	NotFound ()
void	Close ()
void	Redirect ()
void	RedirectLocation ()
void	RedirectFinalize ()

Static Private Member Functions
static bool	starts_with (std::string &haystack, const char *const needle)

Private Attributes
std::string	_category
uint32	_id
uint32	_size
std::string	_redirectUrl
boost::asio::streambuf	_buffer
boost::asio::ip::tcp::socket	_socket
std::shared_ptr< std::vector < char > >	_imageData

Static Private Attributes
static boost::asio::const_buffers_1	_responseOK = boost::asio::buffer("HTTP/1.0 200 OK\r\nContent-Type: image/jpeg\r\n\r\n", 45)
static boost::asio::const_buffers_1	_responseNotFound = boost::asio::buffer("HTTP/1.0 404 Not Found\r\n\r\n", 26)
static boost::asio::const_buffers_1	_responseRedirectBegin = boost::asio::buffer("HTTP/1.0 301 Moved Permanently\r\nLocation: ", 42)
static boost::asio::const_buffers_1	_responseRedirectEnd = boost::asio::buffer("\r\n\r\n", 4)

Detailed Description

Handles a client connection to the image server.

Handles exactly one client; does all the protocol related stuff. Very limited HTTP handling.

Author

caytchen

Date

April 2011

Definition at line 41 of file ImageServerConnection.h.

Constructor & Destructor Documentation

ImageServerConnection::ImageServerConnection ( boost::asio::io_context &  io )

private

Definition at line 33 of file ImageServerConnection.cpp.

Referenced by create().

: _socket(io),
_category(0),
_id(0),
_size(0),
_redirectUrl(ImageServer::FallbackURL)
{
}

Here is the caller graph for this function:

Member Function Documentation

void ImageServerConnection::Close ( )

private

Definition at line 154 of file ImageServerConnection.cpp.

References _socket.

Referenced by NotFound(), RedirectFinalize(), and SendImage().

{
    _socket.close();
}

Here is the caller graph for this function:

std::shared_ptr< ImageServerConnection > ImageServerConnection::create ( boost::asio::io_context &  io )

static

Definition at line 164 of file ImageServerConnection.cpp.

References ImageServerConnection().

Referenced by ImageServerListener::StartAccept().

{
    return std::shared_ptr<ImageServerConnection>(new ImageServerConnection(io));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void ImageServerConnection::NotFound ( )

private

Definition at line 129 of file ImageServerConnection.cpp.

References _responseNotFound, _socket, and Close().

Referenced by ProcessHeaders().

{
    boost::asio::async_write(_socket, _responseNotFound, boost::asio::transfer_all(), std::bind(&ImageServerConnection::Close, shared_from_this()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void ImageServerConnection::Process

(

)

Definition at line 47 of file ImageServerConnection.cpp.

References _buffer, _socket, and ProcessHeaders().

{
    // receive all HTTP headers from the client
    boost::asio::async_read_until(_socket, _buffer, "\r\n\r\n", std::bind(&ImageServerConnection::ProcessHeaders, shared_from_this()));
}

Here is the call graph for this function:

void ImageServerConnection::ProcessHeaders ( )

private

Definition at line 53 of file ImageServerConnection.cpp.

References _buffer, _category, _id, _imageData, _responseOK, _size, _socket, ImageServer::Categories, ImageServer::CategoryCount, IsCharacterID, IsPlayerItem, NotFound(), Redirect(), SendImage(), sImageServer, sLog, and starts_with().

Referenced by Process().

{
    std::istream stream(&_buffer);
    std::string request;

    // every request line ends with \r\n
    std::getline(stream, request, '\r');

    if (!starts_with(request, "GET /"))
    {
        NotFound();
        return;
    }
    request = request.substr(5);

    bool found = false;
    for (uint32 i = 0; i < ImageServer::CategoryCount; i++)
    {
        if (starts_with(request, ImageServer::Categories[i]))
        {
            found = true;
            _category = ImageServer::Categories[i];
            request = request.substr(strlen(ImageServer::Categories[i]));
            break;
        }
    }
    if (!found)
    {
        NotFound();
        return;
    }

    if (!starts_with(request, "/"))
    {
        NotFound();
        return;
    }
    request = request.substr(1);

    int del = request.find_first_of('_');
    if (del == std::string::npos)
    {
        NotFound();
        return;
    }

    // might have some extra data but atoi shouldn't care
    std::string idStr = request.substr(0, del);
    std::string sizeStr = request.substr(del + 1);
    _id = atoi(idStr.c_str());
    _size = atoi(sizeStr.c_str());

    _imageData = sImageServer.GetImage(_category, _id, _size);
    if (!_imageData) {
        if (IsPlayerItem(_id)) {
            sLog.Error("     Image Server","Image for itemID %u not found.", _id);
            NotFound();
            return;
        } else if (IsCharacterID(_id)) {
            sLog.Error("     Image Server","Image for charID %u not found.", _id);
            NotFound();
            return;
        }
        Redirect();
        return;
    }

    // first we have to send the responseOK, then our actual result
    boost::asio::async_write(_socket, _responseOK, boost::asio::transfer_all(), std::bind(&ImageServerConnection::SendImage, shared_from_this()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void ImageServerConnection::Redirect ( )

private

Definition at line 134 of file ImageServerConnection.cpp.

References _responseRedirectBegin, _socket, and RedirectLocation().

Referenced by ProcessHeaders().

{
    boost::asio::async_write(_socket, _responseRedirectBegin, boost::asio::transfer_all(), std::bind(&ImageServerConnection::RedirectLocation, shared_from_this()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void ImageServerConnection::RedirectFinalize ( )

private

Definition at line 149 of file ImageServerConnection.cpp.

References _responseRedirectEnd, _socket, and Close().

Referenced by RedirectLocation().

{
    boost::asio::async_write(_socket, _responseRedirectEnd, boost::asio::transfer_all(), std::bind(&ImageServerConnection::Close, shared_from_this()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void ImageServerConnection::RedirectLocation ( )

private

Definition at line 139 of file ImageServerConnection.cpp.

References _category, _id, _redirectUrl, _size, _socket, ImageServer::FallbackURL, RedirectFinalize(), and sLog.

Referenced by Redirect().

{
    sLog.Error("     Image Server"," RedirectLocation() called.");
    std::string extension = _category == "Character" ? "jpg" : "png";
    std::stringstream url;
    url << ImageServer::FallbackURL << _category << "/" << _id << "_" << _size << "." << extension;
    _redirectUrl = url.str();
    boost::asio::async_write(_socket, boost::asio::buffer(_redirectUrl), boost::asio::transfer_all(), std::bind(&ImageServerConnection::RedirectFinalize, shared_from_this()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

void ImageServerConnection::SendImage ( )

private

Definition at line 124 of file ImageServerConnection.cpp.

References _imageData, _socket, and Close().

Referenced by ProcessHeaders().

{
    boost::asio::async_write(_socket, boost::asio::buffer(*_imageData, _imageData->size()), boost::asio::transfer_all(), std::bind(&ImageServerConnection::Close, shared_from_this()));
}

Here is the call graph for this function:

Here is the caller graph for this function:

boost::asio::ip::tcp::socket & ImageServerConnection::socket

(

)

Definition at line 42 of file ImageServerConnection.cpp.

References _socket.

{
    return _socket;
}

bool ImageServerConnection::starts_with ( std::string &  haystack, const char *const  needle  )

staticprivate

Definition at line 159 of file ImageServerConnection.cpp.

Referenced by ProcessHeaders().

{
    return haystack.substr(0, strlen(needle)).compare(needle) == 0;
}

Here is the caller graph for this function:

Member Data Documentation

boost::asio::streambuf ImageServerConnection::_buffer

private

Definition at line 66 of file ImageServerConnection.h.

Referenced by Process(), and ProcessHeaders().

std::string ImageServerConnection::_category

private

Definition at line 61 of file ImageServerConnection.h.

Referenced by ProcessHeaders(), and RedirectLocation().

uint32 ImageServerConnection::_id

private

Definition at line 62 of file ImageServerConnection.h.

Referenced by ProcessHeaders(), and RedirectLocation().

std::shared_ptr<std::vector<char> > ImageServerConnection::_imageData

private

Definition at line 68 of file ImageServerConnection.h.

Referenced by ProcessHeaders(), and SendImage().

std::string ImageServerConnection::_redirectUrl

private

Definition at line 64 of file ImageServerConnection.h.

Referenced by RedirectLocation().

boost::asio::const_buffers_1 ImageServerConnection::_responseNotFound = boost::asio::buffer("HTTP/1.0 404 Not Found\r\n\r\n", 26)

staticprivate

Definition at line 71 of file ImageServerConnection.h.

Referenced by NotFound().

boost::asio::const_buffers_1 ImageServerConnection::_responseOK = boost::asio::buffer("HTTP/1.0 200 OK\r\nContent-Type: image/jpeg\r\n\r\n", 45)

staticprivate

Definition at line 70 of file ImageServerConnection.h.

Referenced by ProcessHeaders().

boost::asio::const_buffers_1 ImageServerConnection::_responseRedirectBegin = boost::asio::buffer("HTTP/1.0 301 Moved Permanently\r\nLocation: ", 42)

staticprivate

Definition at line 72 of file ImageServerConnection.h.

Referenced by Redirect().

boost::asio::const_buffers_1 ImageServerConnection::_responseRedirectEnd = boost::asio::buffer("\r\n\r\n", 4)

staticprivate

Definition at line 73 of file ImageServerConnection.h.

Referenced by RedirectFinalize().

uint32 ImageServerConnection::_size

private

Definition at line 63 of file ImageServerConnection.h.

Referenced by ProcessHeaders(), and RedirectLocation().

boost::asio::ip::tcp::socket ImageServerConnection::_socket

private

Definition at line 67 of file ImageServerConnection.h.

Referenced by Close(), NotFound(), Process(), ProcessHeaders(), Redirect(), RedirectFinalize(), RedirectLocation(), SendImage(), and socket().

---

The documentation for this class was generated from the following files:

• /backups/local/src/eve/EvEmu_Crucible/src/eve-server/imageserver/ImageServerConnection.h
• /backups/local/src/eve/EvEmu_Crucible/src/eve-server/imageserver/ImageServerConnection.cpp