#include <iostream>
#include <sstream>
#include <boost/iostreams/filtering_stream.hpp>
#include <boost/iostreams/filter/bzip2.hpp>
#include <boost/iostreams/copy.hpp>

using namespace std;
using namespace boost::iostreams;

std::string
decompressString(const uint8_t* pBegin, size_t pLen, size_t pBufSize = 4096)
{
    string input(pBegin, pBegin + pLen);
    stringstream istring(input, ios_base::in | ios_base::binary);
    filtering_istream in;
    in.push(bzip2_decompressor(false, pBufSize));
    in.push(istring);

    stringstream out(ios_base::out | ios_base::binary);
    copy(in, out);

    return out.str();
}


static uint8_t
pbzipFile[] = {
 0x42, 0x5a, 0x68, 0x39, 0x31, 0x41, 0x59, 0x26,
 0x53, 0x59, 0x63, 0xe3, 0xec, 0xa2, 0x00, 0x06,
 0xe4, 0xc1, 0x00, 0xc0, 0x00, 0x02, 0x00, 0x00,
 0x08, 0x20, 0x00, 0x30, 0xcc, 0x09, 0xaa, 0x69,
 0x94, 0xa1, 0x36, 0xa9, 0x28, 0x4f, 0x17, 0x72,
 0x45, 0x38, 0x50, 0x90, 0x63, 0xe3, 0xec, 0xa2,
 0x42, 0x5a, 0x68, 0x39, 0x31, 0x41, 0x59, 0x26,
 0x53, 0x59, 0x01, 0xe8, 0xd0, 0x60, 0x00, 0x00,
 0x01, 0xc0, 0x01, 0xc0, 0x00, 0x00, 0x80, 0x00,
 0x08, 0x20, 0x00, 0x20, 0xaa, 0x6d, 0x41, 0x98,
 0xba, 0x83, 0xc5, 0xdc, 0x91, 0x4e, 0x14, 0x24,
 0x00, 0x7a, 0x34, 0x18, 0x00
};

int
main()
{
    try {
        string output;
        output = decompressString(pbzipFile, sizeof(pbzipFile));
        cout << "Output size 1 = " << output.size() << "\n";
        output = decompressString(pbzipFile, sizeof(pbzipFile), 50);
        cout << "Output size 2 = " << output.size() << "\n";
    }
    catch (std::exception err)
    {
        cout << "Caught exception " << err.what() << "\n";
    }
}