From f36a4004579461743595947f7f657f3eb65b89b4 Mon Sep 17 00:00:00 2001
From: Hayden <64056131+hay-kot@users.noreply.github.com>
Date: Wed, 2 Aug 2023 09:22:11 -0500
Subject: [PATCH] fix deadlock on event bus

---
 backend/internal/core/services/main_test.go | 5 +++--
 backend/internal/data/repo/main_test.go     | 5 ++++-
 2 files changed, 7 insertions(+), 3 deletions(-)

diff --git a/backend/internal/core/services/main_test.go b/backend/internal/core/services/main_test.go
index 872d3f3..b0d248d 100644
--- a/backend/internal/core/services/main_test.go
+++ b/backend/internal/core/services/main_test.go
@@ -14,7 +14,8 @@ import (
 )
 
 var (
-	fk = faker.NewFaker()
+	fk   = faker.NewFaker()
+	tbus = eventbus.New()
 
 	tCtx    = Context{}
 	tClient *ent.Client
@@ -59,7 +60,7 @@ func TestMain(m *testing.M) {
 	}
 
 	tClient = client
-	tRepos = repo.New(tClient, eventbus.New(), os.TempDir()+"/homebox")
+	tRepos = repo.New(tClient, tbus, os.TempDir()+"/homebox")
 	tSvc = New(tRepos)
 	defer client.Close()
 
diff --git a/backend/internal/data/repo/main_test.go b/backend/internal/data/repo/main_test.go
index ab79242..23a4198 100644
--- a/backend/internal/data/repo/main_test.go
+++ b/backend/internal/data/repo/main_test.go
@@ -14,6 +14,7 @@ import (
 
 var (
 	fk = faker.NewFaker()
+  tbus = eventbus.New()
 
 	tClient *ent.Client
 	tRepos  *AllRepos
@@ -44,13 +45,15 @@ func TestMain(m *testing.M) {
 		log.Fatalf("failed opening connection to sqlite: %v", err)
 	}
 
+  go tbus.Run()
+
 	err = client.Schema.Create(context.Background())
 	if err != nil {
 		log.Fatalf("failed creating schema resources: %v", err)
 	}
 
 	tClient = client
-	tRepos = New(tClient, eventbus.New(), os.TempDir())
+	tRepos = New(tClient, tbus, os.TempDir())
 	defer client.Close()
 
 	bootstrap()