update cli structure

src/api/routes/upload.rs

@@ -107,6 +107,7 @@ where
     Ok(data_hash)
 }
 
+#[allow(unused)]
 fn path_is_valid(path: &Path) -> bool {
     let mut components = path.components().peekable();
 

src/cli/app.rs

@@ -23,6 +23,11 @@ pub async fn exec() -> anyhow::Result<()> {
         commands::SubCmd::Serve(args) => {
             commands::serve::exec(args).await
         }
+
+        commands::SubCmd::Call(args) => {
+            commands::call::exec(args).await
+        }
+
         _ => {
             anyhow::bail!("Not supported yet");
         } 

src/cli/commands/call.rs

@@ -0,0 +1,28 @@
+use std::net::SocketAddr;
+
+use crate::storage::FnId;
+
+#[derive(Debug, clap::Args)]
+pub struct CallCmd {
+    #[clap(long, default_value = "0.0.0.0:3401")]
+    pub server_addr: SocketAddr,
+
+    #[clap(long)]
+    pub fn_id: FnId,
+
+    #[clap(default_value = "")]
+    pub args: String,
+}
+
+pub async fn exec(args: CallCmd) -> anyhow::Result<()> {
+    let mut api_client = crate::api::client::Client::new()?;
+    let server_addr = args.server_addr;
+    let fn_id = args.fn_id;
+    let fn_args = args.args.as_bytes().to_vec();
+
+    let response = api_client.call(server_addr, &fn_id, fn_args).await?;
+    let response_json = serde_json::to_string_pretty(&response)?;
+    println!("{}", response_json);
+
+    Ok(())
+}

src/cli/commands/mod.rs

@@ -1,3 +1,4 @@
+pub mod call;
 pub mod serve;
 
 #[derive(clap::Subcommand, Debug)]
@@ -24,19 +25,6 @@ pub enum SubCmd {
     Config(config::ConfigCmd),
 }
 
-mod call {
-    use std::net::SocketAddr;
-
-    use crate::storage::FnId;
-
-    #[derive(Debug, clap::Args)]
-    pub struct CallCmd {
-        #[clap(long, default_value = "0.0.0.0:3401")]
-        pub server_addr: SocketAddr,
-        pub fn_id: FnId,
-    }
-}
-
 mod config {
     #[derive(Debug, clap::Args)]
     pub struct ConfigCmd {