From e14c5774370f523ff763adcc60bea5404ed74e71 Mon Sep 17 00:00:00 2001
From: kanoi <gitkanoi@k1k2.com>
Date: Sun, 24 Aug 2014 21:26:19 +1000
Subject: [PATCH] ckdb - add version to listener

---
 src/ckdb.c | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/ckdb.c b/src/ckdb.c
index 19a2883e..898c70ab 100644
--- a/src/ckdb.c
+++ b/src/ckdb.c
@@ -747,6 +747,7 @@ enum cmd_values {
 	CMD_REPLY, // Means something was wrong - send back reply
 	CMD_SHUTDOWN,
 	CMD_PING,
+	CMD_VERSION,
 	CMD_SHARELOG,
 	CMD_AUTH,
 	CMD_ADDUSER,
@@ -7899,6 +7900,7 @@ static struct CMDS {
 } cmds[] = {
 	{ CMD_SHUTDOWN,	"shutdown",	true,	false,	NULL,		ACCESS_SYSTEM },
 	{ CMD_PING,	"ping",		true,	false,	NULL,		ACCESS_SYSTEM ACCESS_POOL ACCESS_WEB },
+	{ CMD_VERSION,	"version",	true,	false,	NULL,		ACCESS_SYSTEM ACCESS_POOL ACCESS_WEB },
 	{ CMD_SHARELOG,	STR_WORKINFO,	false,	true,	cmd_sharelog,	ACCESS_POOL },
 	{ CMD_SHARELOG,	STR_SHARES,	false,	true,	cmd_sharelog,	ACCESS_POOL },
 	{ CMD_SHARELOG,	STR_SHAREERRORS, false,	true,	cmd_sharelog,	ACCESS_POOL },
@@ -8532,6 +8534,13 @@ static void *socketer(__maybe_unused void *arg)
 						snprintf(reply, sizeof(reply), "%s.%ld.ok.pong", id, now.tv_sec);
 						send_unix_msg(sockd, reply);
 						break;
+					case CMD_VERSION:
+						LOGDEBUG("Listener received version request");
+						snprintf(reply, sizeof(reply),
+							 "%s.%ld.ok.CKDB V%s",
+							 id, now.tv_sec, CKDB_VERSION);
+						send_unix_msg(sockd, reply);
+						break;
 					// Always process immediately:
 					case CMD_AUTH:
 					case CMD_CHKPASS:
@@ -8761,6 +8770,7 @@ static bool reload_line(PGconn *conn, char *filename, uint64_t count, char *buf)
 			// Shouldn't be there
 			case CMD_SHUTDOWN:
 			case CMD_PING:
+			case CMD_VERSION:
 			// Non pool commands, shouldn't be there
 			case CMD_ADDUSER:
 			case CMD_NEWPASS: