mirrors/homebox
1
0
Fork 1
mirror of https://github.com/hay-kot/homebox.git synced 2025-08-02 15:50:27 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix deadlock on event bus

Browse source
This commit is contained in:
Hayden 2023-08-02 09:22:11 -05:00
parent f176ca1887
commit f36a400457
No known key found for this signature in database
GPG key ID: 17CF79474E257545
2 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

5
backend/internal/core/services/main_test.go
View file

@ -14,7 +14,8 @@ import (
) )
var ( var (
fk = faker.NewFaker() fk = faker.NewFaker()
tbus = eventbus.New()
tCtx = Context{} tCtx = Context{}
tClient *ent.Client tClient *ent.Client
@ -59,7 +60,7 @@ func TestMain(m *testing.M) {
} }
tClient = client tClient = client
tRepos = repo.New(tClient, eventbus.New(), os.TempDir()+"/homebox") tRepos = repo.New(tClient, tbus, os.TempDir()+"/homebox")
tSvc = New(tRepos) tSvc = New(tRepos)
defer client.Close() defer client.Close()

5
backend/internal/data/repo/main_test.go
View file

@ -14,6 +14,7 @@ import (
var ( var (
fk = faker.NewFaker() fk = faker.NewFaker()
tbus = eventbus.New()
tClient *ent.Client tClient *ent.Client
tRepos *AllRepos tRepos *AllRepos
@ -44,13 +45,15 @@ func TestMain(m *testing.M) {
log.Fatalf("failed opening connection to sqlite: %v", err) log.Fatalf("failed opening connection to sqlite: %v", err)
} }
go tbus.Run()
err = client.Schema.Create(context.Background()) err = client.Schema.Create(context.Background())
if err != nil { if err != nil {
log.Fatalf("failed creating schema resources: %v", err) log.Fatalf("failed creating schema resources: %v", err)
} }
tClient = client tClient = client
tRepos = New(tClient, eventbus.New(), os.TempDir()) tRepos = New(tClient, tbus, os.TempDir())
defer client.Close() defer client.Close()
bootstrap() bootstrap()