From ebec95a52280980caa88b9c8cd92d69c1a7dc164 Mon Sep 17 00:00:00 2001
From: tobi <31960611+tsmethurst@users.noreply.github.com>
Date: Thu, 2 May 2024 14:43:00 +0200
Subject: [bugfix] Lock when checking/creating notifs to avoid race (#2890)

* [bugfix] Lock when checking/creating notifs to avoid race

* test notif spam
---
 internal/processing/admin/accountapprove.go | 2 +-
 internal/processing/admin/accountreject.go  | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

(limited to 'internal/processing/admin')

diff --git a/internal/processing/admin/accountapprove.go b/internal/processing/admin/accountapprove.go
index ebc91ee0c..c3f6409c3 100644
--- a/internal/processing/admin/accountapprove.go
+++ b/internal/processing/admin/accountapprove.go
@@ -49,7 +49,7 @@ func (p *Processor) AccountApprove(
 	// Get a lock on the account URI,
 	// to ensure it's not also being
 	// rejected at the same time!
-	unlock := p.state.AccountLocks.Lock(user.Account.URI)
+	unlock := p.state.ProcessingLocks.Lock(user.Account.URI)
 	defer unlock()
 
 	if !*user.Approved {
diff --git a/internal/processing/admin/accountreject.go b/internal/processing/admin/accountreject.go
index e7d54be41..8cb54cad6 100644
--- a/internal/processing/admin/accountreject.go
+++ b/internal/processing/admin/accountreject.go
@@ -52,7 +52,7 @@ func (p *Processor) AccountReject(
 	// Get a lock on the account URI,
 	// since we're going to be deleting
 	// it and its associated user.
-	unlock := p.state.AccountLocks.Lock(user.Account.URI)
+	unlock := p.state.ProcessingLocks.Lock(user.Account.URI)
 	defer unlock()
 
 	// Can't reject an account with a
-- 
cgit v1.2.3