Add preliminary version of rspamadm control command

1 files changed, 181 insertions, 0 deletions

diff --git a/src/rspamadm/control.c b/src/rspamadm/control.c
new file mode 100644
index 000000000..55b286c48
--- /dev/null
+++ b/src/rspamadm/control.c
@@ -0,0 +1,181 @@
+/*
+ * Copyright (c) 2015, Vsevolod Stakhov
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *	 * Redistributions of source code must retain the above copyright
+ *	   notice, this list of conditions and the following disclaimer.
+ *	 * Redistributions in binary form must reproduce the above copyright
+ *	   notice, this list of conditions and the following disclaimer in the
+ *	   documentation and/or other materials provided with the distribution.
+ *
+ * THIS SOFTWARE IS PROVIDED BY AUTHOR ''AS IS'' AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL AUTHOR BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include "config.h"
+#include "rspamadm.h"
+#include "cryptobox.h"
+#include "printf.h"
+#include "http.h"
+#include "addr.h"
+#include "unix-std.h"
+#include <event.h>
+#include "libutil/util.h"
+
+static gchar *control_path = RSPAMD_DBDIR "/rspamd.sock";
+gboolean json = FALSE;
+gboolean ucl = FALSE;
+gboolean compact = FALSE;
+gdouble timeout = 1.0;
+
+static void rspamadm_control (gint argc, gchar **argv);
+static const char *rspamadm_control_help (gboolean full_help);
+
+struct rspamadm_command control_command = {
+		.name = "control",
+		.flags = 0,
+		.help = rspamadm_control_help,
+		.run = rspamadm_control
+};
+
+static GOptionEntry entries[] = {
+		{"json", 'j', 0, G_OPTION_ARG_NONE, &json,
+				"Output json",                    NULL},
+		{"ucl", 'u', 0, G_OPTION_ARG_NONE, &ucl,
+				"Output UCL",     NULL},
+		{"compact", 'c', 0, G_OPTION_ARG_NONE, &compact,
+				"Output compacted", NULL},
+		{"socket", 's', 0, G_OPTION_ARG_STRING, &control_path,
+				"Use the following socket path", NULL},
+		{"timeout", 't', 0, G_OPTION_ARG_DOUBLE, &timeout,
+				"Set IO timeout (1s by default)", NULL},
+		{NULL,  0,   0, G_OPTION_ARG_NONE, NULL, NULL, NULL}
+};
+
+static const char *
+rspamadm_control_help (gboolean full_help)
+{
+	const char *help_str;
+
+	if (full_help) {
+		help_str = "Manage rspamd main control interface\n\n"
+				"Usage: rspamadm control [-c] [-j] [-u] [-s path] command\n"
+				"Where options are:\n\n"
+				"-c: output compacted json\n"
+				"-j: output linted json\n"
+				"-u: output ucl\n"
+				"-s: use the following socket instead of " RSPAMD_DBDIR "/rspamd.sock\n"
+				"-t: set IO timeout (1.0 seconds default)\n"
+				"--help: shows available options and commands\n\n"
+				"Supported commands:\n"
+				"stat - show statistics\n"
+				"reload - reload workers dynamic data\n";
+	}
+	else {
+		help_str = "Manage rspamd main control interface";
+	}
+
+	return help_str;
+}
+
+static void
+rspamd_control_error_handler (struct rspamd_http_connection *conn, GError *err)
+{
+	rspamd_fprintf (stderr, "Cannot make HTTP request: %e\n", err);
+}
+
+static gint
+rspamd_control_finish_handler (struct rspamd_http_connection *conn,
+		struct rspamd_http_message *msg)
+{
+	rspamd_fprintf (stdout, "Result: %V\n", msg->body);
+
+	return 0;
+}
+
+static void
+rspamadm_control (gint argc, gchar **argv)
+{
+	GOptionContext *context;
+	GError *error = NULL;
+	struct event_base *ev_base;
+	const gchar *cmd, *path = NULL;
+	struct rspamd_http_connection *conn;
+	struct rspamd_http_message *msg;
+	rspamd_inet_addr_t *addr;
+	struct timeval tv;
+	gint sock;
+
+	context = g_option_context_new (
+			"keypair - create encryption keys");
+	g_option_context_set_summary (context,
+			"Summary:\n  Rspamd administration utility version "
+					RVERSION
+					"\n  Release id: "
+					RID);
+	g_option_context_add_main_entries (context, entries, NULL);
+
+	if (!g_option_context_parse (context, &argc, &argv, &error)) {
+		rspamd_fprintf (stderr, "option parsing failed: %s\n", error->message);
+		g_error_free (error);
+		exit (1);
+	}
+
+	if (argc == 0) {
+		rspamd_fprintf (stderr, "command required\n");
+		exit (1);
+	}
+
+	cmd = argv[1];
+
+	if (g_ascii_strcasecmp (cmd, "stat") == 0) {
+		path = "/stat";
+	}
+	else if (g_ascii_strcasecmp (cmd, "reload") == 0) {
+		path = "/reload";
+	}
+	else {
+		rspamd_fprintf (stderr, "unknown command: %s\n", cmd);
+		exit (1);
+	}
+
+	if (!rspamd_parse_inet_address (&addr, control_path, 0)) {
+		rspamd_fprintf (stderr, "bad control path: %s\n", control_path);
+		exit (1);
+	}
+
+	ev_base = event_init ();
+	sock = rspamd_inet_address_connect (addr, SOCK_STREAM, TRUE);
+
+	if (sock == -1) {
+		rspamd_fprintf (stderr, "cannot connect to: %s\n", control_path);
+		rspamd_inet_address_destroy (addr);
+		exit (1);
+	}
+
+	conn = rspamd_http_connection_new (NULL, rspamd_control_error_handler,
+			rspamd_control_finish_handler, RSPAMD_HTTP_CLIENT_SIMPLE,
+			RSPAMD_HTTP_CLIENT, NULL);
+	msg = rspamd_http_new_message (HTTP_REQUEST);
+	msg->url = rspamd_fstring_new_init (path, strlen (path));
+	double_to_tv (timeout, &tv);
+
+	rspamd_http_connection_write_message (conn, msg, NULL, NULL, NULL, sock,
+			&tv, ev_base);
+
+	event_base_loop (ev_base, 0);
+
+	rspamd_http_connection_unref (conn);
+	rspamd_inet_address_destroy (addr);
+	close (sock);
+}