#include <gtest/gtest.h>

#include "kafka.h"
#include "sf_metrics.h"

uuid_t rule_uuid1;
uuid_t rule_uuid2;

uuid_t sff_uuid1;
uuid_t sff_uuid2;

uuid_t sf_uuid1;
uuid_t sf_uuid2;

#if 1
TEST(SF_METRICS, TEST1)
{
	uint16_t thr_idx0 = 0;
	uint16_t thr_idx1 = 1;

	struct kafka *kfk = kafka_create("./test_resource/sce.conf");
	EXPECT_TRUE(kfk != NULL);
	struct sf_metrics *metrics = sf_metrics_create("./test_resource/sce.conf", kfk);
	EXPECT_TRUE(metrics != NULL);

	struct sf_metrics_key key1 = {0};
	key1.vsys_id = 1;
	uuid_copy(key1.rule_uuid, rule_uuid1);
	uuid_copy(key1.sff_uuid, sff_uuid1);
	uuid_copy(key1.sf_uuid, sf_uuid1);
	struct sf_metrics_key key2 = {0};
	key2.vsys_id = 4;
	uuid_copy(key2.rule_uuid, rule_uuid2);
	uuid_copy(key2.sff_uuid, sff_uuid2);
	uuid_copy(key2.sf_uuid, sf_uuid2);

	// thread 0
	// rx_pkts, rx_bytes, tx_pkts, tx_bytes);
	sf_metrics_input(metrics, thr_idx0, &key1, 1, 2, 2, 4);
	sf_metrics_input(metrics, thr_idx0, &key2, 2, 4, 1, 2);
	sf_metrics_output(metrics, thr_idx0);
	sf_metrics_reset(metrics, thr_idx0);

	printf("\n========================================\nworker thread 0 done\n========================================\n");
	sleep(3);

	// thread 1
	sf_metrics_input(metrics, thr_idx1, &key1, 2, 4, 1, 2);
	sf_metrics_input(metrics, thr_idx1, &key2, 1, 2, 2, 4);
	sf_metrics_output(metrics, thr_idx1);
	sf_metrics_reset(metrics, thr_idx1);

	printf("\n========================================\nworker thread 1 done\n========================================\n");
	sleep(3);

	sf_metrics_destory(metrics);
	kafka_destroy(kfk);
}
#endif

#if 1
TEST(SF_METRICS, TEST2)
{
	uint16_t thr_idx0 = 0;
	uint16_t thr_idx1 = 1;

	struct kafka *kfk = kafka_create("./test_resource/sce.conf");
	EXPECT_TRUE(kfk != NULL);
	struct sf_metrics *metrics = sf_metrics_create("./test_resource/sce.conf", kfk);
	EXPECT_TRUE(metrics != NULL);

	struct sf_metrics_key key1 = {0};
	key1.vsys_id = 1;
	uuid_copy(key1.rule_uuid, rule_uuid1);
	uuid_copy(key1.sff_uuid, sff_uuid1);
	uuid_copy(key1.sf_uuid, sf_uuid1);
	struct sf_metrics_key key2 = {0};
	key2.vsys_id = 4;
	uuid_copy(key2.rule_uuid, rule_uuid2);
	uuid_copy(key2.sff_uuid, sff_uuid2);
	uuid_copy(key2.sf_uuid, sf_uuid2);

	// thread 0
	// rx_pkts, rx_bytes, tx_pkts, tx_bytes);
	sf_metrics_input(metrics, thr_idx0, &key1, 1, 2, 2, 4);
	sf_metrics_input(metrics, thr_idx0, &key2, 2, 4, 1, 2);
	sf_metrics_output(metrics, thr_idx0);
	sf_metrics_reset(metrics, thr_idx0);

	printf("\n========================================\nworker thread 0 done\n========================================\n");

	// thread 1
	sf_metrics_input(metrics, thr_idx1, &key1, 2, 4, 1, 2);
	sf_metrics_input(metrics, thr_idx1, &key2, 1, 2, 2, 4);
	sf_metrics_output(metrics, thr_idx1);
	sf_metrics_reset(metrics, thr_idx1);

	printf("\n========================================\nworker thread 1 done\n========================================\n");
	sleep(3);

	sf_metrics_destory(metrics);
	kafka_destroy(kfk);
}
#endif

int main(int argc, char **argv)
{
	uuid_parse("00000000-0000-0000-0000-000000000001", rule_uuid1);
	uuid_parse("00000000-0000-0000-0000-000000000002", rule_uuid2);

	uuid_parse("00000000-0000-0000-0000-000000000003", sff_uuid1);
	uuid_parse("00000000-0000-0000-0000-000000000004", sff_uuid2);

	uuid_parse("00000000-0000-0000-0000-000000000005", sf_uuid1);
	uuid_parse("00000000-0000-0000-0000-000000000006", sf_uuid2);

	::testing::InitGoogleTest(&argc, argv);
	return RUN_ALL_TESTS();
}