source: trunk/src/core/RpEncode.cc @ 675

/*
 * ----------------------------------------------------------------------
 *  Rappture::encoding
 *
 *  The encoding module for rappture used to zip and b64 encode data.
 * ======================================================================
 *  AUTHOR:  Derrick Kearney, Purdue University
 *  Copyright (c) 2004-2007  Purdue Research Foundation
 *
 *  See the file "license.terms" for information on usage and
 *  redistribution of this file, and for a DISCLAIMER OF ALL WARRANTIES.
 * ======================================================================
 */
#include "RpEncode.h"

#ifdef __cplusplus
extern "C" {
#endif // ifdef __cplusplus

using namespace Rappture::encoding;

/**********************************************************************/
// FUNCTION: Rappture::encoding::isbinary()
/// isbinary checks to see if given string is binary.
/**
 * Checks to see if any of size characters in *buf are binary
 * Full function call:
 * Rappture::encoding::isbinary(buf,size);
 *
 */

int
isbinary(const char* buf, int size)
{
    int index = 0;

    if (size == -1) {
        size = strlen(buf);
    }

    for (index = 0; index < size; index++) {
        if (((buf[index] >= '\000') && (buf[index] <= '\010')) ||
            ((buf[index] >= '\013') && (buf[index] <= '\014')) ||
            ((buf[index] >= '\016') && (buf[index] <= '\037')) ||
            ((buf[index] >= '\177') && (buf[index] <= '\377')) ) {
            // data is binary
            return index+1;
        }

    }
    return 0;
}





/**********************************************************************/
// FUNCTION: Rappture::encoding::encode()
/// Rappture::encoding::encode function encodes provided string
/**
 * Encode a string by compressing it with zlib and then base64 encoding it.
 *
 * Full function call:
 * Rappture::encoding::encode(buf,flags)
 */

Rappture::Outcome
encode (Rappture::Buffer& buf, int flags)
{

    int compress              = 0;
    int base64                = 0;
    int addHeader             = 0;
    Rappture::Outcome err;
    Rappture::Buffer outData;

    if ((flags & RPENC_Z) == RPENC_Z ) {
        compress = 1;
    }
    if ((flags & RPENC_B64) == RPENC_B64 ) {
        base64 = 1;
    }
    if ((flags & RPENC_HDR) == RPENC_HDR ) {
        addHeader = 1;
    }

    outData.append(buf.bytes(),buf.size());
    err = outData.encode(compress,base64);
    if (!err) {
        buf.clear();
        if (addHeader == 1) {
            if ((compress == 1) && (base64 == 0)) {
                buf.append("@@RP-ENC:z\n",11);
            }
            else if ((compress == 0) && (base64 == 1)) {
                buf.append("@@RP-ENC:b64\n",13);
            }
            else if ((compress == 1) && (base64 == 1)) {
                buf.append("@@RP-ENC:zb64\n",14);
            }
            else {
                // do nothing
            }
        }
        else {
            // do nothing
        }
        buf.append(outData.bytes(),outData.size());
    }

    return err;
}

/**********************************************************************/
// FUNCTION: Rappture::encoding::decode()
/// Rappture::encoding::decode function decodes provided string
/**
 * Decode a string by uncompressing it with zlib and base64 decoding it.
 * If binary data is provided, the data is base64 decoded and uncompressed.
 * Rappture::encoding::isbinary is used to qualify binary data.
 *
 * Full function call:
 * Rappture::encoding::decode (buf,flags)
 */

Rappture::Outcome
decode (Rappture::Buffer& buf, int flags)
{

    int decompress            = 0;
    int base64                = 0;
    Rappture::Outcome err;
    Rappture::Buffer outData;

    if ((flags & RPENC_Z) == RPENC_Z ) {
        decompress = 1;
    }
    if ((flags & RPENC_B64) == RPENC_B64 ) {
        base64 = 1;
    }

    if ((buf.size() > 11) && (strncmp(buf.bytes(),"@@RP-ENC:z\n",11) == 0)) {
        outData.append(buf.bytes()+11,buf.size()-11);
        if ( (decompress == 0) && (base64 == 0) ) {
            decompress = 1;
            base64 = 0;
        }
    }
    else if ((buf.size() > 13) && (strncmp(buf.bytes(),"@@RP-ENC:b64\n",13) == 0)) {
        outData.append(buf.bytes()+13,buf.size()-13);
        if ( (decompress == 0) && (base64 == 0) ) {
            decompress = 0;
            base64 = 1;
        }
    }
    else if ((buf.size() > 14) && (strncmp(buf.bytes(),"@@RP-ENC:zb64\n",14) == 0)) {
        outData.append(buf.bytes()+14,buf.size()-14);
        if ( (decompress == 0) && (base64 == 0) ) {
            decompress = 1;
            base64 = 1;
        }
    }
    else {
        // no special recognized tags
        outData.append(buf.bytes(),buf.size());
    }

    err = outData.decode(decompress,base64);
    if (!err) {
        buf.move(outData);
    }

    return err;
}

#ifdef __cplusplus
}
#endif // ifdef __cplusplus