fluxengine/tests/proto.cc

#include "lib/core/globals.h"
#include "lib/core/bytes.h"
#include "tests/testproto.pb.h"
#include "lib/config/config.pb.h"
#include "lib/config/proto.h"
#include "snowhouse/snowhouse.h"
#include "dep/alphanum/alphanum.h"
#include <google/protobuf/text_format.h>
#include <assert.h>
#include <regex>

using namespace snowhouse;

static std::string cleanup(const std::string& s)
{
    auto outs = std::regex_replace(s, std::regex("[ \t\n]+"), " ");
    outs = std::regex_replace(outs, std::regex("^[ \t\n]+"), "");
    outs = std::regex_replace(outs, std::regex("[ \t\n]+$"), "");
    return outs;
}

static void test_setting(void)
{
    TestProto config;
    setProtoByString(&config, "i64", "-1");
    setProtoByString(&config, "i32", "-2");
    setProtoByString(&config, "u64", "3");
    setProtoByString(&config, "u32", "4");
    setProtoByString(&config, "d", "5.5");
    setProtoByString(&config, "f", "6.7");
    setProtoByString(&config, "m.s", "string");
    setProtoByString(&config, "r[0].s", "val1");
    setProtoByString(&config, "r[0].s", "val2");
    setProtoByString(&config, "r[1].s", "val3");
    setProtoByString(&config, "firstoption.s", "1");
    setProtoByString(&config, "secondoption.s", "2");

    std::string s;
    google::protobuf::TextFormat::PrintToString(config, &s);
    s = cleanup(s);
    AssertThat(s, Equals(cleanup(R"M(
		i64: -1
		i32: -2
		u64: 3
		u32: 4
		d: 5.5
		m {
			s: "string"
		}
		r {
			s: "val2"
		}
		r {
			s: "val3"
		}
		secondoption {
			s: "2"
		}
		f: 6.7
		)M")));
}

static void test_getting(void)
{
    std::string s = R"M(
		i64: -1
		i32: -2
		u64: 3
		u32: 4
		d: 5.5
		f: 6.7
		m {
			s: "string"
		}
		r {
			s: "val2"
		}
		r {
			s: "val3"
		}
		secondoption {
			s: "2"
			r: 0
			r: 1
			r: 2
		}
	)M";

    TestProto tp;
    if (!google::protobuf::TextFormat::MergeFromString(cleanup(s), &tp))
        error("couldn't load test proto");

    AssertThat(getProtoByString(&tp, "i64"), Equals("-1"));
    AssertThat(getProtoByString(&tp, "i32"), Equals("-2"));
    AssertThat(getProtoByString(&tp, "u64"), Equals("3"));
    AssertThat(getProtoByString(&tp, "u32"), Equals("4"));
    AssertThat(getProtoByString(&tp, "d"), Equals("5.5"));
    AssertThat(getProtoByString(&tp, "f"), Equals("6.7"));
    AssertThat(getProtoByString(&tp, "m.s"), Equals("string"));
    AssertThat(getProtoByString(&tp, "r[0].s"), Equals("val2"));
    AssertThat(getProtoByString(&tp, "r[1].s"), Equals("val3"));
    AssertThrows(
        ProtoPathNotFoundException, getProtoByString(&tp, "firstoption.s"));
    AssertThat(getProtoByString(&tp, "secondoption.r[2]"), Equals("2"));
    AssertThat(getProtoByString(&tp, "secondoption.s"), Equals("2"));
}

static void test_config(void)
{
    ConfigProto config;

    const std::string text = R"M(
		image_reader {
			filename: "filename"
		}

		flux_sink {
			drive { }
		}
	)M";
    google::protobuf::TextFormat::MergeFromString(text, &config);

    std::string s;
    google::protobuf::TextFormat::PrintToString(config, &s);
    AssertThat(cleanup(s), Equals(cleanup(text)));
}

static void test_load(void)
{
    extern std::string_view testproto_pb_data;

    TestProto proto;
    bool r = proto.ParseFromArray(
        testproto_pb_data.begin(), testproto_pb_data.size());

    std::string s;
    google::protobuf::TextFormat::PrintToString(proto, &s);
    s = cleanup(s);
    AssertThat(s, Equals("u64: 42 r { } secondoption { }"));
    AssertThat(r, Equals(true));
    AssertThat(proto.has_secondoption(), Equals(true));
}

static void test_fields(void)
{
    TestProto proto;
    auto fields = findAllPossibleProtoFields(proto.GetDescriptor());
    std::vector<std::string> fieldNames;
    for (const auto& e : fields)
        fieldNames.push_back(e.first);

    AssertThat(fieldNames,
        Equals(std::vector<std::string>{"d",
            "f",
            "firstoption",
            "firstoption.r[]",
            "firstoption.s",
            "i32",
            "i64",
            "m",
            "m.r[]",
            "m.s",
            "r[]",
            "r[].r[]",
            "r[].s",
            "secondoption",
            "secondoption.r[]",
            "secondoption.s",
            "u32",
            "u64"}));
}

static void test_options(void)
{
    TestProto proto;
    const auto* descriptor = proto.descriptor();
    const auto* field = descriptor->FindFieldByName("i64");
    const auto& options = field->options();
    const std::string s = options.GetExtension(help);
    AssertThat(s, Equals("i64"));
}

static void test_findallfields(void)
{
    std::string s = R"M(
		i64: -1
		i32: -2
		u64: 3
		u32: 4
		d: 5.5
		f: 6.7
		m {
			s: "string"
		}
		r {
			s: "val2"
		}
		r {
			s: "val3"
		}
		secondoption {
			s: "2"
		}
	)M";

    TestProto proto;
    if (!google::protobuf::TextFormat::MergeFromString(cleanup(s), &proto))
        error("couldn't load test proto");

    auto fields = findAllProtoFields(&proto);
    std::vector<std::string> fieldNames;
    for (const auto& e : fields)
        fieldNames.push_back(e.path());
    std::ranges::sort(fieldNames, doj::alphanum_less<std::string>());

    AssertThat(fieldNames,
        Equals(std::vector<std::string>{"d",
            "f",
            "i32",
            "i64",
            "m.s",
            "r[0].s",
            "r[1].s",
            "secondoption.s",
            "u32",
            "u64"}));
}

int main(int argc, const char* argv[])
{
    try
    {
        test_setting();
        test_getting();
        test_config();
        test_load();
        test_fields();
        test_options();
        test_findallfields();
    }
    catch (const ErrorException& e)
    {
        fmt::print("uncaught error: {}\n", e.message);
        return 1;
    }
    return 0;
}