/* SPDX-License-Identifier: LGPL-2.1-or-later */

#ifndef _OTEL_UTIL_H_
#define _OTEL_UTIL_H_

#define FLT_OTEL_HTTP_METH_DEFINES      \
	FLT_OTEL_HTTP_METH_DEF(OPTIONS) \
	FLT_OTEL_HTTP_METH_DEF(GET)     \
	FLT_OTEL_HTTP_METH_DEF(HEAD)    \
	FLT_OTEL_HTTP_METH_DEF(POST)    \
	FLT_OTEL_HTTP_METH_DEF(PUT)     \
	FLT_OTEL_HTTP_METH_DEF(DELETE)  \
	FLT_OTEL_HTTP_METH_DEF(TRACE)   \
	FLT_OTEL_HTTP_METH_DEF(CONNECT)

/* Iterate over all OTel filter configurations across all proxies. */
#define FLT_OTEL_PROXIES_LIST_START()                                           \
	do {                                                                    \
		struct flt_conf *fconf;                                         \
		struct proxy    *px;                                            \
		                                                                \
		for (px = proxies_list; px != NULL; px = px->next)              \
			list_for_each_entry(fconf, &(px->filter_configs), list) \
				if (fconf->id == otel_flt_id) {                 \
					struct flt_otel_conf *conf = fconf->conf;
#define FLT_OTEL_PROXIES_LIST_END() \
				}   \
	} while (0)

#ifdef DEBUG_OTEL
#  define FLT_OTEL_ARGS_DUMP()   do { if (otelc_dbg_level & (1 << OTELC_DBG_LEVEL_LOG)) flt_otel_args_dump((const char **)args); } while (0)
#else
#  define FLT_OTEL_ARGS_DUMP()   while (0)
#endif


#ifndef DEBUG_OTEL
#  define flt_otel_filters_dump()   while (0)
#else
/* Dump configuration arguments for debugging. */
void        flt_otel_args_dump(const char **args);

/* Dump all OTel filter configurations across all proxies. */
void        flt_otel_filters_dump(void);

/* Return a label string identifying a channel direction. */
const char *flt_otel_chn_label(const struct channel *chn);

/* Return the proxy mode string for a stream. */
const char *flt_otel_pr_mode(const struct stream *s);

/* Return the stream processing position as a string. */
const char *flt_otel_stream_pos(const struct stream *s);

/* Return the filter type string for a filter instance. */
const char *flt_otel_type(const struct filter *f);

/* Return the analyzer name string for an analyzer bit. */
const char *flt_otel_analyzer(uint an_bit);

/* Dump a linked list of configuration items as a string. */
const char *flt_otel_list_dump(const struct list *head);
#endif

/* Count the number of non-NULL arguments in an argument array. */
int         flt_otel_args_count(const char **args);

/* Concatenate argument array elements into a single string. */
int         flt_otel_args_concat(const char **args, int idx, int n, char **str);

/* Comparator for qsort: ascending order of doubles with epsilon tolerance. */
int         flt_otel_qsort_compar_double(const void *a, const void *b);

/* Parse a string to double with range validation. */
bool        flt_otel_strtod(const char *nptr, double *value, double limit_min, double limit_max, char **err);

/* Parse a string to int64_t with range validation. */
bool        flt_otel_strtoll(const char *nptr, int64_t *value, int64_t limit_min, int64_t limit_max, char **err);

/* Convert sample data to a string representation. */
int         flt_otel_sample_to_str(const struct sample_data *data, char *value, size_t size, char **err);

/* Convert sample data to an OTel value. */
int         flt_otel_sample_to_value(const char *key, const struct sample_data *data, struct otelc_value *value, char **err);

/* Add a key-value pair to a growable key-value array. */
int         flt_otel_sample_add_kv(struct flt_otel_scope_data_kv *kv, const char *key, const struct otelc_value *value);

/* Evaluate a sample definition into an OTel value. */
int         flt_otel_sample_eval(struct stream *s, uint dir, struct flt_otel_conf_sample *sample, bool flag_native, struct otelc_value *value, char **err);

/* Evaluate a sample expression and add the result to scope data. */
int         flt_otel_sample_add(struct stream *s, uint dir, struct flt_otel_conf_sample *sample, struct flt_otel_scope_data *data, int type, char **err);

#endif /* _OTEL_UTIL_H_ */

/*
 * Local variables:
 *  c-indent-level: 8
 *  c-basic-offset: 8
 * End:
 *
 * vi: noexpandtab shiftwidth=8 tabstop=8
 */