project-swan/libswan/src/SRF.cc

#include "SRF.h"

namespace Swan {

enum class Type {
	OBJECT = 0,
	ARRAY = 1,
	STRING = 2,
	BYTE = 3,
	WORD = 4,
	INT = 5,
	FLOAT = 6,
	DOUBLE = 7,
	NONE = 8,
	BYTE_ARRAY = 9,
	WORD_ARRAY = 10,
	INT_ARRAY = 11,
	FLOAT_ARRAY = 12,
	DOUBLE_ARRAY = 13,
};

static void writeByte(std::ostream &os, uint8_t val) {
	os.put(val);
}

static uint8_t readByte(std::istream &is) {
	return is.get();
}

static void writeWord(std::ostream &os, uint16_t val) {
	os.put((val & 0xff00u) >> 8);
	os.put(val & 0x00ffu);
}

static uint16_t readWord(std::istream &is) {
	return (uint16_t)(
			((uint16_t)is.get()) << 8 |
			((uint16_t)is.get()));
}

static void writeInt(std::ostream &os, int32_t val) {
	uint32_t uval = val;
	os.put((uval & 0xff000000u) << 24);
	os.put((uval & 0x00ff0000u) << 16);
	os.put((uval & 0x0000ff00u) << 8);
	os.put((uval & 0x000000ffu));
}

int32_t readInt(std::istream &is) {
	return (int32_t)(
			((uint32_t)is.get() << 24) |
			((uint32_t)is.get() << 16) |
			((uint32_t)is.get() << 8) |
			((uint32_t)is.get()));
}

static void writeFloat(std::ostream &os, float val) {
	uint32_t uval = (uint32_t)val;
	os.put((uval & 0xff000000u) << 24);
	os.put((uval & 0x00ff0000u) << 16);
	os.put((uval & 0x0000ff00u) << 8);
	os.put((uval & 0x000000ffu));
}

static float readFloat(std::istream &is) {
	return (float)(
			((uint32_t)is.get() << 24) |
			((uint32_t)is.get() << 16) |
			((uint32_t)is.get() << 8) |
			((uint32_t)is.get()));
}

static void writeDouble(std::ostream &os, double val) {
	uint64_t uval = (uint64_t)val;
	os.put((uval & 0xff00000000000000lu) << 56);
	os.put((uval & 0x00ff000000000000lu) << 48);
	os.put((uval & 0x0000ff0000000000lu) << 40);
	os.put((uval & 0x000000ff00000000lu) << 32);
	os.put((uval & 0x00000000ff000000lu) << 24);
	os.put((uval & 0x0000000000ff0000lu) << 16);
	os.put((uval & 0x000000000000ff00lu) << 8);
	os.put((uval & 0x00000000000000fflu));
}

static double readDouble(std::istream &is) {
	return (double)(
			((uint64_t)is.get() << 56) |
			((uint64_t)is.get() << 48) |
			((uint64_t)is.get() << 40) |
			((uint64_t)is.get() << 32) |
			((uint64_t)is.get() << 24) |
			((uint64_t)is.get() << 16) |
			((uint64_t)is.get() << 8) |
			((uint64_t)is.get()));
}

static void writeString(std::ostream &os, const std::string &str) {
	writeInt(os, str.size());
	os.write(str.c_str(), str.size());
}

static std::string readString(std::istream &is) {
	std::string str;
	int32_t len = readInt(is);
	str.reserve(len);
	is.read(str.data(), len);
	return str;
}

static char hexchr(uint8_t nibble) {
	if (nibble < 10)
		return (char)('0' + nibble);
	else
		return (char)('a' + (nibble - 10));
}

SRF *SRF::read(std::istream &is) {
	Type type = (Type)readByte(is);
	SRF *srf;

	switch (type) {
	case Type::OBJECT:
		srf = new SRFObject(); break;
	case Type::ARRAY:
		srf = new SRFArray(); break;
	case Type::STRING:
		srf = new SRFString(); break;
	case Type::BYTE:
		srf = new SRFByte(); break;
	case Type::WORD:
		srf = new SRFWord(); break;
	case Type::INT:
		srf = new SRFInt(); break;
	case Type::FLOAT:
		srf = new SRFFloat(); break;
	case Type::DOUBLE:
		srf = new SRFDouble(); break;
	case Type::NONE:
		srf = new SRFNone(); break;
	case Type::BYTE_ARRAY:
		srf = new SRFByteArray(); break;
	case Type::WORD_ARRAY:
		srf = new SRFWordArray(); break;
	case Type::INT_ARRAY:
		srf = new SRFIntArray(); break;
	case Type::FLOAT_ARRAY:
		srf = new SRFFloatArray(); break;
	case Type::DOUBLE_ARRAY:
		srf = new SRFDoubleArray(); break;
	}

	srf->parse(is);
	return srf;
}

std::ostream &operator<<(std::ostream &os, const SRF &srf) {
	srf.pretty(os);
	return os;
}

SRFObject::SRFObject(std::initializer_list<std::pair<std::string, SRF *>> lst) {
	for (auto &[k, v]: lst)
		val[k] = std::unique_ptr<SRF>(v);
}

void SRFObject::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::OBJECT);
	writeInt(os, val.size());

	for (auto &[k, v]: val) {
		writeString(os, k);
		v->serialize(os);
	}
}

