4 files changed, 22 insertions, 9 deletions

diff --git a/src/client.rs b/src/client.rs
index b6e93d6..7947a02 100644
--- a/src/client.rs
+++ b/src/client.rs
@@ -78,6 +78,7 @@ pub trait Connect {
         &self,
         git_repo_path: &Path,
         repo_coordinates: &HashSet<Coordinate>,
+        user_profiles: &HashSet<PublicKey>,
     ) -> Result<(Vec<Result<FetchReport>>, MultiProgress)>;
     async fn fetch_all_from_relay(
         &self,
@@ -288,6 +289,7 @@ impl Connect for Client {
         &self,
         git_repo_path: &Path,
         repo_coordinates: &HashSet<Coordinate>,
+        user_profiles: &HashSet<PublicKey>,
     ) -> Result<(Vec<Result<FetchReport>>, MultiProgress)> {
         let fallback_relays = &self
             .fallback_relays
@@ -295,8 +297,13 @@ impl Connect for Client {
             .filter_map(|r| Url::parse(r).ok())
             .collect::<HashSet<Url>>();
 
-        let mut request =
-            create_relays_request(git_repo_path, repo_coordinates, fallback_relays.clone()).await?;
+        let mut request = create_relays_request(
+            git_repo_path,
+            repo_coordinates,
+            user_profiles,
+            fallback_relays.clone(),
+        )
+        .await?;
 
         let progress_reporter = MultiProgress::new();
 
@@ -666,7 +673,7 @@ async fn get_global_cache_database(git_repo_path: &Path) -> Result<SQLiteDatabas
     .context("cannot open ngit global nostr cache database")
 }
 
-pub async fn get_event_from_cache(
+pub async fn get_events_from_cache(
     git_repo_path: &Path,
     filters: Vec<nostr::Filter>,
 ) -> Result<Vec<nostr::Event>> {
@@ -725,7 +732,7 @@ pub async fn get_repo_ref_from_cache(
 
         let events = [
             get_event_from_global_cache(git_repo_path, vec![filter.clone()]).await?,
-            get_event_from_cache(git_repo_path, vec![filter]).await?,
+            get_events_from_cache(git_repo_path, vec![filter]).await?,
         ]
         .concat();
         for e in events {
@@ -778,6 +785,7 @@ pub async fn get_repo_ref_from_cache(
 async fn create_relays_request(
     git_repo_path: &Path,
     repo_coordinates: &HashSet<Coordinate>,
+    user_profiles: &HashSet<PublicKey>,
     fallback_relays: HashSet<Url>,
 ) -> Result<FetchRequest> {
     let repo_ref = get_repo_ref_from_cache(git_repo_path, repo_coordinates).await;
@@ -799,7 +807,7 @@ async fn create_relays_request(
             }
         }
 
-        for event in &get_event_from_cache(
+        for event in &get_events_from_cache(
             git_repo_path,
             vec![
                 nostr::Filter::default()
@@ -843,6 +851,7 @@ async fn create_relays_request(
     if let Some(current_user) = current_user {
         missing_contributor_profiles.insert(current_user);
     }
+    missing_contributor_profiles.extend(user_profiles);
 
     let existing_events: HashSet<EventId> = {
         let mut existing_events: HashSet<EventId> = HashSet::new();
diff --git a/src/login.rs b/src/login.rs
index 0a20a90..6c3acfa 100644
--- a/src/login.rs
+++ b/src/login.rs
@@ -628,7 +628,11 @@ async fn get_user_details(
             let term = console::Term::stderr();
             term.write_line("searching for profile...")?;
             let (_, progress_reporter) = client
-                .fetch_all(git_repo.get_path()?, &HashSet::new())
+                .fetch_all(
+                    git_repo.get_path()?,
+                    &HashSet::new(),
+                    &HashSet::from_iter(vec![*public_key]),
+                )
                 .await?;
             events = get_event_from_global_cache(git_repo.get_path()?, filters).await?;
             if !events.is_empty() {
diff --git a/src/repo_ref.rs b/src/repo_ref.rs
index 4952b16..0e91cc4 100644
--- a/src/repo_ref.rs
+++ b/src/repo_ref.rs
@@ -19,7 +19,7 @@ use crate::client::Client;
 use crate::client::MockConnect;
 use crate::{
     cli_interactor::{Interactor, InteractorPrompt, PromptInputParms},
-    client::{get_event_from_cache, get_event_from_global_cache, sign_event, Connect},
+    client::{get_event_from_global_cache, get_events_from_cache, sign_event, Connect},
     git::{Repo, RepoActions},
 };
 
@@ -261,7 +261,7 @@ pub async fn get_repo_coordinates(
                     .reference(git_repo.get_root_commit()?.to_string())
                     .authors(maintainers.clone());
                 let mut events =
-                    get_event_from_cache(git_repo.get_path()?, vec![filter.clone()]).await?;
+                    get_events_from_cache(git_repo.get_path()?, vec![filter.clone()]).await?;
                 if events.is_empty() {
                     events =
                         get_event_from_global_cache(git_repo.get_path()?, vec![filter.clone()])
diff --git a/src/sub_commands/fetch.rs b/src/sub_commands/fetch.rs
index 5a6850c..28eb960 100644
--- a/src/sub_commands/fetch.rs
+++ b/src/sub_commands/fetch.rs
@@ -40,7 +40,7 @@ pub async fn launch(args: &Cli, command_args: &SubCommandArgs) -> Result<()> {
     };
     println!("fetching updates...");
     let (relay_reports, _) = client
-        .fetch_all(git_repo.get_path()?, &repo_coordinates)
+        .fetch_all(git_repo.get_path()?, &repo_coordinates, &HashSet::new())
         .await?;
     let report = consolidate_fetch_reports(relay_reports);
     if report.to_string().is_empty() {