feat(claim) create basic event

replacable event with root-commit, name, description and relay tags

1 files changed, 114 insertions, 0 deletions

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")
+}