currecting signature SELECT command

src/commands/impls/server.rs

@@ -149,9 +149,8 @@ pub async fn ping<C: ClientLike>(client: &C) -> Result<RedisValue, RedisError> {
   protocol_utils::frame_to_results(frame)
 }
 
-pub async fn select<C: ClientLike>(client: &C, db: u8) -> Result<RedisValue, RedisError> {
-  let frame = utils::request_response(client, || Ok((RedisCommandKind::Select, vec![db.into()]))).await?;
-  protocol_utils::frame_to_results(frame)
+pub async fn select<C: ClientLike>(client: &C, index: RedisValue) -> Result<RedisValue, RedisError> {
+  one_arg_value_cmd(client, RedisCommandKind::Select, index).await
 }
 
 pub async fn info<C: ClientLike>(client: &C, section: Option<InfoKind>) -> Result<RedisValue, RedisError> {

src/commands/interfaces/server.rs

@@ -2,7 +2,7 @@ use crate::{
   commands,
   error::RedisError,
   interfaces::{ClientLike, RedisResult},
-  types::{FromRedis, Server},
+  types::{FromRedis, RedisValue, Server},
 };
 use fred_macros::rm_send_if;
 use futures::Future;
@@ -43,8 +43,15 @@ pub trait ServerInterface: ClientLike {
   /// Select the database this client should use.
   ///
   /// <https://redis.io/commands/select>
-  fn select(&self, db: u8) -> impl Future<Output = RedisResult<()>> + Send {
-    async move { commands::server::select(self, db).await?.convert() }
+  fn select<I>(&self, index: I) -> impl Future<Output = RedisResult<()>> + Send
+  where
+    I: TryInto<RedisValue> + Send,
+    I::Error: Into<RedisError> + Send,
+  {
+    async move {
+      try_into!(index);
+      commands::server::select(self, index).await?.convert()
+    }
   }
 
   /// This command will start a coordinated failover between the currently-connected-to master and one of its

tests/integration/centralized.rs

@@ -185,6 +185,7 @@ mod server {
   centralized_test!(server, should_read_db_size);
   centralized_test!(server, should_start_bgsave);
   centralized_test!(server, should_do_bgrewriteaof);
+  centralized_test!(server, should_select_index_command);
 }
 
 #[cfg(feature = "i-sets")]

tests/integration/server/mod.rs

@@ -74,3 +74,8 @@ pub async fn should_do_bgrewriteaof(client: RedisClient, _: RedisConfig) -> Resu
   sleep(Duration::from_millis(1000)).await;
   Ok(())
 }
+
+pub async fn should_select_index_command(client: RedisClient, _: RedisConfig) -> Result<(), RedisError> {
+  assert_eq!(client.select(0).await, Ok(()));
+  Ok(())
+}