void SRFObject::parse(std::istream &is) {
	int32_t count = readInt(is);

	for (int32_t i = 0; i < count; ++i) {
		std::string key = readString(is);
		val[key] = std::unique_ptr<SRF>(SRF::read(is));
	}
}

std::ostream &SRFObject::pretty(std::ostream &os) const {
	os << "{ ";
	bool first = true;
	for (auto &[k, v]: val) {
		if (!first)
			os << ", ";

		os << '\'' << k << "': ";
		v->pretty(os);
		first = false;
	}

	return os << " }";
}

SRFArray::SRFArray(std::initializer_list<SRF *> lst) {
	for (auto &v: lst)
		val.push_back(std::unique_ptr<SRF>(v));
}

void SRFArray::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::ARRAY);
	writeInt(os, val.size());

	for (auto &v: val) {
		v->serialize(os);
	}
}

void SRFArray::parse(std::istream &is) {
	int32_t count = readInt(is);
	val.resize(count);

	for (int32_t i = 0; i < count; ++i) {
		val[i] = std::unique_ptr<SRF>(SRF::read(is));
	}
}

std::ostream &SRFArray::pretty(std::ostream &os) const {
	os << "[ ";
	bool first = true;
	for (auto &v: val) {
		if (!first)
			os << ", ";

		v->pretty(os);
		first = false;
	}

	return os << " ]";
}

void SRFString::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::STRING);
	writeString(os, val);
}

void SRFString::parse(std::istream &is) {
	val = readString(is);
}

std::ostream &SRFString::pretty(std::ostream &os) const {
	return os << '"' << val << '"';
}

void SRFByte::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::BYTE);
	writeByte(os, val);
}

void SRFByte::parse(std::istream &is) {
	val = readByte(is);
}

std::ostream &SRFByte::pretty(std::ostream &os) const {
	return os << "0x"
		<< hexchr((val & 0xf0) >> 4)
		<< hexchr((val & 0x0f) >> 0);
}

void SRFWord::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::WORD);
	writeWord(os, val);
}

void SRFWord::parse(std::istream &is) {
	val = readWord(is);
}

std::ostream &SRFWord::pretty(std::ostream &os) const {
	return os << "0x"
		<< hexchr((val & 0xf000) >> 12)
		<< hexchr((val & 0x0f00) >> 8)
		<< hexchr((val & 0x00f0) >> 4)
		<< hexchr((val & 0x000f) >> 0);
}

void SRFInt::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::INT);
	writeInt(os, val);
}

void SRFInt::parse(std::istream &is) {
	val = readInt(is);
}

