4 files changed, 127 insertions, 7 deletions

diff --git a/src/main.rs b/src/main.rs
index 68b0ed6..54ad748 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -33,7 +33,9 @@ pub struct Cli {
 enum Commands {
     /// save encrypted nsec for future use
     Login(sub_commands::login::SubCommandArgs),
-    /// create and issue Prs
+    /// issue repository reference event as a maintainers
+    Claim(sub_commands::claim::SubCommandArgs),
+    /// create and issue prs
     Prs(sub_commands::prs::SubCommandArgs),
 }
 
@@ -44,6 +46,9 @@ async fn main() -> Result<()> {
         Commands::Login(args) => {
             futures::executor::block_on(sub_commands::login::launch(&cli, args))
         }
+        Commands::Claim(args) => {
+            futures::executor::block_on(sub_commands::claim::launch(&cli, args))
+        }
         Commands::Prs(args) => futures::executor::block_on(sub_commands::prs::launch(&cli, args)),
     }
 }
diff --git a/src/sub_commands/claim.rs b/src/sub_commands/claim.rs
new file mode 100644
index 0000000..5eb66bb
--- /dev/null
+++ b/src/sub_commands/claim.rs
@@ -0,0 +1,114 @@
+use anyhow::{Context, Result};
+use nostr::{EventBuilder, Tag};
+
+use super::prs::create::send_events;
+#[cfg(not(test))]
+use crate::client::Client;
+#[cfg(test)]
+use crate::client::MockConnect;
+use crate::{
+    cli_interactor::{Interactor, InteractorPrompt, PromptInputParms},
+    client::Connect,
+    git::{Repo, RepoActions},
+    login, Cli,
+};
+
+#[derive(Debug, clap::Args)]
+pub struct SubCommandArgs {
+    #[clap(short, long)]
+    /// name of repository
+    title: Option<String>,
+    #[clap(short, long)]
+    /// optional description
+    description: Option<String>,
+}
+
+pub async fn launch(cli_args: &Cli, args: &SubCommandArgs) -> Result<()> {
+    let git_repo = Repo::discover().context("cannot find a git repository")?;
+
+    let (main_or_master_branch_name, _) = git_repo
+        .get_main_or_master_branch()
+        .context("no main or master branch")?;
+
+    let root_commit = git_repo
+        .get_root_commit(main_or_master_branch_name)
+        .context("failed to get root commit of the repository")?;
+
+    // TODO: check for empty repo
+    // TODO: check for existing maintaiers file
+    // TODO: check for other claims
+
+    let name = match &args.title {
+        Some(t) => t.clone(),
+        None => Interactor::default().input(PromptInputParms::default().with_prompt("name"))?,
+    };
+
+    let description = match &args.description {
+        Some(t) => t.clone(),
+        None => Interactor::default()
+            .input(PromptInputParms::default().with_prompt("description (Optional)"))?,
+    };
+
+    #[cfg(not(test))]
+    let mut client = Client::default();
+    #[cfg(test)]
+    let mut client = <MockConnect as std::default::Default>::default();
+
+    let (keys, user_ref) = login::launch(&cli_args.nsec, &cli_args.password, Some(&client)).await?;
+
+    client.set_keys(&keys).await;
+
+    // TODO: choice input defaulting to user relay list filtered by non paid relays
+    let repo_relays: Vec<String> = vec![
+        "ws://localhost:8055".to_string(),
+        "ws://localhost:8056".to_string(),
+    ];
+
+    println!("publishing repostory reference...");
+
+    send_events(
+        &client,
+        vec![generate_repo_event(
+            &name,
+            &description,
+            &repo_relays,
+            &root_commit.to_string(),
+            &keys,
+        )?],
+        user_ref.relays.write(),
+        repo_relays,
+        !cli_args.disable_cli_spinners,
+    )
+    .await?;
+
+    Ok(())
+}
+
+fn generate_repo_event(
+    name: &str,
+    description: &str,
+    relays: &[String],
+    // git_server: String,
+    root_commit: &String,
+    keys: &nostr::Keys,
+) -> Result<nostr::Event> {
+    EventBuilder::new(
+        nostr::event::Kind::Custom(30017),
+        "",
+        &[
+            vec![
+                Tag::Identifier(root_commit.to_string()),
+                Tag::Reference(format!("r-{root_commit}")),
+                Tag::Name(name.to_owned()),
+                Tag::Description(description.to_owned()),
+            ],
+            relays.iter().map(|r| Tag::Relay(r.into())).collect(),
+            // git_servers
+            // other maintainers
+            // code languages and hashtags
+        ]
+        .concat(),
+    )
+    .to_event(keys)
+    .context("failed to create pr event")
+}
diff --git a/src/sub_commands/mod.rs b/src/sub_commands/mod.rs
index 3c3da1d..6e99ca5 100644
--- a/src/sub_commands/mod.rs
+++ b/src/sub_commands/mod.rs
@@ -1,2 +1,3 @@
+pub mod claim;
 pub mod login;
 pub mod prs;
diff --git a/src/sub_commands/prs/create.rs b/src/sub_commands/prs/create.rs
index aad80f4..d82f53e 100644
--- a/src/sub_commands/prs/create.rs
+++ b/src/sub_commands/prs/create.rs
@@ -105,6 +105,11 @@ pub async fn launch(
         "ws://localhost:8056".to_string(),
     ];
 
+    println!(
+        "posting 1 pull request with {} commits...",
+        events.len() - 1
+    );
+
     send_events(
         &client,
         events,
@@ -118,7 +123,7 @@ pub async fn launch(
     Ok(())
 }
 
-async fn send_events(
+pub async fn send_events(
     #[cfg(test)] client: &crate::client::MockConnect,
     #[cfg(not(test))] client: &Client,
     events: Vec<nostr::Event>,
@@ -128,11 +133,6 @@ async fn send_events(
 ) -> Result<()> {
     let (_, _, _, all) = unique_and_duplicate_all(&my_write_relays, &repo_read_relays);
 
-    println!(
-        "posting 1 pull request with {} commits...",
-        events.len() - 1
-    );
-
     let m = MultiProgress::new();
     let pb_style = ProgressStyle::with_template(if animate {
         " {spinner} {prefix} {bar} {pos}/{len} {msg}"