1 files changed, 75 insertions, 32 deletions

diff --git a/src/main.rs b/src/main.rs
index aa2f233..1d6f34d 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -2,18 +2,11 @@
 extern crate dotenv_codegen;
 extern crate git2;
 
+use std::error::Error;
 use std::path::Path;
 
 use clap::Parser;
 use git2::{Cred, RemoteCallbacks};
-use gitlab::api::{projects, Query};
-use gitlab::Gitlab;
-use serde::Deserialize;
-
-#[derive(Debug, Deserialize)]
-struct Project {
-    http_url_to_repo: String,
-}
 
 /// Create a mirror of a repository
 #[derive(Parser, Debug)]
@@ -26,32 +19,28 @@ struct Args {
     /// The URL of the repository to clone
     #[arg(short, long)]
     repo: String,
-
-    /// The username to use for authentication
-    #[arg(long)]
-    username: String,
-
-    /// The password to use for authentication
-    #[arg(long)]
-    password: String,
 }
 
-/* Get project info from Gitlab */
-fn get_project(url: &str) -> Project {
-    let client = Gitlab::new(dotenv!("GITLAB_URL"), dotenv!("GITLAB_TOKEN")).unwrap();
-
-    let endpoint = projects::Project::builder().project(url).build().unwrap();
-    let project: Project = endpoint.query(&client).unwrap();
+fn get_project_url(repo: &str) -> String {
+    format!("https://{}/{}.git", dotenv!("GITLAB_URL"), repo)
+}
 
-    project
+fn get_remote_url(repo: &str) -> String {
+    format!(
+        "https://{}:{}@{}/{}",
+        dotenv!("REMOTE_USERNAME"),
+        dotenv!("REMOTE_PASSWORD"),
+        dotenv!("REMOTE_URL"),
+        repo
+    )
 }
 
 /* Clone project from Gitlab */
-fn clone_project(repo: &str, path: &str, username: &str, password: &str) {
+fn clone_remote_project(repo: &str, path: &str) {
     // Callbacks for authentication
     let mut cb = RemoteCallbacks::new();
     cb.credentials(|_url, _username_from_url, _allowed_types| {
-        Cred::userpass_plaintext(username, password)
+        Cred::userpass_plaintext(dotenv!("GITLAB_USERNAME"), dotenv!("GITLAB_PASSWORD"))
     });
 
     // Prepare fetch options
@@ -69,16 +58,70 @@ fn clone_project(repo: &str, path: &str, username: &str, password: &str) {
     builder.clone(repo, Path::new(&path)).unwrap();
 }
 
+/* Get project ID from Gitlab */
+fn get_project_id(project_name: &str) -> Result<u64, Box<dyn Error>> {
+    let client = reqwest::blocking::Client::new();
+    let encoded_name = urlencoding::encode(project_name);
+
+    let api_url = format!(
+        "https://{}/api/v4/projects/{}",
+        dotenv!("GITLAB_URL"),
+        encoded_name
+    );
+
+    let response = client
+        .get(&api_url)
+        .bearer_auth(dotenv!("GITLAB_TOKEN"))
+        .send()?;
+
+    if response.status().is_success() {
+        let project_info: serde_json::Value = response.json()?;
+        Ok(project_info["id"].as_u64().unwrap())
+    } else {
+        Err("Failed to get project ID".into())
+    }
+}
+
+/* Add mirror to Gitlab */
+fn add_gitlab_mirror(repo_id: u64, mirror_url: &str) -> Result<(), Box<dyn Error>> {
+    let client = reqwest::blocking::Client::new();
+
+    let api_url = format!(
+        "https://{}/api/v4/projects/{}/remote_mirrors",
+        dotenv!("GITLAB_URL"),
+        repo_id
+    );
+
+    let response = client
+        .post(&api_url)
+        .bearer_auth(dotenv!("GITLAB_TOKEN"))
+        .json(&serde_json::json!({
+            "url": mirror_url,
+            "enabled": true,
+            "keep_divergent_refs": false,
+            "only_protected_branches": false,
+        }))
+        .send()?;
+
+    dbg!(response.status());
+    if response.status().is_success() {
+        Ok(())
+    } else {
+        Err("Failed to add mirror".into())
+    }
+}
+
 fn main() {
     dotenv::dotenv().ok();
 
     let args = Args::parse();
-    let project = get_project(&args.repo);
 
-    clone_project(
-        &project.http_url_to_repo,
-        &args.path,
-        &args.username,
-        &args.password,
-    );
+    let project_id = get_project_id(&args.repo).unwrap();
+    let mirror_url = get_remote_url(&args.path);
+    add_gitlab_mirror(project_id, &mirror_url).unwrap();
+
+    dbg!(&project_id);
+    dbg!(&mirror_url);
+
+    clone_remote_project(&get_project_url(&args.repo), &args.path);
 }