/*
 * Copyright (C) 2018 Intel Corporation
 * SPDX-License-Identifier: BSD-3-Clause
 */

#ifndef __LOAD_CONF_H__
#define __LOAD_CONF_H__

#include <stdio.h>
#include <sys/queue.h>
#include <ext2fs/ext2fs.h>
#include "event_queue.h"
#include "probeutils.h"
#include "vmrecord.h"

#define CONTENT_MAX 10
#define EXPRESSION_MAX 5
#define LOG_MAX 20
#define TRIGGER_MAX 20
#define SENDER_MAX 3
#define DATA_MAX 3
#define CRASH_MAX 20
#define INFO_MAX 20
#define VM_MAX 4
#define VM_EVENT_TYPE_MAX 20

struct trigger_t {
	int		id;
	const char	*name;
	size_t		name_len;
	const char	*type;
	size_t		type_len;
	const char	*path;
	size_t		path_len;
};

struct vm_t {
	int		id;
	const char	*name;
	size_t		name_len;
	const char	*channel;
	size_t		channel_len;
	const char	*interval;
	size_t		interval_len;
	const char	*syncevent[VM_EVENT_TYPE_MAX];
	size_t		syncevent_len[VM_EVENT_TYPE_MAX];

	ext2_filsys	datafs;
	unsigned long	history_size[SENDER_MAX];
	char		*history_data;
	char		last_evt_detected[SENDER_MAX][SHORT_KEY_LENGTH + 1];
};

struct log_t {
	int		id;
	const char	*name;
	size_t		name_len;
	const char	*type;
	size_t		type_len;
	const char	*path;
	size_t		path_len;
	const char	*lines;
	size_t		lines_len;
	const char	*deletesource;
	size_t		deletesource_len;
	const char	*sizelimit;
	size_t		sizelimit_len;

	void (*get)(struct log_t *, void *);
};

struct crash_t {
	int		id;
	const char	*name;
	size_t		name_len;
	const char	*channel;
	size_t		channel_len;
	const char	*interval;
	size_t		interval_len;
	struct trigger_t *trigger;
	const char	*content[CONTENT_MAX];
	size_t		content_len[CONTENT_MAX];
	const char	*mightcontent[EXPRESSION_MAX][CONTENT_MAX];
	size_t		mightcontent_len[EXPRESSION_MAX][CONTENT_MAX];
	struct log_t	*log[LOG_MAX];
	const char	*data[DATA_MAX];
	size_t		data_len[DATA_MAX];

	struct crash_t	*parents;

	TAILQ_ENTRY(crash_t) entries;
	TAILQ_HEAD(, crash_t) children;

	int wd;
	int level;
	struct crash_t *(*reclassify)(const struct crash_t *, const char*,
					char**, size_t *);
};

struct info_t {
	int		id;
	const char	*name;
	size_t		name_len;
	const char	*channel;
	size_t		channel_len;
	const char	*interval;
	size_t		interval_len;
	struct trigger_t *trigger;
	struct log_t	*log[LOG_MAX];
};

struct uptime_t {
	const char	*name;
	size_t		name_len;
	const char	*frequency;
	size_t		frequency_len;
	const char	*eventhours;
	size_t		eventhours_len;

	int wd;
	char *path;
};

struct sender_t {
	int		id;
	const char	*name;
	size_t		name_len;
	const char	*outdir;
	size_t		outdir_len;
	const char	*maxcrashdirs;
	size_t		maxcrashdirs_len;
	const char	*maxlines;
	size_t		maxlines_len;
	const char	*spacequota;
	size_t		spacequota_len;
	const char	*foldersize;
	size_t		foldersize_len;
	struct uptime_t *uptime;

	void (*send)(struct event_t *);
	struct vmrecord_t vmrecord;
	size_t		outdir_blocks_size;
	int		sw_updated; /* each sender has their own record */
};

struct conf_t {
	struct sender_t *sender[SENDER_MAX];
	struct vm_t	*vm[VM_MAX];
	struct trigger_t *trigger[TRIGGER_MAX];
	struct log_t	*log[LOG_MAX];
	struct crash_t	*crash[CRASH_MAX];
	struct info_t	*info[INFO_MAX];
};

struct conf_t conf;

#define for_each_sender(id, sender, conf) \
		for (id = 0; \
		     id < SENDER_MAX && (sender = conf.sender[id]); \
		     id++)

#define for_each_trigger(id, trigger, conf) \
		for (id = 0; \
		     id < TRIGGER_MAX && (trigger = conf.trigger[id]); \
		     id++)

#define for_each_vm(id, vm, conf) \
		for (id = 0; \
		     id < VM_MAX && (vm = conf.vm[id]); \
		     id++)

#define for_each_syncevent_vm(id, event, vm) \
		for (id = 0; \
		     id < VM_EVENT_TYPE_MAX && (event = vm->syncevent[id]); \
		     id++)

#define for_each_info(id, info, conf) \
		for (id = 0; \
		     id < INFO_MAX && (info = conf.info[id]); \
		     id++)

#define for_each_log(id, log, conf) \
		for (id = 0; \
		     id < LOG_MAX && (log = conf.log[id]); \
		     id++)

#define for_each_crash(id, crash, conf) \
		for (id = 0; \
		     id < CRASH_MAX && (crash = conf.crash[id]); \
		     id++)

#define for_each_log_collect(id, log, type) \
		for (id = 0; \
		     id < LOG_MAX && (log = type->log[id]); \
		     id++)

#define for_each_content_crash(id, content, crash) \
		for (id = 0; \
		     id < CONTENT_MAX && (content = crash->content[id]); \
		     id++)

#define for_each_content_expression(id, content, exp) \
		for (id = 0; \
		     id < CONTENT_MAX && (content = exp[id]); \
		     id++)

#define exp_valid(exp) \
(__extension__ \
({ \
		int _ret = 0; \
		int _id; \
		const char *content; \
		for_each_content_expression(_id, content, exp) { \
			if (content) \
				_ret = 1; \
		} \
		_ret; \
}) \
)

#define for_each_expression_crash(id, exp, crash) \
		for (id = 0; \
		     id < EXPRESSION_MAX && (exp = crash->mightcontent[id]); \
		     id++)

#define for_crash_children(crash, tcrash) \
			TAILQ_FOREACH(crash, &tcrash->children, entries)

#define is_leaf_crash(crash) \
			(crash && TAILQ_EMPTY(&crash->children))

#define is_root_crash(crash) \
			(crash && crash->parents == NULL)

#define to_collect_logs(type) \
(__extension__ \
({ \
		int _id; \
		int _ret = 0; \
		for (_id = 0; _id < LOG_MAX; _id++) \
			if (type->log[_id]) \
				_ret = 1; \
		_ret; \
}) \
)

int load_conf(const char *path);
struct trigger_t *get_trigger_by_name(const char *name);
struct log_t *get_log_by_name(const char *name);
struct vm_t *get_vm_by_name(const char *name);
struct sender_t *get_sender_by_name(const char *name);
enum event_type_t get_conf_by_wd(int wd, void **private);
struct crash_t *get_crash_by_wd(int wd);
int crash_depth(struct crash_t *tcrash);
int cfg_atoi(const char *a, size_t alen, int *i);

#endif