Merge pull request #1 from SwissDataScienceCenter/tokio

Add tokio and use async reqwest http client

Cargo.toml

@@ -24,6 +24,8 @@ reqwest = { version = "0.12.5", default-features = false, features = ["json", "b
 serde = { version = "1.0.203", features = ["derive"] }
 serde_json = "1.0.118"
 snafu = { version = "0.8.3" }
+tokio = { version = "1", features = ["full"] }
+futures = { version = "0.3" }
 
 [features]
 default = ["reqwest/default-tls"] # link against system library

flake.nix

@@ -40,6 +40,8 @@
       craneLib = crane.mkLib pkgs;
       src = craneLib.cleanCargoSource ./.;
 
+      fenixToolChain = fenix.packages.${system}.complete;
+
       # Common arguments can be set here to avoid repeating them later
       commonArgs = {
         inherit src;
@@ -65,7 +67,7 @@
 
       craneLibLLvmTools =
         craneLib.overrideToolchain
-        (fenix.packages.${system}.complete.withComponents [
+        (fenixToolChain.withComponents [
           "cargo"
           "llvm-tools"
           "rustc"
@@ -152,6 +154,8 @@
         # Inherit inputs from checks.
         checks = self.checks.${system};
 
+        RUST_SRC_PATH = "${fenixToolChain.rust-src}/lib/rustlib/src/rust/library";
+
         # Additional dev-shell environment variables can be set directly
         # MY_CUSTOM_DEVELOPMENT_VAR = "something else";
         RENKU_CLI_RENKU_URL = "https://ci-renku-3668.dev.renku.ch";
@@ -167,6 +171,8 @@
         # Extra inputs can be added here; cargo and rustc are provided by default.
         packages = with pkgs; [
           cargo-edit
+          fenixToolChain.rust-analyzer
+          fenixToolChain.rustfmt
         ];
       };
     });

rustfmt.toml

@@ -0,0 +1 @@
+edition = "2021"

src/cli.rs

@@ -2,23 +2,23 @@ pub mod cmd;
 pub mod opts;
 pub mod sink;
 
-use self::cmd::{Cmd, CmdError, Context};
+use self::cmd::{CmdError, Context};
 use self::opts::{MainOpts, SubCommand};
 use clap::CommandFactory;
 use serde::Serialize;
 use std::fmt;
 
-pub fn execute_cmd(opts: MainOpts) -> Result<(), CmdError> {
+pub async fn execute_cmd(opts: MainOpts) -> Result<(), CmdError> {
     let ctx = Context::new(&opts.common_opts)?;
 
     log::info!("Running command: {:?}", opts.subcmd);
     match &opts.subcmd {
-        SubCommand::Version(input) => input.exec(&ctx)?,
+        SubCommand::Version(input) => input.exec(&ctx).await?,
         SubCommand::ShellCompletion(input) => {
             let mut app = MainOpts::command();
-            input.print_completions(&mut app);
+            input.print_completions(&mut app).await;
         }
-        SubCommand::Project(input) => input.exec(&ctx)?,
+        SubCommand::Project(input) => input.exec(&ctx).await?,
     };
     Ok(())
 }