[Rework] Rewrite rspamc in C++

3 files changed, 2089 insertions, 2130 deletions

diff --git a/src/client/CMakeLists.txt b/src/client/CMakeLists.txt
index 60e422dbd..edf3cc1c4 100644
--- a/src/client/CMakeLists.txt
+++ b/src/client/CMakeLists.txt
@@ -2,7 +2,7 @@
 SET(LIBRSPAMDCLIENTSRC			rspamdclient.c)
 
 # rspamc
-SET(RSPAMCSRC			  rspamc.c)
+SET(RSPAMCSRC rspamc.cxx)
 
 ADD_EXECUTABLE(rspamc ${RSPAMCSRC} ${LIBRSPAMDCLIENTSRC})
 SET_TARGET_PROPERTIES(rspamc PROPERTIES COMPILE_FLAGS "-I${CMAKE_SOURCE_DIR}/lib")
diff --git a/src/client/rspamc.c b/src/client/rspamc.c
deleted file mode 100644
index 20886f933..000000000
--- a/src/client/rspamc.c
+++ /dev/null
@@ -1,2129 +0,0 @@
-/*-
- * Copyright 2016 Vsevolod Stakhov
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *   http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-#include "config.h"
-#include "libutil/util.h"
-#include "libserver/http/http_connection.h"
-#include "libserver/http/http_private.h"
-#include "libserver/cfg_file.h"
-#include "rspamdclient.h"
-#include "utlist.h"
-#include "unix-std.h"
-#ifdef HAVE_SYS_WAIT_H
-#include <sys/wait.h>
-#endif
-
-#define DEFAULT_PORT 11333
-#define DEFAULT_CONTROL_PORT 11334
-
-static gchar *connect_str = "localhost";
-static gchar *password = NULL;
-static gchar *ip = NULL;
-static gchar *from = NULL;
-static gchar *deliver_to = NULL;
-static gchar **rcpts = NULL;
-static gchar *user = NULL;
-static gchar *helo = NULL;
-static gchar *hostname = NULL;
-static gchar *classifier = NULL;
-static gchar *local_addr = NULL;
-static gchar *execute = NULL;
-static gchar *sort = NULL;
-static gchar **http_headers = NULL;
-static gchar **exclude_patterns = NULL;
-static gint weight = 0;
-static gint flag = 0;
-static gchar *fuzzy_symbol = NULL;
-static gchar *dictionary = NULL;
-static gint max_requests = 8;
-static gdouble timeout = 10.0;
-static gboolean pass_all;
-static gboolean tty = FALSE;
-static gboolean verbose = FALSE;
-static gboolean print_commands = FALSE;
-static gboolean json = FALSE;
-static gboolean compact = FALSE;
-static gboolean headers = FALSE;
-static gboolean raw = FALSE;
-static gboolean ucl_reply = FALSE;
-static gboolean extended_urls = FALSE;
-static gboolean mime_output = FALSE;
-static gboolean empty_input = FALSE;
-static gboolean compressed = FALSE;
-static gboolean profile = FALSE;
-static gboolean skip_images = FALSE;
-static gboolean skip_attachments = FALSE;
-static gchar *key = NULL;
-static gchar *user_agent = "rspamc";
-static GList *children;
-static GPatternSpec **exclude_compiled = NULL;
-static struct rspamd_http_context *http_ctx;
-
-static gint retcode = EXIT_SUCCESS;
-
-#define ADD_CLIENT_HEADER(o, n, v) do { \
-    struct rspamd_http_client_header *nh; \
-    nh = g_malloc (sizeof (*nh)); \
-    nh->name = g_strdup (n); \
-    nh->value = g_strdup (v); \
-    g_queue_push_tail ((o), nh); \
-} while (0)
-
-#define ADD_CLIENT_FLAG(str, n) do { \
-   g_string_append ((str), n ","); \
-} while (0)
-
-static gboolean rspamc_password_callback (const gchar *option_name,
-		const gchar *value,
-		gpointer data,
-		GError **error);
-
-static GOptionEntry entries[] =
-{
-	{ "connect", 'h', 0, G_OPTION_ARG_STRING, &connect_str,
-	  "Specify host and port", NULL },
-	{ "password", 'P', G_OPTION_FLAG_OPTIONAL_ARG, G_OPTION_ARG_CALLBACK,
-	  &rspamc_password_callback, "Specify control password", NULL },
-	{ "classifier", 'c', 0, G_OPTION_ARG_STRING, &classifier,
-	  "Classifier to learn spam or ham", NULL },
-	{ "weight", 'w', 0, G_OPTION_ARG_INT, &weight,
-	  "Weight for fuzzy operations", NULL },
-	{ "flag", 'f', 0, G_OPTION_ARG_INT, &flag, "Flag for fuzzy operations",
-	  NULL },
-	{ "pass-all", 'p', 0, G_OPTION_ARG_NONE, &pass_all, "Pass all filters",
-	  NULL },
-	{ "verbose", 'v', 0, G_OPTION_ARG_NONE, &verbose, "More verbose output",
-	  NULL },
-	{ "ip", 'i', 0, G_OPTION_ARG_STRING, &ip,
-	  "Emulate that message was received from specified ip address",
-	  NULL },
-	{ "user", 'u', 0, G_OPTION_ARG_STRING, &user,
-	  "Emulate that message was received from specified authenticated user", NULL },
-	{ "deliver", 'd', 0, G_OPTION_ARG_STRING, &deliver_to,
-	  "Emulate that message is delivered to specified user (for LDA/statistics)", NULL },
-	{ "from", 'F', 0, G_OPTION_ARG_STRING, &from,
-	  "Emulate that message has specified SMTP FROM address", NULL },
-	{ "rcpt", 'r', 0, G_OPTION_ARG_STRING_ARRAY, &rcpts,
-	  "Emulate that message has specified SMTP RCPT address", NULL },
-	{ "helo", 0, 0, G_OPTION_ARG_STRING, &helo,
-	  "Imitate SMTP HELO passing from MTA", NULL },
-	{ "hostname", 0, 0, G_OPTION_ARG_STRING, &hostname,
-	  "Imitate hostname passing from MTA", NULL },
-	{ "timeout", 't', 0, G_OPTION_ARG_DOUBLE, &timeout,
-	  "Time in seconds to wait for a reply", NULL },
-	{ "bind", 'b', 0, G_OPTION_ARG_STRING, &local_addr,
-	  "Bind to specified ip address", NULL },
-	{ "commands", 0, 0, G_OPTION_ARG_NONE, &print_commands,
-	  "List available commands", NULL },
-	{ "json", 'j', 0, G_OPTION_ARG_NONE, &json, "Output json reply", NULL },
-	{ "compact", '\0', 0, G_OPTION_ARG_NONE, &compact, "Output compact json reply", NULL},
-	{ "headers", 0, 0, G_OPTION_ARG_NONE, &headers, "Output HTTP headers",
-	  NULL },
-	{ "raw", 0, 0, G_OPTION_ARG_NONE, &raw, "Input is a raw file, not an email file",
-	  NULL },
-	{ "ucl", 0, 0, G_OPTION_ARG_NONE, &ucl_reply, "Output ucl reply from rspamd",
-	  NULL },
-	{ "max-requests", 'n', 0, G_OPTION_ARG_INT, &max_requests,
-	  "Maximum count of parallel requests to rspamd", NULL },
-	{ "extended-urls", 0, 0, G_OPTION_ARG_NONE, &extended_urls,
-	   "Output urls in extended format", NULL },
-	{ "key", 0, 0, G_OPTION_ARG_STRING, &key,
-	   "Use specified pubkey to encrypt request", NULL },
-	{ "exec", 'e', 0, G_OPTION_ARG_STRING, &execute,
-	   "Execute the specified command and pass output to it", NULL },
-	{ "mime", 'm', 0, G_OPTION_ARG_NONE, &mime_output,
-	   "Write mime body of message with headers instead of just a scan's result", NULL },
-	{"header", 0, 0, G_OPTION_ARG_STRING_ARRAY, &http_headers,
-		"Add custom HTTP header to query (can be repeated)", NULL},
-	{"exclude", 0, 0, G_OPTION_ARG_STRING_ARRAY, &exclude_patterns,
-		"Exclude specific glob patterns in file names (can be repeated)", NULL},
-	{"sort", 0, 0, G_OPTION_ARG_STRING, &sort,
-		"Sort output in a specific order (name, weight, frequency, hits)", NULL},
-	{ "empty", 'E', 0, G_OPTION_ARG_NONE, &empty_input,
-	   "Allow empty input instead of reading from stdin", NULL },
-	{ "fuzzy-symbol", 'S', 0, G_OPTION_ARG_STRING, &fuzzy_symbol,
-	   "Learn the specified fuzzy symbol", NULL },
-	{ "compressed", 'z', 0, G_OPTION_ARG_NONE, &compressed,
-	   "Enable zstd compression", NULL },
-	{ "profile", '\0', 0, G_OPTION_ARG_NONE, &profile,
-	   "Profile symbols execution time", NULL },
-	{ "dictionary", 'D', 0, G_OPTION_ARG_FILENAME, &dictionary,
-	   "Use dictionary to compress data", NULL },
-	{ "skip-images", '\0', 0, G_OPTION_ARG_NONE, &skip_images,
-	   "Skip images when learning/unlearning fuzzy", NULL },
-	{ "skip-attachments", '\0', 0, G_OPTION_ARG_NONE, &skip_attachments,
-	   "Skip attachments when learning/unlearning fuzzy", NULL },
-	{ "user-agent", 'U', 0, G_OPTION_ARG_STRING, &user_agent,
-	   "Use specific User-Agent instead of \"rspamc\"", NULL },
-	{ NULL, 0, 0, G_OPTION_ARG_NONE, NULL, NULL, NULL }
-};
-
-static void rspamc_symbols_output (FILE *out, ucl_object_t *obj);
-static void rspamc_uptime_output (FILE *out, ucl_object_t *obj);
-static void rspamc_counters_output (FILE *out, ucl_object_t *obj);
-static void rspamc_stat_output (FILE *out, ucl_object_t *obj);
-
-enum rspamc_command_type {
-	RSPAMC_COMMAND_UNKNOWN = 0,
-	RSPAMC_COMMAND_CHECK,
-	RSPAMC_COMMAND_SYMBOLS,
-	RSPAMC_COMMAND_LEARN_SPAM,
-	RSPAMC_COMMAND_LEARN_HAM,
-	RSPAMC_COMMAND_FUZZY_ADD,
-	RSPAMC_COMMAND_FUZZY_DEL,
-	RSPAMC_COMMAND_FUZZY_DELHASH,
-	RSPAMC_COMMAND_STAT,
-	RSPAMC_COMMAND_STAT_RESET,
-	RSPAMC_COMMAND_COUNTERS,
-	RSPAMC_COMMAND_UPTIME,
-	RSPAMC_COMMAND_ADD_SYMBOL,
-	RSPAMC_COMMAND_ADD_ACTION
-};
-
-struct rspamc_command {
-	enum rspamc_command_type cmd;
-	const char *name;
-	const char *description;
-	const char *path;
-	gboolean is_controller;
-	gboolean is_privileged;
-	gboolean need_input;
-	void (*command_output_func)(FILE *, ucl_object_t *obj);
-} rspamc_commands[] = {
-	{
-		.cmd = RSPAMC_COMMAND_SYMBOLS,
-		.name = "symbols",
-		.path = "checkv2",
-		.description = "scan message and show symbols (default command)",
-		.is_controller = FALSE,
-		.is_privileged = FALSE,
-		.need_input = TRUE,
-		.command_output_func = rspamc_symbols_output
-	},
-	{
-		.cmd = RSPAMC_COMMAND_LEARN_SPAM,
-		.name = "learn_spam",
-		.path = "learnspam",
-		.description = "learn message as spam",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = TRUE,
-		.command_output_func = NULL
-	},
-	{
-		.cmd = RSPAMC_COMMAND_LEARN_HAM,
-		.name = "learn_ham",
-		.path = "learnham",
-		.description = "learn message as ham",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = TRUE,
-		.command_output_func = NULL
-	},
-	{
-		.cmd = RSPAMC_COMMAND_FUZZY_ADD,
-		.name = "fuzzy_add",
-		.path = "fuzzyadd",
-		.description =
-			"add hashes from a message to the fuzzy storage (check -f and -w options for this command)",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = TRUE,
-		.command_output_func = NULL
-	},
-	{
-		.cmd = RSPAMC_COMMAND_FUZZY_DEL,
-		.name = "fuzzy_del",
-		.path = "fuzzydel",
-		.description =
-			"delete hashes from a message from the fuzzy storage (check -f option for this command)",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = TRUE,
-		.command_output_func = NULL
-	},
-	{
-		.cmd = RSPAMC_COMMAND_FUZZY_DELHASH,
-		.name = "fuzzy_delhash",
-		.path = "fuzzydelhash",
-		.description =
-			"delete a hash from fuzzy storage (check -f option for this command)",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = FALSE,
-		.command_output_func = NULL
-	},
-	{
-		.cmd = RSPAMC_COMMAND_STAT,
-		.name = "stat",
-		.path = "stat",
-		.description = "show rspamd statistics",
-		.is_controller = TRUE,
-		.is_privileged = FALSE,
-		.need_input = FALSE,
-		.command_output_func = rspamc_stat_output,
-	},
-	{
-		.cmd = RSPAMC_COMMAND_STAT_RESET,
-		.name = "stat_reset",
-		.path = "statreset",
-		.description = "show and reset rspamd statistics (useful for graphs)",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = FALSE,
-		.command_output_func = rspamc_stat_output
-	},
-	{
-		.cmd = RSPAMC_COMMAND_COUNTERS,
-		.name = "counters",
-		.path = "counters",
-		.description = "display rspamd symbols statistics",
-		.is_controller = TRUE,
-		.is_privileged = FALSE,
-		.need_input = FALSE,
-		.command_output_func = rspamc_counters_output
-	},
-	{
-		.cmd = RSPAMC_COMMAND_UPTIME,
-		.name = "uptime",
-		.path = "auth",
-		.description = "show rspamd uptime",
-		.is_controller = TRUE,
-		.is_privileged = FALSE,
-		.need_input = FALSE,
-		.command_output_func = rspamc_uptime_output
-	},
-	{
-		.cmd = RSPAMC_COMMAND_ADD_SYMBOL,
-		.name = "add_symbol",
-		.path = "addsymbol",
-		.description = "add or modify symbol settings in rspamd",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = FALSE,
-		.command_output_func = NULL
-	},
-	{
-		.cmd = RSPAMC_COMMAND_ADD_ACTION,
-		.name = "add_action",
-		.path = "addaction",
-		.description = "add or modify action settings",
-		.is_controller = TRUE,
-		.is_privileged = TRUE,
-		.need_input = FALSE,
-		.command_output_func = NULL
-	}
-};
-
-struct rspamc_callback_data {
-	struct rspamc_command *cmd;
-	gchar *filename;
-};
-
-gboolean
-rspamc_password_callback (const gchar *option_name,
-		const gchar *value,
-		gpointer data,
-		GError **error)
-{
-	guint plen = 8192;
-	guint8 *map, *end;
-	gsize sz;
-
-	if (value != NULL) {
-		if (value[0] == '/' || value[0] == '.') {
-			/* Try to open file */
-			map = rspamd_file_xmap (value, PROT_READ, &sz, 0);
-
-			if (map == NULL) {
-				/* Just use it as a string */
-				password = g_strdup (value);
-			}
-			else {
-				/* Strip trailing spaces */
-				g_assert (sz > 0);
-				end = map + sz - 1;
-
-				while (g_ascii_isspace (*end) && end > map) {
-					end --;
-				}
-
-				end ++;
-				password = g_malloc (end - map + 1);
-				rspamd_strlcpy (password, map, end - map + 1);
-				munmap (map, sz);
-			}
-		}
-		else {
-			password = g_strdup (value);
-		}
-	}
-	else {
-		/* Read password from console */
-		password = g_malloc0 (plen);
-		plen = rspamd_read_passphrase (password, plen, 0, NULL);
-	}
-
-	if (plen == 0) {
-		rspamd_fprintf (stderr, "Invalid password\n");
-		exit (EXIT_FAILURE);
-	}
-
-	return TRUE;
-}
-
-/*
- * Parse command line
- */
-static void
-read_cmd_line (gint *argc, gchar ***argv)
-{
-	GError *error = NULL;
-	GOptionContext *context;
-
-	/* Prepare parser */
-	context = g_option_context_new ("- run rspamc client");
-	g_option_context_set_summary (context,
-		"Summary:\n  Rspamd client version " RVERSION "\n  Release id: " RID);
-	g_option_context_add_main_entries (context, entries, NULL);
-
-	/* Parse options */
-	if (!g_option_context_parse (context, argc, argv, &error)) {
-		fprintf (stderr, "option parsing failed: %s\n", error->message);
-		g_option_context_free (context);
-		exit (EXIT_FAILURE);
-	}
-
-	if (json || compact) {
-		ucl_reply = TRUE;
-	}
-	/* Argc and argv are shifted after this function */
-	g_option_context_free (context);
-}
-
-static gboolean
-rspamd_action_from_str_rspamc (const gchar *data, gint *result)
-{
-	if (strcmp (data, "reject") == 0) {
-		*result = METRIC_ACTION_REJECT;
-	}
-	else if (strcmp (data, "greylist") == 0) {
-		*result = METRIC_ACTION_GREYLIST;
-	}
-	else if (strcmp (data, "add_header") == 0) {
-		*result = METRIC_ACTION_ADD_HEADER;
-	}
-	else if (strcmp (data, "rewrite_subject") == 0) {
-		*result = METRIC_ACTION_REWRITE_SUBJECT;
-	}
-	else if (strcmp (data, "add header") == 0) {
-		*result = METRIC_ACTION_ADD_HEADER;
-	}
-	else if (strcmp (data, "rewrite subject") == 0) {
-		*result = METRIC_ACTION_REWRITE_SUBJECT;
-	}
-	else if (strcmp (data, "soft_reject") == 0) {
-		*result = METRIC_ACTION_SOFT_REJECT;
-	}
-	else if (strcmp (data, "soft reject") == 0) {
-		*result = METRIC_ACTION_SOFT_REJECT;
-	}
-	else if (strcmp (data, "no_action") == 0) {
-		*result = METRIC_ACTION_NOACTION;
-	}
-	else if (strcmp (data, "no action") == 0) {
-		*result = METRIC_ACTION_NOACTION;
-	}
-	else {
-		return FALSE;
-	}
-	return TRUE;
-}
-
-/*
- * Check rspamc command from string (used for arguments parsing)
- */
-static struct rspamc_command *
-check_rspamc_command (const gchar *cmd)
-{
-	enum rspamc_command_type ct = 0;
-	guint i;
-
-	if (g_ascii_strcasecmp (cmd, "SYMBOLS") == 0 ||
-		g_ascii_strcasecmp (cmd, "CHECK") == 0 ||
-		g_ascii_strcasecmp (cmd, "REPORT") == 0) {
-		/* These all are symbols, don't use other commands */
-		ct = RSPAMC_COMMAND_SYMBOLS;
-	}
-	else if (g_ascii_strcasecmp (cmd, "LEARN_SPAM") == 0) {
-		ct = RSPAMC_COMMAND_LEARN_SPAM;
-	}
-	else if (g_ascii_strcasecmp (cmd, "LEARN_HAM") == 0) {
-		ct = RSPAMC_COMMAND_LEARN_HAM;
-	}
-	else if (g_ascii_strcasecmp (cmd, "FUZZY_ADD") == 0) {
-		ct = RSPAMC_COMMAND_FUZZY_ADD;
-	}
-	else if (g_ascii_strcasecmp (cmd, "FUZZY_DEL") == 0) {
-		ct = RSPAMC_COMMAND_FUZZY_DEL;
-	}
-	else if (g_ascii_strcasecmp (cmd, "FUZZY_DELHASH") == 0) {
-		ct = RSPAMC_COMMAND_FUZZY_DELHASH;
-	}
-	else if (g_ascii_strcasecmp (cmd, "STAT") == 0) {
-		ct = RSPAMC_COMMAND_STAT;
-	}
-	else if (g_ascii_strcasecmp (cmd, "STAT_RESET") == 0) {
-		ct = RSPAMC_COMMAND_STAT_RESET;
-	}
-	else if (g_ascii_strcasecmp (cmd, "COUNTERS") == 0) {
-		ct = RSPAMC_COMMAND_COUNTERS;
-	}
-	else if (g_ascii_strcasecmp (cmd, "UPTIME") == 0) {
-		ct = RSPAMC_COMMAND_UPTIME;
-	}
-	else if (g_ascii_strcasecmp (cmd, "ADD_SYMBOL") == 0) {
-		ct = RSPAMC_COMMAND_ADD_SYMBOL;
-	}
-	else if (g_ascii_strcasecmp (cmd, "ADD_ACTION") == 0) {
-		ct = RSPAMC_COMMAND_ADD_ACTION;
-	}
-
-	for (i = 0; i < G_N_ELEMENTS (rspamc_commands); i++) {
-		if (rspamc_commands[i].cmd == ct) {
-			return &rspamc_commands[i];
-		}
-	}
-
-	return NULL;
-}
-
-static void
-print_commands_list (void)
-{
-	guint i;
-	guint cmd_len = 0;
-	gchar fmt_str[32];
-
-	rspamd_fprintf (stdout, "Rspamc commands summary:\n");
-
-	for (i = 0; i < G_N_ELEMENTS (rspamc_commands); i++) {
-		gsize clen = strlen (rspamc_commands[i].name);
-
-		if (clen > cmd_len) {
-			cmd_len = clen;
-		}
-	}
-
-	rspamd_snprintf (fmt_str, sizeof (fmt_str), "  %%%ds (%%7s%%1s)\t%%s\n",
-			cmd_len);
-
-	for (i = 0; i < G_N_ELEMENTS (rspamc_commands); i++) {
-		fprintf (stdout,
-				fmt_str,
-				rspamc_commands[i].name,
-				rspamc_commands[i].is_controller ? "control" : "normal",
-				rspamc_commands[i].is_privileged ? "*" : "",
-				rspamc_commands[i].description);
-	}
-
-	rspamd_fprintf (stdout,
-		"\n* is for privileged commands that may need password (see -P option)\n");
-	rspamd_fprintf (stdout,
-		"control commands use port 11334 while normal use 11333 by default (see -h option)\n");
-}
-
-static void
-add_options (GQueue *opts)
-{
-	GString *numbuf;
-	gchar **hdr, **rcpt;
-	GString *flagbuf = g_string_new (NULL);
-
-	if (ip != NULL) {
-		rspamd_inet_addr_t *addr = NULL;
-
-		if (!rspamd_parse_inet_address (&addr, ip, strlen (ip),
-				RSPAMD_INET_ADDRESS_PARSE_DEFAULT)) {
-			/* Try to resolve */
-			struct addrinfo hints, *res, *cur;
-			gint r;
-
-			memset (&hints, 0, sizeof (hints));
-			hints.ai_socktype = SOCK_STREAM; /* Type of the socket */
-#ifdef AI_IDN
-			hints.ai_flags = AI_NUMERICSERV|AI_IDN;
-#else
-			hints.ai_flags = AI_NUMERICSERV;
-#endif
-			hints.ai_family = AF_UNSPEC;
-
-			if ((r = getaddrinfo (ip, "25", &hints, &res)) == 0) {
-
-				cur = res;
-				while (cur) {
-					addr = rspamd_inet_address_from_sa (cur->ai_addr,
-							cur->ai_addrlen);
-
-					if (addr != NULL) {
-						ip = g_strdup (rspamd_inet_address_to_string (addr));
-						rspamd_inet_address_free (addr);
-						break;
-					}
-
-					cur = cur->ai_next;
-				}
-
-				freeaddrinfo (res);
-			}
-			else {
-				rspamd_fprintf (stderr, "address resolution for %s failed: %s\n",
-						ip,
-						gai_strerror (r));
-			}
-		}
-		else {
-			rspamd_inet_address_free (addr);
-		}
-
-		ADD_CLIENT_HEADER (opts, "Ip", ip);
-	}
-
-	if (from != NULL) {
-		ADD_CLIENT_HEADER (opts, "From", from);
-	}
-
-	if (user != NULL) {
-		ADD_CLIENT_HEADER (opts, "User", user);
-	}
-
-	if (rcpts != NULL) {
-
-		for (rcpt = rcpts; *rcpt != NULL; rcpt ++) {
-			ADD_CLIENT_HEADER (opts, "Rcpt", *rcpt);
-		}
-	}
-
-	if (deliver_to != NULL) {
-		ADD_CLIENT_HEADER (opts, "Deliver-To", deliver_to);
-	}
-
-	if (helo != NULL) {
-		ADD_CLIENT_HEADER (opts, "Helo", helo);
-	}
-
-	if (hostname != NULL) {
-		ADD_CLIENT_HEADER (opts, "Hostname", hostname);
-	}
-
-	if (password != NULL) {
-		ADD_CLIENT_HEADER (opts, "Password", password);
-	}
-
-	if (pass_all) {
-		ADD_CLIENT_FLAG (flagbuf, "pass_all");
-	}
-
-	if (raw) {
-		ADD_CLIENT_HEADER (opts, "Raw", "yes");
-	}
-
-	if (classifier) {
-		ADD_CLIENT_HEADER (opts, "Classifier", classifier);
-	}
-
-	if (weight != 0) {
-		numbuf = g_string_sized_new (8);
-		rspamd_printf_gstring (numbuf, "%d", weight);
-		ADD_CLIENT_HEADER (opts, "Weight", numbuf->str);
-		g_string_free (numbuf, TRUE);
-	}
-
-	if (fuzzy_symbol != NULL) {
-		ADD_CLIENT_HEADER (opts, "Symbol", fuzzy_symbol);
-	}
-
-	if (flag != 0) {
-		numbuf = g_string_sized_new (8);
-		rspamd_printf_gstring (numbuf, "%d", flag);
-		ADD_CLIENT_HEADER (opts, "Flag", numbuf->str);
-		g_string_free (numbuf, TRUE);
-	}
-
-	if (extended_urls) {
-		ADD_CLIENT_HEADER (opts, "URL-Format", "extended");
-	}
-
-	if (profile) {
-		ADD_CLIENT_FLAG (flagbuf, "profile");
-	}
-
-	ADD_CLIENT_FLAG (flagbuf, "body_block");
-
-	if (skip_images) {
-		ADD_CLIENT_HEADER (opts, "Skip-Images", "true");
-	}
-
-	if (skip_attachments) {
-		ADD_CLIENT_HEADER (opts, "Skip-Attachments", "true");
-	}
-
-	hdr = http_headers;
-
-	while (hdr != NULL && *hdr != NULL) {
-		gchar **kv = g_strsplit_set (*hdr, ":=", 2);
-
-		if (kv == NULL || kv[1] == NULL) {
-			ADD_CLIENT_HEADER (opts, *hdr, "");
-		}
-		else {
-			ADD_CLIENT_HEADER (opts, kv[0], kv[1]);
-		}
-
-		if (kv) {
-			g_strfreev (kv);
-		}
-
-		hdr ++;
-	}
-
-	if (flagbuf->len > 0) {
-		goffset last = flagbuf->len - 1;
-
-		if (flagbuf->str[last] == ',') {
-			flagbuf->str[last] = '\0';
-			flagbuf->len --;
-		}
-
-		ADD_CLIENT_HEADER (opts, "Flags", flagbuf->str);
-	}
-
-	g_string_free (flagbuf, TRUE);
-}
-
-static void
-rspamc_symbol_output (FILE *out, const ucl_object_t *obj)
-{
-	const ucl_object_t *val, *cur;
-	ucl_object_iter_t it = NULL;
-	gboolean first = TRUE;
-
-	rspamd_fprintf (out, "Symbol: %s ", ucl_object_key (obj));
-	val = ucl_object_lookup (obj, "score");
-
-	if (val != NULL) {
-		rspamd_fprintf (out, "(%.2f)", ucl_object_todouble (val));
-	}
-	val = ucl_object_lookup (obj, "options");
-	if (val != NULL && val->type == UCL_ARRAY) {
-		rspamd_fprintf (out, "[");
-
-		while ((cur = ucl_object_iterate (val, &it, TRUE)) != NULL) {
-			if (first) {
-				rspamd_fprintf (out, "%s", ucl_object_tostring (cur));
-				first = FALSE;
-			}
-			else {
-				rspamd_fprintf (out, ", %s", ucl_object_tostring (cur));
-			}
-		}
-		rspamd_fprintf (out, "]");
-	}
-	rspamd_fprintf (out, "\n");
-}
-
-static gint
-rspamc_symbols_sort_func (gconstpointer a, gconstpointer b)
-{
-	ucl_object_t * const *ua = a, * const *ub = b;
-
-	return strcmp (ucl_object_key (*ua), ucl_object_key (*ub));
-}
-
-#define PRINT_PROTOCOL_STRING(ucl_name, output_message) do { \
-	elt = ucl_object_lookup (obj, (ucl_name)); \
-	if (elt) { \
-		rspamd_fprintf (out, output_message ": %s\n", ucl_object_tostring (elt)); \
-	} \
-} while (0)
-
-static void
-rspamc_metric_output (FILE *out, const ucl_object_t *obj)
-{
-	ucl_object_iter_t it = NULL;
-	const ucl_object_t *cur, *elt;
-	gdouble score = 0, required_score = 0;
-	gint got_scores = 0, action = METRIC_ACTION_MAX;
-	GPtrArray *sym_ptr;
-	guint i;
-
-	sym_ptr = g_ptr_array_new ();
-	rspamd_fprintf (out, "[Metric: default]\n");
-
-	elt = ucl_object_lookup (obj, "required_score");
-
-	if (elt) {
-		required_score = ucl_object_todouble (elt);
-		got_scores++;
-	}
-
-	elt = ucl_object_lookup (obj, "score");
-
-	if (elt) {
-		score = ucl_object_todouble (elt);
-		got_scores++;
-	}
-
-	PRINT_PROTOCOL_STRING ("action", "Action");
-	/* Defined by previous macro */
-	if (elt && rspamd_action_from_str_rspamc (ucl_object_tostring (elt), &action)) {
-		rspamd_fprintf (out, "Spam: %s\n", action < METRIC_ACTION_GREYLIST ?
-				"true" : "false");
-	}
-
-	PRINT_PROTOCOL_STRING ("subject", "Subject");
-
-	if (got_scores == 2) {
-		rspamd_fprintf (out,
-				"Score: %.2f / %.2f\n",
-				score,
-				required_score);
-	}
-
-	elt = ucl_object_lookup (obj, "symbols");
-
-	while (elt && (cur = ucl_object_iterate (elt, &it, true)) != NULL) {
-		if (cur->type == UCL_OBJECT) {
-			g_ptr_array_add (sym_ptr, (void *)cur);
-		}
-	}
-
-	g_ptr_array_sort (sym_ptr, rspamc_symbols_sort_func);
-
-	for (i = 0; i < sym_ptr->len; i ++) {
-		cur = (const ucl_object_t *)g_ptr_array_index (sym_ptr, i);
-		rspamc_symbol_output (out, cur);
-	}
-
-	g_ptr_array_free (sym_ptr, TRUE);
-}
-
-static gint
-rspamc_profile_sort_func (gconstpointer a, gconstpointer b)
-{
-	ucl_object_t * const *ua = a, * const *ub = b;
-
-	return ucl_object_compare (*ua, *ub);
-}
-
-static void
-rspamc_profile_output (FILE *out, const ucl_object_t *obj)
-{
-	ucl_object_iter_t it = NULL;
-	const ucl_object_t *cur;
-	guint i;
-	GPtrArray *ar;
-
-	ar = g_ptr_array_sized_new (obj->len);
-
-	while ((cur = ucl_object_iterate (obj, &it, true)) != NULL) {
-		g_ptr_array_add (ar, (void *)cur);
-	}
-
-	g_ptr_array_sort (ar, rspamc_profile_sort_func);
-
-	for (i = 0; i < ar->len; i ++) {
-		cur = (const ucl_object_t *)g_ptr_array_index (ar, i);
-		rspamd_fprintf (out, "\t%s: %.3f usec\n",
-				ucl_object_key (cur), ucl_object_todouble (cur));
-	}
-
-	g_ptr_array_free (ar, TRUE);
-}
-
-static void
-rspamc_symbols_output (FILE *out, ucl_object_t *obj)
-{
-	ucl_object_iter_t mit = NULL;
-	const ucl_object_t *cmesg, *elt;
-	gchar *emitted;
-
-	rspamc_metric_output (out, obj);
-
-	PRINT_PROTOCOL_STRING ("message-id", "Message-ID");
-	PRINT_PROTOCOL_STRING ("queue-id", "Queue-ID");
-
-	elt = ucl_object_lookup (obj, "urls");
-
-	if (elt) {
-		if (!extended_urls || compact) {
-			emitted = ucl_object_emit (elt, UCL_EMIT_JSON_COMPACT);
-		}
-		else {
-			emitted = ucl_object_emit (elt, UCL_EMIT_JSON);
-		}
-
-		rspamd_fprintf (out, "Urls: %s\n", emitted);
-		free (emitted);
-	}
-
-	elt = ucl_object_lookup (obj, "emails");
-
-	if (elt) {
-		if (!extended_urls || compact) {
-			emitted = ucl_object_emit (elt, UCL_EMIT_JSON_COMPACT);
-		}
-		else {
-			emitted = ucl_object_emit (elt, UCL_EMIT_JSON);
-		}
-
-		rspamd_fprintf (out, "Emails: %s\n", emitted);
-		free (emitted);
-	}
-
-	PRINT_PROTOCOL_STRING ("error", "Scan error");
-
-	elt = ucl_object_lookup (obj, "messages");
-	if (elt && elt->type == UCL_OBJECT) {
-		mit = NULL;
-		while ((cmesg = ucl_object_iterate (elt, &mit, true)) != NULL) {
-			rspamd_fprintf (out, "Message - %s: %s\n",
-					ucl_object_key (cmesg), ucl_object_tostring (cmesg));
-		}
-	}
-
-	elt = ucl_object_lookup (obj, "dkim-signature");
-	if (elt && elt->type == UCL_STRING) {
-		rspamd_fprintf (out, "DKIM-Signature: %s\n", ucl_object_tostring (elt));
-	} else if (elt && elt->type == UCL_ARRAY) {
-		mit = NULL;
-		while ((cmesg = ucl_object_iterate (elt, &mit, true)) != NULL) {
-			rspamd_fprintf (out, "DKIM-Signature: %s\n", ucl_object_tostring (cmesg));
-		}
-	}
-
-	elt = ucl_object_lookup (obj, "profile");
-
-	if (elt) {
-		rspamd_fprintf (out, "Profile data:\n");
-		rspamc_profile_output (out, elt);
-	}
-}
-
-static void
-rspamc_uptime_output (FILE *out, ucl_object_t *obj)
-{
-	const ucl_object_t *elt;
-	int64_t seconds, days, hours, minutes;
-
-	elt = ucl_object_lookup (obj, "version");
-	if (elt != NULL) {
-		rspamd_fprintf (out, "Rspamd version: %s\n", ucl_object_tostring (
-				elt));
-	}
-
-	elt = ucl_object_lookup (obj, "uptime");
-	if (elt != NULL) {
-		rspamd_printf ("Uptime: ");
-		seconds = ucl_object_toint (elt);
-		if (seconds >= 2 * 3600) {
-			days = seconds / 86400;
-			hours = seconds / 3600 - days * 24;
-			minutes = seconds / 60 - hours * 60 - days * 1440;
-			rspamd_printf ("%L day%s %L hour%s %L minute%s\n", days,
-				days > 1 ? "s" : "", hours, hours > 1 ? "s" : "",
-				minutes, minutes > 1 ? "s" : "");
-		}
-		/* If uptime is less than 1 minute print only seconds */
-		else if (seconds / 60 == 0) {
-			rspamd_printf ("%L second%s\n", seconds,
-				(gint)seconds > 1 ? "s" : "");
-		}
-		/* Else print the minutes and seconds. */
-		else {
-			hours = seconds / 3600;
-			minutes = seconds / 60 - hours * 60;
-			seconds -= hours * 3600 + minutes * 60;
-			rspamd_printf ("%L hour %L minute%s %L second%s\n", hours,
-				minutes, minutes > 1 ? "s" : "",
-				seconds, seconds > 1 ? "s" : "");
-		}
-	}
-}
-
-static gint
-rspamc_counters_sort (const ucl_object_t **o1, const ucl_object_t **o2)
-{
-	gint order1 = 0, order2 = 0, c;
-	const ucl_object_t *elt1, *elt2;
-	gboolean inverse = FALSE;
-	gchar **args;
-
-	if (sort != NULL) {
-		args = g_strsplit_set (sort, ":", 2);
-		if (args && args[0]) {
-			if (args[1] && g_ascii_strcasecmp (args[1], "desc") == 0) {
-				inverse = TRUE;
-			}
-
-			if (g_ascii_strcasecmp (args[0], "name") == 0) {
-				elt1 = ucl_object_lookup (*o1, "symbol");
-				elt2 = ucl_object_lookup (*o2, "symbol");
-
-				if (elt1 && elt2) {
-					c = strcmp (ucl_object_tostring (elt1),
-							ucl_object_tostring (elt2));
-
-					order1 = c > 0 ? 1 : 0;
-					order2 = c < 0 ? 1 : 0;
-				}
-			}
-			else if (g_ascii_strcasecmp (args[0], "weight") == 0) {
-				elt1 = ucl_object_lookup (*o1, "weight");
-				elt2 = ucl_object_lookup (*o2, "weight");
-
-				if (elt1 && elt2) {
-					order1 = ucl_object_todouble (elt1) * 1000.0;
-					order2 = ucl_object_todouble (elt2) * 1000.0;
-				}
-			}
-			else if (g_ascii_strcasecmp (args[0], "frequency") == 0) {
-				elt1 = ucl_object_lookup (*o1, "frequency");
-				elt2 = ucl_object_lookup (*o2, "frequency");
-
-				if (elt1 && elt2) {
-					order1 = ucl_object_todouble (elt1) * 100000;
-					order2 = ucl_object_todouble (elt2) * 100000;
-				}
-			}
-			else if (g_ascii_strcasecmp (args[0], "time") == 0) {
-				elt1 = ucl_object_lookup (*o1, "time");
-				elt2 = ucl_object_lookup (*o2, "time");
-
-				if (elt1 && elt2) {
-					order1 = ucl_object_todouble (elt1) * 1000000;
-					order2 = ucl_object_todouble (elt2) * 1000000;
-				}
-			}
-			else if (g_ascii_strcasecmp (args[0], "hits") == 0) {
-				elt1 = ucl_object_lookup (*o1, "hits");
-				elt2 = ucl_object_lookup (*o2, "hits");
-
-				if (elt1 && elt2) {
-					order1 = ucl_object_toint (elt1);
-					order2 = ucl_object_toint (elt2);
-				}
-			}
-		}
-
-		g_strfreev (args);
-	}
-
-	return (inverse ? (order2 - order1) : (order1 - order2));
-}
-
-static void
-rspamc_counters_output (FILE *out, ucl_object_t *obj)
-{
-	const ucl_object_t *cur, *sym, *weight, *freq, *freq_dev, *nhits;
-	ucl_object_iter_t iter = NULL;
-	gchar fmt_buf[64], dash_buf[82], sym_buf[82];
-	static const gint dashes = 44;
-
-	if (obj->type != UCL_ARRAY) {
-		rspamd_printf ("Bad output\n");
-		return;
-	}
-
-	/* Sort symbols by their order */
-	if (sort != NULL) {
-		ucl_object_array_sort (obj, rspamc_counters_sort);
-	}
-
-	/* Find maximum width of symbol's name */
-	gint max_len = sizeof("Symbol") - 1;
-	while ((cur = ucl_object_iterate (obj, &iter, true)) != NULL) {
-		sym = ucl_object_lookup (cur, "symbol");
-		if (sym != NULL) {
-			if (sym->len > max_len) {
-				max_len = sym->len;
-			}
-		}
-	}
-
-	max_len = MIN (sizeof (dash_buf) - dashes - 1, max_len);
-	rspamd_snprintf (fmt_buf, sizeof (fmt_buf),
-		"| %%3s | %%%ds | %%7s | %%13s | %%7s |\n", max_len);
-	memset (dash_buf, '-', dashes + max_len);
-	dash_buf[dashes + max_len] = '\0';
-
-	printf ("Symbols cache\n");
-	printf (" %s \n", dash_buf);
-	if (tty) {
-		printf ("\033[1m");
-	}
-	printf (fmt_buf, "Pri", "Symbol", "Weight", "Frequency", "Hits");
-	printf (" %s \n", dash_buf);
-	printf (fmt_buf, "", "", "", "hits/min", "");
-	if (tty) {
-		printf ("\033[0m");
-	}
-	rspamd_snprintf (fmt_buf, sizeof (fmt_buf),
-		"| %%3d | %%%ds | %%7.1f | %%6.3f(%%5.3f) | %%7ju |\n", max_len);
-
-	iter = NULL;
-	gint i = 0;
-	while ((cur = ucl_object_iterate (obj, &iter, true)) != NULL) {
-		printf (" %s \n", dash_buf);
-		sym = ucl_object_lookup (cur, "symbol");
-		weight = ucl_object_lookup (cur, "weight");
-		freq = ucl_object_lookup (cur, "frequency");
-		freq_dev = ucl_object_lookup (cur, "frequency_stddev");
-		nhits = ucl_object_lookup (cur, "hits");
-
-		if (sym && weight && freq && nhits) {
-			const gchar *sym_name;
-
-			if (sym->len > max_len) {
-				rspamd_snprintf (sym_buf, sizeof (sym_buf), "%*s...",
-						(max_len - 3), ucl_object_tostring (sym));
-				sym_name = sym_buf;
-			}
-			else {
-				sym_name = ucl_object_tostring (sym);
-			}
-
-			printf (fmt_buf, i,
-					sym_name,
-					ucl_object_todouble (weight),
-					ucl_object_todouble (freq) * 60.0,
-					ucl_object_todouble (freq_dev) * 60.0,
-					(uintmax_t)ucl_object_toint (nhits));
-		}
-		i++;
-	}
-	printf (" %s \n", dash_buf);
-}
-
-static void
-rspamc_stat_actions (ucl_object_t *obj, GString *out, gint64 scanned)
-{
-	const ucl_object_t *actions = ucl_object_lookup (obj, "actions"), *cur;
-	ucl_object_iter_t iter = NULL;
-	gint64 spam, ham;
-
-	if (scanned > 0) {
-		if (actions && ucl_object_type(actions) == UCL_OBJECT) {
-			while ((cur = ucl_object_iterate (actions, &iter, true)) != NULL) {
-				gint64 cnt = ucl_object_toint(cur);
-				rspamd_printf_gstring(out, "Messages with action %s: %L"
-										   ", %.2f%%\n", ucl_object_key(cur), cnt,
-						((gdouble) cnt / (gdouble) scanned) * 100.);
-			}
-		}
-
-		spam = ucl_object_toint(ucl_object_lookup(obj, "spam_count"));
-		ham = ucl_object_toint(ucl_object_lookup(obj, "ham_count"));
-		rspamd_printf_gstring(out, "Messages treated as spam: %L, %.2f%%\n", spam,
-				((gdouble) spam / (gdouble) scanned) * 100.);
-		rspamd_printf_gstring(out, "Messages treated as ham: %L, %.2f%%\n", ham,
-				((gdouble) ham / (gdouble) scanned) * 100.);
-	}
-}
-
-static void
-rspamc_stat_statfile (const ucl_object_t *obj, GString *out)
-{
-	gint64 version, size, blocks, used_blocks, nlanguages, nusers;
-	const gchar *label, *symbol, *type;
-
-	version = ucl_object_toint (ucl_object_lookup (obj, "revision"));
-	size = ucl_object_toint (ucl_object_lookup (obj, "size"));
-	blocks = ucl_object_toint (ucl_object_lookup (obj, "total"));
-	used_blocks = ucl_object_toint (ucl_object_lookup (obj, "used"));
-	label = ucl_object_tostring (ucl_object_lookup (obj, "label"));
-	symbol = ucl_object_tostring (ucl_object_lookup (obj, "symbol"));
-	type = ucl_object_tostring (ucl_object_lookup (obj, "type"));
-	nlanguages = ucl_object_toint (ucl_object_lookup (obj, "languages"));
-	nusers = ucl_object_toint (ucl_object_lookup (obj, "users"));
-
-	if (label) {
-		rspamd_printf_gstring (out, "Statfile: %s <%s> type: %s; ", symbol,
-				label, type);
-	}
-	else {
-		rspamd_printf_gstring (out, "Statfile: %s type: %s; ", symbol, type);
-	}
-	rspamd_printf_gstring (out, "length: %hL; free blocks: %hL; total blocks: %hL; "
-			"free: %.2f%%; learned: %L; users: %L; languages: %L\n",
-			size,
-			blocks - used_blocks, blocks,
-			blocks > 0 ? (blocks - used_blocks) * 100.0 / (gdouble)blocks : 0,
-			version,
-			nusers, nlanguages);
-}
-
-static void
-rspamc_stat_output (FILE *out, ucl_object_t *obj)
-{
-	GString *out_str;
-	const ucl_object_t *st;
-	gint64 scanned;
-
-	out_str = g_string_sized_new (BUFSIZ);
-
-	scanned = ucl_object_toint (ucl_object_lookup (obj, "scanned"));
-	rspamd_printf_gstring (out_str, "Messages scanned: %L\n",
-		scanned);
-
-	rspamc_stat_actions (obj, out_str, scanned);
-
-	rspamd_printf_gstring (out_str, "Messages learned: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "learned")));
-	rspamd_printf_gstring (out_str, "Connections count: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "connections")));
-	rspamd_printf_gstring (out_str, "Control connections count: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "control_connections")));
-
-	const ucl_object_t *avg_time_obj = ucl_object_lookup (obj, "scan_times");
-
-	if (avg_time_obj && ucl_object_type (avg_time_obj) == UCL_ARRAY) {
-		ucl_object_iter_t iter = NULL;
-		const ucl_object_t *cur;
-		float sum = 0.0f;
-		volatile float c = 0.0f;
-		unsigned cnt = 0;
-
-		while ((cur = ucl_object_iterate (avg_time_obj, &iter, true)) != NULL) {
-			if (ucl_object_type(cur) == UCL_FLOAT || ucl_object_type(cur) == UCL_INT) {
-				float x = ucl_object_todouble(cur);
-				float y = x - c;
-				float t = sum + y;
-				c = (t - sum) - y;
-				sum = t;
-				cnt ++;
-			}
-		}
-
-		if (cnt > 0) {
-			rspamd_printf_gstring(out_str, "Average scan time: %.3f sec\n", sum / cnt);
-		}
-	}
-
-	/* Pools */
-	rspamd_printf_gstring (out_str, "Pools allocated: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "pools_allocated")));
-	rspamd_printf_gstring (out_str, "Pools freed: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "pools_freed")));
-	rspamd_printf_gstring (out_str, "Bytes allocated: %HL\n",
-		ucl_object_toint (ucl_object_lookup (obj, "bytes_allocated")));
-	rspamd_printf_gstring (out_str, "Memory chunks allocated: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "chunks_allocated")));
-	rspamd_printf_gstring (out_str, "Shared chunks allocated: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "shared_chunks_allocated")));
-	rspamd_printf_gstring (out_str, "Chunks freed: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "chunks_freed")));
-	rspamd_printf_gstring (out_str, "Oversized chunks: %L\n",
-		ucl_object_toint (ucl_object_lookup (obj, "chunks_oversized")));
-	/* Fuzzy */
-
-	st = ucl_object_lookup (obj, "fuzzy_hashes");
-	if (st) {
-		ucl_object_iter_t it = NULL;
-		const ucl_object_t *cur;
-		gint64 stored = 0;
-
-		while ((cur = ucl_iterate_object (st, &it, true)) != NULL) {
-			rspamd_printf_gstring (out_str, "Fuzzy hashes in storage \"%s\": %L\n",
-					ucl_object_key (cur),
-					ucl_object_toint (cur));
-			stored += ucl_object_toint (cur);
-		}
-
-		rspamd_printf_gstring (out_str, "Fuzzy hashes stored: %L\n",
-				stored);
-	}
-
-	st = ucl_object_lookup (obj, "fuzzy_checked");
-	if (st != NULL && ucl_object_type (st) == UCL_ARRAY) {
-		ucl_object_iter_t iter = NULL;
-		const ucl_object_t *cur;
-
-		rspamd_printf_gstring (out_str, "Fuzzy hashes checked: ");
-
-		while ((cur = ucl_object_iterate (st, &iter, true)) != NULL) {
-			rspamd_printf_gstring (out_str, "%hL ", ucl_object_toint (cur));
-		}
-
-		rspamd_printf_gstring (out_str, "\n");
-	}
-
-	st = ucl_object_lookup (obj, "fuzzy_found");
-	if (st != NULL && ucl_object_type (st) == UCL_ARRAY) {
-		ucl_object_iter_t iter = NULL;
-		const ucl_object_t *cur;
-
-		rspamd_printf_gstring (out_str, "Fuzzy hashes found: ");
-
-		while ((cur = ucl_object_iterate (st, &iter, true)) != NULL) {
-			rspamd_printf_gstring (out_str, "%hL ", ucl_object_toint (cur));
-		}
-
-		rspamd_printf_gstring (out_str, "\n");
-	}
-
-	st = ucl_object_lookup (obj, "statfiles");
-	if (st != NULL && ucl_object_type (st) == UCL_ARRAY) {
-		ucl_object_iter_t iter = NULL;
-		const ucl_object_t *cur;
-
-		while ((cur = ucl_object_iterate (st, &iter, true)) != NULL) {
-			rspamc_stat_statfile (cur, out_str);
-		}
-	}
-	rspamd_printf_gstring (out_str, "Total learns: %L\n",
-			ucl_object_toint (ucl_object_lookup (obj, "total_learns")));
-
-	rspamd_fprintf (out, "%v", out_str);
-}
-
-static void
-rspamc_output_headers (FILE *out, struct rspamd_http_message *msg)
-{
-	struct rspamd_http_header *h;
-
-	kh_foreach_value (msg->headers, h, {
-		rspamd_fprintf (out, "%T: %T\n", &h->name, &h->value);
-	});
-
-	rspamd_fprintf (out, "\n");
-}
-
-static void
-rspamc_mime_output (FILE *out, ucl_object_t *result, GString *input,
-		gdouble time, GError *err)
-{
-	const ucl_object_t *cur, *res, *syms;
-	ucl_object_iter_t it = NULL;
-	const gchar *action = "no action", *line_end = "\r\n", *p;
-	gchar scorebuf[32];
-	GString *symbuf, *folded_symbuf, *added_headers;
-	gint act = 0;
-	goffset headers_pos;
-	gdouble score = 0.0, required_score = 0.0;
-	gboolean is_spam = FALSE;
-	gchar *json_header, *json_header_encoded, *sc;
-	enum rspamd_newlines_type nl_type = RSPAMD_TASK_NEWLINES_CRLF;
-
-	headers_pos = rspamd_string_find_eoh (input, NULL);
-
-	if (headers_pos == -1) {
-		rspamd_fprintf (stderr,"cannot find end of headers position");
-		return;
-	}
-
-	p = input->str + headers_pos;
-
-	if (headers_pos > 1 && *(p - 1) == '\n') {
-		if (headers_pos > 2 && *(p - 2) == '\r') {
-			line_end = "\r\n";
-			nl_type = RSPAMD_TASK_NEWLINES_CRLF;
-		}
-		else {
-			line_end = "\n";
-			nl_type = RSPAMD_TASK_NEWLINES_LF;
-		}
-	}
-	else if (headers_pos > 1 && *(p - 1) == '\r') {
-		line_end = "\r";
-		nl_type = RSPAMD_TASK_NEWLINES_CR;
-	}
-
-	added_headers = g_string_sized_new (127);
-
-	if (result) {
-		res = ucl_object_lookup (result, "action");
-
-		if (res) {
-			action = ucl_object_tostring (res);
-		}
-
-		res = ucl_object_lookup (result, "score");
-		if (res) {
-			score = ucl_object_todouble (res);
-		}
-
-		res = ucl_object_lookup (result, "required_score");
-		if (res) {
-			required_score = ucl_object_todouble (res);
-		}
-
-		rspamd_action_from_str_rspamc (action, &act);
-
-		if (act < METRIC_ACTION_GREYLIST) {
-			is_spam = TRUE;
-		}
-
-		rspamd_printf_gstring (added_headers, "X-Spam-Scanner: %s%s",
-				"rspamc " RVERSION, line_end);
-		rspamd_printf_gstring (added_headers, "X-Spam-Scan-Time: %.3f%s",
-				time, line_end);
-
-		/*
-		 * TODO: add rmilter_headers support here
-		 */
-		if (is_spam) {
-			rspamd_printf_gstring (added_headers, "X-Spam: yes%s", line_end);
-		}
-
-		rspamd_printf_gstring (added_headers, "X-Spam-Action: %s%s",
-				action, line_end);
-		rspamd_printf_gstring (added_headers, "X-Spam-Score: %.2f / %.2f%s",
-				score, required_score, line_end);
-
-		/* SA style stars header */
-		for (sc = scorebuf; sc < scorebuf + sizeof (scorebuf) - 1 && score > 0;
-			 sc ++, score -= 1.0) {
-			*sc = '*';
-		}
-
-		*sc = '\0';
-		rspamd_printf_gstring (added_headers, "X-Spam-Level: %s%s",
-				scorebuf, line_end);
-
-		/* Short description of all symbols */
-		symbuf = g_string_sized_new (64);
-		syms = ucl_object_lookup (result, "symbols");
-
-		while (syms && (cur = ucl_object_iterate (syms, &it, true)) != NULL) {
-
-			if (ucl_object_type (cur) == UCL_OBJECT) {
-				rspamd_printf_gstring (symbuf, "%s,", ucl_object_key (cur));
-			}
-		}
-		/* Trim the last comma */
-		if (symbuf->str[symbuf->len - 1] == ',') {
-			g_string_erase (symbuf, symbuf->len - 1, 1);
-		}
-
-		folded_symbuf = rspamd_header_value_fold ("X-Spam-Symbols", strlen ("X-Spam-Symbols"),
-				symbuf->str, symbuf->len,
-				0, nl_type, ",");
-		rspamd_printf_gstring (added_headers, "X-Spam-Symbols: %v%s",
-				folded_symbuf, line_end);
-
-		g_string_free (folded_symbuf, TRUE);
-		g_string_free (symbuf, TRUE);
-
-		res = ucl_object_lookup (result, "dkim-signature");
-		if (res && res->type == UCL_STRING) {
-			rspamd_printf_gstring (added_headers, "DKIM-Signature: %s%s",
-					ucl_object_tostring (res), line_end);
-		} else if (res && res->type == UCL_ARRAY) {
-			it = NULL;
-			while ((cur = ucl_object_iterate (res, &it, true)) != NULL) {
-				rspamd_printf_gstring (added_headers, "DKIM-Signature: %s%s",
-					ucl_object_tostring (cur), line_end);
-			}
-		}
-
-		if (json || ucl_reply || compact) {
-			/* We also append json data as a specific header */
-			if (json) {
-				json_header = ucl_object_emit (result,
-						compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_JSON);
-			}
-			else {
-				json_header = ucl_object_emit (result,
-						compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_CONFIG);
-			}
-
-			json_header_encoded = rspamd_encode_base64_fold (json_header,
-					strlen (json_header), 60, NULL, nl_type);
-			free (json_header);
-			rspamd_printf_gstring (added_headers,
-					"X-Spam-Result: %s%s",
-					json_header_encoded, line_end);
-			g_free (json_header_encoded);
-		}
-
-		ucl_object_unref (result);
-	}
-	else {
-		rspamd_printf_gstring (added_headers, "X-Spam-Scanner: %s%s",
-				"rspamc " RVERSION, line_end);
-		rspamd_printf_gstring (added_headers, "X-Spam-Scan-Time: %.3f%s",
-				time, line_end);
-		rspamd_printf_gstring (added_headers, "X-Spam-Error: %e%s",
-				err, line_end);
-	}
-
-	/* Write message */
-	if (rspamd_fprintf (out, "%*s", (gint)headers_pos, input->str)
-			== headers_pos) {
-		if (rspamd_fprintf (out, "%v", added_headers)
-				== (gint)added_headers->len) {
-			rspamd_fprintf (out, "%s", input->str + headers_pos);
-		}
-	}
-
-	g_string_free (added_headers, TRUE);
-}
-
-static void
-rspamc_client_execute_cmd (struct rspamc_command *cmd, ucl_object_t *result,
-		GString *input, gdouble time, GError *err)
-{
-	gchar **eargv;
-	gint eargc, infd, outfd, errfd;
-	GError *exec_err = NULL;
-	GPid cld;
-	FILE *out;
-	gchar *ucl_out;
-
-	if (!g_shell_parse_argv (execute, &eargc, &eargv, &err)) {
-		rspamd_fprintf (stderr, "Cannot execute %s: %e", execute, err);
-		g_error_free (err);
-
-		return;
-	}
-
-	if (!g_spawn_async_with_pipes (NULL, eargv, NULL,
-			G_SPAWN_SEARCH_PATH|G_SPAWN_DO_NOT_REAP_CHILD, NULL, NULL, &cld,
-			&infd, &outfd, &errfd, &exec_err)) {
-
-		rspamd_fprintf (stderr, "Cannot execute %s: %e", execute, exec_err);
-		g_error_free (exec_err);
-
-		exit (EXIT_FAILURE);
-	}
-	else {
-		children = g_list_prepend (children, GSIZE_TO_POINTER (cld));
-		out = fdopen (infd, "w");
-
-		if (cmd->cmd == RSPAMC_COMMAND_SYMBOLS && mime_output && input) {
-			rspamc_mime_output (out, result, input, time, err);
-		}
-		else if (result) {
-			if (ucl_reply || cmd->command_output_func == NULL) {
-				if (json) {
-					ucl_out = ucl_object_emit (result,
-							compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_JSON);
-				}
-				else {
-					ucl_out = ucl_object_emit (result,
-							compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_CONFIG);
-				}
-				rspamd_fprintf (out, "%s", ucl_out);
-				free (ucl_out);
-			}
-			else {
-				cmd->command_output_func (out, result);
-			}
-
-			ucl_object_unref (result);
-		}
-		else {
-			rspamd_fprintf (out, "%e\n", err);
-		}
-
-		fflush (out);
-
-		fclose (out);
-	}
-
-	g_strfreev (eargv);
-}
-
-static void
-rspamc_client_cb (struct rspamd_client_connection *conn,
-		struct rspamd_http_message *msg,
-		const gchar *name, ucl_object_t *result, GString *input,
-		gpointer ud, gdouble start_time, gdouble send_time,
-		const gchar *body, gsize bodylen,
-		GError *err)
-{
-	gchar *ucl_out;
-	struct rspamc_callback_data *cbdata = (struct rspamc_callback_data *)ud;
-	struct rspamc_command *cmd;
-	FILE *out = stdout;
-	gdouble finish = rspamd_get_ticks (FALSE), diff;
-
-	cmd = cbdata->cmd;
-
-	if (send_time > 0) {
-		diff = finish - send_time;
-	}
-	else {
-		diff = finish - start_time;
-	}
-
-	if (execute) {
-		/* Pass all to the external command */
-		rspamc_client_execute_cmd (cmd, result, input, diff, err);
-	}
-	else {
-
-		if (cmd->cmd == RSPAMC_COMMAND_SYMBOLS && mime_output && input) {
-			if (body) {
-				GString tmp;
-
-				tmp.str = (char *)body;
-				tmp.len = bodylen;
-				rspamc_mime_output (out, result, &tmp, diff, err);
-			}
-			else {
-				rspamc_mime_output (out, result, input, diff, err);
-			}
-		}
-		else {
-			if (cmd->need_input && !json) {
-				if (!compact) {
-					rspamd_fprintf (out, "Results for file: %s (%.3f seconds)\n",
-							cbdata->filename, diff);
-				}
-			}
-			else {
-				if (!compact && !json) {
-					rspamd_fprintf (out, "Results for command: %s (%.3f seconds)\n",
-							cmd->name, diff);
-				}
-			}
-
-			if (result != NULL) {
-				if (headers && msg != NULL) {
-					rspamc_output_headers (out, msg);
-				}
-				if (ucl_reply || cmd->command_output_func == NULL) {
-					if (cmd->need_input) {
-						ucl_object_insert_key (result,
-								ucl_object_fromstring (cbdata->filename),
-								"filename", 0,
-								false);
-					}
-
-					ucl_object_insert_key (result,
-							ucl_object_fromdouble (diff),
-							"scan_time", 0,
-							false);
-
-					if (json) {
-						ucl_out = ucl_object_emit (result,
-								compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_JSON);
-					}
-					else {
-						ucl_out = ucl_object_emit (result,
-								compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_CONFIG);
-					}
-
-					rspamd_fprintf (out, "%s", ucl_out);
-					free (ucl_out);
-				}
-				else {
-					cmd->command_output_func (out, result);
-				}
-
-				if (body) {
-					rspamd_fprintf (out, "\nNew body:\n%*s\n", (int)bodylen,
-							body);
-				}
-
-				ucl_object_unref (result);
-			}
-			else if (err != NULL) {
-				rspamd_fprintf (out, "%s\n", err->message);
-
-				if (json && msg != NULL) {
-					const gchar *raw_body;
-					gsize rawlen;
-
-					raw_body = rspamd_http_message_get_body (msg, &rawlen);
-
-					if (raw_body) {
-						/* We can also output the resulting json */
-						rspamd_fprintf (out, "%*s\n", (gint)(rawlen - bodylen),
-								raw_body);
-					}
-				}
-			}
-			rspamd_fprintf (out, "\n");
-		}
-
-		fflush (out);
-	}
-
-	rspamd_client_destroy (conn);
-	g_free (cbdata->filename);
-	g_free (cbdata);
-
-	if (err) {
-		retcode = EXIT_FAILURE;
-	}
-}
-
-static void
-rspamc_process_input (struct ev_loop *ev_base, struct rspamc_command *cmd,
-	FILE *in, const gchar *name, GQueue *attrs)
-{
-	struct rspamd_client_connection *conn;
-	gchar *hostbuf = NULL, *p;
-	guint16 port;
-	GError *err = NULL;
-	struct rspamc_callback_data *cbdata;
-
-	if (connect_str[0] == '[') {
-		p = strrchr (connect_str, ']');
-
-		if (p != NULL) {
-			hostbuf = g_malloc (p - connect_str);
-			rspamd_strlcpy (hostbuf, connect_str + 1, p - connect_str);
-			p ++;
-		}
-		else {
-			p = connect_str;
-		}
-	}
-	else {
-		p = connect_str;
-	}
-
-	p = strrchr (p, ':');
-
-	if (!hostbuf) {
-		if (p != NULL) {
-			hostbuf = g_malloc (p - connect_str + 1);
-			rspamd_strlcpy (hostbuf, connect_str, p - connect_str + 1);
-		}
-		else {
-			hostbuf = g_strdup (connect_str);
-		}
-	}
-
-	if (p != NULL) {
-		port = strtoul (p + 1, NULL, 10);
-	}
-	else {
-		/*
-		 * If we connect to localhost, 127.0.0.1 or ::1, then try controller
-		 * port first
-		 */
-
-		if (strcmp (hostbuf, "localhost") == 0 ||
-				strcmp (hostbuf, "127.0.0.1") == 0 ||
-				strcmp (hostbuf, "::1") == 0 ||
-				strcmp (hostbuf, "[::1]") == 0) {
-			port = DEFAULT_CONTROL_PORT;
-		}
-		else {
-			port = cmd->is_controller ? DEFAULT_CONTROL_PORT : DEFAULT_PORT;
-		}
-
-	}
-
-	conn = rspamd_client_init (http_ctx, ev_base, hostbuf, port, timeout, key);
-
-	if (conn != NULL) {
-		cbdata = g_malloc0 (sizeof (struct rspamc_callback_data));
-		cbdata->cmd = cmd;
-
-		if (name) {
-			cbdata->filename = g_strdup (name);
-		}
-
-		if (cmd->need_input) {
-			rspamd_client_command (conn, cmd->path, attrs, in, rspamc_client_cb,
-				cbdata, compressed, dictionary, cbdata->filename, &err);
-		}
-		else {
-			rspamd_client_command (conn,
-					cmd->path,
-					attrs,
-					NULL,
-					rspamc_client_cb,
-					cbdata,
-					compressed,
-					dictionary,
-					cbdata->filename,
-					&err);
-		}
-	}
-	else {
-		rspamd_fprintf (stderr, "cannot connect to %s: %s\n", connect_str,
-				strerror (errno));
-		exit (EXIT_FAILURE);
-	}
-
-	g_free (hostbuf);
-}
-
-static gsize
-rspamd_dirent_size (DIR * dirp)
-{
-	goffset name_max;
-	gsize name_end;
-
-#if defined(HAVE_FPATHCONF) && defined(HAVE_DIRFD) \
-       && defined(_PC_NAME_MAX)
-	name_max = fpathconf (dirfd (dirp), _PC_NAME_MAX);
-
-
-# if defined(NAME_MAX)
-	if (name_max == -1) {
-		name_max = (NAME_MAX > 255) ? NAME_MAX : 255;
-	}
-# else
-	if (name_max == -1) {
-		return (size_t)(-1);
-	}
-# endif
-#else
-# if defined(NAME_MAX)
-	name_max = (NAME_MAX > 255) ? NAME_MAX : 255;
-# else
-#   error "buffer size for readdir_r cannot be determined"
-# endif
-#endif
-
-	name_end = G_STRUCT_OFFSET (struct dirent, d_name) + name_max + 1;
-
-	return (name_end > sizeof (struct dirent) ? name_end : sizeof(struct dirent));
-}
-
-static void
-rspamc_process_dir (struct ev_loop *ev_base, struct rspamc_command *cmd,
-	const gchar *name, GQueue *attrs)
-{
-	DIR *d;
-	GPatternSpec **ex;
-	struct dirent *pentry;
-	gint cur_req = 0, r;
-	gchar fpath[PATH_MAX];
-	FILE *in;
-	struct stat st;
-	gboolean is_reg, is_dir, skip;
-
-	d = opendir (name);
-
-	if (d != NULL) {
-		while ((pentry = readdir (d))!= NULL) {
-
-			if (pentry->d_name[0] == '.') {
-				continue;
-			}
-
-			r = rspamd_snprintf (fpath, sizeof (fpath), "%s%c%s",
-					name, G_DIR_SEPARATOR,
-					pentry->d_name);
-
-			/* Check exclude */
-			ex = exclude_compiled;
-			skip = FALSE;
-			while (ex != NULL && *ex != NULL) {
-				if (g_pattern_match (*ex, r, fpath, NULL)) {
-					skip = TRUE;
-					break;
-				}
-
-				ex ++;
-			}
-
-			if (skip) {
-				continue;
-			}
-
-			is_reg = FALSE;
-			is_dir = FALSE;
-
-#if (defined(_DIRENT_HAVE_D_TYPE) || defined(__APPLE__)) && defined(DT_UNKNOWN)
-			if (pentry->d_type == DT_UNKNOWN) {
-				/* Fallback to lstat */
-				if (lstat (fpath, &st) == -1) {
-					rspamd_fprintf (stderr, "cannot stat file %s: %s\n",
-							fpath, strerror (errno));
-					continue;
-				}
-
-				is_dir = S_ISDIR (st.st_mode);
-				is_reg = S_ISREG (st.st_mode);
-			}
-			else {
-				if (pentry->d_type == DT_REG) {
-					is_reg = TRUE;
-				}
-				else if (pentry->d_type == DT_DIR) {
-					is_dir = TRUE;
-				}
-			}
-#else
-			if (lstat (fpath, &st) == -1) {
-				rspamd_fprintf (stderr, "cannot stat file %s: %s\n",
-						fpath, strerror (errno));
-				continue;
-			}
-
-			is_dir = S_ISDIR (st.st_mode);
-			is_reg = S_ISREG (st.st_mode);
-#endif
-			if (is_dir) {
-				rspamc_process_dir (ev_base, cmd, fpath, attrs);
-				continue;
-			}
-			else if (is_reg) {
-				in = fopen (fpath, "r");
-				if (in == NULL) {
-					rspamd_fprintf (stderr, "cannot open file %s: %s\n",
-							fpath, strerror (errno));
-					continue;
-				}
-
-				rspamc_process_input (ev_base, cmd, in, fpath, attrs);
-				cur_req++;
-				fclose (in);
-
-				if (cur_req >= max_requests) {
-					cur_req = 0;
-					/* Wait for completion */
-					ev_loop (ev_base, 0);
-				}
-			}
-		}
-	}
-	else {
-		fprintf (stderr, "cannot open directory %s: %s\n", name, strerror (errno));
-		exit (EXIT_FAILURE);
-	}
-
-	closedir (d);
-	ev_loop (ev_base, 0);
-}
-
-
-static void
-rspamc_kwattr_free (gpointer p)
-{
-	struct rspamd_http_client_header *h = (struct rspamd_http_client_header *)p;
-
-	g_free (h->value);
-	g_free (h->name);
-	g_free (h);
-}
-
-gint
-main (gint argc, gchar **argv, gchar **env)
-{
-	gint i, start_argc, cur_req = 0, res, ret, npatterns;
-	GQueue *kwattrs;
-	GList *cur;
-	GPid cld;
-	struct rspamc_command *cmd;
-	FILE *in = NULL;
-	struct ev_loop *event_loop;
-	struct stat st;
-	struct sigaction sigpipe_act;
-	gchar **exclude_pattern;
-
-	kwattrs = g_queue_new ();
-
-	read_cmd_line (&argc, &argv);
-
-	tty = isatty (STDOUT_FILENO);
-
-	if (print_commands) {
-		print_commands_list ();
-		exit (EXIT_SUCCESS);
-	}
-
-	/* Deal with exclude patterns */
-	exclude_pattern = exclude_patterns;
-	npatterns = 0;
-
-	while (exclude_pattern && *exclude_pattern) {
-		exclude_pattern ++;
-		npatterns ++;
-	}
-
-	if (npatterns > 0) {
-		exclude_compiled = g_malloc0 (sizeof (*exclude_compiled) * (npatterns + 1));
-
-		for (i = 0; i < npatterns; i ++) {
-			exclude_compiled[i] = g_pattern_spec_new (exclude_patterns[i]);
-
-			if (exclude_compiled[i] == NULL) {
-				rspamd_fprintf (stderr, "Invalid glob pattern: %s\n",
-						exclude_patterns[i]);
-				exit (EXIT_FAILURE);
-			}
-		}
-	}
-
-	struct rspamd_external_libs_ctx *libs = rspamd_init_libs ();
-	event_loop = ev_loop_new (EVBACKEND_ALL);
-
-	struct rspamd_http_context_cfg http_config;
-
-	memset (&http_config, 0, sizeof (http_config));
-	http_config.kp_cache_size_client = 32;
-	http_config.kp_cache_size_server = 0;
-	http_config.user_agent = user_agent;
-	http_ctx = rspamd_http_context_create_config (&http_config,
-			event_loop, NULL);
-
-	/* Ignore sigpipe */
-	sigemptyset (&sigpipe_act.sa_mask);
-	sigaddset (&sigpipe_act.sa_mask, SIGPIPE);
-	sigpipe_act.sa_handler = SIG_IGN;
-	sigpipe_act.sa_flags = 0;
-	sigaction (SIGPIPE, &sigpipe_act, NULL);
-
-	/* Now read other args from argc and argv */
-	if (argc == 1) {
-		start_argc = argc;
-		in = stdin;
-		cmd = check_rspamc_command ("symbols");
-	}
-	else if (argc == 2) {
-		/* One argument is whether command or filename */
-		if ((cmd = check_rspamc_command (argv[1])) != NULL) {
-			start_argc = argc;
-			in = stdin;
-		}
-		else {
-			cmd = check_rspamc_command ("symbols"); /* Symbols command */
-			start_argc = 1;
-		}
-	}
-	else {
-		if ((cmd = check_rspamc_command (argv[1])) != NULL) {
-			/* In case of command read arguments starting from 2 */
-			if (cmd->cmd == RSPAMC_COMMAND_ADD_SYMBOL || cmd->cmd ==
-				RSPAMC_COMMAND_ADD_ACTION) {
-				if (argc < 4 || argc > 5) {
-					fprintf (stderr, "invalid arguments\n");
-					exit (EXIT_FAILURE);
-				}
-				if (argc == 5) {
-					ADD_CLIENT_HEADER (kwattrs, "metric", argv[2]);
-					ADD_CLIENT_HEADER (kwattrs, "name",	argv[3]);
-					ADD_CLIENT_HEADER (kwattrs, "value",	argv[4]);
-				}
-				else {
-					ADD_CLIENT_HEADER (kwattrs, "name",  argv[2]);
-					ADD_CLIENT_HEADER (kwattrs, "value", argv[3]);
-				}
-				start_argc = argc;
-			}
-			else {
-				start_argc = 2;
-			}
-		}
-		else {
-			cmd = check_rspamc_command ("symbols");
-			start_argc = 1;
-		}
-	}
-
-	add_options (kwattrs);
-
-	if (start_argc == argc) {
-		/* Do command without input or with stdin */
-		if (empty_input) {
-			rspamc_process_input (event_loop, cmd, NULL, "empty", kwattrs);
-		}
-		else {
-			rspamc_process_input (event_loop, cmd, in, "stdin", kwattrs);
-		}
-	}
-	else {
-		for (i = start_argc; i < argc; i++) {
-			if (cmd->cmd == RSPAMC_COMMAND_FUZZY_DELHASH) {
-				ADD_CLIENT_HEADER (kwattrs, "Hash",  argv[i]);
-			}
-			else {
-				if (stat (argv[i], &st) == -1) {
-					fprintf (stderr, "cannot stat file %s\n", argv[i]);
-					exit (EXIT_FAILURE);
-				}
-				if (S_ISDIR (st.st_mode)) {
-					/* Directories are processed with a separate limit */
-					rspamc_process_dir (event_loop, cmd, argv[i], kwattrs);
-					cur_req = 0;
-				}
-				else {
-					in = fopen (argv[i], "r");
-					if (in == NULL) {
-						fprintf (stderr, "cannot open file %s\n", argv[i]);
-						exit (EXIT_FAILURE);
-					}
-					rspamc_process_input (event_loop, cmd, in, argv[i], kwattrs);
-					cur_req++;
-					fclose (in);
-				}
-				if (cur_req >= max_requests) {
-					cur_req = 0;
-					/* Wait for completion */
-					ev_loop (event_loop, 0);
-				}
-			}
-		}
-
-		if (cmd->cmd == RSPAMC_COMMAND_FUZZY_DELHASH) {
-			rspamc_process_input (event_loop, cmd, NULL, "hashes", kwattrs);
-		}
-	}
-
-	ev_loop (event_loop, 0);
-
-	g_queue_free_full (kwattrs, rspamc_kwattr_free);
-
-	/* Wait for children processes */
-	cur = children ? g_list_first (children) : NULL;
-	ret = 0;
-
-	while (cur) {
-		cld = GPOINTER_TO_SIZE (cur->data);
-
-		if (waitpid (cld, &res, 0) == -1) {
-			fprintf (stderr, "Cannot wait for %d: %s", (gint)cld,
-					strerror (errno));
-
-			ret = errno;
-		}
-
-		if (ret == 0) {
-			/* Check return code */
-			if (WIFSIGNALED (res)) {
-				ret = WTERMSIG (res);
-			}
-			else if (WIFEXITED (res)) {
-				ret = WEXITSTATUS (res);
-			}
-		}
-
-		cur = g_list_next (cur);
-	}
-
-	if (children != NULL) {
-		g_list_free (children);
-	}
-
-	for (i = 0; i < npatterns; i ++) {
-		g_pattern_spec_free (exclude_compiled[i]);
-	}
-
-	rspamd_deinit_libs (libs);
-
-	/* Mix retcode (return from Rspamd side) and ret (return from subprocess) */
-	return ret | retcode;
-}
diff --git a/src/client/rspamc.cxx b/src/client/rspamc.cxx
new file mode 100644
index 000000000..eb82b0208
--- /dev/null
+++ b/src/client/rspamc.cxx
@@ -0,0 +1,2088 @@
+/*-
+ * Copyright 2016 Vsevolod Stakhov
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+#include "config.h"
+#include "libutil/util.h"
+#include "libserver/http/http_connection.h"
+#include "libserver/http/http_private.h"
+#include "libserver/cfg_file.h"
+#include "rspamdclient.h"
+#include "unix-std.h"
+
+#include <vector>
+#include <string>
+#include <optional>
+#include <algorithm>
+#include <functional>
+#include <cstdint>
+#include <cstdio>
+
+#include "frozen/string.h"
+#include "frozen/unordered_map.h"
+#include "fmt/format.h"
+#include "fmt/color.h"
+#include "libutil/cxx/locked_file.hxx"
+#include "libutil/cxx/util.hxx"
+
+#ifdef HAVE_SYS_WAIT_H
+
+#include <sys/wait.h>
+
+#endif
+
+#define DEFAULT_PORT 11333
+#define DEFAULT_CONTROL_PORT 11334
+
+static const char *connect_str = "localhost";
+static const char *password = nullptr;
+static const char *ip = nullptr;
+static const char *from = nullptr;
+static const char *deliver_to = nullptr;
+static const char **rcpts = nullptr;
+static const char *user = nullptr;
+static const char *helo = nullptr;
+static const char *hostname = nullptr;
+static const char *classifier = nullptr;
+static const char *local_addr = nullptr;
+static const char *execute = nullptr;
+static const char *sort = nullptr;
+static const char **http_headers = nullptr;
+static const char **exclude_patterns = nullptr;
+static int weight = 0;
+static int flag = 0;
+static const char *fuzzy_symbol = nullptr;
+static const char *dictionary = nullptr;
+static int max_requests = 8;
+static double timeout = 10.0;
+static gboolean pass_all;
+static gboolean tty = FALSE;
+static gboolean verbose = FALSE;
+static gboolean print_commands = FALSE;
+static gboolean json = FALSE;
+static gboolean compact = FALSE;
+static gboolean headers = FALSE;
+static gboolean raw = FALSE;
+static gboolean ucl_reply = FALSE;
+static gboolean extended_urls = FALSE;
+static gboolean mime_output = FALSE;
+static gboolean empty_input = FALSE;
+static gboolean compressed = FALSE;
+static gboolean profile = FALSE;
+static gboolean skip_images = FALSE;
+static gboolean skip_attachments = FALSE;
+static const char *key = nullptr;
+static const char *user_agent = "rspamc";
+
+std::vector<GPid> children;
+static GPatternSpec **exclude_compiled = nullptr;
+static struct rspamd_http_context *http_ctx;
+
+static gint retcode = EXIT_SUCCESS;
+
+static gboolean rspamc_password_callback(const gchar *option_name,
+										 const gchar *value,
+										 gpointer data,
+										 GError **error);
+
+static GOptionEntry entries[] =
+		{
+				{"connect",          'h',  0,                          G_OPTION_ARG_STRING,       &connect_str,
+																																	  "Specify host and port",                                                    nullptr},
+				{"password",         'P',  G_OPTION_FLAG_OPTIONAL_ARG, G_OPTION_ARG_CALLBACK,
+																								  (void *) &rspamc_password_callback, "Specify control password",                                                 nullptr},
+				{"classifier",       'c',  0,                          G_OPTION_ARG_STRING,       &classifier,
+																																	  "Classifier to learn spam or ham",                                          nullptr},
+				{"weight",           'w',  0,                          G_OPTION_ARG_INT,          &weight,
+																																	  "Weight for fuzzy operations",                                              nullptr},
+				{"flag",             'f',  0,                          G_OPTION_ARG_INT,          &flag,                              "Flag for fuzzy operations",
+																																																				  nullptr},
+				{"pass-all",         'p',  0,                          G_OPTION_ARG_NONE,         &pass_all,                          "Pass all filters",
+																																																				  nullptr},
+				{"verbose",          'v',  0,                          G_OPTION_ARG_NONE,         &verbose,                           "More verbose output",
+																																																				  nullptr},
+				{"ip",               'i',  0,                          G_OPTION_ARG_STRING,       &ip,
+																																	  "Emulate that message was received from specified ip address",
+																																																				  nullptr},
+				{"user",             'u',  0,                          G_OPTION_ARG_STRING,       &user,
+																																	  "Emulate that message was received from specified authenticated user",      nullptr},
+				{"deliver",          'd',  0,                          G_OPTION_ARG_STRING,       &deliver_to,
+																																	  "Emulate that message is delivered to specified user (for LDA/statistics)", nullptr},
+				{"from",             'F',  0,                          G_OPTION_ARG_STRING,       &from,
+																																	  "Emulate that message has specified SMTP FROM address",                     nullptr},
+				{"rcpt",             'r',  0,                          G_OPTION_ARG_STRING_ARRAY, &rcpts,
+																																	  "Emulate that message has specified SMTP RCPT address",                     nullptr},
+				{"helo",             0,    0,                          G_OPTION_ARG_STRING,       &helo,
+																																	  "Imitate SMTP HELO passing from MTA",                                       nullptr},
+				{"hostname",         0,    0,                          G_OPTION_ARG_STRING,       &hostname,
+																																	  "Imitate hostname passing from MTA",                                        nullptr},
+				{"timeout",          't',  0,                          G_OPTION_ARG_DOUBLE,       &timeout,
+																																	  "Time in seconds to wait for a reply",                                      nullptr},
+				{"bind",             'b',  0,                          G_OPTION_ARG_STRING,       &local_addr,
+																																	  "Bind to specified ip address",                                             nullptr},
+				{"commands",         0,    0,                          G_OPTION_ARG_NONE,         &print_commands,
+																																	  "List available commands",                                                  nullptr},
+				{"json",             'j',  0,                          G_OPTION_ARG_NONE,         &json,                              "Output json reply",                                                        nullptr},
+				{"compact",          '\0', 0,                          G_OPTION_ARG_NONE,         &compact,                           "Output compact json reply",                                                nullptr},
+				{"headers",          0,    0,                          G_OPTION_ARG_NONE,         &headers,                           "Output HTTP headers",
+																																																				  nullptr},
+				{"raw",              0,    0,                          G_OPTION_ARG_NONE,         &raw,                               "Input is a raw file, not an email file",
+																																																				  nullptr},
+				{"ucl",              0,    0,                          G_OPTION_ARG_NONE,         &ucl_reply,                         "Output ucl reply from rspamd",
+																																																				  nullptr},
+				{"max-requests",     'n',  0,                          G_OPTION_ARG_INT,          &max_requests,
+																																	  "Maximum count of parallel requests to rspamd",                             nullptr},
+				{"extended-urls",    0,    0,                          G_OPTION_ARG_NONE,         &extended_urls,
+																																	  "Output urls in extended format",                                           nullptr},
+				{"key",              0,    0,                          G_OPTION_ARG_STRING,       &key,
+																																	  "Use specified pubkey to encrypt request",                                  nullptr},
+				{"exec",             'e',  0,                          G_OPTION_ARG_STRING,       &execute,
+																																	  "Execute the specified command and pass output to it",                      nullptr},
+				{"mime",             'm',  0,                          G_OPTION_ARG_NONE,         &mime_output,
+																																	  "Write mime body of message with headers instead of just a scan's result",  nullptr},
+				{"header",           0,    0,                          G_OPTION_ARG_STRING_ARRAY, &http_headers,
+																																	  "Add custom HTTP header to query (can be repeated)",                        nullptr},
+				{"exclude",          0,    0,                          G_OPTION_ARG_STRING_ARRAY, &exclude_patterns,
+																																	  "Exclude specific glob patterns in file names (can be repeated)",           nullptr},
+				{"sort",             0,    0,                          G_OPTION_ARG_STRING,       &sort,
+																																	  "Sort output in a specific order (name, weight, frequency, hits)",          nullptr},
+				{"empty",            'E',  0,                          G_OPTION_ARG_NONE,         &empty_input,
+																																	  "Allow empty input instead of reading from stdin",                          nullptr},
+				{"fuzzy-symbol",     'S',  0,                          G_OPTION_ARG_STRING,       &fuzzy_symbol,
+																																	  "Learn the specified fuzzy symbol",                                         nullptr},
+				{"compressed",       'z',  0,                          G_OPTION_ARG_NONE,         &compressed,
+																																	  "Enable zstd compression",                                                  nullptr},
+				{"profile",          '\0', 0,                          G_OPTION_ARG_NONE,         &profile,
+																																	  "Profile symbols execution time",                                           nullptr},
+				{"dictionary",       'D',  0,                          G_OPTION_ARG_FILENAME,     &dictionary,
+																																	  "Use dictionary to compress data",                                          nullptr},
+				{"skip-images",      '\0', 0,                          G_OPTION_ARG_NONE,         &skip_images,
+																																	  "Skip images when learning/unlearning fuzzy",                               nullptr},
+				{"skip-attachments", '\0', 0,                          G_OPTION_ARG_NONE,         &skip_attachments,
+																																	  "Skip attachments when learning/unlearning fuzzy",                          nullptr},
+				{"user-agent",       'U',  0,                          G_OPTION_ARG_STRING,       &user_agent,
+																																	  "Use specific User-Agent instead of \"rspamc\"",                            nullptr},
+				{nullptr,            0,    0,                          G_OPTION_ARG_NONE,         nullptr,                            nullptr,                                                                    nullptr}
+		};
+
+static void rspamc_symbols_output(FILE *out, ucl_object_t *obj);
+
+static void rspamc_uptime_output(FILE *out, ucl_object_t *obj);
+
+static void rspamc_counters_output(FILE *out, ucl_object_t *obj);
+
+static void rspamc_stat_output(FILE *out, ucl_object_t *obj);
+
+enum rspamc_command_type {
+	RSPAMC_COMMAND_UNKNOWN = 0,
+	RSPAMC_COMMAND_CHECK,
+	RSPAMC_COMMAND_SYMBOLS,
+	RSPAMC_COMMAND_LEARN_SPAM,
+	RSPAMC_COMMAND_LEARN_HAM,
+	RSPAMC_COMMAND_FUZZY_ADD,
+	RSPAMC_COMMAND_FUZZY_DEL,
+	RSPAMC_COMMAND_FUZZY_DELHASH,
+	RSPAMC_COMMAND_STAT,
+	RSPAMC_COMMAND_STAT_RESET,
+	RSPAMC_COMMAND_COUNTERS,
+	RSPAMC_COMMAND_UPTIME,
+	RSPAMC_COMMAND_ADD_SYMBOL,
+	RSPAMC_COMMAND_ADD_ACTION
+};
+
+struct rspamc_command {
+	enum rspamc_command_type cmd;
+	const char *name;
+	const char *path;
+	const char *description;
+	gboolean is_controller;
+	gboolean is_privileged;
+	gboolean need_input;
+
+	void (*command_output_func)(FILE *, ucl_object_t *obj);
+};
+
+std::vector<rspamc_command> rspamc_commands = {
+		{
+				.cmd = RSPAMC_COMMAND_SYMBOLS,
+				.name = "symbols",
+				.path = "checkv2",
+				.description = "scan message and show symbols (default command)",
+				.is_controller = FALSE,
+				.is_privileged = FALSE,
+				.need_input = TRUE,
+				.command_output_func = rspamc_symbols_output
+		},
+		{
+				.cmd = RSPAMC_COMMAND_LEARN_SPAM,
+				.name = "learn_spam",
+				.path = "learnspam",
+				.description = "learn message as spam",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = TRUE,
+				.command_output_func = nullptr
+		},
+		{
+				.cmd = RSPAMC_COMMAND_LEARN_HAM,
+				.name = "learn_ham",
+				.path = "learnham",
+				.description = "learn message as ham",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = TRUE,
+				.command_output_func = nullptr
+		},
+		{
+				.cmd = RSPAMC_COMMAND_FUZZY_ADD,
+				.name = "fuzzy_add",
+				.path = "fuzzyadd",
+				.description =
+				"add hashes from a message to the fuzzy storage (check -f and -w options for this command)",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = TRUE,
+				.command_output_func = nullptr
+		},
+		{
+				.cmd = RSPAMC_COMMAND_FUZZY_DEL,
+				.name = "fuzzy_del",
+				.path = "fuzzydel",
+				.description =
+				"delete hashes from a message from the fuzzy storage (check -f option for this command)",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = TRUE,
+				.command_output_func = nullptr
+		},
+		{
+				.cmd = RSPAMC_COMMAND_FUZZY_DELHASH,
+				.name = "fuzzy_delhash",
+				.path = "fuzzydelhash",
+				.description =
+				"delete a hash from fuzzy storage (check -f option for this command)",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = FALSE,
+				.command_output_func = nullptr
+		},
+		{
+				.cmd = RSPAMC_COMMAND_STAT,
+				.name = "stat",
+				.path = "stat",
+				.description = "show rspamd statistics",
+				.is_controller = TRUE,
+				.is_privileged = FALSE,
+				.need_input = FALSE,
+				.command_output_func = rspamc_stat_output,
+		},
+		{
+				.cmd = RSPAMC_COMMAND_STAT_RESET,
+				.name = "stat_reset",
+				.path = "statreset",
+				.description = "show and reset rspamd statistics (useful for graphs)",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = FALSE,
+				.command_output_func = rspamc_stat_output
+		},
+		{
+				.cmd = RSPAMC_COMMAND_COUNTERS,
+				.name = "counters",
+				.path = "counters",
+				.description = "display rspamd symbols statistics",
+				.is_controller = TRUE,
+				.is_privileged = FALSE,
+				.need_input = FALSE,
+				.command_output_func = rspamc_counters_output
+		},
+		{
+				.cmd = RSPAMC_COMMAND_UPTIME,
+				.name = "uptime",
+				.path = "auth",
+				.description = "show rspamd uptime",
+				.is_controller = TRUE,
+				.is_privileged = FALSE,
+				.need_input = FALSE,
+				.command_output_func = rspamc_uptime_output
+		},
+		{
+				.cmd = RSPAMC_COMMAND_ADD_SYMBOL,
+				.name = "add_symbol",
+				.path = "addsymbol",
+				.description = "add or modify symbol settings in rspamd",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = FALSE,
+				.command_output_func = nullptr
+		},
+		{
+				.cmd = RSPAMC_COMMAND_ADD_ACTION,
+				.name = "add_action",
+				.path = "addaction",
+				.description = "add or modify action settings",
+				.is_controller = TRUE,
+				.is_privileged = TRUE,
+				.need_input = FALSE,
+				.command_output_func = nullptr
+		}
+};
+
+struct rspamc_callback_data {
+	struct rspamc_command cmd;
+	std::string filename;
+};
+
+static gboolean
+rspamc_password_callback(const gchar *option_name,
+						 const gchar *value,
+						 gpointer data,
+						 GError **error)
+{
+	// Some efforts to keep password erased
+	static std::vector<char, rspamd::secure_mem_allocator<char>> processed_passwd;
+	processed_passwd.clear();
+
+	if (value != nullptr) {
+		std::string_view value_view{value};
+		if (value_view[0] == '/' || value_view[0] == '.') {
+			/* Try to open file */
+			auto locked_mmap = rspamd::util::raii_mmaped_locked_file::mmap_shared(value, O_RDONLY, PROT_READ);
+
+			if (!locked_mmap.has_value() || locked_mmap.value().get_size() == 0) {
+				/* Just use it as a string */
+				processed_passwd.assign(std::begin(value_view), std::end(value_view));
+				processed_passwd.push_back('\0');
+			}
+			else {
+				/* Strip trailing spaces */
+				auto *map = (char *) locked_mmap.value().get_map();
+				auto *end = map + locked_mmap.value().get_size() - 1;
+
+				while (g_ascii_isspace(*end) && end > map) {
+					end--;
+				}
+
+				end++;
+				value_view = std::string_view{map, static_cast<std::size_t>(end - map + 1)};
+				processed_passwd.assign(std::begin(value_view), std::end(value_view));
+				processed_passwd.push_back('\0');
+			}
+		}
+		else {
+			processed_passwd.assign(std::begin(value_view), std::end(value_view));
+			processed_passwd.push_back('\0');
+		}
+	}
+	else {
+		/* Read password from console */
+		auto plen = 8192;
+		processed_passwd.resize(plen, '\0');
+		plen = rspamd_read_passphrase(processed_passwd.data(), plen, 0, nullptr);
+		if (plen == 0) {
+			fmt::print(stderr, "Invalid password\n");
+			exit(EXIT_FAILURE);
+		}
+		processed_passwd.resize(plen);
+		processed_passwd.push_back('\0');
+	}
+
+	password = processed_passwd.data();
+
+	return TRUE;
+}
+
+/*
+ * Parse command line
+ */
+static void
+read_cmd_line(gint *argc, gchar ***argv)
+{
+	GError *error = nullptr;
+	GOptionContext *context;
+
+	/* Prepare parser */
+	context = g_option_context_new("- run rspamc client");
+	g_option_context_set_summary(context,
+			"Summary:\n  Rspamd client version " RVERSION "\n  Release id: " RID);
+	g_option_context_add_main_entries(context, entries, nullptr);
+
+	/* Parse options */
+	if (!g_option_context_parse(context, argc, argv, &error)) {
+		fmt::print(stderr, "option parsing failed: {}\n", error->message);
+		g_option_context_free(context);
+		exit(EXIT_FAILURE);
+	}
+
+	if (json || compact) {
+		ucl_reply = TRUE;
+	}
+	/* Argc and argv are shifted after this function */
+	g_option_context_free(context);
+}
+
+static auto
+add_client_header(GQueue *opts, const char *hn, const char *hv) -> void
+{
+	g_assert(hn != nullptr);
+	g_assert(hv != nullptr);
+	auto *nhdr = g_new(rspamd_http_client_header, 1);
+	nhdr->name = g_strdup(hn);
+	nhdr->value = g_strdup(hv);
+	g_queue_push_tail(opts, (void *) nhdr);
+}
+
+static auto
+add_client_header(GQueue *opts, std::string_view hn, std::string_view hv) -> void
+{
+	auto *nhdr = g_new(rspamd_http_client_header, 1);
+	nhdr->name = g_new(char, hn.size() + 1);
+	rspamd_strlcpy(nhdr->name, hn.data(), hn.size() + 1);
+	nhdr->value = g_new(char, hv.size() + 1);
+	rspamd_strlcpy(nhdr->value, hv.data(), hv.size() + 1);
+	g_queue_push_tail(opts, (void *) nhdr);
+}
+
+static auto
+rspamd_string_tolower(const char *inp) -> std::string
+{
+	std::string s{inp};
+	std::transform(std::begin(s), std::end(s), std::begin(s),
+			[](unsigned char c) { return std::tolower(c); });
+	return s;
+}
+
+static auto
+rspamd_action_from_str_rspamc(const char *data) -> std::optional<int>
+{
+	static constexpr const auto str_map = frozen::make_unordered_map<frozen::string, int>({
+			{"reject",          METRIC_ACTION_REJECT},
+			{"greylist",        METRIC_ACTION_GREYLIST},
+			{"add_header",      METRIC_ACTION_ADD_HEADER},
+			{"add header",      METRIC_ACTION_ADD_HEADER},
+			{"rewrite_subject", METRIC_ACTION_REWRITE_SUBJECT},
+			{"rewrite subject", METRIC_ACTION_REWRITE_SUBJECT},
+			{"soft_reject",     METRIC_ACTION_SOFT_REJECT},
+			{"soft reject",     METRIC_ACTION_SOFT_REJECT},
+			{"no_action",       METRIC_ACTION_NOACTION},
+			{"no action",       METRIC_ACTION_NOACTION},
+	});
+
+	auto st_lower = rspamd_string_tolower(data);
+	return rspamd::find_map(str_map, std::string_view{st_lower});
+}
+
+/*
+ * Check rspamc command from string (used for arguments parsing)
+ */
+static auto
+check_rspamc_command(const char *cmd) -> std::optional<rspamc_command>
+{
+	static constexpr const auto str_map = frozen::make_unordered_map<frozen::string, int>({
+			{"symbols",       RSPAMC_COMMAND_SYMBOLS},
+			{"check",         RSPAMC_COMMAND_SYMBOLS},
+			{"report",        RSPAMC_COMMAND_SYMBOLS},
+			{"learn_spam",    RSPAMC_COMMAND_LEARN_SPAM},
+			{"learn_ham",     RSPAMC_COMMAND_LEARN_HAM},
+			{"fuzzy_add",     RSPAMC_COMMAND_FUZZY_ADD},
+			{"fuzzy_del",     RSPAMC_COMMAND_FUZZY_DEL},
+			{"fuzzy_delhash", RSPAMC_COMMAND_FUZZY_DELHASH},
+			{"stat",          RSPAMC_COMMAND_STAT},
+			{"stat_reset",    RSPAMC_COMMAND_STAT_RESET},
+			{"counters",      RSPAMC_COMMAND_COUNTERS},
+			{"uptime",        RSPAMC_COMMAND_UPTIME},
+	});
+
+	std::string cmd_lc = rspamd_string_tolower(cmd);
+	auto ct = rspamd::find_map(str_map, std::string_view{cmd_lc});
+
+	auto elt_it = std::find_if(rspamc_commands.begin(), rspamc_commands.end(), [&](const auto &item) {
+		return item.cmd == ct;
+	});
+
+	if (elt_it != std::end(rspamc_commands)) {
+		return *elt_it;
+	}
+
+	return std::nullopt;
+}
+
+static void
+print_commands_list()
+{
+	guint cmd_len = 0;
+	gchar fmt_str[32];
+
+	fmt::print(stdout, "Rspamc commands summary:\n");
+
+	for (const auto &cmd: rspamc_commands) {
+		auto clen = strlen(cmd.name);
+
+		if (clen > cmd_len) {
+			cmd_len = clen;
+		}
+	}
+
+	rspamd_snprintf(fmt_str, sizeof(fmt_str), "  {:%d} ({:7}{:1})\t{}\n",
+			cmd_len);
+
+	for (const auto &cmd: rspamc_commands) {
+		fmt::print(stdout,
+				fmt_str,
+				cmd.name,
+				cmd.is_controller ? "control" : "normal",
+				cmd.is_privileged ? "*" : "",
+				cmd.description);
+	}
+
+	fmt::print(stdout,
+			"\n* is for privileged commands that may need password (see -P option)\n");
+	fmt::print(stdout,
+			"control commands use port 11334 while normal use 11333 by default (see -h option)\n");
+}
+
+static void
+add_options(GQueue *opts)
+{
+	std::string flagbuf;
+
+	if (ip != nullptr) {
+		rspamd_inet_addr_t *addr = nullptr;
+
+		if (!rspamd_parse_inet_address(&addr, ip, strlen(ip),
+				RSPAMD_INET_ADDRESS_PARSE_DEFAULT)) {
+			/* Try to resolve */
+			struct addrinfo hints, *res, *cur;
+			int r;
+
+			memset(&hints, 0, sizeof(hints));
+			hints.ai_socktype = SOCK_STREAM; /* Type of the socket */
+#ifdef AI_IDN
+			hints.ai_flags = AI_NUMERICSERV|AI_IDN;
+#else
+			hints.ai_flags = AI_NUMERICSERV;
+#endif
+			hints.ai_family = AF_UNSPEC;
+
+			if ((r = getaddrinfo(ip, "25", &hints, &res)) == 0) {
+
+				cur = res;
+				while (cur) {
+					addr = rspamd_inet_address_from_sa(cur->ai_addr,
+							cur->ai_addrlen);
+
+					if (addr != nullptr) {
+						ip = g_strdup(rspamd_inet_address_to_string(addr));
+						rspamd_inet_address_free(addr);
+						break;
+					}
+
+					cur = cur->ai_next;
+				}
+
+				freeaddrinfo(res);
+			}
+			else {
+				fmt::print(stderr, "address resolution for {} failed: {}\n",
+						ip,
+						gai_strerror(r));
+			}
+		}
+		else {
+			rspamd_inet_address_free(addr);
+		}
+
+		add_client_header(opts, "Ip", ip);
+	}
+
+	if (from != nullptr) {
+		add_client_header(opts, "From", from);
+	}
+
+	if (user != nullptr) {
+		add_client_header(opts, "User", user);
+	}
+
+	if (rcpts != nullptr) {
+		for (auto *rcpt = rcpts; *rcpt != nullptr; rcpt++) {
+			add_client_header(opts, "Rcpt", *rcpt);
+		}
+	}
+
+	if (deliver_to != nullptr) {
+		add_client_header(opts, "Deliver-To", deliver_to);
+	}
+
+	if (helo != nullptr) {
+		add_client_header(opts, "Helo", helo);
+	}
+
+	if (hostname != nullptr) {
+		add_client_header(opts, "Hostname", hostname);
+	}
+
+	if (password != nullptr) {
+		add_client_header(opts, "Password", password);
+	}
+
+	if (pass_all) {
+		flagbuf += "pass_all,";
+	}
+
+	if (raw) {
+		add_client_header(opts, "Raw", "yes");
+	}
+
+	if (classifier) {
+		add_client_header(opts, "Classifier", classifier);
+	}
+
+	if (weight != 0) {
+		auto nstr = fmt::format("{}", weight);
+		add_client_header(opts, "Weight", nstr.c_str());
+	}
+
+	if (fuzzy_symbol != nullptr) {
+		add_client_header(opts, "Symbol", fuzzy_symbol);
+	}
+
+	if (flag != 0) {
+		auto nstr = fmt::format("{}", flag);
+		add_client_header(opts, "Flag", nstr.c_str());
+	}
+
+	if (extended_urls) {
+		add_client_header(opts, "URL-Format", "extended");
+	}
+
+	if (profile) {
+		flagbuf += "profile,";
+	}
+
+	flagbuf += "body_block,";
+
+	if (skip_images) {
+		add_client_header(opts, "Skip-Images", "true");
+	}
+
+	if (skip_attachments) {
+		add_client_header(opts, "Skip-Attachments", "true");
+	}
+
+	auto hdr = http_headers;
+
+	while (hdr != nullptr && *hdr != nullptr) {
+		std::string_view hdr_view{*hdr};
+
+		auto delim_pos = std::find_if(std::begin(hdr_view), std::end(hdr_view), [](auto c) {
+			return c == ':' || c == '=';
+		});
+		if (delim_pos == std::end(hdr_view)) {
+			/* Just a header name with no value */
+			add_client_header(opts, *hdr, "");
+		}
+		else {
+			add_client_header(opts,
+					hdr_view.substr(0, std::distance(delim_pos, std::begin(hdr_view))),
+					hdr_view.substr(std::distance(delim_pos, std::begin(hdr_view) + 1)));
+		}
+
+		hdr++;
+	}
+
+	if (!flagbuf.empty()) {
+		if (flagbuf.back() == ',') {
+			flagbuf.pop_back();
+		}
+
+		add_client_header(opts, "Flags", flagbuf.c_str());
+	}
+}
+
+static void
+rspamc_symbol_output(FILE *out, const ucl_object_t *obj)
+{
+	auto first = true;
+
+	fmt::print(out, "Symbol: {} ", ucl_object_key(obj));
+	const auto *val = ucl_object_lookup(obj, "score");
+
+	if (val != nullptr) {
+		fmt::print(out, "({:.2})", ucl_object_todouble(val));
+	}
+	val = ucl_object_lookup(obj, "options");
+	if (val != nullptr && val->type == UCL_ARRAY) {
+		ucl_object_iter_t it = nullptr;
+		const ucl_object_t *cur;
+
+		fmt::print(out, "[");
+
+		while ((cur = ucl_object_iterate (val, &it, true)) != nullptr) {
+			if (first) {
+				fmt::print(out, "{}", ucl_object_tostring(cur));
+				first = false;
+			}
+			else {
+				fmt::print(out, ", {}", ucl_object_tostring(cur));
+			}
+		}
+		fmt::print(out, "]");
+	}
+	fmt::print(out, "\n");
+}
+
+static void
+rspamc_metric_output(FILE *out, const ucl_object_t *obj)
+{
+	double score = 0, required_score = 0;
+	int got_scores = 0;
+
+	auto print_protocol_string = [&](const char *ucl_name, const char *output_message) {
+		auto *elt = ucl_object_lookup(obj, ucl_name);
+		if (elt) {
+			fmt::print(out, "{}: {}\n", output_message, ucl_object_tostring(elt));
+		}
+	};
+
+	fmt::print(out, "[Metric: default]\n");
+
+	const auto *elt = ucl_object_lookup(obj, "required_score");
+
+	if (elt) {
+		required_score = ucl_object_todouble(elt);
+		got_scores++;
+	}
+
+	elt = ucl_object_lookup(obj, "score");
+
+	if (elt) {
+		score = ucl_object_todouble(elt);
+		got_scores++;
+	}
+
+	print_protocol_string("action", "Action");
+
+	elt = ucl_object_lookup(obj, "action");
+	if (elt) {
+		auto act = rspamd_action_from_str_rspamc(ucl_object_tostring(elt));
+
+		if (act.has_value()) {
+			fmt::print(out, "Spam: {}\n", act.value() < METRIC_ACTION_GREYLIST ?
+											  "true" : "false");
+		}
+	}
+
+	print_protocol_string("subject", "Subject");
+
+	if (got_scores == 2) {
+		fmt::print(out,
+				"Score: {:.2} / {:.2}\n",
+				score,
+				required_score);
+	}
+
+	elt = ucl_object_lookup(obj, "symbols");
+
+	if (elt) {
+		std::vector<const ucl_object_t *> symbols;
+		ucl_object_iter_t it = nullptr;
+		const ucl_object_t *cur;
+
+		while ((cur = ucl_object_iterate (elt, &it, true)) != nullptr) {
+			symbols.push_back(cur);
+		}
+
+		std::stable_sort(std::begin(symbols), std::end(symbols),
+						 [](const ucl_object_t *u1, const ucl_object_t *u2) -> int {
+							 return strcmp(ucl_object_key(u1), ucl_object_key(u2));
+						 });
+
+		for (const auto *sym_obj : symbols) {
+			rspamc_symbol_output(out, sym_obj);
+		}
+	}
+}
+
+static void
+rspamc_profile_output(FILE *out, const ucl_object_t *obj)
+{
+	ucl_object_iter_t it = nullptr;
+	const ucl_object_t *cur;
+
+	std::vector<const ucl_object_t *> ar;
+
+	while ((cur = ucl_object_iterate (obj, &it, true)) != nullptr) {
+		ar.push_back(cur);
+	}
+	std::stable_sort(std::begin(ar), std::end(ar),
+			[](const ucl_object_t *u1, const ucl_object_t *u2) -> int {
+				return ucl_object_compare(u1, u2);
+			});
+
+	for (const auto *cur_elt : ar) {
+		fmt::print(out, "\t{}: {:3} usec\n",
+				ucl_object_key(cur_elt), ucl_object_todouble(cur_elt));
+	}
+}
+
+static void
+rspamc_symbols_output(FILE *out, ucl_object_t *obj)
+{
+	rspamc_metric_output(out, obj);
+
+	auto print_protocol_string = [&](const char *ucl_name, const char *output_message) {
+		auto *elt = ucl_object_lookup(obj, ucl_name);
+		if (elt) {
+			fmt::print(out, "{}: {}\n", output_message, ucl_object_tostring(elt));
+		}
+	};
+
+	print_protocol_string("message-id", "Message-ID");
+	print_protocol_string("queue-id", "Queue-ID");
+
+	const auto *elt = ucl_object_lookup(obj, "urls");
+
+	if (elt) {
+		char *emitted;
+
+		if (!extended_urls || compact) {
+			emitted = (char *)ucl_object_emit(elt, UCL_EMIT_JSON_COMPACT);
+		}
+		else {
+			emitted = (char *)ucl_object_emit(elt, UCL_EMIT_JSON);
+		}
+
+		fmt::print(out, "Urls: {}\n", emitted);
+		free(emitted);
+	}
+
+	elt = ucl_object_lookup(obj, "emails");
+
+	if (elt) {
+		char *emitted;
+		if (!extended_urls || compact) {
+			emitted = (char *)ucl_object_emit(elt, UCL_EMIT_JSON_COMPACT);
+		}
+		else {
+			emitted = (char *)ucl_object_emit(elt, UCL_EMIT_JSON);
+		}
+
+		fmt::print(out, "Emails: {}\n", emitted);
+		free(emitted);
+	}
+
+	print_protocol_string("error", "Scan error");
+
+	elt = ucl_object_lookup(obj, "messages");
+	if (elt && elt->type == UCL_OBJECT) {
+		ucl_object_iter_t mit = nullptr;
+		const ucl_object_t *cmesg;
+
+		while ((cmesg = ucl_object_iterate (elt, &mit, true)) != nullptr) {
+			fmt::print(out, "Message - {}: {}\n",
+					ucl_object_key(cmesg), ucl_object_tostring(cmesg));
+		}
+	}
+
+	elt = ucl_object_lookup(obj, "dkim-signature");
+	if (elt && elt->type == UCL_STRING) {
+		fmt::print(out, "DKIM-Signature: {}\n", ucl_object_tostring(elt));
+	}
+	else if (elt && elt->type == UCL_ARRAY) {
+		ucl_object_iter_t it = nullptr;
+		const ucl_object_t *cur;
+
+		while ((cur = ucl_object_iterate (elt, &it, true)) != nullptr) {
+			fmt::print(out, "DKIM-Signature: {}\n", ucl_object_tostring(cur));
+		}
+	}
+
+	elt = ucl_object_lookup(obj, "profile");
+
+	if (elt) {
+		fmt::print(out, "Profile data:\n");
+		rspamc_profile_output(out, elt);
+	}
+}
+
+static void
+rspamc_uptime_output(FILE *out, ucl_object_t *obj)
+{
+	int64_t seconds, days, hours, minutes;
+
+	const auto *elt = ucl_object_lookup(obj, "version");
+	if (elt != nullptr) {
+		fmt::print(out, "Rspamd version: %s\n", ucl_object_tostring(
+				elt));
+	}
+
+	elt = ucl_object_lookup(obj, "uptime");
+	if (elt != nullptr) {
+		fmt::print("Uptime: ");
+		seconds = ucl_object_toint(elt);
+		if (seconds >= 2 * 3600) {
+			days = seconds / 86400;
+			hours = seconds / 3600 - days * 24;
+			minutes = seconds / 60 - hours * 60 - days * 1440;
+			fmt::print("{} day{} {} hour{} {} minute{}\n", days,
+					days > 1 ? "s" : "", hours, hours > 1 ? "s" : "",
+					minutes, minutes > 1 ? "s" : "");
+		}
+			/* If uptime is less than 1 minute print only seconds */
+		else if (seconds / 60 == 0) {
+			fmt::print("{} second%s\n", seconds,
+					(gint) seconds > 1 ? "s" : "");
+		}
+			/* Else print the minutes and seconds. */
+		else {
+			hours = seconds / 3600;
+			minutes = seconds / 60 - hours * 60;
+			seconds -= hours * 3600 + minutes * 60;
+			fmt::print("{} hour {} minute{} {} second{}\n", hours,
+					minutes, minutes > 1 ? "s" : "",
+					seconds, seconds > 1 ? "s" : "");
+		}
+	}
+}
+
+static constexpr auto
+sv_ends_with(std::string_view inp, std::string_view suffix) -> bool {
+	return inp.size() >= suffix.size() && inp.compare(inp.size() - suffix.size(), std::string_view::npos, suffix) == 0;
+}
+
+static void
+rspamc_counters_output(FILE *out, ucl_object_t *obj)
+{
+	using sort_lambda = std::function<int(const ucl_object_t *, const ucl_object_t *)>;
+	static const auto sort_map = frozen::make_unordered_map<frozen::string, sort_lambda>({
+			{"name", [](const ucl_object_t *o1, const ucl_object_t *o2) -> int {
+				const auto *elt1 = ucl_object_lookup(o1, "symbol");
+				const auto *elt2 = ucl_object_lookup(o2, "symbol");
+
+				if (elt1 && elt2) {
+					return strcmp(ucl_object_tostring(elt1),
+							ucl_object_tostring(elt2));
+				}
+				return 0;
+			}},
+			{"weight", [](const ucl_object_t *o1, const ucl_object_t *o2) -> int {
+				const auto *elt1 = ucl_object_lookup(o1, "weight");
+				const auto *elt2 = ucl_object_lookup(o2, "weight");
+
+				if (elt1 && elt2) {
+					return ucl_object_todouble(elt1) * 1000.0 - ucl_object_todouble(elt2) * 1000.0;
+				}
+				return 0;
+			}},
+			{"time", [](const ucl_object_t *o1, const ucl_object_t *o2) -> int {
+				const auto *elt1 = ucl_object_lookup(o1, "time");
+				const auto *elt2 = ucl_object_lookup(o2, "time");
+
+				if (elt1 && elt2) {
+					return ucl_object_todouble(elt1) * 1000.0 - ucl_object_todouble(elt2) * 1000.0;
+				}
+				return 0;
+			}},
+			{"frequency", [](const ucl_object_t *o1, const ucl_object_t *o2) -> int {
+				const auto *elt1 = ucl_object_lookup(o1, "frequency");
+				const auto *elt2 = ucl_object_lookup(o2, "frequency");
+
+				if (elt1 && elt2) {
+					return ucl_object_todouble(elt1) * 1000.0 - ucl_object_todouble(elt2) * 1000.0;
+				}
+				return 0;
+			}},
+			{"hits", [](const ucl_object_t *o1, const ucl_object_t *o2) -> int {
+				const auto *elt1 = ucl_object_lookup(o1, "hits");
+				const auto *elt2 = ucl_object_lookup(o2, "hits");
+
+				if (elt1 && elt2) {
+					return ucl_object_toint(elt1) - ucl_object_toint(elt2);
+				}
+				return 0;
+			}},
+	});
+
+
+	if (obj->type != UCL_ARRAY) {
+		fmt::print(out, "Bad output\n");
+		return;
+	}
+
+	std::vector<const ucl_object_t *> counters_vec;
+	auto max_len = sizeof("Symbol") - 1;
+	ucl_object_iter_t iter = nullptr;
+	const ucl_object_t *cur;
+
+	while ((cur = ucl_object_iterate (obj, &iter, true)) != nullptr) {
+		const auto *sym = ucl_object_lookup(cur, "symbol");
+		if (sym != nullptr) {
+			if (sym->len > max_len) {
+				max_len = sym->len;
+			}
+		}
+		counters_vec.push_back(cur);
+	}
+
+	/* Sort symbols by their order */
+	if (sort != nullptr) {
+		auto sort_view = std::string_view{sort};
+		auto inverse = false;
+
+		if (sv_ends_with(sort_view, ":desc")) {
+			inverse = true;
+			sort_view = std::string_view{sort, strlen(sort) - sizeof(":desc") + 1};
+		}
+
+		const auto sort_functor = sort_map.find(sort_view);
+		if (sort_functor != sort_map.end()) {
+			std::stable_sort(std::begin(counters_vec), std::end(counters_vec),
+							 [&](const ucl_object_t *o1, const ucl_object_t *o2) {
+				auto order = sort_functor->second(o1, o2);
+
+				return inverse ? -(order) : order;
+			});
+		}
+	}
+
+	char fmt_buf[64], dash_buf[82], sym_buf[82];
+	const int dashes = 44;
+
+	max_len = MIN (sizeof(dash_buf) - dashes - 1, max_len);
+	rspamd_snprintf(fmt_buf, sizeof(fmt_buf),
+			"| {:3} | {:%d} | {:^7} | {:^13} | {:^7} |\n", max_len);
+	memset(dash_buf, '-', dashes + max_len);
+	dash_buf[dashes + max_len] = '\0';
+
+	fmt::print(out, "Symbols cache\n");
+	fmt::print(out, fmt::emphasis::bold, " {} \n", dash_buf);
+	fmt::print(out, fmt::emphasis::bold,
+			fmt_buf, "Pri", "Symbol", "Weight", "Frequency", "Hits");
+	fmt::print(out, fmt::emphasis::bold, " {} \n", dash_buf);
+	fmt::print(out, fmt_buf, "", "", "", "hits/min", "");
+	rspamd_snprintf(fmt_buf, sizeof(fmt_buf),
+			"| {:3} | {:%d} | {:7.1f} | {:^6.3f}({:^5.3f}) | {:7} |\n", max_len);
+
+	for (const auto [i, cur] : rspamd::enumerate(counters_vec)) {
+		fmt::print(out, " {} \n", dash_buf);
+		const auto *sym = ucl_object_lookup(cur, "symbol");
+		const auto *weight = ucl_object_lookup(cur, "weight");
+		const auto *freq = ucl_object_lookup(cur, "frequency");
+		const auto *freq_dev = ucl_object_lookup(cur, "frequency_stddev");
+		const auto *nhits = ucl_object_lookup(cur, "hits");
+
+		if (sym && weight && freq && nhits) {
+			const char *sym_name;
+
+			if (sym->len > max_len) {
+				rspamd_snprintf(sym_buf, sizeof(sym_buf), "%*s...",
+						(max_len - 3), ucl_object_tostring(sym));
+				sym_name = sym_buf;
+			}
+			else {
+				sym_name = ucl_object_tostring(sym);
+			}
+
+			fmt::print(out, fmt_buf, i,
+					sym_name,
+					ucl_object_todouble(weight),
+					ucl_object_todouble(freq) * 60.0,
+					ucl_object_todouble(freq_dev) * 60.0,
+					(std::uintmax_t)ucl_object_toint(nhits));
+		}
+	}
+	fmt::print(out, " {} \n", dash_buf);
+}
+
+static void
+rspamc_stat_actions(ucl_object_t *obj, std::string &out, std::int64_t scanned)
+{
+	const ucl_object_t *actions = ucl_object_lookup(obj, "actions"), *cur;
+	ucl_object_iter_t iter = nullptr;
+
+	if (scanned > 0) {
+		if (actions && ucl_object_type(actions) == UCL_OBJECT) {
+			while ((cur = ucl_object_iterate (actions, &iter, true)) != nullptr) {
+				auto cnt = ucl_object_toint(cur);
+				fmt::format_to(std::back_inserter(out), "Messages with action {}: {}, {:.2f}%",
+						ucl_object_key(cur), cnt,
+						((double) cnt / (double) scanned) * 100.);
+			}
+		}
+
+		auto spam = ucl_object_toint(ucl_object_lookup(obj, "spam_count"));
+		auto ham = ucl_object_toint(ucl_object_lookup(obj, "ham_count"));
+		fmt::format_to(std::back_inserter(out), "Messages treated as spam: {}, {:.2f}%\n", spam,
+				((double) spam / (double) scanned) * 100.);
+		fmt::format_to(std::back_inserter(out), "Messages treated as ham: {}, {:.2f}%\n", ham,
+				((double) ham / (double) scanned) * 100.);
+	}
+}
+
+static void
+rspamc_stat_statfile(const ucl_object_t *obj, std::string &out)
+{
+	auto version = ucl_object_toint(ucl_object_lookup(obj, "revision"));
+	auto size = ucl_object_toint(ucl_object_lookup(obj, "size"));
+	auto blocks = ucl_object_toint(ucl_object_lookup(obj, "total"));
+	auto used_blocks = ucl_object_toint(ucl_object_lookup(obj, "used"));
+	auto label = ucl_object_tostring(ucl_object_lookup(obj, "label"));
+	auto symbol = ucl_object_tostring(ucl_object_lookup(obj, "symbol"));
+	auto type = ucl_object_tostring(ucl_object_lookup(obj, "type"));
+	auto nlanguages = ucl_object_toint(ucl_object_lookup(obj, "languages"));
+	auto nusers = ucl_object_toint(ucl_object_lookup(obj, "users"));
+
+	if (label) {
+		fmt::format_to(std::back_inserter(out), "Statfile: {} <{}> type: {}; ", symbol,
+				label, type);
+	}
+	else {
+		fmt::format_to(std::back_inserter(out), "Statfile: {} type: {}; ", symbol, type);
+	}
+	fmt::format_to(std::back_inserter(out), "length: {}; free blocks: {}; total blocks: {}; "
+							   "free: {:.2f}%; learned: {}; users: {}; languages: {}\n",
+			size,
+			blocks - used_blocks, blocks,
+			blocks > 0 ? (blocks - used_blocks) * 100.0 / (double) blocks : 0,
+			version,
+			nusers, nlanguages);
+}
+
+static void
+rspamc_stat_output(FILE *out, ucl_object_t *obj)
+{
+	std::string out_str;
+
+	out_str.reserve(8192);
+
+	auto scanned = ucl_object_toint(ucl_object_lookup(obj, "scanned"));
+	fmt::format_to(std::back_inserter(out_str), "Messages scanned: {}\n", scanned);
+
+	rspamc_stat_actions(obj, out_str, scanned);
+
+	fmt::format_to(std::back_inserter(out_str), "Messages learned: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "learned")));
+	fmt::format_to(std::back_inserter(out_str), "Connections count: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "connections")));
+	fmt::format_to(std::back_inserter(out_str), "Control connections count: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "control_connections")));
+
+	const auto *avg_time_obj = ucl_object_lookup(obj, "scan_times");
+
+	if (avg_time_obj && ucl_object_type(avg_time_obj) == UCL_ARRAY) {
+		ucl_object_iter_t iter = nullptr;
+		const ucl_object_t *cur;
+		std::vector<float> nums;
+
+		while ((cur = ucl_object_iterate (avg_time_obj, &iter, true)) != nullptr) {
+			if (ucl_object_type(cur) == UCL_FLOAT || ucl_object_type(cur) == UCL_INT) {
+				nums.push_back(ucl_object_todouble(cur));
+			}
+		}
+
+		auto cnt = nums.size();
+
+		if (cnt > 0) {
+			auto sum = rspamd_sum_floats(nums.data(), &cnt);
+			fmt::format_to(std::back_inserter(out_str),
+						   "Average scan time: {:.3f} sec\n", sum / cnt);
+		}
+	}
+
+	/* Pools */
+	fmt::format_to(std::back_inserter(out_str),  "Pools allocated: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "pools_allocated")));
+	fmt::format_to(std::back_inserter(out_str),  "Pools freed: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "pools_freed")));
+	fmt::format_to(std::back_inserter(out_str),  "Bytes allocated: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "bytes_allocated")));
+	fmt::format_to(std::back_inserter(out_str),  "Memory chunks allocated: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "chunks_allocated")));
+	fmt::format_to(std::back_inserter(out_str),  "Shared chunks allocated: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "shared_chunks_allocated")));
+	fmt::format_to(std::back_inserter(out_str),  "Chunks freed: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "chunks_freed")));
+	fmt::format_to(std::back_inserter(out_str),  "Oversized chunks: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "chunks_oversized")));
+	/* Fuzzy */
+
+	const auto *st = ucl_object_lookup(obj, "fuzzy_hashes");
+	if (st) {
+		ucl_object_iter_t it = nullptr;
+		const ucl_object_t *cur;
+		std::uint64_t stored = 0;
+
+		while ((cur = ucl_iterate_object (st, &it, true)) != nullptr) {
+			auto num = ucl_object_toint(cur);
+			fmt::format_to(std::back_inserter(out_str), "Fuzzy hashes in storage \"{}\": {}\n",
+					ucl_object_key(cur),
+					num);
+			stored += num;
+		}
+
+		fmt::format_to(std::back_inserter(out_str), "Fuzzy hashes stored: {}\n",
+				stored);
+	}
+
+	st = ucl_object_lookup(obj, "fuzzy_checked");
+	if (st != nullptr && ucl_object_type(st) == UCL_ARRAY) {
+		ucl_object_iter_t iter = nullptr;
+		const ucl_object_t *cur;
+
+		out_str += "Fuzzy hashes checked: ";
+
+		while ((cur = ucl_object_iterate (st, &iter, true)) != nullptr) {
+			fmt::format_to(std::back_inserter(out_str), "{} ", ucl_object_toint(cur));
+		}
+
+		out_str.push_back('\n');
+	}
+
+	st = ucl_object_lookup(obj, "fuzzy_found");
+	if (st != nullptr && ucl_object_type(st) == UCL_ARRAY) {
+		ucl_object_iter_t iter = nullptr;
+		const ucl_object_t *cur;
+
+		out_str += "Fuzzy hashes found: ";
+
+		while ((cur = ucl_object_iterate (st, &iter, true)) != nullptr) {
+			fmt::format_to(std::back_inserter(out_str), "{} ", ucl_object_toint(cur));
+		}
+
+		out_str.push_back('\n');
+	}
+
+	st = ucl_object_lookup(obj, "statfiles");
+	if (st != nullptr && ucl_object_type(st) == UCL_ARRAY) {
+		ucl_object_iter_t iter = nullptr;
+		const ucl_object_t *cur;
+
+		while ((cur = ucl_object_iterate (st, &iter, true)) != nullptr) {
+			rspamc_stat_statfile(cur, out_str);
+		}
+	}
+	fmt::format_to(std::back_inserter(out_str), "Total learns: {}\n",
+			ucl_object_toint(ucl_object_lookup(obj, "total_learns")));
+
+	fmt::print(out, "{}", out_str.c_str());
+}
+
+static void
+rspamc_output_headers(FILE *out, struct rspamd_http_message *msg)
+{
+	struct rspamd_http_header *h;
+
+	kh_foreach_value (msg->headers, h, {
+		fmt::print(out, "{}: {}\n", std::string_view{h->name.begin, h->name.len},
+				std::string_view{h->value.begin, h->value.len});
+	});
+
+	fmt::print(out, "\n");
+}
+
+static void
+rspamc_mime_output(FILE *out, ucl_object_t *result, GString *input,
+				   gdouble time, GError *err)
+{
+	const gchar *action = "no action", *line_end = "\r\n", *p;
+	gdouble score = 0.0, required_score = 0.0;
+	gboolean is_spam = FALSE;
+	auto nl_type = RSPAMD_TASK_NEWLINES_CRLF;
+
+	auto headers_pos = rspamd_string_find_eoh(input, nullptr);
+
+	if (headers_pos == -1) {
+		fmt::print(stderr, "cannot find end of headers position");
+		return;
+	}
+
+	p = input->str + headers_pos;
+
+	if (headers_pos > 1 && *(p - 1) == '\n') {
+		if (headers_pos > 2 && *(p - 2) == '\r') {
+			line_end = "\r\n";
+			nl_type = RSPAMD_TASK_NEWLINES_CRLF;
+		}
+		else {
+			line_end = "\n";
+			nl_type = RSPAMD_TASK_NEWLINES_LF;
+		}
+	}
+	else if (headers_pos > 1 && *(p - 1) == '\r') {
+		line_end = "\r";
+		nl_type = RSPAMD_TASK_NEWLINES_CR;
+	}
+
+	std::string added_headers;
+
+	if (result) {
+		const auto *res = ucl_object_lookup(result, "action");
+
+		if (res) {
+			action = ucl_object_tostring(res);
+		}
+
+		res = ucl_object_lookup(result, "score");
+		if (res) {
+			score = ucl_object_todouble(res);
+		}
+
+		res = ucl_object_lookup(result, "required_score");
+		if (res) {
+			required_score = ucl_object_todouble(res);
+		}
+
+		auto act = rspamd_action_from_str_rspamc(action);
+
+		if (act.has_value() && act.value() < METRIC_ACTION_GREYLIST) {
+			is_spam = TRUE;
+		}
+
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Scanner: {}{}",
+				"rspamc " RVERSION, line_end);
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Scan-Time: {:.3}{}",
+				time, line_end);
+
+		/*
+		 * TODO: add milter_headers support here
+		 */
+		if (is_spam) {
+			fmt::format_to(std::back_inserter(added_headers), "X-Spam: yes{}", line_end);
+		}
+
+		fmt::format_to(std::back_inserter(added_headers),"X-Spam-Action: {}{}",
+				action, line_end);
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Score: {:.2f} / {:.2f}{}",
+				score, required_score, line_end);
+
+		/* SA style stars header */
+		std::string scorebuf;
+		auto adjusted_score = std::min(score, 32.0);
+		while(adjusted_score > 0) {
+			scorebuf.push_back('*');
+			adjusted_score -= 1.0;
+		}
+
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Level: {}{}",
+				scorebuf, line_end);
+
+		/* Short description of all symbols */
+		std::string symbuf;
+		const ucl_object_t *cur;
+		ucl_object_iter_t it = nullptr;
+		const auto *syms = ucl_object_lookup(result, "symbols");
+
+		while (syms && (cur = ucl_object_iterate (syms, &it, true)) != nullptr) {
+			if (ucl_object_type(cur) == UCL_OBJECT) {
+				fmt::format_to(std::back_inserter(symbuf), "{},", ucl_object_key(cur));
+			}
+		}
+		/* Trim the last comma */
+		if (symbuf.back() == ',') {
+			symbuf.pop_back();
+		}
+
+		auto *folded_symbuf = rspamd_header_value_fold("X-Spam-Symbols", strlen("X-Spam-Symbols"),
+				symbuf.data(), symbuf.size(),
+				0, nl_type, ",");
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Symbols: {}{}",
+				folded_symbuf->str, line_end);
+
+		g_string_free(folded_symbuf, TRUE);
+
+		res = ucl_object_lookup(result, "dkim-signature");
+		if (res && res->type == UCL_STRING) {
+			fmt::format_to(std::back_inserter(added_headers), "DKIM-Signature: {}{}",
+					ucl_object_tostring(res), line_end);
+		}
+		else if (res && res->type == UCL_ARRAY) {
+			it = nullptr;
+			while ((cur = ucl_object_iterate (res, &it, true)) != nullptr) {
+				fmt::format_to(std::back_inserter(added_headers), "DKIM-Signature: {}{}",
+						ucl_object_tostring(cur), line_end);
+			}
+		}
+
+		if (json || ucl_reply || compact) {
+			unsigned char *json_header;
+			/* We also append json data as a specific header */
+			if (json) {
+				json_header = ucl_object_emit(result,
+						compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_JSON);
+			}
+			else {
+				json_header = ucl_object_emit(result,
+						compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_CONFIG);
+			}
+
+			auto *json_header_encoded = rspamd_encode_base64_fold(json_header,
+					strlen((char *)json_header), 60, nullptr, nl_type);
+			free(json_header);
+			fmt::format_to(std::back_inserter(added_headers),
+					"X-Spam-Result: {}{}",
+					json_header_encoded, line_end);
+			g_free(json_header_encoded);
+		}
+
+		ucl_object_unref(result);
+	}
+	else {
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Scanner: {}{}",
+				"rspamc " RVERSION, line_end);
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Scan-Time: {:.3f}{}",
+				time, line_end);
+		fmt::format_to(std::back_inserter(added_headers), "X-Spam-Error: {}{}",
+				err->message, line_end);
+	}
+
+	/* Write message */
+	/* Original headers */
+	fmt::print(out, std::string_view{input->str, (std::size_t)headers_pos});
+	/* Added headers */
+	fmt::print(out, added_headers);
+	/* Message body */
+	fmt::print(out, input->str + headers_pos);
+}
+
+static void
+rspamc_client_execute_cmd(const struct rspamc_command &cmd, ucl_object_t *result,
+						  GString *input, gdouble time, GError *err)
+{
+	gchar **eargv;
+	gint eargc, infd, outfd, errfd;
+	GError *exec_err = nullptr;
+	GPid cld;
+
+	if (!g_shell_parse_argv(execute, &eargc, &eargv, &err)) {
+		fmt::print(stderr, "Cannot execute {}: {}", execute, err->message);
+		g_error_free(err);
+
+		return;
+	}
+
+	if (!g_spawn_async_with_pipes(nullptr, eargv, nullptr,
+			static_cast<GSpawnFlags>(G_SPAWN_SEARCH_PATH | G_SPAWN_DO_NOT_REAP_CHILD), nullptr, nullptr, &cld,
+			&infd, &outfd, &errfd, &exec_err)) {
+
+		fmt::print(stderr, "Cannot execute {}: {}", execute, exec_err->message);
+		g_error_free(exec_err);
+
+		exit(EXIT_FAILURE);
+	}
+	else {
+		children.push_back(cld);
+		auto *out = fdopen(infd, "w");
+
+		if (cmd.cmd == RSPAMC_COMMAND_SYMBOLS && mime_output && input) {
+			rspamc_mime_output(out, result, input, time, err);
+		}
+		else if (result) {
+			if (ucl_reply || cmd.command_output_func == nullptr) {
+				char *ucl_out;
+
+				if (json) {
+					ucl_out = (char *)ucl_object_emit(result,
+							compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_JSON);
+				}
+				else {
+					ucl_out = (char *)ucl_object_emit(result,
+							compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_CONFIG);
+				}
+				fmt::print(out, "{}", ucl_out);
+				free(ucl_out);
+			}
+			else {
+				cmd.command_output_func(out, result);
+			}
+
+			ucl_object_unref(result);
+		}
+		else {
+			fmt::print(out, "{}\n", err->message);
+		}
+
+		fflush(out);
+		fclose(out);
+	}
+
+	g_strfreev(eargv);
+}
+
+static void
+rspamc_client_cb(struct rspamd_client_connection *conn,
+				 struct rspamd_http_message *msg,
+				 const char *name, ucl_object_t *result, GString *input,
+				 gpointer ud, gdouble start_time, gdouble send_time,
+				 const char *body, gsize bodylen,
+				 GError *err)
+{
+	struct rspamc_callback_data *cbdata = (struct rspamc_callback_data *) ud;
+	FILE *out = stdout;
+	gdouble finish = rspamd_get_ticks(FALSE), diff;
+
+	auto &cmd = cbdata->cmd;
+
+	if (send_time > 0) {
+		diff = finish - send_time;
+	}
+	else {
+		diff = finish - start_time;
+	}
+
+	if (execute) {
+		/* Pass all to the external command */
+		rspamc_client_execute_cmd(cmd, result, input, diff, err);
+	}
+	else {
+
+		if (cmd.cmd == RSPAMC_COMMAND_SYMBOLS && mime_output && input) {
+			if (body) {
+				GString tmp;
+
+				tmp.str = (char *) body;
+				tmp.len = bodylen;
+				rspamc_mime_output(out, result, &tmp, diff, err);
+			}
+			else {
+				rspamc_mime_output(out, result, input, diff, err);
+			}
+		}
+		else {
+			if (cmd.need_input && !json) {
+				if (!compact) {
+					fmt::print(out, "Results for file: {} ({:.3} seconds)\n",
+							cbdata->filename, diff);
+				}
+			}
+			else {
+				if (!compact && !json) {
+					fmt::print(out, "Results for command: {} ({:.3} seconds)\n",
+							cmd.name, diff);
+				}
+			}
+
+			if (result != nullptr) {
+				if (headers && msg != nullptr) {
+					rspamc_output_headers(out, msg);
+				}
+				if (ucl_reply || cmd.command_output_func == nullptr) {
+					if (cmd.need_input) {
+						ucl_object_insert_key(result,
+								ucl_object_fromstring(cbdata->filename.c_str()),
+								"filename", 0,
+								false);
+					}
+
+					ucl_object_insert_key(result,
+							ucl_object_fromdouble(diff),
+							"scan_time", 0,
+							false);
+
+					char *ucl_out;
+
+					if (json) {
+						ucl_out = (char *)ucl_object_emit(result,
+								compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_JSON);
+					}
+					else {
+						ucl_out = (char *)ucl_object_emit(result,
+								compact ? UCL_EMIT_JSON_COMPACT : UCL_EMIT_CONFIG);
+					}
+
+					fmt::print(out, "{}", ucl_out);
+					free(ucl_out);
+				}
+				else {
+					cmd.command_output_func(out, result);
+				}
+
+				if (body) {
+					fmt::print(out, "\nNew body:\n{}\n",
+							std::string_view{body, bodylen});
+				}
+
+				ucl_object_unref(result);
+			}
+			else if (err != nullptr) {
+				fmt::print(out, "{}\n", err->message);
+
+				if (json && msg != nullptr) {
+					gsize rawlen;
+
+					auto *raw_body = rspamd_http_message_get_body(msg, &rawlen);
+
+					if (raw_body) {
+						/* We can also output the resulting json */
+						fmt::print(out, "{}\n", std::string_view{raw_body, (std::size_t)(rawlen - bodylen)});
+					}
+				}
+			}
+			fmt::print(out, "\n");
+		}
+
+		fflush(out);
+	}
+
+	rspamd_client_destroy(conn);
+	delete cbdata;
+
+	if (err) {
+		retcode = EXIT_FAILURE;
+	}
+}
+
+static void
+rspamc_process_input(struct ev_loop *ev_base, const struct rspamc_command &cmd,
+					 FILE *in, const std::string &name, GQueue *attrs)
+{
+	struct rspamd_client_connection *conn;
+	const char *p;
+	guint16 port;
+	GError *err = nullptr;
+	std::string hostbuf;
+
+	if (connect_str[0] == '[') {
+		p = strrchr(connect_str, ']');
+
+		if (p != nullptr) {
+			hostbuf.assign(connect_str + 1, (std::size_t)(p - connect_str - 1));
+			p++;
+		}
+		else {
+			p = connect_str;
+		}
+	}
+	else {
+		p = connect_str;
+	}
+
+	p = strrchr(p, ':');
+
+	if (hostbuf.empty()) {
+		if (p != nullptr) {
+			hostbuf.assign(connect_str, (std::size_t)(p - connect_str));
+		}
+		else {
+			hostbuf.assign(connect_str);
+		}
+	}
+
+	if (p != nullptr) {
+		port = strtoul(p + 1, nullptr, 10);
+	}
+	else {
+		/*
+		 * If we connect to localhost, 127.0.0.1 or ::1, then try controller
+		 * port first
+		 */
+
+		if (hostbuf == "localhost" ||
+			hostbuf == "127.0.0.1"||
+			hostbuf == "::1" ||
+			hostbuf == "[::1]") {
+			port = DEFAULT_CONTROL_PORT;
+		}
+		else {
+			port = cmd.is_controller ? DEFAULT_CONTROL_PORT : DEFAULT_PORT;
+		}
+
+	}
+
+	conn = rspamd_client_init(http_ctx, ev_base, hostbuf.c_str(), port, timeout, key);
+
+	if (conn != nullptr) {
+		auto *cbdata = new rspamc_callback_data;
+		cbdata->cmd = cmd;
+		cbdata->filename = name;
+
+		if (cmd.need_input) {
+			rspamd_client_command(conn, cmd.path, attrs, in, rspamc_client_cb,
+					cbdata, compressed, dictionary, cbdata->filename.c_str(), &err);
+		}
+		else {
+			rspamd_client_command(conn,
+					cmd.path,
+					attrs,
+					nullptr,
+					rspamc_client_cb,
+					cbdata,
+					compressed,
+					dictionary,
+					cbdata->filename.c_str(),
+					&err);
+		}
+	}
+	else {
+		fmt::print(stderr, "cannot connect to {}: {}\n", connect_str,
+				strerror(errno));
+		exit(EXIT_FAILURE);
+	}
+}
+
+static gsize
+rspamd_dirent_size(DIR *dirp)
+{
+	goffset name_max;
+	gsize name_end;
+
+#if defined(HAVE_FPATHCONF) && defined(HAVE_DIRFD) \
+ && defined(_PC_NAME_MAX)
+	name_max = fpathconf(dirfd(dirp), _PC_NAME_MAX);
+
+
+# if defined(NAME_MAX)
+	if (name_max == -1) {
+		name_max = (NAME_MAX > 255) ? NAME_MAX : 255;
+	}
+# else
+	if (name_max == -1) {
+		return (size_t)(-1);
+	}
+# endif
+#else
+# if defined(NAME_MAX)
+	name_max = (NAME_MAX > 255) ? NAME_MAX : 255;
+# else
+#   error "buffer size for readdir_r cannot be determined"
+# endif
+#endif
+
+	name_end = G_STRUCT_OFFSET (struct dirent, d_name) + name_max + 1;
+
+	return (name_end > sizeof(struct dirent) ? name_end : sizeof(struct dirent));
+}
+
+static void
+rspamc_process_dir(struct ev_loop *ev_base, const struct rspamc_command &cmd,
+				   const std::string &name, GQueue *attrs)
+{
+	static auto cur_req = 0;
+	auto *d = opendir(name.c_str());
+
+	if (d != nullptr) {
+		struct dirent *pentry;
+		std::string fpath;
+
+		fpath.reserve(PATH_MAX);
+
+		while ((pentry = readdir(d)) != nullptr) {
+
+			if (pentry->d_name[0] == '.') {
+				continue;
+			}
+
+			fpath.clear();
+			fmt::format_to(std::back_inserter(fpath), "{}{}{}",
+					name, G_DIR_SEPARATOR,
+					pentry->d_name);
+
+			/* Check exclude */
+			auto **ex = exclude_compiled;
+			auto skip = false;
+			while (ex != nullptr && *ex != nullptr) {
+				if (g_pattern_spec_match(*ex, fpath.size(), fpath.c_str(), nullptr)) {
+					skip = true;
+					break;
+				}
+
+				ex++;
+			}
+
+			if (skip) {
+				continue;
+			}
+
+			auto is_reg = false;
+			auto is_dir = false;
+			struct stat st;
+
+#if (defined(_DIRENT_HAVE_D_TYPE) || defined(__APPLE__)) && defined(DT_UNKNOWN)
+			if (pentry->d_type == DT_UNKNOWN) {
+				/* Fallback to lstat */
+				if (lstat(fpath.c_str(), &st) == -1) {
+					fmt::print(stderr, "cannot stat file {}: {}\n",
+							fpath, strerror(errno));
+					continue;
+				}
+
+				is_dir = S_ISDIR(st.st_mode);
+				is_reg = S_ISREG(st.st_mode);
+			}
+			else {
+				if (pentry->d_type == DT_REG) {
+					is_reg = true;
+				}
+				else if (pentry->d_type == DT_DIR) {
+					is_dir = true;
+				}
+			}
+#else
+			if (lstat(fpath.c_str(), &st) == -1) {
+				fmt::print(stderr, "cannot stat file {}: {}\n",
+						fpath, strerror (errno));
+				continue;
+			}
+
+			is_dir = S_ISDIR(st.st_mode);
+			is_reg = S_ISREG(st.st_mode);
+#endif
+			if (is_dir) {
+				rspamc_process_dir(ev_base, cmd, fpath, attrs);
+				continue;
+			}
+			else if (is_reg) {
+				auto *in = fopen(fpath.c_str(), "r");
+				if (in == nullptr) {
+					fmt::print(stderr, "cannot open file {}: {}\n",
+							fpath, strerror(errno));
+					continue;
+				}
+
+				rspamc_process_input(ev_base, cmd, in, fpath, attrs);
+				cur_req++;
+				fclose(in);
+
+				if (cur_req >= max_requests) {
+					cur_req = 0;
+					/* Wait for completion */
+					ev_loop(ev_base, 0);
+				}
+			}
+		}
+	}
+	else {
+		fmt::print(stderr, "cannot open directory {}: {}\n", name, strerror(errno));
+		exit(EXIT_FAILURE);
+	}
+
+	closedir(d);
+	ev_loop(ev_base, 0);
+}
+
+
+static void
+rspamc_kwattr_free(gpointer p)
+{
+	struct rspamd_http_client_header *h = (struct rspamd_http_client_header *) p;
+
+	g_free(h->value);
+	g_free(h->name);
+	g_free(h);
+}
+
+int
+main(int argc, char **argv, char **env)
+{
+	auto *kwattrs = g_queue_new();
+
+	read_cmd_line(&argc, &argv);
+	tty = isatty(STDOUT_FILENO);
+
+	if (print_commands) {
+		print_commands_list();
+		exit(EXIT_SUCCESS);
+	}
+
+	/* Deal with exclude patterns */
+	auto **exclude_pattern = exclude_patterns;
+	auto npatterns = 0;
+
+	while (exclude_pattern && *exclude_pattern) {
+		exclude_pattern++;
+		npatterns++;
+	}
+
+	if (npatterns > 0) {
+		exclude_compiled = g_new0(GPatternSpec *, (npatterns + 1));
+
+		for (auto i = 0; i < npatterns; i++) {
+			exclude_compiled[i] = g_pattern_spec_new(exclude_patterns[i]);
+
+			if (exclude_compiled[i] == nullptr) {
+				fmt::print(stderr, "Invalid glob pattern: {}\n",
+						exclude_patterns[i]);
+				exit(EXIT_FAILURE);
+			}
+		}
+	}
+
+	auto *libs = rspamd_init_libs();
+	auto *event_loop = ev_loop_new(EVBACKEND_ALL);
+
+	struct rspamd_http_context_cfg http_config;
+	memset(&http_config, 0, sizeof(http_config));
+	http_config.kp_cache_size_client = 32;
+	http_config.kp_cache_size_server = 0;
+	http_config.user_agent = user_agent;
+	http_ctx = rspamd_http_context_create_config(&http_config,
+			event_loop, nullptr);
+
+	/* Ignore sigpipe */
+	struct sigaction sigpipe_act;
+	sigemptyset (&sigpipe_act.sa_mask);
+	sigaddset (&sigpipe_act.sa_mask, SIGPIPE);
+	sigpipe_act.sa_handler = SIG_IGN;
+	sigpipe_act.sa_flags = 0;
+	sigaction(SIGPIPE, &sigpipe_act, nullptr);
+
+	/* Now read other args from argc and argv */
+	FILE *in = nullptr;
+	std::optional<rspamc_command> maybe_cmd;
+	auto start_argc = 0;
+
+	if (argc == 1) {
+		start_argc = argc;
+		in = stdin;
+		maybe_cmd = check_rspamc_command("symbols");
+	}
+	else if (argc == 2) {
+		/* One argument is whether command or filename */
+		maybe_cmd = check_rspamc_command(argv[1]);
+
+		if (maybe_cmd.has_value()) {
+			start_argc = argc;
+			in = stdin;
+		}
+		else {
+			maybe_cmd = check_rspamc_command("symbols"); /* Symbols command */
+			start_argc = 1;
+		}
+	}
+	else {
+		maybe_cmd = check_rspamc_command(argv[1]);
+		if (maybe_cmd.has_value()) {
+			auto &cmd = maybe_cmd.value();
+			/* In case of command read arguments starting from 2 */
+			if (cmd.cmd == RSPAMC_COMMAND_ADD_SYMBOL || cmd.cmd == RSPAMC_COMMAND_ADD_ACTION) {
+				if (argc < 4 || argc > 5) {
+					fmt::print(stderr, "invalid arguments\n");
+					exit(EXIT_FAILURE);
+				}
+				if (argc == 5) {
+					add_client_header(kwattrs, "metric", argv[2]);
+					add_client_header(kwattrs, "name", argv[3]);
+					add_client_header(kwattrs, "value", argv[4]);
+				}
+				else {
+					add_client_header(kwattrs, "name", argv[2]);
+					add_client_header(kwattrs, "value", argv[3]);
+				}
+				start_argc = argc;
+			}
+			else {
+				start_argc = 2;
+			}
+		}
+		else {
+			maybe_cmd = check_rspamc_command("symbols");
+			start_argc = 1;
+		}
+	}
+
+	if (!maybe_cmd.has_value()) {
+		fmt::print(stderr, "invalid command\n");
+		exit(EXIT_FAILURE);
+	}
+
+	add_options(kwattrs);
+	auto cmd = maybe_cmd.value();
+
+	if (start_argc == argc) {
+		/* Do command without input or with stdin */
+		if (empty_input) {
+			rspamc_process_input(event_loop, cmd, nullptr, "empty", kwattrs);
+		}
+		else {
+			rspamc_process_input(event_loop, cmd, in, "stdin", kwattrs);
+		}
+	}
+	else {
+		auto cur_req = 0;
+
+		for (auto i = start_argc; i < argc; i++) {
+			if (cmd.cmd == RSPAMC_COMMAND_FUZZY_DELHASH) {
+				add_client_header(kwattrs, "Hash", argv[i]);
+			}
+			else {
+				struct stat st;
+
+				if (stat(argv[i], &st) == -1) {
+					fmt::print(stderr, "cannot stat file {}\n", argv[i]);
+					exit(EXIT_FAILURE);
+				}
+				if (S_ISDIR (st.st_mode)) {
+					/* Directories are processed with a separate limit */
+					rspamc_process_dir(event_loop, cmd, argv[i], kwattrs);
+					cur_req = 0;
+				}
+				else {
+					in = fopen(argv[i], "r");
+					if (in == nullptr) {
+						fmt::print(stderr, "cannot open file {}\n", argv[i]);
+						exit(EXIT_FAILURE);
+					}
+					rspamc_process_input(event_loop, cmd, in, argv[i], kwattrs);
+					cur_req++;
+					fclose(in);
+				}
+				if (cur_req >= max_requests) {
+					cur_req = 0;
+					/* Wait for completion */
+					ev_loop(event_loop, 0);
+				}
+			}
+		}
+
+		if (cmd.cmd == RSPAMC_COMMAND_FUZZY_DELHASH) {
+			rspamc_process_input(event_loop, cmd, nullptr, "hashes", kwattrs);
+		}
+	}
+
+	ev_loop(event_loop, 0);
+
+	g_queue_free_full(kwattrs, rspamc_kwattr_free);
+
+	/* Wait for children processes */
+	auto ret = 0;
+
+	for (auto cld : children) {
+		auto res = 0;
+		if (waitpid(cld, &res, 0) == -1) {
+			fmt::print(stderr, "Cannot wait for {}: {}", cld,
+					strerror(errno));
+
+			ret = errno;
+		}
+
+		if (ret == 0) {
+			/* Check return code */
+			if (WIFSIGNALED (res)) {
+				ret = WTERMSIG (res);
+			}
+			else if (WIFEXITED (res)) {
+				ret = WEXITSTATUS (res);
+			}
+		}
+	}
+
+	for (auto i = 0; i < npatterns; i++) {
+		g_pattern_spec_free(exclude_compiled[i]);
+	}
+	g_free(exclude_compiled);
+
+	rspamd_deinit_libs(libs);
+
+	/* Mix retcode (return from Rspamd side) and ret (return from subprocess) */
+	return ret | retcode;
+}