homebox/backend/internal/data/repo/main_test.go

65 lines
1.2 KiB
Go
Raw Permalink Normal View History

2022-08-30 02:30:36 +00:00
package repo
import (
"context"
"log"
"os"
"testing"
"github.com/hay-kot/homebox/backend/internal/core/services/reporting/eventbus"
"github.com/hay-kot/homebox/backend/internal/data/ent"
"github.com/hay-kot/homebox/backend/pkgs/faker"
2022-08-30 02:30:36 +00:00
_ "github.com/mattn/go-sqlite3"
)
2022-08-31 03:21:18 +00:00
var (
fk = faker.NewFaker()
tbus = eventbus.New()
tClient *ent.Client
tRepos *AllRepos
tUser UserOut
tGroup Group
2022-08-31 03:21:18 +00:00
)
func bootstrap() {
var (
err error
ctx = context.Background()
)
2022-08-31 03:21:18 +00:00
tGroup, err = tRepos.Groups.GroupCreate(ctx, "test-group")
if err != nil {
log.Fatal(err)
2022-08-31 03:21:18 +00:00
}
tUser, err = tRepos.Users.Create(ctx, userFactory())
if err != nil {
log.Fatal(err)
}
2022-08-31 03:21:18 +00:00
}
2022-08-30 02:30:36 +00:00
func TestMain(m *testing.M) {
client, err := ent.Open("sqlite3", "file:ent?mode=memory&cache=shared&_fk=1")
if err != nil {
log.Fatalf("failed opening connection to sqlite: %v", err)
}
go func() {
_ = tbus.Run(context.Background())
}()
err = client.Schema.Create(context.Background())
if err != nil {
2022-08-30 02:30:36 +00:00
log.Fatalf("failed creating schema resources: %v", err)
}
tClient = client
tRepos = New(tClient, tbus, os.TempDir())
defer func() { _ = client.Close() }()
2022-08-30 02:30:36 +00:00
2022-08-31 03:21:18 +00:00
bootstrap()
2022-08-30 02:30:36 +00:00
os.Exit(m.Run())
}