cloudflare/ClickHouse

#include <unistd.h>
#include <zstd/zstd.h>
#include <vector>
#include <stdexcept>


int main(int argc, char ** argv)
{
	bool compress = argc == 1;

	const size_t size = 1048576;
	std::vector<char> src_buf(size);
	std::vector<char> dst_buf;

	size_t pos = 0;
	while (true)
	{
		ssize_t read_res = read(STDIN_FILENO, &src_buf[pos], size - pos);
		if (read_res < 0)
			throw std::runtime_error("Cannot read from stdin");
		if (read_res == 0)
			break;
		pos += read_res;
	}

	src_buf.resize(pos);

	size_t zstd_res;

	if (compress)
	{
		dst_buf.resize(ZSTD_compressBound(src_buf.size()));

		zstd_res = ZSTD_compress(
			&dst_buf[0],
			dst_buf.size(),
			&src_buf[0],
			src_buf.size(),
			1);
	}
	else
	{
		dst_buf.resize(size);

		zstd_res = ZSTD_decompress(
			&dst_buf[0],
			dst_buf.size(),
			&src_buf[0],
			src_buf.size());
	}

	if (ZSTD_isError(zstd_res))
		throw std::runtime_error(ZSTD_getErrorName(zstd_res));

	dst_buf.resize(zstd_res);

	pos = 0;
	while (pos < dst_buf.size())
	{
		ssize_t write_res = write(STDOUT_FILENO, &dst_buf[pos], dst_buf.size());
		if (write_res <= 0)
			throw std::runtime_error("Cannot write to stdout");
		pos += write_res;
	}

	return 0;
}