std::ostream &SRFInt::pretty(std::ostream &os) const {
	return os << val;
}

void SRFFloat::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::FLOAT);
	writeFloat(os, val);
}

void SRFFloat::parse(std::istream &is) {
	val = readFloat(is);
}

std::ostream &SRFFloat::pretty(std::ostream &os) const {
	return os << val;
}

void SRFDouble::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::DOUBLE);
	writeDouble(os, val);
}

void SRFDouble::parse(std::istream &is) {
	val = readDouble(is);
}

std::ostream &SRFDouble::pretty(std::ostream &os) const {
	return os << val;
}

void SRFNone::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::NONE);
}

void SRFNone::parse(std::istream &is) {}

std::ostream &SRFNone::pretty(std::ostream &os) const {
	return os << "(null)";
}

void SRFByteArray::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::BYTE_ARRAY);
	writeInt(os, val.size());
	os.write((const char *)val.data(), val.size());
}

void SRFByteArray::parse(std::istream &is) {
	int32_t count = readInt(is);
	val.resize(count);
	is.read((char *)val.data(), count);
}

std::ostream &SRFByteArray::pretty(std::ostream &os) const {
	os << "byte[ " << std::hex;
	for (auto v: val) {
		os
			<< hexchr((v & 0xf0) >> 4)
			<< hexchr((v & 0x0f) >> 0) << ' ';
	}

	return os << ']';
}

void SRFWordArray::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::WORD_ARRAY);
	writeInt(os, val.size());

	for (auto &v: val) {
		writeWord(os, v);
	}
}

void SRFWordArray::parse(std::istream &is) {
	int32_t count = readInt(is);
	val.resize(count);

	for (int32_t i = 0; i < count; ++i) {
		val[i] = readWord(is);
	}
}

std::ostream &SRFWordArray::pretty(std::ostream &os) const {
	os << "word[ ";
	for (auto v: val) {
		os
			<< hexchr((v & 0xf000) >> 12)
			<< hexchr((v & 0x0f00) >> 8)
			<< hexchr((v & 0x00f0) >> 4)
			<< hexchr((v & 0x000f) >> 0)
			<< ' ';
	}

	return os << ']';
}

void SRFIntArray::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::INT_ARRAY);
	writeInt(os, val.size());

	for (auto &v: val) {
		writeInt(os, v);
	}
}

void SRFIntArray::parse(std::istream &is) {
	int32_t count = readInt(is);
	val.resize(count);

	for (int32_t i = 0; i < count; ++i) {
		val[i] = readInt(is);
	}
}

std::ostream &SRFIntArray::pretty(std::ostream &os) const {
	os << "int[ ";
	for (auto v: val) {
		os << v << ' ';
	}

	return os << ']';
}

void SRFFloatArray::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::FLOAT_ARRAY);
	writeInt(os, val.size());

	for (auto &v: val) {
		writeFloat(os, v);
	}
}

void SRFFloatArray::parse(std::istream &is) {
	int32_t count = readInt(is);
	val.resize(count);

	for (int32_t i = 0; i < count; ++i) {
		val[i] = readFloat(is);
	}
}

std::ostream &SRFFloatArray::pretty(std::ostream &os) const {
	os << "float[ ";
	for (auto v: val) {
		os << v << ' ';
	}

	return os << ']';
}

void SRFDoubleArray::serialize(std::ostream &os) const {
	writeByte(os, (uint8_t)Type::DOUBLE_ARRAY);
	writeInt(os, val.size());

	for (auto &v: val) {
		writeDouble(os, v);
	}
}

void SRFDoubleArray::parse(std::istream &is) {
	int32_t count = readInt(is);
	val.resize(count);

	for (int32_t i = 0; i < count; ++i) {
		val[i] = readDouble(is);
	}
}

std::ostream &SRFDoubleArray::pretty(std::ostream &os) const {
	os << "double[ ";
	for (auto v: val) {
		os << v << ' ';
	}

	return os << ']';
}

}