DATAREDIS-270 - Add support for 'CLIENT GETNAME'.

Support for getting client connection name has been added for 'jedis', 'jredis' and 'srp' drivers.

Using 'jredis' will throw 'UnsupportedOperationException'.

Original Pull Request: #51

Author: christophstrobl

src/main/java/org/springframework/data/redis/connection/DefaultStringRedisConnection.java

@@ -2191,6 +2191,15 @@ public Long time() {
 		return this.delegate.time();
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisServerCommands#getClientName()
+	 */
+	@Override
+	public String getClientName() {
+		return this.delegate.getClientName();
+	}
+
 	/**
 	 * Specifies if pipelined and tx results should be deserialized to Strings. If false, results of
 	 * {@link #closePipeline()} and {@link #exec()} will be of the type returned by the underlying connection

src/main/java/org/springframework/data/redis/connection/RedisServerCommands.java

@@ -161,4 +161,14 @@ public enum ShutdownOption {
 	 * @since 1.1
 	 */
 	Long time();
+
+	/**
+	 * Returns the name of the current connection.
+	 * 
+	 * @see http://redis.io/commands/client-getname
+	 * @return
+	 * @since 1.3
+	 */
+	String getClientName();
+
 }

src/main/java/org/springframework/data/redis/connection/jedis/JedisConnection.java

@@ -2783,6 +2783,18 @@ public Long time() {
 		return Converters.toTimeMillis(serverTimeInformation.get(0), serverTimeInformation.get(1));
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisServerCommands#getClientName()
+	 */
+	@Override
+	public String getClientName() {
+		if (isPipelined() || isQueueing()) {
+			throw new UnsupportedOperationException();
+		}
+		return jedis.clientGetname();
+	}
+
 	/**
 	 * Specifies if pipelined results should be converted to the expected data type. If false, results of
 	 * {@link #closePipeline()} and {@link #exec()} will be of the type returned by the Jedis driver

src/main/java/org/springframework/data/redis/connection/jredis/JredisConnection.java

@@ -1185,4 +1185,13 @@ public <T> T evalSha(String scriptSha1, ReturnType returnType, int numKeys, byte
 	public Long time() {
 		throw new UnsupportedOperationException("The 'TIME' command is not supported by the JRedis driver.");
 	}
+
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisServerCommands#getClientName()
+	 */
+	@Override
+	public String getClientName() {
+		throw new UnsupportedOperationException("The 'CLIENT GETNAME' command is not supported by the JRedis driver.");
+	}
 }

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java

