feat: Update workflow + action

Author: GeekMasher

src/action.rs

@@ -1,4 +1,6 @@
+use anyhow::Result;
 use ghactions::prelude::*;
+use ghastoolkit::Repository;
 
 #[derive(Actions, Debug, Clone)]
 #[action(
@@ -20,7 +22,24 @@ pub struct Action {
     #[input(description = "GitHub Token")]
     token: String,
 
-    /// GitHub Repository
-    #[input(description = "GitHub Repository")]
-    repository: String,
+    /// GitHub Repository where the extractor is located
+    #[input(description = "GitHub Repository where the extractor is located")]
+    extractor_repository: String,
+}
+
+impl Action {
+    /// Gets the repository to use for the extractor. If the repository is not provided,
+    /// it will use the repository that the action is running in.
+    pub fn extractor_repository(&self) -> Result<Repository> {
+        let repo = if self.extractor_repository.is_empty() {
+            log::debug!("No extractor repository provided, using the current repository");
+            self.get_repository()?
+        } else {
+            log::debug!("Using the provided extractor repository");
+            self.extractor_repository.clone()
+        };
+        log::info!("Extractor Repository :: {}", repo);
+
+        Ok(Repository::parse(&repo)?)
+    }
 }

src/main.rs

@@ -1,42 +1,46 @@
-use anyhow::Result;
-use ghactions::{group, groupend, ActionTrait};
-use log::info;
-use octocrab::{models::issues::Issue, params::State};
-use std::error::Error;
+use std::path::PathBuf;
+
+use anyhow::{Context, Result};
+use ghactions::{group, groupend, ActionTrait, ToolCache};
+use log::{debug, info};
 
 mod action;
+mod extractors;
 
 use action::Action;
 
 #[tokio::main]
-async fn main() -> Result<(), Box<dyn Error>> {
+async fn main() -> Result<()> {
     let action = Action::init()?;
+    debug!("Action :: {:?}", action);
 
-    info!("Action :: {:?}", action);
-
-    group!("Main Workflow");
+    group!("Initialise Workflow");
 
-    info!("Repository: `{}`", action.get_repository()?);
+    let client = octocrab::instance();
 
-    let client = action.octocrab()?;
+    let toolcache = ToolCache::new();
+    debug!("ToolCache :: {:?}", toolcache);
 
-    // https://docs.rs/octocrab/latest/octocrab/index.html
-    // Example to get all the active issues
-    let issues_pages = client
-        .issues(
-            action.get_repository_owner()?,
-            action.get_repository_name()?,
-        )
-        .list()
-        .state(State::Open)
-        .per_page(50)
-        .send()
-        .await?;
+    // Extractor
+    let extractor_repo = action.extractor_repository()?;
+    info!("Extractor Repository :: {}", extractor_repo);
 
-    for issue in client.all_pages::<Issue>(issues_pages).await? {
-        info!(" >> {} -> {}", issue.id, issue.title);
+    let extractor_path = PathBuf::from("./extractors");
+    if !extractor_path.exists() {
+        std::fs::create_dir(&extractor_path)
+            .with_context(|| format!("Failed to create directory {:?}", extractor_path))?;
+        info!("Created Extractor Directory :: {:?}", extractor_path);
     }
 
+    let extractor = extractors::fetch_extractor(&client, &extractor_repo, &extractor_path).await?;
+    log::info!("Extractor :: {:?}", extractor);
+
+    groupend!();
+
+    group!("Download and install extractor");
+
+    // TODO: Validate the extractor
+
     groupend!();
 
     Ok(())