feat(redis): introduce redis client for caching

Author: shiqimei

Dockerfile

@@ -0,0 +1,10 @@
+FROM redis:alpine
+
+# Expose port 6739 
+EXPOSE 6739
+
+# Set default Redis config
+RUN echo "port 6739" >> /usr/local/etc/redis/redis.conf
+
+# Start Redis
+CMD [ "redis-server", "/usr/local/etc/redis/redis.conf" ]

crates/Cargo.lock

@@ -11,6 +11,7 @@ tokio = { version = "1.32.0", features = ["full"] }
 axum = "0.6.20"
 serde = { version = "1.0.188", features = ["derive"] }
 serde_json = "1.0.105"
+redis = { version = "0.23.2", features = [ "cluster-async", "tokio-comp" ] }
 tree-sitter = "0.20.10"
 tree-sitter-rust = "0.20.4"
 tree-sitter-python = "0.20.4"

crates/codeindex/Cargo.toml

@@ -4,6 +4,8 @@ use axum::{
     routing::get,
     Router,
 };
+use redis::cluster::ClusterClient;
+use redis::AsyncCommands;
 use serde_json::Value as JsonValue;
 
 #[derive(serde::Serialize)]
@@ -30,8 +32,28 @@ async fn handler() -> Result<(), CodeIndexError> {
     Err(CodeIndexError::SomethingWentWrong)
 }
 
+async fn fetch_an_integer() -> String {
+    let nodes = vec!["redis://127.0.0.1:6739"];
+    let client = ClusterClient::new(nodes).unwrap();
+    let mut connection = client.get_async_connection().await.expect(
+        format!(
+            "\n[Error] {}\n\t{}\n\t{}\n",
+            "Failed to connect to redis cluster server. Please check:",
+            "1. Whether redis is running and listening on port 6739.",
+            "2. Whether redis cluster support is enabled."
+        )
+        .as_str(),
+    );
+    let _: () = connection.set("test", "test_data").await.unwrap();
+    let rv: String = connection.get("test").await.unwrap();
+    return rv;
+}
+
 #[tokio::main]
 async fn main() {
+    let result = fetch_an_integer();
+    print!("{:?}", result.await);
+
     let app = Router::new()
         .route("/", get(root))
         .route("/:file", get(handler));