diff --git a/extensions/warp-ipfs/src/lib.rs b/extensions/warp-ipfs/src/lib.rs
index 01d4cb605..38debb56b 100644
--- a/extensions/warp-ipfs/src/lib.rs
+++ b/extensions/warp-ipfs/src/lib.rs
@@ -69,6 +69,7 @@ use warp::multipass::{
 
 use crate::config::Bootstrap;
 use crate::store::discovery::Discovery;
+use crate::store::phonebook::PhoneBook;
 use crate::store::{ecdh_decrypt, ecdh_encrypt};
 
 #[derive(Clone)]
@@ -454,13 +455,15 @@ impl WarpIpfs {
             relays.clone(),
         );
 
+        let phonebook = PhoneBook::new(discovery.clone(), pb_tx);
+
         info!("Initializing identity profile");
         let identity_store = IdentityStore::new(
             ipfs.clone(),
             config.path.clone(),
             tesseract.clone(),
             self.multipass_tx.clone(),
-            pb_tx,
+            phonebook,
             &config,
             discovery.clone(),
         )
diff --git a/extensions/warp-ipfs/src/store/identity.rs b/extensions/warp-ipfs/src/store/identity.rs
index 0c1d887ae..afe697ea8 100644
--- a/extensions/warp-ipfs/src/store/identity.rs
+++ b/extensions/warp-ipfs/src/store/identity.rs
@@ -2,7 +2,6 @@
 //onto the lock.
 #![allow(clippy::clone_on_copy)]
 use crate::{
-    behaviour::phonebook::PhoneBookCommand,
     config::{self, Discovery as DiscoveryConfig, UpdateEvents},
     store::{did_to_libp2p_pub, discovery::Discovery, DidExt, PeerIdExt, PeerTopic},
 };
@@ -234,7 +233,7 @@ impl IdentityStore {
         path: Option<PathBuf>,
         tesseract: Tesseract,
         tx: broadcast::Sender<MultiPassEventKind>,
-        pb_tx: futures::channel::mpsc::Sender<PhoneBookCommand>,
+        phonebook: PhoneBook,
         config: &config::Config,
         discovery: Discovery,
     ) -> Result<Self, Error> {
@@ -262,8 +261,6 @@ impl IdentityStore {
             discovery.clone(),
         );
 
-        let phonebook = PhoneBook::new(discovery.clone(), pb_tx);
-
         let signal = Default::default();
 
         let store = Self {
@@ -381,7 +378,6 @@ impl IdentityStore {
 
                             log::debug!("Event: {event:?}");
 
-
                             if let Err(e) = store.process_message(in_did, event).await {
                                 error!("Error: {e}");
                             }