diff options
Diffstat (limited to 'src/main/java/com/juick/ActivityPubManager.java')
-rw-r--r-- | src/main/java/com/juick/ActivityPubManager.java | 20 |
1 files changed, 4 insertions, 16 deletions
diff --git a/src/main/java/com/juick/ActivityPubManager.java b/src/main/java/com/juick/ActivityPubManager.java index f234969b..f4b87b05 100644 --- a/src/main/java/com/juick/ActivityPubManager.java +++ b/src/main/java/com/juick/ActivityPubManager.java @@ -431,8 +431,6 @@ public class ActivityPubManager implements ActivityListener, NotificationListene } } - private static final ReentrantLockMap verificationLock = new ReentrantLockMap(); - public User verifyActor(String method, String path, Map<String, String> headers) { String signatureString = headers.get("signature"); if (StringUtils.isNotEmpty(signatureString)) { @@ -445,20 +443,10 @@ public class ActivityPubManager implements ActivityListener, NotificationListene // local user key = keystoreManager.getPublicKey(); } else { - ReentrantLock lock = null; - try { - lock = verificationLock.getLock(keyId.toASCIIString()); - lock.lock(); - var context = activityPubService.get(keyId); - if (context.isPresent()) { - actor = (Actor) context.get(); - key = KeystoreManager.publicKeyOf(actor); - } - } finally { - if (lock != null) { - lock.unlock(); - verificationLock.retainLock(keyId.toASCIIString()); - } + var context = activityPubService.get(keyId); + if (context.isPresent()) { + actor = (Actor) context.get(); + key = KeystoreManager.publicKeyOf(actor); } } if (key != null) { |