metaproxy_1::filter::HttpFile::Rep Class Reference

Collaboration diagram for metaproxy_1::filter::HttpFile::Rep:

Private Types
typedef std::list< Area >	AreaList
typedef std::map< std::string, Mime >	MimeMap

Private Member Functions
void	fetch_uri (mp::Session &session, Z_HTTP_Request *req, mp::Package &package)
void	fetch_file (mp::Session &session, Z_HTTP_Request *req, std::string &fname, mp::Package &package, bool raw, bool passthru)
std::string	get_mime_type (std::string &fname)

Private Attributes
MimeMap	m_ext_to_map
AreaList	m_area_list

Friends
class	HttpFile

Detailed Description

Definition at line 62 of file filter_http_file.cpp.

Member Typedef Documentation

AreaList

typedef std::list<Area> metaproxy_1::filter::HttpFile::Rep::AreaList

private

Definition at line 65 of file filter_http_file.cpp.

MimeMap

typedef std::map<std::string,Mime> metaproxy_1::filter::HttpFile::Rep::MimeMap

private

Definition at line 66 of file filter_http_file.cpp.

Member Function Documentation

fetch_file()

void mp::filter::HttpFile::Rep::fetch_file ( mp::Session &  session, Z_HTTP_Request *  req, std::string &  fname, mp::Package &  package, bool  raw, bool  passthru  )

private

Definition at line 136 of file filter_http_file.cpp.

{
    mp::odr o(ODR_ENCODE);
 
    if (strcmp(req->method, "GET"))
    {
        if (passthru)
        {
            package.move();
        }
        else
        {
            Z_GDU *gdu = o.create_HTTP_Response(session, req, 405);
            package.response() = gdu;
        }
        return;
    }
 
    struct stat st;
    if (stat(fname.c_str(), &st) == -1 || (st.st_mode & S_IFMT) != S_IFREG)
    {
        if (passthru)
        {
            package.move();
        }
        else
        {
            Z_GDU *gdu = o.create_HTTP_Response(session, req, 404);
            package.response() = gdu;
        }
        return;
    }
 
    FILE *f = fopen(fname.c_str(), "rb");
    if (!f)
    {
        Z_GDU *gdu = o.create_HTTP_Response(session, req, 404);
        package.response() = gdu;
        return;
    }
    if (fseek(f, 0L, SEEK_END) == -1)
    {
        fclose(f);
        Z_GDU *gdu = o.create_HTTP_Response(session, req, 404);
        package.response() = gdu;
        return;
    }
    long sz = ftell(f);
    if (sz > 1000000L)
    {
        fclose(f);
        Z_GDU *gdu = o.create_HTTP_Response(session, req, 404);
        package.response() = gdu;
        return;
    }
    rewind(f);
    char *fbuf = (char*) odr_malloc(o, sz);
    if (sz > 0)
    {
        if (fread(fbuf, sz, 1, f) != 1)
        {
            Z_GDU *gdu = o.create_HTTP_Response(session, req, 500);
            package.response() = gdu;
            fclose(f);
            return;
        }
    }
    fclose(f);
 
    Z_GDU *gdu = 0;
    mp::odr decode(ODR_DECODE);
    if (raw)
    {
        odr_setbuf(decode, (char *) fbuf, sz, 0);
        int r = z_GDU(decode, &gdu, 0, 0);
        if (!r)
        {
            gdu = o.create_HTTP_Response(session, req, 500);
        }
    }
    else
    {
        gdu = o.create_HTTP_Response(session, req, 200);
        Z_HTTP_Response *hres = gdu->u.HTTP_Response;
        hres->content_len = sz;
        hres->content_buf = fbuf;
        std::string content_type = get_mime_type(fname);
        z_HTTP_header_add(o, &hres->headers,
                      "Content-Type", content_type.c_str());
    }
    package.response() = gdu;
}

fetch_uri()

void mp::filter::HttpFile::Rep::fetch_uri ( mp::Session &  session, Z_HTTP_Request *  req, mp::Package &  package  )

private

Definition at line 232 of file filter_http_file.cpp.

{
    bool sane = true;
    std::string::size_type p;
    std::string path = req->path;
 
    p = path.find("#");
    if (p != std::string::npos)
        path = path.erase(p);
 
    p = path.find("?");
    if (p != std::string::npos)
        path = path.erase(p);
 
    path = mp::util::uri_decode(path);
 
    // we don't allow ..
    p = path.find("..");
    if (p != std::string::npos)
        sane = false;
 
    if (sane)
    {
        AreaList::const_iterator it;
        for (it = m_area_list.begin(); it != m_area_list.end(); it++)
        {
            std::string::size_type l = it->m_url_path_prefix.length();
 
            if (path.compare(0, l, it->m_url_path_prefix) == 0)
            {
                std::string fname = it->m_file_root + path.substr(l);
                package.log("http_file", YLOG_LOG, "%s", fname.c_str());
                fetch_file(session, req, fname, package, it->m_raw,
                    it->m_passthru);
                return;
            }
        }
    }
    package.move();
}

get_mime_type()

std::string mp::filter::HttpFile::Rep::get_mime_type ( std::string &  fname )

private

Definition at line 113 of file filter_http_file.cpp.

{
    std::string file_part = fname;
    std::string::size_type p = fname.find_last_of('/');
 
    if (p != std::string::npos)
        file_part = fname.substr(p+1);
 
    p = file_part.find_last_of('.');
    std::string content_type;
    if (p != std::string::npos)
    {
        std::string ext = file_part.substr(p+1);
        MimeMap::const_iterator it = m_ext_to_map.find(ext);
 
        if (it != m_ext_to_map.end())
            content_type = it->second.m_type;
    }
    if (content_type.length() == 0)
        content_type = "application/octet-stream";
    return content_type;
}

Friends And Related Function Documentation

HttpFile

friend class HttpFile

friend

Definition at line 63 of file filter_http_file.cpp.

Member Data Documentation

m_area_list

AreaList metaproxy_1::filter::HttpFile::Rep::m_area_list

private

Definition at line 69 of file filter_http_file.cpp.

m_ext_to_map

MimeMap metaproxy_1::filter::HttpFile::Rep::m_ext_to_map

private

Definition at line 68 of file filter_http_file.cpp.

---

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

• filter_http_file.cpp