@@ -2903,6 +2903,28 @@ public Long time() {
 		return Converters.toTimeMillis(new String(result.get(0)), new String(result.get(1)));
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisServerCommands#getClientName()
+	 */
+	@Override
+	public String getClientName() {
+
+		try {
+			if (isPipelined()) {
+				pipeline(new LettuceResult(getAsyncConnection().clientGetname(), LettuceConverters.bytesToString()));
+				return null;
+			}
+			if (isQueueing()) {
+				transaction(new LettuceTxResult(getConnection().clientGetname(), LettuceConverters.bytesToString()));
+				return null;
+			}
+			return LettuceConverters.toString(getConnection().clientGetname());
+		} catch (Exception ex) {
+			throw convertLettuceAccessException(ex);
+		}
+	}
+
 	/**
 	 * Specifies if pipelined and transaction results should be converted to the expected data type. If false, results of
 	 * {@link #closePipeline()} and {@link #exec()} will be of the type returned by the Lettuce driver

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConverters.java

@@ -16,6 +16,7 @@
 package org.springframework.data.redis.connection.lettuce;
 
 import java.util.ArrayList;
+import java.util.Arrays;
 import java.util.Date;
 import java.util.LinkedHashSet;
 import java.util.List;
@@ -47,6 +48,7 @@ abstract public class LettuceConverters extends Converters {
 
 	private static final Converter<Date, Long> DATE_TO_LONG;
 	private static final Converter<List<byte[]>, Set<byte[]>> BYTES_LIST_TO_BYTES_SET;
+	private static final Converter<byte[], String> BYTES_TO_STRING;
 	private static final Converter<Set<byte[]>, List<byte[]>> BYTES_SET_TO_BYTES_LIST;
 	private static final Converter<KeyValue<byte[], byte[]>, List<byte[]>> KEY_VALUE_TO_BYTES_LIST;
 	private static final Converter<List<ScoredValue<byte[]>>, Set<Tuple>> SCORED_VALUES_TO_TUPLE_SET;
@@ -65,6 +67,17 @@ public Set<byte[]> convert(List<byte[]> results) {
 				return results != null ? new LinkedHashSet<byte[]>(results) : null;
 			}
 
+		};
+		BYTES_TO_STRING = new Converter<byte[], String>() {
+
+			@Override
+			public String convert(byte[] source) {
+				if (source == null || Arrays.equals(source, new byte[0])) {
+					return null;
+				}
+				return new String(source);
+			}
+
 		};
 		BYTES_SET_TO_BYTES_LIST = new Converter<Set<byte[]>, List<byte[]>>() {
 			public List<byte[]> convert(Set<byte[]> results) {
@@ -110,6 +123,10 @@ public static Converter<List<byte[]>, Set<byte[]>> bytesListToBytesSet() {
 		return BYTES_LIST_TO_BYTES_SET;
 	}
 
+	public static Converter<byte[], String> bytesToString() {
+		return BYTES_TO_STRING;
+	}
+
 	public static Converter<KeyValue<byte[], byte[]>, List<byte[]>> keyValueToBytesList() {
 		return KEY_VALUE_TO_BYTES_LIST;
 	}
@@ -158,6 +175,10 @@ public static DataAccessException toDataAccessException(Exception ex) {
 		return EXCEPTION_CONVERTER.convert(ex);
 	}
 
+	public static String toString(byte[] source) {
+		return BYTES_TO_STRING.convert(source);
+	}
+
 	public static ScriptOutputType toScriptOutputType(ReturnType returnType) {
 		switch (returnType) {
 			case BOOLEAN:

src/main/java/org/springframework/data/redis/connection/srp/SrpConnection.java

@@ -2222,6 +2222,24 @@ public Long time() {
 		return SrpConverters.toTimeAsLong(reply.data());
 	}
 
+	/*
+	 * (non-Javadoc)
+	 * @see org.springframework.data.redis.connection.RedisServerCommands#getClientName()
+	 */
+	@Override
+	public String getClientName() {
+
+		try {
+			if (isPipelined()) {
+				pipeline(new SrpGenericResult(pipeline.client_getname(), SrpConverters.replyToString()));
+				return null;
+			}
+			return SrpConverters.toString(client.client_getname());
+		} catch (Exception ex) {
+			throw convertSrpAccessException(ex);
+		}
+	}
+
 	private List<Object> closeTransaction() {
 		List<Object> results = Collections.emptyList();
 		if (txTracker != null) {

src/main/java/org/springframework/data/redis/connection/srp/SrpConverters.java

@@ -35,7 +35,6 @@
 import org.springframework.data.redis.connection.RedisZSetCommands.Tuple;
 import org.springframework.data.redis.connection.convert.Converters;
 import org.springframework.util.Assert;
-import org.springframework.util.NumberUtils;
 
 import redis.client.RedisException;
 import redis.reply.IntegerReply;
@@ -61,6 +60,7 @@ abstract public class SrpConverters extends Converters {
 	private static final Converter<Reply[], Map<byte[], byte[]>> REPLIES_TO_BYTES_MAP;
 	private static final Converter<Reply[], List<Boolean>> REPLIES_TO_BOOLEAN_LIST;
 	private static final Converter<Reply[], List<String>> REPLIES_TO_STRING_LIST;
+	private static final Converter<Reply, String> REPLY_TO_STRING;
 	private static final Converter<byte[], Properties> BYTES_TO_PROPERTIES;
 	private static final Converter<byte[], String> BYTES_TO_STRING;
 	private static final Converter<byte[], Double> BYTES_TO_DOUBLE;
@@ -171,6 +171,16 @@ public List<String> convert(Reply[] source) {
 				return results;
 			}
 		};
+		REPLY_TO_STRING = new Converter<Reply, String>() {
+
+			@Override
+			public String convert(Reply source) {
+				if (source == null) {
+					return null;
+				}
+				return SrpConverters.toString((byte[]) source.data());
+			}
+		};
 	}
 
 	public static Converter<Reply[], List<byte[]>> repliesToBytesList() {
@@ -201,6 +211,10 @@ public static Converter<byte[], String> bytesToString() {
 		return BYTES_TO_STRING;
 	}
 
+	public static Converter<Reply, String> replyToString() {
+		return REPLY_TO_STRING;
+	}
+
 	public static Converter<Reply[], List<Boolean>> repliesToBooleanList() {
 		return REPLIES_TO_BOOLEAN_LIST;
 	}
@@ -237,6 +251,10 @@ public static Map<byte[], byte[]> toBytesMap(Reply[] source) {
 		return REPLIES_TO_BYTES_MAP.convert(source);
 	}
 
+	public static String toString(Reply source) {
+		return REPLY_TO_STRING.convert(source);
+	}
+
 	public static String toString(byte[] source) {
 		return BYTES_TO_STRING.convert(source);
 	}
@@ -293,4 +311,5 @@ public static byte[] toBytes(Position source) {
 	public static List<String> toStringList(String source) {
 		return Collections.singletonList(source);
 	}
+
 }

src/test/java/org/springframework/data/redis/connection/DefaultStringRedisConnectionTests.java

@@ -1710,6 +1710,16 @@ public void testShutdownInDelegatedCorrectlyToNativeConnection() {
 		verify(nativeConnection, times(1)).shutdown(eq(ShutdownOption.NOSAVE));
 	}
 
+	/**
+	 * @see DATAREDIS-270
+	 */
+	@Test
+	public void testGetClientNameIsDelegatedCorrectlyToNativeConnection() {
+
+		actual.add(connection.getClientName());
+		verify(nativeConnection, times(1)).getClientName();
+	}
+
 	protected List<Object> getResults() {
 		return actual;
 	}

src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionUnitTestSuite.java

@@ -90,6 +90,16 @@ public void shutdownSaveShouldBeSentCorrectlyUsingLuaScript() {
 			assertThat(captor.getValue(), equalTo("return redis.call('SHUTDOWN','SAVE')".getBytes()));
 		}
 
+		/**
+		 * @see DATAREDIS-270
+		 */
+		@Test
+		public void getClientNameShouldSendRequestCorrectly() {
+
+			connection.getClientName();
+			verifyNativeConnectionInvocation().clientGetname();
+		}
+
 	}
 
 	public static class JedisConnectionPipelineUnitTests extends JedisConnectionUnitTests {
@@ -118,6 +128,15 @@ public void shutdownSaveShouldBeSentCorrectlyUsingLuaScript() {
 			super.shutdownSaveShouldBeSentCorrectlyUsingLuaScript();
 		}
 
+		/**
+		 * @see DATAREDIS-270
+		 */
+		@Override
+		@Test(expected = UnsupportedOperationException.class)
+		public void getClientNameShouldSendRequestCorrectly() {
+			super.getClientNameShouldSendRequestCorrectly();
+		}
+
 	}
 
 	/**

src/test/java/org/springframework/data/redis/connection/jredis/JRedisConnectionUnitTests.java

@@ -56,4 +56,13 @@ public void shutdownNosaveShouldThrowUnsupportedOperationException() {
 	public void shutdownWithNullShouldThrowUnsupportedOperationException() {
 		connection.shutdown(null);
 	}
+
+	/**
+	 * @see DATAREDIS-270
+	 */
+	@Test(expected = UnsupportedOperationException.class)
+	public void getClientNameShouldSendRequestCorrectly() {
+		connection.getClientName();
+	}
+
 }

src/test/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionUnitTestSuite.java

@@ -82,6 +82,16 @@ public void shutdownWithSaveOptionIsCalledCorrectly() {
 			verifyNativeConnectionInvocation().shutdown(true);
 		}
 
+		/**
+		 * @see DATAREDIS-270
+		 */
+		@Test
+		public void getClientNameShouldSendRequestCorrectly() {
+
+			connection.getClientName();
+			verifyNativeConnectionInvocation().clientGetname();
+		}
+
 	}
 
 	public static class LettucePipelineConnectionUnitTests extends LettuceConnectionUnitTests {

src/test/java/org/springframework/data/redis/connection/srp/SrpConnectionUnitTestSuite.java

@@ -77,6 +77,16 @@ public void shutdownWithNosaveIsCalledCorrectly() {
 			verifyNativeConnectionInvocation().shutdown("NOSAVE".getBytes(Charsets.UTF_8), null);
 		}
 
+		/**
+		 * @see DATAREDIS-270
+		 */
+		@Test
+		public void getClientNameShouldSendRequestCorrectly() {
+
+			connection.getClientName();
+			verifyNativeConnectionInvocation().client_getname();
+		}
+
 	}
 
 	public static class SrpConnectionPiplineUnitTests extends AbstractConnectionUnitTestBase<Pipeline> {
@@ -123,6 +133,16 @@ public void shutdownWithNosaveIsCalledCorrectly() {
 			verifyNativeConnectionInvocation().shutdown("NOSAVE".getBytes(Charsets.UTF_8), null);
 		}
 
+		/**
+		 * @see DATAREDIS-270
+		 */
+		@Test
+		public void getClientNameShouldSendRequestCorrectly() {
+
+			connection.getClientName();
+			verifyNativeConnectionInvocation().client_getname();
+		}
+
 	}
 
 }