add pttl api

Author: yph025869

include/cppredis/client.hpp

@@ -169,7 +169,6 @@ namespace cpp_redis {
 			return client_->pexpire(std::move(keys_[0]), milliseconds);
 		}
 
-
 		template<typename T>
 		bool expire_at(T&& key, std::size_t unix_timestamp)
 		{
@@ -221,7 +220,6 @@ namespace cpp_redis {
 			return client_->remove_expire(std::move(keys_[0]));
 		}
 
-
 		template<typename T>
 		int  remainder_ttl(T&& key)
 		{
@@ -239,6 +237,23 @@ namespace cpp_redis {
 			return client_->remainder_ttl(std::move(keys_[0]));
 		}
 
+		template<typename T>
+		int  remainder_pttl(T&& key)
+		{
+			if (client_ == nullptr) {
+				return -1;
+			}
+
+			reset();
+			any_type_to_string(key);
+
+			if (keys_.empty()) {
+				return -1;
+			}
+
+			return client_->remainder_pttl(std::move(keys_[0]));
+		}
+
 		template<typename T1,typename T2>
 		bool rename_key(T1&& src_key, T2&&new_key){
 			if (client_ == nullptr) {

include/cppredis/client_interface.hpp

@@ -212,6 +212,30 @@ namespace cpp_redis {
 			return int_results[0];
 		}
 
+		//key的剩余时间 -1:表示永久 -2:表示不存在
+		int64_t  remainder_pttl(std::string&& key)
+		{
+			check_args();
+
+			std::string msg = request_->req_n_key(request_->get_cmd(redis_cmd::pttl), 
+				std::forward<std::string>(key));
+			
+			socket_->send_msg(std::move(msg));
+			const auto res = socket_->get_responese();
+
+			if (res->get_result_code() != status::int_result_) {
+				return -2;
+			}
+
+			const auto int_results = res->get_int_results();
+			if (int_results.empty()) {
+				return -2;
+			}
+
+			return int_results[0];
+		}
+
+
 		bool rename_key(std::string&& key,std::string &&new_key)
 		{
 			check_args();

include/cppredis/cpp_define.h

@@ -19,6 +19,7 @@ namespace cpp_redis {
 	const std::string g_pexpire_at_cmd              = "PEXPIREAT";
 	const std::string g_remove_expire_cmd           = "PERSIST";
 	const std::string g_ttl_cmd                     = "TTL";
+	const std::string g_pttl_cmd                    = "PTTL";
 	const std::string g_rename_cmd                  = "RENAME";
 	const std::string g_renamenx_cmd                = "RENAMENX";
 	const std::string g_multi_cmd                   = "MULTI";//¿ªÆôÊÂÎñ 
@@ -144,81 +145,82 @@ namespace cpp_redis {
 		pexpire_at                                  = 17,
 		remove_expire                               = 18,
 		ttl                                         = 19,
-		multi                                       = 20,
-		exec                                        = 21,
-		discard                                     = 22,
-		rename                                      = 23,
-		renamenx                                    = 24,
-		get_set                                     = 25,
-		substr                                      = 26,
-		mget                                        = 27,
-		mset                                        = 28,
-		msetnx                                      = 29,
-		append                                      = 30,
-		rpush                                       = 31,
-		lpush                                       = 32,
-		llen                                        = 33,
-		lrange                                      = 34,
-		rpop                                        = 35,
-		lpop                                        = 36,
-		brpop                                       = 37,
-		blpop                                       = 38,
-		ltrim                                       = 39,
-		lindex                                      = 40,
-		lset                                        = 41,
-		lrem                                        = 42,
-		rpoplpush                                   = 43,
-		lpushx                                      = 44,
-		rpushx                                      = 45,
-		list_insert                                 = 46,
-		brpoplpush                                  = 47,
-		sadd                                        = 48,
-		srem                                        = 49,
-		sismember                                   = 50,
-		spop_elem                                   = 51,
-		srandmember                                 = 52,
-		smove                                       = 53,
-		ssize                                       = 54,
-		smembers                                    = 55,
-		sinter                                      = 56,
-		ssinter_store                               = 57,
-		sunion                                      = 58,
-		ssunion_store                               = 59,
-		sdiff                                       = 60,
-		sdiff_store                                 = 61,
-		zset_add                                    = 62,
-		zset_score                                  = 63,
-		zset_incrby                                 = 64,
-		zset_card                                   = 65,
-		zset_count                                  = 66,
-		zset_range                                  = 67,
-		zset_rank                                   = 68,
-		zset_rem                                    = 69,
-		zset_revrank                                = 70,
-		zset_revrange                               = 71,
-		zset_lexcount                               = 72,
-		zset_rangebylex                             = 73,
-		zset_union_store                            = 74,
-		zset_inter_store                            = 75,
-		zset_range_score                            = 76,
-		zset_remrangebylex                          = 77,
-		zset_rerange_score                          = 78,
-		zset_remrangebyscore                        = 79,
-		zset_remrangeby_rank                        = 80,
-		hash_set                                    = 81,
-		hash_setx                                   = 82,
-		hash_exists                                 = 83,
-		hash_get                                    = 84,
-		hash_del                                    = 85,
-		hash_len                                    = 86,
-		hash_mset                                   = 87,
-		hash_mget                                   = 88,
-		hash_vals                                   = 89,
-		hash_keys                                   = 90,
-		hash_strlen                                 = 91,
-		hash_incrby                                 = 92,
-		hash_get_all                                = 93,
-		hash_incrby_float                           = 94,
+		pttl                                        = 20,
+		multi                                       = 21,
+		exec                                        = 22,
+		discard                                     = 23,
+		rename                                      = 24,
+		renamenx                                    = 25,
+		get_set                                     = 26,
+		substr                                      = 27,
+		mget                                        = 28,
+		mset                                        = 29,
+		msetnx                                      = 30,
+		append                                      = 31,
+		rpush                                       = 32,
+		lpush                                       = 33,
+		llen                                        = 34,
+		lrange                                      = 35,
+		rpop                                        = 36,
+		lpop                                        = 37,
+		brpop                                       = 38,
+		blpop                                       = 39,
+		ltrim                                       = 40,
+		lindex                                      = 41,
+		lset                                        = 42,
+		lrem                                        = 43,
+		rpoplpush                                   = 44,
+		lpushx                                      = 45,
+		rpushx                                      = 46,
+		list_insert                                 = 47,
+		brpoplpush                                  = 48,
+		sadd                                        = 49,
+		srem                                        = 50,
+		sismember                                   = 51,
+		spop_elem                                   = 52,
+		srandmember                                 = 53,
+		smove                                       = 54,
+		ssize                                       = 55,
+		smembers                                    = 56,
+		sinter                                      = 57,
+		ssinter_store                               = 58,
+		sunion                                      = 59,
+		ssunion_store                               = 60,
+		sdiff                                       = 61,
+		sdiff_store                                 = 62,
+		zset_add                                    = 63,
+		zset_score                                  = 64,
+		zset_incrby                                 = 65,
+		zset_card                                   = 66,
+		zset_count                                  = 67,
+		zset_range                                  = 68,
+		zset_rank                                   = 69,
+		zset_rem                                    = 70,
+		zset_revrank                                = 71,
+		zset_revrange                               = 72,
+		zset_lexcount                               = 73,
+		zset_rangebylex                             = 74,
+		zset_union_store                            = 75,
+		zset_inter_store                            = 76,
+		zset_range_score                            = 77,
+		zset_remrangebylex                          = 78,
+		zset_rerange_score                          = 79,
+		zset_remrangebyscore                        = 80,
+		zset_remrangeby_rank                        = 81,
+		hash_set                                    = 82,
+		hash_setx                                   = 83,
+		hash_exists                                 = 84,
+		hash_get                                    = 85,
+		hash_del                                    = 86,
+		hash_len                                    = 87,
+		hash_mset                                   = 88,
+		hash_mget                                   = 89,
+		hash_vals                                   = 90,
+		hash_keys                                   = 91,
+		hash_strlen                                 = 92,
+		hash_incrby                                 = 93,
+		hash_get_all                                = 94,
+		hash_incrby_float                           = 95,
 	};
 
 	enum request_type

include/cppredis/cpp_redis_request.hpp

@@ -81,6 +81,9 @@ namespace cpp_redis {
 			case cpp_redis::ttl:
 				cmd_str = g_ttl_cmd;
 				break;
+			case redis_cmd::pttl:
+				cmd_str = g_pttl_cmd;
+				break;
 			case cpp_redis::rename:
 				cmd_str = g_rename_cmd;
 				break;