diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/bin/git_remote_nostr/fetch.rs | 10 | ||||
| -rw-r--r-- | src/bin/git_remote_nostr/list.rs | 6 | ||||
| -rw-r--r-- | src/bin/git_remote_nostr/main.rs | 6 | ||||
| -rw-r--r-- | src/bin/git_remote_nostr/push.rs | 62 | ||||
| -rw-r--r-- | src/bin/git_remote_nostr/utils.rs | 17 | ||||
| -rw-r--r-- | src/bin/ngit/cli.rs | 2 | ||||
| -rw-r--r-- | src/bin/ngit/sub_commands/export_keys.rs | 2 | ||||
| -rw-r--r-- | src/bin/ngit/sub_commands/init.rs | 12 | ||||
| -rw-r--r-- | src/bin/ngit/sub_commands/list.rs | 19 | ||||
| -rw-r--r-- | src/bin/ngit/sub_commands/login.rs | 4 | ||||
| -rw-r--r-- | src/bin/ngit/sub_commands/logout.rs | 2 | ||||
| -rw-r--r-- | src/bin/ngit/sub_commands/send.rs | 17 | ||||
| -rw-r--r-- | src/lib/cli_interactor.rs | 2 | ||||
| -rw-r--r-- | src/lib/client.rs | 140 | ||||
| -rw-r--r-- | src/lib/git/identify_ahead_behind.rs | 8 | ||||
| -rw-r--r-- | src/lib/git/mod.rs | 87 | ||||
| -rw-r--r-- | src/lib/git/nostr_url.rs | 136 | ||||
| -rw-r--r-- | src/lib/git_events.rs | 22 | ||||
| -rw-r--r-- | src/lib/login/existing.rs | 8 | ||||
| -rw-r--r-- | src/lib/login/fresh.rs | 10 | ||||
| -rw-r--r-- | src/lib/login/mod.rs | 14 | ||||
| -rw-r--r-- | src/lib/login/user.rs | 4 | ||||
| -rw-r--r-- | src/lib/mod.rs | 2 | ||||
| -rw-r--r-- | src/lib/repo_ref.rs | 46 |
24 files changed, 284 insertions, 354 deletions
diff --git a/src/bin/git_remote_nostr/fetch.rs b/src/bin/git_remote_nostr/fetch.rs index 458c6d8..7012955 100644 --- a/src/bin/git_remote_nostr/fetch.rs +++ b/src/bin/git_remote_nostr/fetch.rs | |||
| @@ -6,15 +6,15 @@ use std::{ | |||
| 6 | time::Instant, | 6 | time::Instant, |
| 7 | }; | 7 | }; |
| 8 | 8 | ||
| 9 | use anyhow::{anyhow, bail, Context, Result}; | 9 | use anyhow::{Context, Result, anyhow, bail}; |
| 10 | use auth_git2::GitAuthenticator; | 10 | use auth_git2::GitAuthenticator; |
| 11 | use git2::{Progress, Repository}; | 11 | use git2::{Progress, Repository}; |
| 12 | use ngit::{ | 12 | use ngit::{ |
| 13 | cli_interactor::count_lines_per_msg_vec, | 13 | cli_interactor::count_lines_per_msg_vec, |
| 14 | git::{ | 14 | git::{ |
| 15 | Repo, RepoActions, | ||
| 15 | nostr_url::{CloneUrl, NostrUrlDecoded, ServerProtocol}, | 16 | nostr_url::{CloneUrl, NostrUrlDecoded, ServerProtocol}, |
| 16 | utils::check_ssh_keys, | 17 | utils::check_ssh_keys, |
| 17 | Repo, RepoActions, | ||
| 18 | }, | 18 | }, |
| 19 | git_events::tag_value, | 19 | git_events::tag_value, |
| 20 | login::get_curent_user, | 20 | login::get_curent_user, |
| @@ -24,9 +24,9 @@ use nostr::nips::nip19; | |||
| 24 | use nostr_sdk::{Event, ToBech32}; | 24 | use nostr_sdk::{Event, ToBech32}; |
| 25 | 25 | ||
| 26 | use crate::utils::{ | 26 | use crate::utils::{ |
| 27 | fetch_or_list_error_is_not_authentication_failure, find_proposal_and_patches_by_branch_name, | 27 | Direction, fetch_or_list_error_is_not_authentication_failure, |
| 28 | get_oids_from_fetch_batch, get_open_proposals, get_read_protocols_to_try, join_with_and, | 28 | find_proposal_and_patches_by_branch_name, get_oids_from_fetch_batch, get_open_proposals, |
| 29 | set_protocol_preference, Direction, | 29 | get_read_protocols_to_try, join_with_and, set_protocol_preference, |
| 30 | }; | 30 | }; |
| 31 | 31 | ||
| 32 | pub async fn run_fetch( | 32 | pub async fn run_fetch( |
diff --git a/src/bin/git_remote_nostr/list.rs b/src/bin/git_remote_nostr/list.rs index 9171544..bba15aa 100644 --- a/src/bin/git_remote_nostr/list.rs +++ b/src/bin/git_remote_nostr/list.rs | |||
| @@ -1,7 +1,7 @@ | |||
| 1 | use core::str; | 1 | use core::str; |
| 2 | use std::collections::HashMap; | 2 | use std::collections::HashMap; |
| 3 | 3 | ||
| 4 | use anyhow::{anyhow, Context, Result}; | 4 | use anyhow::{Context, Result, anyhow}; |
| 5 | use auth_git2::GitAuthenticator; | 5 | use auth_git2::GitAuthenticator; |
| 6 | use client::get_state_from_cache; | 6 | use client::get_state_from_cache; |
| 7 | use git::RepoActions; | 7 | use git::RepoActions; |
| @@ -22,9 +22,9 @@ use crate::{ | |||
| 22 | fetch::{fetch_from_git_server, make_commits_for_proposal}, | 22 | fetch::{fetch_from_git_server, make_commits_for_proposal}, |
| 23 | git::Repo, | 23 | git::Repo, |
| 24 | utils::{ | 24 | utils::{ |
| 25 | fetch_or_list_error_is_not_authentication_failure, get_open_proposals, | 25 | Direction, fetch_or_list_error_is_not_authentication_failure, get_open_proposals, |
| 26 | get_read_protocols_to_try, get_short_git_server_name, join_with_and, | 26 | get_read_protocols_to_try, get_short_git_server_name, join_with_and, |
| 27 | set_protocol_preference, Direction, | 27 | set_protocol_preference, |
| 28 | }, | 28 | }, |
| 29 | }; | 29 | }; |
| 30 | 30 | ||
diff --git a/src/bin/git_remote_nostr/main.rs b/src/bin/git_remote_nostr/main.rs index 1a21341..e6f7af3 100644 --- a/src/bin/git_remote_nostr/main.rs +++ b/src/bin/git_remote_nostr/main.rs | |||
| @@ -11,9 +11,9 @@ use std::{ | |||
| 11 | path::{Path, PathBuf}, | 11 | path::{Path, PathBuf}, |
| 12 | }; | 12 | }; |
| 13 | 13 | ||
| 14 | use anyhow::{bail, Context, Result}; | 14 | use anyhow::{Context, Result, bail}; |
| 15 | use client::{consolidate_fetch_reports, get_repo_ref_from_cache, Connect}; | 15 | use client::{Connect, consolidate_fetch_reports, get_repo_ref_from_cache}; |
| 16 | use git::{nostr_url::NostrUrlDecoded, RepoActions}; | 16 | use git::{RepoActions, nostr_url::NostrUrlDecoded}; |
| 17 | use ngit::{client, git, login::existing::load_existing_login}; | 17 | use ngit::{client, git, login::existing::load_existing_login}; |
| 18 | use nostr::nips::nip01::Coordinate; | 18 | use nostr::nips::nip01::Coordinate; |
| 19 | use utils::read_line; | 19 | use utils::read_line; |
diff --git a/src/bin/git_remote_nostr/push.rs b/src/bin/git_remote_nostr/push.rs index f2ac169..e8e1587 100644 --- a/src/bin/git_remote_nostr/push.rs +++ b/src/bin/git_remote_nostr/push.rs | |||
| @@ -6,17 +6,17 @@ use std::{ | |||
| 6 | time::Instant, | 6 | time::Instant, |
| 7 | }; | 7 | }; |
| 8 | 8 | ||
| 9 | use anyhow::{anyhow, bail, Context, Result}; | 9 | use anyhow::{Context, Result, anyhow, bail}; |
| 10 | use auth_git2::GitAuthenticator; | 10 | use auth_git2::GitAuthenticator; |
| 11 | use client::{ | 11 | use client::{ |
| 12 | get_events_from_local_cache, get_state_from_cache, send_events, sign_event, STATE_KIND, | 12 | STATE_KIND, get_events_from_local_cache, get_state_from_cache, send_events, sign_event, |
| 13 | }; | 13 | }; |
| 14 | use console::Term; | 14 | use console::Term; |
| 15 | use git::{sha1_to_oid, RepoActions}; | 15 | use git::{RepoActions, sha1_to_oid}; |
| 16 | use git2::{Oid, Repository}; | ||
| 17 | use git_events::{ | 16 | use git_events::{ |
| 18 | generate_cover_letter_and_patch_events, generate_patch_event, get_commit_id_from_patch, | 17 | generate_cover_letter_and_patch_events, generate_patch_event, get_commit_id_from_patch, |
| 19 | }; | 18 | }; |
| 19 | use git2::{Oid, Repository}; | ||
| 20 | use ngit::{ | 20 | use ngit::{ |
| 21 | cli_interactor::count_lines_per_msg_vec, | 21 | cli_interactor::count_lines_per_msg_vec, |
| 22 | client::{self, get_event_from_cache_by_id}, | 22 | client::{self, get_event_from_cache_by_id}, |
| @@ -32,8 +32,8 @@ use ngit::{ | |||
| 32 | }; | 32 | }; |
| 33 | use nostr::nips::nip10::Marker; | 33 | use nostr::nips::nip10::Marker; |
| 34 | use nostr_sdk::{ | 34 | use nostr_sdk::{ |
| 35 | hashes::sha1::Hash as Sha1Hash, Event, EventBuilder, EventId, Kind, NostrSigner, PublicKey, | 35 | Event, EventBuilder, EventId, Kind, NostrSigner, PublicKey, RelayUrl, Tag, |
| 36 | RelayUrl, Tag, | 36 | hashes::sha1::Hash as Sha1Hash, |
| 37 | }; | 37 | }; |
| 38 | use repo_ref::RepoRef; | 38 | use repo_ref::RepoRef; |
| 39 | use repo_state::RepoState; | 39 | use repo_state::RepoState; |
| @@ -43,9 +43,10 @@ use crate::{ | |||
| 43 | git::Repo, | 43 | git::Repo, |
| 44 | list::list_from_remotes, | 44 | list::list_from_remotes, |
| 45 | utils::{ | 45 | utils::{ |
| 46 | find_proposal_and_patches_by_branch_name, get_all_proposals, get_remote_name_by_url, | 46 | Direction, find_proposal_and_patches_by_branch_name, get_all_proposals, |
| 47 | get_short_git_server_name, get_write_protocols_to_try, join_with_and, | 47 | get_remote_name_by_url, get_short_git_server_name, get_write_protocols_to_try, |
| 48 | push_error_is_not_authentication_failure, read_line, set_protocol_preference, Direction, | 48 | join_with_and, push_error_is_not_authentication_failure, read_line, |
| 49 | set_protocol_preference, | ||
| 49 | }, | 50 | }, |
| 50 | }; | 51 | }; |
| 51 | 52 | ||
| @@ -1023,13 +1024,10 @@ async fn get_merged_status_events( | |||
| 1023 | let (ahead, _) = | 1024 | let (ahead, _) = |
| 1024 | git_repo.get_commits_ahead_behind(&tip_of_remote_branch, &tip_of_pushed_branch)?; | 1025 | git_repo.get_commits_ahead_behind(&tip_of_remote_branch, &tip_of_pushed_branch)?; |
| 1025 | 1026 | ||
| 1026 | let commit_events = get_events_from_local_cache( | 1027 | let commit_events = get_events_from_local_cache(git_repo.get_path()?, vec![ |
| 1027 | git_repo.get_path()?, | 1028 | nostr::Filter::default().kind(nostr::Kind::GitPatch), |
| 1028 | vec![ | 1029 | // TODO: limit by repo_ref |
| 1029 | nostr::Filter::default().kind(nostr::Kind::GitPatch), | 1030 | ]) |
| 1030 | // TODO: limit by repo_ref | ||
| 1031 | ], | ||
| 1032 | ) | ||
| 1033 | .await?; | 1031 | .await?; |
| 1034 | 1032 | ||
| 1035 | let merged_proposals_info = | 1033 | let merged_proposals_info = |
| @@ -1106,12 +1104,9 @@ async fn get_merged_proposals_info( | |||
| 1106 | proposals.entry(proposal_id).or_default(); | 1104 | proposals.entry(proposal_id).or_default(); |
| 1107 | // ignore revisions without all the merged commits | 1105 | // ignore revisions without all the merged commits |
| 1108 | if entry_revision_id == &revision_id { | 1106 | if entry_revision_id == &revision_id { |
| 1109 | merged_patches.insert( | 1107 | merged_patches.insert(*commit_hash, MergedPRCommitType::PatchCommit { |
| 1110 | *commit_hash, | 1108 | event_id: patch_event.id, |
| 1111 | MergedPRCommitType::PatchCommit { | 1109 | }); |
| 1112 | event_id: patch_event.id, | ||
| 1113 | }, | ||
| 1114 | ); | ||
| 1115 | } | 1110 | } |
| 1116 | } | 1111 | } |
| 1117 | } | 1112 | } |
| @@ -1136,12 +1131,9 @@ async fn get_merged_proposals_info( | |||
| 1136 | proposals.entry(proposal_id).or_default(); | 1131 | proposals.entry(proposal_id).or_default(); |
| 1137 | // ignore revisions without all the applied commits | 1132 | // ignore revisions without all the applied commits |
| 1138 | if entry_revision_id == &revision_id { | 1133 | if entry_revision_id == &revision_id { |
| 1139 | merged_patches.insert( | 1134 | merged_patches.insert(*commit_hash, MergedPRCommitType::PatchApplied { |
| 1140 | *commit_hash, | 1135 | event_id: patch_event.id, |
| 1141 | MergedPRCommitType::PatchApplied { | 1136 | }); |
| 1142 | event_id: patch_event.id, | ||
| 1143 | }, | ||
| 1144 | ); | ||
| 1145 | } | 1137 | } |
| 1146 | } | 1138 | } |
| 1147 | } | 1139 | } |
| @@ -1379,10 +1371,9 @@ async fn get_proposal_and_revision_root_from_patch( | |||
| 1379 | .clone(), | 1371 | .clone(), |
| 1380 | )?; | 1372 | )?; |
| 1381 | 1373 | ||
| 1382 | get_events_from_local_cache( | 1374 | get_events_from_local_cache(git_repo.get_path()?, vec![ |
| 1383 | git_repo.get_path()?, | 1375 | nostr::Filter::default().id(proposal_or_revision_id), |
| 1384 | vec![nostr::Filter::default().id(proposal_or_revision_id)], | 1376 | ]) |
| 1385 | ) | ||
| 1386 | .await? | 1377 | .await? |
| 1387 | .first() | 1378 | .first() |
| 1388 | .unwrap() | 1379 | .unwrap() |
| @@ -1538,10 +1529,9 @@ impl BuildRepoState for RepoState { | |||
| 1538 | ) -> Result<RepoState> { | 1529 | ) -> Result<RepoState> { |
| 1539 | let mut tags = vec![Tag::identifier(identifier.clone())]; | 1530 | let mut tags = vec![Tag::identifier(identifier.clone())]; |
| 1540 | for (name, value) in &state { | 1531 | for (name, value) in &state { |
| 1541 | tags.push(Tag::custom( | 1532 | tags.push(Tag::custom(nostr_sdk::TagKind::Custom(name.into()), vec![ |
| 1542 | nostr_sdk::TagKind::Custom(name.into()), | 1533 | value.clone(), |
| 1543 | vec![value.clone()], | 1534 | ])); |
| 1544 | )); | ||
| 1545 | } | 1535 | } |
| 1546 | let event = sign_event(EventBuilder::new(STATE_KIND, "").tags(tags), signer).await?; | 1536 | let event = sign_event(EventBuilder::new(STATE_KIND, "").tags(tags), signer).await?; |
| 1547 | Ok(RepoState { | 1537 | Ok(RepoState { |
diff --git a/src/bin/git_remote_nostr/utils.rs b/src/bin/git_remote_nostr/utils.rs index 8e89652..15ebb10 100644 --- a/src/bin/git_remote_nostr/utils.rs +++ b/src/bin/git_remote_nostr/utils.rs | |||
| @@ -6,7 +6,7 @@ use std::{ | |||
| 6 | str::FromStr, | 6 | str::FromStr, |
| 7 | }; | 7 | }; |
| 8 | 8 | ||
| 9 | use anyhow::{bail, Context, Result}; | 9 | use anyhow::{Context, Result, bail}; |
| 10 | use git2::Repository; | 10 | use git2::Repository; |
| 11 | use ngit::{ | 11 | use ngit::{ |
| 12 | client::{ | 12 | client::{ |
| @@ -14,8 +14,8 @@ use ngit::{ | |||
| 14 | get_proposals_and_revisions_from_cache, | 14 | get_proposals_and_revisions_from_cache, |
| 15 | }, | 15 | }, |
| 16 | git::{ | 16 | git::{ |
| 17 | nostr_url::{CloneUrl, NostrUrlDecoded, ServerProtocol}, | ||
| 18 | Repo, RepoActions, | 17 | Repo, RepoActions, |
| 18 | nostr_url::{CloneUrl, NostrUrlDecoded, ServerProtocol}, | ||
| 19 | }, | 19 | }, |
| 20 | git_events::{ | 20 | git_events::{ |
| 21 | event_is_revision_root, get_most_recent_patch_with_ancestors, | 21 | event_is_revision_root, get_most_recent_patch_with_ancestors, |
| @@ -108,14 +108,11 @@ pub async fn get_open_proposals( | |||
| 108 | .collect(); | 108 | .collect(); |
| 109 | 109 | ||
| 110 | let statuses: Vec<nostr::Event> = { | 110 | let statuses: Vec<nostr::Event> = { |
| 111 | let mut statuses = get_events_from_local_cache( | 111 | let mut statuses = get_events_from_local_cache(git_repo_path, vec![ |
| 112 | git_repo_path, | 112 | nostr::Filter::default() |
| 113 | vec![ | 113 | .kinds(status_kinds().clone()) |
| 114 | nostr::Filter::default() | 114 | .events(proposals.iter().map(|e| e.id)), |
| 115 | .kinds(status_kinds().clone()) | 115 | ]) |
| 116 | .events(proposals.iter().map(|e| e.id)), | ||
| 117 | ], | ||
| 118 | ) | ||
| 119 | .await?; | 116 | .await?; |
| 120 | statuses.sort_by_key(|e| e.created_at); | 117 | statuses.sort_by_key(|e| e.created_at); |
| 121 | statuses.reverse(); | 118 | statuses.reverse(); |
diff --git a/src/bin/ngit/cli.rs b/src/bin/ngit/cli.rs index 1737a9f..60bc5d2 100644 --- a/src/bin/ngit/cli.rs +++ b/src/bin/ngit/cli.rs | |||
| @@ -1,4 +1,4 @@ | |||
| 1 | use anyhow::{bail, Result}; | 1 | use anyhow::{Result, bail}; |
| 2 | use clap::{Parser, Subcommand}; | 2 | use clap::{Parser, Subcommand}; |
| 3 | use ngit::login::SignerInfo; | 3 | use ngit::login::SignerInfo; |
| 4 | 4 | ||
diff --git a/src/bin/ngit/sub_commands/export_keys.rs b/src/bin/ngit/sub_commands/export_keys.rs index 54a716f..45b1b89 100644 --- a/src/bin/ngit/sub_commands/export_keys.rs +++ b/src/bin/ngit/sub_commands/export_keys.rs | |||
| @@ -2,9 +2,9 @@ use anyhow::{Context, Result}; | |||
| 2 | use ngit::{ | 2 | use ngit::{ |
| 3 | cli_interactor::{Interactor, InteractorPrompt, PromptChoiceParms}, | 3 | cli_interactor::{Interactor, InteractorPrompt, PromptChoiceParms}, |
| 4 | login::{ | 4 | login::{ |
| 5 | SignerInfo, SignerInfoSource, | ||
| 5 | existing::{get_signer_info, load_existing_login}, | 6 | existing::{get_signer_info, load_existing_login}, |
| 6 | fresh::generate_qr, | 7 | fresh::generate_qr, |
| 7 | SignerInfo, SignerInfoSource, | ||
| 8 | }, | 8 | }, |
| 9 | }; | 9 | }; |
| 10 | 10 | ||
diff --git a/src/bin/ngit/sub_commands/init.rs b/src/bin/ngit/sub_commands/init.rs index 0894f41..80e182b 100644 --- a/src/bin/ngit/sub_commands/init.rs +++ b/src/bin/ngit/sub_commands/init.rs | |||
| @@ -3,18 +3,18 @@ use std::collections::HashMap; | |||
| 3 | use anyhow::{Context, Result}; | 3 | use anyhow::{Context, Result}; |
| 4 | use console::Style; | 4 | use console::Style; |
| 5 | use ngit::{cli_interactor::PromptConfirmParms, git::nostr_url::NostrUrlDecoded}; | 5 | use ngit::{cli_interactor::PromptConfirmParms, git::nostr_url::NostrUrlDecoded}; |
| 6 | use nostr::{nips::nip01::Coordinate, FromBech32, PublicKey, ToBech32}; | 6 | use nostr::{FromBech32, PublicKey, ToBech32, nips::nip01::Coordinate}; |
| 7 | use nostr_sdk::{Kind, RelayUrl}; | 7 | use nostr_sdk::{Kind, RelayUrl}; |
| 8 | 8 | ||
| 9 | use crate::{ | 9 | use crate::{ |
| 10 | cli::{extract_signer_cli_arguments, Cli}, | 10 | cli::{Cli, extract_signer_cli_arguments}, |
| 11 | cli_interactor::{Interactor, InteractorPrompt, PromptInputParms}, | 11 | cli_interactor::{Interactor, InteractorPrompt, PromptInputParms}, |
| 12 | client::{fetching_with_report, get_repo_ref_from_cache, send_events, Client, Connect}, | 12 | client::{Client, Connect, fetching_with_report, get_repo_ref_from_cache, send_events}, |
| 13 | git::{nostr_url::convert_clone_url_to_https, Repo, RepoActions}, | 13 | git::{Repo, RepoActions, nostr_url::convert_clone_url_to_https}, |
| 14 | login, | 14 | login, |
| 15 | repo_ref::{ | 15 | repo_ref::{ |
| 16 | extract_pks, get_repo_config_from_yaml, save_repo_config_to_yaml, | 16 | RepoRef, extract_pks, get_repo_config_from_yaml, save_repo_config_to_yaml, |
| 17 | try_and_get_repo_coordinates_when_remote_unknown, RepoRef, | 17 | try_and_get_repo_coordinates_when_remote_unknown, |
| 18 | }, | 18 | }, |
| 19 | }; | 19 | }; |
| 20 | 20 | ||
diff --git a/src/bin/ngit/sub_commands/list.rs b/src/bin/ngit/sub_commands/list.rs index ee015ef..9b84c1b 100644 --- a/src/bin/ngit/sub_commands/list.rs +++ b/src/bin/ngit/sub_commands/list.rs | |||
| @@ -1,6 +1,6 @@ | |||
| 1 | use std::{io::Write, ops::Add}; | 1 | use std::{io::Write, ops::Add}; |
| 2 | 2 | ||
| 3 | use anyhow::{bail, Context, Result}; | 3 | use anyhow::{Context, Result, bail}; |
| 4 | use ngit::{ | 4 | use ngit::{ |
| 5 | client::{get_all_proposal_patch_events_from_cache, get_proposals_and_revisions_from_cache}, | 5 | client::{get_all_proposal_patch_events_from_cache, get_proposals_and_revisions_from_cache}, |
| 6 | git_events::{ | 6 | git_events::{ |
| @@ -12,9 +12,9 @@ use nostr_sdk::Kind; | |||
| 12 | use crate::{ | 12 | use crate::{ |
| 13 | cli_interactor::{Interactor, InteractorPrompt, PromptChoiceParms, PromptConfirmParms}, | 13 | cli_interactor::{Interactor, InteractorPrompt, PromptChoiceParms, PromptConfirmParms}, |
| 14 | client::{ | 14 | client::{ |
| 15 | fetching_with_report, get_events_from_local_cache, get_repo_ref_from_cache, Client, Connect, | 15 | Client, Connect, fetching_with_report, get_events_from_local_cache, get_repo_ref_from_cache, |
| 16 | }, | 16 | }, |
| 17 | git::{str_to_sha1, Repo, RepoActions}, | 17 | git::{Repo, RepoActions, str_to_sha1}, |
| 18 | git_events::{ | 18 | git_events::{ |
| 19 | commit_msg_from_patch_oneliner, event_is_revision_root, event_to_cover_letter, | 19 | commit_msg_from_patch_oneliner, event_is_revision_root, event_to_cover_letter, |
| 20 | patch_supports_commit_ids, | 20 | patch_supports_commit_ids, |
| @@ -47,14 +47,11 @@ pub async fn launch() -> Result<()> { | |||
| 47 | } | 47 | } |
| 48 | 48 | ||
| 49 | let statuses: Vec<nostr::Event> = { | 49 | let statuses: Vec<nostr::Event> = { |
| 50 | let mut statuses = get_events_from_local_cache( | 50 | let mut statuses = get_events_from_local_cache(git_repo_path, vec![ |
| 51 | git_repo_path, | 51 | nostr::Filter::default() |
| 52 | vec![ | 52 | .kinds(status_kinds().clone()) |
| 53 | nostr::Filter::default() | 53 | .events(proposals_and_revisions.iter().map(|e| e.id)), |
| 54 | .kinds(status_kinds().clone()) | 54 | ]) |
| 55 | .events(proposals_and_revisions.iter().map(|e| e.id)), | ||
| 56 | ], | ||
| 57 | ) | ||
| 58 | .await?; | 55 | .await?; |
| 59 | statuses.sort_by_key(|e| e.created_at); | 56 | statuses.sort_by_key(|e| e.created_at); |
| 60 | statuses.reverse(); | 57 | statuses.reverse(); |
diff --git a/src/bin/ngit/sub_commands/login.rs b/src/bin/ngit/sub_commands/login.rs index ccbdf01..06236ec 100644 --- a/src/bin/ngit/sub_commands/login.rs +++ b/src/bin/ngit/sub_commands/login.rs | |||
| @@ -3,11 +3,11 @@ use clap; | |||
| 3 | use ngit::{ | 3 | use ngit::{ |
| 4 | cli_interactor::{Interactor, InteractorPrompt, PromptChoiceParms}, | 4 | cli_interactor::{Interactor, InteractorPrompt, PromptChoiceParms}, |
| 5 | git::{get_git_config_item, remove_git_config_item}, | 5 | git::{get_git_config_item, remove_git_config_item}, |
| 6 | login::{existing::load_existing_login, SignerInfoSource}, | 6 | login::{SignerInfoSource, existing::load_existing_login}, |
| 7 | }; | 7 | }; |
| 8 | 8 | ||
| 9 | use crate::{ | 9 | use crate::{ |
| 10 | cli::{extract_signer_cli_arguments, Cli}, | 10 | cli::{Cli, extract_signer_cli_arguments}, |
| 11 | client::{Client, Connect}, | 11 | client::{Client, Connect}, |
| 12 | git::Repo, | 12 | git::Repo, |
| 13 | login::fresh::fresh_login_or_signup, | 13 | login::fresh::fresh_login_or_signup, |
diff --git a/src/bin/ngit/sub_commands/logout.rs b/src/bin/ngit/sub_commands/logout.rs index f3f9620..2df96c8 100644 --- a/src/bin/ngit/sub_commands/logout.rs +++ b/src/bin/ngit/sub_commands/logout.rs | |||
| @@ -1,7 +1,7 @@ | |||
| 1 | use anyhow::{Context, Result}; | 1 | use anyhow::{Context, Result}; |
| 2 | use ngit::{ | 2 | use ngit::{ |
| 3 | git::remove_git_config_item, | 3 | git::remove_git_config_item, |
| 4 | login::{existing::load_existing_login, SignerInfoSource}, | 4 | login::{SignerInfoSource, existing::load_existing_login}, |
| 5 | }; | 5 | }; |
| 6 | 6 | ||
| 7 | use crate::{ | 7 | use crate::{ |
diff --git a/src/bin/ngit/sub_commands/send.rs b/src/bin/ngit/sub_commands/send.rs index c6c75c9..7c898bc 100644 --- a/src/bin/ngit/sub_commands/send.rs +++ b/src/bin/ngit/sub_commands/send.rs | |||
| @@ -1,23 +1,23 @@ | |||
| 1 | use std::path::Path; | 1 | use std::path::Path; |
| 2 | 2 | ||
| 3 | use anyhow::{bail, Context, Result}; | 3 | use anyhow::{Context, Result, bail}; |
| 4 | use console::Style; | 4 | use console::Style; |
| 5 | use ngit::{client::send_events, git_events::generate_cover_letter_and_patch_events}; | 5 | use ngit::{client::send_events, git_events::generate_cover_letter_and_patch_events}; |
| 6 | use nostr::{ | 6 | use nostr::{ |
| 7 | nips::{nip10::Marker, nip19::Nip19Event}, | ||
| 8 | ToBech32, | 7 | ToBech32, |
| 8 | nips::{nip10::Marker, nip19::Nip19Event}, | ||
| 9 | }; | 9 | }; |
| 10 | use nostr_sdk::hashes::sha1::Hash as Sha1Hash; | 10 | use nostr_sdk::hashes::sha1::Hash as Sha1Hash; |
| 11 | 11 | ||
| 12 | use crate::{ | 12 | use crate::{ |
| 13 | cli::{extract_signer_cli_arguments, Cli}, | 13 | cli::{Cli, extract_signer_cli_arguments}, |
| 14 | cli_interactor::{ | 14 | cli_interactor::{ |
| 15 | Interactor, InteractorPrompt, PromptConfirmParms, PromptInputParms, PromptMultiChoiceParms, | 15 | Interactor, InteractorPrompt, PromptConfirmParms, PromptInputParms, PromptMultiChoiceParms, |
| 16 | }, | 16 | }, |
| 17 | client::{ | 17 | client::{ |
| 18 | fetching_with_report, get_events_from_local_cache, get_repo_ref_from_cache, Client, Connect, | 18 | Client, Connect, fetching_with_report, get_events_from_local_cache, get_repo_ref_from_cache, |
| 19 | }, | 19 | }, |
| 20 | git::{identify_ahead_behind, Repo, RepoActions}, | 20 | git::{Repo, RepoActions, identify_ahead_behind}, |
| 21 | git_events::{event_is_patch_set_root, event_tag_from_nip19_or_hex}, | 21 | git_events::{event_is_patch_set_root, event_tag_from_nip19_or_hex}, |
| 22 | login, | 22 | login, |
| 23 | repo_ref::get_repo_coordinates_when_remote_unknown, | 23 | repo_ref::get_repo_coordinates_when_remote_unknown, |
| @@ -369,10 +369,9 @@ async fn get_root_proposal_id_and_mentions_from_in_reply_to( | |||
| 369 | public_key: _, | 369 | public_key: _, |
| 370 | uppercase: false, | 370 | uppercase: false, |
| 371 | }) => { | 371 | }) => { |
| 372 | let events = get_events_from_local_cache( | 372 | let events = get_events_from_local_cache(git_repo_path, vec![ |
| 373 | git_repo_path, | 373 | nostr::Filter::new().id(*event_id), |
| 374 | vec![nostr::Filter::new().id(*event_id)], | 374 | ]) |
| 375 | ) | ||
| 376 | .await?; | 375 | .await?; |
| 377 | 376 | ||
| 378 | if let Some(first) = events.iter().find(|e| e.id.eq(event_id)) { | 377 | if let Some(first) = events.iter().find(|e| e.id.eq(event_id)) { |
diff --git a/src/lib/cli_interactor.rs b/src/lib/cli_interactor.rs index 50a0f0c..1b74101 100644 --- a/src/lib/cli_interactor.rs +++ b/src/lib/cli_interactor.rs | |||
| @@ -1,5 +1,5 @@ | |||
| 1 | use anyhow::{Context, Result}; | 1 | use anyhow::{Context, Result}; |
| 2 | use dialoguer::{theme::ColorfulTheme, Confirm, Input, Password}; | 2 | use dialoguer::{Confirm, Input, Password, theme::ColorfulTheme}; |
| 3 | use indicatif::TermLike; | 3 | use indicatif::TermLike; |
| 4 | #[cfg(test)] | 4 | #[cfg(test)] |
| 5 | use mockall::*; | 5 | use mockall::*; |
diff --git a/src/lib/client.rs b/src/lib/client.rs index 32f5bd7..59ec583 100644 --- a/src/lib/client.rs +++ b/src/lib/client.rs | |||
| @@ -19,7 +19,7 @@ use std::{ | |||
| 19 | time::Duration, | 19 | time::Duration, |
| 20 | }; | 20 | }; |
| 21 | 21 | ||
| 22 | use anyhow::{bail, Context, Result}; | 22 | use anyhow::{Context, Result, bail}; |
| 23 | use async_trait::async_trait; | 23 | use async_trait::async_trait; |
| 24 | use console::Style; | 24 | use console::Style; |
| 25 | use futures::{ | 25 | use futures::{ |
| @@ -29,12 +29,12 @@ use futures::{ | |||
| 29 | use indicatif::{MultiProgress, ProgressBar, ProgressDrawTarget, ProgressState, ProgressStyle}; | 29 | use indicatif::{MultiProgress, ProgressBar, ProgressDrawTarget, ProgressState, ProgressStyle}; |
| 30 | #[cfg(test)] | 30 | #[cfg(test)] |
| 31 | use mockall::*; | 31 | use mockall::*; |
| 32 | use nostr::{nips::nip01::Coordinate, signer::SignerBackend, Event}; | 32 | use nostr::{Event, nips::nip01::Coordinate, signer::SignerBackend}; |
| 33 | use nostr_database::NostrEventsDatabase; | 33 | use nostr_database::NostrEventsDatabase; |
| 34 | use nostr_lmdb::NostrLMDB; | 34 | use nostr_lmdb::NostrLMDB; |
| 35 | use nostr_sdk::{ | 35 | use nostr_sdk::{ |
| 36 | prelude::RelayLimits, EventBuilder, EventId, Kind, NostrSigner, Options, PublicKey, RelayUrl, | 36 | EventBuilder, EventId, Kind, NostrSigner, Options, PublicKey, RelayUrl, SingleLetterTag, |
| 37 | SingleLetterTag, Timestamp, | 37 | Timestamp, prelude::RelayLimits, |
| 38 | }; | 38 | }; |
| 39 | 39 | ||
| 40 | use crate::{ | 40 | use crate::{ |
| @@ -894,18 +894,16 @@ pub async fn get_state_from_cache( | |||
| 894 | ) -> Result<RepoState> { | 894 | ) -> Result<RepoState> { |
| 895 | if let Some(git_repo_path) = git_repo_path { | 895 | if let Some(git_repo_path) = git_repo_path { |
| 896 | RepoState::try_from( | 896 | RepoState::try_from( |
| 897 | get_events_from_local_cache( | 897 | get_events_from_local_cache(git_repo_path, vec![get_filter_state_events( |
| 898 | git_repo_path, | 898 | &repo_ref.coordinates(), |
| 899 | vec![get_filter_state_events(&repo_ref.coordinates())], | 899 | )]) |
| 900 | ) | ||
| 901 | .await?, | 900 | .await?, |
| 902 | ) | 901 | ) |
| 903 | } else { | 902 | } else { |
| 904 | RepoState::try_from( | 903 | RepoState::try_from( |
| 905 | get_event_from_global_cache( | 904 | get_event_from_global_cache(git_repo_path, vec![get_filter_state_events( |
| 906 | git_repo_path, | 905 | &repo_ref.coordinates(), |
| 907 | vec![get_filter_state_events(&repo_ref.coordinates())], | 906 | )]) |
| 908 | ) | ||
| 909 | .await?, | 907 | .await?, |
| 910 | ) | 908 | ) |
| 911 | } | 909 | } |
| @@ -975,20 +973,17 @@ async fn create_relays_request( | |||
| 975 | } | 973 | } |
| 976 | 974 | ||
| 977 | if let Some(git_repo_path) = git_repo_path { | 975 | if let Some(git_repo_path) = git_repo_path { |
| 978 | for event in &get_events_from_local_cache( | 976 | for event in &get_events_from_local_cache(git_repo_path, vec![ |
| 979 | git_repo_path, | 977 | nostr::Filter::default() |
| 980 | vec![ | 978 | .kinds(vec![Kind::GitPatch]) |
| 981 | nostr::Filter::default() | 979 | .custom_tag( |
| 982 | .kinds(vec![Kind::GitPatch]) | 980 | SingleLetterTag::lowercase(nostr_sdk::Alphabet::A), |
| 983 | .custom_tag( | 981 | repo_coordinates_without_relays |
| 984 | SingleLetterTag::lowercase(nostr_sdk::Alphabet::A), | 982 | .iter() |
| 985 | repo_coordinates_without_relays | 983 | .map(std::string::ToString::to_string) |
| 986 | .iter() | 984 | .collect::<Vec<String>>(), |
| 987 | .map(std::string::ToString::to_string) | 985 | ), |
| 988 | .collect::<Vec<String>>(), | 986 | ]) |
| 989 | ), | ||
| 990 | ], | ||
| 991 | ) | ||
| 992 | .await? | 987 | .await? |
| 993 | { | 988 | { |
| 994 | if event_is_patch_set_root(event) || event_is_revision_root(event) { | 989 | if event_is_patch_set_root(event) || event_is_revision_root(event) { |
| @@ -998,11 +993,11 @@ async fn create_relays_request( | |||
| 998 | } | 993 | } |
| 999 | } | 994 | } |
| 1000 | 995 | ||
| 1001 | let profile_events = get_event_from_global_cache( | 996 | let profile_events = |
| 1002 | git_repo_path, | 997 | get_event_from_global_cache(git_repo_path, vec![get_filter_contributor_profiles( |
| 1003 | vec![get_filter_contributor_profiles(contributors.clone())], | 998 | contributors.clone(), |
| 1004 | ) | 999 | )]) |
| 1005 | .await?; | 1000 | .await?; |
| 1006 | for c in &contributors { | 1001 | for c in &contributors { |
| 1007 | if let Some(event) = profile_events | 1002 | if let Some(event) = profile_events |
| 1008 | .iter() | 1003 | .iter() |
| @@ -1564,20 +1559,17 @@ pub async fn get_proposals_and_revisions_from_cache( | |||
| 1564 | git_repo_path: &Path, | 1559 | git_repo_path: &Path, |
| 1565 | repo_coordinates: HashSet<Coordinate>, | 1560 | repo_coordinates: HashSet<Coordinate>, |
| 1566 | ) -> Result<Vec<nostr::Event>> { | 1561 | ) -> Result<Vec<nostr::Event>> { |
| 1567 | let mut proposals = get_events_from_local_cache( | 1562 | let mut proposals = get_events_from_local_cache(git_repo_path, vec![ |
| 1568 | git_repo_path, | 1563 | nostr::Filter::default() |
| 1569 | vec![ | 1564 | .kind(nostr::Kind::GitPatch) |
| 1570 | nostr::Filter::default() | 1565 | .custom_tag( |
| 1571 | .kind(nostr::Kind::GitPatch) | 1566 | nostr::SingleLetterTag::lowercase(nostr_sdk::Alphabet::A), |
| 1572 | .custom_tag( | 1567 | repo_coordinates |
| 1573 | nostr::SingleLetterTag::lowercase(nostr_sdk::Alphabet::A), | 1568 | .iter() |
| 1574 | repo_coordinates | 1569 | .map(std::string::ToString::to_string) |
| 1575 | .iter() | 1570 | .collect::<Vec<String>>(), |
| 1576 | .map(std::string::ToString::to_string) | 1571 | ), |
| 1577 | .collect::<Vec<String>>(), | 1572 | ]) |
| 1578 | ), | ||
| 1579 | ], | ||
| 1580 | ) | ||
| 1581 | .await? | 1573 | .await? |
| 1582 | .iter() | 1574 | .iter() |
| 1583 | .filter(|e| event_is_patch_set_root(e)) | 1575 | .filter(|e| event_is_patch_set_root(e)) |
| @@ -1593,29 +1585,23 @@ pub async fn get_all_proposal_patch_events_from_cache( | |||
| 1593 | repo_ref: &RepoRef, | 1585 | repo_ref: &RepoRef, |
| 1594 | proposal_id: &nostr::EventId, | 1586 | proposal_id: &nostr::EventId, |
| 1595 | ) -> Result<Vec<nostr::Event>> { | 1587 | ) -> Result<Vec<nostr::Event>> { |
| 1596 | let mut commit_events = get_events_from_local_cache( | 1588 | let mut commit_events = get_events_from_local_cache(git_repo_path, vec![ |
| 1597 | git_repo_path, | 1589 | nostr::Filter::default() |
| 1598 | vec![ | 1590 | .kind(nostr::Kind::GitPatch) |
| 1599 | nostr::Filter::default() | 1591 | .event(*proposal_id), |
| 1600 | .kind(nostr::Kind::GitPatch) | 1592 | nostr::Filter::default() |
| 1601 | .event(*proposal_id), | 1593 | .kind(nostr::Kind::GitPatch) |
| 1602 | nostr::Filter::default() | 1594 | .id(*proposal_id), |
| 1603 | .kind(nostr::Kind::GitPatch) | 1595 | ]) |
| 1604 | .id(*proposal_id), | ||
| 1605 | ], | ||
| 1606 | ) | ||
| 1607 | .await?; | 1596 | .await?; |
| 1608 | 1597 | ||
| 1609 | let permissioned_users: HashSet<PublicKey> = [ | 1598 | let permissioned_users: HashSet<PublicKey> = [repo_ref.maintainers.clone(), vec![ |
| 1610 | repo_ref.maintainers.clone(), | 1599 | commit_events |
| 1611 | vec![ | 1600 | .iter() |
| 1612 | commit_events | 1601 | .find(|e| e.id.eq(proposal_id)) |
| 1613 | .iter() | 1602 | .context("proposal not in cache")? |
| 1614 | .find(|e| e.id.eq(proposal_id)) | 1603 | .pubkey, |
| 1615 | .context("proposal not in cache")? | 1604 | ]] |
| 1616 | .pubkey, | ||
| 1617 | ], | ||
| 1618 | ] | ||
| 1619 | .concat() | 1605 | .concat() |
| 1620 | .iter() | 1606 | .iter() |
| 1621 | .copied() | 1607 | .copied() |
| @@ -1629,15 +1615,12 @@ pub async fn get_all_proposal_patch_events_from_cache( | |||
| 1629 | .collect(); | 1615 | .collect(); |
| 1630 | 1616 | ||
| 1631 | if !revision_roots.is_empty() { | 1617 | if !revision_roots.is_empty() { |
| 1632 | for event in get_events_from_local_cache( | 1618 | for event in get_events_from_local_cache(git_repo_path, vec![ |
| 1633 | git_repo_path, | 1619 | nostr::Filter::default() |
| 1634 | vec![ | 1620 | .kind(nostr::Kind::GitPatch) |
| 1635 | nostr::Filter::default() | 1621 | .events(revision_roots) |
| 1636 | .kind(nostr::Kind::GitPatch) | 1622 | .authors(permissioned_users.clone()), |
| 1637 | .events(revision_roots) | 1623 | ]) |
| 1638 | .authors(permissioned_users.clone()), | ||
| 1639 | ], | ||
| 1640 | ) | ||
| 1641 | .await? | 1624 | .await? |
| 1642 | { | 1625 | { |
| 1643 | commit_events.push(event); | 1626 | commit_events.push(event); |
| @@ -1652,10 +1635,9 @@ pub async fn get_all_proposal_patch_events_from_cache( | |||
| 1652 | } | 1635 | } |
| 1653 | 1636 | ||
| 1654 | pub async fn get_event_from_cache_by_id(git_repo: &Repo, event_id: &EventId) -> Result<Event> { | 1637 | pub async fn get_event_from_cache_by_id(git_repo: &Repo, event_id: &EventId) -> Result<Event> { |
| 1655 | Ok(get_events_from_local_cache( | 1638 | Ok(get_events_from_local_cache(git_repo.get_path()?, vec![ |
| 1656 | git_repo.get_path()?, | 1639 | nostr::Filter::default().id(*event_id), |
| 1657 | vec![nostr::Filter::default().id(*event_id)], | 1640 | ]) |
| 1658 | ) | ||
| 1659 | .await? | 1641 | .await? |
| 1660 | .first() | 1642 | .first() |
| 1661 | .context("failed to find event in cache")? | 1643 | .context("failed to find event in cache")? |
diff --git a/src/lib/git/identify_ahead_behind.rs b/src/lib/git/identify_ahead_behind.rs index d736522..baea687 100644 --- a/src/lib/git/identify_ahead_behind.rs +++ b/src/lib/git/identify_ahead_behind.rs | |||
| @@ -184,10 +184,10 @@ mod tests { | |||
| 184 | identify_ahead_behind(&git_repo, &Some("feature".to_string()), &None)?; | 184 | identify_ahead_behind(&git_repo, &Some("feature".to_string()), &None)?; |
| 185 | 185 | ||
| 186 | assert_eq!(from_branch, "feature"); | 186 | assert_eq!(from_branch, "feature"); |
| 187 | assert_eq!( | 187 | assert_eq!(ahead, vec![ |
| 188 | ahead, | 188 | oid_to_sha1(&feature_oid), |
| 189 | vec![oid_to_sha1(&feature_oid), oid_to_sha1(&dev_oid_first)] | 189 | oid_to_sha1(&dev_oid_first) |
| 190 | ); | 190 | ]); |
| 191 | assert_eq!(to_branch, "main"); | 191 | assert_eq!(to_branch, "main"); |
| 192 | assert_eq!(behind, vec![]); | 192 | assert_eq!(behind, vec![]); |
| 193 | 193 | ||
diff --git a/src/lib/git/mod.rs b/src/lib/git/mod.rs index 7a7ad5d..2b78f38 100644 --- a/src/lib/git/mod.rs +++ b/src/lib/git/mod.rs | |||
| @@ -3,12 +3,12 @@ use std::{ | |||
| 3 | path::{Path, PathBuf}, | 3 | path::{Path, PathBuf}, |
| 4 | }; | 4 | }; |
| 5 | 5 | ||
| 6 | use anyhow::{bail, Context, Result}; | 6 | use anyhow::{Context, Result, bail}; |
| 7 | use git2::{DiffOptions, Oid, Revwalk}; | 7 | use git2::{DiffOptions, Oid, Revwalk}; |
| 8 | pub use identify_ahead_behind::identify_ahead_behind; | 8 | pub use identify_ahead_behind::identify_ahead_behind; |
| 9 | use nostr_sdk::{ | 9 | use nostr_sdk::{ |
| 10 | hashes::{sha1::Hash as Sha1Hash, Hash}, | ||
| 11 | Tags, | 10 | Tags, |
| 11 | hashes::{Hash, sha1::Hash as Sha1Hash}, | ||
| 12 | }; | 12 | }; |
| 13 | 13 | ||
| 14 | use crate::git_events::{get_commit_id_from_patch, tag_value}; | 14 | use crate::git_events::{get_commit_id_from_patch, tag_value}; |
| @@ -1493,10 +1493,10 @@ mod tests { | |||
| 1493 | &oid_to_sha1(&feature_oid), | 1493 | &oid_to_sha1(&feature_oid), |
| 1494 | )?; | 1494 | )?; |
| 1495 | assert_eq!(ahead, vec![]); | 1495 | assert_eq!(ahead, vec![]); |
| 1496 | assert_eq!( | 1496 | assert_eq!(behind, vec![ |
| 1497 | behind, | 1497 | oid_to_sha1(&behind_2_oid), |
| 1498 | vec![oid_to_sha1(&behind_2_oid), oid_to_sha1(&behind_1_oid),], | 1498 | oid_to_sha1(&behind_1_oid), |
| 1499 | ); | 1499 | ],); |
| 1500 | Ok(()) | 1500 | Ok(()) |
| 1501 | } | 1501 | } |
| 1502 | 1502 | ||
| @@ -1518,10 +1518,10 @@ mod tests { | |||
| 1518 | &oid_to_sha1(&main_oid), | 1518 | &oid_to_sha1(&main_oid), |
| 1519 | &oid_to_sha1(&ahead_2_oid), | 1519 | &oid_to_sha1(&ahead_2_oid), |
| 1520 | )?; | 1520 | )?; |
| 1521 | assert_eq!( | 1521 | assert_eq!(ahead, vec![ |
| 1522 | ahead, | 1522 | oid_to_sha1(&ahead_2_oid), |
| 1523 | vec![oid_to_sha1(&ahead_2_oid), oid_to_sha1(&ahead_1_oid),], | 1523 | oid_to_sha1(&ahead_1_oid), |
| 1524 | ); | 1524 | ],); |
| 1525 | assert_eq!(behind, vec![]); | 1525 | assert_eq!(behind, vec![]); |
| 1526 | Ok(()) | 1526 | Ok(()) |
| 1527 | } | 1527 | } |
| @@ -1550,14 +1550,14 @@ mod tests { | |||
| 1550 | &oid_to_sha1(&behind_2_oid), | 1550 | &oid_to_sha1(&behind_2_oid), |
| 1551 | &oid_to_sha1(&ahead_2_oid), | 1551 | &oid_to_sha1(&ahead_2_oid), |
| 1552 | )?; | 1552 | )?; |
| 1553 | assert_eq!( | 1553 | assert_eq!(ahead, vec![ |
| 1554 | ahead, | 1554 | oid_to_sha1(&ahead_2_oid), |
| 1555 | vec![oid_to_sha1(&ahead_2_oid), oid_to_sha1(&ahead_1_oid)], | 1555 | oid_to_sha1(&ahead_1_oid) |
| 1556 | ); | 1556 | ],); |
| 1557 | assert_eq!( | 1557 | assert_eq!(behind, vec![ |
| 1558 | behind, | 1558 | oid_to_sha1(&behind_2_oid), |
| 1559 | vec![oid_to_sha1(&behind_2_oid), oid_to_sha1(&behind_1_oid)], | 1559 | oid_to_sha1(&behind_1_oid) |
| 1560 | ); | 1560 | ],); |
| 1561 | Ok(()) | 1561 | Ok(()) |
| 1562 | } | 1562 | } |
| 1563 | } | 1563 | } |
| @@ -2212,10 +2212,9 @@ mod tests { | |||
| 2212 | test_repo.populate_with_test_branch()?; | 2212 | test_repo.populate_with_test_branch()?; |
| 2213 | test_repo.checkout("main")?; | 2213 | test_repo.checkout("main")?; |
| 2214 | 2214 | ||
| 2215 | assert_eq!( | 2215 | assert_eq!(git_repo.parse_starting_commits("HEAD~1")?, vec![ |
| 2216 | git_repo.parse_starting_commits("HEAD~1")?, | 2216 | str_to_sha1("431b84edc0d2fa118d63faa3c2db9c73d630a5ae")? |
| 2217 | vec![str_to_sha1("431b84edc0d2fa118d63faa3c2db9c73d630a5ae")?], | 2217 | ],); |
| 2218 | ); | ||
| 2219 | Ok(()) | 2218 | Ok(()) |
| 2220 | } | 2219 | } |
| 2221 | 2220 | ||
| @@ -2225,10 +2224,9 @@ mod tests { | |||
| 2225 | let git_repo = Repo::from_path(&test_repo.dir)?; | 2224 | let git_repo = Repo::from_path(&test_repo.dir)?; |
| 2226 | test_repo.populate_with_test_branch()?; | 2225 | test_repo.populate_with_test_branch()?; |
| 2227 | 2226 | ||
| 2228 | assert_eq!( | 2227 | assert_eq!(git_repo.parse_starting_commits("HEAD~1")?, vec![ |
| 2229 | git_repo.parse_starting_commits("HEAD~1")?, | 2228 | str_to_sha1("82ff2bcc9aa94d1bd8faee723d4c8cc190d6061c")? |
| 2230 | vec![str_to_sha1("82ff2bcc9aa94d1bd8faee723d4c8cc190d6061c")?], | 2229 | ],); |
| 2231 | ); | ||
| 2232 | Ok(()) | 2230 | Ok(()) |
| 2233 | } | 2231 | } |
| 2234 | } | 2232 | } |
| @@ -2242,13 +2240,10 @@ mod tests { | |||
| 2242 | test_repo.populate_with_test_branch()?; | 2240 | test_repo.populate_with_test_branch()?; |
| 2243 | test_repo.checkout("main")?; | 2241 | test_repo.checkout("main")?; |
| 2244 | 2242 | ||
| 2245 | assert_eq!( | 2243 | assert_eq!(git_repo.parse_starting_commits("HEAD~2")?, vec![ |
| 2246 | git_repo.parse_starting_commits("HEAD~2")?, | 2244 | str_to_sha1("431b84edc0d2fa118d63faa3c2db9c73d630a5ae")?, |
| 2247 | vec![ | 2245 | str_to_sha1("af474d8d271490e5c635aad337abdc050034b16a")?, |
| 2248 | str_to_sha1("431b84edc0d2fa118d63faa3c2db9c73d630a5ae")?, | 2246 | ],); |
| 2249 | str_to_sha1("af474d8d271490e5c635aad337abdc050034b16a")?, | ||
| 2250 | ], | ||
| 2251 | ); | ||
| 2252 | Ok(()) | 2247 | Ok(()) |
| 2253 | } | 2248 | } |
| 2254 | } | 2249 | } |
| @@ -2261,14 +2256,11 @@ mod tests { | |||
| 2261 | let git_repo = Repo::from_path(&test_repo.dir)?; | 2256 | let git_repo = Repo::from_path(&test_repo.dir)?; |
| 2262 | test_repo.populate_with_test_branch()?; | 2257 | test_repo.populate_with_test_branch()?; |
| 2263 | 2258 | ||
| 2264 | assert_eq!( | 2259 | assert_eq!(git_repo.parse_starting_commits("HEAD~3")?, vec![ |
| 2265 | git_repo.parse_starting_commits("HEAD~3")?, | 2260 | str_to_sha1("82ff2bcc9aa94d1bd8faee723d4c8cc190d6061c")?, |
| 2266 | vec![ | 2261 | str_to_sha1("a23e6b05aaeb7d1471b4a838b51f337d5644eeb0")?, |
| 2267 | str_to_sha1("82ff2bcc9aa94d1bd8faee723d4c8cc190d6061c")?, | 2262 | str_to_sha1("7ab82116068982671a8111f27dc10599172334b2")?, |
| 2268 | str_to_sha1("a23e6b05aaeb7d1471b4a838b51f337d5644eeb0")?, | 2263 | ],); |
| 2269 | str_to_sha1("7ab82116068982671a8111f27dc10599172334b2")?, | ||
| 2270 | ], | ||
| 2271 | ); | ||
| 2272 | Ok(()) | 2264 | Ok(()) |
| 2273 | } | 2265 | } |
| 2274 | } | 2266 | } |
| @@ -2282,14 +2274,11 @@ mod tests { | |||
| 2282 | test_repo.populate_with_test_branch()?; | 2274 | test_repo.populate_with_test_branch()?; |
| 2283 | test_repo.checkout("main")?; | 2275 | test_repo.checkout("main")?; |
| 2284 | 2276 | ||
| 2285 | assert_eq!( | 2277 | assert_eq!(git_repo.parse_starting_commits("af474d8..a23e6b0")?, vec![ |
| 2286 | git_repo.parse_starting_commits("af474d8..a23e6b0")?, | 2278 | str_to_sha1("a23e6b05aaeb7d1471b4a838b51f337d5644eeb0")?, |
| 2287 | vec![ | 2279 | str_to_sha1("7ab82116068982671a8111f27dc10599172334b2")?, |
| 2288 | str_to_sha1("a23e6b05aaeb7d1471b4a838b51f337d5644eeb0")?, | 2280 | str_to_sha1("431b84edc0d2fa118d63faa3c2db9c73d630a5ae")?, |
| 2289 | str_to_sha1("7ab82116068982671a8111f27dc10599172334b2")?, | 2281 | ],); |
| 2290 | str_to_sha1("431b84edc0d2fa118d63faa3c2db9c73d630a5ae")?, | ||
| 2291 | ], | ||
| 2292 | ); | ||
| 2293 | Ok(()) | 2282 | Ok(()) |
| 2294 | } | 2283 | } |
| 2295 | } | 2284 | } |
diff --git a/src/lib/git/nostr_url.rs b/src/lib/git/nostr_url.rs index 4fbc786..6b38a93 100644 --- a/src/lib/git/nostr_url.rs +++ b/src/lib/git/nostr_url.rs | |||
| @@ -1,11 +1,11 @@ | |||
| 1 | use core::fmt; | 1 | use core::fmt; |
| 2 | use std::{collections::HashMap, str::FromStr}; | 2 | use std::{collections::HashMap, str::FromStr}; |
| 3 | 3 | ||
| 4 | use anyhow::{anyhow, bail, Context, Error, Result}; | 4 | use anyhow::{Context, Error, Result, anyhow, bail}; |
| 5 | use nostr::nips::{nip01::Coordinate, nip05}; | 5 | use nostr::nips::{nip01::Coordinate, nip05}; |
| 6 | use nostr_sdk::{PublicKey, RelayUrl, ToBech32, Url}; | 6 | use nostr_sdk::{PublicKey, RelayUrl, ToBech32, Url}; |
| 7 | 7 | ||
| 8 | use super::{get_git_config_item, save_git_config_item, Repo}; | 8 | use super::{Repo, get_git_config_item, save_git_config_item}; |
| 9 | 9 | ||
| 10 | #[derive(Debug, PartialEq, Default, Clone)] | 10 | #[derive(Debug, PartialEq, Default, Clone)] |
| 11 | pub enum ServerProtocol { | 11 | pub enum ServerProtocol { |
| @@ -961,24 +961,21 @@ mod tests { | |||
| 961 | #[test] | 961 | #[test] |
| 962 | fn standard() -> Result<()> { | 962 | fn standard() -> Result<()> { |
| 963 | assert_eq!( | 963 | assert_eq!( |
| 964 | format!( | 964 | format!("{}", NostrUrlDecoded { |
| 965 | "{}", | 965 | original_string: String::new(), |
| 966 | NostrUrlDecoded { | 966 | coordinate: Coordinate { |
| 967 | original_string: String::new(), | 967 | identifier: "ngit".to_string(), |
| 968 | coordinate: Coordinate { | 968 | public_key: PublicKey::parse( |
| 969 | identifier: "ngit".to_string(), | 969 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", |
| 970 | public_key: PublicKey::parse( | 970 | ) |
| 971 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", | 971 | .unwrap(), |
| 972 | ) | 972 | kind: nostr_sdk::Kind::GitRepoAnnouncement, |
| 973 | .unwrap(), | 973 | relays: vec![RelayUrl::parse("wss://nos.lol").unwrap()], |
| 974 | kind: nostr_sdk::Kind::GitRepoAnnouncement, | 974 | }, |
| 975 | relays: vec![RelayUrl::parse("wss://nos.lol").unwrap()], | 975 | protocol: None, |
| 976 | }, | 976 | user: None, |
| 977 | protocol: None, | 977 | nip05: None, |
| 978 | user: None, | 978 | }), |
| 979 | nip05: None, | ||
| 980 | } | ||
| 981 | ), | ||
| 982 | "nostr://npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/nos.lol/ngit", | 979 | "nostr://npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/nos.lol/ngit", |
| 983 | ); | 980 | ); |
| 984 | Ok(()) | 981 | Ok(()) |
| @@ -987,24 +984,21 @@ mod tests { | |||
| 987 | #[test] | 984 | #[test] |
| 988 | fn no_relay() -> Result<()> { | 985 | fn no_relay() -> Result<()> { |
| 989 | assert_eq!( | 986 | assert_eq!( |
| 990 | format!( | 987 | format!("{}", NostrUrlDecoded { |
| 991 | "{}", | 988 | original_string: String::new(), |
| 992 | NostrUrlDecoded { | 989 | coordinate: Coordinate { |
| 993 | original_string: String::new(), | 990 | identifier: "ngit".to_string(), |
| 994 | coordinate: Coordinate { | 991 | public_key: PublicKey::parse( |
| 995 | identifier: "ngit".to_string(), | 992 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", |
| 996 | public_key: PublicKey::parse( | 993 | ) |
| 997 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", | 994 | .unwrap(), |
| 998 | ) | 995 | kind: nostr_sdk::Kind::GitRepoAnnouncement, |
| 999 | .unwrap(), | 996 | relays: vec![], |
| 1000 | kind: nostr_sdk::Kind::GitRepoAnnouncement, | 997 | }, |
| 1001 | relays: vec![], | 998 | protocol: None, |
| 1002 | }, | 999 | user: None, |
| 1003 | protocol: None, | 1000 | nip05: None, |
| 1004 | user: None, | 1001 | }), |
| 1005 | nip05: None, | ||
| 1006 | } | ||
| 1007 | ), | ||
| 1008 | "nostr://npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/ngit", | 1002 | "nostr://npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/ngit", |
| 1009 | ); | 1003 | ); |
| 1010 | Ok(()) | 1004 | Ok(()) |
| @@ -1013,24 +1007,21 @@ mod tests { | |||
| 1013 | #[test] | 1007 | #[test] |
| 1014 | fn with_protocol() -> Result<()> { | 1008 | fn with_protocol() -> Result<()> { |
| 1015 | assert_eq!( | 1009 | assert_eq!( |
| 1016 | format!( | 1010 | format!("{}", NostrUrlDecoded { |
| 1017 | "{}", | 1011 | original_string: String::new(), |
| 1018 | NostrUrlDecoded { | 1012 | coordinate: Coordinate { |
| 1019 | original_string: String::new(), | 1013 | identifier: "ngit".to_string(), |
| 1020 | coordinate: Coordinate { | 1014 | public_key: PublicKey::parse( |
| 1021 | identifier: "ngit".to_string(), | 1015 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", |
| 1022 | public_key: PublicKey::parse( | 1016 | ) |
| 1023 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", | 1017 | .unwrap(), |
| 1024 | ) | 1018 | kind: nostr_sdk::Kind::GitRepoAnnouncement, |
| 1025 | .unwrap(), | 1019 | relays: vec![RelayUrl::parse("wss://nos.lol").unwrap()], |
| 1026 | kind: nostr_sdk::Kind::GitRepoAnnouncement, | 1020 | }, |
| 1027 | relays: vec![RelayUrl::parse("wss://nos.lol").unwrap()], | 1021 | protocol: Some(ServerProtocol::Ssh), |
| 1028 | }, | 1022 | user: None, |
| 1029 | protocol: Some(ServerProtocol::Ssh), | 1023 | nip05: None, |
| 1030 | user: None, | 1024 | }), |
| 1031 | nip05: None, | ||
| 1032 | } | ||
| 1033 | ), | ||
| 1034 | "nostr://ssh/npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/nos.lol/ngit", | 1025 | "nostr://ssh/npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/nos.lol/ngit", |
| 1035 | ); | 1026 | ); |
| 1036 | Ok(()) | 1027 | Ok(()) |
| @@ -1039,24 +1030,21 @@ mod tests { | |||
| 1039 | #[test] | 1030 | #[test] |
| 1040 | fn with_protocol_and_user() -> Result<()> { | 1031 | fn with_protocol_and_user() -> Result<()> { |
| 1041 | assert_eq!( | 1032 | assert_eq!( |
| 1042 | format!( | 1033 | format!("{}", NostrUrlDecoded { |
| 1043 | "{}", | 1034 | original_string: String::new(), |
| 1044 | NostrUrlDecoded { | 1035 | coordinate: Coordinate { |
| 1045 | original_string: String::new(), | 1036 | identifier: "ngit".to_string(), |
| 1046 | coordinate: Coordinate { | 1037 | public_key: PublicKey::parse( |
| 1047 | identifier: "ngit".to_string(), | 1038 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", |
| 1048 | public_key: PublicKey::parse( | 1039 | ) |
| 1049 | "npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr", | 1040 | .unwrap(), |
| 1050 | ) | 1041 | kind: nostr_sdk::Kind::GitRepoAnnouncement, |
| 1051 | .unwrap(), | 1042 | relays: vec![RelayUrl::parse("wss://nos.lol").unwrap()], |
| 1052 | kind: nostr_sdk::Kind::GitRepoAnnouncement, | 1043 | }, |
| 1053 | relays: vec![RelayUrl::parse("wss://nos.lol").unwrap()], | 1044 | protocol: Some(ServerProtocol::Ssh), |
| 1054 | }, | 1045 | user: Some("bla".to_string()), |
| 1055 | protocol: Some(ServerProtocol::Ssh), | 1046 | nip05: None, |
| 1056 | user: Some("bla".to_string()), | 1047 | }), |
| 1057 | nip05: None, | ||
| 1058 | } | ||
| 1059 | ), | ||
| 1060 | "nostr://bla@ssh/npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/nos.lol/ngit", | 1048 | "nostr://bla@ssh/npub15qydau2hjma6ngxkl2cyar74wzyjshvl65za5k5rl69264ar2exs5cyejr/nos.lol/ngit", |
| 1061 | ); | 1049 | ); |
| 1062 | Ok(()) | 1050 | Ok(()) |
diff --git a/src/lib/git_events.rs b/src/lib/git_events.rs index d8564ae..af469d3 100644 --- a/src/lib/git_events.rs +++ b/src/lib/git_events.rs | |||
| @@ -1,10 +1,10 @@ | |||
| 1 | use std::{str::FromStr, sync::Arc}; | 1 | use std::{str::FromStr, sync::Arc}; |
| 2 | 2 | ||
| 3 | use anyhow::{bail, Context, Result}; | 3 | use anyhow::{Context, Result, bail}; |
| 4 | use nostr::nips::{nip01::Coordinate, nip10::Marker, nip19::Nip19}; | 4 | use nostr::nips::{nip01::Coordinate, nip10::Marker, nip19::Nip19}; |
| 5 | use nostr_sdk::{ | 5 | use nostr_sdk::{ |
| 6 | hashes::sha1::Hash as Sha1Hash, Event, EventBuilder, EventId, FromBech32, Kind, NostrSigner, | 6 | Event, EventBuilder, EventId, FromBech32, Kind, NostrSigner, PublicKey, RelayUrl, Tag, TagKind, |
| 7 | PublicKey, RelayUrl, Tag, TagKind, TagStandard, | 7 | TagStandard, hashes::sha1::Hash as Sha1Hash, |
| 8 | }; | 8 | }; |
| 9 | 9 | ||
| 10 | use crate::{ | 10 | use crate::{ |
| @@ -131,15 +131,14 @@ pub async fn generate_patch_event( | |||
| 131 | // code that makes it into the main branch, assuming | 131 | // code that makes it into the main branch, assuming |
| 132 | // the commit id is correct | 132 | // the commit id is correct |
| 133 | Tag::from_standardized(TagStandard::Reference(commit.to_string())), | 133 | Tag::from_standardized(TagStandard::Reference(commit.to_string())), |
| 134 | Tag::custom( | 134 | Tag::custom(TagKind::Custom(std::borrow::Cow::Borrowed("alt")), vec![ |
| 135 | TagKind::Custom(std::borrow::Cow::Borrowed("alt")), | 135 | format!( |
| 136 | vec![format!( | ||
| 137 | "git patch: {}", | 136 | "git patch: {}", |
| 138 | git_repo | 137 | git_repo |
| 139 | .get_commit_message_summary(commit) | 138 | .get_commit_message_summary(commit) |
| 140 | .unwrap_or_default() | 139 | .unwrap_or_default() |
| 141 | )], | 140 | ), |
| 142 | ), | 141 | ]), |
| 143 | ], | 142 | ], |
| 144 | if let Some(thread_event_id) = thread_event_id { | 143 | if let Some(thread_event_id) = thread_event_id { |
| 145 | vec![Tag::from_standardized(nostr_sdk::TagStandard::Event { | 144 | vec![Tag::from_standardized(nostr_sdk::TagStandard::Event { |
| @@ -203,10 +202,9 @@ pub async fn generate_patch_event( | |||
| 203 | .collect(), | 202 | .collect(), |
| 204 | vec![ | 203 | vec![ |
| 205 | // a fallback is now in place to extract this from the patch | 204 | // a fallback is now in place to extract this from the patch |
| 206 | Tag::custom( | 205 | Tag::custom(TagKind::Custom(std::borrow::Cow::Borrowed("commit")), vec![ |
| 207 | TagKind::Custom(std::borrow::Cow::Borrowed("commit")), | 206 | commit.to_string(), |
| 208 | vec![commit.to_string()], | 207 | ]), |
| 209 | ), | ||
| 210 | // this is required as patches cannot be relied upon to include the 'base | 208 | // this is required as patches cannot be relied upon to include the 'base |
| 211 | // commit' | 209 | // commit' |
| 212 | Tag::custom( | 210 | Tag::custom( |
diff --git a/src/lib/login/existing.rs b/src/lib/login/existing.rs index 4606c22..efe187e 100644 --- a/src/lib/login/existing.rs +++ b/src/lib/login/existing.rs | |||
| @@ -1,15 +1,15 @@ | |||
| 1 | use std::{str::FromStr, sync::Arc, time::Duration}; | 1 | use std::{str::FromStr, sync::Arc, time::Duration}; |
| 2 | 2 | ||
| 3 | use anyhow::{bail, Context, Result}; | 3 | use anyhow::{Context, Result, bail}; |
| 4 | use nostr::nips::nip46::NostrConnectURI; | 4 | use nostr::nips::nip46::NostrConnectURI; |
| 5 | use nostr_connect::client::NostrConnect; | 5 | use nostr_connect::client::NostrConnect; |
| 6 | use nostr_sdk::{NostrSigner, PublicKey}; | 6 | use nostr_sdk::{NostrSigner, PublicKey}; |
| 7 | 7 | ||
| 8 | use super::{ | 8 | use super::{ |
| 9 | SignerInfo, SignerInfoSource, | ||
| 9 | key_encryption::decrypt_key, | 10 | key_encryption::decrypt_key, |
| 10 | print_logged_in_as, | 11 | print_logged_in_as, |
| 11 | user::{get_user_details, UserRef}, | 12 | user::{UserRef, get_user_details}, |
| 12 | SignerInfo, SignerInfoSource, | ||
| 13 | }; | 13 | }; |
| 14 | #[cfg(not(test))] | 14 | #[cfg(not(test))] |
| 15 | use crate::client::Client; | 15 | use crate::client::Client; |
| @@ -18,7 +18,7 @@ use crate::client::MockConnect; | |||
| 18 | use crate::{ | 18 | use crate::{ |
| 19 | cli_interactor::{Interactor, InteractorPrompt, PromptPasswordParms}, | 19 | cli_interactor::{Interactor, InteractorPrompt, PromptPasswordParms}, |
| 20 | client::fetch_public_key, | 20 | client::fetch_public_key, |
| 21 | git::{get_git_config_item, Repo, RepoActions}, | 21 | git::{Repo, RepoActions, get_git_config_item}, |
| 22 | }; | 22 | }; |
| 23 | 23 | ||
| 24 | /// load signer from git config and UserProfile from cache or relays | 24 | /// load signer from git config and UserProfile from cache or relays |
diff --git a/src/lib/login/fresh.rs b/src/lib/login/fresh.rs index 7cdbde8..635c0b3 100644 --- a/src/lib/login/fresh.rs +++ b/src/lib/login/fresh.rs | |||
| @@ -1,6 +1,6 @@ | |||
| 1 | use std::{str::FromStr, sync::Arc, time::Duration}; | 1 | use std::{str::FromStr, sync::Arc, time::Duration}; |
| 2 | 2 | ||
| 3 | use anyhow::{bail, Context, Result}; | 3 | use anyhow::{Context, Result, bail}; |
| 4 | use console::Style; | 4 | use console::Style; |
| 5 | use dialoguer::theme::{ColorfulTheme, Theme}; | 5 | use dialoguer::theme::{ColorfulTheme, Theme}; |
| 6 | use nostr::nips::{nip05, nip46::NostrConnectURI}; | 6 | use nostr::nips::{nip05, nip46::NostrConnectURI}; |
| @@ -10,11 +10,11 @@ use qrcode::QrCode; | |||
| 10 | use tokio::{signal, sync::Mutex}; | 10 | use tokio::{signal, sync::Mutex}; |
| 11 | 11 | ||
| 12 | use super::{ | 12 | use super::{ |
| 13 | SignerInfo, SignerInfoSource, | ||
| 13 | existing::load_existing_login, | 14 | existing::load_existing_login, |
| 14 | key_encryption::decrypt_key, | 15 | key_encryption::decrypt_key, |
| 15 | print_logged_in_as, | 16 | print_logged_in_as, |
| 16 | user::{get_user_details, UserRef}, | 17 | user::{UserRef, get_user_details}, |
| 17 | SignerInfo, SignerInfoSource, | ||
| 18 | }; | 18 | }; |
| 19 | #[cfg(not(test))] | 19 | #[cfg(not(test))] |
| 20 | use crate::client::Client; | 20 | use crate::client::Client; |
| @@ -25,8 +25,8 @@ use crate::{ | |||
| 25 | Interactor, InteractorPrompt, Printer, PromptChoiceParms, PromptConfirmParms, | 25 | Interactor, InteractorPrompt, Printer, PromptChoiceParms, PromptConfirmParms, |
| 26 | PromptInputParms, PromptPasswordParms, | 26 | PromptInputParms, PromptPasswordParms, |
| 27 | }, | 27 | }, |
| 28 | client::{send_events, Connect}, | 28 | client::{Connect, send_events}, |
| 29 | git::{remove_git_config_item, save_git_config_item, Repo, RepoActions}, | 29 | git::{Repo, RepoActions, remove_git_config_item, save_git_config_item}, |
| 30 | }; | 30 | }; |
| 31 | 31 | ||
| 32 | pub async fn fresh_login_or_signup( | 32 | pub async fn fresh_login_or_signup( |
diff --git a/src/lib/login/mod.rs b/src/lib/login/mod.rs index 0be1e5d..a1c45d5 100644 --- a/src/lib/login/mod.rs +++ b/src/lib/login/mod.rs | |||
| @@ -79,15 +79,11 @@ fn print_logged_in_as( | |||
| 79 | "failed to find your relay list. consider using another nostr client to create one to enhance your nostr experience." | 79 | "failed to find your relay list. consider using another nostr client to create one to enhance your nostr experience." |
| 80 | ); | 80 | ); |
| 81 | } | 81 | } |
| 82 | eprintln!( | 82 | eprintln!("logged in as {}{}", user_ref.metadata.name, match source { |
| 83 | "logged in as {}{}", | 83 | SignerInfoSource::CommandLineArguments => " via cli arguments", |
| 84 | user_ref.metadata.name, | 84 | SignerInfoSource::GitLocal => " to local repository", |
| 85 | match source { | 85 | SignerInfoSource::GitGlobal => "", |
| 86 | SignerInfoSource::CommandLineArguments => " via cli arguments", | 86 | }); |
| 87 | SignerInfoSource::GitLocal => " to local repository", | ||
| 88 | SignerInfoSource::GitGlobal => "", | ||
| 89 | } | ||
| 90 | ); | ||
| 91 | Ok(()) | 87 | Ok(()) |
| 92 | } | 88 | } |
| 93 | 89 | ||
diff --git a/src/lib/login/user.rs b/src/lib/login/user.rs index de4a2d9..107e765 100644 --- a/src/lib/login/user.rs +++ b/src/lib/login/user.rs | |||
| @@ -1,6 +1,6 @@ | |||
| 1 | use std::{collections::HashSet, path::Path}; | 1 | use std::{collections::HashSet, path::Path}; |
| 2 | 2 | ||
| 3 | use anyhow::{bail, Context, Result}; | 3 | use anyhow::{Context, Result, bail}; |
| 4 | use nostr::PublicKey; | 4 | use nostr::PublicKey; |
| 5 | use nostr_sdk::{Alphabet, JsonUtil, Kind, SingleLetterTag, Timestamp, ToBech32}; | 5 | use nostr_sdk::{Alphabet, JsonUtil, Kind, SingleLetterTag, Timestamp, ToBech32}; |
| 6 | use serde::{self, Deserialize, Serialize}; | 6 | use serde::{self, Deserialize, Serialize}; |
| @@ -9,7 +9,7 @@ use serde::{self, Deserialize, Serialize}; | |||
| 9 | use crate::client::Client; | 9 | use crate::client::Client; |
| 10 | #[cfg(test)] | 10 | #[cfg(test)] |
| 11 | use crate::client::MockConnect; | 11 | use crate::client::MockConnect; |
| 12 | use crate::client::{get_event_from_global_cache, Connect}; | 12 | use crate::client::{Connect, get_event_from_global_cache}; |
| 13 | 13 | ||
| 14 | #[derive(Serialize, Deserialize, Clone, Debug, PartialEq, Eq)] | 14 | #[derive(Serialize, Deserialize, Clone, Debug, PartialEq, Eq)] |
| 15 | pub struct UserRef { | 15 | pub struct UserRef { |
diff --git a/src/lib/mod.rs b/src/lib/mod.rs index 6e6f6fe..2072a80 100644 --- a/src/lib/mod.rs +++ b/src/lib/mod.rs | |||
| @@ -6,7 +6,7 @@ pub mod login; | |||
| 6 | pub mod repo_ref; | 6 | pub mod repo_ref; |
| 7 | pub mod repo_state; | 7 | pub mod repo_state; |
| 8 | 8 | ||
| 9 | use anyhow::{anyhow, Result}; | 9 | use anyhow::{Result, anyhow}; |
| 10 | use directories::ProjectDirs; | 10 | use directories::ProjectDirs; |
| 11 | 11 | ||
| 12 | pub fn get_dirs() -> Result<ProjectDirs> { | 12 | pub fn get_dirs() -> Result<ProjectDirs> { |
diff --git a/src/lib/repo_ref.rs b/src/lib/repo_ref.rs index 5d6f4eb..a9d1186 100644 --- a/src/lib/repo_ref.rs +++ b/src/lib/repo_ref.rs | |||
| @@ -6,9 +6,9 @@ use std::{ | |||
| 6 | sync::Arc, | 6 | sync::Arc, |
| 7 | }; | 7 | }; |
| 8 | 8 | ||
| 9 | use anyhow::{bail, Context, Result}; | 9 | use anyhow::{Context, Result, bail}; |
| 10 | use console::Style; | 10 | use console::Style; |
| 11 | use nostr::{nips::nip01::Coordinate, FromBech32, PublicKey, Tag, TagStandard, ToBech32}; | 11 | use nostr::{FromBech32, PublicKey, Tag, TagStandard, ToBech32, nips::nip01::Coordinate}; |
| 12 | use nostr_sdk::{Kind, NostrSigner, RelayUrl, Timestamp}; | 12 | use nostr_sdk::{Kind, NostrSigner, RelayUrl, Timestamp}; |
| 13 | use serde::{Deserialize, Serialize}; | 13 | use serde::{Deserialize, Serialize}; |
| 14 | 14 | ||
| @@ -18,10 +18,10 @@ use crate::{ | |||
| 18 | cli_interactor::{ | 18 | cli_interactor::{ |
| 19 | Interactor, InteractorPrompt, PromptChoiceParms, PromptConfirmParms, PromptInputParms, | 19 | Interactor, InteractorPrompt, PromptChoiceParms, PromptConfirmParms, PromptInputParms, |
| 20 | }, | 20 | }, |
| 21 | client::{consolidate_fetch_reports, get_repo_ref_from_cache, sign_event, Connect}, | 21 | client::{Connect, consolidate_fetch_reports, get_repo_ref_from_cache, sign_event}, |
| 22 | git::{ | 22 | git::{ |
| 23 | nostr_url::{use_nip05_git_config_cache_to_find_nip05_from_public_key, NostrUrlDecoded}, | ||
| 24 | Repo, RepoActions, | 23 | Repo, RepoActions, |
| 24 | nostr_url::{NostrUrlDecoded, use_nip05_git_config_cache_to_find_nip05_from_public_key}, | ||
| 25 | }, | 25 | }, |
| 26 | login::user::get_user_details, | 26 | login::user::get_user_details, |
| 27 | }; | 27 | }; |
| @@ -237,20 +237,17 @@ impl RepoRef { | |||
| 237 | 237 | ||
| 238 | pub fn to_nostr_git_url(&self, git_repo: &Option<&Repo>) -> String { | 238 | pub fn to_nostr_git_url(&self, git_repo: &Option<&Repo>) -> String { |
| 239 | let c = self.coordinate_with_hint(); | 239 | let c = self.coordinate_with_hint(); |
| 240 | format!( | 240 | format!("{}", NostrUrlDecoded { |
| 241 | "{}", | 241 | original_string: String::new(), |
| 242 | NostrUrlDecoded { | 242 | nip05: use_nip05_git_config_cache_to_find_nip05_from_public_key( |
| 243 | original_string: String::new(), | 243 | &c.public_key, |
| 244 | nip05: use_nip05_git_config_cache_to_find_nip05_from_public_key( | 244 | git_repo, |
| 245 | &c.public_key, | 245 | ) |
| 246 | git_repo, | 246 | .unwrap_or_default(), |
| 247 | ) | 247 | coordinate: c, |
| 248 | .unwrap_or_default(), | 248 | protocol: None, |
| 249 | coordinate: c, | 249 | user: None, |
| 250 | protocol: None, | 250 | }) |
| 251 | user: None, | ||
| 252 | } | ||
| 253 | ) | ||
| 254 | } | 251 | } |
| 255 | } | 252 | } |
| 256 | 253 | ||
| @@ -521,14 +518,11 @@ pub fn save_repo_config_to_yaml( | |||
| 521 | .context("failed to convert public key into npub")?, | 518 | .context("failed to convert public key into npub")?, |
| 522 | ); | 519 | ); |
| 523 | } | 520 | } |
| 524 | serde_yaml::to_writer( | 521 | serde_yaml::to_writer(file, &RepoConfigYaml { |
| 525 | file, | 522 | identifier: Some(identifier), |
| 526 | &RepoConfigYaml { | 523 | maintainers: maintainers_npubs, |
| 527 | identifier: Some(identifier), | 524 | relays, |
| 528 | maintainers: maintainers_npubs, | 525 | }) |
| 529 | relays, | ||
| 530 | }, | ||
| 531 | ) | ||
| 532 | .context("failed to write maintainers to maintainers.yaml file serde_yaml") | 526 | .context("failed to write maintainers to maintainers.yaml file serde_yaml") |
| 533 | } | 527 | } |
| 534 | 528 | ||