From af4a7e7ab99db5f3bdd9e12f398d5547f337a835 Mon Sep 17 00:00:00 2001
From: Joachim Bauch <bauch@struktur.de>
Date: Wed, 10 Dec 2025 15:05:52 +0100
Subject: [PATCH] Move notifier code to async package.

---
 notifier.go => async/notifier.go                         | 2 +-
 notifier_test.go => async/notifier_test.go               | 2 +-
 single_notifier.go => async/single_notifier.go           | 2 +-
 single_notifier_test.go => async/single_notifier_test.go | 2 +-
 mcu_janus.go                                             | 5 +++--
 mcu_proxy.go                                             | 2 +-
 6 files changed, 8 insertions(+), 7 deletions(-)
 rename notifier.go => async/notifier.go (99%)
 rename notifier_test.go => async/notifier_test.go (99%)
 rename single_notifier.go => async/single_notifier.go (99%)
 rename single_notifier_test.go => async/single_notifier_test.go (99%)

diff --git a/notifier.go b/async/notifier.go
similarity index 99%
rename from notifier.go
rename to async/notifier.go
index 800711d..06305aa 100644
--- a/notifier.go
+++ b/async/notifier.go
@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"
diff --git a/notifier_test.go b/async/notifier_test.go
similarity index 99%
rename from notifier_test.go
rename to async/notifier_test.go
index aae7c58..9bd61eb 100644
--- a/notifier_test.go
+++ b/async/notifier_test.go
@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"
diff --git a/single_notifier.go b/async/single_notifier.go
similarity index 99%
rename from single_notifier.go
rename to async/single_notifier.go
index 2a41f7d..28c3a45 100644
--- a/single_notifier.go
+++ b/async/single_notifier.go
@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"
diff --git a/single_notifier_test.go b/async/single_notifier_test.go
similarity index 99%
rename from single_notifier_test.go
rename to async/single_notifier_test.go
index 5a90931..1f2c7dd 100644
--- a/single_notifier_test.go
+++ b/async/single_notifier_test.go
@@ -19,7 +19,7 @@
  * You should have received a copy of the GNU Affero General Public License
  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  */
-package signaling
+package async
 
 import (
 	"context"
diff --git a/mcu_janus.go b/mcu_janus.go
index ba440f0..9775ea4 100644
--- a/mcu_janus.go
+++ b/mcu_janus.go
@@ -35,6 +35,7 @@ import (
 	"github.com/notedit/janus-go"
 
 	"github.com/strukturag/nextcloud-spreed-signaling/api"
+	"github.com/strukturag/nextcloud-spreed-signaling/async"
 	"github.com/strukturag/nextcloud-spreed-signaling/internal"
 	"github.com/strukturag/nextcloud-spreed-signaling/log"
 )
@@ -256,8 +257,8 @@ type mcuJanus struct {
 
 	// +checklocks:mu
 	publishers         map[StreamId]*mcuJanusPublisher
-	publisherCreated   Notifier
-	publisherConnected Notifier
+	publisherCreated   async.Notifier
+	publisherConnected async.Notifier
 	// +checklocks:mu
 	remotePublishers map[StreamId]*mcuJanusRemotePublisher
 
diff --git a/mcu_proxy.go b/mcu_proxy.go
index b7569cc..fcf89fc 100644
--- a/mcu_proxy.go
+++ b/mcu_proxy.go
@@ -371,7 +371,7 @@ type mcuProxyConnection struct {
 	trackClose        atomic.Bool
 	temporary         atomic.Bool
 
-	connectedNotifier SingleNotifier
+	connectedNotifier async.SingleNotifier
 
 	msgId      atomic.Int64
 	helloMsgId string