fix: use branch

Author: royalpinto007

coffee_core/src/coffee.rs

@@ -247,7 +247,7 @@ impl PluginManager for CoffeeManager {
         plugin: &str,
         verbose: bool,
         try_dynamic: bool,
-        _branch: Option<String>,
+        branch: Option<String>,
     ) -> Result<(), CoffeeError> {
         log::debug!("installing plugin: {plugin}");
         // keep track if the plugin is successfully installed
@@ -356,7 +356,7 @@ impl PluginManager for CoffeeManager {
         let status = repository.upgrade(&self.config.plugins).await?;
         for plugins in status.plugins_effected.iter() {
             self.remove(plugins).await?;
-            self.install(plugins, verbose, false, None).await?;
+            self.install(plugins, verbose, false, branch).await?;
         }
         self.flush().await?;
         Ok(status)

coffee_github/src/repository.rs

@@ -311,6 +311,7 @@ impl Repository for Github {
     }
 
     async fn switch_branch(&mut self, branch_name: &str) -> Result<(), CoffeeError> {
+        // FIXME: implement the From git2 Error for `CoffeError`
         let repo = git2::Repository::open(&self.url.path_string)
             .map_err(|err| error!("{}", err.message()))?;
         let mut remote = repo

coffee_httpd/src/httpd/server.rs

@@ -91,7 +91,8 @@ async fn coffee_install(
     let try_dynamic = body.try_dynamic;
 
     let mut coffee = data.coffee.lock().await;
-    let result = coffee.install(plugin, false, try_dynamic, None).await;
+    let branch = body.branch;
+    let result = coffee.install(plugin, false, try_dynamic, branch).await;
 
     handle_httpd_response!(result, "Plugin '{plugin}' installed successfully")
 }

coffee_plugin/src/plugin/plugin_mod.rs

@@ -98,7 +98,7 @@ impl RPCCommand<State> for CoffeeInstall {
         let rt = Runtime::new().unwrap();
 
         let request: InstallReq = serde_json::from_value(request)?;
-        rt.block_on(coffee.install(&request.name, false, true, None))
+        rt.block_on(coffee.install(&request.name, false, true, Some(request.branch)))
             .map_err(from)?;
         Ok(json!({}))
     }