Fix Private Messaging between traders

bisq-network · Nov 15, 2023 · 37cda03 · 37cda03
1 parent c009a13
commit 37cda03
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 4 deletions.
diff --git a/identity/src/main/java/bisq/identity/IdentityService.java b/identity/src/main/java/bisq/identity/IdentityService.java
@@ -122,6 +122,28 @@ public Identity getOrCreateDefaultIdentity() {
                 });
     }
 
+    /**
+     * Creates new identity based on given parameters.
+     */
+    public CompletableFuture<Identity> createNewActiveIdentity(String tag,
+                                                               String keyId,
+                                                               KeyPair keyPair) {
+        keyPairService.persistKeyPair(keyId, keyPair);
+        PubKey pubKey = new PubKey(keyPair.getPublic(), keyId);
+
+        TorIdentity torIdentity = createTorIdentity(false);
+        NetworkId networkId = createNetworkId(false, pubKey, torIdentity);
+        Identity identity = new Identity(tag, networkId, torIdentity, keyPair);
+
+        synchronized (lock) {
+            getActiveIdentityByTag().put(tag, identity);
+        }
+        persist();
+
+        return networkService.getNetworkIdOfInitializedNode(networkId, torIdentity)
+                .thenApply(nodes -> identity);
+    }
+
     public Identity createAndInitializeNewActiveIdentity(String tag) {
         Identity identity = createAndInitializeNewIdentity(tag);
 

diff --git a/user/src/main/java/bisq/user/identity/UserIdentityService.java b/user/src/main/java/bisq/user/identity/UserIdentityService.java
@@ -181,10 +181,12 @@ public CompletableFuture<UserIdentity> createAndPublishNewUserProfile(String nic
                                                                           String terms,
                                                                           String statement) {
         String tag = getTag(nickName, proofOfWork);
-        Identity identity = identityService.getOrCreateIdentity(tag, keyId, keyPair);
-        UserIdentity userIdentity = createUserIdentity(nickName, proofOfWork, terms, statement, identity);
-        return publishPublicUserProfile(userIdentity.getUserProfile(), userIdentity.getIdentity().getNodeIdAndKeyPair().getKeyPair())
-                .thenApply(broadcastResult -> userIdentity);
+        return identityService.createNewActiveIdentity(tag, keyId, keyPair)
+                .thenApply(identity -> createUserIdentity(nickName, proofOfWork, terms, statement, identity))
+                .thenApply(userIdentity -> {
+                    publishPublicUserProfile(userIdentity.getUserProfile(), userIdentity.getIdentity().getNodeIdAndKeyPair().getKeyPair());
+                    return userIdentity;
+                });
     }
 
     public void selectChatUserIdentity(UserIdentity userIdentity) {