diff options
author | 2024-01-31 16:50:01 +0300 | |
---|---|---|
committer | 2024-02-01 19:18:13 +0300 | |
commit | 5ef424120ed694b1f69daeafaa1454455d13dee2 (patch) | |
tree | 72c0e5cedcdb5420f2760856c6e762cedf31c6de /src/main/java/com/juick/ActivityPubManager.java | |
parent | 3cf580867600494615a7bdc9ab43ef0735d5aedb (diff) |
CI: enable SQLite
* SQLite JDBC driver does not support generated keys feature. So we implement `returningId` helper
* only one connection should be used from connection pooler
* changes made to prevent connection locking
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) { |